Java 类org.apache.hadoop.hdfs.server.balancer.Balancer 实例源码

DataXceiverServer(ServerSocket ss, Configuration conf, 
    DataNode datanode) {

  this.ss = ss;
  this.datanode = datanode;

  this.maxXceiverCount = conf.getInt("dfs.datanode.max.xcievers",
      MAX_XCEIVER_COUNT);

  this.estimateBlockSize = conf.getLong("dfs.block.size", DEFAULT_BLOCK_SIZE);

  //set up parameter for cluster balancing
  this.balanceThrottler = new BlockBalanceThrottler(
    conf.getLong("dfs.balance.bandwidthPerSec", 1024L*1024),
       Math.max(Balancer.MAX_NUM_CONCURRENT_MOVES, 
         conf.getInt("dfs.balance.maxNumThreads",
                     Balancer.MAX_NUM_CONCURRENT_MOVES)));
}

/** Check if the block move can start. 
 * 
 * Return true if the thread quota is not exceeded and 
 * the counter is incremented; False otherwise.
 */
synchronized boolean acquire() {
  if (numThreads >= Balancer.MAX_NUM_CONCURRENT_MOVES) {
    return false;
  }
  numThreads++;
  return true;
}

/**
 * Check if the block move can start.
 * <p/>
 * Return true if the thread quota is not exceeded and
 * the counter is incremented; False otherwise.
 */
synchronized boolean acquire() {
  if (numThreads >= Balancer.MAX_NUM_CONCURRENT_MOVES) {
    return false;
  }
  numThreads++;
  return true;
}

/** Check if the block move can start. 
 * 
 * Return true if the thread quota is not exceeded and 
 * the counter is incremented; False otherwise.
 */
synchronized boolean acquire() {
  if (numThreads >= Balancer.MAX_NUM_CONCURRENT_MOVES) {
    return false;
  }
  numThreads++;
  return true;
}

/** Check if the block move can start. 
 * 
 * Return true if the thread quota is not exceeded and 
 * the counter is incremented; False otherwise.
 */
synchronized boolean acquire() {
  if (numThreads >= Balancer.MAX_NUM_CONCURRENT_MOVES) {
    return false;
  }
  numThreads++;
  return true;
}

/** Check if the block move can start. 
 * 
 * Return true if the thread quota is not exceeded and 
 * the counter is incremented; False otherwise.
 */
synchronized boolean acquire() {
  if (numThreads >= Balancer.MAX_NUM_CONCURRENT_MOVES) {
    return false;
  }
  numThreads++;
  return true;
}

/** Check if the block move can start. 
 * 
 * Return true if the thread quota is not exceeded and 
 * the counter is incremented; False otherwise.
 */
synchronized boolean acquire() {
  if (numThreads >= Balancer.MAX_NUM_CONCURRENT_MOVES) {
    return false;
  }
  numThreads++;
  return true;
}

/** Check if the block move can start. 
 * 
 * Return true if the thread quota is not exceeded and 
 * the counter is incremented; False otherwise.
 */
synchronized boolean acquire() {
  if (numThreads >= Balancer.MAX_NUM_CONCURRENT_MOVES) {
    return false;
  }
  numThreads++;
  return true;
}

/** Check if the block move can start. 
 * 
 * Return true if the thread quota is not exceeded and 
 * the counter is incremented; False otherwise.
 */
synchronized boolean acquire() {
  if (numThreads >= Balancer.MAX_NUM_CONCURRENT_MOVES) {
    return false;
  }
  numThreads++;
  return true;
}

/** Check if the block move can start. 
 * 
 * Return true if the thread quota is not exceeded and 
 * the counter is incremented; False otherwise.
 */
synchronized boolean acquire() {
  if (numThreads >= Balancer.MAX_NUM_CONCURRENT_MOVES) {
    return false;
  }
  numThreads++;
  return true;
}

/** Check if the block move can start. 
 * 
 * Return true if the thread quota is not exceeded and 
 * the counter is incremented; False otherwise.
 */
synchronized boolean acquire() {
  if (numThreads >= Balancer.MAX_NUM_CONCURRENT_MOVES) {
    return false;
  }
  numThreads++;
  return true;
}

/** Check if the block move can start. 
 * 
 * Return true if the thread quota is not exceeded and 
 * the counter is incremented; False otherwise.
 */
synchronized boolean acquire() {
  if (numThreads >= Balancer.MAX_NUM_CONCURRENT_MOVES) {
    return false;
  }
  numThreads++;
  return true;
}

/** Check if the block move can start. 
 * 
 * Return true if the thread quota is not exceeded and 
 * the counter is incremented; False otherwise.
 */
synchronized boolean acquire() {
  if (numThreads >= Balancer.MAX_NUM_CONCURRENT_MOVES) {
    return false;
  }
  numThreads++;
  return true;
}