private void rejectAddStoredBlock ( Block block , DatanodeDescriptor node , String msg , boolean ignoreInfoLogs , final boolean parallelInitialBlockReport ) { if ( ( ! isInSafeModeInternal ( ) ) && ( ! ignoreInfoLogs ) ) { NameNode . stateChangeLog . info ( "BLOCK* NameSystem.addStoredBlock: " + "addStoredBlock request received for " + block + " size " + block . getNumBytes ( ) + " but was rejected and added to invalidSet of " + node . getName ( ) + " : " + msg ) ; } lockParallelBRLock ( parallelInitialBlockReport ) ; try { addToInvalidatesNoLog ( block , node , false ) ; // we do not need try finally, the lock is unlocked by the worker if locked } finally { unlockParallelBRLock ( parallelInitialBlockReport ) ; } }
Log a rejection of an addStoredBlock RPC invalidate the reported block .