Java 类org.apache.hadoop.hdfs.qjournal.protocol.QJournalProtocolProtos.GetEditLogManifestResponseProto 实例源码

@Override
public GetEditLogManifestResponseProto getEditLogManifest(byte[] jid,
    long sinceTxId) throws IOException {

  RemoteEditLogManifest manifest = jn.getOrCreateJournal(jid)
      .getEditLogManifest(sinceTxId);

  GetEditLogManifestResponseProto ret = new GetEditLogManifestResponseProto();
  ret.setLogs(manifest.getLogs());
  ret.setHttpPort(jn.getBoundHttpAddress().getPort());

  if (JournalNode.LOG.isDebugEnabled()) {
    JournalNode.LOG.info("Returning manifest " + manifest.toString());
  }

  return ret;
}

@Override
public ListenableFuture<RemoteEditLogManifest> getEditLogManifest(
    final long fromTxnId, final boolean forReading, 
    final boolean inProgressOk) {
  return executor.submit(new Callable<RemoteEditLogManifest>() {
    @Override
    public RemoteEditLogManifest call() throws IOException {
      GetEditLogManifestResponseProto ret = getProxy().getEditLogManifest(
          journalId, fromTxnId, forReading, inProgressOk);
      // Update the http port, since we need this to build URLs to any of the
      // returned logs.
      httpPort = ret.getHttpPort();
      return PBHelper.convert(ret.getManifest());
    }
  });
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean forReading, boolean inProgressOk)
    throws IOException {
  try {
    return rpcProxy.getEditLogManifest(NULL_CONTROLLER,
        GetEditLogManifestRequestProto.newBuilder()
          .setJid(convertJournalId(jid))
          .setSinceTxId(sinceTxId)
          .setForReading(forReading)
          .setInProgressOk(inProgressOk)
          .build());
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public ListenableFuture<RemoteEditLogManifest> getEditLogManifest(
    final long fromTxnId, final boolean forReading, 
    final boolean inProgressOk) {
  return executor.submit(new Callable<RemoteEditLogManifest>() {
    @Override
    public RemoteEditLogManifest call() throws IOException {
      GetEditLogManifestResponseProto ret = getProxy().getEditLogManifest(
          journalId, fromTxnId, forReading, inProgressOk);
      // Update the http port, since we need this to build URLs to any of the
      // returned logs.
      httpPort = ret.getHttpPort();
      return PBHelper.convert(ret.getManifest());
    }
  });
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean forReading, boolean inProgressOk)
    throws IOException {
  try {
    return rpcProxy.getEditLogManifest(NULL_CONTROLLER,
        GetEditLogManifestRequestProto.newBuilder()
          .setJid(convertJournalId(jid))
          .setSinceTxId(sinceTxId)
          .setForReading(forReading)
          .setInProgressOk(inProgressOk)
          .build());
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public ListenableFuture<RemoteEditLogManifest> getEditLogManifest(
    final long fromTxnId, final boolean inProgressOk) {
  return parallelExecutor.submit(new Callable<RemoteEditLogManifest>() {
    @Override
    public RemoteEditLogManifest call() throws IOException {
      GetEditLogManifestResponseProto ret = getProxy().getEditLogManifest(
          journalId, fromTxnId, inProgressOk);
      // Update the http port, since we need this to build URLs to any of the
      // returned logs.
      constructHttpServerURI(ret);
      return PBHelper.convert(ret.getManifest());
    }
  });
}

private void constructHttpServerURI(GetEditLogManifestResponseProto ret) {
  if (ret.hasFromURL()) {
    URI uri = URI.create(ret.getFromURL());
    httpServerURL = getHttpServerURI(uri.getScheme(), uri.getPort());
  } else {
    httpServerURL = getHttpServerURI("http", ret.getHttpPort());;
  }
}

@SuppressWarnings("deprecation")
@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean inProgressOk)
    throws IOException {

  RemoteEditLogManifest manifest = jn.getOrCreateJournal(jid)
      .getEditLogManifest(sinceTxId, inProgressOk);

  return GetEditLogManifestResponseProto.newBuilder()
      .setManifest(PBHelper.convert(manifest))
      .setHttpPort(jn.getBoundHttpAddress().getPort())
      .setFromURL(jn.getHttpServerURI())
      .build();
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(
    RpcController controller, GetEditLogManifestRequestProto request)
    throws ServiceException {
  try {
    return impl.getEditLogManifest(
        request.getJid().getIdentifier(),
        request.getSinceTxId(),
        request.getInProgressOk());
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean inProgressOk)
    throws IOException {
  try {
    return rpcProxy.getEditLogManifest(NULL_CONTROLLER,
        GetEditLogManifestRequestProto.newBuilder()
          .setJid(convertJournalId(jid))
          .setSinceTxId(sinceTxId)
          .setInProgressOk(inProgressOk)
          .build());
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public ListenableFuture<RemoteEditLogManifest> getEditLogManifest(
    final long fromTxnId, final boolean inProgressOk) {
  return parallelExecutor.submit(new Callable<RemoteEditLogManifest>() {
    @Override
    public RemoteEditLogManifest call() throws IOException {
      GetEditLogManifestResponseProto ret = getProxy().getEditLogManifest(
          journalId, fromTxnId, inProgressOk);
      // Update the http port, since we need this to build URLs to any of the
      // returned logs.
      constructHttpServerURI(ret);
      return PBHelper.convert(ret.getManifest());
    }
  });
}

private void constructHttpServerURI(GetEditLogManifestResponseProto ret) {
  if (ret.hasFromURL()) {
    URI uri = URI.create(ret.getFromURL());
    httpServerURL = getHttpServerURI(uri.getScheme(), uri.getPort());
  } else {
    httpServerURL = getHttpServerURI("http", ret.getHttpPort());;
  }
}

@SuppressWarnings("deprecation")
@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean inProgressOk)
    throws IOException {

  RemoteEditLogManifest manifest = jn.getOrCreateJournal(jid)
      .getEditLogManifest(sinceTxId, inProgressOk);

  return GetEditLogManifestResponseProto.newBuilder()
      .setManifest(PBHelper.convert(manifest))
      .setHttpPort(jn.getBoundHttpAddress().getPort())
      .setFromURL(jn.getHttpServerURI())
      .build();
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(
    RpcController controller, GetEditLogManifestRequestProto request)
    throws ServiceException {
  try {
    return impl.getEditLogManifest(
        request.getJid().getIdentifier(),
        request.getSinceTxId(),
        request.getInProgressOk());
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean inProgressOk)
    throws IOException {
  try {
    return rpcProxy.getEditLogManifest(NULL_CONTROLLER,
        GetEditLogManifestRequestProto.newBuilder()
          .setJid(convertJournalId(jid))
          .setSinceTxId(sinceTxId)
          .setInProgressOk(inProgressOk)
          .build());
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public ListenableFuture<RemoteEditLogManifest> getEditLogManifest(
    final long fromTxnId, final boolean inProgressOk) {
  return parallelExecutor.submit(new Callable<RemoteEditLogManifest>() {
    @Override
    public RemoteEditLogManifest call() throws IOException {
      GetEditLogManifestResponseProto ret = getProxy().getEditLogManifest(
          journalId, fromTxnId, inProgressOk);
      // Update the http port, since we need this to build URLs to any of the
      // returned logs.
      constructHttpServerURI(ret);
      return PBHelper.convert(ret.getManifest());
    }
  });
}

private void constructHttpServerURI(GetEditLogManifestResponseProto ret) {
  if (ret.hasFromURL()) {
    URI uri = URI.create(ret.getFromURL());
    httpServerURL = getHttpServerURI(uri.getScheme(), uri.getPort());
  } else {
    httpServerURL = getHttpServerURI("http", ret.getHttpPort());;
  }
}

@SuppressWarnings("deprecation")
@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean inProgressOk)
    throws IOException {

  RemoteEditLogManifest manifest = jn.getOrCreateJournal(jid)
      .getEditLogManifest(sinceTxId, inProgressOk);

  return GetEditLogManifestResponseProto.newBuilder()
      .setManifest(PBHelper.convert(manifest))
      .setHttpPort(jn.getBoundHttpAddress().getPort())
      .setFromURL(jn.getHttpServerURI())
      .build();
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(
    RpcController controller, GetEditLogManifestRequestProto request)
    throws ServiceException {
  try {
    return impl.getEditLogManifest(
        request.getJid().getIdentifier(),
        request.getSinceTxId(),
        request.getInProgressOk());
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean inProgressOk)
    throws IOException {
  try {
    return rpcProxy.getEditLogManifest(NULL_CONTROLLER,
        GetEditLogManifestRequestProto.newBuilder()
          .setJid(convertJournalId(jid))
          .setSinceTxId(sinceTxId)
          .setInProgressOk(inProgressOk)
          .build());
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public ListenableFuture<RemoteEditLogManifest> getEditLogManifest(
    final long fromTxnId, final boolean inProgressOk) {
  return parallelExecutor.submit(new Callable<RemoteEditLogManifest>() {
    @Override
    public RemoteEditLogManifest call() throws IOException {
      GetEditLogManifestResponseProto ret = getProxy().getEditLogManifest(
          journalId, fromTxnId, inProgressOk);
      // Update the http port, since we need this to build URLs to any of the
      // returned logs.
      constructHttpServerURI(ret);
      return PBHelper.convert(ret.getManifest());
    }
  });
}

private void constructHttpServerURI(GetEditLogManifestResponseProto ret) {
  if (ret.hasFromURL()) {
    URI uri = URI.create(ret.getFromURL());
    httpServerURL = getHttpServerURI(uri.getScheme(), uri.getPort());
  } else {
    httpServerURL = getHttpServerURI("http", ret.getHttpPort());;
  }
}

@SuppressWarnings("deprecation")
@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean inProgressOk)
    throws IOException {

  RemoteEditLogManifest manifest = jn.getOrCreateJournal(jid)
      .getEditLogManifest(sinceTxId, inProgressOk);

  return GetEditLogManifestResponseProto.newBuilder()
      .setManifest(PBHelper.convert(manifest))
      .setHttpPort(jn.getBoundHttpAddress().getPort())
      .setFromURL(jn.getHttpServerURI())
      .build();
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(
    RpcController controller, GetEditLogManifestRequestProto request)
    throws ServiceException {
  try {
    return impl.getEditLogManifest(
        request.getJid().getIdentifier(),
        request.getSinceTxId(),
        request.getInProgressOk());
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean inProgressOk)
    throws IOException {
  try {
    return rpcProxy.getEditLogManifest(NULL_CONTROLLER,
        GetEditLogManifestRequestProto.newBuilder()
          .setJid(convertJournalId(jid))
          .setSinceTxId(sinceTxId)
          .setInProgressOk(inProgressOk)
          .build());
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public ListenableFuture<RemoteEditLogManifest> getEditLogManifest(
    final long fromTxnId) {
  return executor.submit(new Callable<RemoteEditLogManifest>() {
    @Override
    public RemoteEditLogManifest call() throws IOException {
      GetEditLogManifestResponseProto ret = getProxy().getEditLogManifest(
          journalIdBytes, fromTxnId);
      // Update the http port, since we need this to build URLs to any of the
      // returned logs.
      httpPort = ret.getHttpPort();
      return new RemoteEditLogManifest(ret.getLogs());
    }
  });
}

@Override
public ListenableFuture<RemoteEditLogManifest> getEditLogManifest(
    final long fromTxnId, final boolean forReading) {
  return executor.submit(new Callable<RemoteEditLogManifest>() {
    @Override
    public RemoteEditLogManifest call() throws IOException {
      GetEditLogManifestResponseProto ret = getProxy().getEditLogManifest(
          journalId, fromTxnId, forReading);
      // Update the http port, since we need this to build URLs to any of the
      // returned logs.
      httpPort = ret.getHttpPort();
      return PBHelper.convert(ret.getManifest());
    }
  });
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean forReading) throws IOException {

  RemoteEditLogManifest manifest = jn.getOrCreateJournal(jid)
      .getEditLogManifest(sinceTxId, forReading);

  return GetEditLogManifestResponseProto.newBuilder()
      .setManifest(PBHelper.convert(manifest))
      .setHttpPort(jn.getBoundHttpAddress().getPort())
      .build();
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(
    RpcController controller, GetEditLogManifestRequestProto request)
    throws ServiceException {
  try {
    return impl.getEditLogManifest(
        request.getJid().getIdentifier(),
        request.getSinceTxId(),
        request.getForReading());
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean forReading) throws IOException {
  try {
    return rpcProxy.getEditLogManifest(NULL_CONTROLLER,
        GetEditLogManifestRequestProto.newBuilder()
          .setJid(convertJournalId(jid))
          .setSinceTxId(sinceTxId)
          .setForReading(forReading)
          .build());
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public ListenableFuture<RemoteEditLogManifest> getEditLogManifest(
    final long fromTxnId, final boolean inProgressOk) {
  return parallelExecutor.submit(new Callable<RemoteEditLogManifest>() {
    @Override
    public RemoteEditLogManifest call() throws IOException {
      GetEditLogManifestResponseProto ret = getProxy().getEditLogManifest(
          journalId, fromTxnId, inProgressOk);
      // Update the http port, since we need this to build URLs to any of the
      // returned logs.
      constructHttpServerURI(ret);
      return PBHelper.convert(ret.getManifest());
    }
  });
}

private void constructHttpServerURI(GetEditLogManifestResponseProto ret) {
  if (ret.hasFromURL()) {
    URI uri = URI.create(ret.getFromURL());
    httpServerURL = getHttpServerURI(uri.getScheme(), uri.getPort());
  } else {
    httpServerURL = getHttpServerURI("http", ret.getHttpPort());;
  }
}

@SuppressWarnings("deprecation")
@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean inProgressOk)
    throws IOException {

  RemoteEditLogManifest manifest = jn.getOrCreateJournal(jid)
      .getEditLogManifest(sinceTxId, inProgressOk);

  return GetEditLogManifestResponseProto.newBuilder()
      .setManifest(PBHelper.convert(manifest))
      .setHttpPort(jn.getBoundHttpAddress().getPort())
      .setFromURL(jn.getHttpServerURI())
      .build();
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(
    RpcController controller, GetEditLogManifestRequestProto request)
    throws ServiceException {
  try {
    return impl.getEditLogManifest(
        request.getJid().getIdentifier(),
        request.getSinceTxId(),
        request.getInProgressOk());
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean inProgressOk)
    throws IOException {
  try {
    return rpcProxy.getEditLogManifest(NULL_CONTROLLER,
        GetEditLogManifestRequestProto.newBuilder()
          .setJid(convertJournalId(jid))
          .setSinceTxId(sinceTxId)
          .setInProgressOk(inProgressOk)
          .build());
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean forReading, boolean inProgressOk)
    throws IOException {

  RemoteEditLogManifest manifest = jn.getOrCreateJournal(jid)
      .getEditLogManifest(sinceTxId, forReading, inProgressOk);

  return GetEditLogManifestResponseProto.newBuilder()
      .setManifest(PBHelper.convert(manifest))
      .setHttpPort(jn.getBoundHttpAddress().getPort())
      .build();
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(
    RpcController controller, GetEditLogManifestRequestProto request)
    throws ServiceException {
  try {
    return impl.getEditLogManifest(
        request.getJid().getIdentifier(),
        request.getSinceTxId(),
        request.getForReading(),
        request.getInProgressOk());
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(String jid,
    long sinceTxId, boolean forReading, boolean inProgressOk)
    throws IOException {

  RemoteEditLogManifest manifest = jn.getOrCreateJournal(jid)
      .getEditLogManifest(sinceTxId, forReading, inProgressOk);

  return GetEditLogManifestResponseProto.newBuilder()
      .setManifest(PBHelper.convert(manifest))
      .setHttpPort(jn.getBoundHttpAddress().getPort())
      .build();
}

@Override
public GetEditLogManifestResponseProto getEditLogManifest(
    RpcController controller, GetEditLogManifestRequestProto request)
    throws ServiceException {
  try {
    return impl.getEditLogManifest(
        request.getJid().getIdentifier(),
        request.getSinceTxId(),
        request.getForReading(),
        request.getInProgressOk());
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public ListenableFuture<RemoteEditLogManifest> getEditLogManifest(
    final long fromTxnId, final boolean inProgressOk) {
  return executor.submit(new Callable<RemoteEditLogManifest>() {
    @Override
    public RemoteEditLogManifest call() throws IOException {
      GetEditLogManifestResponseProto ret = getProxy().getEditLogManifest(
          journalId, fromTxnId, inProgressOk);
      // Update the http port, since we need this to build URLs to any of the
      // returned logs.
      constructHttpServerURI(ret);
      return PBHelper.convert(ret.getManifest());
    }
  });
}