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,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,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,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,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,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,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,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,this);
    standbyCheckpointer.start();
  }
}