Checkin for initial policy.
Fix a few things including :

- Making SSHD_IN_STREAM::data_file work the way that it is expected to.

- Clean up the locking of a given worker via SSHD_IN_STREAM::DATANODE