org.apache.hadoop.hdfs.server.namenode.ha.EditLogTailer的实例源码

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

项目：hadoop    文件：NameNodeAdapter.java   

public static FSEditLog spyOnEditLog(NameNode nn) {
  FSEditLog spyEditLog = spy(nn.getNamesystem().getFSImage().getEditLog());
  DFSTestUtil.setEditLogForTesting(nn.getNamesystem(),spyEditLog);
  EditLogTailer tailer = nn.getNamesystem().getEditLogTailer();
  if (tailer != null) {
    tailer.setEditLog(spyEditLog);
  }
  return spyEditLog;
}

项目：aliyun-oss-hadoop-fs    文件：NameNodeAdapter.java   

public static FSEditLog spyOnEditLog(NameNode nn) {
  FSEditLog spyEditLog = spy(nn.getNamesystem().getFSImage().getEditLog());
  DFSTestUtil.setEditLogForTesting(nn.getNamesystem(),spyEditLog);
  EditLogTailer tailer = nn.getNamesystem().getEditLogTailer();
  if (tailer != null) {
    tailer.setEditLog(spyEditLog);
  }
  return spyEditLog;
}

项目：big-c    文件：NameNodeAdapter.java   

public static FSEditLog spyOnEditLog(NameNode nn) {
  FSEditLog spyEditLog = spy(nn.getNamesystem().getFSImage().getEditLog());
  DFSTestUtil.setEditLogForTesting(nn.getNamesystem(),spyEditLog);
  EditLogTailer tailer = nn.getNamesystem().getEditLogTailer();
  if (tailer != null) {
    tailer.setEditLog(spyEditLog);
  }
  return spyEditLog;
}

项目：hadoop-2.6.0-cdh5.4.3    文件：NameNodeAdapter.java   

public static FSEditLog spyOnEditLog(NameNode nn) {
  FSEditLog spyEditLog = spy(nn.getNamesystem().getFSImage().getEditLog());
  nn.getFSImage().setEditLogForTesting(spyEditLog);
  EditLogTailer tailer = nn.getNamesystem().getEditLogTailer();
  if (tailer != null) {
    tailer.setEditLog(spyEditLog);
  }
  return spyEditLog;
}

项目：FlexMap    文件：NameNodeAdapter.java   

public static FSEditLog spyOnEditLog(NameNode nn) {
  FSEditLog spyEditLog = spy(nn.getNamesystem().getFSImage().getEditLog());
  nn.getFSImage().setEditLogForTesting(spyEditLog);
  EditLogTailer tailer = nn.getNamesystem().getEditLogTailer();
  if (tailer != null) {
    tailer.setEditLog(spyEditLog);
  }
  return spyEditLog;
}

项目：hadoop-on-lustre2    文件：NameNodeAdapter.java   

public static FSEditLog spyOnEditLog(NameNode nn) {
  FSEditLog spyEditLog = spy(nn.getNamesystem().getFSImage().getEditLog());
  nn.getFSImage().setEditLogForTesting(spyEditLog);
  EditLogTailer tailer = nn.getNamesystem().getEditLogTailer();
  if (tailer != null) {
    tailer.setEditLog(spyEditLog);
  }
  return spyEditLog;
}

项目：hadoop    文件：FSNamesystem.java   

@VisibleForTesting
public EditLogTailer getEditLogTailer() {
  return editLogTailer;
}

项目：hadoop    文件：FSNamesystem.java   

@VisibleForTesting
public void setEditLogTailerForTests(EditLogTailer tailer) {
  this.editLogTailer = tailer;
}

项目：aliyun-oss-hadoop-fs    文件：FSNamesystem.java   

@VisibleForTesting
public EditLogTailer getEditLogTailer() {
  return editLogTailer;
}

项目：aliyun-oss-hadoop-fs    文件：FSNamesystem.java   

@VisibleForTesting
public void setEditLogTailerForTests(EditLogTailer tailer) {
  this.editLogTailer = tailer;
}

项目：big-c    文件：FSNamesystem.java   

@VisibleForTesting
public EditLogTailer getEditLogTailer() {
  return editLogTailer;
}

项目：big-c    文件：FSNamesystem.java   

@VisibleForTesting
public void setEditLogTailerForTests(EditLogTailer tailer) {
  this.editLogTailer = tailer;
}

项目：hadoop-2.6.0-cdh5.4.3    文件：FSNamesystem.java   

@VisibleForTesting
public EditLogTailer getEditLogTailer() {
  return editLogTailer;
}

项目：hadoop-2.6.0-cdh5.4.3    文件：FSNamesystem.java   

@VisibleForTesting
public void setEditLogTailerForTests(EditLogTailer tailer) {
  this.editLogTailer = tailer;
}

项目：hadoop-plus    文件：FSNamesystem.java   

@VisibleForTesting
public EditLogTailer getEditLogTailer() {
  return editLogTailer;
}

项目：FlexMap    文件：FSNamesystem.java   

@VisibleForTesting
public EditLogTailer getEditLogTailer() {
  return editLogTailer;
}

项目：FlexMap    文件：FSNamesystem.java   

@VisibleForTesting
public void setEditLogTailerForTests(EditLogTailer tailer) {
  this.editLogTailer = tailer;
}

项目：hadoop-TCP    文件：FSNamesystem.java   

@VisibleForTesting
public EditLogTailer getEditLogTailer() {
  return editLogTailer;
}

项目：hardfs    文件：FSNamesystem.java   

@VisibleForTesting
public EditLogTailer getEditLogTailer() {
  return editLogTailer;
}

项目：hadoop-on-lustre2    文件：FSNamesystem.java   

@VisibleForTesting
public EditLogTailer getEditLogTailer() {
  return editLogTailer;
}

项目：hadoop-on-lustre2    文件：FSNamesystem.java   

@VisibleForTesting
public void setEditLogTailerForTests(EditLogTailer tailer) {
  this.editLogTailer = tailer;
}