@Override public EndCheckpointResponseProto endCheckpoint(RpcController unused, EndCheckpointRequestProto request) throws ServiceException { try { impl.endCheckpoint(PBHelper.convert(request.getRegistration()), PBHelper.convert(request.getSignature())); } catch (IOException e) { throw new ServiceException(e); } return VOID_END_CHECKPOINT_RESPONSE; }
@Override public void endCheckpoint(NamenodeRegistration registration, CheckpointSignature sig) throws IOException { EndCheckpointRequestProto req = EndCheckpointRequestProto.newBuilder() .setRegistration(PBHelper.convert(registration)) .setSignature(PBHelper.convert(sig)).build(); try { rpcProxy.endCheckpoint(NULL_CONTROLLER, req); } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }