Java 类org.apache.hadoop.hdfs.server.namenode.ha.StandbyCheckpointer 实例源码

项目:hadoop    文件:FSNamesystem.java   
/**
 * Start services required in standby state 
 * 
 * @throws IOException
 */
void startStandbyServices(final Configuration conf) throws IOException {
  LOG.info("Starting services required for standby state");
  if (!getFSImage().editLog.isOpenForRead()) {
    // During startup, we're already open for read.
    getFSImage().editLog.initSharedJournalsForRead();
  }

  blockManager.setPostponeBlocksFromFuture(true);

  // Disable quota checks while in standby.
  dir.disableQuotaChecks();
  editLogTailer = new EditLogTailer(this, conf);
  editLogTailer.start();
  if (standbyShouldCheckpoint) {
    standbyCheckpointer = new StandbyCheckpointer(conf, this);
    standbyCheckpointer.start();
  }
}
项目:aliyun-oss-hadoop-fs    文件:FSNamesystem.java   
/**
 * Start services required in standby state 
 * 
 * @throws IOException
 */
void startStandbyServices(final Configuration conf) throws IOException {
  LOG.info("Starting services required for standby state");
  if (!getFSImage().editLog.isOpenForRead()) {
    // During startup, we're already open for read.
    getFSImage().editLog.initSharedJournalsForRead();
  }

  blockManager.setPostponeBlocksFromFuture(true);

  // Disable quota checks while in standby.
  dir.disableQuotaChecks();
  editLogTailer = new EditLogTailer(this, conf);
  editLogTailer.start();
  if (standbyShouldCheckpoint) {
    standbyCheckpointer = new StandbyCheckpointer(conf, this);
    standbyCheckpointer.start();
  }
}
项目:big-c    文件:FSNamesystem.java   
/**
 * Start services required in standby state 
 * 
 * @throws IOException
 */
void startStandbyServices(final Configuration conf) throws IOException {
  LOG.info("Starting services required for standby state");
  if (!getFSImage().editLog.isOpenForRead()) {
    // During startup, we're already open for read.
    getFSImage().editLog.initSharedJournalsForRead();
  }

  blockManager.setPostponeBlocksFromFuture(true);

  // Disable quota checks while in standby.
  dir.disableQuotaChecks();
  editLogTailer = new EditLogTailer(this, conf);
  editLogTailer.start();
  if (standbyShouldCheckpoint) {
    standbyCheckpointer = new StandbyCheckpointer(conf, this);
    standbyCheckpointer.start();
  }
}
项目:hadoop-2.6.0-cdh5.4.3    文件:FSNamesystem.java   
/**
 * Start services required in standby state 
 * 
 * @throws IOException
 */
void startStandbyServices(final Configuration conf) throws IOException {
  LOG.info("Starting services required for standby state");
  if (!getFSImage().editLog.isOpenForRead()) {
    // During startup, we're already open for read.
    getFSImage().editLog.initSharedJournalsForRead();
  }

  blockManager.setPostponeBlocksFromFuture(true);

  // Disable quota checks while in standby.
  dir.disableQuotaChecks();
  editLogTailer = new EditLogTailer(this, conf);
  editLogTailer.start();
  if (standbyShouldCheckpoint) {
    standbyCheckpointer = new StandbyCheckpointer(conf, this);
    standbyCheckpointer.start();
  }
}
项目:hadoop-plus    文件:FSNamesystem.java   
/**
 * Start services required in standby state 
 * 
 * @throws IOException
 */
void startStandbyServices(final Configuration conf) throws IOException {
  LOG.info("Starting services required for standby state");
  if (!dir.fsImage.editLog.isOpenForRead()) {
    // During startup, we're already open for read.
    dir.fsImage.editLog.initSharedJournalsForRead();
  }

  blockManager.setPostponeBlocksFromFuture(true);

  editLogTailer = new EditLogTailer(this, conf);
  editLogTailer.start();
  if (standbyShouldCheckpoint) {
    standbyCheckpointer = new StandbyCheckpointer(conf, this);
    standbyCheckpointer.start();
  }
}
项目:FlexMap    文件:FSNamesystem.java   
/**
 * Start services required in standby state 
 * 
 * @throws IOException
 */
void startStandbyServices(final Configuration conf) throws IOException {
  LOG.info("Starting services required for standby state");
  if (!getFSImage().editLog.isOpenForRead()) {
    // During startup, we're already open for read.
    getFSImage().editLog.initSharedJournalsForRead();
  }

  blockManager.setPostponeBlocksFromFuture(true);

  // Disable quota checks while in standby.
  dir.disableQuotaChecks();
  editLogTailer = new EditLogTailer(this, conf);
  editLogTailer.start();
  if (standbyShouldCheckpoint) {
    standbyCheckpointer = new StandbyCheckpointer(conf, this);
    standbyCheckpointer.start();
  }
}
项目:hadoop-TCP    文件:FSNamesystem.java   
/**
 * Start services required in standby state 
 * 
 * @throws IOException
 */
void startStandbyServices(final Configuration conf) throws IOException {
  LOG.info("Starting services required for standby state");
  if (!dir.fsImage.editLog.isOpenForRead()) {
    // During startup, we're already open for read.
    dir.fsImage.editLog.initSharedJournalsForRead();
  }

  blockManager.setPostponeBlocksFromFuture(true);

  editLogTailer = new EditLogTailer(this, conf);
  editLogTailer.start();
  if (standbyShouldCheckpoint) {
    standbyCheckpointer = new StandbyCheckpointer(conf, this);
    standbyCheckpointer.start();
  }
}
项目:hardfs    文件:FSNamesystem.java   
/**
 * Start services required in standby state 
 * 
 * @throws IOException
 */
void startStandbyServices(final Configuration conf) throws IOException {
  LOG.info("Starting services required for standby state");
  if (!dir.fsImage.editLog.isOpenForRead()) {
    // During startup, we're already open for read.
    dir.fsImage.editLog.initSharedJournalsForRead();
  }

  blockManager.setPostponeBlocksFromFuture(true);

  editLogTailer = new EditLogTailer(this, conf);
  editLogTailer.start();
  if (standbyShouldCheckpoint) {
    standbyCheckpointer = new StandbyCheckpointer(conf, this);
    standbyCheckpointer.start();
  }
}
项目:hadoop-on-lustre2    文件:FSNamesystem.java   
/**
 * Start services required in standby state 
 * 
 * @throws IOException
 */
void startStandbyServices(final Configuration conf) throws IOException {
  LOG.info("Starting services required for standby state");
  if (!dir.fsImage.editLog.isOpenForRead()) {
    // During startup, we're already open for read.
    dir.fsImage.editLog.initSharedJournalsForRead();
  }

  blockManager.setPostponeBlocksFromFuture(true);

  editLogTailer = new EditLogTailer(this, conf);
  editLogTailer.start();
  if (standbyShouldCheckpoint) {
    standbyCheckpointer = new StandbyCheckpointer(conf, this);
    standbyCheckpointer.start();
  }
}