@Override public FinalizeLogSegmentResponseProto finalizeLogSegment( RpcController controller, FinalizeLogSegmentRequestProto req) throws ServiceException { try { impl.finalizeLogSegment(convert(req.getReqInfo()), req.getStartTxId(), req.getEndTxId()); } catch (IOException e) { throw new ServiceException(e); } return FinalizeLogSegmentResponseProto.newBuilder().build(); }
@Override public void finalizeLogSegment(RequestInfo reqInfo, long startTxId, long endTxId) throws IOException { FinalizeLogSegmentRequestProto req = FinalizeLogSegmentRequestProto.newBuilder() .setReqInfo(convert(reqInfo)) .setStartTxId(startTxId) .setEndTxId(endTxId) .build(); try { rpcProxy.finalizeLogSegment(NULL_CONTROLLER, req); } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }