diff options
Diffstat (limited to 'src/main/java/com/orbekk/protobuf/Rpc.java')
| -rw-r--r-- | src/main/java/com/orbekk/protobuf/Rpc.java | 1393 |
1 files changed, 72 insertions, 1321 deletions
diff --git a/src/main/java/com/orbekk/protobuf/Rpc.java b/src/main/java/com/orbekk/protobuf/Rpc.java index 38ff1ea..9b087d7 100644 --- a/src/main/java/com/orbekk/protobuf/Rpc.java +++ b/src/main/java/com/orbekk/protobuf/Rpc.java @@ -1,1348 +1,99 @@ -// Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/java/com/orbekk/protobuf/Rpc.proto - package com.orbekk.protobuf; -public final class Rpc { - private Rpc() {} - public static void registerAllExtensions( - com.google.protobuf.ExtensionRegistry registry) { - } - public interface RequestOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // optional string full_service_name = 1; - boolean hasFullServiceName(); - String getFullServiceName(); - - // optional string method_name = 2; - boolean hasMethodName(); - String getMethodName(); - - // optional bytes request_proto = 3; - boolean hasRequestProto(); - com.google.protobuf.ByteString getRequestProto(); - - // optional int64 request_id = 4; - boolean hasRequestId(); - long getRequestId(); - } - public static final class Request extends - com.google.protobuf.GeneratedMessage - implements RequestOrBuilder { - // Use Request.newBuilder() to construct. - private Request(Builder builder) { - super(builder); - } - private Request(boolean noInit) {} - - private static final Request defaultInstance; - public static Request getDefaultInstance() { - return defaultInstance; - } - - public Request getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return com.orbekk.protobuf.Rpc.internal_static_com_orbekk_protobuf_Request_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return com.orbekk.protobuf.Rpc.internal_static_com_orbekk_protobuf_Request_fieldAccessorTable; - } - - private int bitField0_; - // optional string full_service_name = 1; - public static final int FULL_SERVICE_NAME_FIELD_NUMBER = 1; - private java.lang.Object fullServiceName_; - public boolean hasFullServiceName() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public String getFullServiceName() { - java.lang.Object ref = fullServiceName_; - if (ref instanceof String) { - return (String) ref; - } else { - com.google.protobuf.ByteString bs = - (com.google.protobuf.ByteString) ref; - String s = bs.toStringUtf8(); - if (com.google.protobuf.Internal.isValidUtf8(bs)) { - fullServiceName_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getFullServiceNameBytes() { - java.lang.Object ref = fullServiceName_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - fullServiceName_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - // optional string method_name = 2; - public static final int METHOD_NAME_FIELD_NUMBER = 2; - private java.lang.Object methodName_; - public boolean hasMethodName() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public String getMethodName() { - java.lang.Object ref = methodName_; - if (ref instanceof String) { - return (String) ref; - } else { - com.google.protobuf.ByteString bs = - (com.google.protobuf.ByteString) ref; - String s = bs.toStringUtf8(); - if (com.google.protobuf.Internal.isValidUtf8(bs)) { - methodName_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getMethodNameBytes() { - java.lang.Object ref = methodName_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - methodName_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - // optional bytes request_proto = 3; - public static final int REQUEST_PROTO_FIELD_NUMBER = 3; - private com.google.protobuf.ByteString requestProto_; - public boolean hasRequestProto() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public com.google.protobuf.ByteString getRequestProto() { - return requestProto_; - } - - // optional int64 request_id = 4; - public static final int REQUEST_ID_FIELD_NUMBER = 4; - private long requestId_; - public boolean hasRequestId() { - return ((bitField0_ & 0x00000008) == 0x00000008); - } - public long getRequestId() { - return requestId_; - } - - private void initFields() { - fullServiceName_ = ""; - methodName_ = ""; - requestProto_ = com.google.protobuf.ByteString.EMPTY; - requestId_ = 0L; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - memoizedIsInitialized = 1; - return true; - } - - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - getSerializedSize(); - if (((bitField0_ & 0x00000001) == 0x00000001)) { - output.writeBytes(1, getFullServiceNameBytes()); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeBytes(2, getMethodNameBytes()); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - output.writeBytes(3, requestProto_); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - output.writeInt64(4, requestId_); - } - getUnknownFields().writeTo(output); - } - - private int memoizedSerializedSize = -1; - public int getSerializedSize() { - int size = memoizedSerializedSize; - if (size != -1) return size; - - size = 0; - if (((bitField0_ & 0x00000001) == 0x00000001)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(1, getFullServiceNameBytes()); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(2, getMethodNameBytes()); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(3, requestProto_); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - size += com.google.protobuf.CodedOutputStream - .computeInt64Size(4, requestId_); - } - size += getUnknownFields().getSerializedSize(); - memoizedSerializedSize = size; - return size; - } - - private static final long serialVersionUID = 0L; - @java.lang.Override - protected java.lang.Object writeReplace() - throws java.io.ObjectStreamException { - return super.writeReplace(); - } - - public static com.orbekk.protobuf.Rpc.Request parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Request parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Request parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Request parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Request parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Request parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Request parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static com.orbekk.protobuf.Rpc.Request parseDelimitedFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input, extensionRegistry)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static com.orbekk.protobuf.Rpc.Request parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Request parseFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } +import java.util.ArrayList; +import java.util.List; +import java.util.concurrent.CountDownLatch; + +import com.google.protobuf.RpcCallback; +import com.google.protobuf.RpcController; + +public class Rpc implements RpcController { + private String errorText = ""; + private boolean hasFailed; + private boolean canceled; + private List<RpcCallback<Object>> cancelNotificationListeners = null; - public static Builder newBuilder() { return Builder.create(); } - public Builder newBuilderForType() { return newBuilder(); } - public static Builder newBuilder(com.orbekk.protobuf.Rpc.Request prototype) { - return newBuilder().mergeFrom(prototype); + public Rpc() { } - public Builder toBuilder() { return newBuilder(this); } - @java.lang.Override - protected Builder newBuilderForType( - com.google.protobuf.GeneratedMessage.BuilderParent parent) { - Builder builder = new Builder(parent); - return builder; + public Rpc(Rpc other) { + copyFrom(other); } - public static final class Builder extends - com.google.protobuf.GeneratedMessage.Builder<Builder> - implements com.orbekk.protobuf.Rpc.RequestOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return com.orbekk.protobuf.Rpc.internal_static_com_orbekk_protobuf_Request_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return com.orbekk.protobuf.Rpc.internal_static_com_orbekk_protobuf_Request_fieldAccessorTable; - } - - // Construct using com.orbekk.protobuf.Rpc.Request.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - fullServiceName_ = ""; - bitField0_ = (bitField0_ & ~0x00000001); - methodName_ = ""; - bitField0_ = (bitField0_ & ~0x00000002); - requestProto_ = com.google.protobuf.ByteString.EMPTY; - bitField0_ = (bitField0_ & ~0x00000004); - requestId_ = 0L; - bitField0_ = (bitField0_ & ~0x00000008); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return com.orbekk.protobuf.Rpc.Request.getDescriptor(); - } - - public com.orbekk.protobuf.Rpc.Request getDefaultInstanceForType() { - return com.orbekk.protobuf.Rpc.Request.getDefaultInstance(); - } - - public com.orbekk.protobuf.Rpc.Request build() { - com.orbekk.protobuf.Rpc.Request result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private com.orbekk.protobuf.Rpc.Request buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - com.orbekk.protobuf.Rpc.Request result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public com.orbekk.protobuf.Rpc.Request buildPartial() { - com.orbekk.protobuf.Rpc.Request result = new com.orbekk.protobuf.Rpc.Request(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.fullServiceName_ = fullServiceName_; - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.methodName_ = methodName_; - if (((from_bitField0_ & 0x00000004) == 0x00000004)) { - to_bitField0_ |= 0x00000004; - } - result.requestProto_ = requestProto_; - if (((from_bitField0_ & 0x00000008) == 0x00000008)) { - to_bitField0_ |= 0x00000008; - } - result.requestId_ = requestId_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof com.orbekk.protobuf.Rpc.Request) { - return mergeFrom((com.orbekk.protobuf.Rpc.Request)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(com.orbekk.protobuf.Rpc.Request other) { - if (other == com.orbekk.protobuf.Rpc.Request.getDefaultInstance()) return this; - if (other.hasFullServiceName()) { - setFullServiceName(other.getFullServiceName()); - } - if (other.hasMethodName()) { - setMethodName(other.getMethodName()); - } - if (other.hasRequestProto()) { - setRequestProto(other.getRequestProto()); - } - if (other.hasRequestId()) { - setRequestId(other.getRequestId()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - return true; - } - - public Builder mergeFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - com.google.protobuf.UnknownFieldSet.Builder unknownFields = - com.google.protobuf.UnknownFieldSet.newBuilder( - this.getUnknownFields()); - while (true) { - int tag = input.readTag(); - switch (tag) { - case 0: - this.setUnknownFields(unknownFields.build()); - onChanged(); - return this; - default: { - if (!parseUnknownField(input, unknownFields, - extensionRegistry, tag)) { - this.setUnknownFields(unknownFields.build()); - onChanged(); - return this; - } - break; - } - case 10: { - bitField0_ |= 0x00000001; - fullServiceName_ = input.readBytes(); - break; - } - case 18: { - bitField0_ |= 0x00000002; - methodName_ = input.readBytes(); - break; - } - case 26: { - bitField0_ |= 0x00000004; - requestProto_ = input.readBytes(); - break; - } - case 32: { - bitField0_ |= 0x00000008; - requestId_ = input.readInt64(); - break; + + public void copyFrom(Rpc other) { + errorText = other.errorText; + hasFailed = other.hasFailed; + canceled = other.canceled; + if (other.cancelNotificationListeners != null) { + for (RpcCallback<Object> listener : + other.cancelNotificationListeners) { + notifyOnCancel(listener); } - } - } - } - - private int bitField0_; - - // optional string full_service_name = 1; - private java.lang.Object fullServiceName_ = ""; - public boolean hasFullServiceName() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public String getFullServiceName() { - java.lang.Object ref = fullServiceName_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - fullServiceName_ = s; - return s; - } else { - return (String) ref; - } - } - public Builder setFullServiceName(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000001; - fullServiceName_ = value; - onChanged(); - return this; - } - public Builder clearFullServiceName() { - bitField0_ = (bitField0_ & ~0x00000001); - fullServiceName_ = getDefaultInstance().getFullServiceName(); - onChanged(); - return this; - } - void setFullServiceName(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000001; - fullServiceName_ = value; - onChanged(); - } - - // optional string method_name = 2; - private java.lang.Object methodName_ = ""; - public boolean hasMethodName() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public String getMethodName() { - java.lang.Object ref = methodName_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - methodName_ = s; - return s; - } else { - return (String) ref; } - } - public Builder setMethodName(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000002; - methodName_ = value; - onChanged(); - return this; - } - public Builder clearMethodName() { - bitField0_ = (bitField0_ & ~0x00000002); - methodName_ = getDefaultInstance().getMethodName(); - onChanged(); - return this; - } - void setMethodName(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000002; - methodName_ = value; - onChanged(); - } - - // optional bytes request_proto = 3; - private com.google.protobuf.ByteString requestProto_ = com.google.protobuf.ByteString.EMPTY; - public boolean hasRequestProto() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public com.google.protobuf.ByteString getRequestProto() { - return requestProto_; - } - public Builder setRequestProto(com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000004; - requestProto_ = value; - onChanged(); - return this; - } - public Builder clearRequestProto() { - bitField0_ = (bitField0_ & ~0x00000004); - requestProto_ = getDefaultInstance().getRequestProto(); - onChanged(); - return this; - } - - // optional int64 request_id = 4; - private long requestId_ ; - public boolean hasRequestId() { - return ((bitField0_ & 0x00000008) == 0x00000008); - } - public long getRequestId() { - return requestId_; - } - public Builder setRequestId(long value) { - bitField0_ |= 0x00000008; - requestId_ = value; - onChanged(); - return this; - } - public Builder clearRequestId() { - bitField0_ = (bitField0_ & ~0x00000008); - requestId_ = 0L; - onChanged(); - return this; - } - - // @@protoc_insertion_point(builder_scope:com.orbekk.protobuf.Request) - } - - static { - defaultInstance = new Request(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:com.orbekk.protobuf.Request) - } - - public interface ResponseOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // optional bytes response_proto = 1; - boolean hasResponseProto(); - com.google.protobuf.ByteString getResponseProto(); - - // optional .com.orbekk.protobuf.Response.Error error = 2; - boolean hasError(); - com.orbekk.protobuf.Rpc.Response.Error getError(); - - // optional int32 app_error = 4; - boolean hasAppError(); - int getAppError(); - - // optional string error_message = 3; - boolean hasErrorMessage(); - String getErrorMessage(); - - // optional int64 request_id = 5; - boolean hasRequestId(); - long getRequestId(); - } - public static final class Response extends - com.google.protobuf.GeneratedMessage - implements ResponseOrBuilder { - // Use Response.newBuilder() to construct. - private Response(Builder builder) { - super(builder); } - private Response(boolean noInit) {} - private static final Response defaultInstance; - public static Response getDefaultInstance() { - return defaultInstance; + public void writeTo(Data.Response.Builder response) { + response.setHasFailed(hasFailed); + response.setCanceled(canceled); + response.setErrorText(errorText); } - public Response getDefaultInstanceForType() { - return defaultInstance; + public void readFrom(Data.Response response) { + hasFailed = response.getHasFailed(); + canceled = response.getCanceled(); + errorText = response.getErrorText(); } - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return com.orbekk.protobuf.Rpc.internal_static_com_orbekk_protobuf_Response_descriptor; + @Override + public String errorText() { + return errorText; } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return com.orbekk.protobuf.Rpc.internal_static_com_orbekk_protobuf_Response_fieldAccessorTable; - } - - public enum Error - implements com.google.protobuf.ProtocolMessageEnum { - UNKNOWN_SERVICE(0, 0), - UNKNOWN_METHOD(1, 1), - CANCELED(2, 2), - APP_ERROR(3, 3), - ; - - public static final int UNKNOWN_SERVICE_VALUE = 0; - public static final int UNKNOWN_METHOD_VALUE = 1; - public static final int CANCELED_VALUE = 2; - public static final int APP_ERROR_VALUE = 3; - - - public final int getNumber() { return value; } - - public static Error valueOf(int value) { - switch (value) { - case 0: return UNKNOWN_SERVICE; - case 1: return UNKNOWN_METHOD; - case 2: return CANCELED; - case 3: return APP_ERROR; - default: return null; - } - } - - public static com.google.protobuf.Internal.EnumLiteMap<Error> - internalGetValueMap() { - return internalValueMap; - } - private static com.google.protobuf.Internal.EnumLiteMap<Error> - internalValueMap = - new com.google.protobuf.Internal.EnumLiteMap<Error>() { - public Error findValueByNumber(int number) { - return Error.valueOf(number); - } - }; - - public final com.google.protobuf.Descriptors.EnumValueDescriptor - getValueDescriptor() { - return getDescriptor().getValues().get(index); - } - public final com.google.protobuf.Descriptors.EnumDescriptor - getDescriptorForType() { - return getDescriptor(); - } - public static final com.google.protobuf.Descriptors.EnumDescriptor - getDescriptor() { - return com.orbekk.protobuf.Rpc.Response.getDescriptor().getEnumTypes().get(0); - } - - private static final Error[] VALUES = { - UNKNOWN_SERVICE, UNKNOWN_METHOD, CANCELED, APP_ERROR, - }; - - public static Error valueOf( - com.google.protobuf.Descriptors.EnumValueDescriptor desc) { - if (desc.getType() != getDescriptor()) { - throw new java.lang.IllegalArgumentException( - "EnumValueDescriptor is not for this type."); - } - return VALUES[desc.getIndex()]; - } - - private final int index; - private final int value; - - private Error(int index, int value) { - this.index = index; - this.value = value; - } - - // @@protoc_insertion_point(enum_scope:com.orbekk.protobuf.Response.Error) - } - - private int bitField0_; - // optional bytes response_proto = 1; - public static final int RESPONSE_PROTO_FIELD_NUMBER = 1; - private com.google.protobuf.ByteString responseProto_; - public boolean hasResponseProto() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public com.google.protobuf.ByteString getResponseProto() { - return responseProto_; - } - - // optional .com.orbekk.protobuf.Response.Error error = 2; - public static final int ERROR_FIELD_NUMBER = 2; - private com.orbekk.protobuf.Rpc.Response.Error error_; - public boolean hasError() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public com.orbekk.protobuf.Rpc.Response.Error getError() { - return error_; + + public boolean isOk() { + return !hasFailed && !canceled; } - // optional int32 app_error = 4; - public static final int APP_ERROR_FIELD_NUMBER = 4; - private int appError_; - public boolean hasAppError() { - return ((bitField0_ & 0x00000004) == 0x00000004); + @Override + public boolean failed() { + return hasFailed; } - public int getAppError() { - return appError_; - } - - // optional string error_message = 3; - public static final int ERROR_MESSAGE_FIELD_NUMBER = 3; - private java.lang.Object errorMessage_; - public boolean hasErrorMessage() { - return ((bitField0_ & 0x00000008) == 0x00000008); + + @Override + public boolean isCanceled() { + return canceled; } - public String getErrorMessage() { - java.lang.Object ref = errorMessage_; - if (ref instanceof String) { - return (String) ref; - } else { - com.google.protobuf.ByteString bs = - (com.google.protobuf.ByteString) ref; - String s = bs.toStringUtf8(); - if (com.google.protobuf.Internal.isValidUtf8(bs)) { - errorMessage_ = s; + + @Override + public void notifyOnCancel(RpcCallback<Object> listener) { + if (cancelNotificationListeners == null) { + cancelNotificationListeners = + new ArrayList<RpcCallback<Object>>(); } - return s; - } - } - private com.google.protobuf.ByteString getErrorMessageBytes() { - java.lang.Object ref = errorMessage_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - errorMessage_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - // optional int64 request_id = 5; - public static final int REQUEST_ID_FIELD_NUMBER = 5; - private long requestId_; - public boolean hasRequestId() { - return ((bitField0_ & 0x00000010) == 0x00000010); - } - public long getRequestId() { - return requestId_; - } - - private void initFields() { - responseProto_ = com.google.protobuf.ByteString.EMPTY; - error_ = com.orbekk.protobuf.Rpc.Response.Error.UNKNOWN_SERVICE; - appError_ = 0; - errorMessage_ = ""; - requestId_ = 0L; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - memoizedIsInitialized = 1; - return true; - } - - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - getSerializedSize(); - if (((bitField0_ & 0x00000001) == 0x00000001)) { - output.writeBytes(1, responseProto_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeEnum(2, error_.getNumber()); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - output.writeBytes(3, getErrorMessageBytes()); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - output.writeInt32(4, appError_); - } - if (((bitField0_ & 0x00000010) == 0x00000010)) { - output.writeInt64(5, requestId_); - } - getUnknownFields().writeTo(output); - } - - private int memoizedSerializedSize = -1; - public int getSerializedSize() { - int size = memoizedSerializedSize; - if (size != -1) return size; - - size = 0; - if (((bitField0_ & 0x00000001) == 0x00000001)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(1, responseProto_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeEnumSize(2, error_.getNumber()); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(3, getErrorMessageBytes()); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - size += com.google.protobuf.CodedOutputStream - .computeInt32Size(4, appError_); - } - if (((bitField0_ & 0x00000010) == 0x00000010)) { - size += com.google.protobuf.CodedOutputStream - .computeInt64Size(5, requestId_); - } - size += getUnknownFields().getSerializedSize(); - memoizedSerializedSize = size; - return size; - } - - private static final long serialVersionUID = 0L; - @java.lang.Override - protected java.lang.Object writeReplace() - throws java.io.ObjectStreamException { - return super.writeReplace(); - } - - public static com.orbekk.protobuf.Rpc.Response parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Response parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); + cancelNotificationListeners.add(listener); } - public static com.orbekk.protobuf.Rpc.Response parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Response parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Response parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Response parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Response parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static com.orbekk.protobuf.Rpc.Response parseDelimitedFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input, extensionRegistry)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static com.orbekk.protobuf.Rpc.Response parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static com.orbekk.protobuf.Rpc.Response parseFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - - public static Builder newBuilder() { return Builder.create(); } - public Builder newBuilderForType() { return newBuilder(); } - public static Builder newBuilder(com.orbekk.protobuf.Rpc.Response prototype) { - return newBuilder().mergeFrom(prototype); - } - public Builder toBuilder() { return newBuilder(this); } - - @java.lang.Override - protected Builder newBuilderForType( - com.google.protobuf.GeneratedMessage.BuilderParent parent) { - Builder builder = new Builder(parent); - return builder; + + @Override + public void reset() { + copyFrom(new Rpc()); } - public static final class Builder extends - com.google.protobuf.GeneratedMessage.Builder<Builder> - implements com.orbekk.protobuf.Rpc.ResponseOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return com.orbekk.protobuf.Rpc.internal_static_com_orbekk_protobuf_Response_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return com.orbekk.protobuf.Rpc.internal_static_com_orbekk_protobuf_Response_fieldAccessorTable; - } - - // Construct using com.orbekk.protobuf.Rpc.Response.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - responseProto_ = com.google.protobuf.ByteString.EMPTY; - bitField0_ = (bitField0_ & ~0x00000001); - error_ = com.orbekk.protobuf.Rpc.Response.Error.UNKNOWN_SERVICE; - bitField0_ = (bitField0_ & ~0x00000002); - appError_ = 0; - bitField0_ = (bitField0_ & ~0x00000004); - errorMessage_ = ""; - bitField0_ = (bitField0_ & ~0x00000008); - requestId_ = 0L; - bitField0_ = (bitField0_ & ~0x00000010); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return com.orbekk.protobuf.Rpc.Response.getDescriptor(); - } - - public com.orbekk.protobuf.Rpc.Response getDefaultInstanceForType() { - return com.orbekk.protobuf.Rpc.Response.getDefaultInstance(); - } - - public com.orbekk.protobuf.Rpc.Response build() { - com.orbekk.protobuf.Rpc.Response result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private com.orbekk.protobuf.Rpc.Response buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - com.orbekk.protobuf.Rpc.Response result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public com.orbekk.protobuf.Rpc.Response buildPartial() { - com.orbekk.protobuf.Rpc.Response result = new com.orbekk.protobuf.Rpc.Response(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.responseProto_ = responseProto_; - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.error_ = error_; - if (((from_bitField0_ & 0x00000004) == 0x00000004)) { - to_bitField0_ |= 0x00000004; - } - result.appError_ = appError_; - if (((from_bitField0_ & 0x00000008) == 0x00000008)) { - to_bitField0_ |= 0x00000008; - } - result.errorMessage_ = errorMessage_; - if (((from_bitField0_ & 0x00000010) == 0x00000010)) { - to_bitField0_ |= 0x00000010; - } - result.requestId_ = requestId_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof com.orbekk.protobuf.Rpc.Response) { - return mergeFrom((com.orbekk.protobuf.Rpc.Response)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(com.orbekk.protobuf.Rpc.Response other) { - if (other == com.orbekk.protobuf.Rpc.Response.getDefaultInstance()) return this; - if (other.hasResponseProto()) { - setResponseProto(other.getResponseProto()); - } - if (other.hasError()) { - setError(other.getError()); - } - if (other.hasAppError()) { - setAppError(other.getAppError()); - } - if (other.hasErrorMessage()) { - setErrorMessage(other.getErrorMessage()); - } - if (other.hasRequestId()) { - setRequestId(other.getRequestId()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - return true; - } - - public Builder mergeFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - com.google.protobuf.UnknownFieldSet.Builder unknownFields = - com.google.protobuf.UnknownFieldSet.newBuilder( - this.getUnknownFields()); - while (true) { - int tag = input.readTag(); - switch (tag) { - case 0: - this.setUnknownFields(unknownFields.build()); - onChanged(); - return this; - default: { - if (!parseUnknownField(input, unknownFields, - extensionRegistry, tag)) { - this.setUnknownFields(unknownFields.build()); - onChanged(); - return this; - } - break; - } - case 10: { - bitField0_ |= 0x00000001; - responseProto_ = input.readBytes(); - break; - } - case 16: { - int rawValue = input.readEnum(); - com.orbekk.protobuf.Rpc.Response.Error value = com.orbekk.protobuf.Rpc.Response.Error.valueOf(rawValue); - if (value == null) { - unknownFields.mergeVarintField(2, rawValue); - } else { - bitField0_ |= 0x00000002; - error_ = value; - } - break; - } - case 26: { - bitField0_ |= 0x00000008; - errorMessage_ = input.readBytes(); - break; - } - case 32: { - bitField0_ |= 0x00000004; - appError_ = input.readInt32(); - break; - } - case 40: { - bitField0_ |= 0x00000010; - requestId_ = input.readInt64(); - break; + + @Override + public void setFailed(String message) { + hasFailed = true; + errorText = message; + } + + public void cancel() { + canceled = true; + if (cancelNotificationListeners != null) { + for (RpcCallback<Object> listener : + cancelNotificationListeners) { + listener.run(null); } - } - } - } - - private int bitField0_; - - // optional bytes response_proto = 1; - private com.google.protobuf.ByteString responseProto_ = com.google.protobuf.ByteString.EMPTY; - public boolean hasResponseProto() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public com.google.protobuf.ByteString getResponseProto() { - return responseProto_; - } - public Builder setResponseProto(com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000001; - responseProto_ = value; - onChanged(); - return this; - } - public Builder clearResponseProto() { - bitField0_ = (bitField0_ & ~0x00000001); - responseProto_ = getDefaultInstance().getResponseProto(); - onChanged(); - return this; - } - - // optional .com.orbekk.protobuf.Response.Error error = 2; - private com.orbekk.protobuf.Rpc.Response.Error error_ = com.orbekk.protobuf.Rpc.Response.Error.UNKNOWN_SERVICE; - public boolean hasError() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public com.orbekk.protobuf.Rpc.Response.Error getError() { - return error_; - } - public Builder setError(com.orbekk.protobuf.Rpc.Response.Error value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000002; - error_ = value; - onChanged(); - return this; - } - public Builder clearError() { - bitField0_ = (bitField0_ & ~0x00000002); - error_ = com.orbekk.protobuf.Rpc.Response.Error.UNKNOWN_SERVICE; - onChanged(); - return this; - } - - // optional int32 app_error = 4; - private int appError_ ; - public boolean hasAppError() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public int getAppError() { - return appError_; - } - public Builder setAppError(int value) { - bitField0_ |= 0x00000004; - appError_ = value; - onChanged(); - return this; - } - public Builder clearAppError() { - bitField0_ = (bitField0_ & ~0x00000004); - appError_ = 0; - onChanged(); - return this; - } - - // optional string error_message = 3; - private java.lang.Object errorMessage_ = ""; - public boolean hasErrorMessage() { - return ((bitField0_ & 0x00000008) == 0x00000008); - } - public String getErrorMessage() { - java.lang.Object ref = errorMessage_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - errorMessage_ = s; - return s; - } else { - return (String) ref; } - } - public Builder setErrorMessage(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000008; - errorMessage_ = value; - onChanged(); - return this; - } - public Builder clearErrorMessage() { - bitField0_ = (bitField0_ & ~0x00000008); - errorMessage_ = getDefaultInstance().getErrorMessage(); - onChanged(); - return this; - } - void setErrorMessage(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000008; - errorMessage_ = value; - onChanged(); - } - - // optional int64 request_id = 5; - private long requestId_ ; - public boolean hasRequestId() { - return ((bitField0_ & 0x00000010) == 0x00000010); - } - public long getRequestId() { - return requestId_; - } - public Builder setRequestId(long value) { - bitField0_ |= 0x00000010; - requestId_ = value; - onChanged(); - return this; - } - public Builder clearRequestId() { - bitField0_ = (bitField0_ & ~0x00000010); - requestId_ = 0L; - onChanged(); - return this; - } - - // @@protoc_insertion_point(builder_scope:com.orbekk.protobuf.Response) } - - static { - defaultInstance = new Response(true); - defaultInstance.initFields(); + + @Override + public void startCancel() { } - - // @@protoc_insertion_point(class_scope:com.orbekk.protobuf.Response) - } - - private static com.google.protobuf.Descriptors.Descriptor - internal_static_com_orbekk_protobuf_Request_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_com_orbekk_protobuf_Request_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_com_orbekk_protobuf_Response_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_com_orbekk_protobuf_Response_fieldAccessorTable; - - public static com.google.protobuf.Descriptors.FileDescriptor - getDescriptor() { - return descriptor; - } - private static com.google.protobuf.Descriptors.FileDescriptor - descriptor; - static { - java.lang.String[] descriptorData = { - "\n+src/main/java/com/orbekk/protobuf/Rpc." + - "proto\022\023com.orbekk.protobuf\"d\n\007Request\022\031\n" + - "\021full_service_name\030\001 \001(\t\022\023\n\013method_name\030" + - "\002 \001(\t\022\025\n\rrequest_proto\030\003 \001(\014\022\022\n\nrequest_" + - "id\030\004 \001(\003\"\343\001\n\010Response\022\026\n\016response_proto\030" + - "\001 \001(\014\0222\n\005error\030\002 \001(\0162#.com.orbekk.protob" + - "uf.Response.Error\022\021\n\tapp_error\030\004 \001(\005\022\025\n\r" + - "error_message\030\003 \001(\t\022\022\n\nrequest_id\030\005 \001(\003\"" + - "M\n\005Error\022\023\n\017UNKNOWN_SERVICE\020\000\022\022\n\016UNKNOWN" + - "_METHOD\020\001\022\014\n\010CANCELED\020\002\022\r\n\tAPP_ERROR\020\003" - }; - com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = - new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { - public com.google.protobuf.ExtensionRegistry assignDescriptors( - com.google.protobuf.Descriptors.FileDescriptor root) { - descriptor = root; - internal_static_com_orbekk_protobuf_Request_descriptor = - getDescriptor().getMessageTypes().get(0); - internal_static_com_orbekk_protobuf_Request_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_com_orbekk_protobuf_Request_descriptor, - new java.lang.String[] { "FullServiceName", "MethodName", "RequestProto", "RequestId", }, - com.orbekk.protobuf.Rpc.Request.class, - com.orbekk.protobuf.Rpc.Request.Builder.class); - internal_static_com_orbekk_protobuf_Response_descriptor = - getDescriptor().getMessageTypes().get(1); - internal_static_com_orbekk_protobuf_Response_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_com_orbekk_protobuf_Response_descriptor, - new java.lang.String[] { "ResponseProto", "Error", "AppError", "ErrorMessage", "RequestId", }, - com.orbekk.protobuf.Rpc.Response.class, - com.orbekk.protobuf.Rpc.Response.Builder.class); - return null; - } - }; - com.google.protobuf.Descriptors.FileDescriptor - .internalBuildGeneratedFileFrom(descriptorData, - new com.google.protobuf.Descriptors.FileDescriptor[] { - }, assigner); - } - - // @@protoc_insertion_point(outer_class_scope) } |