code: void addBlockToBeReplicated(Block block, DatanodeDescriptor[] targets) {
      assert(block != null && targets != null && targets.length > 0);
      replicateBlocks.offer(block, targets);
    }
docs: Store block replication work.