@Override public NewEpochResponseProto newEpoch(RpcController controller, NewEpochRequestProto request) throws ServiceException { try { return impl.newEpoch( request.getJid().getIdentifier(), PBHelper.convert(request.getNsInfo()), request.getEpoch()); } catch (IOException ioe) { throw new ServiceException(ioe); } }
@Override public NewEpochResponseProto newEpoch(String jid, NamespaceInfo nsInfo, long epoch) throws IOException { try { NewEpochRequestProto req = NewEpochRequestProto.newBuilder() .setJid(convertJournalId(jid)) .setNsInfo(PBHelper.convert(nsInfo)) .setEpoch(epoch) .build(); return rpcProxy.newEpoch(NULL_CONTROLLER, req); } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }