http://git-wip-us.apache.org/repos/asf/bookkeeper/blob/c813b3d3/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 5fedfff..b5c0008 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 @@ -304,6 +304,14 @@ public final class BookkeeperProtocol { * <code>AUTH = 5;</code> */ AUTH(4, 5), + /** + * <code>WRITE_LAC = 6;</code> + */ + WRITE_LAC(5, 6), + /** + * <code>READ_LAC = 7;</code> + */ + READ_LAC(6, 7), ; /** @@ -330,6 +338,14 @@ public final class BookkeeperProtocol { * <code>AUTH = 5;</code> */ public static final int AUTH_VALUE = 5; + /** + * <code>WRITE_LAC = 6;</code> + */ + public static final int WRITE_LAC_VALUE = 6; + /** + * <code>READ_LAC = 7;</code> + */ + public static final int READ_LAC_VALUE = 7; public final int getNumber() { return value; } @@ -341,6 +357,8 @@ public final class BookkeeperProtocol { case 3: return RANGE_READ_ENTRY; case 4: return RANGE_ADD_ENTRY; case 5: return AUTH; + case 6: return WRITE_LAC; + case 7: return READ_LAC; default: return null; } } @@ -1064,6 +1082,32 @@ public final class BookkeeperProtocol { * <code>optional .AuthMessage authRequest = 102;</code> */ org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessageOrBuilder getAuthRequestOrBuilder(); + + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + boolean hasWriteLacRequest(); + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest getWriteLacRequest(); + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequestOrBuilder getWriteLacRequestOrBuilder(); + + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + boolean hasReadLacRequest(); + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest getReadLacRequest(); + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequestOrBuilder getReadLacRequestOrBuilder(); } /** * Protobuf type {@code Request} @@ -1169,6 +1213,32 @@ public final class BookkeeperProtocol { bitField0_ |= 0x00000008; break; } + case 826: { + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.Builder subBuilder = null; + if (((bitField0_ & 0x00000010) == 0x00000010)) { + subBuilder = writeLacRequest_.toBuilder(); + } + writeLacRequest_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(writeLacRequest_); + writeLacRequest_ = subBuilder.buildPartial(); + } + bitField0_ |= 0x00000010; + break; + } + case 834: { + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.Builder subBuilder = null; + if (((bitField0_ & 0x00000020) == 0x00000020)) { + subBuilder = readLacRequest_.toBuilder(); + } + readLacRequest_ = input.readMessage(org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(readLacRequest_); + readLacRequest_ = subBuilder.buildPartial(); + } + bitField0_ |= 0x00000020; + break; + } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { @@ -1305,11 +1375,55 @@ public final class BookkeeperProtocol { return authRequest_; } + public static final int WRITELACREQUEST_FIELD_NUMBER = 103; + private org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest writeLacRequest_; + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + public boolean hasWriteLacRequest() { + return ((bitField0_ & 0x00000010) == 0x00000010); + } + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest getWriteLacRequest() { + return writeLacRequest_; + } + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequestOrBuilder getWriteLacRequestOrBuilder() { + return writeLacRequest_; + } + + public static final int READLACREQUEST_FIELD_NUMBER = 104; + private org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest readLacRequest_; + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + public boolean hasReadLacRequest() { + return ((bitField0_ & 0x00000020) == 0x00000020); + } + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest getReadLacRequest() { + return readLacRequest_; + } + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequestOrBuilder getReadLacRequestOrBuilder() { + return readLacRequest_; + } + private void initFields() { header_ = org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.getDefaultInstance(); readRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadRequest.getDefaultInstance(); addRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.AddRequest.getDefaultInstance(); authRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage.getDefaultInstance(); + writeLacRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.getDefaultInstance(); + readLacRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.getDefaultInstance(); } private byte memoizedIsInitialized = -1; public final boolean isInitialized() { @@ -1343,6 +1457,18 @@ public final class BookkeeperProtocol { return false; } } + if (hasWriteLacRequest()) { + if (!getWriteLacRequest().isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + } + if (hasReadLacRequest()) { + if (!getReadLacRequest().isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + } memoizedIsInitialized = 1; return true; } @@ -1362,6 +1488,12 @@ public final class BookkeeperProtocol { if (((bitField0_ & 0x00000008) == 0x00000008)) { output.writeMessage(102, authRequest_); } + if (((bitField0_ & 0x00000010) == 0x00000010)) { + output.writeMessage(103, writeLacRequest_); + } + if (((bitField0_ & 0x00000020) == 0x00000020)) { + output.writeMessage(104, readLacRequest_); + } getUnknownFields().writeTo(output); } @@ -1387,6 +1519,14 @@ public final class BookkeeperProtocol { size += com.google.protobuf.CodedOutputStream .computeMessageSize(102, authRequest_); } + if (((bitField0_ & 0x00000010) == 0x00000010)) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(103, writeLacRequest_); + } + if (((bitField0_ & 0x00000020) == 0x00000020)) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(104, readLacRequest_); + } size += getUnknownFields().getSerializedSize(); memoizedSerializedSize = size; return size; @@ -1500,6 +1640,8 @@ public final class BookkeeperProtocol { getReadRequestFieldBuilder(); getAddRequestFieldBuilder(); getAuthRequestFieldBuilder(); + getWriteLacRequestFieldBuilder(); + getReadLacRequestFieldBuilder(); } } private static Builder create() { @@ -1532,6 +1674,18 @@ public final class BookkeeperProtocol { authRequestBuilder_.clear(); } bitField0_ = (bitField0_ & ~0x00000008); + if (writeLacRequestBuilder_ == null) { + writeLacRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.getDefaultInstance(); + } else { + writeLacRequestBuilder_.clear(); + } + bitField0_ = (bitField0_ & ~0x00000010); + if (readLacRequestBuilder_ == null) { + readLacRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.getDefaultInstance(); + } else { + readLacRequestBuilder_.clear(); + } + bitField0_ = (bitField0_ & ~0x00000020); return this; } @@ -1592,6 +1746,22 @@ public final class BookkeeperProtocol { } else { result.authRequest_ = authRequestBuilder_.build(); } + if (((from_bitField0_ & 0x00000010) == 0x00000010)) { + to_bitField0_ |= 0x00000010; + } + if (writeLacRequestBuilder_ == null) { + result.writeLacRequest_ = writeLacRequest_; + } else { + result.writeLacRequest_ = writeLacRequestBuilder_.build(); + } + if (((from_bitField0_ & 0x00000020) == 0x00000020)) { + to_bitField0_ |= 0x00000020; + } + if (readLacRequestBuilder_ == null) { + result.readLacRequest_ = readLacRequest_; + } else { + result.readLacRequest_ = readLacRequestBuilder_.build(); + } result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -1620,6 +1790,12 @@ public final class BookkeeperProtocol { if (other.hasAuthRequest()) { mergeAuthRequest(other.getAuthRequest()); } + if (other.hasWriteLacRequest()) { + mergeWriteLacRequest(other.getWriteLacRequest()); + } + if (other.hasReadLacRequest()) { + mergeReadLacRequest(other.getReadLacRequest()); + } this.mergeUnknownFields(other.getUnknownFields()); return this; } @@ -1651,6 +1827,18 @@ public final class BookkeeperProtocol { return false; } } + if (hasWriteLacRequest()) { + if (!getWriteLacRequest().isInitialized()) { + + return false; + } + } + if (hasReadLacRequest()) { + if (!getReadLacRequest().isInitialized()) { + + return false; + } + } return true; } @@ -2173,6 +2361,238 @@ public final class BookkeeperProtocol { return authRequestBuilder_; } + private org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest writeLacRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.getDefaultInstance(); + private com.google.protobuf.SingleFieldBuilder< + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest, org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequestOrBuilder> writeLacRequestBuilder_; + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + public boolean hasWriteLacRequest() { + return ((bitField0_ & 0x00000010) == 0x00000010); + } + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest getWriteLacRequest() { + if (writeLacRequestBuilder_ == null) { + return writeLacRequest_; + } else { + return writeLacRequestBuilder_.getMessage(); + } + } + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + public Builder setWriteLacRequest(org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest value) { + if (writeLacRequestBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + writeLacRequest_ = value; + onChanged(); + } else { + writeLacRequestBuilder_.setMessage(value); + } + bitField0_ |= 0x00000010; + return this; + } + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + public Builder setWriteLacRequest( + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.Builder builderForValue) { + if (writeLacRequestBuilder_ == null) { + writeLacRequest_ = builderForValue.build(); + onChanged(); + } else { + writeLacRequestBuilder_.setMessage(builderForValue.build()); + } + bitField0_ |= 0x00000010; + return this; + } + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + public Builder mergeWriteLacRequest(org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest value) { + if (writeLacRequestBuilder_ == null) { + if (((bitField0_ & 0x00000010) == 0x00000010) && + writeLacRequest_ != org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.getDefaultInstance()) { + writeLacRequest_ = + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.newBuilder(writeLacRequest_).mergeFrom(value).buildPartial(); + } else { + writeLacRequest_ = value; + } + onChanged(); + } else { + writeLacRequestBuilder_.mergeFrom(value); + } + bitField0_ |= 0x00000010; + return this; + } + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + public Builder clearWriteLacRequest() { + if (writeLacRequestBuilder_ == null) { + writeLacRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.getDefaultInstance(); + onChanged(); + } else { + writeLacRequestBuilder_.clear(); + } + bitField0_ = (bitField0_ & ~0x00000010); + return this; + } + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.Builder getWriteLacRequestBuilder() { + bitField0_ |= 0x00000010; + onChanged(); + return getWriteLacRequestFieldBuilder().getBuilder(); + } + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequestOrBuilder getWriteLacRequestOrBuilder() { + if (writeLacRequestBuilder_ != null) { + return writeLacRequestBuilder_.getMessageOrBuilder(); + } else { + return writeLacRequest_; + } + } + /** + * <code>optional .WriteLacRequest writeLacRequest = 103;</code> + */ + private com.google.protobuf.SingleFieldBuilder< + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest, org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequestOrBuilder> + getWriteLacRequestFieldBuilder() { + if (writeLacRequestBuilder_ == null) { + writeLacRequestBuilder_ = new com.google.protobuf.SingleFieldBuilder< + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest, org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequestOrBuilder>( + getWriteLacRequest(), + getParentForChildren(), + isClean()); + writeLacRequest_ = null; + } + return writeLacRequestBuilder_; + } + + private org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest readLacRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.getDefaultInstance(); + private com.google.protobuf.SingleFieldBuilder< + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest, org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequestOrBuilder> readLacRequestBuilder_; + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + public boolean hasReadLacRequest() { + return ((bitField0_ & 0x00000020) == 0x00000020); + } + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest getReadLacRequest() { + if (readLacRequestBuilder_ == null) { + return readLacRequest_; + } else { + return readLacRequestBuilder_.getMessage(); + } + } + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + public Builder setReadLacRequest(org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest value) { + if (readLacRequestBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + readLacRequest_ = value; + onChanged(); + } else { + readLacRequestBuilder_.setMessage(value); + } + bitField0_ |= 0x00000020; + return this; + } + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + public Builder setReadLacRequest( + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.Builder builderForValue) { + if (readLacRequestBuilder_ == null) { + readLacRequest_ = builderForValue.build(); + onChanged(); + } else { + readLacRequestBuilder_.setMessage(builderForValue.build()); + } + bitField0_ |= 0x00000020; + return this; + } + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + public Builder mergeReadLacRequest(org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest value) { + if (readLacRequestBuilder_ == null) { + if (((bitField0_ & 0x00000020) == 0x00000020) && + readLacRequest_ != org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.getDefaultInstance()) { + readLacRequest_ = + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.newBuilder(readLacRequest_).mergeFrom(value).buildPartial(); + } else { + readLacRequest_ = value; + } + onChanged(); + } else { + readLacRequestBuilder_.mergeFrom(value); + } + bitField0_ |= 0x00000020; + return this; + } + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + public Builder clearReadLacRequest() { + if (readLacRequestBuilder_ == null) { + readLacRequest_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.getDefaultInstance(); + onChanged(); + } else { + readLacRequestBuilder_.clear(); + } + bitField0_ = (bitField0_ & ~0x00000020); + return this; + } + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.Builder getReadLacRequestBuilder() { + bitField0_ |= 0x00000020; + onChanged(); + return getReadLacRequestFieldBuilder().getBuilder(); + } + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequestOrBuilder getReadLacRequestOrBuilder() { + if (readLacRequestBuilder_ != null) { + return readLacRequestBuilder_.getMessageOrBuilder(); + } else { + return readLacRequest_; + } + } + /** + * <code>optional .ReadLacRequest readLacRequest = 104;</code> + */ + private com.google.protobuf.SingleFieldBuilder< + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest, org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequestOrBuilder> + getReadLacRequestFieldBuilder() { + if (readLacRequestBuilder_ == null) { + readLacRequestBuilder_ = new com.google.protobuf.SingleFieldBuilder< + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest, org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequestOrBuilder>( + getReadLacRequest(), + getParentForChildren(), + isClean()); + readLacRequest_ = null; + } + return readLacRequestBuilder_; + } + // @@protoc_insertion_point(builder_scope:Request) } @@ -3809,113 +4229,66 @@ public final class BookkeeperProtocol { // @@protoc_insertion_point(class_scope:AddRequest) } - public interface ResponseOrBuilder extends - // @@protoc_insertion_point(interface_extends:Response) + public interface WriteLacRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:WriteLacRequest) com.google.protobuf.MessageOrBuilder { /** - * <code>required .BKPacketHeader header = 1;</code> - */ - boolean hasHeader(); - /** - * <code>required .BKPacketHeader header = 1;</code> + * <code>required int64 ledgerId = 1;</code> */ - org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader getHeader(); + boolean hasLedgerId(); /** - * <code>required .BKPacketHeader header = 1;</code> + * <code>required int64 ledgerId = 1;</code> */ - org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeaderOrBuilder getHeaderOrBuilder(); + long getLedgerId(); /** - * <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> + * <code>required int64 lac = 2;</code> */ - boolean hasStatus(); + boolean hasLac(); /** - * <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> + * <code>required int64 lac = 2;</code> */ - org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode getStatus(); + long getLac(); /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> + * <code>required bytes masterKey = 3;</code> */ - boolean hasReadResponse(); + boolean hasMasterKey(); /** - * <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> + * <code>required bytes masterKey = 3;</code> */ - org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponseOrBuilder getAddResponseOrBuilder(); + com.google.protobuf.ByteString getMasterKey(); /** - * <code>optional .AuthMessage authResponse = 102;</code> - */ - boolean hasAuthResponse(); - /** - * <code>optional .AuthMessage authResponse = 102;</code> + * <code>required bytes body = 4;</code> */ - org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage getAuthResponse(); + boolean hasBody(); /** - * <code>optional .AuthMessage authResponse = 102;</code> + * <code>required bytes body = 4;</code> */ - org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessageOrBuilder getAuthResponseOrBuilder(); + com.google.protobuf.ByteString getBody(); } /** - * Protobuf type {@code Response} + * Protobuf type {@code WriteLacRequest} */ - public static final class Response extends + public static final class WriteLacRequest 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:WriteLacRequest) + WriteLacRequestOrBuilder { + // Use WriteLacRequest.newBuilder() to construct. + private WriteLacRequest(com.google.protobuf.GeneratedMessage.Builder<?> builder) { super(builder); this.unknownFields = builder.getUnknownFields(); } - private Response(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + private WriteLacRequest(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } - private static final Response defaultInstance; - public static Response getDefaultInstance() { + private static final WriteLacRequest defaultInstance; + public static WriteLacRequest getDefaultInstance() { return defaultInstance; } - public Response getDefaultInstanceForType() { + public WriteLacRequest getDefaultInstanceForType() { return defaultInstance; } @@ -3925,7 +4298,7 @@ public final class BookkeeperProtocol { getUnknownFields() { return this.unknownFields; } - private Response( + private WriteLacRequest( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { @@ -3948,67 +4321,24 @@ 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; + ledgerId_ = input.readInt64(); 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; - } + bitField0_ |= 0x00000002; + lac_ = input.readInt64(); 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(); - } + case 26: { bitField0_ |= 0x00000004; + masterKey_ = input.readBytes(); 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(); - } + case 34: { 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; + body_ = input.readBytes(); break; } } @@ -4025,159 +4355,97 @@ 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_WriteLacRequest_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_WriteLacRequest_fieldAccessorTable .ensureFieldAccessorsInitialized( - org.apache.bookkeeper.proto.BookkeeperProtocol.Response.class, org.apache.bookkeeper.proto.BookkeeperProtocol.Response.Builder.class); + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.class, org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.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<WriteLacRequest> PARSER = + new com.google.protobuf.AbstractParser<WriteLacRequest>() { + public WriteLacRequest parsePartialFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { - return new Response(input, extensionRegistry); + return new WriteLacRequest(input, extensionRegistry); } }; @java.lang.Override - public com.google.protobuf.Parser<Response> getParserForType() { + public com.google.protobuf.Parser<WriteLacRequest> getParserForType() { return PARSER; } private int bitField0_; - public static final int HEADER_FIELD_NUMBER = 1; - private org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader header_; + public static final int LEDGERID_FIELD_NUMBER = 1; + private long ledgerId_; /** - * <code>required .BKPacketHeader header = 1;</code> + * <code>required int64 ledgerId = 1;</code> */ - public boolean hasHeader() { + public boolean hasLedgerId() { 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> + * <code>required int64 ledgerId = 1;</code> */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeaderOrBuilder getHeaderOrBuilder() { - return header_; + public long getLedgerId() { + return ledgerId_; } - public static final int STATUS_FIELD_NUMBER = 2; - private org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode status_; + public static final int LAC_FIELD_NUMBER = 2; + private long lac_; /** - * <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> + * <code>required int64 lac = 2;</code> */ - public boolean hasStatus() { + public boolean hasLac() { 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> + * <code>required int64 lac = 2;</code> */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode getStatus() { - return status_; + public long getLac() { + return lac_; } - public static final int READRESPONSE_FIELD_NUMBER = 100; - private org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse readResponse_; + public static final int MASTERKEY_FIELD_NUMBER = 3; + private com.google.protobuf.ByteString masterKey_; /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> + * <code>required bytes masterKey = 3;</code> */ - public boolean hasReadResponse() { + public boolean hasMasterKey() { 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> + * <code>required bytes masterKey = 3;</code> */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponseOrBuilder getReadResponseOrBuilder() { - return readResponse_; + public com.google.protobuf.ByteString getMasterKey() { + return masterKey_; } - public static final int ADDRESPONSE_FIELD_NUMBER = 101; - private org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse addResponse_; + public static final int BODY_FIELD_NUMBER = 4; + private com.google.protobuf.ByteString body_; /** - * <code>optional .AddResponse addResponse = 101;</code> + * <code>required bytes body = 4;</code> */ - public boolean hasAddResponse() { + public boolean hasBody() { 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> + * <code>required bytes body = 4;</code> */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessageOrBuilder getAuthResponseOrBuilder() { - return authResponse_; + public com.google.protobuf.ByteString getBody() { + return body_; } 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(); + ledgerId_ = 0L; + lac_ = 0L; + masterKey_ = com.google.protobuf.ByteString.EMPTY; + body_ = com.google.protobuf.ByteString.EMPTY; } private byte memoizedIsInitialized = -1; public final boolean isInitialized() { @@ -4185,35 +4453,21 @@ public final class BookkeeperProtocol { if (isInitialized == 1) return true; if (isInitialized == 0) return false; - if (!hasHeader()) { + if (!hasLedgerId()) { memoizedIsInitialized = 0; return false; } - if (!hasStatus()) { + if (!hasLac()) { memoizedIsInitialized = 0; return false; } - if (!getHeader().isInitialized()) { + if (!hasMasterKey()) { 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 (!hasBody()) { + memoizedIsInitialized = 0; + return false; } memoizedIsInitialized = 1; return true; @@ -4223,19 +4477,16 @@ public final class BookkeeperProtocol { throws java.io.IOException { getSerializedSize(); if (((bitField0_ & 0x00000001) == 0x00000001)) { - output.writeMessage(1, header_); + output.writeInt64(1, ledgerId_); } if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeEnum(2, status_.getNumber()); + output.writeInt64(2, lac_); } if (((bitField0_ & 0x00000004) == 0x00000004)) { - output.writeMessage(100, readResponse_); + output.writeBytes(3, masterKey_); } if (((bitField0_ & 0x00000008) == 0x00000008)) { - output.writeMessage(101, addResponse_); - } - if (((bitField0_ & 0x00000010) == 0x00000010)) { - output.writeMessage(102, authResponse_); + output.writeBytes(4, body_); } getUnknownFields().writeTo(output); } @@ -4248,23 +4499,19 @@ public final class BookkeeperProtocol { size = 0; if (((bitField0_ & 0x00000001) == 0x00000001)) { size += com.google.protobuf.CodedOutputStream - .computeMessageSize(1, header_); + .computeInt64Size(1, ledgerId_); } if (((bitField0_ & 0x00000002) == 0x00000002)) { size += com.google.protobuf.CodedOutputStream - .computeEnumSize(2, status_.getNumber()); + .computeInt64Size(2, lac_); } if (((bitField0_ & 0x00000004) == 0x00000004)) { size += com.google.protobuf.CodedOutputStream - .computeMessageSize(100, readResponse_); + .computeBytesSize(3, masterKey_); } if (((bitField0_ & 0x00000008) == 0x00000008)) { size += com.google.protobuf.CodedOutputStream - .computeMessageSize(101, addResponse_); - } - if (((bitField0_ & 0x00000010) == 0x00000010)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(102, authResponse_); + .computeBytesSize(4, body_); } size += getUnknownFields().getSerializedSize(); memoizedSerializedSize = size; @@ -4278,53 +4525,53 @@ public final class BookkeeperProtocol { return super.writeReplace(); } - public static org.apache.bookkeeper.proto.BookkeeperProtocol.Response parseFrom( + public static org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest parseFrom( com.google.protobuf.ByteString 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.WriteLacRequest 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) + public static org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest 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.WriteLacRequest 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.WriteLacRequest 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.WriteLacRequest 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.WriteLacRequest 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.WriteLacRequest 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.WriteLacRequest 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.WriteLacRequest parseFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { @@ -4333,7 +4580,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.WriteLacRequest prototype) { return newBuilder().mergeFrom(prototype); } public Builder toBuilder() { return newBuilder(this); } @@ -4345,25 +4592,25 @@ public final class BookkeeperProtocol { return builder; } /** - * Protobuf type {@code Response} + * Protobuf type {@code WriteLacRequest} */ 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:WriteLacRequest) + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequestOrBuilder { 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_WriteLacRequest_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_WriteLacRequest_fieldAccessorTable .ensureFieldAccessorsInitialized( - org.apache.bookkeeper.proto.BookkeeperProtocol.Response.class, org.apache.bookkeeper.proto.BookkeeperProtocol.Response.Builder.class); + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.class, org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.Builder.class); } - // Construct using org.apache.bookkeeper.proto.BookkeeperProtocol.Response.newBuilder() + // Construct using org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.newBuilder() private Builder() { maybeForceBuilderInitialization(); } @@ -4375,10 +4622,6 @@ public final class BookkeeperProtocol { } private void maybeForceBuilderInitialization() { if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getHeaderFieldBuilder(); - getReadResponseFieldBuilder(); - getAddResponseFieldBuilder(); - getAuthResponseFieldBuilder(); } } private static Builder create() { @@ -4387,32 +4630,14 @@ public final class BookkeeperProtocol { public Builder clear() { super.clear(); - if (headerBuilder_ == null) { - header_ = org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.getDefaultInstance(); - } else { - headerBuilder_.clear(); - } + ledgerId_ = 0L; bitField0_ = (bitField0_ & ~0x00000001); - status_ = org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode.EOK; + lac_ = 0L; bitField0_ = (bitField0_ & ~0x00000002); - if (readResponseBuilder_ == null) { - readResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.getDefaultInstance(); - } else { - readResponseBuilder_.clear(); - } + masterKey_ = com.google.protobuf.ByteString.EMPTY; bitField0_ = (bitField0_ & ~0x00000004); - if (addResponseBuilder_ == null) { - addResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.AddResponse.getDefaultInstance(); - } else { - addResponseBuilder_.clear(); - } + body_ = com.google.protobuf.ByteString.EMPTY; bitField0_ = (bitField0_ & ~0x00000008); - if (authResponseBuilder_ == null) { - authResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.AuthMessage.getDefaultInstance(); - } else { - authResponseBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000010); return this; } @@ -4422,126 +4647,89 @@ 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_WriteLacRequest_descriptor; } - public org.apache.bookkeeper.proto.BookkeeperProtocol.Response getDefaultInstanceForType() { - return org.apache.bookkeeper.proto.BookkeeperProtocol.Response.getDefaultInstance(); + public org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest getDefaultInstanceForType() { + return org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.getDefaultInstance(); } - public org.apache.bookkeeper.proto.BookkeeperProtocol.Response build() { - org.apache.bookkeeper.proto.BookkeeperProtocol.Response result = buildPartial(); + public org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest build() { + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest 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.WriteLacRequest buildPartial() { + org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest result = new org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest(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(); - } + result.ledgerId_ = ledgerId_; if (((from_bitField0_ & 0x00000002) == 0x00000002)) { to_bitField0_ |= 0x00000002; } - result.status_ = status_; + result.lac_ = lac_; if (((from_bitField0_ & 0x00000004) == 0x00000004)) { to_bitField0_ |= 0x00000004; } - if (readResponseBuilder_ == null) { - result.readResponse_ = readResponse_; - } else { - result.readResponse_ = readResponseBuilder_.build(); - } + result.masterKey_ = masterKey_; 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(); - } + result.body_ = body_; 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.WriteLacRequest) { + return mergeFrom((org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest)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()); + public Builder mergeFrom(org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest other) { + if (other == org.apache.bookkeeper.proto.BookkeeperProtocol.WriteLacRequest.getDefaultInstance()) return this; + if (other.hasLedgerId()) { + setLedgerId(other.getLedgerId()); } - if (other.hasReadResponse()) { - mergeReadResponse(other.getReadResponse()); + if (other.hasLac()) { + setLac(other.getLac()); } - if (other.hasAddResponse()) { - mergeAddResponse(other.getAddResponse()); + if (other.hasMasterKey()) { + setMasterKey(other.getMasterKey()); } - if (other.hasAuthResponse()) { - mergeAuthResponse(other.getAuthResponse()); + if (other.hasBody()) { + setBody(other.getBody()); } this.mergeUnknownFields(other.getUnknownFields()); return this; } public final boolean isInitialized() { - if (!hasHeader()) { + if (!hasLedgerId()) { return false; } - if (!hasStatus()) { + if (!hasLac()) { return false; } - if (!getHeader().isInitialized()) { + if (!hasMasterKey()) { return false; } - if (hasReadResponse()) { - if (!getReadResponse().isInitialized()) { - - return false; - } - } - if (hasAddResponse()) { - if (!getAddResponse().isInitialized()) { - - return false; - } - } - if (hasAuthResponse()) { - if (!getAuthResponse().isInitialized()) { - - return false; - } + if (!hasBody()) { + + return false; } return true; } @@ -4550,11 +4738,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.WriteLacRequest 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.WriteLacRequest) e.getUnfinishedMessage(); throw e; } finally { if (parsedMessage != null) { @@ -4565,632 +4753,3580 @@ 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_; + private long ledgerId_ ; /** - * <code>required .BKPacketHeader header = 1;</code> + * <code>required int64 ledgerId = 1;</code> */ - public boolean hasHeader() { + public boolean hasLedgerId() { return ((bitField0_ & 0x00000001) == 0x00000001); } /** - * <code>required .BKPacketHeader header = 1;</code> + * <code>required int64 ledgerId = 1;</code> */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader getHeader() { - if (headerBuilder_ == null) { - return header_; - } else { - return headerBuilder_.getMessage(); - } + public long getLedgerId() { + return ledgerId_; } /** - * <code>required .BKPacketHeader header = 1;</code> + * <code>required int64 ledgerId = 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); - } + public Builder setLedgerId(long value) { bitField0_ |= 0x00000001; + ledgerId_ = value; + onChanged(); return this; } /** - * <code>required .BKPacketHeader header = 1;</code> + * <code>required int64 ledgerId = 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; + public Builder clearLedgerId() { + bitField0_ = (bitField0_ & ~0x00000001); + ledgerId_ = 0L; + onChanged(); return this; } + + private long lac_ ; /** - * <code>required .BKPacketHeader header = 1;</code> + * <code>required int64 lac = 2;</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; + public boolean hasLac() { + return ((bitField0_ & 0x00000002) == 0x00000002); } /** - * <code>required .BKPacketHeader header = 1;</code> + * <code>required int64 lac = 2;</code> */ - public Builder clearHeader() { - if (headerBuilder_ == null) { - header_ = org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.getDefaultInstance(); - onChanged(); - } else { - headerBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); + public long getLac() { + return lac_; + } + /** + * <code>required int64 lac = 2;</code> + */ + public Builder setLac(long value) { + bitField0_ |= 0x00000002; + lac_ = value; + onChanged(); return this; } /** - * <code>required .BKPacketHeader header = 1;</code> + * <code>required int64 lac = 2;</code> */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader.Builder getHeaderBuilder() { - bitField0_ |= 0x00000001; + public Builder clearLac() { + bitField0_ = (bitField0_ & ~0x00000002); + lac_ = 0L; onChanged(); - return getHeaderFieldBuilder().getBuilder(); + return this; } + + private com.google.protobuf.ByteString masterKey_ = com.google.protobuf.ByteString.EMPTY; /** - * <code>required .BKPacketHeader header = 1;</code> + * <code>required bytes masterKey = 3;</code> */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeaderOrBuilder getHeaderOrBuilder() { - if (headerBuilder_ != null) { - return headerBuilder_.getMessageOrBuilder(); - } else { - return header_; - } + public boolean hasMasterKey() { + return ((bitField0_ & 0x00000004) == 0x00000004); } /** - * <code>required .BKPacketHeader header = 1;</code> + * <code>required bytes masterKey = 3;</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; - /** - * <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 com.google.protobuf.ByteString getMasterKey() { + return masterKey_; } /** - * <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> + * <code>required bytes masterKey = 3;</code> */ - public Builder setStatus(org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode value) { + public Builder setMasterKey(com.google.protobuf.ByteString value) { if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000002; - status_ = value; + throw new NullPointerException(); + } + bitField0_ |= 0x00000004; + masterKey_ = value; onChanged(); return this; } /** - * <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> + * <code>required bytes masterKey = 3;</code> */ - public Builder clearStatus() { - bitField0_ = (bitField0_ & ~0x00000002); - status_ = org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode.EOK; + public Builder clearMasterKey() { + bitField0_ = (bitField0_ & ~0x00000004); + masterKey_ = getDefaultInstance().getMasterKey(); onChanged(); return this; } - private org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse readResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse, org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.Builder, org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponseOrBuilder> readResponseBuilder_; + private com.google.protobuf.ByteString body_ = com.google.protobuf.ByteString.EMPTY; /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> + * <code>required bytes body = 4;</code> */ - public boolean hasReadResponse() { - return ((bitField0_ & 0x00000004) == 0x00000004); + public boolean hasBody() { + return ((bitField0_ & 0x00000008) == 0x00000008); } /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> + * <code>required bytes body = 4;</code> */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse getReadResponse() { - if (readResponseBuilder_ == null) { - return readResponse_; - } else { - return readResponseBuilder_.getMessage(); - } + public com.google.protobuf.ByteString getBody() { + return body_; } /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> + * <code>required bytes body = 4;</code> */ - public Builder setReadResponse(org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse value) { - if (readResponseBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - readResponse_ = value; - onChanged(); - } else { - readResponseBuilder_.setMessage(value); - } - bitField0_ |= 0x00000004; + public Builder setBody(com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000008; + body_ = value; + onChanged(); return this; } /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> + * <code>required bytes body = 4;</code> */ - public Builder setReadResponse( - org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.Builder builderForValue) { - if (readResponseBuilder_ == null) { - readResponse_ = builderForValue.build(); - onChanged(); - } else { - readResponseBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000004; + public Builder clearBody() { + bitField0_ = (bitField0_ & ~0x00000008); + body_ = getDefaultInstance().getBody(); + onChanged(); return this; } - /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> - */ - public Builder mergeReadResponse(org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse value) { - if (readResponseBuilder_ == null) { - if (((bitField0_ & 0x00000004) == 0x00000004) && - readResponse_ != org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.getDefaultInstance()) { - readResponse_ = - org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.newBuilder(readResponse_).mergeFrom(value).buildPartial(); - } else { - readResponse_ = value; + + // @@protoc_insertion_point(builder_scope:WriteLacRequest) + } + + static { + defaultInstance = new WriteLacRequest(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:WriteLacRequest) + } + + public interface ReadLacRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:ReadLacRequest) + com.google.protobuf.MessageOrBuilder { + + /** + * <code>required int64 ledgerId = 1;</code> + */ + boolean hasLedgerId(); + /** + * <code>required int64 ledgerId = 1;</code> + */ + long getLedgerId(); + } + /** + * Protobuf type {@code ReadLacRequest} + */ + public static final class ReadLacRequest extends + com.google.protobuf.GeneratedMessage implements + // @@protoc_insertion_point(message_implements:ReadLacRequest) + ReadLacRequestOrBuilder { + // Use ReadLacRequest.newBuilder() to construct. + private ReadLacRequest(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private ReadLacRequest(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final ReadLacRequest defaultInstance; + public static ReadLacRequest getDefaultInstance() { + return defaultInstance; + } + + public ReadLacRequest getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private ReadLacRequest( + 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 8: { + bitField0_ |= 0x00000001; + ledgerId_ = input.readInt64(); + break; + } } - onChanged(); - } else { - readResponseBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000004; - return this; - } - /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> - */ - public Builder clearReadResponse() { - if (readResponseBuilder_ == null) { - readResponse_ = org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.getDefaultInstance(); - onChanged(); - } else { - readResponseBuilder_.clear(); } - bitField0_ = (bitField0_ & ~0x00000004); - return this; + } 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(); } - /** - * <code>optional .ReadResponse readResponse = 100;</code> - * - * <pre> - * Response - * </pre> - */ - public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.Builder getReadResponseBuilder() { - bitField0_ |= 0x00000004; + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_ReadLacRequest_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_ReadLacRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.class, org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.Builder.class); + } + + public static com.google.protobuf.Parser<ReadLacRequest> PARSER = + new com.google.protobuf.AbstractParser<ReadLacRequest>() { + public ReadLacRequest parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new ReadLacRequest(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<ReadLacRequest> getParserForType() { + return PARSER; + } + + private int bitField0_; + public static final int LEDGERID_FIELD_NUMBER = 1; + private long ledgerId_; + /** + * <code>required int64 ledgerId = 1;</code> + */ + public boolean hasLedgerId() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required int64 ledgerId = 1;</code> + */ + public long getLedgerId() { + return ledgerId_; + } + + private void initFields() { + ledgerId_ = 0L; + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + if (!hasLedgerId()) { + 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.writeInt64(1, ledgerId_); + } + 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 + .computeInt64Size(1, ledgerId_); + } + 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.ReadLacRequest parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest 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.ReadLacRequest parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest 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.ReadLacRequest parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest 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.ReadLacRequest parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest 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.ReadLacRequest parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + + public static Builder newBuilder() { return Builder.create(); } + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder(org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest 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; + } + /** + * Protobuf type {@code ReadLacRequest} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder<Builder> implements + // @@protoc_insertion_point(builder_implements:ReadLacRequest) + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequestOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_ReadLacRequest_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_ReadLacRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.class, org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.Builder.class); + } + + // Construct using org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessage.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(); + ledgerId_ = 0L; + bitField0_ = (bitField0_ & ~0x00000001); + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.bookkeeper.proto.BookkeeperProtocol.internal_static_ReadLacRequest_descriptor; + } + + public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest getDefaultInstanceForType() { + return org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.getDefaultInstance(); + } + + public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest build() { + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest buildPartial() { + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest result = new org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.ledgerId_ = ledgerId_; + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest) { + return mergeFrom((org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest other) { + if (other == org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest.getDefaultInstance()) return this; + if (other.hasLedgerId()) { + setLedgerId(other.getLedgerId()); + } + this.mergeUnknownFields(other.getUnknownFields()); + return this; + } + + public final boolean isInitialized() { + if (!hasLedgerId()) { + + return false; + } + return true; + } + + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (org.apache.bookkeeper.proto.BookkeeperProtocol.ReadLacRequest) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + private long ledgerId_ ; + /** + * <code>required int64 ledgerId = 1;</code> + */ + public boolean hasLedgerId() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required int64 ledgerId = 1;</code> + */ + public long getLedgerId() { + return ledgerId_; + } + /** + * <code>required int64 ledgerId = 1;</code> + */ + public Builder setLedgerId(long value) { + bitField0_ |= 0x00000001; + ledgerId_ = value; + onChanged(); + return this; + } + /** + * <code>required int64 ledgerId = 1;</code> + */ + public Builder clearLedgerId() { + bitField0_ = (bitField0_ & ~0x00000001); + ledgerId_ = 0L; + onChanged(); + return this; + } + + // @@protoc_insertion_point(builder_scope:ReadLacRequest) + } + + static { + defaultInstance = new ReadLacRequest(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:ReadLacRequest) + } + + 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>option
<TRUNCATED>
