@Override public KillTaskResponseProto killTask(RpcController controller, KillTaskRequestProto proto) throws ServiceException { KillTaskRequest request = new KillTaskRequestPBImpl(proto); try { KillTaskResponse response = real.killTask(request); return ((KillTaskResponsePBImpl)response).getProto(); } catch (IOException e) { throw new ServiceException(e); } }
@Override public KillTaskResponse killTask(KillTaskRequest request) throws IOException { KillTaskRequestProto requestProto = ((KillTaskRequestPBImpl)request).getProto(); try { return new KillTaskResponsePBImpl(proxy.killTask(null, requestProto)); } catch (ServiceException e) { throw unwrapAndThrowException(e); } }
public KillTaskRequestPBImpl() { builder = KillTaskRequestProto.newBuilder(); }
public KillTaskRequestPBImpl(KillTaskRequestProto proto) { this.proto = proto; viaProto = true; }
public KillTaskRequestProto getProto() { mergeLocalToProto(); proto = viaProto ? proto : builder.build(); viaProto = true; return proto; }
private void maybeInitBuilder() { if (viaProto || builder == null) { builder = KillTaskRequestProto.newBuilder(proto); } viaProto = false; }