You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bookkeeper.apache.org by si...@apache.org on 2017/01/31 03:02:01 UTC
[2/3] bookkeeper git commit: BOOKKEEPER-874: Explict LAC from Writer
to Bookies
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>