/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tserver/remote_bootstrap.pb.h
Line | Count | Source (jump to first uncovered line) |
1 | | // Generated by the protocol buffer compiler. DO NOT EDIT! |
2 | | // source: yb/tserver/remote_bootstrap.proto |
3 | | |
4 | | #ifndef PROTOBUF_yb_2ftserver_2fremote_5fbootstrap_2eproto__INCLUDED |
5 | | #define PROTOBUF_yb_2ftserver_2fremote_5fbootstrap_2eproto__INCLUDED |
6 | | |
7 | | #include <string> |
8 | | |
9 | | #include <google/protobuf/stubs/common.h> |
10 | | |
11 | | #if GOOGLE_PROTOBUF_VERSION < 3005000 |
12 | | #error This file was generated by a newer version of protoc which is |
13 | | #error incompatible with your Protocol Buffer headers. Please update |
14 | | #error your headers. |
15 | | #endif |
16 | | #if 3005001 < GOOGLE_PROTOBUF_MIN_PROTOC_VERSION |
17 | | #error This file was generated by an older version of protoc which is |
18 | | #error incompatible with your Protocol Buffer headers. Please |
19 | | #error regenerate this file with a newer version of protoc. |
20 | | #endif |
21 | | |
22 | | #include <google/protobuf/io/coded_stream.h> |
23 | | #include <google/protobuf/arena.h> |
24 | | #include <google/protobuf/arenastring.h> |
25 | | #include <google/protobuf/generated_message_table_driven.h> |
26 | | #include <google/protobuf/generated_message_util.h> |
27 | | #include <google/protobuf/metadata.h> |
28 | | #include <google/protobuf/message.h> |
29 | | #include <google/protobuf/repeated_field.h> // IWYU pragma: export |
30 | | #include <google/protobuf/extension_set.h> // IWYU pragma: export |
31 | | #include <google/protobuf/generated_enum_reflection.h> |
32 | | #include <google/protobuf/unknown_field_set.h> |
33 | | #include "yb/common/wire_protocol.pb.h" |
34 | | #include "yb/consensus/metadata.pb.h" |
35 | | #include "yb/rpc/rpc_header.pb.h" |
36 | | #include "yb/tablet/metadata.pb.h" |
37 | | // @@protoc_insertion_point(includes) |
38 | | |
39 | | namespace protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto { |
40 | | // Internal implementation detail -- do not use these members. |
41 | | struct TableStruct { |
42 | | static const ::google::protobuf::internal::ParseTableField entries[]; |
43 | | static const ::google::protobuf::internal::AuxillaryParseTableField aux[]; |
44 | | static const ::google::protobuf::internal::ParseTable schema[13]; |
45 | | static const ::google::protobuf::internal::FieldMetadata field_metadata[]; |
46 | | static const ::google::protobuf::internal::SerializationTable serialization_table[]; |
47 | | static const ::google::protobuf::uint32 offsets[]; |
48 | | }; |
49 | | void AddDescriptors(); |
50 | | void InitDefaultsRemoteBootstrapErrorPBImpl(); |
51 | | void InitDefaultsRemoteBootstrapErrorPB(); |
52 | | void InitDefaultsBeginRemoteBootstrapSessionRequestPBImpl(); |
53 | | void InitDefaultsBeginRemoteBootstrapSessionRequestPB(); |
54 | | void InitDefaultsBeginRemoteBootstrapSessionResponsePBImpl(); |
55 | | void InitDefaultsBeginRemoteBootstrapSessionResponsePB(); |
56 | | void InitDefaultsCheckRemoteBootstrapSessionActiveRequestPBImpl(); |
57 | | void InitDefaultsCheckRemoteBootstrapSessionActiveRequestPB(); |
58 | | void InitDefaultsCheckRemoteBootstrapSessionActiveResponsePBImpl(); |
59 | | void InitDefaultsCheckRemoteBootstrapSessionActiveResponsePB(); |
60 | | void InitDefaultsDataIdPBImpl(); |
61 | | void InitDefaultsDataIdPB(); |
62 | | void InitDefaultsFetchDataRequestPBImpl(); |
63 | | void InitDefaultsFetchDataRequestPB(); |
64 | | void InitDefaultsDataChunkPBImpl(); |
65 | | void InitDefaultsDataChunkPB(); |
66 | | void InitDefaultsFetchDataResponsePBImpl(); |
67 | | void InitDefaultsFetchDataResponsePB(); |
68 | | void InitDefaultsEndRemoteBootstrapSessionRequestPBImpl(); |
69 | | void InitDefaultsEndRemoteBootstrapSessionRequestPB(); |
70 | | void InitDefaultsEndRemoteBootstrapSessionResponsePBImpl(); |
71 | | void InitDefaultsEndRemoteBootstrapSessionResponsePB(); |
72 | | void InitDefaultsRemoveSessionRequestPBImpl(); |
73 | | void InitDefaultsRemoveSessionRequestPB(); |
74 | | void InitDefaultsRemoveSessionResponsePBImpl(); |
75 | | void InitDefaultsRemoveSessionResponsePB(); |
76 | 15.8k | inline void InitDefaults() { |
77 | 15.8k | InitDefaultsRemoteBootstrapErrorPB(); |
78 | 15.8k | InitDefaultsBeginRemoteBootstrapSessionRequestPB(); |
79 | 15.8k | InitDefaultsBeginRemoteBootstrapSessionResponsePB(); |
80 | 15.8k | InitDefaultsCheckRemoteBootstrapSessionActiveRequestPB(); |
81 | 15.8k | InitDefaultsCheckRemoteBootstrapSessionActiveResponsePB(); |
82 | 15.8k | InitDefaultsDataIdPB(); |
83 | 15.8k | InitDefaultsFetchDataRequestPB(); |
84 | 15.8k | InitDefaultsDataChunkPB(); |
85 | 15.8k | InitDefaultsFetchDataResponsePB(); |
86 | 15.8k | InitDefaultsEndRemoteBootstrapSessionRequestPB(); |
87 | 15.8k | InitDefaultsEndRemoteBootstrapSessionResponsePB(); |
88 | 15.8k | InitDefaultsRemoveSessionRequestPB(); |
89 | 15.8k | InitDefaultsRemoveSessionResponsePB(); |
90 | 15.8k | } |
91 | | } // namespace protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto |
92 | | namespace yb { |
93 | | namespace tserver { |
94 | | class BeginRemoteBootstrapSessionRequestPB; |
95 | | class BeginRemoteBootstrapSessionRequestPBDefaultTypeInternal; |
96 | | extern BeginRemoteBootstrapSessionRequestPBDefaultTypeInternal _BeginRemoteBootstrapSessionRequestPB_default_instance_; |
97 | | class BeginRemoteBootstrapSessionResponsePB; |
98 | | class BeginRemoteBootstrapSessionResponsePBDefaultTypeInternal; |
99 | | extern BeginRemoteBootstrapSessionResponsePBDefaultTypeInternal _BeginRemoteBootstrapSessionResponsePB_default_instance_; |
100 | | class CheckRemoteBootstrapSessionActiveRequestPB; |
101 | | class CheckRemoteBootstrapSessionActiveRequestPBDefaultTypeInternal; |
102 | | extern CheckRemoteBootstrapSessionActiveRequestPBDefaultTypeInternal _CheckRemoteBootstrapSessionActiveRequestPB_default_instance_; |
103 | | class CheckRemoteBootstrapSessionActiveResponsePB; |
104 | | class CheckRemoteBootstrapSessionActiveResponsePBDefaultTypeInternal; |
105 | | extern CheckRemoteBootstrapSessionActiveResponsePBDefaultTypeInternal _CheckRemoteBootstrapSessionActiveResponsePB_default_instance_; |
106 | | class DataChunkPB; |
107 | | class DataChunkPBDefaultTypeInternal; |
108 | | extern DataChunkPBDefaultTypeInternal _DataChunkPB_default_instance_; |
109 | | class DataIdPB; |
110 | | class DataIdPBDefaultTypeInternal; |
111 | | extern DataIdPBDefaultTypeInternal _DataIdPB_default_instance_; |
112 | | class EndRemoteBootstrapSessionRequestPB; |
113 | | class EndRemoteBootstrapSessionRequestPBDefaultTypeInternal; |
114 | | extern EndRemoteBootstrapSessionRequestPBDefaultTypeInternal _EndRemoteBootstrapSessionRequestPB_default_instance_; |
115 | | class EndRemoteBootstrapSessionResponsePB; |
116 | | class EndRemoteBootstrapSessionResponsePBDefaultTypeInternal; |
117 | | extern EndRemoteBootstrapSessionResponsePBDefaultTypeInternal _EndRemoteBootstrapSessionResponsePB_default_instance_; |
118 | | class FetchDataRequestPB; |
119 | | class FetchDataRequestPBDefaultTypeInternal; |
120 | | extern FetchDataRequestPBDefaultTypeInternal _FetchDataRequestPB_default_instance_; |
121 | | class FetchDataResponsePB; |
122 | | class FetchDataResponsePBDefaultTypeInternal; |
123 | | extern FetchDataResponsePBDefaultTypeInternal _FetchDataResponsePB_default_instance_; |
124 | | class RemoteBootstrapErrorPB; |
125 | | class RemoteBootstrapErrorPBDefaultTypeInternal; |
126 | | extern RemoteBootstrapErrorPBDefaultTypeInternal _RemoteBootstrapErrorPB_default_instance_; |
127 | | class RemoveSessionRequestPB; |
128 | | class RemoveSessionRequestPBDefaultTypeInternal; |
129 | | extern RemoveSessionRequestPBDefaultTypeInternal _RemoveSessionRequestPB_default_instance_; |
130 | | class RemoveSessionResponsePB; |
131 | | class RemoveSessionResponsePBDefaultTypeInternal; |
132 | | extern RemoveSessionResponsePBDefaultTypeInternal _RemoveSessionResponsePB_default_instance_; |
133 | | } // namespace tserver |
134 | | } // namespace yb |
135 | | namespace yb { |
136 | | namespace tserver { |
137 | | |
138 | | enum RemoteBootstrapErrorPB_Code { |
139 | | RemoteBootstrapErrorPB_Code_UNKNOWN_ERROR = 1, |
140 | | RemoteBootstrapErrorPB_Code_NO_SESSION = 2, |
141 | | RemoteBootstrapErrorPB_Code_TABLET_NOT_FOUND = 3, |
142 | | RemoteBootstrapErrorPB_Code_BLOCK_NOT_FOUND = 4, |
143 | | RemoteBootstrapErrorPB_Code_WAL_SEGMENT_NOT_FOUND = 5, |
144 | | RemoteBootstrapErrorPB_Code_INVALID_REMOTE_BOOTSTRAP_REQUEST = 6, |
145 | | RemoteBootstrapErrorPB_Code_IO_ERROR = 7, |
146 | | RemoteBootstrapErrorPB_Code_ROCKSDB_FILE_NOT_FOUND = 8 |
147 | | }; |
148 | | bool RemoteBootstrapErrorPB_Code_IsValid(int value); |
149 | | const RemoteBootstrapErrorPB_Code RemoteBootstrapErrorPB_Code_Code_MIN = RemoteBootstrapErrorPB_Code_UNKNOWN_ERROR; |
150 | | const RemoteBootstrapErrorPB_Code RemoteBootstrapErrorPB_Code_Code_MAX = RemoteBootstrapErrorPB_Code_ROCKSDB_FILE_NOT_FOUND; |
151 | | const int RemoteBootstrapErrorPB_Code_Code_ARRAYSIZE = RemoteBootstrapErrorPB_Code_Code_MAX + 1; |
152 | | |
153 | | const ::google::protobuf::EnumDescriptor* RemoteBootstrapErrorPB_Code_descriptor(); |
154 | 1.01k | inline const ::std::string& RemoteBootstrapErrorPB_Code_Name(RemoteBootstrapErrorPB_Code value) { |
155 | 1.01k | return ::google::protobuf::internal::NameOfEnum( |
156 | 1.01k | RemoteBootstrapErrorPB_Code_descriptor(), value); |
157 | 1.01k | } |
158 | | inline bool RemoteBootstrapErrorPB_Code_Parse( |
159 | 0 | const ::std::string& name, RemoteBootstrapErrorPB_Code* value) { |
160 | 0 | return ::google::protobuf::internal::ParseNamedEnum<RemoteBootstrapErrorPB_Code>( |
161 | 0 | RemoteBootstrapErrorPB_Code_descriptor(), name, value); |
162 | 0 | } |
163 | | enum DataIdPB_IdType { |
164 | | DataIdPB_IdType_UNKNOWN = 0, |
165 | | DataIdPB_IdType_LOG_SEGMENT = 2, |
166 | | DataIdPB_IdType_ROCKSDB_FILE = 3, |
167 | | DataIdPB_IdType_SNAPSHOT_FILE = 4 |
168 | | }; |
169 | | bool DataIdPB_IdType_IsValid(int value); |
170 | | const DataIdPB_IdType DataIdPB_IdType_IdType_MIN = DataIdPB_IdType_UNKNOWN; |
171 | | const DataIdPB_IdType DataIdPB_IdType_IdType_MAX = DataIdPB_IdType_SNAPSHOT_FILE; |
172 | | const int DataIdPB_IdType_IdType_ARRAYSIZE = DataIdPB_IdType_IdType_MAX + 1; |
173 | | |
174 | | const ::google::protobuf::EnumDescriptor* DataIdPB_IdType_descriptor(); |
175 | 5 | inline const ::std::string& DataIdPB_IdType_Name(DataIdPB_IdType value) { |
176 | 5 | return ::google::protobuf::internal::NameOfEnum( |
177 | 5 | DataIdPB_IdType_descriptor(), value); |
178 | 5 | } |
179 | | inline bool DataIdPB_IdType_Parse( |
180 | 0 | const ::std::string& name, DataIdPB_IdType* value) { |
181 | 0 | return ::google::protobuf::internal::ParseNamedEnum<DataIdPB_IdType>( |
182 | 0 | DataIdPB_IdType_descriptor(), name, value); |
183 | 0 | } |
184 | | // =================================================================== |
185 | | |
186 | | class RemoteBootstrapErrorPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.RemoteBootstrapErrorPB) */ { |
187 | | public: |
188 | | RemoteBootstrapErrorPB(); |
189 | | virtual ~RemoteBootstrapErrorPB(); |
190 | | |
191 | | RemoteBootstrapErrorPB(const RemoteBootstrapErrorPB& from); |
192 | | |
193 | 0 | inline RemoteBootstrapErrorPB& operator=(const RemoteBootstrapErrorPB& from) { |
194 | 0 | CopyFrom(from); |
195 | 0 | return *this; |
196 | 0 | } |
197 | | #if LANG_CXX11 |
198 | | RemoteBootstrapErrorPB(RemoteBootstrapErrorPB&& from) noexcept |
199 | 0 | : RemoteBootstrapErrorPB() { |
200 | 0 | *this = ::std::move(from); |
201 | 0 | } |
202 | | |
203 | 0 | inline RemoteBootstrapErrorPB& operator=(RemoteBootstrapErrorPB&& from) noexcept { |
204 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
205 | 0 | if (this != &from) InternalSwap(&from); |
206 | 0 | } else { |
207 | 0 | CopyFrom(from); |
208 | 0 | } |
209 | 0 | return *this; |
210 | 0 | } |
211 | | #endif |
212 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
213 | 0 | return _internal_metadata_.unknown_fields(); |
214 | 0 | } |
215 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
216 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
217 | 0 | } |
218 | | |
219 | | static const ::google::protobuf::Descriptor* descriptor(); |
220 | | static const RemoteBootstrapErrorPB& default_instance(); |
221 | | |
222 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
223 | 53.6k | static inline const RemoteBootstrapErrorPB* internal_default_instance() { |
224 | 53.6k | return reinterpret_cast<const RemoteBootstrapErrorPB*>( |
225 | 53.6k | &_RemoteBootstrapErrorPB_default_instance_); |
226 | 53.6k | } |
227 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
228 | | 0; |
229 | | |
230 | | void Swap(RemoteBootstrapErrorPB* other); |
231 | 0 | friend void swap(RemoteBootstrapErrorPB& a, RemoteBootstrapErrorPB& b) { |
232 | 0 | a.Swap(&b); |
233 | 0 | } |
234 | | |
235 | | // implements Message ---------------------------------------------- |
236 | | |
237 | 0 | inline RemoteBootstrapErrorPB* New() const PROTOBUF_FINAL { return New(NULL); } |
238 | | |
239 | | RemoteBootstrapErrorPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
240 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
241 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
242 | | void CopyFrom(const RemoteBootstrapErrorPB& from); |
243 | | void MergeFrom(const RemoteBootstrapErrorPB& from); |
244 | | void Clear() PROTOBUF_FINAL; |
245 | | bool IsInitialized() const PROTOBUF_FINAL; |
246 | | |
247 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
248 | | bool MergePartialFromCodedStream( |
249 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
250 | | void SerializeWithCachedSizes( |
251 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
252 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
253 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
254 | 1.02k | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
255 | | private: |
256 | | void SharedCtor(); |
257 | | void SharedDtor(); |
258 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
259 | | void InternalSwap(RemoteBootstrapErrorPB* other); |
260 | | private: |
261 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
262 | 0 | return NULL; |
263 | 0 | } |
264 | 0 | inline void* MaybeArenaPtr() const { |
265 | 0 | return NULL; |
266 | 0 | } |
267 | | public: |
268 | | |
269 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
270 | | |
271 | | // nested types ---------------------------------------------------- |
272 | | |
273 | | typedef RemoteBootstrapErrorPB_Code Code; |
274 | | static const Code UNKNOWN_ERROR = |
275 | | RemoteBootstrapErrorPB_Code_UNKNOWN_ERROR; |
276 | | static const Code NO_SESSION = |
277 | | RemoteBootstrapErrorPB_Code_NO_SESSION; |
278 | | static const Code TABLET_NOT_FOUND = |
279 | | RemoteBootstrapErrorPB_Code_TABLET_NOT_FOUND; |
280 | | static const Code BLOCK_NOT_FOUND = |
281 | | RemoteBootstrapErrorPB_Code_BLOCK_NOT_FOUND; |
282 | | static const Code WAL_SEGMENT_NOT_FOUND = |
283 | | RemoteBootstrapErrorPB_Code_WAL_SEGMENT_NOT_FOUND; |
284 | | static const Code INVALID_REMOTE_BOOTSTRAP_REQUEST = |
285 | | RemoteBootstrapErrorPB_Code_INVALID_REMOTE_BOOTSTRAP_REQUEST; |
286 | | static const Code IO_ERROR = |
287 | | RemoteBootstrapErrorPB_Code_IO_ERROR; |
288 | | static const Code ROCKSDB_FILE_NOT_FOUND = |
289 | | RemoteBootstrapErrorPB_Code_ROCKSDB_FILE_NOT_FOUND; |
290 | 0 | static inline bool Code_IsValid(int value) { |
291 | 0 | return RemoteBootstrapErrorPB_Code_IsValid(value); |
292 | 0 | } |
293 | | static const Code Code_MIN = |
294 | | RemoteBootstrapErrorPB_Code_Code_MIN; |
295 | | static const Code Code_MAX = |
296 | | RemoteBootstrapErrorPB_Code_Code_MAX; |
297 | | static const int Code_ARRAYSIZE = |
298 | | RemoteBootstrapErrorPB_Code_Code_ARRAYSIZE; |
299 | | static inline const ::google::protobuf::EnumDescriptor* |
300 | 0 | Code_descriptor() { |
301 | 0 | return RemoteBootstrapErrorPB_Code_descriptor(); |
302 | 0 | } |
303 | 1.01k | static inline const ::std::string& Code_Name(Code value) { |
304 | 1.01k | return RemoteBootstrapErrorPB_Code_Name(value); |
305 | 1.01k | } |
306 | | static inline bool Code_Parse(const ::std::string& name, |
307 | 0 | Code* value) { |
308 | 0 | return RemoteBootstrapErrorPB_Code_Parse(name, value); |
309 | 0 | } |
310 | | |
311 | | // accessors ------------------------------------------------------- |
312 | | |
313 | | // required .yb.AppStatusPB status = 2; |
314 | | bool has_status() const; |
315 | | void clear_status(); |
316 | | static const int kStatusFieldNumber = 2; |
317 | | const ::yb::AppStatusPB& status() const; |
318 | | ::yb::AppStatusPB* release_status(); |
319 | | ::yb::AppStatusPB* mutable_status(); |
320 | | void set_allocated_status(::yb::AppStatusPB* status); |
321 | | |
322 | | // required .yb.tserver.RemoteBootstrapErrorPB.Code code = 1 [default = UNKNOWN_ERROR]; |
323 | | bool has_code() const; |
324 | | void clear_code(); |
325 | | static const int kCodeFieldNumber = 1; |
326 | | ::yb::tserver::RemoteBootstrapErrorPB_Code code() const; |
327 | | void set_code(::yb::tserver::RemoteBootstrapErrorPB_Code value); |
328 | | |
329 | | static const int kRemoteBootstrapErrorExtFieldNumber = 102; |
330 | | static ::google::protobuf::internal::ExtensionIdentifier< ::yb::rpc::ErrorStatusPB, |
331 | | ::google::protobuf::internal::MessageTypeTraits< ::yb::tserver::RemoteBootstrapErrorPB >, 11, false > |
332 | | remote_bootstrap_error_ext; |
333 | | // @@protoc_insertion_point(class_scope:yb.tserver.RemoteBootstrapErrorPB) |
334 | | private: |
335 | | void set_has_code(); |
336 | | void clear_has_code(); |
337 | | void set_has_status(); |
338 | | void clear_has_status(); |
339 | | |
340 | | // helper for ByteSizeLong() |
341 | | size_t RequiredFieldsByteSizeFallback() const; |
342 | | |
343 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
344 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
345 | | mutable int _cached_size_; |
346 | | ::yb::AppStatusPB* status_; |
347 | | int code_; |
348 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
349 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsRemoteBootstrapErrorPBImpl(); |
350 | | }; |
351 | | // ------------------------------------------------------------------- |
352 | | |
353 | | class BeginRemoteBootstrapSessionRequestPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.BeginRemoteBootstrapSessionRequestPB) */ { |
354 | | public: |
355 | | BeginRemoteBootstrapSessionRequestPB(); |
356 | | virtual ~BeginRemoteBootstrapSessionRequestPB(); |
357 | | |
358 | | BeginRemoteBootstrapSessionRequestPB(const BeginRemoteBootstrapSessionRequestPB& from); |
359 | | |
360 | 0 | inline BeginRemoteBootstrapSessionRequestPB& operator=(const BeginRemoteBootstrapSessionRequestPB& from) { |
361 | 0 | CopyFrom(from); |
362 | 0 | return *this; |
363 | 0 | } |
364 | | #if LANG_CXX11 |
365 | | BeginRemoteBootstrapSessionRequestPB(BeginRemoteBootstrapSessionRequestPB&& from) noexcept |
366 | 0 | : BeginRemoteBootstrapSessionRequestPB() { |
367 | 0 | *this = ::std::move(from); |
368 | 0 | } |
369 | | |
370 | 0 | inline BeginRemoteBootstrapSessionRequestPB& operator=(BeginRemoteBootstrapSessionRequestPB&& from) noexcept { |
371 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
372 | 0 | if (this != &from) InternalSwap(&from); |
373 | 0 | } else { |
374 | 0 | CopyFrom(from); |
375 | 0 | } |
376 | 0 | return *this; |
377 | 0 | } |
378 | | #endif |
379 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
380 | 0 | return _internal_metadata_.unknown_fields(); |
381 | 0 | } |
382 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
383 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
384 | 0 | } |
385 | | |
386 | | static const ::google::protobuf::Descriptor* descriptor(); |
387 | | static const BeginRemoteBootstrapSessionRequestPB& default_instance(); |
388 | | |
389 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
390 | 18.7k | static inline const BeginRemoteBootstrapSessionRequestPB* internal_default_instance() { |
391 | 18.7k | return reinterpret_cast<const BeginRemoteBootstrapSessionRequestPB*>( |
392 | 18.7k | &_BeginRemoteBootstrapSessionRequestPB_default_instance_); |
393 | 18.7k | } |
394 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
395 | | 1; |
396 | | |
397 | | void Swap(BeginRemoteBootstrapSessionRequestPB* other); |
398 | 0 | friend void swap(BeginRemoteBootstrapSessionRequestPB& a, BeginRemoteBootstrapSessionRequestPB& b) { |
399 | 0 | a.Swap(&b); |
400 | 0 | } |
401 | | |
402 | | // implements Message ---------------------------------------------- |
403 | | |
404 | 0 | inline BeginRemoteBootstrapSessionRequestPB* New() const PROTOBUF_FINAL { return New(NULL); } |
405 | | |
406 | | BeginRemoteBootstrapSessionRequestPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
407 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
408 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
409 | | void CopyFrom(const BeginRemoteBootstrapSessionRequestPB& from); |
410 | | void MergeFrom(const BeginRemoteBootstrapSessionRequestPB& from); |
411 | | void Clear() PROTOBUF_FINAL; |
412 | | bool IsInitialized() const PROTOBUF_FINAL; |
413 | | |
414 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
415 | | bool MergePartialFromCodedStream( |
416 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
417 | | void SerializeWithCachedSizes( |
418 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
419 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
420 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
421 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
422 | | private: |
423 | | void SharedCtor(); |
424 | | void SharedDtor(); |
425 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
426 | | void InternalSwap(BeginRemoteBootstrapSessionRequestPB* other); |
427 | | private: |
428 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
429 | 0 | return NULL; |
430 | 0 | } |
431 | 0 | inline void* MaybeArenaPtr() const { |
432 | 0 | return NULL; |
433 | 0 | } |
434 | | public: |
435 | | |
436 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
437 | | |
438 | | // nested types ---------------------------------------------------- |
439 | | |
440 | | // accessors ------------------------------------------------------- |
441 | | |
442 | | // required bytes requestor_uuid = 1; |
443 | | bool has_requestor_uuid() const; |
444 | | void clear_requestor_uuid(); |
445 | | static const int kRequestorUuidFieldNumber = 1; |
446 | | const ::std::string& requestor_uuid() const; |
447 | | void set_requestor_uuid(const ::std::string& value); |
448 | | #if LANG_CXX11 |
449 | | void set_requestor_uuid(::std::string&& value); |
450 | | #endif |
451 | | void set_requestor_uuid(const char* value); |
452 | | void set_requestor_uuid(const void* value, size_t size); |
453 | | ::std::string* mutable_requestor_uuid(); |
454 | | ::std::string* release_requestor_uuid(); |
455 | | void set_allocated_requestor_uuid(::std::string* requestor_uuid); |
456 | | |
457 | | // required bytes tablet_id = 2; |
458 | | bool has_tablet_id() const; |
459 | | void clear_tablet_id(); |
460 | | static const int kTabletIdFieldNumber = 2; |
461 | | const ::std::string& tablet_id() const; |
462 | | void set_tablet_id(const ::std::string& value); |
463 | | #if LANG_CXX11 |
464 | | void set_tablet_id(::std::string&& value); |
465 | | #endif |
466 | | void set_tablet_id(const char* value); |
467 | | void set_tablet_id(const void* value, size_t size); |
468 | | ::std::string* mutable_tablet_id(); |
469 | | ::std::string* release_tablet_id(); |
470 | | void set_allocated_tablet_id(::std::string* tablet_id); |
471 | | |
472 | | // @@protoc_insertion_point(class_scope:yb.tserver.BeginRemoteBootstrapSessionRequestPB) |
473 | | private: |
474 | | void set_has_requestor_uuid(); |
475 | | void clear_has_requestor_uuid(); |
476 | | void set_has_tablet_id(); |
477 | | void clear_has_tablet_id(); |
478 | | |
479 | | // helper for ByteSizeLong() |
480 | | size_t RequiredFieldsByteSizeFallback() const; |
481 | | |
482 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
483 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
484 | | mutable int _cached_size_; |
485 | | ::google::protobuf::internal::ArenaStringPtr requestor_uuid_; |
486 | | ::google::protobuf::internal::ArenaStringPtr tablet_id_; |
487 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
488 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsBeginRemoteBootstrapSessionRequestPBImpl(); |
489 | | }; |
490 | | // ------------------------------------------------------------------- |
491 | | |
492 | | class BeginRemoteBootstrapSessionResponsePB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.BeginRemoteBootstrapSessionResponsePB) */ { |
493 | | public: |
494 | | BeginRemoteBootstrapSessionResponsePB(); |
495 | | virtual ~BeginRemoteBootstrapSessionResponsePB(); |
496 | | |
497 | | BeginRemoteBootstrapSessionResponsePB(const BeginRemoteBootstrapSessionResponsePB& from); |
498 | | |
499 | 0 | inline BeginRemoteBootstrapSessionResponsePB& operator=(const BeginRemoteBootstrapSessionResponsePB& from) { |
500 | 0 | CopyFrom(from); |
501 | 0 | return *this; |
502 | 0 | } |
503 | | #if LANG_CXX11 |
504 | | BeginRemoteBootstrapSessionResponsePB(BeginRemoteBootstrapSessionResponsePB&& from) noexcept |
505 | 0 | : BeginRemoteBootstrapSessionResponsePB() { |
506 | 0 | *this = ::std::move(from); |
507 | 0 | } |
508 | | |
509 | 0 | inline BeginRemoteBootstrapSessionResponsePB& operator=(BeginRemoteBootstrapSessionResponsePB&& from) noexcept { |
510 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
511 | 0 | if (this != &from) InternalSwap(&from); |
512 | 0 | } else { |
513 | 0 | CopyFrom(from); |
514 | 0 | } |
515 | 0 | return *this; |
516 | 0 | } |
517 | | #endif |
518 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
519 | 0 | return _internal_metadata_.unknown_fields(); |
520 | 0 | } |
521 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
522 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
523 | 0 | } |
524 | | |
525 | | static const ::google::protobuf::Descriptor* descriptor(); |
526 | | static const BeginRemoteBootstrapSessionResponsePB& default_instance(); |
527 | | |
528 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
529 | 24.5k | static inline const BeginRemoteBootstrapSessionResponsePB* internal_default_instance() { |
530 | 24.5k | return reinterpret_cast<const BeginRemoteBootstrapSessionResponsePB*>( |
531 | 24.5k | &_BeginRemoteBootstrapSessionResponsePB_default_instance_); |
532 | 24.5k | } |
533 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
534 | | 2; |
535 | | |
536 | | void Swap(BeginRemoteBootstrapSessionResponsePB* other); |
537 | 0 | friend void swap(BeginRemoteBootstrapSessionResponsePB& a, BeginRemoteBootstrapSessionResponsePB& b) { |
538 | 0 | a.Swap(&b); |
539 | 0 | } |
540 | | |
541 | | // implements Message ---------------------------------------------- |
542 | | |
543 | 0 | inline BeginRemoteBootstrapSessionResponsePB* New() const PROTOBUF_FINAL { return New(NULL); } |
544 | | |
545 | | BeginRemoteBootstrapSessionResponsePB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
546 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
547 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
548 | | void CopyFrom(const BeginRemoteBootstrapSessionResponsePB& from); |
549 | | void MergeFrom(const BeginRemoteBootstrapSessionResponsePB& from); |
550 | | void Clear() PROTOBUF_FINAL; |
551 | | bool IsInitialized() const PROTOBUF_FINAL; |
552 | | |
553 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
554 | | bool MergePartialFromCodedStream( |
555 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
556 | | void SerializeWithCachedSizes( |
557 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
558 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
559 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
560 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
561 | | private: |
562 | | void SharedCtor(); |
563 | | void SharedDtor(); |
564 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
565 | | void InternalSwap(BeginRemoteBootstrapSessionResponsePB* other); |
566 | | private: |
567 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
568 | 0 | return NULL; |
569 | 0 | } |
570 | 0 | inline void* MaybeArenaPtr() const { |
571 | 0 | return NULL; |
572 | 0 | } |
573 | | public: |
574 | | |
575 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
576 | | |
577 | | // nested types ---------------------------------------------------- |
578 | | |
579 | | // accessors ------------------------------------------------------- |
580 | | |
581 | | // repeated uint64 DEPRECATED_wal_segment_seqnos = 4; |
582 | | int deprecated_wal_segment_seqnos_size() const; |
583 | | void clear_deprecated_wal_segment_seqnos(); |
584 | | static const int kDEPRECATEDWalSegmentSeqnosFieldNumber = 4; |
585 | | ::google::protobuf::uint64 deprecated_wal_segment_seqnos(int index) const; |
586 | | void set_deprecated_wal_segment_seqnos(int index, ::google::protobuf::uint64 value); |
587 | | void add_deprecated_wal_segment_seqnos(::google::protobuf::uint64 value); |
588 | | const ::google::protobuf::RepeatedField< ::google::protobuf::uint64 >& |
589 | | deprecated_wal_segment_seqnos() const; |
590 | | ::google::protobuf::RepeatedField< ::google::protobuf::uint64 >* |
591 | | mutable_deprecated_wal_segment_seqnos(); |
592 | | |
593 | | // required bytes session_id = 1; |
594 | | bool has_session_id() const; |
595 | | void clear_session_id(); |
596 | | static const int kSessionIdFieldNumber = 1; |
597 | | const ::std::string& session_id() const; |
598 | | void set_session_id(const ::std::string& value); |
599 | | #if LANG_CXX11 |
600 | | void set_session_id(::std::string&& value); |
601 | | #endif |
602 | | void set_session_id(const char* value); |
603 | | void set_session_id(const void* value, size_t size); |
604 | | ::std::string* mutable_session_id(); |
605 | | ::std::string* release_session_id(); |
606 | | void set_allocated_session_id(::std::string* session_id); |
607 | | |
608 | | // required .yb.tablet.RaftGroupReplicaSuperBlockPB superblock = 3; |
609 | | bool has_superblock() const; |
610 | | void clear_superblock(); |
611 | | static const int kSuperblockFieldNumber = 3; |
612 | | const ::yb::tablet::RaftGroupReplicaSuperBlockPB& superblock() const; |
613 | | ::yb::tablet::RaftGroupReplicaSuperBlockPB* release_superblock(); |
614 | | ::yb::tablet::RaftGroupReplicaSuperBlockPB* mutable_superblock(); |
615 | | void set_allocated_superblock(::yb::tablet::RaftGroupReplicaSuperBlockPB* superblock); |
616 | | |
617 | | // required .yb.consensus.ConsensusStatePB initial_committed_cstate = 5; |
618 | | bool has_initial_committed_cstate() const; |
619 | | void clear_initial_committed_cstate(); |
620 | | static const int kInitialCommittedCstateFieldNumber = 5; |
621 | | const ::yb::consensus::ConsensusStatePB& initial_committed_cstate() const; |
622 | | ::yb::consensus::ConsensusStatePB* release_initial_committed_cstate(); |
623 | | ::yb::consensus::ConsensusStatePB* mutable_initial_committed_cstate(); |
624 | | void set_allocated_initial_committed_cstate(::yb::consensus::ConsensusStatePB* initial_committed_cstate); |
625 | | |
626 | | // required uint64 session_idle_timeout_millis = 2; |
627 | | bool has_session_idle_timeout_millis() const; |
628 | | void clear_session_idle_timeout_millis(); |
629 | | static const int kSessionIdleTimeoutMillisFieldNumber = 2; |
630 | | ::google::protobuf::uint64 session_idle_timeout_millis() const; |
631 | | void set_session_idle_timeout_millis(::google::protobuf::uint64 value); |
632 | | |
633 | | // optional uint64 first_wal_segment_seqno = 6; |
634 | | bool has_first_wal_segment_seqno() const; |
635 | | void clear_first_wal_segment_seqno(); |
636 | | static const int kFirstWalSegmentSeqnoFieldNumber = 6; |
637 | | ::google::protobuf::uint64 first_wal_segment_seqno() const; |
638 | | void set_first_wal_segment_seqno(::google::protobuf::uint64 value); |
639 | | |
640 | | // @@protoc_insertion_point(class_scope:yb.tserver.BeginRemoteBootstrapSessionResponsePB) |
641 | | private: |
642 | | void set_has_session_id(); |
643 | | void clear_has_session_id(); |
644 | | void set_has_session_idle_timeout_millis(); |
645 | | void clear_has_session_idle_timeout_millis(); |
646 | | void set_has_superblock(); |
647 | | void clear_has_superblock(); |
648 | | void set_has_first_wal_segment_seqno(); |
649 | | void clear_has_first_wal_segment_seqno(); |
650 | | void set_has_initial_committed_cstate(); |
651 | | void clear_has_initial_committed_cstate(); |
652 | | |
653 | | // helper for ByteSizeLong() |
654 | | size_t RequiredFieldsByteSizeFallback() const; |
655 | | |
656 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
657 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
658 | | mutable int _cached_size_; |
659 | | ::google::protobuf::RepeatedField< ::google::protobuf::uint64 > deprecated_wal_segment_seqnos_; |
660 | | ::google::protobuf::internal::ArenaStringPtr session_id_; |
661 | | ::yb::tablet::RaftGroupReplicaSuperBlockPB* superblock_; |
662 | | ::yb::consensus::ConsensusStatePB* initial_committed_cstate_; |
663 | | ::google::protobuf::uint64 session_idle_timeout_millis_; |
664 | | ::google::protobuf::uint64 first_wal_segment_seqno_; |
665 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
666 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsBeginRemoteBootstrapSessionResponsePBImpl(); |
667 | | }; |
668 | | // ------------------------------------------------------------------- |
669 | | |
670 | | class CheckRemoteBootstrapSessionActiveRequestPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.CheckRemoteBootstrapSessionActiveRequestPB) */ { |
671 | | public: |
672 | | CheckRemoteBootstrapSessionActiveRequestPB(); |
673 | | virtual ~CheckRemoteBootstrapSessionActiveRequestPB(); |
674 | | |
675 | | CheckRemoteBootstrapSessionActiveRequestPB(const CheckRemoteBootstrapSessionActiveRequestPB& from); |
676 | | |
677 | 0 | inline CheckRemoteBootstrapSessionActiveRequestPB& operator=(const CheckRemoteBootstrapSessionActiveRequestPB& from) { |
678 | 0 | CopyFrom(from); |
679 | 0 | return *this; |
680 | 0 | } |
681 | | #if LANG_CXX11 |
682 | | CheckRemoteBootstrapSessionActiveRequestPB(CheckRemoteBootstrapSessionActiveRequestPB&& from) noexcept |
683 | 0 | : CheckRemoteBootstrapSessionActiveRequestPB() { |
684 | 0 | *this = ::std::move(from); |
685 | 0 | } |
686 | | |
687 | 0 | inline CheckRemoteBootstrapSessionActiveRequestPB& operator=(CheckRemoteBootstrapSessionActiveRequestPB&& from) noexcept { |
688 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
689 | 0 | if (this != &from) InternalSwap(&from); |
690 | 0 | } else { |
691 | 0 | CopyFrom(from); |
692 | 0 | } |
693 | 0 | return *this; |
694 | 0 | } |
695 | | #endif |
696 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
697 | 0 | return _internal_metadata_.unknown_fields(); |
698 | 0 | } |
699 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
700 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
701 | 0 | } |
702 | | |
703 | | static const ::google::protobuf::Descriptor* descriptor(); |
704 | | static const CheckRemoteBootstrapSessionActiveRequestPB& default_instance(); |
705 | | |
706 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
707 | 15.8k | static inline const CheckRemoteBootstrapSessionActiveRequestPB* internal_default_instance() { |
708 | 15.8k | return reinterpret_cast<const CheckRemoteBootstrapSessionActiveRequestPB*>( |
709 | 15.8k | &_CheckRemoteBootstrapSessionActiveRequestPB_default_instance_); |
710 | 15.8k | } |
711 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
712 | | 3; |
713 | | |
714 | | void Swap(CheckRemoteBootstrapSessionActiveRequestPB* other); |
715 | 0 | friend void swap(CheckRemoteBootstrapSessionActiveRequestPB& a, CheckRemoteBootstrapSessionActiveRequestPB& b) { |
716 | 0 | a.Swap(&b); |
717 | 0 | } |
718 | | |
719 | | // implements Message ---------------------------------------------- |
720 | | |
721 | 0 | inline CheckRemoteBootstrapSessionActiveRequestPB* New() const PROTOBUF_FINAL { return New(NULL); } |
722 | | |
723 | | CheckRemoteBootstrapSessionActiveRequestPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
724 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
725 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
726 | | void CopyFrom(const CheckRemoteBootstrapSessionActiveRequestPB& from); |
727 | | void MergeFrom(const CheckRemoteBootstrapSessionActiveRequestPB& from); |
728 | | void Clear() PROTOBUF_FINAL; |
729 | | bool IsInitialized() const PROTOBUF_FINAL; |
730 | | |
731 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
732 | | bool MergePartialFromCodedStream( |
733 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
734 | | void SerializeWithCachedSizes( |
735 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
736 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
737 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
738 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
739 | | private: |
740 | | void SharedCtor(); |
741 | | void SharedDtor(); |
742 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
743 | | void InternalSwap(CheckRemoteBootstrapSessionActiveRequestPB* other); |
744 | | private: |
745 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
746 | 0 | return NULL; |
747 | 0 | } |
748 | 0 | inline void* MaybeArenaPtr() const { |
749 | 0 | return NULL; |
750 | 0 | } |
751 | | public: |
752 | | |
753 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
754 | | |
755 | | // nested types ---------------------------------------------------- |
756 | | |
757 | | // accessors ------------------------------------------------------- |
758 | | |
759 | | // required bytes session_id = 1; |
760 | | bool has_session_id() const; |
761 | | void clear_session_id(); |
762 | | static const int kSessionIdFieldNumber = 1; |
763 | | const ::std::string& session_id() const; |
764 | | void set_session_id(const ::std::string& value); |
765 | | #if LANG_CXX11 |
766 | | void set_session_id(::std::string&& value); |
767 | | #endif |
768 | | void set_session_id(const char* value); |
769 | | void set_session_id(const void* value, size_t size); |
770 | | ::std::string* mutable_session_id(); |
771 | | ::std::string* release_session_id(); |
772 | | void set_allocated_session_id(::std::string* session_id); |
773 | | |
774 | | // optional bool keepalive = 2 [default = false]; |
775 | | bool has_keepalive() const; |
776 | | void clear_keepalive(); |
777 | | static const int kKeepaliveFieldNumber = 2; |
778 | | bool keepalive() const; |
779 | | void set_keepalive(bool value); |
780 | | |
781 | | // @@protoc_insertion_point(class_scope:yb.tserver.CheckRemoteBootstrapSessionActiveRequestPB) |
782 | | private: |
783 | | void set_has_session_id(); |
784 | | void clear_has_session_id(); |
785 | | void set_has_keepalive(); |
786 | | void clear_has_keepalive(); |
787 | | |
788 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
789 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
790 | | mutable int _cached_size_; |
791 | | ::google::protobuf::internal::ArenaStringPtr session_id_; |
792 | | bool keepalive_; |
793 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
794 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsCheckRemoteBootstrapSessionActiveRequestPBImpl(); |
795 | | }; |
796 | | // ------------------------------------------------------------------- |
797 | | |
798 | | class CheckRemoteBootstrapSessionActiveResponsePB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.CheckRemoteBootstrapSessionActiveResponsePB) */ { |
799 | | public: |
800 | | CheckRemoteBootstrapSessionActiveResponsePB(); |
801 | | virtual ~CheckRemoteBootstrapSessionActiveResponsePB(); |
802 | | |
803 | | CheckRemoteBootstrapSessionActiveResponsePB(const CheckRemoteBootstrapSessionActiveResponsePB& from); |
804 | | |
805 | 0 | inline CheckRemoteBootstrapSessionActiveResponsePB& operator=(const CheckRemoteBootstrapSessionActiveResponsePB& from) { |
806 | 0 | CopyFrom(from); |
807 | 0 | return *this; |
808 | 0 | } |
809 | | #if LANG_CXX11 |
810 | | CheckRemoteBootstrapSessionActiveResponsePB(CheckRemoteBootstrapSessionActiveResponsePB&& from) noexcept |
811 | 0 | : CheckRemoteBootstrapSessionActiveResponsePB() { |
812 | 0 | *this = ::std::move(from); |
813 | 0 | } |
814 | | |
815 | 0 | inline CheckRemoteBootstrapSessionActiveResponsePB& operator=(CheckRemoteBootstrapSessionActiveResponsePB&& from) noexcept { |
816 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
817 | 0 | if (this != &from) InternalSwap(&from); |
818 | 0 | } else { |
819 | 0 | CopyFrom(from); |
820 | 0 | } |
821 | 0 | return *this; |
822 | 0 | } |
823 | | #endif |
824 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
825 | 0 | return _internal_metadata_.unknown_fields(); |
826 | 0 | } |
827 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
828 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
829 | 0 | } |
830 | | |
831 | | static const ::google::protobuf::Descriptor* descriptor(); |
832 | | static const CheckRemoteBootstrapSessionActiveResponsePB& default_instance(); |
833 | | |
834 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
835 | 15.8k | static inline const CheckRemoteBootstrapSessionActiveResponsePB* internal_default_instance() { |
836 | 15.8k | return reinterpret_cast<const CheckRemoteBootstrapSessionActiveResponsePB*>( |
837 | 15.8k | &_CheckRemoteBootstrapSessionActiveResponsePB_default_instance_); |
838 | 15.8k | } |
839 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
840 | | 4; |
841 | | |
842 | | void Swap(CheckRemoteBootstrapSessionActiveResponsePB* other); |
843 | 0 | friend void swap(CheckRemoteBootstrapSessionActiveResponsePB& a, CheckRemoteBootstrapSessionActiveResponsePB& b) { |
844 | 0 | a.Swap(&b); |
845 | 0 | } |
846 | | |
847 | | // implements Message ---------------------------------------------- |
848 | | |
849 | 0 | inline CheckRemoteBootstrapSessionActiveResponsePB* New() const PROTOBUF_FINAL { return New(NULL); } |
850 | | |
851 | | CheckRemoteBootstrapSessionActiveResponsePB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
852 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
853 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
854 | | void CopyFrom(const CheckRemoteBootstrapSessionActiveResponsePB& from); |
855 | | void MergeFrom(const CheckRemoteBootstrapSessionActiveResponsePB& from); |
856 | | void Clear() PROTOBUF_FINAL; |
857 | | bool IsInitialized() const PROTOBUF_FINAL; |
858 | | |
859 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
860 | | bool MergePartialFromCodedStream( |
861 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
862 | | void SerializeWithCachedSizes( |
863 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
864 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
865 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
866 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
867 | | private: |
868 | | void SharedCtor(); |
869 | | void SharedDtor(); |
870 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
871 | | void InternalSwap(CheckRemoteBootstrapSessionActiveResponsePB* other); |
872 | | private: |
873 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
874 | 0 | return NULL; |
875 | 0 | } |
876 | 0 | inline void* MaybeArenaPtr() const { |
877 | 0 | return NULL; |
878 | 0 | } |
879 | | public: |
880 | | |
881 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
882 | | |
883 | | // nested types ---------------------------------------------------- |
884 | | |
885 | | // accessors ------------------------------------------------------- |
886 | | |
887 | | // required bool session_is_active = 1; |
888 | | bool has_session_is_active() const; |
889 | | void clear_session_is_active(); |
890 | | static const int kSessionIsActiveFieldNumber = 1; |
891 | | bool session_is_active() const; |
892 | | void set_session_is_active(bool value); |
893 | | |
894 | | // @@protoc_insertion_point(class_scope:yb.tserver.CheckRemoteBootstrapSessionActiveResponsePB) |
895 | | private: |
896 | | void set_has_session_is_active(); |
897 | | void clear_has_session_is_active(); |
898 | | |
899 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
900 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
901 | | mutable int _cached_size_; |
902 | | bool session_is_active_; |
903 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
904 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsCheckRemoteBootstrapSessionActiveResponsePBImpl(); |
905 | | }; |
906 | | // ------------------------------------------------------------------- |
907 | | |
908 | | class DataIdPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.DataIdPB) */ { |
909 | | public: |
910 | | DataIdPB(); |
911 | | virtual ~DataIdPB(); |
912 | | |
913 | | DataIdPB(const DataIdPB& from); |
914 | | |
915 | 0 | inline DataIdPB& operator=(const DataIdPB& from) { |
916 | 0 | CopyFrom(from); |
917 | 0 | return *this; |
918 | 0 | } |
919 | | #if LANG_CXX11 |
920 | | DataIdPB(DataIdPB&& from) noexcept |
921 | 0 | : DataIdPB() { |
922 | 0 | *this = ::std::move(from); |
923 | 0 | } |
924 | | |
925 | 0 | inline DataIdPB& operator=(DataIdPB&& from) noexcept { |
926 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
927 | 0 | if (this != &from) InternalSwap(&from); |
928 | 0 | } else { |
929 | 0 | CopyFrom(from); |
930 | 0 | } |
931 | 0 | return *this; |
932 | 0 | } |
933 | | #endif |
934 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
935 | 0 | return _internal_metadata_.unknown_fields(); |
936 | 0 | } |
937 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
938 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
939 | 0 | } |
940 | | |
941 | | static const ::google::protobuf::Descriptor* descriptor(); |
942 | | static const DataIdPB& default_instance(); |
943 | | |
944 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
945 | 47.5k | static inline const DataIdPB* internal_default_instance() { |
946 | 47.5k | return reinterpret_cast<const DataIdPB*>( |
947 | 47.5k | &_DataIdPB_default_instance_); |
948 | 47.5k | } |
949 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
950 | | 5; |
951 | | |
952 | | void Swap(DataIdPB* other); |
953 | 0 | friend void swap(DataIdPB& a, DataIdPB& b) { |
954 | 0 | a.Swap(&b); |
955 | 0 | } |
956 | | |
957 | | // implements Message ---------------------------------------------- |
958 | | |
959 | 0 | inline DataIdPB* New() const PROTOBUF_FINAL { return New(NULL); } |
960 | | |
961 | | DataIdPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
962 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
963 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
964 | | void CopyFrom(const DataIdPB& from); |
965 | | void MergeFrom(const DataIdPB& from); |
966 | | void Clear() PROTOBUF_FINAL; |
967 | | bool IsInitialized() const PROTOBUF_FINAL; |
968 | | |
969 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
970 | | bool MergePartialFromCodedStream( |
971 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
972 | | void SerializeWithCachedSizes( |
973 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
974 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
975 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
976 | 5.83k | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
977 | | private: |
978 | | void SharedCtor(); |
979 | | void SharedDtor(); |
980 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
981 | | void InternalSwap(DataIdPB* other); |
982 | | private: |
983 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
984 | 0 | return NULL; |
985 | 0 | } |
986 | 0 | inline void* MaybeArenaPtr() const { |
987 | 0 | return NULL; |
988 | 0 | } |
989 | | public: |
990 | | |
991 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
992 | | |
993 | | // nested types ---------------------------------------------------- |
994 | | |
995 | | typedef DataIdPB_IdType IdType; |
996 | | static const IdType UNKNOWN = |
997 | | DataIdPB_IdType_UNKNOWN; |
998 | | static const IdType LOG_SEGMENT = |
999 | | DataIdPB_IdType_LOG_SEGMENT; |
1000 | | static const IdType ROCKSDB_FILE = |
1001 | | DataIdPB_IdType_ROCKSDB_FILE; |
1002 | | static const IdType SNAPSHOT_FILE = |
1003 | | DataIdPB_IdType_SNAPSHOT_FILE; |
1004 | 0 | static inline bool IdType_IsValid(int value) { |
1005 | 0 | return DataIdPB_IdType_IsValid(value); |
1006 | 0 | } |
1007 | | static const IdType IdType_MIN = |
1008 | | DataIdPB_IdType_IdType_MIN; |
1009 | | static const IdType IdType_MAX = |
1010 | | DataIdPB_IdType_IdType_MAX; |
1011 | | static const int IdType_ARRAYSIZE = |
1012 | | DataIdPB_IdType_IdType_ARRAYSIZE; |
1013 | | static inline const ::google::protobuf::EnumDescriptor* |
1014 | 0 | IdType_descriptor() { |
1015 | 0 | return DataIdPB_IdType_descriptor(); |
1016 | 0 | } |
1017 | 5 | static inline const ::std::string& IdType_Name(IdType value) { |
1018 | 5 | return DataIdPB_IdType_Name(value); |
1019 | 5 | } |
1020 | | static inline bool IdType_Parse(const ::std::string& name, |
1021 | 0 | IdType* value) { |
1022 | 0 | return DataIdPB_IdType_Parse(name, value); |
1023 | 0 | } |
1024 | | |
1025 | | // accessors ------------------------------------------------------- |
1026 | | |
1027 | | // optional string file_name = 4; |
1028 | | bool has_file_name() const; |
1029 | | void clear_file_name(); |
1030 | | static const int kFileNameFieldNumber = 4; |
1031 | | const ::std::string& file_name() const; |
1032 | | void set_file_name(const ::std::string& value); |
1033 | | #if LANG_CXX11 |
1034 | | void set_file_name(::std::string&& value); |
1035 | | #endif |
1036 | | void set_file_name(const char* value); |
1037 | | void set_file_name(const char* value, size_t size); |
1038 | | ::std::string* mutable_file_name(); |
1039 | | ::std::string* release_file_name(); |
1040 | | void set_allocated_file_name(::std::string* file_name); |
1041 | | |
1042 | | // optional bytes snapshot_id = 5; |
1043 | | bool has_snapshot_id() const; |
1044 | | void clear_snapshot_id(); |
1045 | | static const int kSnapshotIdFieldNumber = 5; |
1046 | | const ::std::string& snapshot_id() const; |
1047 | | void set_snapshot_id(const ::std::string& value); |
1048 | | #if LANG_CXX11 |
1049 | | void set_snapshot_id(::std::string&& value); |
1050 | | #endif |
1051 | | void set_snapshot_id(const char* value); |
1052 | | void set_snapshot_id(const void* value, size_t size); |
1053 | | ::std::string* mutable_snapshot_id(); |
1054 | | ::std::string* release_snapshot_id(); |
1055 | | void set_allocated_snapshot_id(::std::string* snapshot_id); |
1056 | | |
1057 | | // optional uint64 wal_segment_seqno = 3; |
1058 | | bool has_wal_segment_seqno() const; |
1059 | | void clear_wal_segment_seqno(); |
1060 | | static const int kWalSegmentSeqnoFieldNumber = 3; |
1061 | | ::google::protobuf::uint64 wal_segment_seqno() const; |
1062 | | void set_wal_segment_seqno(::google::protobuf::uint64 value); |
1063 | | |
1064 | | // required .yb.tserver.DataIdPB.IdType type = 1; |
1065 | | bool has_type() const; |
1066 | | void clear_type(); |
1067 | | static const int kTypeFieldNumber = 1; |
1068 | | ::yb::tserver::DataIdPB_IdType type() const; |
1069 | | void set_type(::yb::tserver::DataIdPB_IdType value); |
1070 | | |
1071 | | // @@protoc_insertion_point(class_scope:yb.tserver.DataIdPB) |
1072 | | private: |
1073 | | void set_has_type(); |
1074 | | void clear_has_type(); |
1075 | | void set_has_wal_segment_seqno(); |
1076 | | void clear_has_wal_segment_seqno(); |
1077 | | void set_has_file_name(); |
1078 | | void clear_has_file_name(); |
1079 | | void set_has_snapshot_id(); |
1080 | | void clear_has_snapshot_id(); |
1081 | | |
1082 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
1083 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
1084 | | mutable int _cached_size_; |
1085 | | ::google::protobuf::internal::ArenaStringPtr file_name_; |
1086 | | ::google::protobuf::internal::ArenaStringPtr snapshot_id_; |
1087 | | ::google::protobuf::uint64 wal_segment_seqno_; |
1088 | | int type_; |
1089 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
1090 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsDataIdPBImpl(); |
1091 | | }; |
1092 | | // ------------------------------------------------------------------- |
1093 | | |
1094 | | class FetchDataRequestPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.FetchDataRequestPB) */ { |
1095 | | public: |
1096 | | FetchDataRequestPB(); |
1097 | | virtual ~FetchDataRequestPB(); |
1098 | | |
1099 | | FetchDataRequestPB(const FetchDataRequestPB& from); |
1100 | | |
1101 | 0 | inline FetchDataRequestPB& operator=(const FetchDataRequestPB& from) { |
1102 | 0 | CopyFrom(from); |
1103 | 0 | return *this; |
1104 | 0 | } |
1105 | | #if LANG_CXX11 |
1106 | | FetchDataRequestPB(FetchDataRequestPB&& from) noexcept |
1107 | 0 | : FetchDataRequestPB() { |
1108 | 0 | *this = ::std::move(from); |
1109 | 0 | } |
1110 | | |
1111 | 0 | inline FetchDataRequestPB& operator=(FetchDataRequestPB&& from) noexcept { |
1112 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
1113 | 0 | if (this != &from) InternalSwap(&from); |
1114 | 0 | } else { |
1115 | 0 | CopyFrom(from); |
1116 | 0 | } |
1117 | 0 | return *this; |
1118 | 0 | } |
1119 | | #endif |
1120 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
1121 | 0 | return _internal_metadata_.unknown_fields(); |
1122 | 0 | } |
1123 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
1124 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
1125 | 0 | } |
1126 | | |
1127 | | static const ::google::protobuf::Descriptor* descriptor(); |
1128 | | static const FetchDataRequestPB& default_instance(); |
1129 | | |
1130 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
1131 | 39.0k | static inline const FetchDataRequestPB* internal_default_instance() { |
1132 | 39.0k | return reinterpret_cast<const FetchDataRequestPB*>( |
1133 | 39.0k | &_FetchDataRequestPB_default_instance_); |
1134 | 39.0k | } |
1135 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
1136 | | 6; |
1137 | | |
1138 | | void Swap(FetchDataRequestPB* other); |
1139 | 0 | friend void swap(FetchDataRequestPB& a, FetchDataRequestPB& b) { |
1140 | 0 | a.Swap(&b); |
1141 | 0 | } |
1142 | | |
1143 | | // implements Message ---------------------------------------------- |
1144 | | |
1145 | 0 | inline FetchDataRequestPB* New() const PROTOBUF_FINAL { return New(NULL); } |
1146 | | |
1147 | | FetchDataRequestPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
1148 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1149 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1150 | | void CopyFrom(const FetchDataRequestPB& from); |
1151 | | void MergeFrom(const FetchDataRequestPB& from); |
1152 | | void Clear() PROTOBUF_FINAL; |
1153 | | bool IsInitialized() const PROTOBUF_FINAL; |
1154 | | |
1155 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
1156 | | bool MergePartialFromCodedStream( |
1157 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
1158 | | void SerializeWithCachedSizes( |
1159 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
1160 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
1161 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
1162 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
1163 | | private: |
1164 | | void SharedCtor(); |
1165 | | void SharedDtor(); |
1166 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
1167 | | void InternalSwap(FetchDataRequestPB* other); |
1168 | | private: |
1169 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
1170 | 0 | return NULL; |
1171 | 0 | } |
1172 | 0 | inline void* MaybeArenaPtr() const { |
1173 | 0 | return NULL; |
1174 | 0 | } |
1175 | | public: |
1176 | | |
1177 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
1178 | | |
1179 | | // nested types ---------------------------------------------------- |
1180 | | |
1181 | | // accessors ------------------------------------------------------- |
1182 | | |
1183 | | // required bytes session_id = 1; |
1184 | | bool has_session_id() const; |
1185 | | void clear_session_id(); |
1186 | | static const int kSessionIdFieldNumber = 1; |
1187 | | const ::std::string& session_id() const; |
1188 | | void set_session_id(const ::std::string& value); |
1189 | | #if LANG_CXX11 |
1190 | | void set_session_id(::std::string&& value); |
1191 | | #endif |
1192 | | void set_session_id(const char* value); |
1193 | | void set_session_id(const void* value, size_t size); |
1194 | | ::std::string* mutable_session_id(); |
1195 | | ::std::string* release_session_id(); |
1196 | | void set_allocated_session_id(::std::string* session_id); |
1197 | | |
1198 | | // required .yb.tserver.DataIdPB data_id = 2; |
1199 | | bool has_data_id() const; |
1200 | | void clear_data_id(); |
1201 | | static const int kDataIdFieldNumber = 2; |
1202 | | const ::yb::tserver::DataIdPB& data_id() const; |
1203 | | ::yb::tserver::DataIdPB* release_data_id(); |
1204 | | ::yb::tserver::DataIdPB* mutable_data_id(); |
1205 | | void set_allocated_data_id(::yb::tserver::DataIdPB* data_id); |
1206 | | |
1207 | | // optional uint64 offset = 3 [default = 0]; |
1208 | | bool has_offset() const; |
1209 | | void clear_offset(); |
1210 | | static const int kOffsetFieldNumber = 3; |
1211 | | ::google::protobuf::uint64 offset() const; |
1212 | | void set_offset(::google::protobuf::uint64 value); |
1213 | | |
1214 | | // optional int64 max_length = 4 [default = 0]; |
1215 | | bool has_max_length() const; |
1216 | | void clear_max_length(); |
1217 | | static const int kMaxLengthFieldNumber = 4; |
1218 | | ::google::protobuf::int64 max_length() const; |
1219 | | void set_max_length(::google::protobuf::int64 value); |
1220 | | |
1221 | | // @@protoc_insertion_point(class_scope:yb.tserver.FetchDataRequestPB) |
1222 | | private: |
1223 | | void set_has_session_id(); |
1224 | | void clear_has_session_id(); |
1225 | | void set_has_data_id(); |
1226 | | void clear_has_data_id(); |
1227 | | void set_has_offset(); |
1228 | | void clear_has_offset(); |
1229 | | void set_has_max_length(); |
1230 | | void clear_has_max_length(); |
1231 | | |
1232 | | // helper for ByteSizeLong() |
1233 | | size_t RequiredFieldsByteSizeFallback() const; |
1234 | | |
1235 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
1236 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
1237 | | mutable int _cached_size_; |
1238 | | ::google::protobuf::internal::ArenaStringPtr session_id_; |
1239 | | ::yb::tserver::DataIdPB* data_id_; |
1240 | | ::google::protobuf::uint64 offset_; |
1241 | | ::google::protobuf::int64 max_length_; |
1242 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
1243 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsFetchDataRequestPBImpl(); |
1244 | | }; |
1245 | | // ------------------------------------------------------------------- |
1246 | | |
1247 | | class DataChunkPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.DataChunkPB) */ { |
1248 | | public: |
1249 | | DataChunkPB(); |
1250 | | virtual ~DataChunkPB(); |
1251 | | |
1252 | | DataChunkPB(const DataChunkPB& from); |
1253 | | |
1254 | 0 | inline DataChunkPB& operator=(const DataChunkPB& from) { |
1255 | 0 | CopyFrom(from); |
1256 | 0 | return *this; |
1257 | 0 | } |
1258 | | #if LANG_CXX11 |
1259 | | DataChunkPB(DataChunkPB&& from) noexcept |
1260 | 0 | : DataChunkPB() { |
1261 | 0 | *this = ::std::move(from); |
1262 | 0 | } |
1263 | | |
1264 | 0 | inline DataChunkPB& operator=(DataChunkPB&& from) noexcept { |
1265 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
1266 | 0 | if (this != &from) InternalSwap(&from); |
1267 | 0 | } else { |
1268 | 0 | CopyFrom(from); |
1269 | 0 | } |
1270 | 0 | return *this; |
1271 | 0 | } |
1272 | | #endif |
1273 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
1274 | 0 | return _internal_metadata_.unknown_fields(); |
1275 | 0 | } |
1276 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
1277 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
1278 | 0 | } |
1279 | | |
1280 | | static const ::google::protobuf::Descriptor* descriptor(); |
1281 | | static const DataChunkPB& default_instance(); |
1282 | | |
1283 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
1284 | 41.3k | static inline const DataChunkPB* internal_default_instance() { |
1285 | 41.3k | return reinterpret_cast<const DataChunkPB*>( |
1286 | 41.3k | &_DataChunkPB_default_instance_); |
1287 | 41.3k | } |
1288 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
1289 | | 7; |
1290 | | |
1291 | | void Swap(DataChunkPB* other); |
1292 | 0 | friend void swap(DataChunkPB& a, DataChunkPB& b) { |
1293 | 0 | a.Swap(&b); |
1294 | 0 | } |
1295 | | |
1296 | | // implements Message ---------------------------------------------- |
1297 | | |
1298 | 0 | inline DataChunkPB* New() const PROTOBUF_FINAL { return New(NULL); } |
1299 | | |
1300 | | DataChunkPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
1301 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1302 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1303 | | void CopyFrom(const DataChunkPB& from); |
1304 | | void MergeFrom(const DataChunkPB& from); |
1305 | | void Clear() PROTOBUF_FINAL; |
1306 | | bool IsInitialized() const PROTOBUF_FINAL; |
1307 | | |
1308 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
1309 | | bool MergePartialFromCodedStream( |
1310 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
1311 | | void SerializeWithCachedSizes( |
1312 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
1313 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
1314 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
1315 | 4.82k | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
1316 | | private: |
1317 | | void SharedCtor(); |
1318 | | void SharedDtor(); |
1319 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
1320 | | void InternalSwap(DataChunkPB* other); |
1321 | | private: |
1322 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
1323 | 0 | return NULL; |
1324 | 0 | } |
1325 | 0 | inline void* MaybeArenaPtr() const { |
1326 | 0 | return NULL; |
1327 | 0 | } |
1328 | | public: |
1329 | | |
1330 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
1331 | | |
1332 | | // nested types ---------------------------------------------------- |
1333 | | |
1334 | | // accessors ------------------------------------------------------- |
1335 | | |
1336 | | // required bytes data = 2; |
1337 | | bool has_data() const; |
1338 | | void clear_data(); |
1339 | | static const int kDataFieldNumber = 2; |
1340 | | const ::std::string& data() const; |
1341 | | void set_data(const ::std::string& value); |
1342 | | #if LANG_CXX11 |
1343 | | void set_data(::std::string&& value); |
1344 | | #endif |
1345 | | void set_data(const char* value); |
1346 | | void set_data(const void* value, size_t size); |
1347 | | ::std::string* mutable_data(); |
1348 | | ::std::string* release_data(); |
1349 | | void set_allocated_data(::std::string* data); |
1350 | | |
1351 | | // required uint64 offset = 1; |
1352 | | bool has_offset() const; |
1353 | | void clear_offset(); |
1354 | | static const int kOffsetFieldNumber = 1; |
1355 | | ::google::protobuf::uint64 offset() const; |
1356 | | void set_offset(::google::protobuf::uint64 value); |
1357 | | |
1358 | | // required int64 total_data_length = 4; |
1359 | | bool has_total_data_length() const; |
1360 | | void clear_total_data_length(); |
1361 | | static const int kTotalDataLengthFieldNumber = 4; |
1362 | | ::google::protobuf::int64 total_data_length() const; |
1363 | | void set_total_data_length(::google::protobuf::int64 value); |
1364 | | |
1365 | | // required fixed32 crc32 = 3; |
1366 | | bool has_crc32() const; |
1367 | | void clear_crc32(); |
1368 | | static const int kCrc32FieldNumber = 3; |
1369 | | ::google::protobuf::uint32 crc32() const; |
1370 | | void set_crc32(::google::protobuf::uint32 value); |
1371 | | |
1372 | | // @@protoc_insertion_point(class_scope:yb.tserver.DataChunkPB) |
1373 | | private: |
1374 | | void set_has_offset(); |
1375 | | void clear_has_offset(); |
1376 | | void set_has_data(); |
1377 | | void clear_has_data(); |
1378 | | void set_has_crc32(); |
1379 | | void clear_has_crc32(); |
1380 | | void set_has_total_data_length(); |
1381 | | void clear_has_total_data_length(); |
1382 | | |
1383 | | // helper for ByteSizeLong() |
1384 | | size_t RequiredFieldsByteSizeFallback() const; |
1385 | | |
1386 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
1387 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
1388 | | mutable int _cached_size_; |
1389 | | ::google::protobuf::internal::ArenaStringPtr data_; |
1390 | | ::google::protobuf::uint64 offset_; |
1391 | | ::google::protobuf::int64 total_data_length_; |
1392 | | ::google::protobuf::uint32 crc32_; |
1393 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
1394 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsDataChunkPBImpl(); |
1395 | | }; |
1396 | | // ------------------------------------------------------------------- |
1397 | | |
1398 | | class FetchDataResponsePB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.FetchDataResponsePB) */ { |
1399 | | public: |
1400 | | FetchDataResponsePB(); |
1401 | | virtual ~FetchDataResponsePB(); |
1402 | | |
1403 | | FetchDataResponsePB(const FetchDataResponsePB& from); |
1404 | | |
1405 | 0 | inline FetchDataResponsePB& operator=(const FetchDataResponsePB& from) { |
1406 | 0 | CopyFrom(from); |
1407 | 0 | return *this; |
1408 | 0 | } |
1409 | | #if LANG_CXX11 |
1410 | | FetchDataResponsePB(FetchDataResponsePB&& from) noexcept |
1411 | 0 | : FetchDataResponsePB() { |
1412 | 0 | *this = ::std::move(from); |
1413 | 0 | } |
1414 | | |
1415 | 0 | inline FetchDataResponsePB& operator=(FetchDataResponsePB&& from) noexcept { |
1416 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
1417 | 0 | if (this != &from) InternalSwap(&from); |
1418 | 0 | } else { |
1419 | 0 | CopyFrom(from); |
1420 | 0 | } |
1421 | 0 | return *this; |
1422 | 0 | } |
1423 | | #endif |
1424 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
1425 | 0 | return _internal_metadata_.unknown_fields(); |
1426 | 0 | } |
1427 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
1428 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
1429 | 0 | } |
1430 | | |
1431 | | static const ::google::protobuf::Descriptor* descriptor(); |
1432 | | static const FetchDataResponsePB& default_instance(); |
1433 | | |
1434 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
1435 | 39.1k | static inline const FetchDataResponsePB* internal_default_instance() { |
1436 | 39.1k | return reinterpret_cast<const FetchDataResponsePB*>( |
1437 | 39.1k | &_FetchDataResponsePB_default_instance_); |
1438 | 39.1k | } |
1439 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
1440 | | 8; |
1441 | | |
1442 | | void Swap(FetchDataResponsePB* other); |
1443 | 0 | friend void swap(FetchDataResponsePB& a, FetchDataResponsePB& b) { |
1444 | 0 | a.Swap(&b); |
1445 | 0 | } |
1446 | | |
1447 | | // implements Message ---------------------------------------------- |
1448 | | |
1449 | 0 | inline FetchDataResponsePB* New() const PROTOBUF_FINAL { return New(NULL); } |
1450 | | |
1451 | | FetchDataResponsePB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
1452 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1453 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1454 | | void CopyFrom(const FetchDataResponsePB& from); |
1455 | | void MergeFrom(const FetchDataResponsePB& from); |
1456 | | void Clear() PROTOBUF_FINAL; |
1457 | | bool IsInitialized() const PROTOBUF_FINAL; |
1458 | | |
1459 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
1460 | | bool MergePartialFromCodedStream( |
1461 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
1462 | | void SerializeWithCachedSizes( |
1463 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
1464 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
1465 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
1466 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
1467 | | private: |
1468 | | void SharedCtor(); |
1469 | | void SharedDtor(); |
1470 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
1471 | | void InternalSwap(FetchDataResponsePB* other); |
1472 | | private: |
1473 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
1474 | 0 | return NULL; |
1475 | 0 | } |
1476 | 0 | inline void* MaybeArenaPtr() const { |
1477 | 0 | return NULL; |
1478 | 0 | } |
1479 | | public: |
1480 | | |
1481 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
1482 | | |
1483 | | // nested types ---------------------------------------------------- |
1484 | | |
1485 | | // accessors ------------------------------------------------------- |
1486 | | |
1487 | | // required .yb.tserver.DataChunkPB chunk = 1; |
1488 | | bool has_chunk() const; |
1489 | | void clear_chunk(); |
1490 | | static const int kChunkFieldNumber = 1; |
1491 | | const ::yb::tserver::DataChunkPB& chunk() const; |
1492 | | ::yb::tserver::DataChunkPB* release_chunk(); |
1493 | | ::yb::tserver::DataChunkPB* mutable_chunk(); |
1494 | | void set_allocated_chunk(::yb::tserver::DataChunkPB* chunk); |
1495 | | |
1496 | | // @@protoc_insertion_point(class_scope:yb.tserver.FetchDataResponsePB) |
1497 | | private: |
1498 | | void set_has_chunk(); |
1499 | | void clear_has_chunk(); |
1500 | | |
1501 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
1502 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
1503 | | mutable int _cached_size_; |
1504 | | ::yb::tserver::DataChunkPB* chunk_; |
1505 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
1506 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsFetchDataResponsePBImpl(); |
1507 | | }; |
1508 | | // ------------------------------------------------------------------- |
1509 | | |
1510 | | class EndRemoteBootstrapSessionRequestPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.EndRemoteBootstrapSessionRequestPB) */ { |
1511 | | public: |
1512 | | EndRemoteBootstrapSessionRequestPB(); |
1513 | | virtual ~EndRemoteBootstrapSessionRequestPB(); |
1514 | | |
1515 | | EndRemoteBootstrapSessionRequestPB(const EndRemoteBootstrapSessionRequestPB& from); |
1516 | | |
1517 | 0 | inline EndRemoteBootstrapSessionRequestPB& operator=(const EndRemoteBootstrapSessionRequestPB& from) { |
1518 | 0 | CopyFrom(from); |
1519 | 0 | return *this; |
1520 | 0 | } |
1521 | | #if LANG_CXX11 |
1522 | | EndRemoteBootstrapSessionRequestPB(EndRemoteBootstrapSessionRequestPB&& from) noexcept |
1523 | 0 | : EndRemoteBootstrapSessionRequestPB() { |
1524 | 0 | *this = ::std::move(from); |
1525 | 0 | } |
1526 | | |
1527 | 0 | inline EndRemoteBootstrapSessionRequestPB& operator=(EndRemoteBootstrapSessionRequestPB&& from) noexcept { |
1528 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
1529 | 0 | if (this != &from) InternalSwap(&from); |
1530 | 0 | } else { |
1531 | 0 | CopyFrom(from); |
1532 | 0 | } |
1533 | 0 | return *this; |
1534 | 0 | } |
1535 | | #endif |
1536 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
1537 | 0 | return _internal_metadata_.unknown_fields(); |
1538 | 0 | } |
1539 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
1540 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
1541 | 0 | } |
1542 | | |
1543 | | static const ::google::protobuf::Descriptor* descriptor(); |
1544 | | static const EndRemoteBootstrapSessionRequestPB& default_instance(); |
1545 | | |
1546 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
1547 | 19.8k | static inline const EndRemoteBootstrapSessionRequestPB* internal_default_instance() { |
1548 | 19.8k | return reinterpret_cast<const EndRemoteBootstrapSessionRequestPB*>( |
1549 | 19.8k | &_EndRemoteBootstrapSessionRequestPB_default_instance_); |
1550 | 19.8k | } |
1551 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
1552 | | 9; |
1553 | | |
1554 | | void Swap(EndRemoteBootstrapSessionRequestPB* other); |
1555 | 0 | friend void swap(EndRemoteBootstrapSessionRequestPB& a, EndRemoteBootstrapSessionRequestPB& b) { |
1556 | 0 | a.Swap(&b); |
1557 | 0 | } |
1558 | | |
1559 | | // implements Message ---------------------------------------------- |
1560 | | |
1561 | 0 | inline EndRemoteBootstrapSessionRequestPB* New() const PROTOBUF_FINAL { return New(NULL); } |
1562 | | |
1563 | | EndRemoteBootstrapSessionRequestPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
1564 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1565 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1566 | | void CopyFrom(const EndRemoteBootstrapSessionRequestPB& from); |
1567 | | void MergeFrom(const EndRemoteBootstrapSessionRequestPB& from); |
1568 | | void Clear() PROTOBUF_FINAL; |
1569 | | bool IsInitialized() const PROTOBUF_FINAL; |
1570 | | |
1571 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
1572 | | bool MergePartialFromCodedStream( |
1573 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
1574 | | void SerializeWithCachedSizes( |
1575 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
1576 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
1577 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
1578 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
1579 | | private: |
1580 | | void SharedCtor(); |
1581 | | void SharedDtor(); |
1582 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
1583 | | void InternalSwap(EndRemoteBootstrapSessionRequestPB* other); |
1584 | | private: |
1585 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
1586 | 0 | return NULL; |
1587 | 0 | } |
1588 | 0 | inline void* MaybeArenaPtr() const { |
1589 | 0 | return NULL; |
1590 | 0 | } |
1591 | | public: |
1592 | | |
1593 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
1594 | | |
1595 | | // nested types ---------------------------------------------------- |
1596 | | |
1597 | | // accessors ------------------------------------------------------- |
1598 | | |
1599 | | // required bytes session_id = 1; |
1600 | | bool has_session_id() const; |
1601 | | void clear_session_id(); |
1602 | | static const int kSessionIdFieldNumber = 1; |
1603 | | const ::std::string& session_id() const; |
1604 | | void set_session_id(const ::std::string& value); |
1605 | | #if LANG_CXX11 |
1606 | | void set_session_id(::std::string&& value); |
1607 | | #endif |
1608 | | void set_session_id(const char* value); |
1609 | | void set_session_id(const void* value, size_t size); |
1610 | | ::std::string* mutable_session_id(); |
1611 | | ::std::string* release_session_id(); |
1612 | | void set_allocated_session_id(::std::string* session_id); |
1613 | | |
1614 | | // optional .yb.AppStatusPB error = 3; |
1615 | | bool has_error() const; |
1616 | | void clear_error(); |
1617 | | static const int kErrorFieldNumber = 3; |
1618 | | const ::yb::AppStatusPB& error() const; |
1619 | | ::yb::AppStatusPB* release_error(); |
1620 | | ::yb::AppStatusPB* mutable_error(); |
1621 | | void set_allocated_error(::yb::AppStatusPB* error); |
1622 | | |
1623 | | // required bool is_success = 2; |
1624 | | bool has_is_success() const; |
1625 | | void clear_is_success(); |
1626 | | static const int kIsSuccessFieldNumber = 2; |
1627 | | bool is_success() const; |
1628 | | void set_is_success(bool value); |
1629 | | |
1630 | | // optional bool keep_session = 4 [default = false]; |
1631 | | bool has_keep_session() const; |
1632 | | void clear_keep_session(); |
1633 | | static const int kKeepSessionFieldNumber = 4; |
1634 | | bool keep_session() const; |
1635 | | void set_keep_session(bool value); |
1636 | | |
1637 | | // @@protoc_insertion_point(class_scope:yb.tserver.EndRemoteBootstrapSessionRequestPB) |
1638 | | private: |
1639 | | void set_has_session_id(); |
1640 | | void clear_has_session_id(); |
1641 | | void set_has_is_success(); |
1642 | | void clear_has_is_success(); |
1643 | | void set_has_error(); |
1644 | | void clear_has_error(); |
1645 | | void set_has_keep_session(); |
1646 | | void clear_has_keep_session(); |
1647 | | |
1648 | | // helper for ByteSizeLong() |
1649 | | size_t RequiredFieldsByteSizeFallback() const; |
1650 | | |
1651 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
1652 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
1653 | | mutable int _cached_size_; |
1654 | | ::google::protobuf::internal::ArenaStringPtr session_id_; |
1655 | | ::yb::AppStatusPB* error_; |
1656 | | bool is_success_; |
1657 | | bool keep_session_; |
1658 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
1659 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsEndRemoteBootstrapSessionRequestPBImpl(); |
1660 | | }; |
1661 | | // ------------------------------------------------------------------- |
1662 | | |
1663 | | class EndRemoteBootstrapSessionResponsePB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.EndRemoteBootstrapSessionResponsePB) */ { |
1664 | | public: |
1665 | | EndRemoteBootstrapSessionResponsePB(); |
1666 | | virtual ~EndRemoteBootstrapSessionResponsePB(); |
1667 | | |
1668 | | EndRemoteBootstrapSessionResponsePB(const EndRemoteBootstrapSessionResponsePB& from); |
1669 | | |
1670 | 0 | inline EndRemoteBootstrapSessionResponsePB& operator=(const EndRemoteBootstrapSessionResponsePB& from) { |
1671 | 0 | CopyFrom(from); |
1672 | 0 | return *this; |
1673 | 0 | } |
1674 | | #if LANG_CXX11 |
1675 | | EndRemoteBootstrapSessionResponsePB(EndRemoteBootstrapSessionResponsePB&& from) noexcept |
1676 | 0 | : EndRemoteBootstrapSessionResponsePB() { |
1677 | 0 | *this = ::std::move(from); |
1678 | 0 | } |
1679 | | |
1680 | 0 | inline EndRemoteBootstrapSessionResponsePB& operator=(EndRemoteBootstrapSessionResponsePB&& from) noexcept { |
1681 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
1682 | 0 | if (this != &from) InternalSwap(&from); |
1683 | 0 | } else { |
1684 | 0 | CopyFrom(from); |
1685 | 0 | } |
1686 | 0 | return *this; |
1687 | 0 | } |
1688 | | #endif |
1689 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
1690 | 0 | return _internal_metadata_.unknown_fields(); |
1691 | 0 | } |
1692 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
1693 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
1694 | 0 | } |
1695 | | |
1696 | | static const ::google::protobuf::Descriptor* descriptor(); |
1697 | | static const EndRemoteBootstrapSessionResponsePB& default_instance(); |
1698 | | |
1699 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
1700 | 17.8k | static inline const EndRemoteBootstrapSessionResponsePB* internal_default_instance() { |
1701 | 17.8k | return reinterpret_cast<const EndRemoteBootstrapSessionResponsePB*>( |
1702 | 17.8k | &_EndRemoteBootstrapSessionResponsePB_default_instance_); |
1703 | 17.8k | } |
1704 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
1705 | | 10; |
1706 | | |
1707 | | void Swap(EndRemoteBootstrapSessionResponsePB* other); |
1708 | 0 | friend void swap(EndRemoteBootstrapSessionResponsePB& a, EndRemoteBootstrapSessionResponsePB& b) { |
1709 | 0 | a.Swap(&b); |
1710 | 0 | } |
1711 | | |
1712 | | // implements Message ---------------------------------------------- |
1713 | | |
1714 | 0 | inline EndRemoteBootstrapSessionResponsePB* New() const PROTOBUF_FINAL { return New(NULL); } |
1715 | | |
1716 | | EndRemoteBootstrapSessionResponsePB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
1717 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1718 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1719 | | void CopyFrom(const EndRemoteBootstrapSessionResponsePB& from); |
1720 | | void MergeFrom(const EndRemoteBootstrapSessionResponsePB& from); |
1721 | | void Clear() PROTOBUF_FINAL; |
1722 | | bool IsInitialized() const PROTOBUF_FINAL; |
1723 | | |
1724 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
1725 | | bool MergePartialFromCodedStream( |
1726 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
1727 | | void SerializeWithCachedSizes( |
1728 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
1729 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
1730 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
1731 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
1732 | | private: |
1733 | | void SharedCtor(); |
1734 | | void SharedDtor(); |
1735 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
1736 | | void InternalSwap(EndRemoteBootstrapSessionResponsePB* other); |
1737 | | private: |
1738 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
1739 | 0 | return NULL; |
1740 | 0 | } |
1741 | 0 | inline void* MaybeArenaPtr() const { |
1742 | 0 | return NULL; |
1743 | 0 | } |
1744 | | public: |
1745 | | |
1746 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
1747 | | |
1748 | | // nested types ---------------------------------------------------- |
1749 | | |
1750 | | // accessors ------------------------------------------------------- |
1751 | | |
1752 | | // optional bool session_kept = 1 [default = false]; |
1753 | | bool has_session_kept() const; |
1754 | | void clear_session_kept(); |
1755 | | static const int kSessionKeptFieldNumber = 1; |
1756 | | bool session_kept() const; |
1757 | | void set_session_kept(bool value); |
1758 | | |
1759 | | // @@protoc_insertion_point(class_scope:yb.tserver.EndRemoteBootstrapSessionResponsePB) |
1760 | | private: |
1761 | | void set_has_session_kept(); |
1762 | | void clear_has_session_kept(); |
1763 | | |
1764 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
1765 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
1766 | | mutable int _cached_size_; |
1767 | | bool session_kept_; |
1768 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
1769 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsEndRemoteBootstrapSessionResponsePBImpl(); |
1770 | | }; |
1771 | | // ------------------------------------------------------------------- |
1772 | | |
1773 | | class RemoveSessionRequestPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.RemoveSessionRequestPB) */ { |
1774 | | public: |
1775 | | RemoveSessionRequestPB(); |
1776 | | virtual ~RemoveSessionRequestPB(); |
1777 | | |
1778 | | RemoveSessionRequestPB(const RemoveSessionRequestPB& from); |
1779 | | |
1780 | 0 | inline RemoveSessionRequestPB& operator=(const RemoveSessionRequestPB& from) { |
1781 | 0 | CopyFrom(from); |
1782 | 0 | return *this; |
1783 | 0 | } |
1784 | | #if LANG_CXX11 |
1785 | | RemoveSessionRequestPB(RemoveSessionRequestPB&& from) noexcept |
1786 | 0 | : RemoveSessionRequestPB() { |
1787 | 0 | *this = ::std::move(from); |
1788 | 0 | } |
1789 | | |
1790 | 0 | inline RemoveSessionRequestPB& operator=(RemoveSessionRequestPB&& from) noexcept { |
1791 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
1792 | 0 | if (this != &from) InternalSwap(&from); |
1793 | 0 | } else { |
1794 | 0 | CopyFrom(from); |
1795 | 0 | } |
1796 | 0 | return *this; |
1797 | 0 | } |
1798 | | #endif |
1799 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
1800 | 0 | return _internal_metadata_.unknown_fields(); |
1801 | 0 | } |
1802 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
1803 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
1804 | 0 | } |
1805 | | |
1806 | | static const ::google::protobuf::Descriptor* descriptor(); |
1807 | | static const RemoveSessionRequestPB& default_instance(); |
1808 | | |
1809 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
1810 | 17.7k | static inline const RemoveSessionRequestPB* internal_default_instance() { |
1811 | 17.7k | return reinterpret_cast<const RemoveSessionRequestPB*>( |
1812 | 17.7k | &_RemoveSessionRequestPB_default_instance_); |
1813 | 17.7k | } |
1814 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
1815 | | 11; |
1816 | | |
1817 | | void Swap(RemoveSessionRequestPB* other); |
1818 | 0 | friend void swap(RemoveSessionRequestPB& a, RemoveSessionRequestPB& b) { |
1819 | 0 | a.Swap(&b); |
1820 | 0 | } |
1821 | | |
1822 | | // implements Message ---------------------------------------------- |
1823 | | |
1824 | 0 | inline RemoveSessionRequestPB* New() const PROTOBUF_FINAL { return New(NULL); } |
1825 | | |
1826 | | RemoveSessionRequestPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
1827 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1828 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1829 | | void CopyFrom(const RemoveSessionRequestPB& from); |
1830 | | void MergeFrom(const RemoveSessionRequestPB& from); |
1831 | | void Clear() PROTOBUF_FINAL; |
1832 | | bool IsInitialized() const PROTOBUF_FINAL; |
1833 | | |
1834 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
1835 | | bool MergePartialFromCodedStream( |
1836 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
1837 | | void SerializeWithCachedSizes( |
1838 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
1839 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
1840 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
1841 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
1842 | | private: |
1843 | | void SharedCtor(); |
1844 | | void SharedDtor(); |
1845 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
1846 | | void InternalSwap(RemoveSessionRequestPB* other); |
1847 | | private: |
1848 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
1849 | 0 | return NULL; |
1850 | 0 | } |
1851 | 0 | inline void* MaybeArenaPtr() const { |
1852 | 0 | return NULL; |
1853 | 0 | } |
1854 | | public: |
1855 | | |
1856 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
1857 | | |
1858 | | // nested types ---------------------------------------------------- |
1859 | | |
1860 | | // accessors ------------------------------------------------------- |
1861 | | |
1862 | | // optional bytes session_id = 1; |
1863 | | bool has_session_id() const; |
1864 | | void clear_session_id(); |
1865 | | static const int kSessionIdFieldNumber = 1; |
1866 | | const ::std::string& session_id() const; |
1867 | | void set_session_id(const ::std::string& value); |
1868 | | #if LANG_CXX11 |
1869 | | void set_session_id(::std::string&& value); |
1870 | | #endif |
1871 | | void set_session_id(const char* value); |
1872 | | void set_session_id(const void* value, size_t size); |
1873 | | ::std::string* mutable_session_id(); |
1874 | | ::std::string* release_session_id(); |
1875 | | void set_allocated_session_id(::std::string* session_id); |
1876 | | |
1877 | | // @@protoc_insertion_point(class_scope:yb.tserver.RemoveSessionRequestPB) |
1878 | | private: |
1879 | | void set_has_session_id(); |
1880 | | void clear_has_session_id(); |
1881 | | |
1882 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
1883 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
1884 | | mutable int _cached_size_; |
1885 | | ::google::protobuf::internal::ArenaStringPtr session_id_; |
1886 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
1887 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsRemoveSessionRequestPBImpl(); |
1888 | | }; |
1889 | | // ------------------------------------------------------------------- |
1890 | | |
1891 | | class RemoveSessionResponsePB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.tserver.RemoveSessionResponsePB) */ { |
1892 | | public: |
1893 | | RemoveSessionResponsePB(); |
1894 | | virtual ~RemoveSessionResponsePB(); |
1895 | | |
1896 | | RemoveSessionResponsePB(const RemoveSessionResponsePB& from); |
1897 | | |
1898 | 0 | inline RemoveSessionResponsePB& operator=(const RemoveSessionResponsePB& from) { |
1899 | 0 | CopyFrom(from); |
1900 | 0 | return *this; |
1901 | 0 | } |
1902 | | #if LANG_CXX11 |
1903 | | RemoveSessionResponsePB(RemoveSessionResponsePB&& from) noexcept |
1904 | 0 | : RemoveSessionResponsePB() { |
1905 | 0 | *this = ::std::move(from); |
1906 | 0 | } |
1907 | | |
1908 | 0 | inline RemoveSessionResponsePB& operator=(RemoveSessionResponsePB&& from) noexcept { |
1909 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
1910 | 0 | if (this != &from) InternalSwap(&from); |
1911 | 0 | } else { |
1912 | 0 | CopyFrom(from); |
1913 | 0 | } |
1914 | 0 | return *this; |
1915 | 0 | } |
1916 | | #endif |
1917 | 0 | inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { |
1918 | 0 | return _internal_metadata_.unknown_fields(); |
1919 | 0 | } |
1920 | 0 | inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { |
1921 | 0 | return _internal_metadata_.mutable_unknown_fields(); |
1922 | 0 | } |
1923 | | |
1924 | | static const ::google::protobuf::Descriptor* descriptor(); |
1925 | | static const RemoveSessionResponsePB& default_instance(); |
1926 | | |
1927 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
1928 | 17.7k | static inline const RemoveSessionResponsePB* internal_default_instance() { |
1929 | 17.7k | return reinterpret_cast<const RemoveSessionResponsePB*>( |
1930 | 17.7k | &_RemoveSessionResponsePB_default_instance_); |
1931 | 17.7k | } |
1932 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
1933 | | 12; |
1934 | | |
1935 | | void Swap(RemoveSessionResponsePB* other); |
1936 | 0 | friend void swap(RemoveSessionResponsePB& a, RemoveSessionResponsePB& b) { |
1937 | 0 | a.Swap(&b); |
1938 | 0 | } |
1939 | | |
1940 | | // implements Message ---------------------------------------------- |
1941 | | |
1942 | 0 | inline RemoveSessionResponsePB* New() const PROTOBUF_FINAL { return New(NULL); } |
1943 | | |
1944 | | RemoveSessionResponsePB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
1945 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1946 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
1947 | | void CopyFrom(const RemoveSessionResponsePB& from); |
1948 | | void MergeFrom(const RemoveSessionResponsePB& from); |
1949 | | void Clear() PROTOBUF_FINAL; |
1950 | | bool IsInitialized() const PROTOBUF_FINAL; |
1951 | | |
1952 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
1953 | | bool MergePartialFromCodedStream( |
1954 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
1955 | | void SerializeWithCachedSizes( |
1956 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
1957 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
1958 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
1959 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
1960 | | private: |
1961 | | void SharedCtor(); |
1962 | | void SharedDtor(); |
1963 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
1964 | | void InternalSwap(RemoveSessionResponsePB* other); |
1965 | | private: |
1966 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
1967 | 0 | return NULL; |
1968 | 0 | } |
1969 | 0 | inline void* MaybeArenaPtr() const { |
1970 | 0 | return NULL; |
1971 | 0 | } |
1972 | | public: |
1973 | | |
1974 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
1975 | | |
1976 | | // nested types ---------------------------------------------------- |
1977 | | |
1978 | | // accessors ------------------------------------------------------- |
1979 | | |
1980 | | // @@protoc_insertion_point(class_scope:yb.tserver.RemoveSessionResponsePB) |
1981 | | private: |
1982 | | |
1983 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
1984 | | ::google::protobuf::internal::HasBits<1> _has_bits_; |
1985 | | mutable int _cached_size_; |
1986 | | friend struct ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::TableStruct; |
1987 | | friend void ::protobuf_yb_2ftserver_2fremote_5fbootstrap_2eproto::InitDefaultsRemoveSessionResponsePBImpl(); |
1988 | | }; |
1989 | | // =================================================================== |
1990 | | |
1991 | | |
1992 | | // =================================================================== |
1993 | | |
1994 | | #ifdef __GNUC__ |
1995 | | #pragma GCC diagnostic push |
1996 | | #pragma GCC diagnostic ignored "-Wstrict-aliasing" |
1997 | | #endif // __GNUC__ |
1998 | | // RemoteBootstrapErrorPB |
1999 | | |
2000 | | // required .yb.tserver.RemoteBootstrapErrorPB.Code code = 1 [default = UNKNOWN_ERROR]; |
2001 | 0 | inline bool RemoteBootstrapErrorPB::has_code() const { |
2002 | 0 | return (_has_bits_[0] & 0x00000002u) != 0; |
2003 | 0 | } |
2004 | 2.04k | inline void RemoteBootstrapErrorPB::set_has_code() { |
2005 | 2.04k | _has_bits_[0] |= 0x00000002u; |
2006 | 2.04k | } |
2007 | 0 | inline void RemoteBootstrapErrorPB::clear_has_code() { |
2008 | 0 | _has_bits_[0] &= ~0x00000002u; |
2009 | 0 | } |
2010 | 0 | inline void RemoteBootstrapErrorPB::clear_code() { |
2011 | 0 | code_ = 1; |
2012 | 0 | clear_has_code(); |
2013 | 0 | } |
2014 | 4.08k | inline ::yb::tserver::RemoteBootstrapErrorPB_Code RemoteBootstrapErrorPB::code() const { |
2015 | | // @@protoc_insertion_point(field_get:yb.tserver.RemoteBootstrapErrorPB.code) |
2016 | 4.08k | return static_cast< ::yb::tserver::RemoteBootstrapErrorPB_Code >(code_); |
2017 | 4.08k | } |
2018 | 2.04k | inline void RemoteBootstrapErrorPB::set_code(::yb::tserver::RemoteBootstrapErrorPB_Code value) { |
2019 | 2.04k | assert(::yb::tserver::RemoteBootstrapErrorPB_Code_IsValid(value)); |
2020 | 2.04k | set_has_code(); |
2021 | 2.04k | code_ = value; |
2022 | | // @@protoc_insertion_point(field_set:yb.tserver.RemoteBootstrapErrorPB.code) |
2023 | 2.04k | } |
2024 | | |
2025 | | // required .yb.AppStatusPB status = 2; |
2026 | 2.04k | inline bool RemoteBootstrapErrorPB::has_status() const { |
2027 | 2.04k | return (_has_bits_[0] & 0x00000001u) != 0; |
2028 | 2.04k | } |
2029 | 3.06k | inline void RemoteBootstrapErrorPB::set_has_status() { |
2030 | 3.06k | _has_bits_[0] |= 0x00000001u; |
2031 | 3.06k | } |
2032 | 0 | inline void RemoteBootstrapErrorPB::clear_has_status() { |
2033 | 0 | _has_bits_[0] &= ~0x00000001u; |
2034 | 0 | } |
2035 | 2.05k | inline const ::yb::AppStatusPB& RemoteBootstrapErrorPB::status() const { |
2036 | 2.05k | const ::yb::AppStatusPB* p = status_; |
2037 | | // @@protoc_insertion_point(field_get:yb.tserver.RemoteBootstrapErrorPB.status) |
2038 | 2.05k | return p != NULL ? *p : *reinterpret_cast<const ::yb::AppStatusPB*>( |
2039 | 0 | &::yb::_AppStatusPB_default_instance_); |
2040 | 2.05k | } |
2041 | 0 | inline ::yb::AppStatusPB* RemoteBootstrapErrorPB::release_status() { |
2042 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.RemoteBootstrapErrorPB.status) |
2043 | 0 | clear_has_status(); |
2044 | 0 | ::yb::AppStatusPB* temp = status_; |
2045 | 0 | status_ = NULL; |
2046 | 0 | return temp; |
2047 | 0 | } |
2048 | 3.06k | inline ::yb::AppStatusPB* RemoteBootstrapErrorPB::mutable_status() { |
2049 | 3.06k | set_has_status(); |
2050 | 3.06k | if (status_ == NULL) { |
2051 | 3.06k | status_ = new ::yb::AppStatusPB; |
2052 | 3.06k | } |
2053 | | // @@protoc_insertion_point(field_mutable:yb.tserver.RemoteBootstrapErrorPB.status) |
2054 | 3.06k | return status_; |
2055 | 3.06k | } |
2056 | 0 | inline void RemoteBootstrapErrorPB::set_allocated_status(::yb::AppStatusPB* status) { |
2057 | 0 | ::google::protobuf::Arena* message_arena = GetArenaNoVirtual(); |
2058 | 0 | if (message_arena == NULL) { |
2059 | 0 | delete reinterpret_cast< ::google::protobuf::MessageLite*>(status_); |
2060 | 0 | } |
2061 | 0 | if (status) { |
2062 | 0 | ::google::protobuf::Arena* submessage_arena = NULL; |
2063 | 0 | if (message_arena != submessage_arena) { |
2064 | 0 | status = ::google::protobuf::internal::GetOwnedMessage( |
2065 | 0 | message_arena, status, submessage_arena); |
2066 | 0 | } |
2067 | 0 | set_has_status(); |
2068 | 0 | } else { |
2069 | 0 | clear_has_status(); |
2070 | 0 | } |
2071 | 0 | status_ = status; |
2072 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.RemoteBootstrapErrorPB.status) |
2073 | 0 | } |
2074 | | |
2075 | | // ------------------------------------------------------------------- |
2076 | | |
2077 | | // BeginRemoteBootstrapSessionRequestPB |
2078 | | |
2079 | | // required bytes requestor_uuid = 1; |
2080 | 0 | inline bool BeginRemoteBootstrapSessionRequestPB::has_requestor_uuid() const { |
2081 | 0 | return (_has_bits_[0] & 0x00000001u) != 0; |
2082 | 0 | } |
2083 | 2.91k | inline void BeginRemoteBootstrapSessionRequestPB::set_has_requestor_uuid() { |
2084 | 2.91k | _has_bits_[0] |= 0x00000001u; |
2085 | 2.91k | } |
2086 | 0 | inline void BeginRemoteBootstrapSessionRequestPB::clear_has_requestor_uuid() { |
2087 | 0 | _has_bits_[0] &= ~0x00000001u; |
2088 | 0 | } |
2089 | 0 | inline void BeginRemoteBootstrapSessionRequestPB::clear_requestor_uuid() { |
2090 | 0 | requestor_uuid_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2091 | 0 | clear_has_requestor_uuid(); |
2092 | 0 | } |
2093 | 5.81k | inline const ::std::string& BeginRemoteBootstrapSessionRequestPB::requestor_uuid() const { |
2094 | | // @@protoc_insertion_point(field_get:yb.tserver.BeginRemoteBootstrapSessionRequestPB.requestor_uuid) |
2095 | 5.81k | return requestor_uuid_.GetNoArena(); |
2096 | 5.81k | } |
2097 | 1.45k | inline void BeginRemoteBootstrapSessionRequestPB::set_requestor_uuid(const ::std::string& value) { |
2098 | 1.45k | set_has_requestor_uuid(); |
2099 | 1.45k | requestor_uuid_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); |
2100 | | // @@protoc_insertion_point(field_set:yb.tserver.BeginRemoteBootstrapSessionRequestPB.requestor_uuid) |
2101 | 1.45k | } |
2102 | | #if LANG_CXX11 |
2103 | 0 | inline void BeginRemoteBootstrapSessionRequestPB::set_requestor_uuid(::std::string&& value) { |
2104 | 0 | set_has_requestor_uuid(); |
2105 | 0 | requestor_uuid_.SetNoArena( |
2106 | 0 | &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); |
2107 | 0 | // @@protoc_insertion_point(field_set_rvalue:yb.tserver.BeginRemoteBootstrapSessionRequestPB.requestor_uuid) |
2108 | 0 | } |
2109 | | #endif |
2110 | 0 | inline void BeginRemoteBootstrapSessionRequestPB::set_requestor_uuid(const char* value) { |
2111 | 0 | GOOGLE_DCHECK(value != NULL); |
2112 | 0 | set_has_requestor_uuid(); |
2113 | 0 | requestor_uuid_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); |
2114 | 0 | // @@protoc_insertion_point(field_set_char:yb.tserver.BeginRemoteBootstrapSessionRequestPB.requestor_uuid) |
2115 | 0 | } |
2116 | 0 | inline void BeginRemoteBootstrapSessionRequestPB::set_requestor_uuid(const void* value, size_t size) { |
2117 | 0 | set_has_requestor_uuid(); |
2118 | 0 | requestor_uuid_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), |
2119 | 0 | ::std::string(reinterpret_cast<const char*>(value), size)); |
2120 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.tserver.BeginRemoteBootstrapSessionRequestPB.requestor_uuid) |
2121 | 0 | } |
2122 | 1.45k | inline ::std::string* BeginRemoteBootstrapSessionRequestPB::mutable_requestor_uuid() { |
2123 | 1.45k | set_has_requestor_uuid(); |
2124 | | // @@protoc_insertion_point(field_mutable:yb.tserver.BeginRemoteBootstrapSessionRequestPB.requestor_uuid) |
2125 | 1.45k | return requestor_uuid_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2126 | 1.45k | } |
2127 | 0 | inline ::std::string* BeginRemoteBootstrapSessionRequestPB::release_requestor_uuid() { |
2128 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.BeginRemoteBootstrapSessionRequestPB.requestor_uuid) |
2129 | 0 | clear_has_requestor_uuid(); |
2130 | 0 | return requestor_uuid_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2131 | 0 | } |
2132 | 0 | inline void BeginRemoteBootstrapSessionRequestPB::set_allocated_requestor_uuid(::std::string* requestor_uuid) { |
2133 | 0 | if (requestor_uuid != NULL) { |
2134 | 0 | set_has_requestor_uuid(); |
2135 | 0 | } else { |
2136 | 0 | clear_has_requestor_uuid(); |
2137 | 0 | } |
2138 | 0 | requestor_uuid_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), requestor_uuid); |
2139 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.BeginRemoteBootstrapSessionRequestPB.requestor_uuid) |
2140 | 0 | } |
2141 | | |
2142 | | // required bytes tablet_id = 2; |
2143 | 0 | inline bool BeginRemoteBootstrapSessionRequestPB::has_tablet_id() const { |
2144 | 0 | return (_has_bits_[0] & 0x00000002u) != 0; |
2145 | 0 | } |
2146 | 2.91k | inline void BeginRemoteBootstrapSessionRequestPB::set_has_tablet_id() { |
2147 | 2.91k | _has_bits_[0] |= 0x00000002u; |
2148 | 2.91k | } |
2149 | 0 | inline void BeginRemoteBootstrapSessionRequestPB::clear_has_tablet_id() { |
2150 | 0 | _has_bits_[0] &= ~0x00000002u; |
2151 | 0 | } |
2152 | 0 | inline void BeginRemoteBootstrapSessionRequestPB::clear_tablet_id() { |
2153 | 0 | tablet_id_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2154 | 0 | clear_has_tablet_id(); |
2155 | 0 | } |
2156 | 5.81k | inline const ::std::string& BeginRemoteBootstrapSessionRequestPB::tablet_id() const { |
2157 | | // @@protoc_insertion_point(field_get:yb.tserver.BeginRemoteBootstrapSessionRequestPB.tablet_id) |
2158 | 5.81k | return tablet_id_.GetNoArena(); |
2159 | 5.81k | } |
2160 | 1.45k | inline void BeginRemoteBootstrapSessionRequestPB::set_tablet_id(const ::std::string& value) { |
2161 | 1.45k | set_has_tablet_id(); |
2162 | 1.45k | tablet_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); |
2163 | | // @@protoc_insertion_point(field_set:yb.tserver.BeginRemoteBootstrapSessionRequestPB.tablet_id) |
2164 | 1.45k | } |
2165 | | #if LANG_CXX11 |
2166 | 0 | inline void BeginRemoteBootstrapSessionRequestPB::set_tablet_id(::std::string&& value) { |
2167 | 0 | set_has_tablet_id(); |
2168 | 0 | tablet_id_.SetNoArena( |
2169 | 0 | &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); |
2170 | 0 | // @@protoc_insertion_point(field_set_rvalue:yb.tserver.BeginRemoteBootstrapSessionRequestPB.tablet_id) |
2171 | 0 | } |
2172 | | #endif |
2173 | 0 | inline void BeginRemoteBootstrapSessionRequestPB::set_tablet_id(const char* value) { |
2174 | 0 | GOOGLE_DCHECK(value != NULL); |
2175 | 0 | set_has_tablet_id(); |
2176 | 0 | tablet_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); |
2177 | 0 | // @@protoc_insertion_point(field_set_char:yb.tserver.BeginRemoteBootstrapSessionRequestPB.tablet_id) |
2178 | 0 | } |
2179 | 0 | inline void BeginRemoteBootstrapSessionRequestPB::set_tablet_id(const void* value, size_t size) { |
2180 | 0 | set_has_tablet_id(); |
2181 | 0 | tablet_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), |
2182 | 0 | ::std::string(reinterpret_cast<const char*>(value), size)); |
2183 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.tserver.BeginRemoteBootstrapSessionRequestPB.tablet_id) |
2184 | 0 | } |
2185 | 1.45k | inline ::std::string* BeginRemoteBootstrapSessionRequestPB::mutable_tablet_id() { |
2186 | 1.45k | set_has_tablet_id(); |
2187 | | // @@protoc_insertion_point(field_mutable:yb.tserver.BeginRemoteBootstrapSessionRequestPB.tablet_id) |
2188 | 1.45k | return tablet_id_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2189 | 1.45k | } |
2190 | 0 | inline ::std::string* BeginRemoteBootstrapSessionRequestPB::release_tablet_id() { |
2191 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.BeginRemoteBootstrapSessionRequestPB.tablet_id) |
2192 | 0 | clear_has_tablet_id(); |
2193 | 0 | return tablet_id_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2194 | 0 | } |
2195 | 0 | inline void BeginRemoteBootstrapSessionRequestPB::set_allocated_tablet_id(::std::string* tablet_id) { |
2196 | 0 | if (tablet_id != NULL) { |
2197 | 0 | set_has_tablet_id(); |
2198 | 0 | } else { |
2199 | 0 | clear_has_tablet_id(); |
2200 | 0 | } |
2201 | 0 | tablet_id_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), tablet_id); |
2202 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.BeginRemoteBootstrapSessionRequestPB.tablet_id) |
2203 | 0 | } |
2204 | | |
2205 | | // ------------------------------------------------------------------- |
2206 | | |
2207 | | // BeginRemoteBootstrapSessionResponsePB |
2208 | | |
2209 | | // required bytes session_id = 1; |
2210 | 0 | inline bool BeginRemoteBootstrapSessionResponsePB::has_session_id() const { |
2211 | 0 | return (_has_bits_[0] & 0x00000001u) != 0; |
2212 | 0 | } |
2213 | 2.88k | inline void BeginRemoteBootstrapSessionResponsePB::set_has_session_id() { |
2214 | 2.88k | _has_bits_[0] |= 0x00000001u; |
2215 | 2.88k | } |
2216 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::clear_has_session_id() { |
2217 | 0 | _has_bits_[0] &= ~0x00000001u; |
2218 | 0 | } |
2219 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::clear_session_id() { |
2220 | 0 | session_id_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2221 | 0 | clear_has_session_id(); |
2222 | 0 | } |
2223 | 5.75k | inline const ::std::string& BeginRemoteBootstrapSessionResponsePB::session_id() const { |
2224 | | // @@protoc_insertion_point(field_get:yb.tserver.BeginRemoteBootstrapSessionResponsePB.session_id) |
2225 | 5.75k | return session_id_.GetNoArena(); |
2226 | 5.75k | } |
2227 | 1.44k | inline void BeginRemoteBootstrapSessionResponsePB::set_session_id(const ::std::string& value) { |
2228 | 1.44k | set_has_session_id(); |
2229 | 1.44k | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); |
2230 | | // @@protoc_insertion_point(field_set:yb.tserver.BeginRemoteBootstrapSessionResponsePB.session_id) |
2231 | 1.44k | } |
2232 | | #if LANG_CXX11 |
2233 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::set_session_id(::std::string&& value) { |
2234 | 0 | set_has_session_id(); |
2235 | 0 | session_id_.SetNoArena( |
2236 | 0 | &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); |
2237 | 0 | // @@protoc_insertion_point(field_set_rvalue:yb.tserver.BeginRemoteBootstrapSessionResponsePB.session_id) |
2238 | 0 | } |
2239 | | #endif |
2240 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::set_session_id(const char* value) { |
2241 | 0 | GOOGLE_DCHECK(value != NULL); |
2242 | 0 | set_has_session_id(); |
2243 | 0 | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); |
2244 | 0 | // @@protoc_insertion_point(field_set_char:yb.tserver.BeginRemoteBootstrapSessionResponsePB.session_id) |
2245 | 0 | } |
2246 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::set_session_id(const void* value, size_t size) { |
2247 | 0 | set_has_session_id(); |
2248 | 0 | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), |
2249 | 0 | ::std::string(reinterpret_cast<const char*>(value), size)); |
2250 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.tserver.BeginRemoteBootstrapSessionResponsePB.session_id) |
2251 | 0 | } |
2252 | 1.44k | inline ::std::string* BeginRemoteBootstrapSessionResponsePB::mutable_session_id() { |
2253 | 1.44k | set_has_session_id(); |
2254 | | // @@protoc_insertion_point(field_mutable:yb.tserver.BeginRemoteBootstrapSessionResponsePB.session_id) |
2255 | 1.44k | return session_id_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2256 | 1.44k | } |
2257 | 0 | inline ::std::string* BeginRemoteBootstrapSessionResponsePB::release_session_id() { |
2258 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.BeginRemoteBootstrapSessionResponsePB.session_id) |
2259 | 0 | clear_has_session_id(); |
2260 | 0 | return session_id_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2261 | 0 | } |
2262 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::set_allocated_session_id(::std::string* session_id) { |
2263 | 0 | if (session_id != NULL) { |
2264 | 0 | set_has_session_id(); |
2265 | 0 | } else { |
2266 | 0 | clear_has_session_id(); |
2267 | 0 | } |
2268 | 0 | session_id_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), session_id); |
2269 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.BeginRemoteBootstrapSessionResponsePB.session_id) |
2270 | 0 | } |
2271 | | |
2272 | | // required uint64 session_idle_timeout_millis = 2; |
2273 | 0 | inline bool BeginRemoteBootstrapSessionResponsePB::has_session_idle_timeout_millis() const { |
2274 | 0 | return (_has_bits_[0] & 0x00000008u) != 0; |
2275 | 0 | } |
2276 | 2.88k | inline void BeginRemoteBootstrapSessionResponsePB::set_has_session_idle_timeout_millis() { |
2277 | 2.88k | _has_bits_[0] |= 0x00000008u; |
2278 | 2.88k | } |
2279 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::clear_has_session_idle_timeout_millis() { |
2280 | 0 | _has_bits_[0] &= ~0x00000008u; |
2281 | 0 | } |
2282 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::clear_session_idle_timeout_millis() { |
2283 | 0 | session_idle_timeout_millis_ = GOOGLE_ULONGLONG(0); |
2284 | 0 | clear_has_session_idle_timeout_millis(); |
2285 | 0 | } |
2286 | 5.75k | inline ::google::protobuf::uint64 BeginRemoteBootstrapSessionResponsePB::session_idle_timeout_millis() const { |
2287 | | // @@protoc_insertion_point(field_get:yb.tserver.BeginRemoteBootstrapSessionResponsePB.session_idle_timeout_millis) |
2288 | 5.75k | return session_idle_timeout_millis_; |
2289 | 5.75k | } |
2290 | 1.43k | inline void BeginRemoteBootstrapSessionResponsePB::set_session_idle_timeout_millis(::google::protobuf::uint64 value) { |
2291 | 1.43k | set_has_session_idle_timeout_millis(); |
2292 | 1.43k | session_idle_timeout_millis_ = value; |
2293 | | // @@protoc_insertion_point(field_set:yb.tserver.BeginRemoteBootstrapSessionResponsePB.session_idle_timeout_millis) |
2294 | 1.43k | } |
2295 | | |
2296 | | // required .yb.tablet.RaftGroupReplicaSuperBlockPB superblock = 3; |
2297 | 2.88k | inline bool BeginRemoteBootstrapSessionResponsePB::has_superblock() const { |
2298 | 2.88k | return (_has_bits_[0] & 0x00000002u) != 0; |
2299 | 2.88k | } |
2300 | 5.75k | inline void BeginRemoteBootstrapSessionResponsePB::set_has_superblock() { |
2301 | 5.75k | _has_bits_[0] |= 0x00000002u; |
2302 | 5.75k | } |
2303 | 1.43k | inline void BeginRemoteBootstrapSessionResponsePB::clear_has_superblock() { |
2304 | 1.43k | _has_bits_[0] &= ~0x00000002u; |
2305 | 1.43k | } |
2306 | 5.74k | inline const ::yb::tablet::RaftGroupReplicaSuperBlockPB& BeginRemoteBootstrapSessionResponsePB::superblock() const { |
2307 | 5.74k | const ::yb::tablet::RaftGroupReplicaSuperBlockPB* p = superblock_; |
2308 | | // @@protoc_insertion_point(field_get:yb.tserver.BeginRemoteBootstrapSessionResponsePB.superblock) |
2309 | 5.74k | return p != NULL ? *p : *reinterpret_cast<const ::yb::tablet::RaftGroupReplicaSuperBlockPB*>( |
2310 | 1 | &::yb::tablet::_RaftGroupReplicaSuperBlockPB_default_instance_); |
2311 | 5.74k | } |
2312 | 1.43k | inline ::yb::tablet::RaftGroupReplicaSuperBlockPB* BeginRemoteBootstrapSessionResponsePB::release_superblock() { |
2313 | | // @@protoc_insertion_point(field_release:yb.tserver.BeginRemoteBootstrapSessionResponsePB.superblock) |
2314 | 1.43k | clear_has_superblock(); |
2315 | 1.43k | ::yb::tablet::RaftGroupReplicaSuperBlockPB* temp = superblock_; |
2316 | 1.43k | superblock_ = NULL; |
2317 | 1.43k | return temp; |
2318 | 1.43k | } |
2319 | 5.75k | inline ::yb::tablet::RaftGroupReplicaSuperBlockPB* BeginRemoteBootstrapSessionResponsePB::mutable_superblock() { |
2320 | 5.75k | set_has_superblock(); |
2321 | 5.75k | if (superblock_ == NULL) { |
2322 | 2.87k | superblock_ = new ::yb::tablet::RaftGroupReplicaSuperBlockPB; |
2323 | 2.87k | } |
2324 | | // @@protoc_insertion_point(field_mutable:yb.tserver.BeginRemoteBootstrapSessionResponsePB.superblock) |
2325 | 5.75k | return superblock_; |
2326 | 5.75k | } |
2327 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::set_allocated_superblock(::yb::tablet::RaftGroupReplicaSuperBlockPB* superblock) { |
2328 | 0 | ::google::protobuf::Arena* message_arena = GetArenaNoVirtual(); |
2329 | 0 | if (message_arena == NULL) { |
2330 | 0 | delete reinterpret_cast< ::google::protobuf::MessageLite*>(superblock_); |
2331 | 0 | } |
2332 | 0 | if (superblock) { |
2333 | 0 | ::google::protobuf::Arena* submessage_arena = NULL; |
2334 | 0 | if (message_arena != submessage_arena) { |
2335 | 0 | superblock = ::google::protobuf::internal::GetOwnedMessage( |
2336 | 0 | message_arena, superblock, submessage_arena); |
2337 | 0 | } |
2338 | 0 | set_has_superblock(); |
2339 | 0 | } else { |
2340 | 0 | clear_has_superblock(); |
2341 | 0 | } |
2342 | 0 | superblock_ = superblock; |
2343 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.BeginRemoteBootstrapSessionResponsePB.superblock) |
2344 | 0 | } |
2345 | | |
2346 | | // repeated uint64 DEPRECATED_wal_segment_seqnos = 4; |
2347 | 2.88k | inline int BeginRemoteBootstrapSessionResponsePB::deprecated_wal_segment_seqnos_size() const { |
2348 | 2.88k | return deprecated_wal_segment_seqnos_.size(); |
2349 | 2.88k | } |
2350 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::clear_deprecated_wal_segment_seqnos() { |
2351 | 0 | deprecated_wal_segment_seqnos_.Clear(); |
2352 | 0 | } |
2353 | 0 | inline ::google::protobuf::uint64 BeginRemoteBootstrapSessionResponsePB::deprecated_wal_segment_seqnos(int index) const { |
2354 | 0 | // @@protoc_insertion_point(field_get:yb.tserver.BeginRemoteBootstrapSessionResponsePB.DEPRECATED_wal_segment_seqnos) |
2355 | 0 | return deprecated_wal_segment_seqnos_.Get(index); |
2356 | 0 | } |
2357 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::set_deprecated_wal_segment_seqnos(int index, ::google::protobuf::uint64 value) { |
2358 | 0 | deprecated_wal_segment_seqnos_.Set(index, value); |
2359 | 0 | // @@protoc_insertion_point(field_set:yb.tserver.BeginRemoteBootstrapSessionResponsePB.DEPRECATED_wal_segment_seqnos) |
2360 | 0 | } |
2361 | 1.69k | inline void BeginRemoteBootstrapSessionResponsePB::add_deprecated_wal_segment_seqnos(::google::protobuf::uint64 value) { |
2362 | 1.69k | deprecated_wal_segment_seqnos_.Add(value); |
2363 | | // @@protoc_insertion_point(field_add:yb.tserver.BeginRemoteBootstrapSessionResponsePB.DEPRECATED_wal_segment_seqnos) |
2364 | 1.69k | } |
2365 | | inline const ::google::protobuf::RepeatedField< ::google::protobuf::uint64 >& |
2366 | 4.30k | BeginRemoteBootstrapSessionResponsePB::deprecated_wal_segment_seqnos() const { |
2367 | | // @@protoc_insertion_point(field_list:yb.tserver.BeginRemoteBootstrapSessionResponsePB.DEPRECATED_wal_segment_seqnos) |
2368 | 4.30k | return deprecated_wal_segment_seqnos_; |
2369 | 4.30k | } |
2370 | | inline ::google::protobuf::RepeatedField< ::google::protobuf::uint64 >* |
2371 | 2.88k | BeginRemoteBootstrapSessionResponsePB::mutable_deprecated_wal_segment_seqnos() { |
2372 | | // @@protoc_insertion_point(field_mutable_list:yb.tserver.BeginRemoteBootstrapSessionResponsePB.DEPRECATED_wal_segment_seqnos) |
2373 | 2.88k | return &deprecated_wal_segment_seqnos_; |
2374 | 2.88k | } |
2375 | | |
2376 | | // optional uint64 first_wal_segment_seqno = 6; |
2377 | 4.31k | inline bool BeginRemoteBootstrapSessionResponsePB::has_first_wal_segment_seqno() const { |
2378 | 4.31k | return (_has_bits_[0] & 0x00000010u) != 0; |
2379 | 4.31k | } |
2380 | 2.88k | inline void BeginRemoteBootstrapSessionResponsePB::set_has_first_wal_segment_seqno() { |
2381 | 2.88k | _has_bits_[0] |= 0x00000010u; |
2382 | 2.88k | } |
2383 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::clear_has_first_wal_segment_seqno() { |
2384 | 0 | _has_bits_[0] &= ~0x00000010u; |
2385 | 0 | } |
2386 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::clear_first_wal_segment_seqno() { |
2387 | 0 | first_wal_segment_seqno_ = GOOGLE_ULONGLONG(0); |
2388 | 0 | clear_has_first_wal_segment_seqno(); |
2389 | 0 | } |
2390 | 5.75k | inline ::google::protobuf::uint64 BeginRemoteBootstrapSessionResponsePB::first_wal_segment_seqno() const { |
2391 | | // @@protoc_insertion_point(field_get:yb.tserver.BeginRemoteBootstrapSessionResponsePB.first_wal_segment_seqno) |
2392 | 5.75k | return first_wal_segment_seqno_; |
2393 | 5.75k | } |
2394 | 1.44k | inline void BeginRemoteBootstrapSessionResponsePB::set_first_wal_segment_seqno(::google::protobuf::uint64 value) { |
2395 | 1.44k | set_has_first_wal_segment_seqno(); |
2396 | 1.44k | first_wal_segment_seqno_ = value; |
2397 | | // @@protoc_insertion_point(field_set:yb.tserver.BeginRemoteBootstrapSessionResponsePB.first_wal_segment_seqno) |
2398 | 1.44k | } |
2399 | | |
2400 | | // required .yb.consensus.ConsensusStatePB initial_committed_cstate = 5; |
2401 | 2.88k | inline bool BeginRemoteBootstrapSessionResponsePB::has_initial_committed_cstate() const { |
2402 | 2.88k | return (_has_bits_[0] & 0x00000004u) != 0; |
2403 | 2.88k | } |
2404 | 2.88k | inline void BeginRemoteBootstrapSessionResponsePB::set_has_initial_committed_cstate() { |
2405 | 2.88k | _has_bits_[0] |= 0x00000004u; |
2406 | 2.88k | } |
2407 | 1.43k | inline void BeginRemoteBootstrapSessionResponsePB::clear_has_initial_committed_cstate() { |
2408 | 1.43k | _has_bits_[0] &= ~0x00000004u; |
2409 | 1.43k | } |
2410 | 0 | inline const ::yb::consensus::ConsensusStatePB& BeginRemoteBootstrapSessionResponsePB::initial_committed_cstate() const { |
2411 | 0 | const ::yb::consensus::ConsensusStatePB* p = initial_committed_cstate_; |
2412 | 0 | // @@protoc_insertion_point(field_get:yb.tserver.BeginRemoteBootstrapSessionResponsePB.initial_committed_cstate) |
2413 | 0 | return p != NULL ? *p : *reinterpret_cast<const ::yb::consensus::ConsensusStatePB*>( |
2414 | 0 | &::yb::consensus::_ConsensusStatePB_default_instance_); |
2415 | 0 | } |
2416 | 1.43k | inline ::yb::consensus::ConsensusStatePB* BeginRemoteBootstrapSessionResponsePB::release_initial_committed_cstate() { |
2417 | | // @@protoc_insertion_point(field_release:yb.tserver.BeginRemoteBootstrapSessionResponsePB.initial_committed_cstate) |
2418 | 1.43k | clear_has_initial_committed_cstate(); |
2419 | 1.43k | ::yb::consensus::ConsensusStatePB* temp = initial_committed_cstate_; |
2420 | 1.43k | initial_committed_cstate_ = NULL; |
2421 | 1.43k | return temp; |
2422 | 1.43k | } |
2423 | 2.88k | inline ::yb::consensus::ConsensusStatePB* BeginRemoteBootstrapSessionResponsePB::mutable_initial_committed_cstate() { |
2424 | 2.88k | set_has_initial_committed_cstate(); |
2425 | 2.88k | if (initial_committed_cstate_ == NULL) { |
2426 | 2.88k | initial_committed_cstate_ = new ::yb::consensus::ConsensusStatePB; |
2427 | 2.88k | } |
2428 | | // @@protoc_insertion_point(field_mutable:yb.tserver.BeginRemoteBootstrapSessionResponsePB.initial_committed_cstate) |
2429 | 2.88k | return initial_committed_cstate_; |
2430 | 2.88k | } |
2431 | 0 | inline void BeginRemoteBootstrapSessionResponsePB::set_allocated_initial_committed_cstate(::yb::consensus::ConsensusStatePB* initial_committed_cstate) { |
2432 | 0 | ::google::protobuf::Arena* message_arena = GetArenaNoVirtual(); |
2433 | 0 | if (message_arena == NULL) { |
2434 | 0 | delete reinterpret_cast< ::google::protobuf::MessageLite*>(initial_committed_cstate_); |
2435 | 0 | } |
2436 | 0 | if (initial_committed_cstate) { |
2437 | 0 | ::google::protobuf::Arena* submessage_arena = NULL; |
2438 | 0 | if (message_arena != submessage_arena) { |
2439 | 0 | initial_committed_cstate = ::google::protobuf::internal::GetOwnedMessage( |
2440 | 0 | message_arena, initial_committed_cstate, submessage_arena); |
2441 | 0 | } |
2442 | 0 | set_has_initial_committed_cstate(); |
2443 | 0 | } else { |
2444 | 0 | clear_has_initial_committed_cstate(); |
2445 | 0 | } |
2446 | 0 | initial_committed_cstate_ = initial_committed_cstate; |
2447 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.BeginRemoteBootstrapSessionResponsePB.initial_committed_cstate) |
2448 | 0 | } |
2449 | | |
2450 | | // ------------------------------------------------------------------- |
2451 | | |
2452 | | // CheckRemoteBootstrapSessionActiveRequestPB |
2453 | | |
2454 | | // required bytes session_id = 1; |
2455 | 4 | inline bool CheckRemoteBootstrapSessionActiveRequestPB::has_session_id() const { |
2456 | 4 | return (_has_bits_[0] & 0x00000001u) != 0; |
2457 | 4 | } |
2458 | 4 | inline void CheckRemoteBootstrapSessionActiveRequestPB::set_has_session_id() { |
2459 | 4 | _has_bits_[0] |= 0x00000001u; |
2460 | 4 | } |
2461 | 0 | inline void CheckRemoteBootstrapSessionActiveRequestPB::clear_has_session_id() { |
2462 | 0 | _has_bits_[0] &= ~0x00000001u; |
2463 | 0 | } |
2464 | 0 | inline void CheckRemoteBootstrapSessionActiveRequestPB::clear_session_id() { |
2465 | 0 | session_id_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2466 | 0 | clear_has_session_id(); |
2467 | 0 | } |
2468 | 8 | inline const ::std::string& CheckRemoteBootstrapSessionActiveRequestPB::session_id() const { |
2469 | | // @@protoc_insertion_point(field_get:yb.tserver.CheckRemoteBootstrapSessionActiveRequestPB.session_id) |
2470 | 8 | return session_id_.GetNoArena(); |
2471 | 8 | } |
2472 | 2 | inline void CheckRemoteBootstrapSessionActiveRequestPB::set_session_id(const ::std::string& value) { |
2473 | 2 | set_has_session_id(); |
2474 | 2 | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); |
2475 | | // @@protoc_insertion_point(field_set:yb.tserver.CheckRemoteBootstrapSessionActiveRequestPB.session_id) |
2476 | 2 | } |
2477 | | #if LANG_CXX11 |
2478 | 0 | inline void CheckRemoteBootstrapSessionActiveRequestPB::set_session_id(::std::string&& value) { |
2479 | 0 | set_has_session_id(); |
2480 | 0 | session_id_.SetNoArena( |
2481 | 0 | &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); |
2482 | 0 | // @@protoc_insertion_point(field_set_rvalue:yb.tserver.CheckRemoteBootstrapSessionActiveRequestPB.session_id) |
2483 | 0 | } |
2484 | | #endif |
2485 | 0 | inline void CheckRemoteBootstrapSessionActiveRequestPB::set_session_id(const char* value) { |
2486 | 0 | GOOGLE_DCHECK(value != NULL); |
2487 | 0 | set_has_session_id(); |
2488 | 0 | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); |
2489 | 0 | // @@protoc_insertion_point(field_set_char:yb.tserver.CheckRemoteBootstrapSessionActiveRequestPB.session_id) |
2490 | 0 | } |
2491 | 0 | inline void CheckRemoteBootstrapSessionActiveRequestPB::set_session_id(const void* value, size_t size) { |
2492 | 0 | set_has_session_id(); |
2493 | 0 | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), |
2494 | 0 | ::std::string(reinterpret_cast<const char*>(value), size)); |
2495 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.tserver.CheckRemoteBootstrapSessionActiveRequestPB.session_id) |
2496 | 0 | } |
2497 | 2 | inline ::std::string* CheckRemoteBootstrapSessionActiveRequestPB::mutable_session_id() { |
2498 | 2 | set_has_session_id(); |
2499 | | // @@protoc_insertion_point(field_mutable:yb.tserver.CheckRemoteBootstrapSessionActiveRequestPB.session_id) |
2500 | 2 | return session_id_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2501 | 2 | } |
2502 | 0 | inline ::std::string* CheckRemoteBootstrapSessionActiveRequestPB::release_session_id() { |
2503 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.CheckRemoteBootstrapSessionActiveRequestPB.session_id) |
2504 | 0 | clear_has_session_id(); |
2505 | 0 | return session_id_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2506 | 0 | } |
2507 | 0 | inline void CheckRemoteBootstrapSessionActiveRequestPB::set_allocated_session_id(::std::string* session_id) { |
2508 | 0 | if (session_id != NULL) { |
2509 | 0 | set_has_session_id(); |
2510 | 0 | } else { |
2511 | 0 | clear_has_session_id(); |
2512 | 0 | } |
2513 | 0 | session_id_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), session_id); |
2514 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.CheckRemoteBootstrapSessionActiveRequestPB.session_id) |
2515 | 0 | } |
2516 | | |
2517 | | // optional bool keepalive = 2 [default = false]; |
2518 | 4 | inline bool CheckRemoteBootstrapSessionActiveRequestPB::has_keepalive() const { |
2519 | 4 | return (_has_bits_[0] & 0x00000002u) != 0; |
2520 | 4 | } |
2521 | 0 | inline void CheckRemoteBootstrapSessionActiveRequestPB::set_has_keepalive() { |
2522 | 0 | _has_bits_[0] |= 0x00000002u; |
2523 | 0 | } |
2524 | 0 | inline void CheckRemoteBootstrapSessionActiveRequestPB::clear_has_keepalive() { |
2525 | 0 | _has_bits_[0] &= ~0x00000002u; |
2526 | 0 | } |
2527 | 0 | inline void CheckRemoteBootstrapSessionActiveRequestPB::clear_keepalive() { |
2528 | 0 | keepalive_ = false; |
2529 | 0 | clear_has_keepalive(); |
2530 | 0 | } |
2531 | 1 | inline bool CheckRemoteBootstrapSessionActiveRequestPB::keepalive() const { |
2532 | | // @@protoc_insertion_point(field_get:yb.tserver.CheckRemoteBootstrapSessionActiveRequestPB.keepalive) |
2533 | 1 | return keepalive_; |
2534 | 1 | } |
2535 | 0 | inline void CheckRemoteBootstrapSessionActiveRequestPB::set_keepalive(bool value) { |
2536 | 0 | set_has_keepalive(); |
2537 | 0 | keepalive_ = value; |
2538 | 0 | // @@protoc_insertion_point(field_set:yb.tserver.CheckRemoteBootstrapSessionActiveRequestPB.keepalive) |
2539 | 0 | } |
2540 | | |
2541 | | // ------------------------------------------------------------------- |
2542 | | |
2543 | | // CheckRemoteBootstrapSessionActiveResponsePB |
2544 | | |
2545 | | // required bool session_is_active = 1; |
2546 | 4 | inline bool CheckRemoteBootstrapSessionActiveResponsePB::has_session_is_active() const { |
2547 | 4 | return (_has_bits_[0] & 0x00000001u) != 0; |
2548 | 4 | } |
2549 | 4 | inline void CheckRemoteBootstrapSessionActiveResponsePB::set_has_session_is_active() { |
2550 | 4 | _has_bits_[0] |= 0x00000001u; |
2551 | 4 | } |
2552 | 0 | inline void CheckRemoteBootstrapSessionActiveResponsePB::clear_has_session_is_active() { |
2553 | 0 | _has_bits_[0] &= ~0x00000001u; |
2554 | 0 | } |
2555 | 0 | inline void CheckRemoteBootstrapSessionActiveResponsePB::clear_session_is_active() { |
2556 | 0 | session_is_active_ = false; |
2557 | 0 | clear_has_session_is_active(); |
2558 | 0 | } |
2559 | 5 | inline bool CheckRemoteBootstrapSessionActiveResponsePB::session_is_active() const { |
2560 | | // @@protoc_insertion_point(field_get:yb.tserver.CheckRemoteBootstrapSessionActiveResponsePB.session_is_active) |
2561 | 5 | return session_is_active_; |
2562 | 5 | } |
2563 | 2 | inline void CheckRemoteBootstrapSessionActiveResponsePB::set_session_is_active(bool value) { |
2564 | 2 | set_has_session_is_active(); |
2565 | 2 | session_is_active_ = value; |
2566 | | // @@protoc_insertion_point(field_set:yb.tserver.CheckRemoteBootstrapSessionActiveResponsePB.session_is_active) |
2567 | 2 | } |
2568 | | |
2569 | | // ------------------------------------------------------------------- |
2570 | | |
2571 | | // DataIdPB |
2572 | | |
2573 | | // required .yb.tserver.DataIdPB.IdType type = 1; |
2574 | 11.6k | inline bool DataIdPB::has_type() const { |
2575 | 11.6k | return (_has_bits_[0] & 0x00000008u) != 0; |
2576 | 11.6k | } |
2577 | 10.0k | inline void DataIdPB::set_has_type() { |
2578 | 10.0k | _has_bits_[0] |= 0x00000008u; |
2579 | 10.0k | } |
2580 | 0 | inline void DataIdPB::clear_has_type() { |
2581 | 0 | _has_bits_[0] &= ~0x00000008u; |
2582 | 0 | } |
2583 | 0 | inline void DataIdPB::clear_type() { |
2584 | 0 | type_ = 0; |
2585 | 0 | clear_has_type(); |
2586 | 0 | } |
2587 | 40.7k | inline ::yb::tserver::DataIdPB_IdType DataIdPB::type() const { |
2588 | | // @@protoc_insertion_point(field_get:yb.tserver.DataIdPB.type) |
2589 | 40.7k | return static_cast< ::yb::tserver::DataIdPB_IdType >(type_); |
2590 | 40.7k | } |
2591 | 10.0k | inline void DataIdPB::set_type(::yb::tserver::DataIdPB_IdType value) { |
2592 | 10.0k | assert(::yb::tserver::DataIdPB_IdType_IsValid(value)); |
2593 | 10.0k | set_has_type(); |
2594 | 10.0k | type_ = value; |
2595 | | // @@protoc_insertion_point(field_set:yb.tserver.DataIdPB.type) |
2596 | 10.0k | } |
2597 | | |
2598 | | // optional uint64 wal_segment_seqno = 3; |
2599 | 17.4k | inline bool DataIdPB::has_wal_segment_seqno() const { |
2600 | 17.4k | return (_has_bits_[0] & 0x00000004u) != 0; |
2601 | 17.4k | } |
2602 | 4.55k | inline void DataIdPB::set_has_wal_segment_seqno() { |
2603 | 4.55k | _has_bits_[0] |= 0x00000004u; |
2604 | 4.55k | } |
2605 | 0 | inline void DataIdPB::clear_has_wal_segment_seqno() { |
2606 | 0 | _has_bits_[0] &= ~0x00000004u; |
2607 | 0 | } |
2608 | 0 | inline void DataIdPB::clear_wal_segment_seqno() { |
2609 | 0 | wal_segment_seqno_ = GOOGLE_ULONGLONG(0); |
2610 | 0 | clear_has_wal_segment_seqno(); |
2611 | 0 | } |
2612 | 11.5k | inline ::google::protobuf::uint64 DataIdPB::wal_segment_seqno() const { |
2613 | | // @@protoc_insertion_point(field_get:yb.tserver.DataIdPB.wal_segment_seqno) |
2614 | 11.5k | return wal_segment_seqno_; |
2615 | 11.5k | } |
2616 | 2.24k | inline void DataIdPB::set_wal_segment_seqno(::google::protobuf::uint64 value) { |
2617 | 2.24k | set_has_wal_segment_seqno(); |
2618 | 2.24k | wal_segment_seqno_ = value; |
2619 | | // @@protoc_insertion_point(field_set:yb.tserver.DataIdPB.wal_segment_seqno) |
2620 | 2.24k | } |
2621 | | |
2622 | | // optional string file_name = 4; |
2623 | 17.5k | inline bool DataIdPB::has_file_name() const { |
2624 | 17.5k | return (_has_bits_[0] & 0x00000001u) != 0; |
2625 | 17.5k | } |
2626 | 10.5k | inline void DataIdPB::set_has_file_name() { |
2627 | 10.5k | _has_bits_[0] |= 0x00000001u; |
2628 | 10.5k | } |
2629 | 0 | inline void DataIdPB::clear_has_file_name() { |
2630 | 0 | _has_bits_[0] &= ~0x00000001u; |
2631 | 0 | } |
2632 | 0 | inline void DataIdPB::clear_file_name() { |
2633 | 0 | file_name_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2634 | 0 | clear_has_file_name(); |
2635 | 0 | } |
2636 | 35.2k | inline const ::std::string& DataIdPB::file_name() const { |
2637 | | // @@protoc_insertion_point(field_get:yb.tserver.DataIdPB.file_name) |
2638 | 35.2k | return file_name_.GetNoArena(); |
2639 | 35.2k | } |
2640 | 3.52k | inline void DataIdPB::set_file_name(const ::std::string& value) { |
2641 | 3.52k | set_has_file_name(); |
2642 | 3.52k | file_name_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); |
2643 | | // @@protoc_insertion_point(field_set:yb.tserver.DataIdPB.file_name) |
2644 | 3.52k | } |
2645 | | #if LANG_CXX11 |
2646 | 0 | inline void DataIdPB::set_file_name(::std::string&& value) { |
2647 | 0 | set_has_file_name(); |
2648 | 0 | file_name_.SetNoArena( |
2649 | 0 | &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); |
2650 | 0 | // @@protoc_insertion_point(field_set_rvalue:yb.tserver.DataIdPB.file_name) |
2651 | 0 | } |
2652 | | #endif |
2653 | 2 | inline void DataIdPB::set_file_name(const char* value) { |
2654 | 2 | GOOGLE_DCHECK(value != NULL); |
2655 | 2 | set_has_file_name(); |
2656 | 2 | file_name_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); |
2657 | | // @@protoc_insertion_point(field_set_char:yb.tserver.DataIdPB.file_name) |
2658 | 2 | } |
2659 | 0 | inline void DataIdPB::set_file_name(const char* value, size_t size) { |
2660 | 0 | set_has_file_name(); |
2661 | 0 | file_name_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), |
2662 | 0 | ::std::string(reinterpret_cast<const char*>(value), size)); |
2663 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.tserver.DataIdPB.file_name) |
2664 | 0 | } |
2665 | 3.52k | inline ::std::string* DataIdPB::mutable_file_name() { |
2666 | 3.52k | set_has_file_name(); |
2667 | | // @@protoc_insertion_point(field_mutable:yb.tserver.DataIdPB.file_name) |
2668 | 3.52k | return file_name_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2669 | 3.52k | } |
2670 | 0 | inline ::std::string* DataIdPB::release_file_name() { |
2671 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.DataIdPB.file_name) |
2672 | 0 | clear_has_file_name(); |
2673 | 0 | return file_name_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2674 | 0 | } |
2675 | 0 | inline void DataIdPB::set_allocated_file_name(::std::string* file_name) { |
2676 | 0 | if (file_name != NULL) { |
2677 | 0 | set_has_file_name(); |
2678 | 0 | } else { |
2679 | 0 | clear_has_file_name(); |
2680 | 0 | } |
2681 | 0 | file_name_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), file_name); |
2682 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.DataIdPB.file_name) |
2683 | 0 | } |
2684 | | |
2685 | | // optional bytes snapshot_id = 5; |
2686 | 11.6k | inline bool DataIdPB::has_snapshot_id() const { |
2687 | 11.6k | return (_has_bits_[0] & 0x00000002u) != 0; |
2688 | 11.6k | } |
2689 | 92 | inline void DataIdPB::set_has_snapshot_id() { |
2690 | 92 | _has_bits_[0] |= 0x00000002u; |
2691 | 92 | } |
2692 | 0 | inline void DataIdPB::clear_has_snapshot_id() { |
2693 | 0 | _has_bits_[0] &= ~0x00000002u; |
2694 | 0 | } |
2695 | 0 | inline void DataIdPB::clear_snapshot_id() { |
2696 | 0 | snapshot_id_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2697 | 0 | clear_has_snapshot_id(); |
2698 | 0 | } |
2699 | 90 | inline const ::std::string& DataIdPB::snapshot_id() const { |
2700 | | // @@protoc_insertion_point(field_get:yb.tserver.DataIdPB.snapshot_id) |
2701 | 90 | return snapshot_id_.GetNoArena(); |
2702 | 90 | } |
2703 | 56 | inline void DataIdPB::set_snapshot_id(const ::std::string& value) { |
2704 | 56 | set_has_snapshot_id(); |
2705 | 56 | snapshot_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); |
2706 | | // @@protoc_insertion_point(field_set:yb.tserver.DataIdPB.snapshot_id) |
2707 | 56 | } |
2708 | | #if LANG_CXX11 |
2709 | 0 | inline void DataIdPB::set_snapshot_id(::std::string&& value) { |
2710 | 0 | set_has_snapshot_id(); |
2711 | 0 | snapshot_id_.SetNoArena( |
2712 | 0 | &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); |
2713 | 0 | // @@protoc_insertion_point(field_set_rvalue:yb.tserver.DataIdPB.snapshot_id) |
2714 | 0 | } |
2715 | | #endif |
2716 | 0 | inline void DataIdPB::set_snapshot_id(const char* value) { |
2717 | 0 | GOOGLE_DCHECK(value != NULL); |
2718 | 0 | set_has_snapshot_id(); |
2719 | 0 | snapshot_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); |
2720 | 0 | // @@protoc_insertion_point(field_set_char:yb.tserver.DataIdPB.snapshot_id) |
2721 | 0 | } |
2722 | 0 | inline void DataIdPB::set_snapshot_id(const void* value, size_t size) { |
2723 | 0 | set_has_snapshot_id(); |
2724 | 0 | snapshot_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), |
2725 | 0 | ::std::string(reinterpret_cast<const char*>(value), size)); |
2726 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.tserver.DataIdPB.snapshot_id) |
2727 | 0 | } |
2728 | 18 | inline ::std::string* DataIdPB::mutable_snapshot_id() { |
2729 | 18 | set_has_snapshot_id(); |
2730 | | // @@protoc_insertion_point(field_mutable:yb.tserver.DataIdPB.snapshot_id) |
2731 | 18 | return snapshot_id_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2732 | 18 | } |
2733 | 0 | inline ::std::string* DataIdPB::release_snapshot_id() { |
2734 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.DataIdPB.snapshot_id) |
2735 | 0 | clear_has_snapshot_id(); |
2736 | 0 | return snapshot_id_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2737 | 0 | } |
2738 | 0 | inline void DataIdPB::set_allocated_snapshot_id(::std::string* snapshot_id) { |
2739 | 0 | if (snapshot_id != NULL) { |
2740 | 0 | set_has_snapshot_id(); |
2741 | 0 | } else { |
2742 | 0 | clear_has_snapshot_id(); |
2743 | 0 | } |
2744 | 0 | snapshot_id_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), snapshot_id); |
2745 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.DataIdPB.snapshot_id) |
2746 | 0 | } |
2747 | | |
2748 | | // ------------------------------------------------------------------- |
2749 | | |
2750 | | // FetchDataRequestPB |
2751 | | |
2752 | | // required bytes session_id = 1; |
2753 | 0 | inline bool FetchDataRequestPB::has_session_id() const { |
2754 | 0 | return (_has_bits_[0] & 0x00000001u) != 0; |
2755 | 0 | } |
2756 | 11.6k | inline void FetchDataRequestPB::set_has_session_id() { |
2757 | 11.6k | _has_bits_[0] |= 0x00000001u; |
2758 | 11.6k | } |
2759 | 0 | inline void FetchDataRequestPB::clear_has_session_id() { |
2760 | 0 | _has_bits_[0] &= ~0x00000001u; |
2761 | 0 | } |
2762 | 0 | inline void FetchDataRequestPB::clear_session_id() { |
2763 | 0 | session_id_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2764 | 0 | clear_has_session_id(); |
2765 | 0 | } |
2766 | 23.3k | inline const ::std::string& FetchDataRequestPB::session_id() const { |
2767 | | // @@protoc_insertion_point(field_get:yb.tserver.FetchDataRequestPB.session_id) |
2768 | 23.3k | return session_id_.GetNoArena(); |
2769 | 23.3k | } |
2770 | 5.83k | inline void FetchDataRequestPB::set_session_id(const ::std::string& value) { |
2771 | 5.83k | set_has_session_id(); |
2772 | 5.83k | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); |
2773 | | // @@protoc_insertion_point(field_set:yb.tserver.FetchDataRequestPB.session_id) |
2774 | 5.83k | } |
2775 | | #if LANG_CXX11 |
2776 | 0 | inline void FetchDataRequestPB::set_session_id(::std::string&& value) { |
2777 | 0 | set_has_session_id(); |
2778 | 0 | session_id_.SetNoArena( |
2779 | 0 | &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); |
2780 | 0 | // @@protoc_insertion_point(field_set_rvalue:yb.tserver.FetchDataRequestPB.session_id) |
2781 | 0 | } |
2782 | | #endif |
2783 | 0 | inline void FetchDataRequestPB::set_session_id(const char* value) { |
2784 | 0 | GOOGLE_DCHECK(value != NULL); |
2785 | 0 | set_has_session_id(); |
2786 | 0 | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); |
2787 | 0 | // @@protoc_insertion_point(field_set_char:yb.tserver.FetchDataRequestPB.session_id) |
2788 | 0 | } |
2789 | 0 | inline void FetchDataRequestPB::set_session_id(const void* value, size_t size) { |
2790 | 0 | set_has_session_id(); |
2791 | 0 | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), |
2792 | 0 | ::std::string(reinterpret_cast<const char*>(value), size)); |
2793 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.tserver.FetchDataRequestPB.session_id) |
2794 | 0 | } |
2795 | 5.83k | inline ::std::string* FetchDataRequestPB::mutable_session_id() { |
2796 | 5.83k | set_has_session_id(); |
2797 | | // @@protoc_insertion_point(field_mutable:yb.tserver.FetchDataRequestPB.session_id) |
2798 | 5.83k | return session_id_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2799 | 5.83k | } |
2800 | 0 | inline ::std::string* FetchDataRequestPB::release_session_id() { |
2801 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.FetchDataRequestPB.session_id) |
2802 | 0 | clear_has_session_id(); |
2803 | 0 | return session_id_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2804 | 0 | } |
2805 | 0 | inline void FetchDataRequestPB::set_allocated_session_id(::std::string* session_id) { |
2806 | 0 | if (session_id != NULL) { |
2807 | 0 | set_has_session_id(); |
2808 | 0 | } else { |
2809 | 0 | clear_has_session_id(); |
2810 | 0 | } |
2811 | 0 | session_id_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), session_id); |
2812 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.FetchDataRequestPB.session_id) |
2813 | 0 | } |
2814 | | |
2815 | | // required .yb.tserver.DataIdPB data_id = 2; |
2816 | 11.6k | inline bool FetchDataRequestPB::has_data_id() const { |
2817 | 11.6k | return (_has_bits_[0] & 0x00000002u) != 0; |
2818 | 11.6k | } |
2819 | 11.6k | inline void FetchDataRequestPB::set_has_data_id() { |
2820 | 11.6k | _has_bits_[0] |= 0x00000002u; |
2821 | 11.6k | } |
2822 | 0 | inline void FetchDataRequestPB::clear_has_data_id() { |
2823 | 0 | _has_bits_[0] &= ~0x00000002u; |
2824 | 0 | } |
2825 | 0 | inline void FetchDataRequestPB::clear_data_id() { |
2826 | 0 | if (data_id_ != NULL) data_id_->Clear(); |
2827 | 0 | clear_has_data_id(); |
2828 | 0 | } |
2829 | 5.83k | inline const ::yb::tserver::DataIdPB& FetchDataRequestPB::data_id() const { |
2830 | 5.83k | const ::yb::tserver::DataIdPB* p = data_id_; |
2831 | | // @@protoc_insertion_point(field_get:yb.tserver.FetchDataRequestPB.data_id) |
2832 | 5.83k | return p != NULL ? *p : *reinterpret_cast<const ::yb::tserver::DataIdPB*>( |
2833 | 0 | &::yb::tserver::_DataIdPB_default_instance_); |
2834 | 5.83k | } |
2835 | 0 | inline ::yb::tserver::DataIdPB* FetchDataRequestPB::release_data_id() { |
2836 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.FetchDataRequestPB.data_id) |
2837 | 0 | clear_has_data_id(); |
2838 | 0 | ::yb::tserver::DataIdPB* temp = data_id_; |
2839 | 0 | data_id_ = NULL; |
2840 | 0 | return temp; |
2841 | 0 | } |
2842 | 11.6k | inline ::yb::tserver::DataIdPB* FetchDataRequestPB::mutable_data_id() { |
2843 | 11.6k | set_has_data_id(); |
2844 | 11.6k | if (data_id_ == NULL) { |
2845 | 11.6k | data_id_ = new ::yb::tserver::DataIdPB; |
2846 | 11.6k | } |
2847 | | // @@protoc_insertion_point(field_mutable:yb.tserver.FetchDataRequestPB.data_id) |
2848 | 11.6k | return data_id_; |
2849 | 11.6k | } |
2850 | 0 | inline void FetchDataRequestPB::set_allocated_data_id(::yb::tserver::DataIdPB* data_id) { |
2851 | 0 | ::google::protobuf::Arena* message_arena = GetArenaNoVirtual(); |
2852 | 0 | if (message_arena == NULL) { |
2853 | 0 | delete data_id_; |
2854 | 0 | } |
2855 | 0 | if (data_id) { |
2856 | 0 | ::google::protobuf::Arena* submessage_arena = NULL; |
2857 | 0 | if (message_arena != submessage_arena) { |
2858 | 0 | data_id = ::google::protobuf::internal::GetOwnedMessage( |
2859 | 0 | message_arena, data_id, submessage_arena); |
2860 | 0 | } |
2861 | 0 | set_has_data_id(); |
2862 | 0 | } else { |
2863 | 0 | clear_has_data_id(); |
2864 | 0 | } |
2865 | 0 | data_id_ = data_id; |
2866 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.FetchDataRequestPB.data_id) |
2867 | 0 | } |
2868 | | |
2869 | | // optional uint64 offset = 3 [default = 0]; |
2870 | 11.6k | inline bool FetchDataRequestPB::has_offset() const { |
2871 | 11.6k | return (_has_bits_[0] & 0x00000004u) != 0; |
2872 | 11.6k | } |
2873 | 11.6k | inline void FetchDataRequestPB::set_has_offset() { |
2874 | 11.6k | _has_bits_[0] |= 0x00000004u; |
2875 | 11.6k | } |
2876 | 0 | inline void FetchDataRequestPB::clear_has_offset() { |
2877 | 0 | _has_bits_[0] &= ~0x00000004u; |
2878 | 0 | } |
2879 | 0 | inline void FetchDataRequestPB::clear_offset() { |
2880 | 0 | offset_ = GOOGLE_ULONGLONG(0); |
2881 | 0 | clear_has_offset(); |
2882 | 0 | } |
2883 | 23.3k | inline ::google::protobuf::uint64 FetchDataRequestPB::offset() const { |
2884 | | // @@protoc_insertion_point(field_get:yb.tserver.FetchDataRequestPB.offset) |
2885 | 23.3k | return offset_; |
2886 | 23.3k | } |
2887 | 5.82k | inline void FetchDataRequestPB::set_offset(::google::protobuf::uint64 value) { |
2888 | 5.82k | set_has_offset(); |
2889 | 5.82k | offset_ = value; |
2890 | | // @@protoc_insertion_point(field_set:yb.tserver.FetchDataRequestPB.offset) |
2891 | 5.82k | } |
2892 | | |
2893 | | // optional int64 max_length = 4 [default = 0]; |
2894 | 11.6k | inline bool FetchDataRequestPB::has_max_length() const { |
2895 | 11.6k | return (_has_bits_[0] & 0x00000008u) != 0; |
2896 | 11.6k | } |
2897 | 11.6k | inline void FetchDataRequestPB::set_has_max_length() { |
2898 | 11.6k | _has_bits_[0] |= 0x00000008u; |
2899 | 11.6k | } |
2900 | 0 | inline void FetchDataRequestPB::clear_has_max_length() { |
2901 | 0 | _has_bits_[0] &= ~0x00000008u; |
2902 | 0 | } |
2903 | 0 | inline void FetchDataRequestPB::clear_max_length() { |
2904 | 0 | max_length_ = GOOGLE_LONGLONG(0); |
2905 | 0 | clear_has_max_length(); |
2906 | 0 | } |
2907 | 23.3k | inline ::google::protobuf::int64 FetchDataRequestPB::max_length() const { |
2908 | | // @@protoc_insertion_point(field_get:yb.tserver.FetchDataRequestPB.max_length) |
2909 | 23.3k | return max_length_; |
2910 | 23.3k | } |
2911 | 5.82k | inline void FetchDataRequestPB::set_max_length(::google::protobuf::int64 value) { |
2912 | 5.82k | set_has_max_length(); |
2913 | 5.82k | max_length_ = value; |
2914 | | // @@protoc_insertion_point(field_set:yb.tserver.FetchDataRequestPB.max_length) |
2915 | 5.82k | } |
2916 | | |
2917 | | // ------------------------------------------------------------------- |
2918 | | |
2919 | | // DataChunkPB |
2920 | | |
2921 | | // required uint64 offset = 1; |
2922 | 0 | inline bool DataChunkPB::has_offset() const { |
2923 | 0 | return (_has_bits_[0] & 0x00000002u) != 0; |
2924 | 0 | } |
2925 | 9.65k | inline void DataChunkPB::set_has_offset() { |
2926 | 9.65k | _has_bits_[0] |= 0x00000002u; |
2927 | 9.65k | } |
2928 | 0 | inline void DataChunkPB::clear_has_offset() { |
2929 | 0 | _has_bits_[0] &= ~0x00000002u; |
2930 | 0 | } |
2931 | 0 | inline void DataChunkPB::clear_offset() { |
2932 | 0 | offset_ = GOOGLE_ULONGLONG(0); |
2933 | 0 | clear_has_offset(); |
2934 | 0 | } |
2935 | 24.1k | inline ::google::protobuf::uint64 DataChunkPB::offset() const { |
2936 | | // @@protoc_insertion_point(field_get:yb.tserver.DataChunkPB.offset) |
2937 | 24.1k | return offset_; |
2938 | 24.1k | } |
2939 | 4.82k | inline void DataChunkPB::set_offset(::google::protobuf::uint64 value) { |
2940 | 4.82k | set_has_offset(); |
2941 | 4.82k | offset_ = value; |
2942 | | // @@protoc_insertion_point(field_set:yb.tserver.DataChunkPB.offset) |
2943 | 4.82k | } |
2944 | | |
2945 | | // required bytes data = 2; |
2946 | 0 | inline bool DataChunkPB::has_data() const { |
2947 | 0 | return (_has_bits_[0] & 0x00000001u) != 0; |
2948 | 0 | } |
2949 | 9.65k | inline void DataChunkPB::set_has_data() { |
2950 | 9.65k | _has_bits_[0] |= 0x00000001u; |
2951 | 9.65k | } |
2952 | 0 | inline void DataChunkPB::clear_has_data() { |
2953 | 0 | _has_bits_[0] &= ~0x00000001u; |
2954 | 0 | } |
2955 | 0 | inline void DataChunkPB::clear_data() { |
2956 | 0 | data_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2957 | 0 | clear_has_data(); |
2958 | 0 | } |
2959 | 53.0k | inline const ::std::string& DataChunkPB::data() const { |
2960 | | // @@protoc_insertion_point(field_get:yb.tserver.DataChunkPB.data) |
2961 | 53.0k | return data_.GetNoArena(); |
2962 | 53.0k | } |
2963 | 0 | inline void DataChunkPB::set_data(const ::std::string& value) { |
2964 | 0 | set_has_data(); |
2965 | 0 | data_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); |
2966 | 0 | // @@protoc_insertion_point(field_set:yb.tserver.DataChunkPB.data) |
2967 | 0 | } |
2968 | | #if LANG_CXX11 |
2969 | 0 | inline void DataChunkPB::set_data(::std::string&& value) { |
2970 | 0 | set_has_data(); |
2971 | 0 | data_.SetNoArena( |
2972 | 0 | &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); |
2973 | 0 | // @@protoc_insertion_point(field_set_rvalue:yb.tserver.DataChunkPB.data) |
2974 | 0 | } |
2975 | | #endif |
2976 | 0 | inline void DataChunkPB::set_data(const char* value) { |
2977 | 0 | GOOGLE_DCHECK(value != NULL); |
2978 | 0 | set_has_data(); |
2979 | 0 | data_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); |
2980 | 0 | // @@protoc_insertion_point(field_set_char:yb.tserver.DataChunkPB.data) |
2981 | 0 | } |
2982 | 0 | inline void DataChunkPB::set_data(const void* value, size_t size) { |
2983 | 0 | set_has_data(); |
2984 | 0 | data_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), |
2985 | 0 | ::std::string(reinterpret_cast<const char*>(value), size)); |
2986 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.tserver.DataChunkPB.data) |
2987 | 0 | } |
2988 | 9.65k | inline ::std::string* DataChunkPB::mutable_data() { |
2989 | 9.65k | set_has_data(); |
2990 | | // @@protoc_insertion_point(field_mutable:yb.tserver.DataChunkPB.data) |
2991 | 9.65k | return data_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2992 | 9.65k | } |
2993 | 0 | inline ::std::string* DataChunkPB::release_data() { |
2994 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.DataChunkPB.data) |
2995 | 0 | clear_has_data(); |
2996 | 0 | return data_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2997 | 0 | } |
2998 | 0 | inline void DataChunkPB::set_allocated_data(::std::string* data) { |
2999 | 0 | if (data != NULL) { |
3000 | 0 | set_has_data(); |
3001 | 0 | } else { |
3002 | 0 | clear_has_data(); |
3003 | 0 | } |
3004 | 0 | data_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), data); |
3005 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.DataChunkPB.data) |
3006 | 0 | } |
3007 | | |
3008 | | // required fixed32 crc32 = 3; |
3009 | 0 | inline bool DataChunkPB::has_crc32() const { |
3010 | 0 | return (_has_bits_[0] & 0x00000008u) != 0; |
3011 | 0 | } |
3012 | 9.65k | inline void DataChunkPB::set_has_crc32() { |
3013 | 9.65k | _has_bits_[0] |= 0x00000008u; |
3014 | 9.65k | } |
3015 | 0 | inline void DataChunkPB::clear_has_crc32() { |
3016 | 0 | _has_bits_[0] &= ~0x00000008u; |
3017 | 0 | } |
3018 | 0 | inline void DataChunkPB::clear_crc32() { |
3019 | 0 | crc32_ = 0u; |
3020 | 0 | clear_has_crc32(); |
3021 | 0 | } |
3022 | 9.65k | inline ::google::protobuf::uint32 DataChunkPB::crc32() const { |
3023 | | // @@protoc_insertion_point(field_get:yb.tserver.DataChunkPB.crc32) |
3024 | 9.65k | return crc32_; |
3025 | 9.65k | } |
3026 | 4.82k | inline void DataChunkPB::set_crc32(::google::protobuf::uint32 value) { |
3027 | 4.82k | set_has_crc32(); |
3028 | 4.82k | crc32_ = value; |
3029 | | // @@protoc_insertion_point(field_set:yb.tserver.DataChunkPB.crc32) |
3030 | 4.82k | } |
3031 | | |
3032 | | // required int64 total_data_length = 4; |
3033 | 0 | inline bool DataChunkPB::has_total_data_length() const { |
3034 | 0 | return (_has_bits_[0] & 0x00000004u) != 0; |
3035 | 0 | } |
3036 | 9.65k | inline void DataChunkPB::set_has_total_data_length() { |
3037 | 9.65k | _has_bits_[0] |= 0x00000004u; |
3038 | 9.65k | } |
3039 | 0 | inline void DataChunkPB::clear_has_total_data_length() { |
3040 | 0 | _has_bits_[0] &= ~0x00000004u; |
3041 | 0 | } |
3042 | 0 | inline void DataChunkPB::clear_total_data_length() { |
3043 | 0 | total_data_length_ = GOOGLE_LONGLONG(0); |
3044 | 0 | clear_has_total_data_length(); |
3045 | 0 | } |
3046 | 24.1k | inline ::google::protobuf::int64 DataChunkPB::total_data_length() const { |
3047 | | // @@protoc_insertion_point(field_get:yb.tserver.DataChunkPB.total_data_length) |
3048 | 24.1k | return total_data_length_; |
3049 | 24.1k | } |
3050 | 4.82k | inline void DataChunkPB::set_total_data_length(::google::protobuf::int64 value) { |
3051 | 4.82k | set_has_total_data_length(); |
3052 | 4.82k | total_data_length_ = value; |
3053 | | // @@protoc_insertion_point(field_set:yb.tserver.DataChunkPB.total_data_length) |
3054 | 4.82k | } |
3055 | | |
3056 | | // ------------------------------------------------------------------- |
3057 | | |
3058 | | // FetchDataResponsePB |
3059 | | |
3060 | | // required .yb.tserver.DataChunkPB chunk = 1; |
3061 | 24.1k | inline bool FetchDataResponsePB::has_chunk() const { |
3062 | 24.1k | return (_has_bits_[0] & 0x00000001u) != 0; |
3063 | 24.1k | } |
3064 | 9.65k | inline void FetchDataResponsePB::set_has_chunk() { |
3065 | 9.65k | _has_bits_[0] |= 0x00000001u; |
3066 | 9.65k | } |
3067 | 0 | inline void FetchDataResponsePB::clear_has_chunk() { |
3068 | 0 | _has_bits_[0] &= ~0x00000001u; |
3069 | 0 | } |
3070 | 0 | inline void FetchDataResponsePB::clear_chunk() { |
3071 | 0 | if (chunk_ != NULL) chunk_->Clear(); |
3072 | 0 | clear_has_chunk(); |
3073 | 0 | } |
3074 | 33.7k | inline const ::yb::tserver::DataChunkPB& FetchDataResponsePB::chunk() const { |
3075 | 33.7k | const ::yb::tserver::DataChunkPB* p = chunk_; |
3076 | | // @@protoc_insertion_point(field_get:yb.tserver.FetchDataResponsePB.chunk) |
3077 | 33.7k | return p != NULL ? *p : *reinterpret_cast<const ::yb::tserver::DataChunkPB*>( |
3078 | 0 | &::yb::tserver::_DataChunkPB_default_instance_); |
3079 | 33.7k | } |
3080 | 0 | inline ::yb::tserver::DataChunkPB* FetchDataResponsePB::release_chunk() { |
3081 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.FetchDataResponsePB.chunk) |
3082 | 0 | clear_has_chunk(); |
3083 | 0 | ::yb::tserver::DataChunkPB* temp = chunk_; |
3084 | 0 | chunk_ = NULL; |
3085 | 0 | return temp; |
3086 | 0 | } |
3087 | 9.65k | inline ::yb::tserver::DataChunkPB* FetchDataResponsePB::mutable_chunk() { |
3088 | 9.65k | set_has_chunk(); |
3089 | 9.65k | if (chunk_ == NULL) { |
3090 | 9.65k | chunk_ = new ::yb::tserver::DataChunkPB; |
3091 | 9.65k | } |
3092 | | // @@protoc_insertion_point(field_mutable:yb.tserver.FetchDataResponsePB.chunk) |
3093 | 9.65k | return chunk_; |
3094 | 9.65k | } |
3095 | 0 | inline void FetchDataResponsePB::set_allocated_chunk(::yb::tserver::DataChunkPB* chunk) { |
3096 | 0 | ::google::protobuf::Arena* message_arena = GetArenaNoVirtual(); |
3097 | 0 | if (message_arena == NULL) { |
3098 | 0 | delete chunk_; |
3099 | 0 | } |
3100 | 0 | if (chunk) { |
3101 | 0 | ::google::protobuf::Arena* submessage_arena = NULL; |
3102 | 0 | if (message_arena != submessage_arena) { |
3103 | 0 | chunk = ::google::protobuf::internal::GetOwnedMessage( |
3104 | 0 | message_arena, chunk, submessage_arena); |
3105 | 0 | } |
3106 | 0 | set_has_chunk(); |
3107 | 0 | } else { |
3108 | 0 | clear_has_chunk(); |
3109 | 0 | } |
3110 | 0 | chunk_ = chunk; |
3111 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.FetchDataResponsePB.chunk) |
3112 | 0 | } |
3113 | | |
3114 | | // ------------------------------------------------------------------- |
3115 | | |
3116 | | // EndRemoteBootstrapSessionRequestPB |
3117 | | |
3118 | | // required bytes session_id = 1; |
3119 | 0 | inline bool EndRemoteBootstrapSessionRequestPB::has_session_id() const { |
3120 | 0 | return (_has_bits_[0] & 0x00000001u) != 0; |
3121 | 0 | } |
3122 | 2.00k | inline void EndRemoteBootstrapSessionRequestPB::set_has_session_id() { |
3123 | 2.00k | _has_bits_[0] |= 0x00000001u; |
3124 | 2.00k | } |
3125 | 0 | inline void EndRemoteBootstrapSessionRequestPB::clear_has_session_id() { |
3126 | 0 | _has_bits_[0] &= ~0x00000001u; |
3127 | 0 | } |
3128 | 0 | inline void EndRemoteBootstrapSessionRequestPB::clear_session_id() { |
3129 | 0 | session_id_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
3130 | 0 | clear_has_session_id(); |
3131 | 0 | } |
3132 | 5.01k | inline const ::std::string& EndRemoteBootstrapSessionRequestPB::session_id() const { |
3133 | | // @@protoc_insertion_point(field_get:yb.tserver.EndRemoteBootstrapSessionRequestPB.session_id) |
3134 | 5.01k | return session_id_.GetNoArena(); |
3135 | 5.01k | } |
3136 | 1.00k | inline void EndRemoteBootstrapSessionRequestPB::set_session_id(const ::std::string& value) { |
3137 | 1.00k | set_has_session_id(); |
3138 | 1.00k | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); |
3139 | | // @@protoc_insertion_point(field_set:yb.tserver.EndRemoteBootstrapSessionRequestPB.session_id) |
3140 | 1.00k | } |
3141 | | #if LANG_CXX11 |
3142 | 0 | inline void EndRemoteBootstrapSessionRequestPB::set_session_id(::std::string&& value) { |
3143 | 0 | set_has_session_id(); |
3144 | 0 | session_id_.SetNoArena( |
3145 | 0 | &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); |
3146 | 0 | // @@protoc_insertion_point(field_set_rvalue:yb.tserver.EndRemoteBootstrapSessionRequestPB.session_id) |
3147 | 0 | } |
3148 | | #endif |
3149 | 0 | inline void EndRemoteBootstrapSessionRequestPB::set_session_id(const char* value) { |
3150 | 0 | GOOGLE_DCHECK(value != NULL); |
3151 | 0 | set_has_session_id(); |
3152 | 0 | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); |
3153 | 0 | // @@protoc_insertion_point(field_set_char:yb.tserver.EndRemoteBootstrapSessionRequestPB.session_id) |
3154 | 0 | } |
3155 | 0 | inline void EndRemoteBootstrapSessionRequestPB::set_session_id(const void* value, size_t size) { |
3156 | 0 | set_has_session_id(); |
3157 | 0 | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), |
3158 | 0 | ::std::string(reinterpret_cast<const char*>(value), size)); |
3159 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.tserver.EndRemoteBootstrapSessionRequestPB.session_id) |
3160 | 0 | } |
3161 | 1.00k | inline ::std::string* EndRemoteBootstrapSessionRequestPB::mutable_session_id() { |
3162 | 1.00k | set_has_session_id(); |
3163 | | // @@protoc_insertion_point(field_mutable:yb.tserver.EndRemoteBootstrapSessionRequestPB.session_id) |
3164 | 1.00k | return session_id_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
3165 | 1.00k | } |
3166 | 0 | inline ::std::string* EndRemoteBootstrapSessionRequestPB::release_session_id() { |
3167 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.EndRemoteBootstrapSessionRequestPB.session_id) |
3168 | 0 | clear_has_session_id(); |
3169 | 0 | return session_id_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
3170 | 0 | } |
3171 | 0 | inline void EndRemoteBootstrapSessionRequestPB::set_allocated_session_id(::std::string* session_id) { |
3172 | 0 | if (session_id != NULL) { |
3173 | 0 | set_has_session_id(); |
3174 | 0 | } else { |
3175 | 0 | clear_has_session_id(); |
3176 | 0 | } |
3177 | 0 | session_id_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), session_id); |
3178 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.EndRemoteBootstrapSessionRequestPB.session_id) |
3179 | 0 | } |
3180 | | |
3181 | | // required bool is_success = 2; |
3182 | 0 | inline bool EndRemoteBootstrapSessionRequestPB::has_is_success() const { |
3183 | 0 | return (_has_bits_[0] & 0x00000004u) != 0; |
3184 | 0 | } |
3185 | 2.00k | inline void EndRemoteBootstrapSessionRequestPB::set_has_is_success() { |
3186 | 2.00k | _has_bits_[0] |= 0x00000004u; |
3187 | 2.00k | } |
3188 | 0 | inline void EndRemoteBootstrapSessionRequestPB::clear_has_is_success() { |
3189 | 0 | _has_bits_[0] &= ~0x00000004u; |
3190 | 0 | } |
3191 | 0 | inline void EndRemoteBootstrapSessionRequestPB::clear_is_success() { |
3192 | 0 | is_success_ = false; |
3193 | 0 | clear_has_is_success(); |
3194 | 0 | } |
3195 | 2.00k | inline bool EndRemoteBootstrapSessionRequestPB::is_success() const { |
3196 | | // @@protoc_insertion_point(field_get:yb.tserver.EndRemoteBootstrapSessionRequestPB.is_success) |
3197 | 2.00k | return is_success_; |
3198 | 2.00k | } |
3199 | 1.00k | inline void EndRemoteBootstrapSessionRequestPB::set_is_success(bool value) { |
3200 | 1.00k | set_has_is_success(); |
3201 | 1.00k | is_success_ = value; |
3202 | | // @@protoc_insertion_point(field_set:yb.tserver.EndRemoteBootstrapSessionRequestPB.is_success) |
3203 | 1.00k | } |
3204 | | |
3205 | | // optional .yb.AppStatusPB error = 3; |
3206 | 4.01k | inline bool EndRemoteBootstrapSessionRequestPB::has_error() const { |
3207 | 4.01k | return (_has_bits_[0] & 0x00000002u) != 0; |
3208 | 4.01k | } |
3209 | 0 | inline void EndRemoteBootstrapSessionRequestPB::set_has_error() { |
3210 | 0 | _has_bits_[0] |= 0x00000002u; |
3211 | 0 | } |
3212 | 0 | inline void EndRemoteBootstrapSessionRequestPB::clear_has_error() { |
3213 | 0 | _has_bits_[0] &= ~0x00000002u; |
3214 | 0 | } |
3215 | 0 | inline const ::yb::AppStatusPB& EndRemoteBootstrapSessionRequestPB::error() const { |
3216 | 0 | const ::yb::AppStatusPB* p = error_; |
3217 | 0 | // @@protoc_insertion_point(field_get:yb.tserver.EndRemoteBootstrapSessionRequestPB.error) |
3218 | 0 | return p != NULL ? *p : *reinterpret_cast<const ::yb::AppStatusPB*>( |
3219 | 0 | &::yb::_AppStatusPB_default_instance_); |
3220 | 0 | } |
3221 | 0 | inline ::yb::AppStatusPB* EndRemoteBootstrapSessionRequestPB::release_error() { |
3222 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.EndRemoteBootstrapSessionRequestPB.error) |
3223 | 0 | clear_has_error(); |
3224 | 0 | ::yb::AppStatusPB* temp = error_; |
3225 | 0 | error_ = NULL; |
3226 | 0 | return temp; |
3227 | 0 | } |
3228 | 0 | inline ::yb::AppStatusPB* EndRemoteBootstrapSessionRequestPB::mutable_error() { |
3229 | 0 | set_has_error(); |
3230 | 0 | if (error_ == NULL) { |
3231 | 0 | error_ = new ::yb::AppStatusPB; |
3232 | 0 | } |
3233 | 0 | // @@protoc_insertion_point(field_mutable:yb.tserver.EndRemoteBootstrapSessionRequestPB.error) |
3234 | 0 | return error_; |
3235 | 0 | } |
3236 | 0 | inline void EndRemoteBootstrapSessionRequestPB::set_allocated_error(::yb::AppStatusPB* error) { |
3237 | 0 | ::google::protobuf::Arena* message_arena = GetArenaNoVirtual(); |
3238 | 0 | if (message_arena == NULL) { |
3239 | 0 | delete reinterpret_cast< ::google::protobuf::MessageLite*>(error_); |
3240 | 0 | } |
3241 | 0 | if (error) { |
3242 | 0 | ::google::protobuf::Arena* submessage_arena = NULL; |
3243 | 0 | if (message_arena != submessage_arena) { |
3244 | 0 | error = ::google::protobuf::internal::GetOwnedMessage( |
3245 | 0 | message_arena, error, submessage_arena); |
3246 | 0 | } |
3247 | 0 | set_has_error(); |
3248 | 0 | } else { |
3249 | 0 | clear_has_error(); |
3250 | 0 | } |
3251 | 0 | error_ = error; |
3252 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.EndRemoteBootstrapSessionRequestPB.error) |
3253 | 0 | } |
3254 | | |
3255 | | // optional bool keep_session = 4 [default = false]; |
3256 | 2.01k | inline bool EndRemoteBootstrapSessionRequestPB::has_keep_session() const { |
3257 | 2.01k | return (_has_bits_[0] & 0x00000008u) != 0; |
3258 | 2.01k | } |
3259 | 1.99k | inline void EndRemoteBootstrapSessionRequestPB::set_has_keep_session() { |
3260 | 1.99k | _has_bits_[0] |= 0x00000008u; |
3261 | 1.99k | } |
3262 | 0 | inline void EndRemoteBootstrapSessionRequestPB::clear_has_keep_session() { |
3263 | 0 | _has_bits_[0] &= ~0x00000008u; |
3264 | 0 | } |
3265 | 0 | inline void EndRemoteBootstrapSessionRequestPB::clear_keep_session() { |
3266 | 0 | keep_session_ = false; |
3267 | 0 | clear_has_keep_session(); |
3268 | 0 | } |
3269 | 2.00k | inline bool EndRemoteBootstrapSessionRequestPB::keep_session() const { |
3270 | | // @@protoc_insertion_point(field_get:yb.tserver.EndRemoteBootstrapSessionRequestPB.keep_session) |
3271 | 2.00k | return keep_session_; |
3272 | 2.00k | } |
3273 | 999 | inline void EndRemoteBootstrapSessionRequestPB::set_keep_session(bool value) { |
3274 | 999 | set_has_keep_session(); |
3275 | 999 | keep_session_ = value; |
3276 | | // @@protoc_insertion_point(field_set:yb.tserver.EndRemoteBootstrapSessionRequestPB.keep_session) |
3277 | 999 | } |
3278 | | |
3279 | | // ------------------------------------------------------------------- |
3280 | | |
3281 | | // EndRemoteBootstrapSessionResponsePB |
3282 | | |
3283 | | // optional bool session_kept = 1 [default = false]; |
3284 | 1.99k | inline bool EndRemoteBootstrapSessionResponsePB::has_session_kept() const { |
3285 | 1.99k | return (_has_bits_[0] & 0x00000001u) != 0; |
3286 | 1.99k | } |
3287 | 1.99k | inline void EndRemoteBootstrapSessionResponsePB::set_has_session_kept() { |
3288 | 1.99k | _has_bits_[0] |= 0x00000001u; |
3289 | 1.99k | } |
3290 | 0 | inline void EndRemoteBootstrapSessionResponsePB::clear_has_session_kept() { |
3291 | 0 | _has_bits_[0] &= ~0x00000001u; |
3292 | 0 | } |
3293 | 0 | inline void EndRemoteBootstrapSessionResponsePB::clear_session_kept() { |
3294 | 0 | session_kept_ = false; |
3295 | 0 | clear_has_session_kept(); |
3296 | 0 | } |
3297 | 1.99k | inline bool EndRemoteBootstrapSessionResponsePB::session_kept() const { |
3298 | | // @@protoc_insertion_point(field_get:yb.tserver.EndRemoteBootstrapSessionResponsePB.session_kept) |
3299 | 1.99k | return session_kept_; |
3300 | 1.99k | } |
3301 | 996 | inline void EndRemoteBootstrapSessionResponsePB::set_session_kept(bool value) { |
3302 | 996 | set_has_session_kept(); |
3303 | 996 | session_kept_ = value; |
3304 | | // @@protoc_insertion_point(field_set:yb.tserver.EndRemoteBootstrapSessionResponsePB.session_kept) |
3305 | 996 | } |
3306 | | |
3307 | | // ------------------------------------------------------------------- |
3308 | | |
3309 | | // RemoveSessionRequestPB |
3310 | | |
3311 | | // optional bytes session_id = 1; |
3312 | 1.88k | inline bool RemoveSessionRequestPB::has_session_id() const { |
3313 | 1.88k | return (_has_bits_[0] & 0x00000001u) != 0; |
3314 | 1.88k | } |
3315 | 1.88k | inline void RemoveSessionRequestPB::set_has_session_id() { |
3316 | 1.88k | _has_bits_[0] |= 0x00000001u; |
3317 | 1.88k | } |
3318 | 0 | inline void RemoveSessionRequestPB::clear_has_session_id() { |
3319 | 0 | _has_bits_[0] &= ~0x00000001u; |
3320 | 0 | } |
3321 | 0 | inline void RemoveSessionRequestPB::clear_session_id() { |
3322 | 0 | session_id_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
3323 | 0 | clear_has_session_id(); |
3324 | 0 | } |
3325 | 3.76k | inline const ::std::string& RemoveSessionRequestPB::session_id() const { |
3326 | | // @@protoc_insertion_point(field_get:yb.tserver.RemoveSessionRequestPB.session_id) |
3327 | 3.76k | return session_id_.GetNoArena(); |
3328 | 3.76k | } |
3329 | 941 | inline void RemoveSessionRequestPB::set_session_id(const ::std::string& value) { |
3330 | 941 | set_has_session_id(); |
3331 | 941 | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); |
3332 | | // @@protoc_insertion_point(field_set:yb.tserver.RemoveSessionRequestPB.session_id) |
3333 | 941 | } |
3334 | | #if LANG_CXX11 |
3335 | 0 | inline void RemoveSessionRequestPB::set_session_id(::std::string&& value) { |
3336 | 0 | set_has_session_id(); |
3337 | 0 | session_id_.SetNoArena( |
3338 | 0 | &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); |
3339 | 0 | // @@protoc_insertion_point(field_set_rvalue:yb.tserver.RemoveSessionRequestPB.session_id) |
3340 | 0 | } |
3341 | | #endif |
3342 | 0 | inline void RemoveSessionRequestPB::set_session_id(const char* value) { |
3343 | 0 | GOOGLE_DCHECK(value != NULL); |
3344 | 0 | set_has_session_id(); |
3345 | 0 | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); |
3346 | 0 | // @@protoc_insertion_point(field_set_char:yb.tserver.RemoveSessionRequestPB.session_id) |
3347 | 0 | } |
3348 | 0 | inline void RemoveSessionRequestPB::set_session_id(const void* value, size_t size) { |
3349 | 0 | set_has_session_id(); |
3350 | 0 | session_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), |
3351 | 0 | ::std::string(reinterpret_cast<const char*>(value), size)); |
3352 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.tserver.RemoveSessionRequestPB.session_id) |
3353 | 0 | } |
3354 | 941 | inline ::std::string* RemoveSessionRequestPB::mutable_session_id() { |
3355 | 941 | set_has_session_id(); |
3356 | | // @@protoc_insertion_point(field_mutable:yb.tserver.RemoveSessionRequestPB.session_id) |
3357 | 941 | return session_id_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
3358 | 941 | } |
3359 | 0 | inline ::std::string* RemoveSessionRequestPB::release_session_id() { |
3360 | 0 | // @@protoc_insertion_point(field_release:yb.tserver.RemoveSessionRequestPB.session_id) |
3361 | 0 | clear_has_session_id(); |
3362 | 0 | return session_id_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
3363 | 0 | } |
3364 | 0 | inline void RemoveSessionRequestPB::set_allocated_session_id(::std::string* session_id) { |
3365 | 0 | if (session_id != NULL) { |
3366 | 0 | set_has_session_id(); |
3367 | 0 | } else { |
3368 | 0 | clear_has_session_id(); |
3369 | 0 | } |
3370 | 0 | session_id_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), session_id); |
3371 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.tserver.RemoveSessionRequestPB.session_id) |
3372 | 0 | } |
3373 | | |
3374 | | // ------------------------------------------------------------------- |
3375 | | |
3376 | | // RemoveSessionResponsePB |
3377 | | |
3378 | | #ifdef __GNUC__ |
3379 | | #pragma GCC diagnostic pop |
3380 | | #endif // __GNUC__ |
3381 | | // ------------------------------------------------------------------- |
3382 | | |
3383 | | // ------------------------------------------------------------------- |
3384 | | |
3385 | | // ------------------------------------------------------------------- |
3386 | | |
3387 | | // ------------------------------------------------------------------- |
3388 | | |
3389 | | // ------------------------------------------------------------------- |
3390 | | |
3391 | | // ------------------------------------------------------------------- |
3392 | | |
3393 | | // ------------------------------------------------------------------- |
3394 | | |
3395 | | // ------------------------------------------------------------------- |
3396 | | |
3397 | | // ------------------------------------------------------------------- |
3398 | | |
3399 | | // ------------------------------------------------------------------- |
3400 | | |
3401 | | // ------------------------------------------------------------------- |
3402 | | |
3403 | | // ------------------------------------------------------------------- |
3404 | | |
3405 | | |
3406 | | // @@protoc_insertion_point(namespace_scope) |
3407 | | |
3408 | | } // namespace tserver |
3409 | | } // namespace yb |
3410 | | |
3411 | | namespace google { |
3412 | | namespace protobuf { |
3413 | | |
3414 | | template <> struct is_proto_enum< ::yb::tserver::RemoteBootstrapErrorPB_Code> : ::google::protobuf::internal::true_type {}; |
3415 | | template <> |
3416 | 0 | inline const EnumDescriptor* GetEnumDescriptor< ::yb::tserver::RemoteBootstrapErrorPB_Code>() { |
3417 | 0 | return ::yb::tserver::RemoteBootstrapErrorPB_Code_descriptor(); |
3418 | 0 | } |
3419 | | template <> struct is_proto_enum< ::yb::tserver::DataIdPB_IdType> : ::google::protobuf::internal::true_type {}; |
3420 | | template <> |
3421 | 0 | inline const EnumDescriptor* GetEnumDescriptor< ::yb::tserver::DataIdPB_IdType>() { |
3422 | 0 | return ::yb::tserver::DataIdPB_IdType_descriptor(); |
3423 | 0 | } |
3424 | | |
3425 | | } // namespace protobuf |
3426 | | } // namespace google |
3427 | | |
3428 | | // @@protoc_insertion_point(global_scope) |
3429 | | |
3430 | | #endif // PROTOBUF_yb_2ftserver_2fremote_5fbootstrap_2eproto__INCLUDED |