@Override public EmptyResponseProto ping(RpcController controller, EmptyRequestProto request) throws ServiceException { return null; }
@Override public EmptyResponseProto error(RpcController controller, EmptyRequestProto request) throws ServiceException { return null; }
@Override public EmptyResponseProto ping(RpcController unused, EmptyRequestProto request) throws ServiceException { return EmptyResponseProto.newBuilder().build(); }
@Override public EmptyResponseProto error(RpcController unused, EmptyRequestProto request) throws ServiceException { throw new ServiceException("error", new IOException("error")); }
@Override public EmptyResponseProto ping(RpcController controller, EmptyRequestProto request) throws ServiceException { // TODO Auto-generated method stub return null; }
@Override public EmptyResponseProto error(RpcController controller, EmptyRequestProto request) throws ServiceException { // TODO Auto-generated method stub return null; }
@Override public void ping(RpcController controller, TestProtos.EmptyRequestProto request, RpcCallback<TestProtos.EmptyResponseProto> done) { done.run(TestProtos.EmptyResponseProto.getDefaultInstance()); }
@Override public void error(RpcController controller, TestProtos.EmptyRequestProto request, RpcCallback<TestProtos.EmptyResponseProto> done) { CoprocessorRpcUtils.setControllerException(controller, new IOException("Test exception")); done.run(null); }
@Override public void pause(RpcController controller, PauseRequestProto request, RpcCallback<EmptyResponseProto> done) { Threads.sleepWithoutInterrupt(request.getMs()); done.run(EmptyResponseProto.getDefaultInstance()); }