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

@Override
public GetJournalCTimeResponseProto getJournalCTime(RpcController controller,
    GetJournalCTimeRequestProto request) throws ServiceException {
  try {
    Long resultCTime = impl.getJournalCTime(convert(request.getJid()));
    return GetJournalCTimeResponseProto.newBuilder()
        .setResultCTime(resultCTime)
        .build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public Long getJournalCTime(String journalId) throws IOException {
  try {
    GetJournalCTimeResponseProto response = rpcProxy.getJournalCTime(
        NULL_CONTROLLER,
        GetJournalCTimeRequestProto.newBuilder()
          .setJid(convertJournalId(journalId))
          .build());
    return response.getResultCTime();
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public GetJournalCTimeResponseProto getJournalCTime(RpcController controller,
    GetJournalCTimeRequestProto request) throws ServiceException {
  try {
    Long resultCTime = impl.getJournalCTime(convert(request.getJid()));
    return GetJournalCTimeResponseProto.newBuilder()
        .setResultCTime(resultCTime)
        .build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public Long getJournalCTime(String journalId) throws IOException {
  try {
    GetJournalCTimeResponseProto response = rpcProxy.getJournalCTime(
        NULL_CONTROLLER,
        GetJournalCTimeRequestProto.newBuilder()
          .setJid(convertJournalId(journalId))
          .build());
    return response.getResultCTime();
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public GetJournalCTimeResponseProto getJournalCTime(RpcController controller,
    GetJournalCTimeRequestProto request) throws ServiceException {
  try {
    Long resultCTime = impl.getJournalCTime(convert(request.getJid()));
    return GetJournalCTimeResponseProto.newBuilder()
        .setResultCTime(resultCTime)
        .build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public Long getJournalCTime(String journalId) throws IOException {
  try {
    GetJournalCTimeResponseProto response = rpcProxy.getJournalCTime(
        NULL_CONTROLLER,
        GetJournalCTimeRequestProto.newBuilder()
          .setJid(convertJournalId(journalId))
          .build());
    return response.getResultCTime();
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public GetJournalCTimeResponseProto getJournalCTime(RpcController controller,
    GetJournalCTimeRequestProto request) throws ServiceException {
  try {
    Long resultCTime = impl.getJournalCTime(convert(request.getJid()));
    return GetJournalCTimeResponseProto.newBuilder()
        .setResultCTime(resultCTime)
        .build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public Long getJournalCTime(String journalId) throws IOException {
  try {
    GetJournalCTimeResponseProto response = rpcProxy.getJournalCTime(
        NULL_CONTROLLER,
        GetJournalCTimeRequestProto.newBuilder()
          .setJid(convertJournalId(journalId))
          .build());
    return response.getResultCTime();
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public GetJournalCTimeResponseProto getJournalCTime(RpcController controller,
    GetJournalCTimeRequestProto request) throws ServiceException {
  try {
    Long resultCTime = impl.getJournalCTime(convert(request.getJid()));
    return GetJournalCTimeResponseProto.newBuilder()
        .setResultCTime(resultCTime)
        .build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public Long getJournalCTime(String journalId) throws IOException {
  try {
    GetJournalCTimeResponseProto response = rpcProxy.getJournalCTime(
        NULL_CONTROLLER,
        GetJournalCTimeRequestProto.newBuilder()
          .setJid(convertJournalId(journalId))
          .build());
    return response.getResultCTime();
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public GetJournalCTimeResponseProto getJournalCTime(RpcController controller,
    GetJournalCTimeRequestProto request) throws ServiceException {
  try {
    Long resultCTime = impl.getJournalCTime(convert(request.getJid()));
    return GetJournalCTimeResponseProto.newBuilder()
        .setResultCTime(resultCTime)
        .build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public Long getJournalCTime(String journalId) throws IOException {
  try {
    GetJournalCTimeResponseProto response = rpcProxy.getJournalCTime(
        NULL_CONTROLLER,
        GetJournalCTimeRequestProto.newBuilder()
          .setJid(convertJournalId(journalId))
          .build());
    return response.getResultCTime();
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}