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();
  }
}