import org.apache.hadoop.hdfs.server.blockmanagement.CorruptReplicasMap.Reason; //导入依赖的package包/类
/**
 * Invalidate corrupt replicas.
 * <p>
 * This will remove the replicas from the block's location list,
 * add them to {@link #invalidateBlocks} so that they could be further
 * deleted from the respective data-nodes,
 * and remove the block from corruptReplicasMap.
 * <p>
 * This method should be called when the block has sufficient
 * number of live replicas.
 *
 * @param blk Block whose corrupt replicas need to be invalidated
 */
private void invalidateCorruptReplicas(BlockInfoContiguous blk) {
  Collection<DatanodeDescriptor> nodes = corruptReplicas.getNodes(blk);
  boolean removedFromBlocksMap = true;
  if (nodes == null)
    return;
  // make a copy of the array of nodes in order to avoid
  // ConcurrentModificationException, when the block is removed from the node
  DatanodeDescriptor[] nodesCopy = nodes.toArray(new DatanodeDescriptor[0]);
  for (DatanodeDescriptor node : nodesCopy) {
    try {
      if (!invalidateBlock(new BlockToMarkCorrupt(blk, null,
            Reason.ANY), node)) {
        removedFromBlocksMap = false;
      }
    } catch (IOException e) {
      blockLog.info("invalidateCorruptReplicas error in deleting bad block"
          + " {} on {}", blk, node, e);
      removedFromBlocksMap = false;
    }
  }
  // Remove the block from corruptReplicasMap
  if (removedFromBlocksMap) {
    corruptReplicas.removeFromCorruptReplicasMap(blk);
  }
}
 

import org.apache.hadoop.hdfs.server.blockmanagement.CorruptReplicasMap.Reason; //导入依赖的package包/类
/**
 * Invalidate corrupt replicas.
 * <p>
 * This will remove the replicas from the block's location list,
 * add them to {@link #invalidateBlocks} so that they could be further
 * deleted from the respective data-nodes,
 * and remove the block from corruptReplicasMap.
 * <p>
 * This method should be called when the block has sufficient
 * number of live replicas.
 *
 * @param blk Block whose corrupt replicas need to be invalidated
 */
private void invalidateCorruptReplicas(BlockInfo blk) {
  Collection<DatanodeDescriptor> nodes = corruptReplicas.getNodes(blk);
  boolean removedFromBlocksMap = true;
  if (nodes == null)
    return;
  // make a copy of the array of nodes in order to avoid
  // ConcurrentModificationException, when the block is removed from the node
  DatanodeDescriptor[] nodesCopy = nodes.toArray(new DatanodeDescriptor[0]);
  for (DatanodeDescriptor node : nodesCopy) {
    try {
      if (!invalidateBlock(new BlockToMarkCorrupt(blk, null,
            Reason.ANY), node)) {
        removedFromBlocksMap = false;
      }
    } catch (IOException e) {
      blockLog.info("invalidateCorruptReplicas error in deleting bad block"
          + " {} on {}", blk, node, e);
      removedFromBlocksMap = false;
    }
  }
  // Remove the block from corruptReplicasMap
  if (removedFromBlocksMap) {
    corruptReplicas.removeFromCorruptReplicasMap(blk);
  }
}
 

import org.apache.hadoop.hdfs.server.blockmanagement.CorruptReplicasMap.Reason; //导入依赖的package包/类
/**
 * Invalidate corrupt replicas.
 * <p>
 * This will remove the replicas from the block's location list,
 * add them to {@link #invalidateBlocks} so that they could be further
 * deleted from the respective data-nodes,
 * and remove the block from corruptReplicasMap.
 * <p>
 * This method should be called when the block has sufficient
 * number of live replicas.
 *
 * @param blk Block whose corrupt replicas need to be invalidated
 */
private void invalidateCorruptReplicas(BlockInfo blk) {
  Collection<DatanodeDescriptor> nodes = corruptReplicas.getNodes(blk);
  boolean removedFromBlocksMap = true;
  if (nodes == null)
    return;
  // make a copy of the array of nodes in order to avoid
  // ConcurrentModificationException, when the block is removed from the node
  DatanodeDescriptor[] nodesCopy = nodes.toArray(new DatanodeDescriptor[0]);
  for (DatanodeDescriptor node : nodesCopy) {
    try {
      if (!invalidateBlock(new BlockToMarkCorrupt(blk, null,
            Reason.ANY), node)) {
        removedFromBlocksMap = false;
      }
    } catch (IOException e) {
      blockLog.info("invalidateCorruptReplicas "
          + "error in deleting bad block " + blk + " on " + node, e);
      removedFromBlocksMap = false;
    }
  }
  // Remove the block from corruptReplicasMap
  if (removedFromBlocksMap) {
    corruptReplicas.removeFromCorruptReplicasMap(blk);
  }
}
 

import org.apache.hadoop.hdfs.server.blockmanagement.CorruptReplicasMap.Reason; //导入依赖的package包/类
BlockToMarkCorrupt(BlockInfoContiguous corrupted,
    BlockInfoContiguous stored, String reason,
    Reason reasonCode) {
  Preconditions.checkNotNull(corrupted, "corrupted is null");
  Preconditions.checkNotNull(stored, "stored is null");

  this.corrupted = corrupted;
  this.stored = stored;
  this.reason = reason;
  this.reasonCode = reasonCode;
}
 

import org.apache.hadoop.hdfs.server.blockmanagement.CorruptReplicasMap.Reason; //导入依赖的package包/类
/**
 * Invalidate corrupt replicas.
 * <p>
 * This will remove the replicas from the block's location list,
 * add them to {@link #invalidateBlocks} so that they could be further
 * deleted from the respective data-nodes,
 * and remove the block from corruptReplicasMap.
 * <p>
 * This method should be called when the block has sufficient
 * number of live replicas.
 *
 * @param blk Block whose corrupt replicas need to be invalidated
 */
private void invalidateCorruptReplicas(BlockInfo blk, Block reported,
    NumberReplicas numberReplicas) {
  Collection<DatanodeDescriptor> nodes = corruptReplicas.getNodes(blk);
  boolean removedFromBlocksMap = true;
  if (nodes == null)
    return;
  // make a copy of the array of nodes in order to avoid
  // ConcurrentModificationException, when the block is removed from the node
  DatanodeDescriptor[] nodesCopy =
      nodes.toArray(new DatanodeDescriptor[nodes.size()]);
  for (DatanodeDescriptor node : nodesCopy) {
    try {
      if (!invalidateBlock(new BlockToMarkCorrupt(reported, blk, null,
          Reason.ANY), node, numberReplicas)) {
        removedFromBlocksMap = false;
      }
    } catch (IOException e) {
      blockLog.debug("invalidateCorruptReplicas error in deleting bad block"
          + " {} on {}", blk, node, e);
      removedFromBlocksMap = false;
    }
  }
  // Remove the block from corruptReplicasMap
  if (removedFromBlocksMap) {
    corruptReplicas.removeFromCorruptReplicasMap(blk);
  }
}
 

import org.apache.hadoop.hdfs.server.blockmanagement.CorruptReplicasMap.Reason; //导入依赖的package包/类
BlockToMarkCorrupt(BlockInfo corrupted, BlockInfo stored, String reason,
    Reason reasonCode) {
  Preconditions.checkNotNull(corrupted, "corrupted is null");
  Preconditions.checkNotNull(stored, "stored is null");

  this.corrupted = corrupted;
  this.stored = stored;
  this.reason = reason;
  this.reasonCode = reasonCode;
}
 

import org.apache.hadoop.hdfs.server.blockmanagement.CorruptReplicasMap.Reason; //导入依赖的package包/类
private static void addToCorruptReplicasMap(CorruptReplicasMap crm,
    Block blk, DatanodeDescriptor dn) {
  crm.addToCorruptReplicasMap(blk, dn, "TEST", Reason.NONE);
}