4 #ifndef PROTOBUF_datatransfer_2eproto__INCLUDED
5 #define PROTOBUF_datatransfer_2eproto__INCLUDED
9 #include <google/protobuf/stubs/common.h>
11 #if GOOGLE_PROTOBUF_VERSION < 3000000
12 #error This file was generated by a newer version of protoc which is
13 #error incompatible with your Protocol Buffer headers. Please update
16 #if 3000000 < 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.
22 #include <google/protobuf/arena.h>
23 #include <google/protobuf/arenastring.h>
24 #include <google/protobuf/generated_message_util.h>
25 #include <google/protobuf/metadata.h>
26 #include <google/protobuf/message.h>
27 #include <google/protobuf/repeated_field.h>
28 #include <google/protobuf/extension_set.h>
29 #include <google/protobuf/generated_enum_reflection.h>
30 #include <google/protobuf/unknown_field_set.h>
31 #include "Security.pb.h"
39 void protobuf_AddDesc_datatransfer_2eproto();
40 void protobuf_AssignDesc_datatransfer_2eproto();
41 void protobuf_ShutdownFile_datatransfer_2eproto();
43 class BaseHeaderProto;
44 class BlockOpResponseProto;
45 class CachingStrategyProto;
47 class ClientOperationHeaderProto;
48 class ClientReadStatusProto;
49 class DNTransferAckProto;
50 class DataTransferEncryptorMessageProto;
51 class DataTransferTraceInfoProto;
52 class OpBlockChecksumProto;
53 class OpBlockChecksumResponseProto;
54 class OpCopyBlockProto;
55 class OpReadBlockProto;
56 class OpReplaceBlockProto;
57 class OpRequestShortCircuitAccessProto;
58 class OpTransferBlockProto;
59 class OpWriteBlockProto;
60 class PacketHeaderProto;
61 class PipelineAckProto;
62 class ReadOpChecksumInfoProto;
63 class ReleaseShortCircuitAccessRequestProto;
64 class ReleaseShortCircuitAccessResponseProto;
65 class ShortCircuitShmIdProto;
66 class ShortCircuitShmRequestProto;
67 class ShortCircuitShmResponseProto;
68 class ShortCircuitShmSlotProto;
70 enum DataTransferEncryptorMessageProto_DataTransferEncryptorStatus {
71 DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_SUCCESS = 0,
72 DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_ERROR_UNKNOWN_KEY = 1,
73 DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_ERROR = 2
75 bool DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_IsValid(
int value);
76 const DataTransferEncryptorMessageProto_DataTransferEncryptorStatus DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_DataTransferEncryptorStatus_MIN = DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_SUCCESS;
77 const DataTransferEncryptorMessageProto_DataTransferEncryptorStatus DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_DataTransferEncryptorStatus_MAX = DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_ERROR;
78 const int DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_DataTransferEncryptorStatus_ARRAYSIZE = DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_DataTransferEncryptorStatus_MAX + 1;
80 const ::google::protobuf::EnumDescriptor* DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_descriptor();
81 inline const ::std::string& DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_Name(DataTransferEncryptorMessageProto_DataTransferEncryptorStatus value) {
82 return ::google::protobuf::internal::NameOfEnum(
83 DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_descriptor(), value);
85 inline bool DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_Parse(
86 const ::std::string& name, DataTransferEncryptorMessageProto_DataTransferEncryptorStatus* value) {
87 return ::google::protobuf::internal::ParseNamedEnum<DataTransferEncryptorMessageProto_DataTransferEncryptorStatus>(
88 DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_descriptor(), name, value);
90 enum OpWriteBlockProto_BlockConstructionStage {
91 OpWriteBlockProto_BlockConstructionStage_PIPELINE_SETUP_APPEND = 0,
92 OpWriteBlockProto_BlockConstructionStage_PIPELINE_SETUP_APPEND_RECOVERY = 1,
93 OpWriteBlockProto_BlockConstructionStage_DATA_STREAMING = 2,
94 OpWriteBlockProto_BlockConstructionStage_PIPELINE_SETUP_STREAMING_RECOVERY = 3,
95 OpWriteBlockProto_BlockConstructionStage_PIPELINE_CLOSE = 4,
96 OpWriteBlockProto_BlockConstructionStage_PIPELINE_CLOSE_RECOVERY = 5,
97 OpWriteBlockProto_BlockConstructionStage_PIPELINE_SETUP_CREATE = 6,
98 OpWriteBlockProto_BlockConstructionStage_TRANSFER_RBW = 7,
99 OpWriteBlockProto_BlockConstructionStage_TRANSFER_FINALIZED = 8
101 bool OpWriteBlockProto_BlockConstructionStage_IsValid(
int value);
102 const OpWriteBlockProto_BlockConstructionStage OpWriteBlockProto_BlockConstructionStage_BlockConstructionStage_MIN = OpWriteBlockProto_BlockConstructionStage_PIPELINE_SETUP_APPEND;
103 const OpWriteBlockProto_BlockConstructionStage OpWriteBlockProto_BlockConstructionStage_BlockConstructionStage_MAX = OpWriteBlockProto_BlockConstructionStage_TRANSFER_FINALIZED;
104 const int OpWriteBlockProto_BlockConstructionStage_BlockConstructionStage_ARRAYSIZE = OpWriteBlockProto_BlockConstructionStage_BlockConstructionStage_MAX + 1;
106 const ::google::protobuf::EnumDescriptor* OpWriteBlockProto_BlockConstructionStage_descriptor();
107 inline const ::std::string& OpWriteBlockProto_BlockConstructionStage_Name(OpWriteBlockProto_BlockConstructionStage value) {
108 return ::google::protobuf::internal::NameOfEnum(
109 OpWriteBlockProto_BlockConstructionStage_descriptor(), value);
111 inline bool OpWriteBlockProto_BlockConstructionStage_Parse(
112 const ::std::string& name, OpWriteBlockProto_BlockConstructionStage* value) {
113 return ::google::protobuf::internal::ParseNamedEnum<OpWriteBlockProto_BlockConstructionStage>(
114 OpWriteBlockProto_BlockConstructionStage_descriptor(), name, value);
122 ERROR_ACCESS_TOKEN = 5,
124 ERROR_UNSUPPORTED = 7,
131 bool Status_IsValid(
int value);
132 const Status Status_MIN = SUCCESS;
133 const Status Status_MAX = IN_PROGRESS;
134 const int Status_ARRAYSIZE = Status_MAX + 1;
136 const ::google::protobuf::EnumDescriptor* Status_descriptor();
137 inline const ::std::string& Status_Name(Status value) {
138 return ::google::protobuf::internal::NameOfEnum(
139 Status_descriptor(), value);
141 inline bool Status_Parse(
142 const ::std::string& name, Status* value) {
143 return ::google::protobuf::internal::ParseNamedEnum<Status>(
144 Status_descriptor(), name, value);
146 enum ShortCircuitFdResponse {
147 DO_NOT_USE_RECEIPT_VERIFICATION = 0,
148 USE_RECEIPT_VERIFICATION = 1
150 bool ShortCircuitFdResponse_IsValid(
int value);
151 const ShortCircuitFdResponse ShortCircuitFdResponse_MIN = DO_NOT_USE_RECEIPT_VERIFICATION;
152 const ShortCircuitFdResponse ShortCircuitFdResponse_MAX = USE_RECEIPT_VERIFICATION;
153 const int ShortCircuitFdResponse_ARRAYSIZE = ShortCircuitFdResponse_MAX + 1;
155 const ::google::protobuf::EnumDescriptor* ShortCircuitFdResponse_descriptor();
156 inline const ::std::string& ShortCircuitFdResponse_Name(ShortCircuitFdResponse value) {
157 return ::google::protobuf::internal::NameOfEnum(
158 ShortCircuitFdResponse_descriptor(), value);
160 inline bool ShortCircuitFdResponse_Parse(
161 const ::std::string& name, ShortCircuitFdResponse* value) {
162 return ::google::protobuf::internal::ParseNamedEnum<ShortCircuitFdResponse>(
163 ShortCircuitFdResponse_descriptor(), name, value);
179 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
180 return _internal_metadata_.unknown_fields();
183 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
184 return _internal_metadata_.mutable_unknown_fields();
187 static const ::google::protobuf::Descriptor* descriptor();
197 void CopyFrom(const ::google::protobuf::Message& from);
198 void MergeFrom(const ::google::protobuf::Message& from);
202 bool IsInitialized()
const;
204 int ByteSize()
const;
205 bool MergePartialFromCodedStream(
206 ::google::protobuf::io::CodedInputStream* input);
207 void SerializeWithCachedSizes(
208 ::google::protobuf::io::CodedOutputStream* output)
const;
209 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
210 bool deterministic, ::google::protobuf::uint8* output)
const;
211 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
212 return InternalSerializeWithCachedSizesToArray(
false, output);
214 int GetCachedSize()
const {
return _cached_size_; }
218 void SetCachedSize(
int size)
const;
221 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
222 return _internal_metadata_.arena();
224 inline void* MaybeArenaPtr()
const {
225 return _internal_metadata_.raw_arena_ptr();
229 ::google::protobuf::Metadata GetMetadata()
const;
233 typedef DataTransferEncryptorMessageProto_DataTransferEncryptorStatus DataTransferEncryptorStatus;
234 static const DataTransferEncryptorStatus SUCCESS =
235 DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_SUCCESS;
236 static const DataTransferEncryptorStatus ERROR_UNKNOWN_KEY =
237 DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_ERROR_UNKNOWN_KEY;
238 static const DataTransferEncryptorStatus ERROR =
239 DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_ERROR;
240 static inline bool DataTransferEncryptorStatus_IsValid(
int value) {
241 return DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_IsValid(value);
243 static const DataTransferEncryptorStatus DataTransferEncryptorStatus_MIN =
244 DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_DataTransferEncryptorStatus_MIN;
245 static const DataTransferEncryptorStatus DataTransferEncryptorStatus_MAX =
246 DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_DataTransferEncryptorStatus_MAX;
247 static const int DataTransferEncryptorStatus_ARRAYSIZE =
248 DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_DataTransferEncryptorStatus_ARRAYSIZE;
249 static inline const ::google::protobuf::EnumDescriptor*
250 DataTransferEncryptorStatus_descriptor() {
251 return DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_descriptor();
253 static inline const ::std::string& DataTransferEncryptorStatus_Name(DataTransferEncryptorStatus value) {
254 return DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_Name(value);
256 static inline bool DataTransferEncryptorStatus_Parse(const ::std::string& name,
257 DataTransferEncryptorStatus* value) {
258 return DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_Parse(name, value);
264 bool has_status()
const;
266 static const int kStatusFieldNumber = 1;
267 ::hadoop::hdfs::DataTransferEncryptorMessageProto_DataTransferEncryptorStatus status()
const;
268 void set_status(::hadoop::hdfs::DataTransferEncryptorMessageProto_DataTransferEncryptorStatus value);
271 bool has_payload()
const;
272 void clear_payload();
273 static const int kPayloadFieldNumber = 2;
274 const ::std::string& payload()
const;
275 void set_payload(const ::std::string& value);
276 void set_payload(
const char* value);
277 void set_payload(
const void* value,
size_t size);
278 ::std::string* mutable_payload();
279 ::std::string* release_payload();
280 void set_allocated_payload(::std::string* payload);
283 bool has_message()
const;
284 void clear_message();
285 static const int kMessageFieldNumber = 3;
286 const ::std::string& message()
const;
287 void set_message(const ::std::string& value);
288 void set_message(
const char* value);
289 void set_message(
const char* value,
size_t size);
290 ::std::string* mutable_message();
291 ::std::string* release_message();
292 void set_allocated_message(::std::string* message);
295 int cipheroption_size()
const;
296 void clear_cipheroption();
297 static const int kCipherOptionFieldNumber = 4;
298 const ::hadoop::hdfs::CipherOptionProto& cipheroption(
int index)
const;
301 ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::CipherOptionProto >*
302 mutable_cipheroption();
303 const ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::CipherOptionProto >&
304 cipheroption()
const;
308 inline void set_has_status();
309 inline void clear_has_status();
310 inline void set_has_payload();
311 inline void clear_has_payload();
312 inline void set_has_message();
313 inline void clear_has_message();
315 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
316 ::google::protobuf::uint32 _has_bits_[1];
317 mutable int _cached_size_;
318 ::google::protobuf::internal::ArenaStringPtr payload_;
319 ::google::protobuf::internal::ArenaStringPtr message_;
320 ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::CipherOptionProto > cipheroption_;
322 friend void protobuf_AddDesc_datatransfer_2eproto();
323 friend void protobuf_AssignDesc_datatransfer_2eproto();
324 friend void protobuf_ShutdownFile_datatransfer_2eproto();
326 void InitAsDefaultInstance();
343 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
344 return _internal_metadata_.unknown_fields();
347 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
348 return _internal_metadata_.mutable_unknown_fields();
351 static const ::google::protobuf::Descriptor* descriptor();
361 void CopyFrom(const ::google::protobuf::Message& from);
362 void MergeFrom(const ::google::protobuf::Message& from);
366 bool IsInitialized()
const;
368 int ByteSize()
const;
369 bool MergePartialFromCodedStream(
370 ::google::protobuf::io::CodedInputStream* input);
371 void SerializeWithCachedSizes(
372 ::google::protobuf::io::CodedOutputStream* output)
const;
373 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
374 bool deterministic, ::google::protobuf::uint8* output)
const;
375 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
376 return InternalSerializeWithCachedSizesToArray(
false, output);
378 int GetCachedSize()
const {
return _cached_size_; }
382 void SetCachedSize(
int size)
const;
385 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
386 return _internal_metadata_.arena();
388 inline void* MaybeArenaPtr()
const {
389 return _internal_metadata_.raw_arena_ptr();
393 ::google::protobuf::Metadata GetMetadata()
const;
400 bool has_block()
const;
402 static const int kBlockFieldNumber = 1;
403 const ::hadoop::hdfs::ExtendedBlockProto& block()
const;
409 bool has_token()
const;
411 static const int kTokenFieldNumber = 2;
412 const ::hadoop::common::TokenProto& token()
const;
418 bool has_traceinfo()
const;
419 void clear_traceinfo();
420 static const int kTraceInfoFieldNumber = 3;
421 const ::hadoop::hdfs::DataTransferTraceInfoProto& traceinfo()
const;
428 inline void set_has_block();
429 inline void clear_has_block();
430 inline void set_has_token();
431 inline void clear_has_token();
432 inline void set_has_traceinfo();
433 inline void clear_has_traceinfo();
435 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
436 ::google::protobuf::uint32 _has_bits_[1];
437 mutable int _cached_size_;
441 friend void protobuf_AddDesc_datatransfer_2eproto();
442 friend void protobuf_AssignDesc_datatransfer_2eproto();
443 friend void protobuf_ShutdownFile_datatransfer_2eproto();
445 void InitAsDefaultInstance();
462 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
463 return _internal_metadata_.unknown_fields();
466 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
467 return _internal_metadata_.mutable_unknown_fields();
470 static const ::google::protobuf::Descriptor* descriptor();
480 void CopyFrom(const ::google::protobuf::Message& from);
481 void MergeFrom(const ::google::protobuf::Message& from);
485 bool IsInitialized()
const;
487 int ByteSize()
const;
488 bool MergePartialFromCodedStream(
489 ::google::protobuf::io::CodedInputStream* input);
490 void SerializeWithCachedSizes(
491 ::google::protobuf::io::CodedOutputStream* output)
const;
492 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
493 bool deterministic, ::google::protobuf::uint8* output)
const;
494 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
495 return InternalSerializeWithCachedSizesToArray(
false, output);
497 int GetCachedSize()
const {
return _cached_size_; }
501 void SetCachedSize(
int size)
const;
504 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
505 return _internal_metadata_.arena();
507 inline void* MaybeArenaPtr()
const {
508 return _internal_metadata_.raw_arena_ptr();
512 ::google::protobuf::Metadata GetMetadata()
const;
519 bool has_traceid()
const;
520 void clear_traceid();
521 static const int kTraceIdFieldNumber = 1;
522 ::google::protobuf::uint64 traceid()
const;
523 void set_traceid(::google::protobuf::uint64 value);
526 bool has_parentid()
const;
527 void clear_parentid();
528 static const int kParentIdFieldNumber = 2;
529 ::google::protobuf::uint64 parentid()
const;
530 void set_parentid(::google::protobuf::uint64 value);
534 inline void set_has_traceid();
535 inline void clear_has_traceid();
536 inline void set_has_parentid();
537 inline void clear_has_parentid();
540 int RequiredFieldsByteSizeFallback()
const;
542 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
543 ::google::protobuf::uint32 _has_bits_[1];
544 mutable int _cached_size_;
545 ::google::protobuf::uint64 traceid_;
546 ::google::protobuf::uint64 parentid_;
547 friend void protobuf_AddDesc_datatransfer_2eproto();
548 friend void protobuf_AssignDesc_datatransfer_2eproto();
549 friend void protobuf_ShutdownFile_datatransfer_2eproto();
551 void InitAsDefaultInstance();
568 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
569 return _internal_metadata_.unknown_fields();
572 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
573 return _internal_metadata_.mutable_unknown_fields();
576 static const ::google::protobuf::Descriptor* descriptor();
586 void CopyFrom(const ::google::protobuf::Message& from);
587 void MergeFrom(const ::google::protobuf::Message& from);
591 bool IsInitialized()
const;
593 int ByteSize()
const;
594 bool MergePartialFromCodedStream(
595 ::google::protobuf::io::CodedInputStream* input);
596 void SerializeWithCachedSizes(
597 ::google::protobuf::io::CodedOutputStream* output)
const;
598 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
599 bool deterministic, ::google::protobuf::uint8* output)
const;
600 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
601 return InternalSerializeWithCachedSizesToArray(
false, output);
603 int GetCachedSize()
const {
return _cached_size_; }
607 void SetCachedSize(
int size)
const;
610 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
611 return _internal_metadata_.arena();
613 inline void* MaybeArenaPtr()
const {
614 return _internal_metadata_.raw_arena_ptr();
618 ::google::protobuf::Metadata GetMetadata()
const;
625 bool has_baseheader()
const;
626 void clear_baseheader();
627 static const int kBaseHeaderFieldNumber = 1;
628 const ::hadoop::hdfs::BaseHeaderProto& baseheader()
const;
634 bool has_clientname()
const;
635 void clear_clientname();
636 static const int kClientNameFieldNumber = 2;
637 const ::std::string& clientname()
const;
638 void set_clientname(const ::std::string& value);
639 void set_clientname(
const char* value);
640 void set_clientname(
const char* value,
size_t size);
641 ::std::string* mutable_clientname();
642 ::std::string* release_clientname();
643 void set_allocated_clientname(::std::string* clientname);
647 inline void set_has_baseheader();
648 inline void clear_has_baseheader();
649 inline void set_has_clientname();
650 inline void clear_has_clientname();
653 int RequiredFieldsByteSizeFallback()
const;
655 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
656 ::google::protobuf::uint32 _has_bits_[1];
657 mutable int _cached_size_;
659 ::google::protobuf::internal::ArenaStringPtr clientname_;
660 friend void protobuf_AddDesc_datatransfer_2eproto();
661 friend void protobuf_AssignDesc_datatransfer_2eproto();
662 friend void protobuf_ShutdownFile_datatransfer_2eproto();
664 void InitAsDefaultInstance();
681 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
682 return _internal_metadata_.unknown_fields();
685 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
686 return _internal_metadata_.mutable_unknown_fields();
689 static const ::google::protobuf::Descriptor* descriptor();
699 void CopyFrom(const ::google::protobuf::Message& from);
700 void MergeFrom(const ::google::protobuf::Message& from);
704 bool IsInitialized()
const;
706 int ByteSize()
const;
707 bool MergePartialFromCodedStream(
708 ::google::protobuf::io::CodedInputStream* input);
709 void SerializeWithCachedSizes(
710 ::google::protobuf::io::CodedOutputStream* output)
const;
711 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
712 bool deterministic, ::google::protobuf::uint8* output)
const;
713 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
714 return InternalSerializeWithCachedSizesToArray(
false, output);
716 int GetCachedSize()
const {
return _cached_size_; }
720 void SetCachedSize(
int size)
const;
723 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
724 return _internal_metadata_.arena();
726 inline void* MaybeArenaPtr()
const {
727 return _internal_metadata_.raw_arena_ptr();
731 ::google::protobuf::Metadata GetMetadata()
const;
738 bool has_dropbehind()
const;
739 void clear_dropbehind();
740 static const int kDropBehindFieldNumber = 1;
741 bool dropbehind()
const;
742 void set_dropbehind(
bool value);
745 bool has_readahead()
const;
746 void clear_readahead();
747 static const int kReadaheadFieldNumber = 2;
748 ::google::protobuf::int64 readahead()
const;
749 void set_readahead(::google::protobuf::int64 value);
753 inline void set_has_dropbehind();
754 inline void clear_has_dropbehind();
755 inline void set_has_readahead();
756 inline void clear_has_readahead();
758 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
759 ::google::protobuf::uint32 _has_bits_[1];
760 mutable int _cached_size_;
761 ::google::protobuf::int64 readahead_;
763 friend void protobuf_AddDesc_datatransfer_2eproto();
764 friend void protobuf_AssignDesc_datatransfer_2eproto();
765 friend void protobuf_ShutdownFile_datatransfer_2eproto();
767 void InitAsDefaultInstance();
784 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
785 return _internal_metadata_.unknown_fields();
788 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
789 return _internal_metadata_.mutable_unknown_fields();
792 static const ::google::protobuf::Descriptor* descriptor();
802 void CopyFrom(const ::google::protobuf::Message& from);
803 void MergeFrom(const ::google::protobuf::Message& from);
807 bool IsInitialized()
const;
809 int ByteSize()
const;
810 bool MergePartialFromCodedStream(
811 ::google::protobuf::io::CodedInputStream* input);
812 void SerializeWithCachedSizes(
813 ::google::protobuf::io::CodedOutputStream* output)
const;
814 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
815 bool deterministic, ::google::protobuf::uint8* output)
const;
816 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
817 return InternalSerializeWithCachedSizesToArray(
false, output);
819 int GetCachedSize()
const {
return _cached_size_; }
823 void SetCachedSize(
int size)
const;
826 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
827 return _internal_metadata_.arena();
829 inline void* MaybeArenaPtr()
const {
830 return _internal_metadata_.raw_arena_ptr();
834 ::google::protobuf::Metadata GetMetadata()
const;
841 bool has_header()
const;
843 static const int kHeaderFieldNumber = 1;
844 const ::hadoop::hdfs::ClientOperationHeaderProto& header()
const;
850 bool has_offset()
const;
852 static const int kOffsetFieldNumber = 2;
853 ::google::protobuf::uint64 offset()
const;
854 void set_offset(::google::protobuf::uint64 value);
857 bool has_len()
const;
859 static const int kLenFieldNumber = 3;
860 ::google::protobuf::uint64 len()
const;
861 void set_len(::google::protobuf::uint64 value);
864 bool has_sendchecksums()
const;
865 void clear_sendchecksums();
866 static const int kSendChecksumsFieldNumber = 4;
867 bool sendchecksums()
const;
868 void set_sendchecksums(
bool value);
871 bool has_cachingstrategy()
const;
872 void clear_cachingstrategy();
873 static const int kCachingStrategyFieldNumber = 5;
874 const ::hadoop::hdfs::CachingStrategyProto& cachingstrategy()
const;
881 inline void set_has_header();
882 inline void clear_has_header();
883 inline void set_has_offset();
884 inline void clear_has_offset();
885 inline void set_has_len();
886 inline void clear_has_len();
887 inline void set_has_sendchecksums();
888 inline void clear_has_sendchecksums();
889 inline void set_has_cachingstrategy();
890 inline void clear_has_cachingstrategy();
893 int RequiredFieldsByteSizeFallback()
const;
895 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
896 ::google::protobuf::uint32 _has_bits_[1];
897 mutable int _cached_size_;
899 ::google::protobuf::uint64 offset_;
900 ::google::protobuf::uint64 len_;
903 friend void protobuf_AddDesc_datatransfer_2eproto();
904 friend void protobuf_AssignDesc_datatransfer_2eproto();
905 friend void protobuf_ShutdownFile_datatransfer_2eproto();
907 void InitAsDefaultInstance();
924 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
925 return _internal_metadata_.unknown_fields();
928 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
929 return _internal_metadata_.mutable_unknown_fields();
932 static const ::google::protobuf::Descriptor* descriptor();
942 void CopyFrom(const ::google::protobuf::Message& from);
943 void MergeFrom(const ::google::protobuf::Message& from);
947 bool IsInitialized()
const;
949 int ByteSize()
const;
950 bool MergePartialFromCodedStream(
951 ::google::protobuf::io::CodedInputStream* input);
952 void SerializeWithCachedSizes(
953 ::google::protobuf::io::CodedOutputStream* output)
const;
954 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
955 bool deterministic, ::google::protobuf::uint8* output)
const;
956 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
957 return InternalSerializeWithCachedSizesToArray(
false, output);
959 int GetCachedSize()
const {
return _cached_size_; }
963 void SetCachedSize(
int size)
const;
966 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
967 return _internal_metadata_.arena();
969 inline void* MaybeArenaPtr()
const {
970 return _internal_metadata_.raw_arena_ptr();
974 ::google::protobuf::Metadata GetMetadata()
const;
981 bool has_type()
const;
983 static const int kTypeFieldNumber = 1;
984 ::hadoop::hdfs::ChecksumTypeProto type()
const;
985 void set_type(::hadoop::hdfs::ChecksumTypeProto value);
988 bool has_bytesperchecksum()
const;
989 void clear_bytesperchecksum();
990 static const int kBytesPerChecksumFieldNumber = 2;
991 ::google::protobuf::uint32 bytesperchecksum()
const;
992 void set_bytesperchecksum(::google::protobuf::uint32 value);
996 inline void set_has_type();
997 inline void clear_has_type();
998 inline void set_has_bytesperchecksum();
999 inline void clear_has_bytesperchecksum();
1002 int RequiredFieldsByteSizeFallback()
const;
1004 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
1005 ::google::protobuf::uint32 _has_bits_[1];
1006 mutable int _cached_size_;
1008 ::google::protobuf::uint32 bytesperchecksum_;
1009 friend void protobuf_AddDesc_datatransfer_2eproto();
1010 friend void protobuf_AssignDesc_datatransfer_2eproto();
1011 friend void protobuf_ShutdownFile_datatransfer_2eproto();
1013 void InitAsDefaultInstance();
1030 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
1031 return _internal_metadata_.unknown_fields();
1034 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1035 return _internal_metadata_.mutable_unknown_fields();
1038 static const ::google::protobuf::Descriptor* descriptor();
1048 void CopyFrom(const ::google::protobuf::Message& from);
1049 void MergeFrom(const ::google::protobuf::Message& from);
1053 bool IsInitialized()
const;
1055 int ByteSize()
const;
1056 bool MergePartialFromCodedStream(
1057 ::google::protobuf::io::CodedInputStream* input);
1058 void SerializeWithCachedSizes(
1059 ::google::protobuf::io::CodedOutputStream* output)
const;
1060 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
1061 bool deterministic, ::google::protobuf::uint8* output)
const;
1062 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
1063 return InternalSerializeWithCachedSizesToArray(
false, output);
1065 int GetCachedSize()
const {
return _cached_size_; }
1069 void SetCachedSize(
int size)
const;
1072 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
1073 return _internal_metadata_.arena();
1075 inline void* MaybeArenaPtr()
const {
1076 return _internal_metadata_.raw_arena_ptr();
1080 ::google::protobuf::Metadata GetMetadata()
const;
1084 typedef OpWriteBlockProto_BlockConstructionStage BlockConstructionStage;
1085 static const BlockConstructionStage PIPELINE_SETUP_APPEND =
1086 OpWriteBlockProto_BlockConstructionStage_PIPELINE_SETUP_APPEND;
1087 static const BlockConstructionStage PIPELINE_SETUP_APPEND_RECOVERY =
1088 OpWriteBlockProto_BlockConstructionStage_PIPELINE_SETUP_APPEND_RECOVERY;
1089 static const BlockConstructionStage DATA_STREAMING =
1090 OpWriteBlockProto_BlockConstructionStage_DATA_STREAMING;
1091 static const BlockConstructionStage PIPELINE_SETUP_STREAMING_RECOVERY =
1092 OpWriteBlockProto_BlockConstructionStage_PIPELINE_SETUP_STREAMING_RECOVERY;
1093 static const BlockConstructionStage PIPELINE_CLOSE =
1094 OpWriteBlockProto_BlockConstructionStage_PIPELINE_CLOSE;
1095 static const BlockConstructionStage PIPELINE_CLOSE_RECOVERY =
1096 OpWriteBlockProto_BlockConstructionStage_PIPELINE_CLOSE_RECOVERY;
1097 static const BlockConstructionStage PIPELINE_SETUP_CREATE =
1098 OpWriteBlockProto_BlockConstructionStage_PIPELINE_SETUP_CREATE;
1099 static const BlockConstructionStage TRANSFER_RBW =
1100 OpWriteBlockProto_BlockConstructionStage_TRANSFER_RBW;
1101 static const BlockConstructionStage TRANSFER_FINALIZED =
1102 OpWriteBlockProto_BlockConstructionStage_TRANSFER_FINALIZED;
1103 static inline bool BlockConstructionStage_IsValid(
int value) {
1104 return OpWriteBlockProto_BlockConstructionStage_IsValid(value);
1106 static const BlockConstructionStage BlockConstructionStage_MIN =
1107 OpWriteBlockProto_BlockConstructionStage_BlockConstructionStage_MIN;
1108 static const BlockConstructionStage BlockConstructionStage_MAX =
1109 OpWriteBlockProto_BlockConstructionStage_BlockConstructionStage_MAX;
1110 static const int BlockConstructionStage_ARRAYSIZE =
1111 OpWriteBlockProto_BlockConstructionStage_BlockConstructionStage_ARRAYSIZE;
1112 static inline const ::google::protobuf::EnumDescriptor*
1113 BlockConstructionStage_descriptor() {
1114 return OpWriteBlockProto_BlockConstructionStage_descriptor();
1116 static inline const ::std::string& BlockConstructionStage_Name(BlockConstructionStage value) {
1117 return OpWriteBlockProto_BlockConstructionStage_Name(value);
1119 static inline bool BlockConstructionStage_Parse(const ::std::string& name,
1120 BlockConstructionStage* value) {
1121 return OpWriteBlockProto_BlockConstructionStage_Parse(name, value);
1127 bool has_header()
const;
1128 void clear_header();
1129 static const int kHeaderFieldNumber = 1;
1130 const ::hadoop::hdfs::ClientOperationHeaderProto& header()
const;
1136 int targets_size()
const;
1137 void clear_targets();
1138 static const int kTargetsFieldNumber = 2;
1139 const ::hadoop::hdfs::DatanodeInfoProto& targets(
int index)
const;
1142 ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::DatanodeInfoProto >*
1144 const ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::DatanodeInfoProto >&
1148 bool has_source()
const;
1149 void clear_source();
1150 static const int kSourceFieldNumber = 3;
1151 const ::hadoop::hdfs::DatanodeInfoProto& source()
const;
1157 bool has_stage()
const;
1159 static const int kStageFieldNumber = 4;
1160 ::hadoop::hdfs::OpWriteBlockProto_BlockConstructionStage stage()
const;
1161 void set_stage(::hadoop::hdfs::OpWriteBlockProto_BlockConstructionStage value);
1164 bool has_pipelinesize()
const;
1165 void clear_pipelinesize();
1166 static const int kPipelineSizeFieldNumber = 5;
1167 ::google::protobuf::uint32 pipelinesize()
const;
1168 void set_pipelinesize(::google::protobuf::uint32 value);
1171 bool has_minbytesrcvd()
const;
1172 void clear_minbytesrcvd();
1173 static const int kMinBytesRcvdFieldNumber = 6;
1174 ::google::protobuf::uint64 minbytesrcvd()
const;
1175 void set_minbytesrcvd(::google::protobuf::uint64 value);
1178 bool has_maxbytesrcvd()
const;
1179 void clear_maxbytesrcvd();
1180 static const int kMaxBytesRcvdFieldNumber = 7;
1181 ::google::protobuf::uint64 maxbytesrcvd()
const;
1182 void set_maxbytesrcvd(::google::protobuf::uint64 value);
1185 bool has_latestgenerationstamp()
const;
1186 void clear_latestgenerationstamp();
1187 static const int kLatestGenerationStampFieldNumber = 8;
1188 ::google::protobuf::uint64 latestgenerationstamp()
const;
1189 void set_latestgenerationstamp(::google::protobuf::uint64 value);
1192 bool has_requestedchecksum()
const;
1193 void clear_requestedchecksum();
1194 static const int kRequestedChecksumFieldNumber = 9;
1195 const ::hadoop::hdfs::ChecksumProto& requestedchecksum()
const;
1201 bool has_cachingstrategy()
const;
1202 void clear_cachingstrategy();
1203 static const int kCachingStrategyFieldNumber = 10;
1204 const ::hadoop::hdfs::CachingStrategyProto& cachingstrategy()
const;
1210 bool has_storagetype()
const;
1211 void clear_storagetype();
1212 static const int kStorageTypeFieldNumber = 11;
1213 ::hadoop::hdfs::StorageTypeProto storagetype()
const;
1214 void set_storagetype(::hadoop::hdfs::StorageTypeProto value);
1217 int targetstoragetypes_size()
const;
1218 void clear_targetstoragetypes();
1219 static const int kTargetStorageTypesFieldNumber = 12;
1220 ::hadoop::hdfs::StorageTypeProto targetstoragetypes(
int index)
const;
1221 void set_targetstoragetypes(
int index, ::hadoop::hdfs::StorageTypeProto value);
1222 void add_targetstoragetypes(::hadoop::hdfs::StorageTypeProto value);
1223 const ::google::protobuf::RepeatedField<int>& targetstoragetypes()
const;
1224 ::google::protobuf::RepeatedField<int>* mutable_targetstoragetypes();
1227 bool has_allowlazypersist()
const;
1228 void clear_allowlazypersist();
1229 static const int kAllowLazyPersistFieldNumber = 13;
1230 bool allowlazypersist()
const;
1231 void set_allowlazypersist(
bool value);
1234 bool has_pinning()
const;
1235 void clear_pinning();
1236 static const int kPinningFieldNumber = 14;
1237 bool pinning()
const;
1238 void set_pinning(
bool value);
1241 int targetpinnings_size()
const;
1242 void clear_targetpinnings();
1243 static const int kTargetPinningsFieldNumber = 15;
1244 bool targetpinnings(
int index)
const;
1245 void set_targetpinnings(
int index,
bool value);
1246 void add_targetpinnings(
bool value);
1247 const ::google::protobuf::RepeatedField< bool >&
1248 targetpinnings()
const;
1249 ::google::protobuf::RepeatedField< bool >*
1250 mutable_targetpinnings();
1254 inline void set_has_header();
1255 inline void clear_has_header();
1256 inline void set_has_source();
1257 inline void clear_has_source();
1258 inline void set_has_stage();
1259 inline void clear_has_stage();
1260 inline void set_has_pipelinesize();
1261 inline void clear_has_pipelinesize();
1262 inline void set_has_minbytesrcvd();
1263 inline void clear_has_minbytesrcvd();
1264 inline void set_has_maxbytesrcvd();
1265 inline void clear_has_maxbytesrcvd();
1266 inline void set_has_latestgenerationstamp();
1267 inline void clear_has_latestgenerationstamp();
1268 inline void set_has_requestedchecksum();
1269 inline void clear_has_requestedchecksum();
1270 inline void set_has_cachingstrategy();
1271 inline void clear_has_cachingstrategy();
1272 inline void set_has_storagetype();
1273 inline void clear_has_storagetype();
1274 inline void set_has_allowlazypersist();
1275 inline void clear_has_allowlazypersist();
1276 inline void set_has_pinning();
1277 inline void clear_has_pinning();
1280 int RequiredFieldsByteSizeFallback()
const;
1282 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
1283 ::google::protobuf::uint32 _has_bits_[1];
1284 mutable int _cached_size_;
1286 ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::DatanodeInfoProto > targets_;
1289 ::google::protobuf::uint32 pipelinesize_;
1290 ::google::protobuf::uint64 minbytesrcvd_;
1291 ::google::protobuf::uint64 maxbytesrcvd_;
1292 ::google::protobuf::uint64 latestgenerationstamp_;
1295 ::google::protobuf::RepeatedField<int> targetstoragetypes_;
1297 bool allowlazypersist_;
1299 ::google::protobuf::RepeatedField< bool > targetpinnings_;
1300 friend void protobuf_AddDesc_datatransfer_2eproto();
1301 friend void protobuf_AssignDesc_datatransfer_2eproto();
1302 friend void protobuf_ShutdownFile_datatransfer_2eproto();
1304 void InitAsDefaultInstance();
1321 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
1322 return _internal_metadata_.unknown_fields();
1325 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1326 return _internal_metadata_.mutable_unknown_fields();
1329 static const ::google::protobuf::Descriptor* descriptor();
1339 void CopyFrom(const ::google::protobuf::Message& from);
1340 void MergeFrom(const ::google::protobuf::Message& from);
1344 bool IsInitialized()
const;
1346 int ByteSize()
const;
1347 bool MergePartialFromCodedStream(
1348 ::google::protobuf::io::CodedInputStream* input);
1349 void SerializeWithCachedSizes(
1350 ::google::protobuf::io::CodedOutputStream* output)
const;
1351 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
1352 bool deterministic, ::google::protobuf::uint8* output)
const;
1353 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
1354 return InternalSerializeWithCachedSizesToArray(
false, output);
1356 int GetCachedSize()
const {
return _cached_size_; }
1360 void SetCachedSize(
int size)
const;
1363 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
1364 return _internal_metadata_.arena();
1366 inline void* MaybeArenaPtr()
const {
1367 return _internal_metadata_.raw_arena_ptr();
1371 ::google::protobuf::Metadata GetMetadata()
const;
1378 bool has_header()
const;
1379 void clear_header();
1380 static const int kHeaderFieldNumber = 1;
1381 const ::hadoop::hdfs::ClientOperationHeaderProto& header()
const;
1387 int targets_size()
const;
1388 void clear_targets();
1389 static const int kTargetsFieldNumber = 2;
1390 const ::hadoop::hdfs::DatanodeInfoProto& targets(
int index)
const;
1393 ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::DatanodeInfoProto >*
1395 const ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::DatanodeInfoProto >&
1399 int targetstoragetypes_size()
const;
1400 void clear_targetstoragetypes();
1401 static const int kTargetStorageTypesFieldNumber = 3;
1402 ::hadoop::hdfs::StorageTypeProto targetstoragetypes(
int index)
const;
1403 void set_targetstoragetypes(
int index, ::hadoop::hdfs::StorageTypeProto value);
1404 void add_targetstoragetypes(::hadoop::hdfs::StorageTypeProto value);
1405 const ::google::protobuf::RepeatedField<int>& targetstoragetypes()
const;
1406 ::google::protobuf::RepeatedField<int>* mutable_targetstoragetypes();
1410 inline void set_has_header();
1411 inline void clear_has_header();
1413 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
1414 ::google::protobuf::uint32 _has_bits_[1];
1415 mutable int _cached_size_;
1417 ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::DatanodeInfoProto > targets_;
1418 ::google::protobuf::RepeatedField<int> targetstoragetypes_;
1419 friend void protobuf_AddDesc_datatransfer_2eproto();
1420 friend void protobuf_AssignDesc_datatransfer_2eproto();
1421 friend void protobuf_ShutdownFile_datatransfer_2eproto();
1423 void InitAsDefaultInstance();
1440 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
1441 return _internal_metadata_.unknown_fields();
1444 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1445 return _internal_metadata_.mutable_unknown_fields();
1448 static const ::google::protobuf::Descriptor* descriptor();
1458 void CopyFrom(const ::google::protobuf::Message& from);
1459 void MergeFrom(const ::google::protobuf::Message& from);
1463 bool IsInitialized()
const;
1465 int ByteSize()
const;
1466 bool MergePartialFromCodedStream(
1467 ::google::protobuf::io::CodedInputStream* input);
1468 void SerializeWithCachedSizes(
1469 ::google::protobuf::io::CodedOutputStream* output)
const;
1470 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
1471 bool deterministic, ::google::protobuf::uint8* output)
const;
1472 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
1473 return InternalSerializeWithCachedSizesToArray(
false, output);
1475 int GetCachedSize()
const {
return _cached_size_; }
1479 void SetCachedSize(
int size)
const;
1482 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
1483 return _internal_metadata_.arena();
1485 inline void* MaybeArenaPtr()
const {
1486 return _internal_metadata_.raw_arena_ptr();
1490 ::google::protobuf::Metadata GetMetadata()
const;
1497 bool has_header()
const;
1498 void clear_header();
1499 static const int kHeaderFieldNumber = 1;
1500 const ::hadoop::hdfs::BaseHeaderProto& header()
const;
1506 bool has_delhint()
const;
1507 void clear_delhint();
1508 static const int kDelHintFieldNumber = 2;
1509 const ::std::string& delhint()
const;
1510 void set_delhint(const ::std::string& value);
1511 void set_delhint(
const char* value);
1512 void set_delhint(
const char* value,
size_t size);
1513 ::std::string* mutable_delhint();
1514 ::std::string* release_delhint();
1515 void set_allocated_delhint(::std::string* delhint);
1518 bool has_source()
const;
1519 void clear_source();
1520 static const int kSourceFieldNumber = 3;
1521 const ::hadoop::hdfs::DatanodeInfoProto& source()
const;
1527 bool has_storagetype()
const;
1528 void clear_storagetype();
1529 static const int kStorageTypeFieldNumber = 4;
1530 ::hadoop::hdfs::StorageTypeProto storagetype()
const;
1531 void set_storagetype(::hadoop::hdfs::StorageTypeProto value);
1535 inline void set_has_header();
1536 inline void clear_has_header();
1537 inline void set_has_delhint();
1538 inline void clear_has_delhint();
1539 inline void set_has_source();
1540 inline void clear_has_source();
1541 inline void set_has_storagetype();
1542 inline void clear_has_storagetype();
1545 int RequiredFieldsByteSizeFallback()
const;
1547 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
1548 ::google::protobuf::uint32 _has_bits_[1];
1549 mutable int _cached_size_;
1551 ::google::protobuf::internal::ArenaStringPtr delhint_;
1554 friend void protobuf_AddDesc_datatransfer_2eproto();
1555 friend void protobuf_AssignDesc_datatransfer_2eproto();
1556 friend void protobuf_ShutdownFile_datatransfer_2eproto();
1558 void InitAsDefaultInstance();
1575 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
1576 return _internal_metadata_.unknown_fields();
1579 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1580 return _internal_metadata_.mutable_unknown_fields();
1583 static const ::google::protobuf::Descriptor* descriptor();
1593 void CopyFrom(const ::google::protobuf::Message& from);
1594 void MergeFrom(const ::google::protobuf::Message& from);
1598 bool IsInitialized()
const;
1600 int ByteSize()
const;
1601 bool MergePartialFromCodedStream(
1602 ::google::protobuf::io::CodedInputStream* input);
1603 void SerializeWithCachedSizes(
1604 ::google::protobuf::io::CodedOutputStream* output)
const;
1605 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
1606 bool deterministic, ::google::protobuf::uint8* output)
const;
1607 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
1608 return InternalSerializeWithCachedSizesToArray(
false, output);
1610 int GetCachedSize()
const {
return _cached_size_; }
1614 void SetCachedSize(
int size)
const;
1617 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
1618 return _internal_metadata_.arena();
1620 inline void* MaybeArenaPtr()
const {
1621 return _internal_metadata_.raw_arena_ptr();
1625 ::google::protobuf::Metadata GetMetadata()
const;
1632 bool has_header()
const;
1633 void clear_header();
1634 static const int kHeaderFieldNumber = 1;
1635 const ::hadoop::hdfs::BaseHeaderProto& header()
const;
1642 inline void set_has_header();
1643 inline void clear_has_header();
1645 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
1646 ::google::protobuf::uint32 _has_bits_[1];
1647 mutable int _cached_size_;
1649 friend void protobuf_AddDesc_datatransfer_2eproto();
1650 friend void protobuf_AssignDesc_datatransfer_2eproto();
1651 friend void protobuf_ShutdownFile_datatransfer_2eproto();
1653 void InitAsDefaultInstance();
1670 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
1671 return _internal_metadata_.unknown_fields();
1674 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1675 return _internal_metadata_.mutable_unknown_fields();
1678 static const ::google::protobuf::Descriptor* descriptor();
1688 void CopyFrom(const ::google::protobuf::Message& from);
1689 void MergeFrom(const ::google::protobuf::Message& from);
1693 bool IsInitialized()
const;
1695 int ByteSize()
const;
1696 bool MergePartialFromCodedStream(
1697 ::google::protobuf::io::CodedInputStream* input);
1698 void SerializeWithCachedSizes(
1699 ::google::protobuf::io::CodedOutputStream* output)
const;
1700 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
1701 bool deterministic, ::google::protobuf::uint8* output)
const;
1702 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
1703 return InternalSerializeWithCachedSizesToArray(
false, output);
1705 int GetCachedSize()
const {
return _cached_size_; }
1709 void SetCachedSize(
int size)
const;
1712 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
1713 return _internal_metadata_.arena();
1715 inline void* MaybeArenaPtr()
const {
1716 return _internal_metadata_.raw_arena_ptr();
1720 ::google::protobuf::Metadata GetMetadata()
const;
1727 bool has_header()
const;
1728 void clear_header();
1729 static const int kHeaderFieldNumber = 1;
1730 const ::hadoop::hdfs::BaseHeaderProto& header()
const;
1737 inline void set_has_header();
1738 inline void clear_has_header();
1740 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
1741 ::google::protobuf::uint32 _has_bits_[1];
1742 mutable int _cached_size_;
1744 friend void protobuf_AddDesc_datatransfer_2eproto();
1745 friend void protobuf_AssignDesc_datatransfer_2eproto();
1746 friend void protobuf_ShutdownFile_datatransfer_2eproto();
1748 void InitAsDefaultInstance();
1765 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
1766 return _internal_metadata_.unknown_fields();
1769 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1770 return _internal_metadata_.mutable_unknown_fields();
1773 static const ::google::protobuf::Descriptor* descriptor();
1783 void CopyFrom(const ::google::protobuf::Message& from);
1784 void MergeFrom(const ::google::protobuf::Message& from);
1788 bool IsInitialized()
const;
1790 int ByteSize()
const;
1791 bool MergePartialFromCodedStream(
1792 ::google::protobuf::io::CodedInputStream* input);
1793 void SerializeWithCachedSizes(
1794 ::google::protobuf::io::CodedOutputStream* output)
const;
1795 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
1796 bool deterministic, ::google::protobuf::uint8* output)
const;
1797 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
1798 return InternalSerializeWithCachedSizesToArray(
false, output);
1800 int GetCachedSize()
const {
return _cached_size_; }
1804 void SetCachedSize(
int size)
const;
1807 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
1808 return _internal_metadata_.arena();
1810 inline void* MaybeArenaPtr()
const {
1811 return _internal_metadata_.raw_arena_ptr();
1815 ::google::protobuf::Metadata GetMetadata()
const;
1822 bool has_hi()
const;
1824 static const int kHiFieldNumber = 1;
1825 ::google::protobuf::int64 hi()
const;
1826 void set_hi(::google::protobuf::int64 value);
1829 bool has_lo()
const;
1831 static const int kLoFieldNumber = 2;
1832 ::google::protobuf::int64 lo()
const;
1833 void set_lo(::google::protobuf::int64 value);
1837 inline void set_has_hi();
1838 inline void clear_has_hi();
1839 inline void set_has_lo();
1840 inline void clear_has_lo();
1843 int RequiredFieldsByteSizeFallback()
const;
1845 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
1846 ::google::protobuf::uint32 _has_bits_[1];
1847 mutable int _cached_size_;
1848 ::google::protobuf::int64 hi_;
1849 ::google::protobuf::int64 lo_;
1850 friend void protobuf_AddDesc_datatransfer_2eproto();
1851 friend void protobuf_AssignDesc_datatransfer_2eproto();
1852 friend void protobuf_ShutdownFile_datatransfer_2eproto();
1854 void InitAsDefaultInstance();
1871 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
1872 return _internal_metadata_.unknown_fields();
1875 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1876 return _internal_metadata_.mutable_unknown_fields();
1879 static const ::google::protobuf::Descriptor* descriptor();
1889 void CopyFrom(const ::google::protobuf::Message& from);
1890 void MergeFrom(const ::google::protobuf::Message& from);
1894 bool IsInitialized()
const;
1896 int ByteSize()
const;
1897 bool MergePartialFromCodedStream(
1898 ::google::protobuf::io::CodedInputStream* input);
1899 void SerializeWithCachedSizes(
1900 ::google::protobuf::io::CodedOutputStream* output)
const;
1901 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
1902 bool deterministic, ::google::protobuf::uint8* output)
const;
1903 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
1904 return InternalSerializeWithCachedSizesToArray(
false, output);
1906 int GetCachedSize()
const {
return _cached_size_; }
1910 void SetCachedSize(
int size)
const;
1913 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
1914 return _internal_metadata_.arena();
1916 inline void* MaybeArenaPtr()
const {
1917 return _internal_metadata_.raw_arena_ptr();
1921 ::google::protobuf::Metadata GetMetadata()
const;
1928 bool has_shmid()
const;
1930 static const int kShmIdFieldNumber = 1;
1931 const ::hadoop::hdfs::ShortCircuitShmIdProto& shmid()
const;
1937 bool has_slotidx()
const;
1938 void clear_slotidx();
1939 static const int kSlotIdxFieldNumber = 2;
1940 ::google::protobuf::int32 slotidx()
const;
1941 void set_slotidx(::google::protobuf::int32 value);
1945 inline void set_has_shmid();
1946 inline void clear_has_shmid();
1947 inline void set_has_slotidx();
1948 inline void clear_has_slotidx();
1951 int RequiredFieldsByteSizeFallback()
const;
1953 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
1954 ::google::protobuf::uint32 _has_bits_[1];
1955 mutable int _cached_size_;
1957 ::google::protobuf::int32 slotidx_;
1958 friend void protobuf_AddDesc_datatransfer_2eproto();
1959 friend void protobuf_AssignDesc_datatransfer_2eproto();
1960 friend void protobuf_ShutdownFile_datatransfer_2eproto();
1962 void InitAsDefaultInstance();
1979 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
1980 return _internal_metadata_.unknown_fields();
1983 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1984 return _internal_metadata_.mutable_unknown_fields();
1987 static const ::google::protobuf::Descriptor* descriptor();
1997 void CopyFrom(const ::google::protobuf::Message& from);
1998 void MergeFrom(const ::google::protobuf::Message& from);
2002 bool IsInitialized()
const;
2004 int ByteSize()
const;
2005 bool MergePartialFromCodedStream(
2006 ::google::protobuf::io::CodedInputStream* input);
2007 void SerializeWithCachedSizes(
2008 ::google::protobuf::io::CodedOutputStream* output)
const;
2009 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
2010 bool deterministic, ::google::protobuf::uint8* output)
const;
2011 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
2012 return InternalSerializeWithCachedSizesToArray(
false, output);
2014 int GetCachedSize()
const {
return _cached_size_; }
2018 void SetCachedSize(
int size)
const;
2021 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
2022 return _internal_metadata_.arena();
2024 inline void* MaybeArenaPtr()
const {
2025 return _internal_metadata_.raw_arena_ptr();
2029 ::google::protobuf::Metadata GetMetadata()
const;
2036 bool has_header()
const;
2037 void clear_header();
2038 static const int kHeaderFieldNumber = 1;
2039 const ::hadoop::hdfs::BaseHeaderProto& header()
const;
2045 bool has_maxversion()
const;
2046 void clear_maxversion();
2047 static const int kMaxVersionFieldNumber = 2;
2048 ::google::protobuf::uint32 maxversion()
const;
2049 void set_maxversion(::google::protobuf::uint32 value);
2052 bool has_slotid()
const;
2053 void clear_slotid();
2054 static const int kSlotIdFieldNumber = 3;
2055 const ::hadoop::hdfs::ShortCircuitShmSlotProto& slotid()
const;
2061 bool has_supportsreceiptverification()
const;
2062 void clear_supportsreceiptverification();
2063 static const int kSupportsReceiptVerificationFieldNumber = 4;
2064 bool supportsreceiptverification()
const;
2065 void set_supportsreceiptverification(
bool value);
2069 inline void set_has_header();
2070 inline void clear_has_header();
2071 inline void set_has_maxversion();
2072 inline void clear_has_maxversion();
2073 inline void set_has_slotid();
2074 inline void clear_has_slotid();
2075 inline void set_has_supportsreceiptverification();
2076 inline void clear_has_supportsreceiptverification();
2079 int RequiredFieldsByteSizeFallback()
const;
2081 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
2082 ::google::protobuf::uint32 _has_bits_[1];
2083 mutable int _cached_size_;
2086 ::google::protobuf::uint32 maxversion_;
2087 bool supportsreceiptverification_;
2088 friend void protobuf_AddDesc_datatransfer_2eproto();
2089 friend void protobuf_AssignDesc_datatransfer_2eproto();
2090 friend void protobuf_ShutdownFile_datatransfer_2eproto();
2092 void InitAsDefaultInstance();
2109 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
2110 return _internal_metadata_.unknown_fields();
2113 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
2114 return _internal_metadata_.mutable_unknown_fields();
2117 static const ::google::protobuf::Descriptor* descriptor();
2127 void CopyFrom(const ::google::protobuf::Message& from);
2128 void MergeFrom(const ::google::protobuf::Message& from);
2132 bool IsInitialized()
const;
2134 int ByteSize()
const;
2135 bool MergePartialFromCodedStream(
2136 ::google::protobuf::io::CodedInputStream* input);
2137 void SerializeWithCachedSizes(
2138 ::google::protobuf::io::CodedOutputStream* output)
const;
2139 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
2140 bool deterministic, ::google::protobuf::uint8* output)
const;
2141 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
2142 return InternalSerializeWithCachedSizesToArray(
false, output);
2144 int GetCachedSize()
const {
return _cached_size_; }
2148 void SetCachedSize(
int size)
const;
2151 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
2152 return _internal_metadata_.arena();
2154 inline void* MaybeArenaPtr()
const {
2155 return _internal_metadata_.raw_arena_ptr();
2159 ::google::protobuf::Metadata GetMetadata()
const;
2166 bool has_slotid()
const;
2167 void clear_slotid();
2168 static const int kSlotIdFieldNumber = 1;
2169 const ::hadoop::hdfs::ShortCircuitShmSlotProto& slotid()
const;
2175 bool has_traceinfo()
const;
2176 void clear_traceinfo();
2177 static const int kTraceInfoFieldNumber = 2;
2178 const ::hadoop::hdfs::DataTransferTraceInfoProto& traceinfo()
const;
2185 inline void set_has_slotid();
2186 inline void clear_has_slotid();
2187 inline void set_has_traceinfo();
2188 inline void clear_has_traceinfo();
2190 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
2191 ::google::protobuf::uint32 _has_bits_[1];
2192 mutable int _cached_size_;
2195 friend void protobuf_AddDesc_datatransfer_2eproto();
2196 friend void protobuf_AssignDesc_datatransfer_2eproto();
2197 friend void protobuf_ShutdownFile_datatransfer_2eproto();
2199 void InitAsDefaultInstance();
2216 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
2217 return _internal_metadata_.unknown_fields();
2220 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
2221 return _internal_metadata_.mutable_unknown_fields();
2224 static const ::google::protobuf::Descriptor* descriptor();
2234 void CopyFrom(const ::google::protobuf::Message& from);
2235 void MergeFrom(const ::google::protobuf::Message& from);
2239 bool IsInitialized()
const;
2241 int ByteSize()
const;
2242 bool MergePartialFromCodedStream(
2243 ::google::protobuf::io::CodedInputStream* input);
2244 void SerializeWithCachedSizes(
2245 ::google::protobuf::io::CodedOutputStream* output)
const;
2246 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
2247 bool deterministic, ::google::protobuf::uint8* output)
const;
2248 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
2249 return InternalSerializeWithCachedSizesToArray(
false, output);
2251 int GetCachedSize()
const {
return _cached_size_; }
2255 void SetCachedSize(
int size)
const;
2258 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
2259 return _internal_metadata_.arena();
2261 inline void* MaybeArenaPtr()
const {
2262 return _internal_metadata_.raw_arena_ptr();
2266 ::google::protobuf::Metadata GetMetadata()
const;
2273 bool has_status()
const;
2274 void clear_status();
2275 static const int kStatusFieldNumber = 1;
2276 ::hadoop::hdfs::Status status()
const;
2277 void set_status(::hadoop::hdfs::Status value);
2280 bool has_error()
const;
2282 static const int kErrorFieldNumber = 2;
2283 const ::std::string& error()
const;
2284 void set_error(const ::std::string& value);
2285 void set_error(
const char* value);
2286 void set_error(
const char* value,
size_t size);
2287 ::std::string* mutable_error();
2288 ::std::string* release_error();
2289 void set_allocated_error(::std::string* error);
2293 inline void set_has_status();
2294 inline void clear_has_status();
2295 inline void set_has_error();
2296 inline void clear_has_error();
2298 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
2299 ::google::protobuf::uint32 _has_bits_[1];
2300 mutable int _cached_size_;
2301 ::google::protobuf::internal::ArenaStringPtr error_;
2303 friend void protobuf_AddDesc_datatransfer_2eproto();
2304 friend void protobuf_AssignDesc_datatransfer_2eproto();
2305 friend void protobuf_ShutdownFile_datatransfer_2eproto();
2307 void InitAsDefaultInstance();
2324 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
2325 return _internal_metadata_.unknown_fields();
2328 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
2329 return _internal_metadata_.mutable_unknown_fields();
2332 static const ::google::protobuf::Descriptor* descriptor();
2342 void CopyFrom(const ::google::protobuf::Message& from);
2343 void MergeFrom(const ::google::protobuf::Message& from);
2347 bool IsInitialized()
const;
2349 int ByteSize()
const;
2350 bool MergePartialFromCodedStream(
2351 ::google::protobuf::io::CodedInputStream* input);
2352 void SerializeWithCachedSizes(
2353 ::google::protobuf::io::CodedOutputStream* output)
const;
2354 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
2355 bool deterministic, ::google::protobuf::uint8* output)
const;
2356 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
2357 return InternalSerializeWithCachedSizesToArray(
false, output);
2359 int GetCachedSize()
const {
return _cached_size_; }
2363 void SetCachedSize(
int size)
const;
2366 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
2367 return _internal_metadata_.arena();
2369 inline void* MaybeArenaPtr()
const {
2370 return _internal_metadata_.raw_arena_ptr();
2374 ::google::protobuf::Metadata GetMetadata()
const;
2381 bool has_clientname()
const;
2382 void clear_clientname();
2383 static const int kClientNameFieldNumber = 1;
2384 const ::std::string& clientname()
const;
2385 void set_clientname(const ::std::string& value);
2386 void set_clientname(
const char* value);
2387 void set_clientname(
const char* value,
size_t size);
2388 ::std::string* mutable_clientname();
2389 ::std::string* release_clientname();
2390 void set_allocated_clientname(::std::string* clientname);
2393 bool has_traceinfo()
const;
2394 void clear_traceinfo();
2395 static const int kTraceInfoFieldNumber = 2;
2396 const ::hadoop::hdfs::DataTransferTraceInfoProto& traceinfo()
const;
2403 inline void set_has_clientname();
2404 inline void clear_has_clientname();
2405 inline void set_has_traceinfo();
2406 inline void clear_has_traceinfo();
2408 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
2409 ::google::protobuf::uint32 _has_bits_[1];
2410 mutable int _cached_size_;
2411 ::google::protobuf::internal::ArenaStringPtr clientname_;
2413 friend void protobuf_AddDesc_datatransfer_2eproto();
2414 friend void protobuf_AssignDesc_datatransfer_2eproto();
2415 friend void protobuf_ShutdownFile_datatransfer_2eproto();
2417 void InitAsDefaultInstance();
2434 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
2435 return _internal_metadata_.unknown_fields();
2438 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
2439 return _internal_metadata_.mutable_unknown_fields();
2442 static const ::google::protobuf::Descriptor* descriptor();
2452 void CopyFrom(const ::google::protobuf::Message& from);
2453 void MergeFrom(const ::google::protobuf::Message& from);
2457 bool IsInitialized()
const;
2459 int ByteSize()
const;
2460 bool MergePartialFromCodedStream(
2461 ::google::protobuf::io::CodedInputStream* input);
2462 void SerializeWithCachedSizes(
2463 ::google::protobuf::io::CodedOutputStream* output)
const;
2464 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
2465 bool deterministic, ::google::protobuf::uint8* output)
const;
2466 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
2467 return InternalSerializeWithCachedSizesToArray(
false, output);
2469 int GetCachedSize()
const {
return _cached_size_; }
2473 void SetCachedSize(
int size)
const;
2476 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
2477 return _internal_metadata_.arena();
2479 inline void* MaybeArenaPtr()
const {
2480 return _internal_metadata_.raw_arena_ptr();
2484 ::google::protobuf::Metadata GetMetadata()
const;
2491 bool has_status()
const;
2492 void clear_status();
2493 static const int kStatusFieldNumber = 1;
2494 ::hadoop::hdfs::Status status()
const;
2495 void set_status(::hadoop::hdfs::Status value);
2498 bool has_error()
const;
2500 static const int kErrorFieldNumber = 2;
2501 const ::std::string& error()
const;
2502 void set_error(const ::std::string& value);
2503 void set_error(
const char* value);
2504 void set_error(
const char* value,
size_t size);
2505 ::std::string* mutable_error();
2506 ::std::string* release_error();
2507 void set_allocated_error(::std::string* error);
2510 bool has_id()
const;
2512 static const int kIdFieldNumber = 3;
2513 const ::hadoop::hdfs::ShortCircuitShmIdProto& id()
const;
2520 inline void set_has_status();
2521 inline void clear_has_status();
2522 inline void set_has_error();
2523 inline void clear_has_error();
2524 inline void set_has_id();
2525 inline void clear_has_id();
2527 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
2528 ::google::protobuf::uint32 _has_bits_[1];
2529 mutable int _cached_size_;
2530 ::google::protobuf::internal::ArenaStringPtr error_;
2533 friend void protobuf_AddDesc_datatransfer_2eproto();
2534 friend void protobuf_AssignDesc_datatransfer_2eproto();
2535 friend void protobuf_ShutdownFile_datatransfer_2eproto();
2537 void InitAsDefaultInstance();
2554 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
2555 return _internal_metadata_.unknown_fields();
2558 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
2559 return _internal_metadata_.mutable_unknown_fields();
2562 static const ::google::protobuf::Descriptor* descriptor();
2572 void CopyFrom(const ::google::protobuf::Message& from);
2573 void MergeFrom(const ::google::protobuf::Message& from);
2577 bool IsInitialized()
const;
2579 int ByteSize()
const;
2580 bool MergePartialFromCodedStream(
2581 ::google::protobuf::io::CodedInputStream* input);
2582 void SerializeWithCachedSizes(
2583 ::google::protobuf::io::CodedOutputStream* output)
const;
2584 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
2585 bool deterministic, ::google::protobuf::uint8* output)
const;
2586 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
2587 return InternalSerializeWithCachedSizesToArray(
false, output);
2589 int GetCachedSize()
const {
return _cached_size_; }
2593 void SetCachedSize(
int size)
const;
2596 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
2597 return _internal_metadata_.arena();
2599 inline void* MaybeArenaPtr()
const {
2600 return _internal_metadata_.raw_arena_ptr();
2604 ::google::protobuf::Metadata GetMetadata()
const;
2611 bool has_offsetinblock()
const;
2612 void clear_offsetinblock();
2613 static const int kOffsetInBlockFieldNumber = 1;
2614 ::google::protobuf::int64 offsetinblock()
const;
2615 void set_offsetinblock(::google::protobuf::int64 value);
2618 bool has_seqno()
const;
2620 static const int kSeqnoFieldNumber = 2;
2621 ::google::protobuf::int64 seqno()
const;
2622 void set_seqno(::google::protobuf::int64 value);
2625 bool has_lastpacketinblock()
const;
2626 void clear_lastpacketinblock();
2627 static const int kLastPacketInBlockFieldNumber = 3;
2628 bool lastpacketinblock()
const;
2629 void set_lastpacketinblock(
bool value);
2632 bool has_datalen()
const;
2633 void clear_datalen();
2634 static const int kDataLenFieldNumber = 4;
2635 ::google::protobuf::int32 datalen()
const;
2636 void set_datalen(::google::protobuf::int32 value);
2639 bool has_syncblock()
const;
2640 void clear_syncblock();
2641 static const int kSyncBlockFieldNumber = 5;
2642 bool syncblock()
const;
2643 void set_syncblock(
bool value);
2647 inline void set_has_offsetinblock();
2648 inline void clear_has_offsetinblock();
2649 inline void set_has_seqno();
2650 inline void clear_has_seqno();
2651 inline void set_has_lastpacketinblock();
2652 inline void clear_has_lastpacketinblock();
2653 inline void set_has_datalen();
2654 inline void clear_has_datalen();
2655 inline void set_has_syncblock();
2656 inline void clear_has_syncblock();
2659 int RequiredFieldsByteSizeFallback()
const;
2661 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
2662 ::google::protobuf::uint32 _has_bits_[1];
2663 mutable int _cached_size_;
2664 ::google::protobuf::int64 offsetinblock_;
2665 ::google::protobuf::int64 seqno_;
2666 ::google::protobuf::int32 datalen_;
2667 bool lastpacketinblock_;
2669 friend void protobuf_AddDesc_datatransfer_2eproto();
2670 friend void protobuf_AssignDesc_datatransfer_2eproto();
2671 friend void protobuf_ShutdownFile_datatransfer_2eproto();
2673 void InitAsDefaultInstance();
2690 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
2691 return _internal_metadata_.unknown_fields();
2694 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
2695 return _internal_metadata_.mutable_unknown_fields();
2698 static const ::google::protobuf::Descriptor* descriptor();
2708 void CopyFrom(const ::google::protobuf::Message& from);
2709 void MergeFrom(const ::google::protobuf::Message& from);
2713 bool IsInitialized()
const;
2715 int ByteSize()
const;
2716 bool MergePartialFromCodedStream(
2717 ::google::protobuf::io::CodedInputStream* input);
2718 void SerializeWithCachedSizes(
2719 ::google::protobuf::io::CodedOutputStream* output)
const;
2720 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
2721 bool deterministic, ::google::protobuf::uint8* output)
const;
2722 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
2723 return InternalSerializeWithCachedSizesToArray(
false, output);
2725 int GetCachedSize()
const {
return _cached_size_; }
2729 void SetCachedSize(
int size)
const;
2732 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
2733 return _internal_metadata_.arena();
2735 inline void* MaybeArenaPtr()
const {
2736 return _internal_metadata_.raw_arena_ptr();
2740 ::google::protobuf::Metadata GetMetadata()
const;
2747 bool has_seqno()
const;
2749 static const int kSeqnoFieldNumber = 1;
2750 ::google::protobuf::int64 seqno()
const;
2751 void set_seqno(::google::protobuf::int64 value);
2754 int reply_size()
const;
2756 static const int kReplyFieldNumber = 2;
2757 ::hadoop::hdfs::Status reply(
int index)
const;
2758 void set_reply(
int index, ::hadoop::hdfs::Status value);
2759 void add_reply(::hadoop::hdfs::Status value);
2760 const ::google::protobuf::RepeatedField<int>& reply()
const;
2761 ::google::protobuf::RepeatedField<int>* mutable_reply();
2764 bool has_downstreamacktimenanos()
const;
2765 void clear_downstreamacktimenanos();
2766 static const int kDownstreamAckTimeNanosFieldNumber = 3;
2767 ::google::protobuf::uint64 downstreamacktimenanos()
const;
2768 void set_downstreamacktimenanos(::google::protobuf::uint64 value);
2771 int flag_size()
const;
2773 static const int kFlagFieldNumber = 4;
2774 ::google::protobuf::uint32 flag(
int index)
const;
2775 void set_flag(
int index, ::google::protobuf::uint32 value);
2776 void add_flag(::google::protobuf::uint32 value);
2777 const ::google::protobuf::RepeatedField< ::google::protobuf::uint32 >&
2779 ::google::protobuf::RepeatedField< ::google::protobuf::uint32 >*
2784 inline void set_has_seqno();
2785 inline void clear_has_seqno();
2786 inline void set_has_downstreamacktimenanos();
2787 inline void clear_has_downstreamacktimenanos();
2789 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
2790 ::google::protobuf::uint32 _has_bits_[1];
2791 mutable int _cached_size_;
2792 ::google::protobuf::int64 seqno_;
2793 ::google::protobuf::RepeatedField<int> reply_;
2794 ::google::protobuf::uint64 downstreamacktimenanos_;
2795 ::google::protobuf::RepeatedField< ::google::protobuf::uint32 > flag_;
2796 mutable int _flag_cached_byte_size_;
2797 friend void protobuf_AddDesc_datatransfer_2eproto();
2798 friend void protobuf_AssignDesc_datatransfer_2eproto();
2799 friend void protobuf_ShutdownFile_datatransfer_2eproto();
2801 void InitAsDefaultInstance();
2818 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
2819 return _internal_metadata_.unknown_fields();
2822 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
2823 return _internal_metadata_.mutable_unknown_fields();
2826 static const ::google::protobuf::Descriptor* descriptor();
2836 void CopyFrom(const ::google::protobuf::Message& from);
2837 void MergeFrom(const ::google::protobuf::Message& from);
2841 bool IsInitialized()
const;
2843 int ByteSize()
const;
2844 bool MergePartialFromCodedStream(
2845 ::google::protobuf::io::CodedInputStream* input);
2846 void SerializeWithCachedSizes(
2847 ::google::protobuf::io::CodedOutputStream* output)
const;
2848 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
2849 bool deterministic, ::google::protobuf::uint8* output)
const;
2850 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
2851 return InternalSerializeWithCachedSizesToArray(
false, output);
2853 int GetCachedSize()
const {
return _cached_size_; }
2857 void SetCachedSize(
int size)
const;
2860 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
2861 return _internal_metadata_.arena();
2863 inline void* MaybeArenaPtr()
const {
2864 return _internal_metadata_.raw_arena_ptr();
2868 ::google::protobuf::Metadata GetMetadata()
const;
2875 bool has_checksum()
const;
2876 void clear_checksum();
2877 static const int kChecksumFieldNumber = 1;
2878 const ::hadoop::hdfs::ChecksumProto& checksum()
const;
2884 bool has_chunkoffset()
const;
2885 void clear_chunkoffset();
2886 static const int kChunkOffsetFieldNumber = 2;
2887 ::google::protobuf::uint64 chunkoffset()
const;
2888 void set_chunkoffset(::google::protobuf::uint64 value);
2892 inline void set_has_checksum();
2893 inline void clear_has_checksum();
2894 inline void set_has_chunkoffset();
2895 inline void clear_has_chunkoffset();
2898 int RequiredFieldsByteSizeFallback()
const;
2900 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
2901 ::google::protobuf::uint32 _has_bits_[1];
2902 mutable int _cached_size_;
2904 ::google::protobuf::uint64 chunkoffset_;
2905 friend void protobuf_AddDesc_datatransfer_2eproto();
2906 friend void protobuf_AssignDesc_datatransfer_2eproto();
2907 friend void protobuf_ShutdownFile_datatransfer_2eproto();
2909 void InitAsDefaultInstance();
2926 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
2927 return _internal_metadata_.unknown_fields();
2930 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
2931 return _internal_metadata_.mutable_unknown_fields();
2934 static const ::google::protobuf::Descriptor* descriptor();
2944 void CopyFrom(const ::google::protobuf::Message& from);
2945 void MergeFrom(const ::google::protobuf::Message& from);
2949 bool IsInitialized()
const;
2951 int ByteSize()
const;
2952 bool MergePartialFromCodedStream(
2953 ::google::protobuf::io::CodedInputStream* input);
2954 void SerializeWithCachedSizes(
2955 ::google::protobuf::io::CodedOutputStream* output)
const;
2956 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
2957 bool deterministic, ::google::protobuf::uint8* output)
const;
2958 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
2959 return InternalSerializeWithCachedSizesToArray(
false, output);
2961 int GetCachedSize()
const {
return _cached_size_; }
2965 void SetCachedSize(
int size)
const;
2968 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
2969 return _internal_metadata_.arena();
2971 inline void* MaybeArenaPtr()
const {
2972 return _internal_metadata_.raw_arena_ptr();
2976 ::google::protobuf::Metadata GetMetadata()
const;
2983 bool has_status()
const;
2984 void clear_status();
2985 static const int kStatusFieldNumber = 1;
2986 ::hadoop::hdfs::Status status()
const;
2987 void set_status(::hadoop::hdfs::Status value);
2990 bool has_firstbadlink()
const;
2991 void clear_firstbadlink();
2992 static const int kFirstBadLinkFieldNumber = 2;
2993 const ::std::string& firstbadlink()
const;
2994 void set_firstbadlink(const ::std::string& value);
2995 void set_firstbadlink(
const char* value);
2996 void set_firstbadlink(
const char* value,
size_t size);
2997 ::std::string* mutable_firstbadlink();
2998 ::std::string* release_firstbadlink();
2999 void set_allocated_firstbadlink(::std::string* firstbadlink);
3002 bool has_checksumresponse()
const;
3003 void clear_checksumresponse();
3004 static const int kChecksumResponseFieldNumber = 3;
3005 const ::hadoop::hdfs::OpBlockChecksumResponseProto& checksumresponse()
const;
3011 bool has_readopchecksuminfo()
const;
3012 void clear_readopchecksuminfo();
3013 static const int kReadOpChecksumInfoFieldNumber = 4;
3014 const ::hadoop::hdfs::ReadOpChecksumInfoProto& readopchecksuminfo()
const;
3020 bool has_message()
const;
3021 void clear_message();
3022 static const int kMessageFieldNumber = 5;
3023 const ::std::string& message()
const;
3024 void set_message(const ::std::string& value);
3025 void set_message(
const char* value);
3026 void set_message(
const char* value,
size_t size);
3027 ::std::string* mutable_message();
3028 ::std::string* release_message();
3029 void set_allocated_message(::std::string* message);
3032 bool has_shortcircuitaccessversion()
const;
3033 void clear_shortcircuitaccessversion();
3034 static const int kShortCircuitAccessVersionFieldNumber = 6;
3035 ::google::protobuf::uint32 shortcircuitaccessversion()
const;
3036 void set_shortcircuitaccessversion(::google::protobuf::uint32 value);
3040 inline void set_has_status();
3041 inline void clear_has_status();
3042 inline void set_has_firstbadlink();
3043 inline void clear_has_firstbadlink();
3044 inline void set_has_checksumresponse();
3045 inline void clear_has_checksumresponse();
3046 inline void set_has_readopchecksuminfo();
3047 inline void clear_has_readopchecksuminfo();
3048 inline void set_has_message();
3049 inline void clear_has_message();
3050 inline void set_has_shortcircuitaccessversion();
3051 inline void clear_has_shortcircuitaccessversion();
3053 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
3054 ::google::protobuf::uint32 _has_bits_[1];
3055 mutable int _cached_size_;
3056 ::google::protobuf::internal::ArenaStringPtr firstbadlink_;
3059 ::google::protobuf::uint32 shortcircuitaccessversion_;
3061 ::google::protobuf::internal::ArenaStringPtr message_;
3062 friend void protobuf_AddDesc_datatransfer_2eproto();
3063 friend void protobuf_AssignDesc_datatransfer_2eproto();
3064 friend void protobuf_ShutdownFile_datatransfer_2eproto();
3066 void InitAsDefaultInstance();
3083 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
3084 return _internal_metadata_.unknown_fields();
3087 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
3088 return _internal_metadata_.mutable_unknown_fields();
3091 static const ::google::protobuf::Descriptor* descriptor();
3101 void CopyFrom(const ::google::protobuf::Message& from);
3102 void MergeFrom(const ::google::protobuf::Message& from);
3106 bool IsInitialized()
const;
3108 int ByteSize()
const;
3109 bool MergePartialFromCodedStream(
3110 ::google::protobuf::io::CodedInputStream* input);
3111 void SerializeWithCachedSizes(
3112 ::google::protobuf::io::CodedOutputStream* output)
const;
3113 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
3114 bool deterministic, ::google::protobuf::uint8* output)
const;
3115 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
3116 return InternalSerializeWithCachedSizesToArray(
false, output);
3118 int GetCachedSize()
const {
return _cached_size_; }
3122 void SetCachedSize(
int size)
const;
3125 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
3126 return _internal_metadata_.arena();
3128 inline void* MaybeArenaPtr()
const {
3129 return _internal_metadata_.raw_arena_ptr();
3133 ::google::protobuf::Metadata GetMetadata()
const;
3140 bool has_status()
const;
3141 void clear_status();
3142 static const int kStatusFieldNumber = 1;
3143 ::hadoop::hdfs::Status status()
const;
3144 void set_status(::hadoop::hdfs::Status value);
3148 inline void set_has_status();
3149 inline void clear_has_status();
3151 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
3152 ::google::protobuf::uint32 _has_bits_[1];
3153 mutable int _cached_size_;
3155 friend void protobuf_AddDesc_datatransfer_2eproto();
3156 friend void protobuf_AssignDesc_datatransfer_2eproto();
3157 friend void protobuf_ShutdownFile_datatransfer_2eproto();
3159 void InitAsDefaultInstance();
3176 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
3177 return _internal_metadata_.unknown_fields();
3180 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
3181 return _internal_metadata_.mutable_unknown_fields();
3184 static const ::google::protobuf::Descriptor* descriptor();
3194 void CopyFrom(const ::google::protobuf::Message& from);
3195 void MergeFrom(const ::google::protobuf::Message& from);
3199 bool IsInitialized()
const;
3201 int ByteSize()
const;
3202 bool MergePartialFromCodedStream(
3203 ::google::protobuf::io::CodedInputStream* input);
3204 void SerializeWithCachedSizes(
3205 ::google::protobuf::io::CodedOutputStream* output)
const;
3206 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
3207 bool deterministic, ::google::protobuf::uint8* output)
const;
3208 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
3209 return InternalSerializeWithCachedSizesToArray(
false, output);
3211 int GetCachedSize()
const {
return _cached_size_; }
3215 void SetCachedSize(
int size)
const;
3218 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
3219 return _internal_metadata_.arena();
3221 inline void* MaybeArenaPtr()
const {
3222 return _internal_metadata_.raw_arena_ptr();
3226 ::google::protobuf::Metadata GetMetadata()
const;
3233 bool has_status()
const;
3234 void clear_status();
3235 static const int kStatusFieldNumber = 1;
3236 ::hadoop::hdfs::Status status()
const;
3237 void set_status(::hadoop::hdfs::Status value);
3241 inline void set_has_status();
3242 inline void clear_has_status();
3244 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
3245 ::google::protobuf::uint32 _has_bits_[1];
3246 mutable int _cached_size_;
3248 friend void protobuf_AddDesc_datatransfer_2eproto();
3249 friend void protobuf_AssignDesc_datatransfer_2eproto();
3250 friend void protobuf_ShutdownFile_datatransfer_2eproto();
3252 void InitAsDefaultInstance();
3269 inline const ::google::protobuf::UnknownFieldSet& unknown_fields()
const {
3270 return _internal_metadata_.unknown_fields();
3273 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
3274 return _internal_metadata_.mutable_unknown_fields();
3277 static const ::google::protobuf::Descriptor* descriptor();
3287 void CopyFrom(const ::google::protobuf::Message& from);
3288 void MergeFrom(const ::google::protobuf::Message& from);
3292 bool IsInitialized()
const;
3294 int ByteSize()
const;
3295 bool MergePartialFromCodedStream(
3296 ::google::protobuf::io::CodedInputStream* input);
3297 void SerializeWithCachedSizes(
3298 ::google::protobuf::io::CodedOutputStream* output)
const;
3299 ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(
3300 bool deterministic, ::google::protobuf::uint8* output)
const;
3301 ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const {
3302 return InternalSerializeWithCachedSizesToArray(
false, output);
3304 int GetCachedSize()
const {
return _cached_size_; }
3308 void SetCachedSize(
int size)
const;
3311 inline ::google::protobuf::Arena* GetArenaNoVirtual()
const {
3312 return _internal_metadata_.arena();
3314 inline void* MaybeArenaPtr()
const {
3315 return _internal_metadata_.raw_arena_ptr();
3319 ::google::protobuf::Metadata GetMetadata()
const;
3326 bool has_bytespercrc()
const;
3327 void clear_bytespercrc();
3328 static const int kBytesPerCrcFieldNumber = 1;
3329 ::google::protobuf::uint32 bytespercrc()
const;
3330 void set_bytespercrc(::google::protobuf::uint32 value);
3333 bool has_crcperblock()
const;
3334 void clear_crcperblock();
3335 static const int kCrcPerBlockFieldNumber = 2;
3336 ::google::protobuf::uint64 crcperblock()
const;
3337 void set_crcperblock(::google::protobuf::uint64 value);
3340 bool has_md5()
const;
3342 static const int kMd5FieldNumber = 3;
3343 const ::std::string& md5()
const;
3344 void set_md5(const ::std::string& value);
3345 void set_md5(
const char* value);
3346 void set_md5(
const void* value,
size_t size);
3347 ::std::string* mutable_md5();
3348 ::std::string* release_md5();
3349 void set_allocated_md5(::std::string* md5);
3352 bool has_crctype()
const;
3353 void clear_crctype();
3354 static const int kCrcTypeFieldNumber = 4;
3355 ::hadoop::hdfs::ChecksumTypeProto crctype()
const;
3356 void set_crctype(::hadoop::hdfs::ChecksumTypeProto value);
3360 inline void set_has_bytespercrc();
3361 inline void clear_has_bytespercrc();
3362 inline void set_has_crcperblock();
3363 inline void clear_has_crcperblock();
3364 inline void set_has_md5();
3365 inline void clear_has_md5();
3366 inline void set_has_crctype();
3367 inline void clear_has_crctype();
3370 int RequiredFieldsByteSizeFallback()
const;
3372 ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;
3373 ::google::protobuf::uint32 _has_bits_[1];
3374 mutable int _cached_size_;
3375 ::google::protobuf::uint64 crcperblock_;
3376 ::google::protobuf::uint32 bytespercrc_;
3378 ::google::protobuf::internal::ArenaStringPtr md5_;
3379 friend void protobuf_AddDesc_datatransfer_2eproto();
3380 friend void protobuf_AssignDesc_datatransfer_2eproto();
3381 friend void protobuf_ShutdownFile_datatransfer_2eproto();
3383 void InitAsDefaultInstance();
3391 #if !PROTOBUF_INLINE_NOT_IN_HEADERS
3395 inline bool DataTransferEncryptorMessageProto::has_status()
const {
3396 return (_has_bits_[0] & 0x00000001u) != 0;
3398 inline void DataTransferEncryptorMessageProto::set_has_status() {
3399 _has_bits_[0] |= 0x00000001u;
3401 inline void DataTransferEncryptorMessageProto::clear_has_status() {
3402 _has_bits_[0] &= ~0x00000001u;
3404 inline void DataTransferEncryptorMessageProto::clear_status() {
3408 inline ::hadoop::hdfs::DataTransferEncryptorMessageProto_DataTransferEncryptorStatus DataTransferEncryptorMessageProto::status()
const {
3410 return static_cast< ::hadoop::hdfs::DataTransferEncryptorMessageProto_DataTransferEncryptorStatus
>(status_);
3412 inline void DataTransferEncryptorMessageProto::set_status(::hadoop::hdfs::DataTransferEncryptorMessageProto_DataTransferEncryptorStatus value) {
3413 assert(::hadoop::hdfs::DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_IsValid(value));
3420 inline bool DataTransferEncryptorMessageProto::has_payload()
const {
3421 return (_has_bits_[0] & 0x00000002u) != 0;
3423 inline void DataTransferEncryptorMessageProto::set_has_payload() {
3424 _has_bits_[0] |= 0x00000002u;
3426 inline void DataTransferEncryptorMessageProto::clear_has_payload() {
3427 _has_bits_[0] &= ~0x00000002u;
3429 inline void DataTransferEncryptorMessageProto::clear_payload() {
3430 payload_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
3431 clear_has_payload();
3433 inline const ::std::string& DataTransferEncryptorMessageProto::payload()
const {
3435 return payload_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
3437 inline void DataTransferEncryptorMessageProto::set_payload(const ::std::string& value) {
3439 payload_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
3442 inline void DataTransferEncryptorMessageProto::set_payload(
const char* value) {
3444 payload_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
3447 inline void DataTransferEncryptorMessageProto::set_payload(
const void* value,
size_t size) {
3449 payload_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
3450 ::std::string(reinterpret_cast<const char*>(value), size));
3453 inline ::std::string* DataTransferEncryptorMessageProto::mutable_payload() {
3456 return payload_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
3458 inline ::std::string* DataTransferEncryptorMessageProto::release_payload() {
3460 clear_has_payload();
3461 return payload_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
3463 inline void DataTransferEncryptorMessageProto::set_allocated_payload(::std::string* payload) {
3464 if (payload != NULL) {
3467 clear_has_payload();
3469 payload_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), payload);
3474 inline bool DataTransferEncryptorMessageProto::has_message()
const {
3475 return (_has_bits_[0] & 0x00000004u) != 0;
3477 inline void DataTransferEncryptorMessageProto::set_has_message() {
3478 _has_bits_[0] |= 0x00000004u;
3480 inline void DataTransferEncryptorMessageProto::clear_has_message() {
3481 _has_bits_[0] &= ~0x00000004u;
3483 inline void DataTransferEncryptorMessageProto::clear_message() {
3484 message_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
3485 clear_has_message();
3487 inline const ::std::string& DataTransferEncryptorMessageProto::message()
const {
3489 return message_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
3491 inline void DataTransferEncryptorMessageProto::set_message(const ::std::string& value) {
3493 message_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
3496 inline void DataTransferEncryptorMessageProto::set_message(
const char* value) {
3498 message_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
3501 inline void DataTransferEncryptorMessageProto::set_message(
const char* value,
size_t size) {
3503 message_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
3504 ::std::string(reinterpret_cast<const char*>(value), size));
3507 inline ::std::string* DataTransferEncryptorMessageProto::mutable_message() {
3510 return message_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
3512 inline ::std::string* DataTransferEncryptorMessageProto::release_message() {
3514 clear_has_message();
3515 return message_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
3517 inline void DataTransferEncryptorMessageProto::set_allocated_message(::std::string* message) {
3518 if (message != NULL) {
3521 clear_has_message();
3523 message_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), message);
3528 inline int DataTransferEncryptorMessageProto::cipheroption_size()
const {
3529 return cipheroption_.size();
3531 inline void DataTransferEncryptorMessageProto::clear_cipheroption() {
3532 cipheroption_.Clear();
3534 inline const ::hadoop::hdfs::CipherOptionProto& DataTransferEncryptorMessageProto::cipheroption(
int index)
const {
3536 return cipheroption_.Get(index);
3538 inline ::hadoop::hdfs::CipherOptionProto* DataTransferEncryptorMessageProto::mutable_cipheroption(
int index) {
3540 return cipheroption_.Mutable(index);
3542 inline ::hadoop::hdfs::CipherOptionProto* DataTransferEncryptorMessageProto::add_cipheroption() {
3544 return cipheroption_.Add();
3546 inline ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::CipherOptionProto >*
3547 DataTransferEncryptorMessageProto::mutable_cipheroption() {
3549 return &cipheroption_;
3551 inline const ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::CipherOptionProto >&
3552 DataTransferEncryptorMessageProto::cipheroption()
const {
3554 return cipheroption_;
3562 inline bool BaseHeaderProto::has_block()
const {
3563 return (_has_bits_[0] & 0x00000001u) != 0;
3565 inline void BaseHeaderProto::set_has_block() {
3566 _has_bits_[0] |= 0x00000001u;
3568 inline void BaseHeaderProto::clear_has_block() {
3569 _has_bits_[0] &= ~0x00000001u;
3571 inline void BaseHeaderProto::clear_block() {
3572 if (block_ != NULL) block_->::hadoop::hdfs::ExtendedBlockProto::Clear();
3575 inline const ::hadoop::hdfs::ExtendedBlockProto& BaseHeaderProto::block()
const {
3577 return block_ != NULL ? *block_ : *default_instance_->block_;
3579 inline ::hadoop::hdfs::ExtendedBlockProto* BaseHeaderProto::mutable_block() {
3581 if (block_ == NULL) {
3582 block_ = new ::hadoop::hdfs::ExtendedBlockProto;
3587 inline ::hadoop::hdfs::ExtendedBlockProto* BaseHeaderProto::release_block() {
3606 inline bool BaseHeaderProto::has_token()
const {
3607 return (_has_bits_[0] & 0x00000002u) != 0;
3609 inline void BaseHeaderProto::set_has_token() {
3610 _has_bits_[0] |= 0x00000002u;
3612 inline void BaseHeaderProto::clear_has_token() {
3613 _has_bits_[0] &= ~0x00000002u;
3615 inline void BaseHeaderProto::clear_token() {
3616 if (token_ != NULL) token_->::hadoop::common::TokenProto::Clear();
3619 inline const ::hadoop::common::TokenProto& BaseHeaderProto::token()
const {
3621 return token_ != NULL ? *token_ : *default_instance_->token_;
3623 inline ::hadoop::common::TokenProto* BaseHeaderProto::mutable_token() {
3625 if (token_ == NULL) {
3626 token_ = new ::hadoop::common::TokenProto;
3631 inline ::hadoop::common::TokenProto* BaseHeaderProto::release_token() {
3650 inline bool BaseHeaderProto::has_traceinfo()
const {
3651 return (_has_bits_[0] & 0x00000004u) != 0;
3653 inline void BaseHeaderProto::set_has_traceinfo() {
3654 _has_bits_[0] |= 0x00000004u;
3656 inline void BaseHeaderProto::clear_has_traceinfo() {
3657 _has_bits_[0] &= ~0x00000004u;
3659 inline void BaseHeaderProto::clear_traceinfo() {
3660 if (traceinfo_ != NULL) traceinfo_->::hadoop::hdfs::DataTransferTraceInfoProto::Clear();
3661 clear_has_traceinfo();
3663 inline const ::hadoop::hdfs::DataTransferTraceInfoProto& BaseHeaderProto::traceinfo()
const {
3665 return traceinfo_ != NULL ? *traceinfo_ : *default_instance_->traceinfo_;
3667 inline ::hadoop::hdfs::DataTransferTraceInfoProto* BaseHeaderProto::mutable_traceinfo() {
3668 set_has_traceinfo();
3669 if (traceinfo_ == NULL) {
3670 traceinfo_ = new ::hadoop::hdfs::DataTransferTraceInfoProto;
3675 inline ::hadoop::hdfs::DataTransferTraceInfoProto* BaseHeaderProto::release_traceinfo() {
3677 clear_has_traceinfo();
3684 traceinfo_ = traceinfo;
3686 set_has_traceinfo();
3688 clear_has_traceinfo();
3698 inline bool DataTransferTraceInfoProto::has_traceid()
const {
3699 return (_has_bits_[0] & 0x00000001u) != 0;
3701 inline void DataTransferTraceInfoProto::set_has_traceid() {
3702 _has_bits_[0] |= 0x00000001u;
3704 inline void DataTransferTraceInfoProto::clear_has_traceid() {
3705 _has_bits_[0] &= ~0x00000001u;
3707 inline void DataTransferTraceInfoProto::clear_traceid() {
3708 traceid_ = GOOGLE_ULONGLONG(0);
3709 clear_has_traceid();
3711 inline ::google::protobuf::uint64 DataTransferTraceInfoProto::traceid()
const {
3715 inline void DataTransferTraceInfoProto::set_traceid(::google::protobuf::uint64 value) {
3722 inline bool DataTransferTraceInfoProto::has_parentid()
const {
3723 return (_has_bits_[0] & 0x00000002u) != 0;
3725 inline void DataTransferTraceInfoProto::set_has_parentid() {
3726 _has_bits_[0] |= 0x00000002u;
3728 inline void DataTransferTraceInfoProto::clear_has_parentid() {
3729 _has_bits_[0] &= ~0x00000002u;
3731 inline void DataTransferTraceInfoProto::clear_parentid() {
3732 parentid_ = GOOGLE_ULONGLONG(0);
3733 clear_has_parentid();
3735 inline ::google::protobuf::uint64 DataTransferTraceInfoProto::parentid()
const {
3739 inline void DataTransferTraceInfoProto::set_parentid(::google::protobuf::uint64 value) {
3750 inline bool ClientOperationHeaderProto::has_baseheader()
const {
3751 return (_has_bits_[0] & 0x00000001u) != 0;
3753 inline void ClientOperationHeaderProto::set_has_baseheader() {
3754 _has_bits_[0] |= 0x00000001u;
3756 inline void ClientOperationHeaderProto::clear_has_baseheader() {
3757 _has_bits_[0] &= ~0x00000001u;
3759 inline void ClientOperationHeaderProto::clear_baseheader() {
3760 if (baseheader_ != NULL) baseheader_->::hadoop::hdfs::BaseHeaderProto::Clear();
3761 clear_has_baseheader();
3763 inline const ::hadoop::hdfs::BaseHeaderProto& ClientOperationHeaderProto::baseheader()
const {
3765 return baseheader_ != NULL ? *baseheader_ : *default_instance_->baseheader_;
3767 inline ::hadoop::hdfs::BaseHeaderProto* ClientOperationHeaderProto::mutable_baseheader() {
3768 set_has_baseheader();
3769 if (baseheader_ == NULL) {
3770 baseheader_ = new ::hadoop::hdfs::BaseHeaderProto;
3775 inline ::hadoop::hdfs::BaseHeaderProto* ClientOperationHeaderProto::release_baseheader() {
3777 clear_has_baseheader();
3784 baseheader_ = baseheader;
3786 set_has_baseheader();
3788 clear_has_baseheader();
3794 inline bool ClientOperationHeaderProto::has_clientname()
const {
3795 return (_has_bits_[0] & 0x00000002u) != 0;
3797 inline void ClientOperationHeaderProto::set_has_clientname() {
3798 _has_bits_[0] |= 0x00000002u;
3800 inline void ClientOperationHeaderProto::clear_has_clientname() {
3801 _has_bits_[0] &= ~0x00000002u;
3803 inline void ClientOperationHeaderProto::clear_clientname() {
3804 clientname_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
3805 clear_has_clientname();
3807 inline const ::std::string& ClientOperationHeaderProto::clientname()
const {
3809 return clientname_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
3811 inline void ClientOperationHeaderProto::set_clientname(const ::std::string& value) {
3812 set_has_clientname();
3813 clientname_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
3816 inline void ClientOperationHeaderProto::set_clientname(
const char* value) {
3817 set_has_clientname();
3818 clientname_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
3821 inline void ClientOperationHeaderProto::set_clientname(
const char* value,
size_t size) {
3822 set_has_clientname();
3823 clientname_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
3824 ::std::string(reinterpret_cast<const char*>(value), size));
3827 inline ::std::string* ClientOperationHeaderProto::mutable_clientname() {
3828 set_has_clientname();
3830 return clientname_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
3832 inline ::std::string* ClientOperationHeaderProto::release_clientname() {
3834 clear_has_clientname();
3835 return clientname_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
3837 inline void ClientOperationHeaderProto::set_allocated_clientname(::std::string* clientname) {
3838 if (clientname != NULL) {
3839 set_has_clientname();
3841 clear_has_clientname();
3843 clientname_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), clientname);
3852 inline bool CachingStrategyProto::has_dropbehind()
const {
3853 return (_has_bits_[0] & 0x00000001u) != 0;
3855 inline void CachingStrategyProto::set_has_dropbehind() {
3856 _has_bits_[0] |= 0x00000001u;
3858 inline void CachingStrategyProto::clear_has_dropbehind() {
3859 _has_bits_[0] &= ~0x00000001u;
3861 inline void CachingStrategyProto::clear_dropbehind() {
3862 dropbehind_ =
false;
3863 clear_has_dropbehind();
3865 inline bool CachingStrategyProto::dropbehind()
const {
3869 inline void CachingStrategyProto::set_dropbehind(
bool value) {
3870 set_has_dropbehind();
3871 dropbehind_ = value;
3876 inline bool CachingStrategyProto::has_readahead()
const {
3877 return (_has_bits_[0] & 0x00000002u) != 0;
3879 inline void CachingStrategyProto::set_has_readahead() {
3880 _has_bits_[0] |= 0x00000002u;
3882 inline void CachingStrategyProto::clear_has_readahead() {
3883 _has_bits_[0] &= ~0x00000002u;
3885 inline void CachingStrategyProto::clear_readahead() {
3886 readahead_ = GOOGLE_LONGLONG(0);
3887 clear_has_readahead();
3889 inline ::google::protobuf::int64 CachingStrategyProto::readahead()
const {
3893 inline void CachingStrategyProto::set_readahead(::google::protobuf::int64 value) {
3894 set_has_readahead();
3904 inline bool OpReadBlockProto::has_header()
const {
3905 return (_has_bits_[0] & 0x00000001u) != 0;
3907 inline void OpReadBlockProto::set_has_header() {
3908 _has_bits_[0] |= 0x00000001u;
3910 inline void OpReadBlockProto::clear_has_header() {
3911 _has_bits_[0] &= ~0x00000001u;
3913 inline void OpReadBlockProto::clear_header() {
3914 if (header_ != NULL) header_->::hadoop::hdfs::ClientOperationHeaderProto::Clear();
3917 inline const ::hadoop::hdfs::ClientOperationHeaderProto& OpReadBlockProto::header()
const {
3919 return header_ != NULL ? *header_ : *default_instance_->header_;
3921 inline ::hadoop::hdfs::ClientOperationHeaderProto* OpReadBlockProto::mutable_header() {
3923 if (header_ == NULL) {
3924 header_ = new ::hadoop::hdfs::ClientOperationHeaderProto;
3929 inline ::hadoop::hdfs::ClientOperationHeaderProto* OpReadBlockProto::release_header() {
3948 inline bool OpReadBlockProto::has_offset()
const {
3949 return (_has_bits_[0] & 0x00000002u) != 0;
3951 inline void OpReadBlockProto::set_has_offset() {
3952 _has_bits_[0] |= 0x00000002u;
3954 inline void OpReadBlockProto::clear_has_offset() {
3955 _has_bits_[0] &= ~0x00000002u;
3957 inline void OpReadBlockProto::clear_offset() {
3958 offset_ = GOOGLE_ULONGLONG(0);
3961 inline ::google::protobuf::uint64 OpReadBlockProto::offset()
const {
3965 inline void OpReadBlockProto::set_offset(::google::protobuf::uint64 value) {
3972 inline bool OpReadBlockProto::has_len()
const {
3973 return (_has_bits_[0] & 0x00000004u) != 0;
3975 inline void OpReadBlockProto::set_has_len() {
3976 _has_bits_[0] |= 0x00000004u;
3978 inline void OpReadBlockProto::clear_has_len() {
3979 _has_bits_[0] &= ~0x00000004u;
3981 inline void OpReadBlockProto::clear_len() {
3982 len_ = GOOGLE_ULONGLONG(0);
3985 inline ::google::protobuf::uint64 OpReadBlockProto::len()
const {
3989 inline void OpReadBlockProto::set_len(::google::protobuf::uint64 value) {
3996 inline bool OpReadBlockProto::has_sendchecksums()
const {
3997 return (_has_bits_[0] & 0x00000008u) != 0;
3999 inline void OpReadBlockProto::set_has_sendchecksums() {
4000 _has_bits_[0] |= 0x00000008u;
4002 inline void OpReadBlockProto::clear_has_sendchecksums() {
4003 _has_bits_[0] &= ~0x00000008u;
4005 inline void OpReadBlockProto::clear_sendchecksums() {
4006 sendchecksums_ =
true;
4007 clear_has_sendchecksums();
4009 inline bool OpReadBlockProto::sendchecksums()
const {
4011 return sendchecksums_;
4013 inline void OpReadBlockProto::set_sendchecksums(
bool value) {
4014 set_has_sendchecksums();
4015 sendchecksums_ = value;
4020 inline bool OpReadBlockProto::has_cachingstrategy()
const {
4021 return (_has_bits_[0] & 0x00000010u) != 0;
4023 inline void OpReadBlockProto::set_has_cachingstrategy() {
4024 _has_bits_[0] |= 0x00000010u;
4026 inline void OpReadBlockProto::clear_has_cachingstrategy() {
4027 _has_bits_[0] &= ~0x00000010u;
4029 inline void OpReadBlockProto::clear_cachingstrategy() {
4030 if (cachingstrategy_ != NULL) cachingstrategy_->::hadoop::hdfs::CachingStrategyProto::Clear();
4031 clear_has_cachingstrategy();
4033 inline const ::hadoop::hdfs::CachingStrategyProto& OpReadBlockProto::cachingstrategy()
const {
4035 return cachingstrategy_ != NULL ? *cachingstrategy_ : *default_instance_->cachingstrategy_;
4037 inline ::hadoop::hdfs::CachingStrategyProto* OpReadBlockProto::mutable_cachingstrategy() {
4038 set_has_cachingstrategy();
4039 if (cachingstrategy_ == NULL) {
4040 cachingstrategy_ = new ::hadoop::hdfs::CachingStrategyProto;
4043 return cachingstrategy_;
4045 inline ::hadoop::hdfs::CachingStrategyProto* OpReadBlockProto::release_cachingstrategy() {
4047 clear_has_cachingstrategy();
4049 cachingstrategy_ = NULL;
4053 delete cachingstrategy_;
4054 cachingstrategy_ = cachingstrategy;
4055 if (cachingstrategy) {
4056 set_has_cachingstrategy();
4058 clear_has_cachingstrategy();
4068 inline bool ChecksumProto::has_type()
const {
4069 return (_has_bits_[0] & 0x00000001u) != 0;
4071 inline void ChecksumProto::set_has_type() {
4072 _has_bits_[0] |= 0x00000001u;
4074 inline void ChecksumProto::clear_has_type() {
4075 _has_bits_[0] &= ~0x00000001u;
4077 inline void ChecksumProto::clear_type() {
4081 inline ::hadoop::hdfs::ChecksumTypeProto ChecksumProto::type()
const {
4083 return static_cast< ::hadoop::hdfs::ChecksumTypeProto
>(type_);
4085 inline void ChecksumProto::set_type(::hadoop::hdfs::ChecksumTypeProto value) {
4086 assert(::hadoop::hdfs::ChecksumTypeProto_IsValid(value));
4093 inline bool ChecksumProto::has_bytesperchecksum()
const {
4094 return (_has_bits_[0] & 0x00000002u) != 0;
4096 inline void ChecksumProto::set_has_bytesperchecksum() {
4097 _has_bits_[0] |= 0x00000002u;
4099 inline void ChecksumProto::clear_has_bytesperchecksum() {
4100 _has_bits_[0] &= ~0x00000002u;
4102 inline void ChecksumProto::clear_bytesperchecksum() {
4103 bytesperchecksum_ = 0u;
4104 clear_has_bytesperchecksum();
4106 inline ::google::protobuf::uint32 ChecksumProto::bytesperchecksum()
const {
4108 return bytesperchecksum_;
4110 inline void ChecksumProto::set_bytesperchecksum(::google::protobuf::uint32 value) {
4111 set_has_bytesperchecksum();
4112 bytesperchecksum_ = value;
4121 inline bool OpWriteBlockProto::has_header()
const {
4122 return (_has_bits_[0] & 0x00000001u) != 0;
4124 inline void OpWriteBlockProto::set_has_header() {
4125 _has_bits_[0] |= 0x00000001u;
4127 inline void OpWriteBlockProto::clear_has_header() {
4128 _has_bits_[0] &= ~0x00000001u;
4130 inline void OpWriteBlockProto::clear_header() {
4131 if (header_ != NULL) header_->::hadoop::hdfs::ClientOperationHeaderProto::Clear();
4134 inline const ::hadoop::hdfs::ClientOperationHeaderProto& OpWriteBlockProto::header()
const {
4136 return header_ != NULL ? *header_ : *default_instance_->header_;
4138 inline ::hadoop::hdfs::ClientOperationHeaderProto* OpWriteBlockProto::mutable_header() {
4140 if (header_ == NULL) {
4141 header_ = new ::hadoop::hdfs::ClientOperationHeaderProto;
4146 inline ::hadoop::hdfs::ClientOperationHeaderProto* OpWriteBlockProto::release_header() {
4165 inline int OpWriteBlockProto::targets_size()
const {
4166 return targets_.size();
4168 inline void OpWriteBlockProto::clear_targets() {
4171 inline const ::hadoop::hdfs::DatanodeInfoProto& OpWriteBlockProto::targets(
int index)
const {
4173 return targets_.Get(index);
4175 inline ::hadoop::hdfs::DatanodeInfoProto* OpWriteBlockProto::mutable_targets(
int index) {
4177 return targets_.Mutable(index);
4179 inline ::hadoop::hdfs::DatanodeInfoProto* OpWriteBlockProto::add_targets() {
4181 return targets_.Add();
4183 inline ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::DatanodeInfoProto >*
4184 OpWriteBlockProto::mutable_targets() {
4188 inline const ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::DatanodeInfoProto >&
4189 OpWriteBlockProto::targets()
const {
4195 inline bool OpWriteBlockProto::has_source()
const {
4196 return (_has_bits_[0] & 0x00000004u) != 0;
4198 inline void OpWriteBlockProto::set_has_source() {
4199 _has_bits_[0] |= 0x00000004u;
4201 inline void OpWriteBlockProto::clear_has_source() {
4202 _has_bits_[0] &= ~0x00000004u;
4204 inline void OpWriteBlockProto::clear_source() {
4205 if (source_ != NULL) source_->::hadoop::hdfs::DatanodeInfoProto::Clear();
4208 inline const ::hadoop::hdfs::DatanodeInfoProto& OpWriteBlockProto::source()
const {
4210 return source_ != NULL ? *source_ : *default_instance_->source_;
4212 inline ::hadoop::hdfs::DatanodeInfoProto* OpWriteBlockProto::mutable_source() {
4214 if (source_ == NULL) {
4215 source_ = new ::hadoop::hdfs::DatanodeInfoProto;
4220 inline ::hadoop::hdfs::DatanodeInfoProto* OpWriteBlockProto::release_source() {
4239 inline bool OpWriteBlockProto::has_stage()
const {
4240 return (_has_bits_[0] & 0x00000008u) != 0;
4242 inline void OpWriteBlockProto::set_has_stage() {
4243 _has_bits_[0] |= 0x00000008u;
4245 inline void OpWriteBlockProto::clear_has_stage() {
4246 _has_bits_[0] &= ~0x00000008u;
4248 inline void OpWriteBlockProto::clear_stage() {
4252 inline ::hadoop::hdfs::OpWriteBlockProto_BlockConstructionStage OpWriteBlockProto::stage()
const {
4254 return static_cast< ::hadoop::hdfs::OpWriteBlockProto_BlockConstructionStage
>(stage_);
4256 inline void OpWriteBlockProto::set_stage(::hadoop::hdfs::OpWriteBlockProto_BlockConstructionStage value) {
4257 assert(::hadoop::hdfs::OpWriteBlockProto_BlockConstructionStage_IsValid(value));
4264 inline bool OpWriteBlockProto::has_pipelinesize()
const {
4265 return (_has_bits_[0] & 0x00000010u) != 0;
4267 inline void OpWriteBlockProto::set_has_pipelinesize() {
4268 _has_bits_[0] |= 0x00000010u;
4270 inline void OpWriteBlockProto::clear_has_pipelinesize() {
4271 _has_bits_[0] &= ~0x00000010u;
4273 inline void OpWriteBlockProto::clear_pipelinesize() {
4275 clear_has_pipelinesize();
4277 inline ::google::protobuf::uint32 OpWriteBlockProto::pipelinesize()
const {
4279 return pipelinesize_;
4281 inline void OpWriteBlockProto::set_pipelinesize(::google::protobuf::uint32 value) {
4282 set_has_pipelinesize();
4283 pipelinesize_ = value;
4288 inline bool OpWriteBlockProto::has_minbytesrcvd()
const {
4289 return (_has_bits_[0] & 0x00000020u) != 0;
4291 inline void OpWriteBlockProto::set_has_minbytesrcvd() {
4292 _has_bits_[0] |= 0x00000020u;
4294 inline void OpWriteBlockProto::clear_has_minbytesrcvd() {
4295 _has_bits_[0] &= ~0x00000020u;
4297 inline void OpWriteBlockProto::clear_minbytesrcvd() {
4298 minbytesrcvd_ = GOOGLE_ULONGLONG(0);
4299 clear_has_minbytesrcvd();
4301 inline ::google::protobuf::uint64 OpWriteBlockProto::minbytesrcvd()
const {
4303 return minbytesrcvd_;
4305 inline void OpWriteBlockProto::set_minbytesrcvd(::google::protobuf::uint64 value) {
4306 set_has_minbytesrcvd();
4307 minbytesrcvd_ = value;
4312 inline bool OpWriteBlockProto::has_maxbytesrcvd()
const {
4313 return (_has_bits_[0] & 0x00000040u) != 0;
4315 inline void OpWriteBlockProto::set_has_maxbytesrcvd() {
4316 _has_bits_[0] |= 0x00000040u;
4318 inline void OpWriteBlockProto::clear_has_maxbytesrcvd() {
4319 _has_bits_[0] &= ~0x00000040u;
4321 inline void OpWriteBlockProto::clear_maxbytesrcvd() {
4322 maxbytesrcvd_ = GOOGLE_ULONGLONG(0);
4323 clear_has_maxbytesrcvd();
4325 inline ::google::protobuf::uint64 OpWriteBlockProto::maxbytesrcvd()
const {
4327 return maxbytesrcvd_;
4329 inline void OpWriteBlockProto::set_maxbytesrcvd(::google::protobuf::uint64 value) {
4330 set_has_maxbytesrcvd();
4331 maxbytesrcvd_ = value;
4336 inline bool OpWriteBlockProto::has_latestgenerationstamp()
const {
4337 return (_has_bits_[0] & 0x00000080u) != 0;
4339 inline void OpWriteBlockProto::set_has_latestgenerationstamp() {
4340 _has_bits_[0] |= 0x00000080u;
4342 inline void OpWriteBlockProto::clear_has_latestgenerationstamp() {
4343 _has_bits_[0] &= ~0x00000080u;
4345 inline void OpWriteBlockProto::clear_latestgenerationstamp() {
4346 latestgenerationstamp_ = GOOGLE_ULONGLONG(0);
4347 clear_has_latestgenerationstamp();
4349 inline ::google::protobuf::uint64 OpWriteBlockProto::latestgenerationstamp()
const {
4351 return latestgenerationstamp_;
4353 inline void OpWriteBlockProto::set_latestgenerationstamp(::google::protobuf::uint64 value) {
4354 set_has_latestgenerationstamp();
4355 latestgenerationstamp_ = value;
4360 inline bool OpWriteBlockProto::has_requestedchecksum()
const {
4361 return (_has_bits_[0] & 0x00000100u) != 0;
4363 inline void OpWriteBlockProto::set_has_requestedchecksum() {
4364 _has_bits_[0] |= 0x00000100u;
4366 inline void OpWriteBlockProto::clear_has_requestedchecksum() {
4367 _has_bits_[0] &= ~0x00000100u;
4369 inline void OpWriteBlockProto::clear_requestedchecksum() {
4370 if (requestedchecksum_ != NULL) requestedchecksum_->::hadoop::hdfs::ChecksumProto::Clear();
4371 clear_has_requestedchecksum();
4373 inline const ::hadoop::hdfs::ChecksumProto& OpWriteBlockProto::requestedchecksum()
const {
4375 return requestedchecksum_ != NULL ? *requestedchecksum_ : *default_instance_->requestedchecksum_;
4377 inline ::hadoop::hdfs::ChecksumProto* OpWriteBlockProto::mutable_requestedchecksum() {
4378 set_has_requestedchecksum();
4379 if (requestedchecksum_ == NULL) {
4380 requestedchecksum_ = new ::hadoop::hdfs::ChecksumProto;
4383 return requestedchecksum_;
4385 inline ::hadoop::hdfs::ChecksumProto* OpWriteBlockProto::release_requestedchecksum() {
4387 clear_has_requestedchecksum();
4389 requestedchecksum_ = NULL;
4393 delete requestedchecksum_;
4394 requestedchecksum_ = requestedchecksum;
4395 if (requestedchecksum) {
4396 set_has_requestedchecksum();
4398 clear_has_requestedchecksum();
4404 inline bool OpWriteBlockProto::has_cachingstrategy()
const {
4405 return (_has_bits_[0] & 0x00000200u) != 0;
4407 inline void OpWriteBlockProto::set_has_cachingstrategy() {
4408 _has_bits_[0] |= 0x00000200u;
4410 inline void OpWriteBlockProto::clear_has_cachingstrategy() {
4411 _has_bits_[0] &= ~0x00000200u;
4413 inline void OpWriteBlockProto::clear_cachingstrategy() {
4414 if (cachingstrategy_ != NULL) cachingstrategy_->::hadoop::hdfs::CachingStrategyProto::Clear();
4415 clear_has_cachingstrategy();
4417 inline const ::hadoop::hdfs::CachingStrategyProto& OpWriteBlockProto::cachingstrategy()
const {
4419 return cachingstrategy_ != NULL ? *cachingstrategy_ : *default_instance_->cachingstrategy_;
4421 inline ::hadoop::hdfs::CachingStrategyProto* OpWriteBlockProto::mutable_cachingstrategy() {
4422 set_has_cachingstrategy();
4423 if (cachingstrategy_ == NULL) {
4424 cachingstrategy_ = new ::hadoop::hdfs::CachingStrategyProto;
4427 return cachingstrategy_;
4429 inline ::hadoop::hdfs::CachingStrategyProto* OpWriteBlockProto::release_cachingstrategy() {
4431 clear_has_cachingstrategy();
4433 cachingstrategy_ = NULL;
4437 delete cachingstrategy_;
4438 cachingstrategy_ = cachingstrategy;
4439 if (cachingstrategy) {
4440 set_has_cachingstrategy();
4442 clear_has_cachingstrategy();
4448 inline bool OpWriteBlockProto::has_storagetype()
const {
4449 return (_has_bits_[0] & 0x00000400u) != 0;
4451 inline void OpWriteBlockProto::set_has_storagetype() {
4452 _has_bits_[0] |= 0x00000400u;
4454 inline void OpWriteBlockProto::clear_has_storagetype() {
4455 _has_bits_[0] &= ~0x00000400u;
4457 inline void OpWriteBlockProto::clear_storagetype() {
4459 clear_has_storagetype();
4461 inline ::hadoop::hdfs::StorageTypeProto OpWriteBlockProto::storagetype()
const {
4463 return static_cast< ::hadoop::hdfs::StorageTypeProto
>(storagetype_);
4465 inline void OpWriteBlockProto::set_storagetype(::hadoop::hdfs::StorageTypeProto value) {
4466 assert(::hadoop::hdfs::StorageTypeProto_IsValid(value));
4467 set_has_storagetype();
4468 storagetype_ = value;
4473 inline int OpWriteBlockProto::targetstoragetypes_size()
const {
4474 return targetstoragetypes_.size();
4476 inline void OpWriteBlockProto::clear_targetstoragetypes() {
4477 targetstoragetypes_.Clear();
4479 inline ::hadoop::hdfs::StorageTypeProto OpWriteBlockProto::targetstoragetypes(
int index)
const {
4481 return static_cast< ::hadoop::hdfs::StorageTypeProto
>(targetstoragetypes_.Get(index));
4483 inline void OpWriteBlockProto::set_targetstoragetypes(
int index, ::hadoop::hdfs::StorageTypeProto value) {
4484 assert(::hadoop::hdfs::StorageTypeProto_IsValid(value));
4485 targetstoragetypes_.Set(index, value);
4488 inline void OpWriteBlockProto::add_targetstoragetypes(::hadoop::hdfs::StorageTypeProto value) {
4489 assert(::hadoop::hdfs::StorageTypeProto_IsValid(value));
4490 targetstoragetypes_.Add(value);
4493 inline const ::google::protobuf::RepeatedField<int>&
4494 OpWriteBlockProto::targetstoragetypes()
const {
4496 return targetstoragetypes_;
4498 inline ::google::protobuf::RepeatedField<int>*
4499 OpWriteBlockProto::mutable_targetstoragetypes() {
4501 return &targetstoragetypes_;
4505 inline bool OpWriteBlockProto::has_allowlazypersist()
const {
4506 return (_has_bits_[0] & 0x00001000u) != 0;
4508 inline void OpWriteBlockProto::set_has_allowlazypersist() {
4509 _has_bits_[0] |= 0x00001000u;
4511 inline void OpWriteBlockProto::clear_has_allowlazypersist() {
4512 _has_bits_[0] &= ~0x00001000u;
4514 inline void OpWriteBlockProto::clear_allowlazypersist() {
4515 allowlazypersist_ =
false;
4516 clear_has_allowlazypersist();
4518 inline bool OpWriteBlockProto::allowlazypersist()
const {
4520 return allowlazypersist_;
4522 inline void OpWriteBlockProto::set_allowlazypersist(
bool value) {
4523 set_has_allowlazypersist();
4524 allowlazypersist_ = value;
4529 inline bool OpWriteBlockProto::has_pinning()
const {
4530 return (_has_bits_[0] & 0x00002000u) != 0;
4532 inline void OpWriteBlockProto::set_has_pinning() {
4533 _has_bits_[0] |= 0x00002000u;
4535 inline void OpWriteBlockProto::clear_has_pinning() {
4536 _has_bits_[0] &= ~0x00002000u;
4538 inline void OpWriteBlockProto::clear_pinning() {
4540 clear_has_pinning();
4542 inline bool OpWriteBlockProto::pinning()
const {
4546 inline void OpWriteBlockProto::set_pinning(
bool value) {
4553 inline int OpWriteBlockProto::targetpinnings_size()
const {
4554 return targetpinnings_.size();
4556 inline void OpWriteBlockProto::clear_targetpinnings() {
4557 targetpinnings_.Clear();
4559 inline bool OpWriteBlockProto::targetpinnings(
int index)
const {
4561 return targetpinnings_.Get(index);
4563 inline void OpWriteBlockProto::set_targetpinnings(
int index,
bool value) {
4564 targetpinnings_.Set(index, value);
4567 inline void OpWriteBlockProto::add_targetpinnings(
bool value) {
4568 targetpinnings_.Add(value);
4571 inline const ::google::protobuf::RepeatedField< bool >&
4572 OpWriteBlockProto::targetpinnings()
const {
4574 return targetpinnings_;
4576 inline ::google::protobuf::RepeatedField< bool >*
4577 OpWriteBlockProto::mutable_targetpinnings() {
4579 return &targetpinnings_;
4587 inline bool OpTransferBlockProto::has_header()
const {
4588 return (_has_bits_[0] & 0x00000001u) != 0;
4590 inline void OpTransferBlockProto::set_has_header() {
4591 _has_bits_[0] |= 0x00000001u;
4593 inline void OpTransferBlockProto::clear_has_header() {
4594 _has_bits_[0] &= ~0x00000001u;
4596 inline void OpTransferBlockProto::clear_header() {
4597 if (header_ != NULL) header_->::hadoop::hdfs::ClientOperationHeaderProto::Clear();
4600 inline const ::hadoop::hdfs::ClientOperationHeaderProto& OpTransferBlockProto::header()
const {
4602 return header_ != NULL ? *header_ : *default_instance_->header_;
4604 inline ::hadoop::hdfs::ClientOperationHeaderProto* OpTransferBlockProto::mutable_header() {
4606 if (header_ == NULL) {
4607 header_ = new ::hadoop::hdfs::ClientOperationHeaderProto;
4612 inline ::hadoop::hdfs::ClientOperationHeaderProto* OpTransferBlockProto::release_header() {
4631 inline int OpTransferBlockProto::targets_size()
const {
4632 return targets_.size();
4634 inline void OpTransferBlockProto::clear_targets() {
4637 inline const ::hadoop::hdfs::DatanodeInfoProto& OpTransferBlockProto::targets(
int index)
const {
4639 return targets_.Get(index);
4641 inline ::hadoop::hdfs::DatanodeInfoProto* OpTransferBlockProto::mutable_targets(
int index) {
4643 return targets_.Mutable(index);
4645 inline ::hadoop::hdfs::DatanodeInfoProto* OpTransferBlockProto::add_targets() {
4647 return targets_.Add();
4649 inline ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::DatanodeInfoProto >*
4650 OpTransferBlockProto::mutable_targets() {
4654 inline const ::google::protobuf::RepeatedPtrField< ::hadoop::hdfs::DatanodeInfoProto >&
4655 OpTransferBlockProto::targets()
const {
4661 inline int OpTransferBlockProto::targetstoragetypes_size()
const {
4662 return targetstoragetypes_.size();
4664 inline void OpTransferBlockProto::clear_targetstoragetypes() {
4665 targetstoragetypes_.Clear();
4667 inline ::hadoop::hdfs::StorageTypeProto OpTransferBlockProto::targetstoragetypes(
int index)
const {
4669 return static_cast< ::hadoop::hdfs::StorageTypeProto
>(targetstoragetypes_.Get(index));
4671 inline void OpTransferBlockProto::set_targetstoragetypes(
int index, ::hadoop::hdfs::StorageTypeProto value) {
4672 assert(::hadoop::hdfs::StorageTypeProto_IsValid(value));
4673 targetstoragetypes_.Set(index, value);
4676 inline void OpTransferBlockProto::add_targetstoragetypes(::hadoop::hdfs::StorageTypeProto value) {
4677 assert(::hadoop::hdfs::StorageTypeProto_IsValid(value));
4678 targetstoragetypes_.Add(value);
4681 inline const ::google::protobuf::RepeatedField<int>&
4682 OpTransferBlockProto::targetstoragetypes()
const {
4684 return targetstoragetypes_;
4686 inline ::google::protobuf::RepeatedField<int>*
4687 OpTransferBlockProto::mutable_targetstoragetypes() {
4689 return &targetstoragetypes_;
4697 inline bool OpReplaceBlockProto::has_header()
const {
4698 return (_has_bits_[0] & 0x00000001u) != 0;
4700 inline void OpReplaceBlockProto::set_has_header() {
4701 _has_bits_[0] |= 0x00000001u;
4703 inline void OpReplaceBlockProto::clear_has_header() {
4704 _has_bits_[0] &= ~0x00000001u;
4706 inline void OpReplaceBlockProto::clear_header() {
4707 if (header_ != NULL) header_->::hadoop::hdfs::BaseHeaderProto::Clear();
4710 inline const ::hadoop::hdfs::BaseHeaderProto& OpReplaceBlockProto::header()
const {
4712 return header_ != NULL ? *header_ : *default_instance_->header_;
4714 inline ::hadoop::hdfs::BaseHeaderProto* OpReplaceBlockProto::mutable_header() {
4716 if (header_ == NULL) {
4717 header_ = new ::hadoop::hdfs::BaseHeaderProto;
4722 inline ::hadoop::hdfs::BaseHeaderProto* OpReplaceBlockProto::release_header() {
4741 inline bool OpReplaceBlockProto::has_delhint()
const {
4742 return (_has_bits_[0] & 0x00000002u) != 0;
4744 inline void OpReplaceBlockProto::set_has_delhint() {
4745 _has_bits_[0] |= 0x00000002u;
4747 inline void OpReplaceBlockProto::clear_has_delhint() {
4748 _has_bits_[0] &= ~0x00000002u;
4750 inline void OpReplaceBlockProto::clear_delhint() {
4751 delhint_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
4752 clear_has_delhint();
4754 inline const ::std::string& OpReplaceBlockProto::delhint()
const {
4756 return delhint_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
4758 inline void OpReplaceBlockProto::set_delhint(const ::std::string& value) {
4760 delhint_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
4763 inline void OpReplaceBlockProto::set_delhint(
const char* value) {
4765 delhint_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
4768 inline void OpReplaceBlockProto::set_delhint(
const char* value,
size_t size) {
4770 delhint_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
4771 ::std::string(reinterpret_cast<const char*>(value), size));
4774 inline ::std::string* OpReplaceBlockProto::mutable_delhint() {
4777 return delhint_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
4779 inline ::std::string* OpReplaceBlockProto::release_delhint() {
4781 clear_has_delhint();
4782 return delhint_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
4784 inline void OpReplaceBlockProto::set_allocated_delhint(::std::string* delhint) {
4785 if (delhint != NULL) {
4788 clear_has_delhint();
4790 delhint_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), delhint);
4795 inline bool OpReplaceBlockProto::has_source()
const {
4796 return (_has_bits_[0] & 0x00000004u) != 0;
4798 inline void OpReplaceBlockProto::set_has_source() {
4799 _has_bits_[0] |= 0x00000004u;
4801 inline void OpReplaceBlockProto::clear_has_source() {
4802 _has_bits_[0] &= ~0x00000004u;
4804 inline void OpReplaceBlockProto::clear_source() {
4805 if (source_ != NULL) source_->::hadoop::hdfs::DatanodeInfoProto::Clear();
4808 inline const ::hadoop::hdfs::DatanodeInfoProto& OpReplaceBlockProto::source()
const {
4810 return source_ != NULL ? *source_ : *default_instance_->source_;
4812 inline ::hadoop::hdfs::DatanodeInfoProto* OpReplaceBlockProto::mutable_source() {
4814 if (source_ == NULL) {
4815 source_ = new ::hadoop::hdfs::DatanodeInfoProto;
4820 inline ::hadoop::hdfs::DatanodeInfoProto* OpReplaceBlockProto::release_source() {
4839 inline bool OpReplaceBlockProto::has_storagetype()
const {
4840 return (_has_bits_[0] & 0x00000008u) != 0;
4842 inline void OpReplaceBlockProto::set_has_storagetype() {
4843 _has_bits_[0] |= 0x00000008u;
4845 inline void OpReplaceBlockProto::clear_has_storagetype() {
4846 _has_bits_[0] &= ~0x00000008u;
4848 inline void OpReplaceBlockProto::clear_storagetype() {
4850 clear_has_storagetype();
4852 inline ::hadoop::hdfs::StorageTypeProto OpReplaceBlockProto::storagetype()
const {
4854 return static_cast< ::hadoop::hdfs::StorageTypeProto
>(storagetype_);
4856 inline void OpReplaceBlockProto::set_storagetype(::hadoop::hdfs::StorageTypeProto value) {
4857 assert(::hadoop::hdfs::StorageTypeProto_IsValid(value));
4858 set_has_storagetype();
4859 storagetype_ = value;
4868 inline bool OpCopyBlockProto::has_header()
const {
4869 return (_has_bits_[0] & 0x00000001u) != 0;
4871 inline void OpCopyBlockProto::set_has_header() {
4872 _has_bits_[0] |= 0x00000001u;
4874 inline void OpCopyBlockProto::clear_has_header() {
4875 _has_bits_[0] &= ~0x00000001u;
4877 inline void OpCopyBlockProto::clear_header() {
4878 if (header_ != NULL) header_->::hadoop::hdfs::BaseHeaderProto::Clear();
4881 inline const ::hadoop::hdfs::BaseHeaderProto& OpCopyBlockProto::header()
const {
4883 return header_ != NULL ? *header_ : *default_instance_->header_;
4885 inline ::hadoop::hdfs::BaseHeaderProto* OpCopyBlockProto::mutable_header() {
4887 if (header_ == NULL) {
4888 header_ = new ::hadoop::hdfs::BaseHeaderProto;
4893 inline ::hadoop::hdfs::BaseHeaderProto* OpCopyBlockProto::release_header() {
4916 inline bool OpBlockChecksumProto::has_header()
const {
4917 return (_has_bits_[0] & 0x00000001u) != 0;
4919 inline void OpBlockChecksumProto::set_has_header() {
4920 _has_bits_[0] |= 0x00000001u;
4922 inline void OpBlockChecksumProto::clear_has_header() {
4923 _has_bits_[0] &= ~0x00000001u;
4925 inline void OpBlockChecksumProto::clear_header() {
4926 if (header_ != NULL) header_->::hadoop::hdfs::BaseHeaderProto::Clear();
4929 inline const ::hadoop::hdfs::BaseHeaderProto& OpBlockChecksumProto::header()
const {
4931 return header_ != NULL ? *header_ : *default_instance_->header_;
4933 inline ::hadoop::hdfs::BaseHeaderProto* OpBlockChecksumProto::mutable_header() {
4935 if (header_ == NULL) {
4936 header_ = new ::hadoop::hdfs::BaseHeaderProto;
4941 inline ::hadoop::hdfs::BaseHeaderProto* OpBlockChecksumProto::release_header() {
4964 inline bool ShortCircuitShmIdProto::has_hi()
const {
4965 return (_has_bits_[0] & 0x00000001u) != 0;
4967 inline void ShortCircuitShmIdProto::set_has_hi() {
4968 _has_bits_[0] |= 0x00000001u;
4970 inline void ShortCircuitShmIdProto::clear_has_hi() {
4971 _has_bits_[0] &= ~0x00000001u;
4973 inline void ShortCircuitShmIdProto::clear_hi() {
4974 hi_ = GOOGLE_LONGLONG(0);
4977 inline ::google::protobuf::int64 ShortCircuitShmIdProto::hi()
const {
4981 inline void ShortCircuitShmIdProto::set_hi(::google::protobuf::int64 value) {
4988 inline bool ShortCircuitShmIdProto::has_lo()
const {
4989 return (_has_bits_[0] & 0x00000002u) != 0;
4991 inline void ShortCircuitShmIdProto::set_has_lo() {
4992 _has_bits_[0] |= 0x00000002u;
4994 inline void ShortCircuitShmIdProto::clear_has_lo() {
4995 _has_bits_[0] &= ~0x00000002u;
4997 inline void ShortCircuitShmIdProto::clear_lo() {
4998 lo_ = GOOGLE_LONGLONG(0);
5001 inline ::google::protobuf::int64 ShortCircuitShmIdProto::lo()
const {
5005 inline void ShortCircuitShmIdProto::set_lo(::google::protobuf::int64 value) {
5016 inline bool ShortCircuitShmSlotProto::has_shmid()
const {
5017 return (_has_bits_[0] & 0x00000001u) != 0;
5019 inline void ShortCircuitShmSlotProto::set_has_shmid() {
5020 _has_bits_[0] |= 0x00000001u;
5022 inline void ShortCircuitShmSlotProto::clear_has_shmid() {
5023 _has_bits_[0] &= ~0x00000001u;
5025 inline void ShortCircuitShmSlotProto::clear_shmid() {
5026 if (shmid_ != NULL) shmid_->::hadoop::hdfs::ShortCircuitShmIdProto::Clear();
5029 inline const ::hadoop::hdfs::ShortCircuitShmIdProto& ShortCircuitShmSlotProto::shmid()
const {
5031 return shmid_ != NULL ? *shmid_ : *default_instance_->shmid_;
5033 inline ::hadoop::hdfs::ShortCircuitShmIdProto* ShortCircuitShmSlotProto::mutable_shmid() {
5035 if (shmid_ == NULL) {
5036 shmid_ = new ::hadoop::hdfs::ShortCircuitShmIdProto;
5041 inline ::hadoop::hdfs::ShortCircuitShmIdProto* ShortCircuitShmSlotProto::release_shmid() {
5060 inline bool ShortCircuitShmSlotProto::has_slotidx()
const {
5061 return (_has_bits_[0] & 0x00000002u) != 0;
5063 inline void ShortCircuitShmSlotProto::set_has_slotidx() {
5064 _has_bits_[0] |= 0x00000002u;
5066 inline void ShortCircuitShmSlotProto::clear_has_slotidx() {
5067 _has_bits_[0] &= ~0x00000002u;
5069 inline void ShortCircuitShmSlotProto::clear_slotidx() {
5071 clear_has_slotidx();
5073 inline ::google::protobuf::int32 ShortCircuitShmSlotProto::slotidx()
const {
5077 inline void ShortCircuitShmSlotProto::set_slotidx(::google::protobuf::int32 value) {
5088 inline bool OpRequestShortCircuitAccessProto::has_header()
const {
5089 return (_has_bits_[0] & 0x00000001u) != 0;
5091 inline void OpRequestShortCircuitAccessProto::set_has_header() {
5092 _has_bits_[0] |= 0x00000001u;
5094 inline void OpRequestShortCircuitAccessProto::clear_has_header() {
5095 _has_bits_[0] &= ~0x00000001u;
5097 inline void OpRequestShortCircuitAccessProto::clear_header() {
5098 if (header_ != NULL) header_->::hadoop::hdfs::BaseHeaderProto::Clear();
5101 inline const ::hadoop::hdfs::BaseHeaderProto& OpRequestShortCircuitAccessProto::header()
const {
5103 return header_ != NULL ? *header_ : *default_instance_->header_;
5105 inline ::hadoop::hdfs::BaseHeaderProto* OpRequestShortCircuitAccessProto::mutable_header() {
5107 if (header_ == NULL) {
5108 header_ = new ::hadoop::hdfs::BaseHeaderProto;
5113 inline ::hadoop::hdfs::BaseHeaderProto* OpRequestShortCircuitAccessProto::release_header() {
5132 inline bool OpRequestShortCircuitAccessProto::has_maxversion()
const {
5133 return (_has_bits_[0] & 0x00000002u) != 0;
5135 inline void OpRequestShortCircuitAccessProto::set_has_maxversion() {
5136 _has_bits_[0] |= 0x00000002u;
5138 inline void OpRequestShortCircuitAccessProto::clear_has_maxversion() {
5139 _has_bits_[0] &= ~0x00000002u;
5141 inline void OpRequestShortCircuitAccessProto::clear_maxversion() {
5143 clear_has_maxversion();
5145 inline ::google::protobuf::uint32 OpRequestShortCircuitAccessProto::maxversion()
const {
5149 inline void OpRequestShortCircuitAccessProto::set_maxversion(::google::protobuf::uint32 value) {
5150 set_has_maxversion();
5151 maxversion_ = value;
5156 inline bool OpRequestShortCircuitAccessProto::has_slotid()
const {
5157 return (_has_bits_[0] & 0x00000004u) != 0;
5159 inline void OpRequestShortCircuitAccessProto::set_has_slotid() {
5160 _has_bits_[0] |= 0x00000004u;
5162 inline void OpRequestShortCircuitAccessProto::clear_has_slotid() {
5163 _has_bits_[0] &= ~0x00000004u;
5165 inline void OpRequestShortCircuitAccessProto::clear_slotid() {
5166 if (slotid_ != NULL) slotid_->::hadoop::hdfs::ShortCircuitShmSlotProto::Clear();
5169 inline const ::hadoop::hdfs::ShortCircuitShmSlotProto& OpRequestShortCircuitAccessProto::slotid()
const {
5171 return slotid_ != NULL ? *slotid_ : *default_instance_->slotid_;
5173 inline ::hadoop::hdfs::ShortCircuitShmSlotProto* OpRequestShortCircuitAccessProto::mutable_slotid() {
5175 if (slotid_ == NULL) {
5176 slotid_ = new ::hadoop::hdfs::ShortCircuitShmSlotProto;
5181 inline ::hadoop::hdfs::ShortCircuitShmSlotProto* OpRequestShortCircuitAccessProto::release_slotid() {
5200 inline bool OpRequestShortCircuitAccessProto::has_supportsreceiptverification()
const {
5201 return (_has_bits_[0] & 0x00000008u) != 0;
5203 inline void OpRequestShortCircuitAccessProto::set_has_supportsreceiptverification() {
5204 _has_bits_[0] |= 0x00000008u;
5206 inline void OpRequestShortCircuitAccessProto::clear_has_supportsreceiptverification() {
5207 _has_bits_[0] &= ~0x00000008u;
5209 inline void OpRequestShortCircuitAccessProto::clear_supportsreceiptverification() {
5210 supportsreceiptverification_ =
false;
5211 clear_has_supportsreceiptverification();
5213 inline bool OpRequestShortCircuitAccessProto::supportsreceiptverification()
const {
5215 return supportsreceiptverification_;
5217 inline void OpRequestShortCircuitAccessProto::set_supportsreceiptverification(
bool value) {
5218 set_has_supportsreceiptverification();
5219 supportsreceiptverification_ = value;
5228 inline bool ReleaseShortCircuitAccessRequestProto::has_slotid()
const {
5229 return (_has_bits_[0] & 0x00000001u) != 0;
5231 inline void ReleaseShortCircuitAccessRequestProto::set_has_slotid() {
5232 _has_bits_[0] |= 0x00000001u;
5234 inline void ReleaseShortCircuitAccessRequestProto::clear_has_slotid() {
5235 _has_bits_[0] &= ~0x00000001u;
5237 inline void ReleaseShortCircuitAccessRequestProto::clear_slotid() {
5238 if (slotid_ != NULL) slotid_->::hadoop::hdfs::ShortCircuitShmSlotProto::Clear();
5241 inline const ::hadoop::hdfs::ShortCircuitShmSlotProto& ReleaseShortCircuitAccessRequestProto::slotid()
const {
5243 return slotid_ != NULL ? *slotid_ : *default_instance_->slotid_;
5245 inline ::hadoop::hdfs::ShortCircuitShmSlotProto* ReleaseShortCircuitAccessRequestProto::mutable_slotid() {
5247 if (slotid_ == NULL) {
5248 slotid_ = new ::hadoop::hdfs::ShortCircuitShmSlotProto;
5253 inline ::hadoop::hdfs::ShortCircuitShmSlotProto* ReleaseShortCircuitAccessRequestProto::release_slotid() {
5272 inline bool ReleaseShortCircuitAccessRequestProto::has_traceinfo()
const {
5273 return (_has_bits_[0] & 0x00000002u) != 0;
5275 inline void ReleaseShortCircuitAccessRequestProto::set_has_traceinfo() {
5276 _has_bits_[0] |= 0x00000002u;
5278 inline void ReleaseShortCircuitAccessRequestProto::clear_has_traceinfo() {
5279 _has_bits_[0] &= ~0x00000002u;
5281 inline void ReleaseShortCircuitAccessRequestProto::clear_traceinfo() {
5282 if (traceinfo_ != NULL) traceinfo_->::hadoop::hdfs::DataTransferTraceInfoProto::Clear();
5283 clear_has_traceinfo();
5285 inline const ::hadoop::hdfs::DataTransferTraceInfoProto& ReleaseShortCircuitAccessRequestProto::traceinfo()
const {
5287 return traceinfo_ != NULL ? *traceinfo_ : *default_instance_->traceinfo_;
5289 inline ::hadoop::hdfs::DataTransferTraceInfoProto* ReleaseShortCircuitAccessRequestProto::mutable_traceinfo() {
5290 set_has_traceinfo();
5291 if (traceinfo_ == NULL) {
5292 traceinfo_ = new ::hadoop::hdfs::DataTransferTraceInfoProto;
5297 inline ::hadoop::hdfs::DataTransferTraceInfoProto* ReleaseShortCircuitAccessRequestProto::release_traceinfo() {
5299 clear_has_traceinfo();
5306 traceinfo_ = traceinfo;
5308 set_has_traceinfo();
5310 clear_has_traceinfo();
5320 inline bool ReleaseShortCircuitAccessResponseProto::has_status()
const {
5321 return (_has_bits_[0] & 0x00000001u) != 0;
5323 inline void ReleaseShortCircuitAccessResponseProto::set_has_status() {
5324 _has_bits_[0] |= 0x00000001u;
5326 inline void ReleaseShortCircuitAccessResponseProto::clear_has_status() {
5327 _has_bits_[0] &= ~0x00000001u;
5329 inline void ReleaseShortCircuitAccessResponseProto::clear_status() {
5333 inline ::hadoop::hdfs::Status ReleaseShortCircuitAccessResponseProto::status()
const {
5335 return static_cast< ::hadoop::hdfs::Status
>(status_);
5337 inline void ReleaseShortCircuitAccessResponseProto::set_status(::hadoop::hdfs::Status value) {
5338 assert(::hadoop::hdfs::Status_IsValid(value));
5345 inline bool ReleaseShortCircuitAccessResponseProto::has_error()
const {
5346 return (_has_bits_[0] & 0x00000002u) != 0;
5348 inline void ReleaseShortCircuitAccessResponseProto::set_has_error() {
5349 _has_bits_[0] |= 0x00000002u;
5351 inline void ReleaseShortCircuitAccessResponseProto::clear_has_error() {
5352 _has_bits_[0] &= ~0x00000002u;
5354 inline void ReleaseShortCircuitAccessResponseProto::clear_error() {
5355 error_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5358 inline const ::std::string& ReleaseShortCircuitAccessResponseProto::error()
const {
5360 return error_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5362 inline void ReleaseShortCircuitAccessResponseProto::set_error(const ::std::string& value) {
5364 error_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
5367 inline void ReleaseShortCircuitAccessResponseProto::set_error(
const char* value) {
5369 error_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
5372 inline void ReleaseShortCircuitAccessResponseProto::set_error(
const char* value,
size_t size) {
5374 error_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
5375 ::std::string(reinterpret_cast<const char*>(value), size));
5378 inline ::std::string* ReleaseShortCircuitAccessResponseProto::mutable_error() {
5381 return error_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5383 inline ::std::string* ReleaseShortCircuitAccessResponseProto::release_error() {
5386 return error_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5388 inline void ReleaseShortCircuitAccessResponseProto::set_allocated_error(::std::string* error) {
5389 if (error != NULL) {
5394 error_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), error);
5403 inline bool ShortCircuitShmRequestProto::has_clientname()
const {
5404 return (_has_bits_[0] & 0x00000001u) != 0;
5406 inline void ShortCircuitShmRequestProto::set_has_clientname() {
5407 _has_bits_[0] |= 0x00000001u;
5409 inline void ShortCircuitShmRequestProto::clear_has_clientname() {
5410 _has_bits_[0] &= ~0x00000001u;
5412 inline void ShortCircuitShmRequestProto::clear_clientname() {
5413 clientname_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5414 clear_has_clientname();
5416 inline const ::std::string& ShortCircuitShmRequestProto::clientname()
const {
5418 return clientname_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5420 inline void ShortCircuitShmRequestProto::set_clientname(const ::std::string& value) {
5421 set_has_clientname();
5422 clientname_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
5425 inline void ShortCircuitShmRequestProto::set_clientname(
const char* value) {
5426 set_has_clientname();
5427 clientname_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
5430 inline void ShortCircuitShmRequestProto::set_clientname(
const char* value,
size_t size) {
5431 set_has_clientname();
5432 clientname_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
5433 ::std::string(reinterpret_cast<const char*>(value), size));
5436 inline ::std::string* ShortCircuitShmRequestProto::mutable_clientname() {
5437 set_has_clientname();
5439 return clientname_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5441 inline ::std::string* ShortCircuitShmRequestProto::release_clientname() {
5443 clear_has_clientname();
5444 return clientname_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5446 inline void ShortCircuitShmRequestProto::set_allocated_clientname(::std::string* clientname) {
5447 if (clientname != NULL) {
5448 set_has_clientname();
5450 clear_has_clientname();
5452 clientname_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), clientname);
5457 inline bool ShortCircuitShmRequestProto::has_traceinfo()
const {
5458 return (_has_bits_[0] & 0x00000002u) != 0;
5460 inline void ShortCircuitShmRequestProto::set_has_traceinfo() {
5461 _has_bits_[0] |= 0x00000002u;
5463 inline void ShortCircuitShmRequestProto::clear_has_traceinfo() {
5464 _has_bits_[0] &= ~0x00000002u;
5466 inline void ShortCircuitShmRequestProto::clear_traceinfo() {
5467 if (traceinfo_ != NULL) traceinfo_->::hadoop::hdfs::DataTransferTraceInfoProto::Clear();
5468 clear_has_traceinfo();
5470 inline const ::hadoop::hdfs::DataTransferTraceInfoProto& ShortCircuitShmRequestProto::traceinfo()
const {
5472 return traceinfo_ != NULL ? *traceinfo_ : *default_instance_->traceinfo_;
5474 inline ::hadoop::hdfs::DataTransferTraceInfoProto* ShortCircuitShmRequestProto::mutable_traceinfo() {
5475 set_has_traceinfo();
5476 if (traceinfo_ == NULL) {
5477 traceinfo_ = new ::hadoop::hdfs::DataTransferTraceInfoProto;
5482 inline ::hadoop::hdfs::DataTransferTraceInfoProto* ShortCircuitShmRequestProto::release_traceinfo() {
5484 clear_has_traceinfo();
5491 traceinfo_ = traceinfo;
5493 set_has_traceinfo();
5495 clear_has_traceinfo();
5505 inline bool ShortCircuitShmResponseProto::has_status()
const {
5506 return (_has_bits_[0] & 0x00000001u) != 0;
5508 inline void ShortCircuitShmResponseProto::set_has_status() {
5509 _has_bits_[0] |= 0x00000001u;
5511 inline void ShortCircuitShmResponseProto::clear_has_status() {
5512 _has_bits_[0] &= ~0x00000001u;
5514 inline void ShortCircuitShmResponseProto::clear_status() {
5518 inline ::hadoop::hdfs::Status ShortCircuitShmResponseProto::status()
const {
5520 return static_cast< ::hadoop::hdfs::Status
>(status_);
5522 inline void ShortCircuitShmResponseProto::set_status(::hadoop::hdfs::Status value) {
5523 assert(::hadoop::hdfs::Status_IsValid(value));
5530 inline bool ShortCircuitShmResponseProto::has_error()
const {
5531 return (_has_bits_[0] & 0x00000002u) != 0;
5533 inline void ShortCircuitShmResponseProto::set_has_error() {
5534 _has_bits_[0] |= 0x00000002u;
5536 inline void ShortCircuitShmResponseProto::clear_has_error() {
5537 _has_bits_[0] &= ~0x00000002u;
5539 inline void ShortCircuitShmResponseProto::clear_error() {
5540 error_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5543 inline const ::std::string& ShortCircuitShmResponseProto::error()
const {
5545 return error_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5547 inline void ShortCircuitShmResponseProto::set_error(const ::std::string& value) {
5549 error_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
5552 inline void ShortCircuitShmResponseProto::set_error(
const char* value) {
5554 error_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
5557 inline void ShortCircuitShmResponseProto::set_error(
const char* value,
size_t size) {
5559 error_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
5560 ::std::string(reinterpret_cast<const char*>(value), size));
5563 inline ::std::string* ShortCircuitShmResponseProto::mutable_error() {
5566 return error_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5568 inline ::std::string* ShortCircuitShmResponseProto::release_error() {
5571 return error_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5573 inline void ShortCircuitShmResponseProto::set_allocated_error(::std::string* error) {
5574 if (error != NULL) {
5579 error_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), error);
5584 inline bool ShortCircuitShmResponseProto::has_id()
const {
5585 return (_has_bits_[0] & 0x00000004u) != 0;
5587 inline void ShortCircuitShmResponseProto::set_has_id() {
5588 _has_bits_[0] |= 0x00000004u;
5590 inline void ShortCircuitShmResponseProto::clear_has_id() {
5591 _has_bits_[0] &= ~0x00000004u;
5593 inline void ShortCircuitShmResponseProto::clear_id() {
5594 if (id_ != NULL) id_->::hadoop::hdfs::ShortCircuitShmIdProto::Clear();
5597 inline const ::hadoop::hdfs::ShortCircuitShmIdProto& ShortCircuitShmResponseProto::id()
const {
5599 return id_ != NULL ? *id_ : *default_instance_->id_;
5601 inline ::hadoop::hdfs::ShortCircuitShmIdProto* ShortCircuitShmResponseProto::mutable_id() {
5604 id_ = new ::hadoop::hdfs::ShortCircuitShmIdProto;
5609 inline ::hadoop::hdfs::ShortCircuitShmIdProto* ShortCircuitShmResponseProto::release_id() {
5632 inline bool PacketHeaderProto::has_offsetinblock()
const {
5633 return (_has_bits_[0] & 0x00000001u) != 0;
5635 inline void PacketHeaderProto::set_has_offsetinblock() {
5636 _has_bits_[0] |= 0x00000001u;
5638 inline void PacketHeaderProto::clear_has_offsetinblock() {
5639 _has_bits_[0] &= ~0x00000001u;
5641 inline void PacketHeaderProto::clear_offsetinblock() {
5642 offsetinblock_ = GOOGLE_LONGLONG(0);
5643 clear_has_offsetinblock();
5645 inline ::google::protobuf::int64 PacketHeaderProto::offsetinblock()
const {
5647 return offsetinblock_;
5649 inline void PacketHeaderProto::set_offsetinblock(::google::protobuf::int64 value) {
5650 set_has_offsetinblock();
5651 offsetinblock_ = value;
5656 inline bool PacketHeaderProto::has_seqno()
const {
5657 return (_has_bits_[0] & 0x00000002u) != 0;
5659 inline void PacketHeaderProto::set_has_seqno() {
5660 _has_bits_[0] |= 0x00000002u;
5662 inline void PacketHeaderProto::clear_has_seqno() {
5663 _has_bits_[0] &= ~0x00000002u;
5665 inline void PacketHeaderProto::clear_seqno() {
5666 seqno_ = GOOGLE_LONGLONG(0);
5669 inline ::google::protobuf::int64 PacketHeaderProto::seqno()
const {
5673 inline void PacketHeaderProto::set_seqno(::google::protobuf::int64 value) {
5680 inline bool PacketHeaderProto::has_lastpacketinblock()
const {
5681 return (_has_bits_[0] & 0x00000004u) != 0;
5683 inline void PacketHeaderProto::set_has_lastpacketinblock() {
5684 _has_bits_[0] |= 0x00000004u;
5686 inline void PacketHeaderProto::clear_has_lastpacketinblock() {
5687 _has_bits_[0] &= ~0x00000004u;
5689 inline void PacketHeaderProto::clear_lastpacketinblock() {
5690 lastpacketinblock_ =
false;
5691 clear_has_lastpacketinblock();
5693 inline bool PacketHeaderProto::lastpacketinblock()
const {
5695 return lastpacketinblock_;
5697 inline void PacketHeaderProto::set_lastpacketinblock(
bool value) {
5698 set_has_lastpacketinblock();
5699 lastpacketinblock_ = value;
5704 inline bool PacketHeaderProto::has_datalen()
const {
5705 return (_has_bits_[0] & 0x00000008u) != 0;
5707 inline void PacketHeaderProto::set_has_datalen() {
5708 _has_bits_[0] |= 0x00000008u;
5710 inline void PacketHeaderProto::clear_has_datalen() {
5711 _has_bits_[0] &= ~0x00000008u;
5713 inline void PacketHeaderProto::clear_datalen() {
5715 clear_has_datalen();
5717 inline ::google::protobuf::int32 PacketHeaderProto::datalen()
const {
5721 inline void PacketHeaderProto::set_datalen(::google::protobuf::int32 value) {
5728 inline bool PacketHeaderProto::has_syncblock()
const {
5729 return (_has_bits_[0] & 0x00000010u) != 0;
5731 inline void PacketHeaderProto::set_has_syncblock() {
5732 _has_bits_[0] |= 0x00000010u;
5734 inline void PacketHeaderProto::clear_has_syncblock() {
5735 _has_bits_[0] &= ~0x00000010u;
5737 inline void PacketHeaderProto::clear_syncblock() {
5739 clear_has_syncblock();
5741 inline bool PacketHeaderProto::syncblock()
const {
5745 inline void PacketHeaderProto::set_syncblock(
bool value) {
5746 set_has_syncblock();
5756 inline bool PipelineAckProto::has_seqno()
const {
5757 return (_has_bits_[0] & 0x00000001u) != 0;
5759 inline void PipelineAckProto::set_has_seqno() {
5760 _has_bits_[0] |= 0x00000001u;
5762 inline void PipelineAckProto::clear_has_seqno() {
5763 _has_bits_[0] &= ~0x00000001u;
5765 inline void PipelineAckProto::clear_seqno() {
5766 seqno_ = GOOGLE_LONGLONG(0);
5769 inline ::google::protobuf::int64 PipelineAckProto::seqno()
const {
5773 inline void PipelineAckProto::set_seqno(::google::protobuf::int64 value) {
5780 inline int PipelineAckProto::reply_size()
const {
5781 return reply_.size();
5783 inline void PipelineAckProto::clear_reply() {
5786 inline ::hadoop::hdfs::Status PipelineAckProto::reply(
int index)
const {
5788 return static_cast< ::hadoop::hdfs::Status
>(reply_.Get(index));
5790 inline void PipelineAckProto::set_reply(
int index, ::hadoop::hdfs::Status value) {
5791 assert(::hadoop::hdfs::Status_IsValid(value));
5792 reply_.Set(index, value);
5795 inline void PipelineAckProto::add_reply(::hadoop::hdfs::Status value) {
5796 assert(::hadoop::hdfs::Status_IsValid(value));
5800 inline const ::google::protobuf::RepeatedField<int>&
5801 PipelineAckProto::reply()
const {
5805 inline ::google::protobuf::RepeatedField<int>*
5806 PipelineAckProto::mutable_reply() {
5812 inline bool PipelineAckProto::has_downstreamacktimenanos()
const {
5813 return (_has_bits_[0] & 0x00000004u) != 0;
5815 inline void PipelineAckProto::set_has_downstreamacktimenanos() {
5816 _has_bits_[0] |= 0x00000004u;
5818 inline void PipelineAckProto::clear_has_downstreamacktimenanos() {
5819 _has_bits_[0] &= ~0x00000004u;
5821 inline void PipelineAckProto::clear_downstreamacktimenanos() {
5822 downstreamacktimenanos_ = GOOGLE_ULONGLONG(0);
5823 clear_has_downstreamacktimenanos();
5825 inline ::google::protobuf::uint64 PipelineAckProto::downstreamacktimenanos()
const {
5827 return downstreamacktimenanos_;
5829 inline void PipelineAckProto::set_downstreamacktimenanos(::google::protobuf::uint64 value) {
5830 set_has_downstreamacktimenanos();
5831 downstreamacktimenanos_ = value;
5836 inline int PipelineAckProto::flag_size()
const {
5837 return flag_.size();
5839 inline void PipelineAckProto::clear_flag() {
5842 inline ::google::protobuf::uint32 PipelineAckProto::flag(
int index)
const {
5844 return flag_.Get(index);
5846 inline void PipelineAckProto::set_flag(
int index, ::google::protobuf::uint32 value) {
5847 flag_.Set(index, value);
5850 inline void PipelineAckProto::add_flag(::google::protobuf::uint32 value) {
5854 inline const ::google::protobuf::RepeatedField< ::google::protobuf::uint32 >&
5855 PipelineAckProto::flag()
const {
5859 inline ::google::protobuf::RepeatedField< ::google::protobuf::uint32 >*
5860 PipelineAckProto::mutable_flag() {
5870 inline bool ReadOpChecksumInfoProto::has_checksum()
const {
5871 return (_has_bits_[0] & 0x00000001u) != 0;
5873 inline void ReadOpChecksumInfoProto::set_has_checksum() {
5874 _has_bits_[0] |= 0x00000001u;
5876 inline void ReadOpChecksumInfoProto::clear_has_checksum() {
5877 _has_bits_[0] &= ~0x00000001u;
5879 inline void ReadOpChecksumInfoProto::clear_checksum() {
5880 if (checksum_ != NULL) checksum_->::hadoop::hdfs::ChecksumProto::Clear();
5881 clear_has_checksum();
5883 inline const ::hadoop::hdfs::ChecksumProto& ReadOpChecksumInfoProto::checksum()
const {
5885 return checksum_ != NULL ? *checksum_ : *default_instance_->checksum_;
5887 inline ::hadoop::hdfs::ChecksumProto* ReadOpChecksumInfoProto::mutable_checksum() {
5889 if (checksum_ == NULL) {
5890 checksum_ = new ::hadoop::hdfs::ChecksumProto;
5895 inline ::hadoop::hdfs::ChecksumProto* ReadOpChecksumInfoProto::release_checksum() {
5897 clear_has_checksum();
5904 checksum_ = checksum;
5908 clear_has_checksum();
5914 inline bool ReadOpChecksumInfoProto::has_chunkoffset()
const {
5915 return (_has_bits_[0] & 0x00000002u) != 0;
5917 inline void ReadOpChecksumInfoProto::set_has_chunkoffset() {
5918 _has_bits_[0] |= 0x00000002u;
5920 inline void ReadOpChecksumInfoProto::clear_has_chunkoffset() {
5921 _has_bits_[0] &= ~0x00000002u;
5923 inline void ReadOpChecksumInfoProto::clear_chunkoffset() {
5924 chunkoffset_ = GOOGLE_ULONGLONG(0);
5925 clear_has_chunkoffset();
5927 inline ::google::protobuf::uint64 ReadOpChecksumInfoProto::chunkoffset()
const {
5929 return chunkoffset_;
5931 inline void ReadOpChecksumInfoProto::set_chunkoffset(::google::protobuf::uint64 value) {
5932 set_has_chunkoffset();
5933 chunkoffset_ = value;
5942 inline bool BlockOpResponseProto::has_status()
const {
5943 return (_has_bits_[0] & 0x00000001u) != 0;
5945 inline void BlockOpResponseProto::set_has_status() {
5946 _has_bits_[0] |= 0x00000001u;
5948 inline void BlockOpResponseProto::clear_has_status() {
5949 _has_bits_[0] &= ~0x00000001u;
5951 inline void BlockOpResponseProto::clear_status() {
5955 inline ::hadoop::hdfs::Status BlockOpResponseProto::status()
const {
5957 return static_cast< ::hadoop::hdfs::Status
>(status_);
5959 inline void BlockOpResponseProto::set_status(::hadoop::hdfs::Status value) {
5960 assert(::hadoop::hdfs::Status_IsValid(value));
5967 inline bool BlockOpResponseProto::has_firstbadlink()
const {
5968 return (_has_bits_[0] & 0x00000002u) != 0;
5970 inline void BlockOpResponseProto::set_has_firstbadlink() {
5971 _has_bits_[0] |= 0x00000002u;
5973 inline void BlockOpResponseProto::clear_has_firstbadlink() {
5974 _has_bits_[0] &= ~0x00000002u;
5976 inline void BlockOpResponseProto::clear_firstbadlink() {
5977 firstbadlink_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5978 clear_has_firstbadlink();
5980 inline const ::std::string& BlockOpResponseProto::firstbadlink()
const {
5982 return firstbadlink_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
5984 inline void BlockOpResponseProto::set_firstbadlink(const ::std::string& value) {
5985 set_has_firstbadlink();
5986 firstbadlink_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
5989 inline void BlockOpResponseProto::set_firstbadlink(
const char* value) {
5990 set_has_firstbadlink();
5991 firstbadlink_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
5994 inline void BlockOpResponseProto::set_firstbadlink(
const char* value,
size_t size) {
5995 set_has_firstbadlink();
5996 firstbadlink_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
5997 ::std::string(reinterpret_cast<const char*>(value), size));
6000 inline ::std::string* BlockOpResponseProto::mutable_firstbadlink() {
6001 set_has_firstbadlink();
6003 return firstbadlink_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6005 inline ::std::string* BlockOpResponseProto::release_firstbadlink() {
6007 clear_has_firstbadlink();
6008 return firstbadlink_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6010 inline void BlockOpResponseProto::set_allocated_firstbadlink(::std::string* firstbadlink) {
6011 if (firstbadlink != NULL) {
6012 set_has_firstbadlink();
6014 clear_has_firstbadlink();
6016 firstbadlink_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), firstbadlink);
6021 inline bool BlockOpResponseProto::has_checksumresponse()
const {
6022 return (_has_bits_[0] & 0x00000004u) != 0;
6024 inline void BlockOpResponseProto::set_has_checksumresponse() {
6025 _has_bits_[0] |= 0x00000004u;
6027 inline void BlockOpResponseProto::clear_has_checksumresponse() {
6028 _has_bits_[0] &= ~0x00000004u;
6030 inline void BlockOpResponseProto::clear_checksumresponse() {
6031 if (checksumresponse_ != NULL) checksumresponse_->::hadoop::hdfs::OpBlockChecksumResponseProto::Clear();
6032 clear_has_checksumresponse();
6034 inline const ::hadoop::hdfs::OpBlockChecksumResponseProto& BlockOpResponseProto::checksumresponse()
const {
6036 return checksumresponse_ != NULL ? *checksumresponse_ : *default_instance_->checksumresponse_;
6038 inline ::hadoop::hdfs::OpBlockChecksumResponseProto* BlockOpResponseProto::mutable_checksumresponse() {
6039 set_has_checksumresponse();
6040 if (checksumresponse_ == NULL) {
6041 checksumresponse_ = new ::hadoop::hdfs::OpBlockChecksumResponseProto;
6044 return checksumresponse_;
6046 inline ::hadoop::hdfs::OpBlockChecksumResponseProto* BlockOpResponseProto::release_checksumresponse() {
6048 clear_has_checksumresponse();
6050 checksumresponse_ = NULL;
6054 delete checksumresponse_;
6055 checksumresponse_ = checksumresponse;
6056 if (checksumresponse) {
6057 set_has_checksumresponse();
6059 clear_has_checksumresponse();
6065 inline bool BlockOpResponseProto::has_readopchecksuminfo()
const {
6066 return (_has_bits_[0] & 0x00000008u) != 0;
6068 inline void BlockOpResponseProto::set_has_readopchecksuminfo() {
6069 _has_bits_[0] |= 0x00000008u;
6071 inline void BlockOpResponseProto::clear_has_readopchecksuminfo() {
6072 _has_bits_[0] &= ~0x00000008u;
6074 inline void BlockOpResponseProto::clear_readopchecksuminfo() {
6075 if (readopchecksuminfo_ != NULL) readopchecksuminfo_->::hadoop::hdfs::ReadOpChecksumInfoProto::Clear();
6076 clear_has_readopchecksuminfo();
6078 inline const ::hadoop::hdfs::ReadOpChecksumInfoProto& BlockOpResponseProto::readopchecksuminfo()
const {
6080 return readopchecksuminfo_ != NULL ? *readopchecksuminfo_ : *default_instance_->readopchecksuminfo_;
6082 inline ::hadoop::hdfs::ReadOpChecksumInfoProto* BlockOpResponseProto::mutable_readopchecksuminfo() {
6083 set_has_readopchecksuminfo();
6084 if (readopchecksuminfo_ == NULL) {
6085 readopchecksuminfo_ = new ::hadoop::hdfs::ReadOpChecksumInfoProto;
6088 return readopchecksuminfo_;
6090 inline ::hadoop::hdfs::ReadOpChecksumInfoProto* BlockOpResponseProto::release_readopchecksuminfo() {
6092 clear_has_readopchecksuminfo();
6094 readopchecksuminfo_ = NULL;
6098 delete readopchecksuminfo_;
6099 readopchecksuminfo_ = readopchecksuminfo;
6100 if (readopchecksuminfo) {
6101 set_has_readopchecksuminfo();
6103 clear_has_readopchecksuminfo();
6109 inline bool BlockOpResponseProto::has_message()
const {
6110 return (_has_bits_[0] & 0x00000010u) != 0;
6112 inline void BlockOpResponseProto::set_has_message() {
6113 _has_bits_[0] |= 0x00000010u;
6115 inline void BlockOpResponseProto::clear_has_message() {
6116 _has_bits_[0] &= ~0x00000010u;
6118 inline void BlockOpResponseProto::clear_message() {
6119 message_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6120 clear_has_message();
6122 inline const ::std::string& BlockOpResponseProto::message()
const {
6124 return message_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6126 inline void BlockOpResponseProto::set_message(const ::std::string& value) {
6128 message_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
6131 inline void BlockOpResponseProto::set_message(
const char* value) {
6133 message_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
6136 inline void BlockOpResponseProto::set_message(
const char* value,
size_t size) {
6138 message_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
6139 ::std::string(reinterpret_cast<const char*>(value), size));
6142 inline ::std::string* BlockOpResponseProto::mutable_message() {
6145 return message_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6147 inline ::std::string* BlockOpResponseProto::release_message() {
6149 clear_has_message();
6150 return message_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6152 inline void BlockOpResponseProto::set_allocated_message(::std::string* message) {
6153 if (message != NULL) {
6156 clear_has_message();
6158 message_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), message);
6163 inline bool BlockOpResponseProto::has_shortcircuitaccessversion()
const {
6164 return (_has_bits_[0] & 0x00000020u) != 0;
6166 inline void BlockOpResponseProto::set_has_shortcircuitaccessversion() {
6167 _has_bits_[0] |= 0x00000020u;
6169 inline void BlockOpResponseProto::clear_has_shortcircuitaccessversion() {
6170 _has_bits_[0] &= ~0x00000020u;
6172 inline void BlockOpResponseProto::clear_shortcircuitaccessversion() {
6173 shortcircuitaccessversion_ = 0u;
6174 clear_has_shortcircuitaccessversion();
6176 inline ::google::protobuf::uint32 BlockOpResponseProto::shortcircuitaccessversion()
const {
6178 return shortcircuitaccessversion_;
6180 inline void BlockOpResponseProto::set_shortcircuitaccessversion(::google::protobuf::uint32 value) {
6181 set_has_shortcircuitaccessversion();
6182 shortcircuitaccessversion_ = value;
6191 inline bool ClientReadStatusProto::has_status()
const {
6192 return (_has_bits_[0] & 0x00000001u) != 0;
6194 inline void ClientReadStatusProto::set_has_status() {
6195 _has_bits_[0] |= 0x00000001u;
6197 inline void ClientReadStatusProto::clear_has_status() {
6198 _has_bits_[0] &= ~0x00000001u;
6200 inline void ClientReadStatusProto::clear_status() {
6204 inline ::hadoop::hdfs::Status ClientReadStatusProto::status()
const {
6206 return static_cast< ::hadoop::hdfs::Status
>(status_);
6208 inline void ClientReadStatusProto::set_status(::hadoop::hdfs::Status value) {
6209 assert(::hadoop::hdfs::Status_IsValid(value));
6220 inline bool DNTransferAckProto::has_status()
const {
6221 return (_has_bits_[0] & 0x00000001u) != 0;
6223 inline void DNTransferAckProto::set_has_status() {
6224 _has_bits_[0] |= 0x00000001u;
6226 inline void DNTransferAckProto::clear_has_status() {
6227 _has_bits_[0] &= ~0x00000001u;
6229 inline void DNTransferAckProto::clear_status() {
6233 inline ::hadoop::hdfs::Status DNTransferAckProto::status()
const {
6235 return static_cast< ::hadoop::hdfs::Status
>(status_);
6237 inline void DNTransferAckProto::set_status(::hadoop::hdfs::Status value) {
6238 assert(::hadoop::hdfs::Status_IsValid(value));
6249 inline bool OpBlockChecksumResponseProto::has_bytespercrc()
const {
6250 return (_has_bits_[0] & 0x00000001u) != 0;
6252 inline void OpBlockChecksumResponseProto::set_has_bytespercrc() {
6253 _has_bits_[0] |= 0x00000001u;
6255 inline void OpBlockChecksumResponseProto::clear_has_bytespercrc() {
6256 _has_bits_[0] &= ~0x00000001u;
6258 inline void OpBlockChecksumResponseProto::clear_bytespercrc() {
6260 clear_has_bytespercrc();
6262 inline ::google::protobuf::uint32 OpBlockChecksumResponseProto::bytespercrc()
const {
6264 return bytespercrc_;
6266 inline void OpBlockChecksumResponseProto::set_bytespercrc(::google::protobuf::uint32 value) {
6267 set_has_bytespercrc();
6268 bytespercrc_ = value;
6273 inline bool OpBlockChecksumResponseProto::has_crcperblock()
const {
6274 return (_has_bits_[0] & 0x00000002u) != 0;
6276 inline void OpBlockChecksumResponseProto::set_has_crcperblock() {
6277 _has_bits_[0] |= 0x00000002u;
6279 inline void OpBlockChecksumResponseProto::clear_has_crcperblock() {
6280 _has_bits_[0] &= ~0x00000002u;
6282 inline void OpBlockChecksumResponseProto::clear_crcperblock() {
6283 crcperblock_ = GOOGLE_ULONGLONG(0);
6284 clear_has_crcperblock();
6286 inline ::google::protobuf::uint64 OpBlockChecksumResponseProto::crcperblock()
const {
6288 return crcperblock_;
6290 inline void OpBlockChecksumResponseProto::set_crcperblock(::google::protobuf::uint64 value) {
6291 set_has_crcperblock();
6292 crcperblock_ = value;
6297 inline bool OpBlockChecksumResponseProto::has_md5()
const {
6298 return (_has_bits_[0] & 0x00000004u) != 0;
6300 inline void OpBlockChecksumResponseProto::set_has_md5() {
6301 _has_bits_[0] |= 0x00000004u;
6303 inline void OpBlockChecksumResponseProto::clear_has_md5() {
6304 _has_bits_[0] &= ~0x00000004u;
6306 inline void OpBlockChecksumResponseProto::clear_md5() {
6307 md5_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6310 inline const ::std::string& OpBlockChecksumResponseProto::md5()
const {
6312 return md5_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6314 inline void OpBlockChecksumResponseProto::set_md5(const ::std::string& value) {
6316 md5_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
6319 inline void OpBlockChecksumResponseProto::set_md5(
const char* value) {
6321 md5_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
6324 inline void OpBlockChecksumResponseProto::set_md5(
const void* value,
size_t size) {
6326 md5_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
6327 ::std::string(reinterpret_cast<const char*>(value), size));
6330 inline ::std::string* OpBlockChecksumResponseProto::mutable_md5() {
6333 return md5_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6335 inline ::std::string* OpBlockChecksumResponseProto::release_md5() {
6338 return md5_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
6340 inline void OpBlockChecksumResponseProto::set_allocated_md5(::std::string* md5) {
6346 md5_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), md5);
6351 inline bool OpBlockChecksumResponseProto::has_crctype()
const {
6352 return (_has_bits_[0] & 0x00000008u) != 0;
6354 inline void OpBlockChecksumResponseProto::set_has_crctype() {
6355 _has_bits_[0] |= 0x00000008u;
6357 inline void OpBlockChecksumResponseProto::clear_has_crctype() {
6358 _has_bits_[0] &= ~0x00000008u;
6360 inline void OpBlockChecksumResponseProto::clear_crctype() {
6362 clear_has_crctype();
6364 inline ::hadoop::hdfs::ChecksumTypeProto OpBlockChecksumResponseProto::crctype()
const {
6366 return static_cast< ::hadoop::hdfs::ChecksumTypeProto
>(crctype_);
6368 inline void OpBlockChecksumResponseProto::set_crctype(::hadoop::hdfs::ChecksumTypeProto value) {
6369 assert(::hadoop::hdfs::ChecksumTypeProto_IsValid(value));
6375 #endif // !PROTOBUF_INLINE_NOT_IN_HEADERS
6434 namespace protobuf {
6436 template <>
struct is_proto_enum< ::hadoop::hdfs::DataTransferEncryptorMessageProto_DataTransferEncryptorStatus> : ::google::protobuf::internal::true_type {};
6438 inline const EnumDescriptor* GetEnumDescriptor< ::hadoop::hdfs::DataTransferEncryptorMessageProto_DataTransferEncryptorStatus>() {
6439 return ::hadoop::hdfs::DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_descriptor();
6441 template <>
struct is_proto_enum< ::hadoop::hdfs::OpWriteBlockProto_BlockConstructionStage> : ::google::protobuf::internal::true_type {};
6443 inline const EnumDescriptor* GetEnumDescriptor< ::hadoop::hdfs::OpWriteBlockProto_BlockConstructionStage>() {
6444 return ::hadoop::hdfs::OpWriteBlockProto_BlockConstructionStage_descriptor();
6446 template <>
struct is_proto_enum< ::hadoop::hdfs::Status> : ::google::protobuf::internal::true_type {};
6448 inline const EnumDescriptor* GetEnumDescriptor< ::hadoop::hdfs::Status>() {
6449 return ::hadoop::hdfs::Status_descriptor();
6451 template <>
struct is_proto_enum< ::hadoop::hdfs::ShortCircuitFdResponse> : ::google::protobuf::internal::true_type {};
6453 inline const EnumDescriptor* GetEnumDescriptor< ::hadoop::hdfs::ShortCircuitFdResponse>() {
6454 return ::hadoop::hdfs::ShortCircuitFdResponse_descriptor();
6463 #endif // PROTOBUF_datatransfer_2eproto__INCLUDED
Definition: datatransfer.pb.h:669
Definition: datatransfer.pb.h:3071
Definition: datatransfer.pb.h:2914
Definition: datatransfer.pb.h:1018
Definition: datatransfer.pb.h:2422
Definition: datatransfer.pb.h:912
Definition: hdfs.pb.h:3151
Definition: datatransfer.pb.h:450
Definition: datatransfer.pb.h:2097
Definition: datatransfer.pb.h:2312
Definition: datatransfer.pb.h:2204
Definition: datatransfer.pb.h:1658
Definition: datatransfer.pb.h:1967
Definition: datatransfer.pb.h:3164
Definition: hdfs.pb.h:314
Definition: datatransfer.pb.h:2678
Definition: datatransfer.pb.h:1309
Definition: datatransfer.pb.h:167
Definition: Security.pb.h:50
Definition: datatransfer.pb.h:772
Definition: datatransfer.pb.h:2806
Definition: datatransfer.pb.h:1563
Definition: datatransfer.pb.h:3257
Definition: datatransfer.pb.h:1428
Definition: datatransfer.pb.h:1753
Definition: datatransfer.pb.h:1859
Definition: hdfs.pb.h:838