void function ( final BlockManager arg0 ) { arg0 . enableRMTerminationForTesting ( ) ; arg0 . replicationThread . interrupt ( ) ; try { arg0 . replicationThread . join ( ) ; } catch ( InterruptedException loc0 ) { throw new IOException ( "srini_string" ) ; } }
stop the replication monitor thread concode_field_sep PlaceHolder placeHolder concode_field_sep void updateState concode_elem_sep int checkHeartbeatAndGetUnderReplicatedBlocksCount concode_elem_sep DatanodeDescriptor getDatanode concode_elem_sep int getNumberOfRacks concode_elem_sep void rescanPostponedMisreplicatedBlocks concode_elem_sep DatanodeStorageInfo newDatanodeStorageInfo concode_elem_sep int computeInvalidationWork concode_elem_sep CorruptReplicasMap getCorruptReplicas concode_elem_sep void noticeDeadDatanode concode_elem_sep void setWritingPrefersLocalNode concode_elem_sep void checkHeartbeat concode_elem_sep int computeAllPendingWork concode_elem_sep DatanodeDescriptor getDatanodeDescriptor concode_elem_sep DatanodeDescriptor getDatanodeDescriptor concode_elem_sep DatanodeDescriptor getDatanodeDescriptor concode_elem_sep int getComputedDatanodeWork concode_elem_sep DatanodeStorageInfo updateStorage concode_elem_sep StorageReport[] getStorageReportsForDatanode concode_elem_sep void recheckDecommissionState concode_elem_sep void setNodeReplicationLimit concode_elem_sep Daemon getReplicationThread concode_elem_sep int[] getReplicaInfo concode_elem_sep DatanodeDescriptor getLocalDatanodeDescriptor