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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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