http://git-wip-us.apache.org/repos/asf/bookkeeper/blob/0583175d/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookkeeperProtocol.java ---------------------------------------------------------------------- diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookkeeperProtocol.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookkeeperProtocol.java index b5c0008..07e4d67 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookkeeperProtocol.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookkeeperProtocol.java @@ -312,6 +312,10 @@ public final class BookkeeperProtocol { * <code>READ_LAC = 7;</code> */ READ_LAC(6, 7), + /** + * <code>GET_BOOKIE_INFO = 8;</code> + */ + GET_BOOKIE_INFO(7, 8), ; /** @@ -346,6 +350,10 @@ public final class BookkeeperProtocol { * <code>READ_LAC = 7;</code> */ public static final int READ_LAC_VALUE = 7; + /** + * <code>GET_BOOKIE_INFO = 8;</code> + */ + public static final int GET_BOOKIE_INFO_VALUE = 8; public final int getNumber() { return value; } @@ -359,6 +367,7 @@ public final class BookkeeperProtocol { case 5: return AUTH; case 6: return WRITE_LAC; case 7: return READ_LAC; + case 8: return GET_BOOKIE_INFO; default: return null; } } @@ -1108,6 +1117,19 @@ public final class BookkeeperProtocol { * <code>optional .ReadLacRequest readLacRequest = 104;</code> */ org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequestOrBuilder getReadLacRequestOrBuilder(); + + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + boolean hasGetBookieInfoRequest(); + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest getGetBookieInfoRequest(); + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequestOrBuilder getGetBookieInfoRequestOrBuilder(); } /** * Protobuf type {@code Request} @@ -1239,6 +1261,19 @@ public final class BookkeeperProtocol { bitField0_ |= 0x00000020; break; } + case 842: { + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.Builder subBuilder = null; + if (((bitField0_ & 0x00000040) == 0x00000040)) { + subBuilder = getBookieInfoRequest_.toBuilder(); + } + getBookieInfoRequest_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(getBookieInfoRequest_); + getBookieInfoRequest_ = subBuilder.buildPartial(); + } + bitField0_ |= 0x00000040; + break; + } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { @@ -1417,6 +1452,27 @@ public final class BookkeeperProtocol { return readLacRequest_; } + public static final int GETBOOKIEINFOREQUEST_FIELD_NUMBER = 105; + private org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest getBookieInfoRequest_; + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + public boolean hasGetBookieInfoRequest() { + return ((bitField0_ & 0x00000040) == 0x00000040); + } + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest getGetBookieInfoRequest() { + return getBookieInfoRequest_; + } + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequestOrBuilder getGetBookieInfoRequestOrBuilder() { + return getBookieInfoRequest_; + } + private void initFields() { header_ = org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.getDefaultInstance(); readRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadRequest.getDefaultInstance(); @@ -1424,6 +1480,7 @@ public final class BookkeeperProtocol { authRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage.getDefaultInstance(); writeLacRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.getDefaultInstance(); readLacRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.getDefaultInstance(); + getBookieInfoRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.getDefaultInstance(); } private byte memoizedIsInitialized = -1; public final boolean isInitialized() { @@ -1494,6 +1551,9 @@ public final class BookkeeperProtocol { if (((bitField0_ & 0x00000020) == 0x00000020)) { output.writeMessage(104, readLacRequest_); } + if (((bitField0_ & 0x00000040) == 0x00000040)) { + output.writeMessage(105, getBookieInfoRequest_); + } getUnknownFields().writeTo(output); } @@ -1527,6 +1587,10 @@ public final class BookkeeperProtocol { size += com.google.protobuf.CodedOutputStream .computeMessageSize(104, readLacRequest_); } + if (((bitField0_ & 0x00000040) == 0x00000040)) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(105, getBookieInfoRequest_); + } size += getUnknownFields().getSerializedSize(); memoizedSerializedSize = size; return size; @@ -1642,6 +1706,7 @@ public final class BookkeeperProtocol { getAuthRequestFieldBuilder(); getWriteLacRequestFieldBuilder(); getReadLacRequestFieldBuilder(); + getGetBookieInfoRequestFieldBuilder(); } } private static Builder create() { @@ -1686,6 +1751,12 @@ public final class BookkeeperProtocol { readLacRequestBuilder_.clear(); } bitField0_ = (bitField0_ & ~0x00000020); + if (getBookieInfoRequestBuilder_ == null) { + getBookieInfoRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.getDefaultInstance(); + } else { + getBookieInfoRequestBuilder_.clear(); + } + bitField0_ = (bitField0_ & ~0x00000040); return this; } @@ -1762,6 +1833,14 @@ public final class BookkeeperProtocol { } else { result.readLacRequest_ = readLacRequestBuilder_.build(); } + if (((from_bitField0_ & 0x00000040) == 0x00000040)) { + to_bitField0_ |= 0x00000040; + } + if (getBookieInfoRequestBuilder_ == null) { + result.getBookieInfoRequest_ = getBookieInfoRequest_; + } else { + result.getBookieInfoRequest_ = getBookieInfoRequestBuilder_.build(); + } result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -1796,6 +1875,9 @@ public final class BookkeeperProtocol { if (other.hasReadLacRequest()) { mergeReadLacRequest(other.getReadLacRequest()); } + if (other.hasGetBookieInfoRequest()) { + mergeGetBookieInfoRequest(other.getGetBookieInfoRequest()); + } this.mergeUnknownFields(other.getUnknownFields()); return this; } @@ -2593,6 +2675,122 @@ public final class BookkeeperProtocol { return readLacRequestBuilder_; } + private org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest getBookieInfoRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.getDefaultInstance(); + private com.google.protobuf.SingleFieldBuilder< + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest, org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequestOrBuilder> getBookieInfoRequestBuilder_; + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + public boolean hasGetBookieInfoRequest() { + return ((bitField0_ & 0x00000040) == 0x00000040); + } + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest getGetBookieInfoRequest() { + if (getBookieInfoRequestBuilder_ == null) { + return getBookieInfoRequest_; + } else { + return getBookieInfoRequestBuilder_.getMessage(); + } + } + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + public Builder setGetBookieInfoRequest(org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest value) { + if (getBookieInfoRequestBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + getBookieInfoRequest_ = value; + onChanged(); + } else { + getBookieInfoRequestBuilder_.setMessage(value); + } + bitField0_ |= 0x00000040; + return this; + } + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + public Builder setGetBookieInfoRequest( + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.Builder builderForValue) { + if (getBookieInfoRequestBuilder_ == null) { + getBookieInfoRequest_ = builderForValue.build(); + onChanged(); + } else { + getBookieInfoRequestBuilder_.setMessage(builderForValue.build()); + } + bitField0_ |= 0x00000040; + return this; + } + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + public Builder mergeGetBookieInfoRequest(org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest value) { + if (getBookieInfoRequestBuilder_ == null) { + if (((bitField0_ & 0x00000040) == 0x00000040) && + getBookieInfoRequest_ != org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.getDefaultInstance()) { + getBookieInfoRequest_ = + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.newBuilder(getBookieInfoRequest_).mergeFrom(value).buildPartial(); + } else { + getBookieInfoRequest_ = value; + } + onChanged(); + } else { + getBookieInfoRequestBuilder_.mergeFrom(value); + } + bitField0_ |= 0x00000040; + return this; + } + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + public Builder clearGetBookieInfoRequest() { + if (getBookieInfoRequestBuilder_ == null) { + getBookieInfoRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.getDefaultInstance(); + onChanged(); + } else { + getBookieInfoRequestBuilder_.clear(); + } + bitField0_ = (bitField0_ & ~0x00000040); + return this; + } + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.Builder getGetBookieInfoRequestBuilder() { + bitField0_ |= 0x00000040; + onChanged(); + return getGetBookieInfoRequestFieldBuilder().getBuilder(); + } + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequestOrBuilder getGetBookieInfoRequestOrBuilder() { + if (getBookieInfoRequestBuilder_ != null) { + return getBookieInfoRequestBuilder_.getMessageOrBuilder(); + } else { + return getBookieInfoRequest_; + } + } + /** + * <code>optional .GetBookieInfoRequest getBookieInfoRequest = 105;</code> + */ + private com.google.protobuf.SingleFieldBuilder< + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest, org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequestOrBuilder> + getGetBookieInfoRequestFieldBuilder() { + if (getBookieInfoRequestBuilder_ == null) { + getBookieInfoRequestBuilder_ = new com.google.protobuf.SingleFieldBuilder< + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest, org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequestOrBuilder>( + getGetBookieInfoRequest(), + getParentForChildren(), + isClean()); + getBookieInfoRequest_ = null; + } + return getBookieInfoRequestBuilder_; + } + // @@protoc_insertion_point(builder_scope:Request) } @@ -5303,139 +5501,47 @@ public final class BookkeeperProtocol { // @@protoc_insertion_point(class_scope:ReadLacRequest) } - public interface ResponseOrBuilder extends - // @@protoc_insertion_point(interface_extends:Response) + public interface GetBookieInfoRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:GetBookieInfoRequest) com.google.protobuf.MessageOrBuilder { /** - * <code>required .BKPacketHeader header = 1;</code> - */ - boolean hasHeader(); - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader getHeader(); - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeaderOrBuilder getHeaderOrBuilder(); - - /** - * <code>required .StatusCode status = 2;</code> - * - * <pre> - * EOK if the underlying request succeeded. Each individual response - * has a more meaningful status. EBADREQ if we have an unsupported request. - * </pre> - */ - boolean hasStatus(); - /** - * <code>required .StatusCode status = 2;</code> - * - * <pre> - * EOK if the underlying request succeeded. Each individual response - * has a more meaningful status. EBADREQ if we have an unsupported request. - * </pre> - */ - org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode getStatus(); - - /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> - */ - boolean hasReadResponse(); - /** - * <code>optional .ReadResponse readResponse = 100;</code> + * <code>optional int64 requested = 1;</code> * * <pre> - * Response + * bitwise OR of Flags * </pre> */ - org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse getReadResponse(); + boolean hasRequested(); /** - * <code>optional .ReadResponse readResponse = 100;</code> + * <code>optional int64 requested = 1;</code> * * <pre> - * Response + * bitwise OR of Flags * </pre> */ - org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponseOrBuilder getReadResponseOrBuilder(); - - /** - * <code>optional .AddResponse addResponse = 101;</code> - */ - boolean hasAddResponse(); - /** - * <code>optional .AddResponse addResponse = 101;</code> - */ - org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse getAddResponse(); - /** - * <code>optional .AddResponse addResponse = 101;</code> - */ - org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponseOrBuilder getAddResponseOrBuilder(); - - /** - * <code>optional .AuthMessage authResponse = 102;</code> - */ - boolean hasAuthResponse(); - /** - * <code>optional .AuthMessage authResponse = 102;</code> - */ - org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage getAuthResponse(); - /** - * <code>optional .AuthMessage authResponse = 102;</code> - */ - org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessageOrBuilder getAuthResponseOrBuilder(); - - /** - * <code>optional .WriteLacResponse writeLacResponse = 103;</code> - */ - boolean hasWriteLacResponse(); - /** - * <code>optional .WriteLacResponse writeLacResponse = 103;</code> - */ - org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse getWriteLacResponse(); - /** - * <code>optional .WriteLacResponse writeLacResponse = 103;</code> - */ - org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponseOrBuilder getWriteLacResponseOrBuilder(); - - /** - * <code>optional .ReadLacResponse readLacResponse = 104;</code> - */ - boolean hasReadLacResponse(); - /** - * <code>optional .ReadLacResponse readLacResponse = 104;</code> - */ - org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse getReadLacResponse(); - /** - * <code>optional .ReadLacResponse readLacResponse = 104;</code> - */ - org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponseOrBuilder getReadLacResponseOrBuilder(); + long getRequested(); } /** - * Protobuf type {@code Response} + * Protobuf type {@code GetBookieInfoRequest} */ - public static final class Response extends + public static final class GetBookieInfoRequest extends com.google.protobuf.GeneratedMessage implements - // @@protoc_insertion_point(message_implements:Response) - ResponseOrBuilder { - // Use Response.newBuilder() to construct. - private Response(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + // @@protoc_insertion_point(message_implements:GetBookieInfoRequest) + GetBookieInfoRequestOrBuilder { + // Use GetBookieInfoRequest.newBuilder() to construct. + private GetBookieInfoRequest(com.google.protobuf.GeneratedMessage.Builder<?> builder) { super(builder); this.unknownFields = builder.getUnknownFields(); } - private Response(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + private GetBookieInfoRequest(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } - private static final Response defaultInstance; - public static Response getDefaultInstance() { + private static final GetBookieInfoRequest defaultInstance; + public static GetBookieInfoRequest getDefaultInstance() { return defaultInstance; } - public Response getDefaultInstanceForType() { + public GetBookieInfoRequest getDefaultInstanceForType() { return defaultInstance; } @@ -5445,7 +5551,7 @@ public final class BookkeeperProtocol { getUnknownFields() { return this.unknownFields; } - private Response( + private GetBookieInfoRequest( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { @@ -5468,93 +5574,9 @@ public final class BookkeeperProtocol { } break; } - case 10: { - org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.Builder subBuilder = null; - if (((bitField0_ & 0x00000001) == 0x00000001)) { - subBuilder = header_.toBuilder(); - } - header_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.PARSER, extensionRegistry); - if (subBuilder != null) { - subBuilder.mergeFrom(header_); - header_ = subBuilder.buildPartial(); - } + case 8: { bitField0_ |= 0x00000001; - break; - } - case 16: { - int rawValue = input.readEnum(); - org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode value = org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode.valueOf(rawValue); - if (value == null) { - unknownFields.mergeVarintField(2, rawValue); - } else { - bitField0_ |= 0x00000002; - status_ = value; - } - break; - } - case 802: { - org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.Builder subBuilder = null; - if (((bitField0_ & 0x00000004) == 0x00000004)) { - subBuilder = readResponse_.toBuilder(); - } - readResponse_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.PARSER, extensionRegistry); - if (subBuilder != null) { - subBuilder.mergeFrom(readResponse_); - readResponse_ = subBuilder.buildPartial(); - } - bitField0_ |= 0x00000004; - break; - } - case 810: { - org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse.Builder subBuilder = null; - if (((bitField0_ & 0x00000008) == 0x00000008)) { - subBuilder = addResponse_.toBuilder(); - } - addResponse_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse.PARSER, extensionRegistry); - if (subBuilder != null) { - subBuilder.mergeFrom(addResponse_); - addResponse_ = subBuilder.buildPartial(); - } - bitField0_ |= 0x00000008; - break; - } - case 818: { - org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage.Builder subBuilder = null; - if (((bitField0_ & 0x00000010) == 0x00000010)) { - subBuilder = authResponse_.toBuilder(); - } - authResponse_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage.PARSER, extensionRegistry); - if (subBuilder != null) { - subBuilder.mergeFrom(authResponse_); - authResponse_ = subBuilder.buildPartial(); - } - bitField0_ |= 0x00000010; - break; - } - case 826: { - org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse.Builder subBuilder = null; - if (((bitField0_ & 0x00000020) == 0x00000020)) { - subBuilder = writeLacResponse_.toBuilder(); - } - writeLacResponse_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse.PARSER, extensionRegistry); - if (subBuilder != null) { - subBuilder.mergeFrom(writeLacResponse_); - writeLacResponse_ = subBuilder.buildPartial(); - } - bitField0_ |= 0x00000020; - break; - } - case 834: { - org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse.Builder subBuilder = null; - if (((bitField0_ & 0x00000040) == 0x00000040)) { - subBuilder = readLacResponse_.toBuilder(); - } - readLacResponse_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse.PARSER, extensionRegistry); - if (subBuilder != null) { - subBuilder.mergeFrom(readLacResponse_); - readLacResponse_ = subBuilder.buildPartial(); - } - bitField0_ |= 0x00000040; + requested_ = input.readInt64(); break; } } @@ -5571,376 +5593,228 @@ public final class BookkeeperProtocol { } public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { - return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_Response_descriptor; + return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_GetBookieInfoRequest_descriptor; } protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable() { - return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_Response_fieldAccessorTable + return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_GetBookieInfoRequest_fieldAccessorTable .ensureFieldAccessorsInitialized( - org.apache.bookkeeper.proto.BookkeeperProtocol.Response.class, org.apache.bookkeeper.proto.BookkeeperProtocol.Response.Builder.class); + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.class, org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.Builder.class); } - public static com.google.protobuf.Parser<Response> PARSER = - new com.google.protobuf.AbstractParser<Response>() { - public Response parsePartialFrom( + public static com.google.protobuf.Parser<GetBookieInfoRequest> PARSER = + new com.google.protobuf.AbstractParser<GetBookieInfoRequest>() { + public GetBookieInfoRequest parsePartialFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { - return new Response(input, extensionRegistry); + return new GetBookieInfoRequest(input, extensionRegistry); } }; @java.lang.Override - public com.google.protobuf.Parser<Response> getParserForType() { + public com.google.protobuf.Parser<GetBookieInfoRequest> getParserForType() { return PARSER; } - private int bitField0_; - public static final int HEADER_FIELD_NUMBER = 1; - private org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader header_; - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - public boolean hasHeader() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader getHeader() { - return header_; - } /** - * <code>required .BKPacketHeader header = 1;</code> + * Protobuf enum {@code GetBookieInfoRequest.Flags} */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeaderOrBuilder getHeaderOrBuilder() { - return header_; + public enum Flags + implements com.google.protobuf.ProtocolMessageEnum { + /** + * <code>TOTAL_DISK_CAPACITY = 1;</code> + */ + TOTAL_DISK_CAPACITY(0, 1), + /** + * <code>FREE_DISK_SPACE = 2;</code> + */ + FREE_DISK_SPACE(1, 2), + ; + + /** + * <code>TOTAL_DISK_CAPACITY = 1;</code> + */ + public static final int TOTAL_DISK_CAPACITY_VALUE = 1; + /** + * <code>FREE_DISK_SPACE = 2;</code> + */ + public static final int FREE_DISK_SPACE_VALUE = 2; + + + public final int getNumber() { return value; } + + public static Flags valueOf(int value) { + switch (value) { + case 1: return TOTAL_DISK_CAPACITY; + case 2: return FREE_DISK_SPACE; + default: return null; + } + } + + public static com.google.protobuf.Internal.EnumLiteMap<Flags> + internalGetValueMap() { + return internalValueMap; + } + private static com.google.protobuf.Internal.EnumLiteMap<Flags> + internalValueMap = + new com.google.protobuf.Internal.EnumLiteMap<Flags>() { + public Flags findValueByNumber(int number) { + return Flags.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 org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.getDescriptor().getEnumTypes().get(0); + } + + private static final Flags[] VALUES = values(); + + public static Flags 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 Flags(int index, int value) { + this.index = index; + this.value = value; + } + + // @@protoc_insertion_point(enum_scope:GetBookieInfoRequest.Flags) } - public static final int STATUS_FIELD_NUMBER = 2; - private org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode status_; + private int bitField0_; + public static final int REQUESTED_FIELD_NUMBER = 1; + private long requested_; /** - * <code>required .StatusCode status = 2;</code> + * <code>optional int64 requested = 1;</code> * * <pre> - * EOK if the underlying request succeeded. Each individual response - * has a more meaningful status. EBADREQ if we have an unsupported request. + * bitwise OR of Flags * </pre> */ - public boolean hasStatus() { - return ((bitField0_ & 0x00000002) == 0x00000002); + public boolean hasRequested() { + return ((bitField0_ & 0x00000001) == 0x00000001); } /** - * <code>required .StatusCode status = 2;</code> + * <code>optional int64 requested = 1;</code> * * <pre> - * EOK if the underlying request succeeded. Each individual response - * has a more meaningful status. EBADREQ if we have an unsupported request. + * bitwise OR of Flags * </pre> */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode getStatus() { - return status_; + public long getRequested() { + return requested_; } - public static final int READRESPONSE_FIELD_NUMBER = 100; - private org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse readResponse_; - /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> - */ - public boolean hasReadResponse() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse getReadResponse() { - return readResponse_; + private void initFields() { + requested_ = 0L; } - /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponseOrBuilder getReadResponseOrBuilder() { - return readResponse_; + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; } - public static final int ADDRESPONSE_FIELD_NUMBER = 101; - private org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse addResponse_; - /** - * <code>optional .AddResponse addResponse = 101;</code> - */ - public boolean hasAddResponse() { - return ((bitField0_ & 0x00000008) == 0x00000008); + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeInt64(1, requested_); + } + getUnknownFields().writeTo(output); } - /** - * <code>optional .AddResponse addResponse = 101;</code> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse getAddResponse() { - return addResponse_; + + 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 + .computeInt64Size(1, requested_); + } + size += getUnknownFields().getSerializedSize(); + memoizedSerializedSize = size; + return size; } - /** - * <code>optional .AddResponse addResponse = 101;</code> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponseOrBuilder getAddResponseOrBuilder() { - return addResponse_; + + private static final long serialVersionUID = 0L; + @java.lang.Override + protected java.lang.Object writeReplace() + throws java.io.ObjectStreamException { + return super.writeReplace(); } - public static final int AUTHRESPONSE_FIELD_NUMBER = 102; - private org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage authResponse_; - /** - * <code>optional .AuthMessage authResponse = 102;</code> - */ - public boolean hasAuthResponse() { - return ((bitField0_ & 0x00000010) == 0x00000010); + public static org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); } - /** - * <code>optional .AuthMessage authResponse = 102;</code> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage getAuthResponse() { - return authResponse_; + public static org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); } - /** - * <code>optional .AuthMessage authResponse = 102;</code> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessageOrBuilder getAuthResponseOrBuilder() { - return authResponse_; + public static org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); } - - public static final int WRITELACRESPONSE_FIELD_NUMBER = 103; - private org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse writeLacResponse_; - /** - * <code>optional .WriteLacResponse writeLacResponse = 103;</code> - */ - public boolean hasWriteLacResponse() { - return ((bitField0_ & 0x00000020) == 0x00000020); - } - /** - * <code>optional .WriteLacResponse writeLacResponse = 103;</code> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse getWriteLacResponse() { - return writeLacResponse_; - } - /** - * <code>optional .WriteLacResponse writeLacResponse = 103;</code> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponseOrBuilder getWriteLacResponseOrBuilder() { - return writeLacResponse_; - } - - public static final int READLACRESPONSE_FIELD_NUMBER = 104; - private org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse readLacResponse_; - /** - * <code>optional .ReadLacResponse readLacResponse = 104;</code> - */ - public boolean hasReadLacResponse() { - return ((bitField0_ & 0x00000040) == 0x00000040); - } - /** - * <code>optional .ReadLacResponse readLacResponse = 104;</code> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse getReadLacResponse() { - return readLacResponse_; - } - /** - * <code>optional .ReadLacResponse readLacResponse = 104;</code> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponseOrBuilder getReadLacResponseOrBuilder() { - return readLacResponse_; - } - - private void initFields() { - header_ = org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.getDefaultInstance(); - status_ = org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode.EOK; - readResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.getDefaultInstance(); - addResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse.getDefaultInstance(); - authResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage.getDefaultInstance(); - writeLacResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse.getDefaultInstance(); - readLacResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse.getDefaultInstance(); - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized == 1) return true; - if (isInitialized == 0) return false; - - if (!hasHeader()) { - memoizedIsInitialized = 0; - return false; - } - if (!hasStatus()) { - memoizedIsInitialized = 0; - return false; - } - if (!getHeader().isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - if (hasReadResponse()) { - if (!getReadResponse().isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - } - if (hasAddResponse()) { - if (!getAddResponse().isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - } - if (hasAuthResponse()) { - if (!getAuthResponse().isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - } - if (hasWriteLacResponse()) { - if (!getWriteLacResponse().isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - } - if (hasReadLacResponse()) { - if (!getReadLacResponse().isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - } - memoizedIsInitialized = 1; - return true; - } - - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - getSerializedSize(); - if (((bitField0_ & 0x00000001) == 0x00000001)) { - output.writeMessage(1, header_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeEnum(2, status_.getNumber()); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - output.writeMessage(100, readResponse_); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - output.writeMessage(101, addResponse_); - } - if (((bitField0_ & 0x00000010) == 0x00000010)) { - output.writeMessage(102, authResponse_); - } - if (((bitField0_ & 0x00000020) == 0x00000020)) { - output.writeMessage(103, writeLacResponse_); - } - if (((bitField0_ & 0x00000040) == 0x00000040)) { - output.writeMessage(104, readLacResponse_); - } - 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 - .computeMessageSize(1, header_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeEnumSize(2, status_.getNumber()); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(100, readResponse_); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(101, addResponse_); - } - if (((bitField0_ & 0x00000010) == 0x00000010)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(102, authResponse_); - } - if (((bitField0_ & 0x00000020) == 0x00000020)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(103, writeLacResponse_); - } - if (((bitField0_ & 0x00000040) == 0x00000040)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(104, readLacResponse_); - } - 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 org.apache.bookkeeper.proto.BookkeeperProtocol.Response parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data); - } - public static org.apache.bookkeeper.proto.BookkeeperProtocol.Response parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data, extensionRegistry); - } - public static org.apache.bookkeeper.proto.BookkeeperProtocol.Response parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data); - } - public static org.apache.bookkeeper.proto.BookkeeperProtocol.Response parseFrom( + public static org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest parseFrom( byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data, extensionRegistry); } - public static org.apache.bookkeeper.proto.BookkeeperProtocol.Response parseFrom(java.io.InputStream input) + public static org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest parseFrom(java.io.InputStream input) throws java.io.IOException { return PARSER.parseFrom(input); } - public static org.apache.bookkeeper.proto.BookkeeperProtocol.Response parseFrom( + public static org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest parseFrom( java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { return PARSER.parseFrom(input, extensionRegistry); } - public static org.apache.bookkeeper.proto.BookkeeperProtocol.Response parseDelimitedFrom(java.io.InputStream input) + public static org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException { return PARSER.parseDelimitedFrom(input); } - public static org.apache.bookkeeper.proto.BookkeeperProtocol.Response parseDelimitedFrom( + public static org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest parseDelimitedFrom( java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { return PARSER.parseDelimitedFrom(input, extensionRegistry); } - public static org.apache.bookkeeper.proto.BookkeeperProtocol.Response parseFrom( + public static org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest parseFrom( com.google.protobuf.CodedInputStream input) throws java.io.IOException { return PARSER.parseFrom(input); } - public static org.apache.bookkeeper.proto.BookkeeperProtocol.Response parseFrom( + public static org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest parseFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { @@ -5949,7 +5823,7 @@ public final class BookkeeperProtocol { public static Builder newBuilder() { return Builder.create(); } public Builder newBuilderForType() { return newBuilder(); } - public static Builder newBuilder(org.apache.bookkeeper.proto.BookkeeperProtocol.Response prototype) { + public static Builder newBuilder(org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest prototype) { return newBuilder().mergeFrom(prototype); } public Builder toBuilder() { return newBuilder(this); } @@ -5961,25 +5835,25 @@ public final class BookkeeperProtocol { return builder; } /** - * Protobuf type {@code Response} + * Protobuf type {@code GetBookieInfoRequest} */ public static final class Builder extends com.google.protobuf.GeneratedMessage.Builder<Builder> implements - // @@protoc_insertion_point(builder_implements:Response) - org.apache.bookkeeper.proto.BookkeeperProtocol.ResponseOrBuilder { + // @@protoc_insertion_point(builder_implements:GetBookieInfoRequest) + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequestOrBuilder { public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { - return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_Response_descriptor; + return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_GetBookieInfoRequest_descriptor; } protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable() { - return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_Response_fieldAccessorTable + return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_GetBookieInfoRequest_fieldAccessorTable .ensureFieldAccessorsInitialized( - org.apache.bookkeeper.proto.BookkeeperProtocol.Response.class, org.apache.bookkeeper.proto.BookkeeperProtocol.Response.Builder.class); + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.class, org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.Builder.class); } - // Construct using org.apache.bookkeeper.proto.BookkeeperProtocol.Response.newBuilder() + // Construct using org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.newBuilder() private Builder() { maybeForceBuilderInitialization(); } @@ -5991,12 +5865,6 @@ public final class BookkeeperProtocol { } private void maybeForceBuilderInitialization() { if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getHeaderFieldBuilder(); - getReadResponseFieldBuilder(); - getAddResponseFieldBuilder(); - getAuthResponseFieldBuilder(); - getWriteLacResponseFieldBuilder(); - getReadLacResponseFieldBuilder(); } } private static Builder create() { @@ -6005,44 +5873,8 @@ public final class BookkeeperProtocol { public Builder clear() { super.clear(); - if (headerBuilder_ == null) { - header_ = org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.getDefaultInstance(); - } else { - headerBuilder_.clear(); - } + requested_ = 0L; bitField0_ = (bitField0_ & ~0x00000001); - status_ = org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode.EOK; - bitField0_ = (bitField0_ & ~0x00000002); - if (readResponseBuilder_ == null) { - readResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.getDefaultInstance(); - } else { - readResponseBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000004); - if (addResponseBuilder_ == null) { - addResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse.getDefaultInstance(); - } else { - addResponseBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000008); - if (authResponseBuilder_ == null) { - authResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage.getDefaultInstance(); - } else { - authResponseBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000010); - if (writeLacResponseBuilder_ == null) { - writeLacResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse.getDefaultInstance(); - } else { - writeLacResponseBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000020); - if (readLacResponseBuilder_ == null) { - readLacResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse.getDefaultInstance(); - } else { - readLacResponseBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000040); return this; } @@ -6052,161 +5884,53 @@ public final class BookkeeperProtocol { public com.google.protobuf.Descriptors.Descriptor getDescriptorForType() { - return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_Response_descriptor; + return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_GetBookieInfoRequest_descriptor; } - public org.apache.bookkeeper.proto.BookkeeperProtocol.Response getDefaultInstanceForType() { - return org.apache.bookkeeper.proto.BookkeeperProtocol.Response.getDefaultInstance(); + public org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest getDefaultInstanceForType() { + return org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.getDefaultInstance(); } - public org.apache.bookkeeper.proto.BookkeeperProtocol.Response build() { - org.apache.bookkeeper.proto.BookkeeperProtocol.Response result = buildPartial(); + public org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest build() { + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest result = buildPartial(); if (!result.isInitialized()) { throw newUninitializedMessageException(result); } return result; } - public org.apache.bookkeeper.proto.BookkeeperProtocol.Response buildPartial() { - org.apache.bookkeeper.proto.BookkeeperProtocol.Response result = new org.apache.bookkeeper.proto.BookkeeperProtocol.Response(this); + public org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest buildPartial() { + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest result = new org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest(this); int from_bitField0_ = bitField0_; int to_bitField0_ = 0; if (((from_bitField0_ & 0x00000001) == 0x00000001)) { to_bitField0_ |= 0x00000001; } - if (headerBuilder_ == null) { - result.header_ = header_; - } else { - result.header_ = headerBuilder_.build(); - } - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.status_ = status_; - if (((from_bitField0_ & 0x00000004) == 0x00000004)) { - to_bitField0_ |= 0x00000004; - } - if (readResponseBuilder_ == null) { - result.readResponse_ = readResponse_; - } else { - result.readResponse_ = readResponseBuilder_.build(); - } - if (((from_bitField0_ & 0x00000008) == 0x00000008)) { - to_bitField0_ |= 0x00000008; - } - if (addResponseBuilder_ == null) { - result.addResponse_ = addResponse_; - } else { - result.addResponse_ = addResponseBuilder_.build(); - } - if (((from_bitField0_ & 0x00000010) == 0x00000010)) { - to_bitField0_ |= 0x00000010; - } - if (authResponseBuilder_ == null) { - result.authResponse_ = authResponse_; - } else { - result.authResponse_ = authResponseBuilder_.build(); - } - if (((from_bitField0_ & 0x00000020) == 0x00000020)) { - to_bitField0_ |= 0x00000020; - } - if (writeLacResponseBuilder_ == null) { - result.writeLacResponse_ = writeLacResponse_; - } else { - result.writeLacResponse_ = writeLacResponseBuilder_.build(); - } - if (((from_bitField0_ & 0x00000040) == 0x00000040)) { - to_bitField0_ |= 0x00000040; - } - if (readLacResponseBuilder_ == null) { - result.readLacResponse_ = readLacResponse_; - } else { - result.readLacResponse_ = readLacResponseBuilder_.build(); - } + result.requested_ = requested_; result.bitField0_ = to_bitField0_; onBuilt(); return result; } public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof org.apache.bookkeeper.proto.BookkeeperProtocol.Response) { - return mergeFrom((org.apache.bookkeeper.proto.BookkeeperProtocol.Response)other); + if (other instanceof org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest) { + return mergeFrom((org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest)other); } else { super.mergeFrom(other); return this; } } - public Builder mergeFrom(org.apache.bookkeeper.proto.BookkeeperProtocol.Response other) { - if (other == org.apache.bookkeeper.proto.BookkeeperProtocol.Response.getDefaultInstance()) return this; - if (other.hasHeader()) { - mergeHeader(other.getHeader()); - } - if (other.hasStatus()) { - setStatus(other.getStatus()); - } - if (other.hasReadResponse()) { - mergeReadResponse(other.getReadResponse()); - } - if (other.hasAddResponse()) { - mergeAddResponse(other.getAddResponse()); - } - if (other.hasAuthResponse()) { - mergeAuthResponse(other.getAuthResponse()); - } - if (other.hasWriteLacResponse()) { - mergeWriteLacResponse(other.getWriteLacResponse()); - } - if (other.hasReadLacResponse()) { - mergeReadLacResponse(other.getReadLacResponse()); + public Builder mergeFrom(org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest other) { + if (other == org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest.getDefaultInstance()) return this; + if (other.hasRequested()) { + setRequested(other.getRequested()); } this.mergeUnknownFields(other.getUnknownFields()); return this; } public final boolean isInitialized() { - if (!hasHeader()) { - - return false; - } - if (!hasStatus()) { - - return false; - } - if (!getHeader().isInitialized()) { - - return false; - } - if (hasReadResponse()) { - if (!getReadResponse().isInitialized()) { - - return false; - } - } - if (hasAddResponse()) { - if (!getAddResponse().isInitialized()) { - - return false; - } - } - if (hasAuthResponse()) { - if (!getAuthResponse().isInitialized()) { - - return false; - } - } - if (hasWriteLacResponse()) { - if (!getWriteLacResponse().isInitialized()) { - - return false; - } - } - if (hasReadLacResponse()) { - if (!getReadLacResponse().isInitialized()) { - - return false; - } - } return true; } @@ -6214,11 +5938,11 @@ public final class BookkeeperProtocol { com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { - org.apache.bookkeeper.proto.BookkeeperProtocol.Response parsedMessage = null; + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest parsedMessage = null; try { parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); } catch (com.google.protobuf.InvalidProtocolBufferException e) { - parsedMessage = (org.apache.bookkeeper.proto.BookkeeperProtocol.Response) e.getUnfinishedMessage(); + parsedMessage = (org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoRequest) e.getUnfinishedMessage(); throw e; } finally { if (parsedMessage != null) { @@ -6229,168 +5953,1238 @@ public final class BookkeeperProtocol { } private int bitField0_; - private org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader header_ = org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader, org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeaderOrBuilder> headerBuilder_; - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - public boolean hasHeader() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader getHeader() { - if (headerBuilder_ == null) { - return header_; - } else { - return headerBuilder_.getMessage(); - } - } - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - public Builder setHeader(org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader value) { - if (headerBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - header_ = value; - onChanged(); - } else { - headerBuilder_.setMessage(value); - } - bitField0_ |= 0x00000001; - return this; - } - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - public Builder setHeader( - org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.Builder builderForValue) { - if (headerBuilder_ == null) { - header_ = builderForValue.build(); - onChanged(); - } else { - headerBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000001; - return this; - } - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - public Builder mergeHeader(org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader value) { - if (headerBuilder_ == null) { - if (((bitField0_ & 0x00000001) == 0x00000001) && - header_ != org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.getDefaultInstance()) { - header_ = - org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.newBuilder(header_).mergeFrom(value).buildPartial(); - } else { - header_ = value; - } - onChanged(); - } else { - headerBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000001; - return this; - } - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - public Builder clearHeader() { - if (headerBuilder_ == null) { - header_ = org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.getDefaultInstance(); - onChanged(); - } else { - headerBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - return this; - } - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.Builder getHeaderBuilder() { - bitField0_ |= 0x00000001; - onChanged(); - return getHeaderFieldBuilder().getBuilder(); - } - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeaderOrBuilder getHeaderOrBuilder() { - if (headerBuilder_ != null) { - return headerBuilder_.getMessageOrBuilder(); - } else { - return header_; - } - } - /** - * <code>required .BKPacketHeader header = 1;</code> - */ - private com.google.protobuf.SingleFieldBuilder< - org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader, org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeaderOrBuilder> - getHeaderFieldBuilder() { - if (headerBuilder_ == null) { - headerBuilder_ = new com.google.protobuf.SingleFieldBuilder< - org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader, org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeaderOrBuilder>( - getHeader(), - getParentForChildren(), - isClean()); - header_ = null; - } - return headerBuilder_; - } - - private org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode status_ = org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode.EOK; + private long requested_ ; /** - * <code>required .StatusCode status = 2;</code> + * <code>optional int64 requested = 1;</code> * * <pre> - * EOK if the underlying request succeeded. Each individual response - * has a more meaningful status. EBADREQ if we have an unsupported request. + * bitwise OR of Flags * </pre> */ - public boolean hasStatus() { - return ((bitField0_ & 0x00000002) == 0x00000002); + public boolean hasRequested() { + return ((bitField0_ & 0x00000001) == 0x00000001); } /** - * <code>required .StatusCode status = 2;</code> + * <code>optional int64 requested = 1;</code> * * <pre> - * EOK if the underlying request succeeded. Each individual response - * has a more meaningful status. EBADREQ if we have an unsupported request. + * bitwise OR of Flags * </pre> */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode getStatus() { - return status_; + public long getRequested() { + return requested_; } /** - * <code>required .StatusCode status = 2;</code> + * <code>optional int64 requested = 1;</code> * * <pre> - * EOK if the underlying request succeeded. Each individual response - * has a more meaningful status. EBADREQ if we have an unsupported request. + * bitwise OR of Flags * </pre> */ - public Builder setStatus(org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000002; - status_ = value; + public Builder setRequested(long value) { + bitField0_ |= 0x00000001; + requested_ = value; onChanged(); return this; } /** - * <code>required .StatusCode status = 2;</code> + * <code>optional int64 requested = 1;</code> * * <pre> - * EOK if the underlying request succeeded. Each individual response - * has a more meaningful status. EBADREQ if we have an unsupported request. + * bitwise OR of Flags + * </pre> + */ + public Builder clearRequested() { + bitField0_ = (bitField0_ & ~0x00000001); + requested_ = 0L; + onChanged(); + return this; + } + + // @@protoc_insertion_point(builder_scope:GetBookieInfoRequest) + } + + static { + defaultInstance = new GetBookieInfoRequest(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:GetBookieInfoRequest) + } + + public interface ResponseOrBuilder extends + // @@protoc_insertion_point(interface_extends:Response) + com.google.protobuf.MessageOrBuilder { + + /** + * <code>required .BKPacketHeader header = 1;</code> + */ + boolean hasHeader(); + /** + * <code>required .BKPacketHeader header = 1;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader getHeader(); + /** + * <code>required .BKPacketHeader header = 1;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeaderOrBuilder getHeaderOrBuilder(); + + /** + * <code>required .StatusCode status = 2;</code> + * + * <pre> + * EOK if the underlying request succeeded. Each individual response + * has a more meaningful status. EBADREQ if we have an unsupported request. + * </pre> + */ + boolean hasStatus(); + /** + * <code>required .StatusCode status = 2;</code> + * + * <pre> + * EOK if the underlying request succeeded. Each individual response + * has a more meaningful status. EBADREQ if we have an unsupported request. + * </pre> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode getStatus(); + + /** + * <code>optional .ReadResponse readResponse = 100;</code> + * + * <pre> + * Response + * </pre> + */ + boolean hasReadResponse(); + /** + * <code>optional .ReadResponse readResponse = 100;</code> + * + * <pre> + * Response + * </pre> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse getReadResponse(); + /** + * <code>optional .ReadResponse readResponse = 100;</code> + * + * <pre> + * Response + * </pre> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponseOrBuilder getReadResponseOrBuilder(); + + /** + * <code>optional .AddResponse addResponse = 101;</code> + */ + boolean hasAddResponse(); + /** + * <code>optional .AddResponse addResponse = 101;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse getAddResponse(); + /** + * <code>optional .AddResponse addResponse = 101;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponseOrBuilder getAddResponseOrBuilder(); + + /** + * <code>optional .AuthMessage authResponse = 102;</code> + */ + boolean hasAuthResponse(); + /** + * <code>optional .AuthMessage authResponse = 102;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage getAuthResponse(); + /** + * <code>optional .AuthMessage authResponse = 102;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessageOrBuilder getAuthResponseOrBuilder(); + + /** + * <code>optional .WriteLacResponse writeLacResponse = 103;</code> + */ + boolean hasWriteLacResponse(); + /** + * <code>optional .WriteLacResponse writeLacResponse = 103;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse getWriteLacResponse(); + /** + * <code>optional .WriteLacResponse writeLacResponse = 103;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponseOrBuilder getWriteLacResponseOrBuilder(); + + /** + * <code>optional .ReadLacResponse readLacResponse = 104;</code> + */ + boolean hasReadLacResponse(); + /** + * <code>optional .ReadLacResponse readLacResponse = 104;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse getReadLacResponse(); + /** + * <code>optional .ReadLacResponse readLacResponse = 104;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponseOrBuilder getReadLacResponseOrBuilder(); + + /** + * <code>optional .GetBookieInfoResponse getBookieInfoResponse = 105;</code> + */ + boolean hasGetBookieInfoResponse(); + /** + * <code>optional .GetBookieInfoResponse getBookieInfoResponse = 105;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoResponse getGetBookieInfoResponse(); + /** + * <code>optional .GetBookieInfoResponse getBookieInfoResponse = 105;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoResponseOrBuilder getGetBookieInfoResponseOrBuilder(); + } + /** + * Protobuf type {@code Response} + */ + public static final class Response extends + com.google.protobuf.GeneratedMessage implements + // @@protoc_insertion_point(message_implements:Response) + ResponseOrBuilder { + // Use Response.newBuilder() to construct. + private Response(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private Response(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final Response defaultInstance; + public static Response getDefaultInstance() { + return defaultInstance; + } + + public Response getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private Response( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + initFields(); + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField(input, unknownFields, + extensionRegistry, tag)) { + done = true; + } + break; + } + case 10: { + org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.Builder subBuilder = null; + if (((bitField0_ & 0x00000001) == 0x00000001)) { + subBuilder = header_.toBuilder(); + } + header_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(header_); + header_ = subBuilder.buildPartial(); + } + bitField0_ |= 0x00000001; + break; + } + case 16: { + int rawValue = input.readEnum(); + org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode value = org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode.valueOf(rawValue); + if (value == null) { + unknownFields.mergeVarintField(2, rawValue); + } else { + bitField0_ |= 0x00000002; + status_ = value; + } + break; + } + case 802: { + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.Builder subBuilder = null; + if (((bitField0_ & 0x00000004) == 0x00000004)) { + subBuilder = readResponse_.toBuilder(); + } + readResponse_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(readResponse_); + readResponse_ = subBuilder.buildPartial(); + } + bitField0_ |= 0x00000004; + break; + } + case 810: { + org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse.Builder subBuilder = null; + if (((bitField0_ & 0x00000008) == 0x00000008)) { + subBuilder = addResponse_.toBuilder(); + } + addResponse_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(addResponse_); + addResponse_ = subBuilder.buildPartial(); + } + bitField0_ |= 0x00000008; + break; + } + case 818: { + org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage.Builder subBuilder = null; + if (((bitField0_ & 0x00000010) == 0x00000010)) { + subBuilder = authResponse_.toBuilder(); + } + authResponse_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(authResponse_); + authResponse_ = subBuilder.buildPartial(); + } + bitField0_ |= 0x00000010; + break; + } + case 826: { + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse.Builder subBuilder = null; + if (((bitField0_ & 0x00000020) == 0x00000020)) { + subBuilder = writeLacResponse_.toBuilder(); + } + writeLacResponse_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(writeLacResponse_); + writeLacResponse_ = subBuilder.buildPartial(); + } + bitField0_ |= 0x00000020; + break; + } + case 834: { + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse.Builder subBuilder = null; + if (((bitField0_ & 0x00000040) == 0x00000040)) { + subBuilder = readLacResponse_.toBuilder(); + } + readLacResponse_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(readLacResponse_); + readLacResponse_ = subBuilder.buildPartial(); + } + bitField0_ |= 0x00000040; + break; + } + case 842: { + org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoResponse.Builder subBuilder = null; + if (((bitField0_ & 0x00000080) == 0x00000080)) { + subBuilder = getBookieInfoResponse_.toBuilder(); + } + getBookieInfoResponse_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoResponse.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(getBookieInfoResponse_); + getBookieInfoResponse_ = subBuilder.buildPartial(); + } + bitField0_ |= 0x00000080; + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_Response_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_Response_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.bookkeeper.proto.BookkeeperProtocol.Response.class, org.apache.bookkeeper.proto.BookkeeperProtocol.Response.Builder.class); + } + + public static com.google.protobuf.Parser<Response> PARSER = + new com.google.protobuf.AbstractParser<Response>() { + public Response parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new Response(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<Response> getParserForType() { + return PARSER; + } + + private int bitField0_; + public static final int HEADER_FIELD_NUMBER = 1; + private org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader header_; + /** + * <code>required .BKPacketHeader header = 1;</code> + */ + public boolean hasHeader() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required .BKPacketHeader header = 1;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader getHeader() { + return header_; + } + /** + * <code>required .BKPacketHeader header = 1;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeaderOrBuilder getHeaderOrBuilder() { + return header_; + } + + public static final int STATUS_FIELD_NUMBER = 2; + private org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode status_; + /** + * <code>required .StatusCode status = 2;</code> + * + * <pre> + * EOK if the underlying request succeeded. Each individual response + * has a more meaningful status. EBADREQ if we have an unsupported request. + * </pre> + */ + public boolean hasStatus() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>required .StatusCode status = 2;</code> + * + * <pre> + * EOK if the underlying request succeeded. Each individual response + * has a more meaningful status. EBADREQ if we have an unsupported request. + * </pre> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode getStatus() { + return status_; + } + + public static final int READRESPONSE_FIELD_NUMBER = 100; + private org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse readResponse_; + /** + * <code>optional .ReadResponse readResponse = 100;</code> + * + * <pre> + * Response + * </pre> + */ + public boolean hasReadResponse() { + return ((bitField0_ & 0x00000004) == 0x00000004); + } + /** + * <code>optional .ReadResponse readResponse = 100;</code> + * + * <pre> + * Response + * </pre> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse getReadResponse() { + return readResponse_; + } + /** + * <code>optional .ReadResponse readResponse = 100;</code> + * + * <pre> + * Response + * </pre> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponseOrBuilder getReadResponseOrBuilder() { + return readResponse_; + } + + public static final int ADDRESPONSE_FIELD_NUMBER = 101; + private org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse addResponse_; + /** + * <code>optional .AddResponse addResponse = 101;</code> + */ + public boolean hasAddResponse() { + return ((bitField0_ & 0x00000008) == 0x00000008); + } + /** + * <code>optional .AddResponse addResponse = 101;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse getAddResponse() { + return addResponse_; + } + /** + * <code>optional .AddResponse addResponse = 101;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponseOrBuilder getAddResponseOrBuilder() { + return addResponse_; + } + + public static final int AUTHRESPONSE_FIELD_NUMBER = 102; + private org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage authResponse_; + /** + * <code>optional .AuthMessage authResponse = 102;</code> + */ + public boolean hasAuthResponse() { + return ((bitField0_ & 0x00000010) == 0x00000010); + } + /** + * <code>optional .AuthMessage authResponse = 102;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage getAuthResponse() { + return authResponse_; + } + /** + * <code>optional .AuthMessage authResponse = 102;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessageOrBuilder getAuthResponseOrBuilder() { + return authResponse_; + } + + public static final int WRITELACRESPONSE_FIELD_NUMBER = 103; + private org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse writeLacResponse_; + /** + * <code>optional .WriteLacResponse writeLacResponse = 103;</code> + */ + public boolean hasWriteLacResponse() { + return ((bitField0_ & 0x00000020) == 0x00000020); + } + /** + * <code>optional .WriteLacResponse writeLacResponse = 103;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse getWriteLacResponse() { + return writeLacResponse_; + } + /** + * <code>optional .WriteLacResponse writeLacResponse = 103;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponseOrBuilder getWriteLacResponseOrBuilder() { + return writeLacResponse_; + } + + public static final int READLACRESPONSE_FIELD_NUMBER = 104; + private org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse readLacResponse_; + /** + * <code>optional .ReadLacResponse readLacResponse = 104;</code> + */ + public boolean hasReadLacResponse() { + return ((bitField0_ & 0x00000040) == 0x00000040); + } + /** + * <code>optional .ReadLacResponse readLacResponse = 104;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse getReadLacResponse() { + return readLacResponse_; + } + /** + * <code>optional .ReadLacResponse readLacResponse = 104;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponseOrBuilder getReadLacResponseOrBuilder() { + return readLacResponse_; + } + + public static final int GETBOOKIEINFORESPONSE_FIELD_NUMBER = 105; + private org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoResponse getBookieInfoResponse_; + /** + * <code>optional .GetBookieInfoResponse getBookieInfoResponse = 105;</code> + */ + public boolean hasGetBookieInfoResponse() { + return ((bitField0_ & 0x00000080) == 0x00000080); + } + /** + * <code>optional .GetBookieInfoResponse getBookieInfoResponse = 105;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoResponse getGetBookieInfoResponse() { + return getBookieInfoResponse_; + } + /** + * <code>optional .GetBookieInfoResponse getBookieInfoResponse = 105;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoResponseOrBuilder getGetBookieInfoResponseOrBuilder() { + return getBookieInfoResponse_; + } + + private void initFields() { + header_ = org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.getDefaultInstance(); + status_ = org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode.EOK; + readResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.getDefaultInstance(); + addResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse.getDefaultInstance(); + authResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage.getDefaultInstance(); + writeLacResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacResponse.getDefaultInstance(); + readLacResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacResponse.getDefaultInstance(); + getBookieInfoResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.GetBookieInfoResponse.getDefaultInstance(); + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + if (!hasHeader()) { + memoizedIsInitialized = 0; + return false; + } + if (!hasStatus()) { + memoizedIsInitialized = 0; + return false; + } + if (!getHeader().isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + if (hasReadResponse()) { + if (!getReadResponse().isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + } + if (hasAddResponse()) { + if (!getAddResponse().isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + } + if (hasAuthResponse()) { + if (!getAuthResponse().isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + } + if (hasWriteLacResponse()) { + if (!getWriteLacResponse().isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + } + if (hasReadLacResponse()) { + if (!getReadLacResponse().isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + } + if (hasGetBookieInfoResponse()) { + if (!getGetBookieInfoResponse().isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + } + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeMessage(1, header_); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + output.writeEnum(2, status_.getNumber()); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { + output.writeMessage(100, readResponse_); + } + if (((bitField0_ & 0x00000008) == 0x00000008)) { + output.writeMessage(101, addResponse_); + } + if (((bitField0_ & 0x00000010) == 0x00000010)) { + output.writeMessage(102, authResponse_); + } + if (((bitField0_ & 0x00000020) == 0x00000020)) { + output.writeMessage(103, writeLacResponse_); + } + if (((bitField0_ & 0x00000040) == 0x00000040)) { + output.writeMessage(104, readLacResponse_); + } + if (((bitField0_ & 0x00000080) == 0x00000080)) { + output.writeMessage(105, getBookieInfoResponse_); + } + 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.CodedOutputSt
<TRUNCATED>
