1// Generated by the protocol buffer compiler. DO NOT EDIT!
2// source: ClientDatanodeProtocol.proto
3
4#include "ClientDatanodeProtocol.pb.h"
5
6#include <algorithm>
7
8#include <google/protobuf/stubs/common.h>
9#include <google/protobuf/stubs/port.h>
10#include <google/protobuf/io/coded_stream.h>
11#include <google/protobuf/wire_format_lite_inl.h>
12#include <google/protobuf/descriptor.h>
13#include <google/protobuf/generated_message_reflection.h>
14#include <google/protobuf/reflection_ops.h>
15#include <google/protobuf/wire_format.h>
16// This is a temporary google only hack
17#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
18#include "third_party/protobuf/version.h"
19#endif
20// @@protoc_insertion_point(includes)
21
22namespace protobuf_Security_2eproto {
23extern PROTOBUF_INTERNAL_EXPORT_protobuf_Security_2eproto ::google::protobuf::internal::SCCInfo<0> scc_info_TokenProto;
24} // namespace protobuf_Security_2eproto
25namespace protobuf_hdfs_2eproto {
26extern PROTOBUF_INTERNAL_EXPORT_protobuf_hdfs_2eproto ::google::protobuf::internal::SCCInfo<0> scc_info_ExtendedBlockProto;
27} // namespace protobuf_hdfs_2eproto
28namespace Hdfs {
29namespace Internal {
30class GetReplicaVisibleLengthRequestProtoDefaultTypeInternal {
31 public:
32 ::google::protobuf::internal::ExplicitlyConstructed<GetReplicaVisibleLengthRequestProto>
33 _instance;
34} _GetReplicaVisibleLengthRequestProto_default_instance_;
35class GetReplicaVisibleLengthResponseProtoDefaultTypeInternal {
36 public:
37 ::google::protobuf::internal::ExplicitlyConstructed<GetReplicaVisibleLengthResponseProto>
38 _instance;
39} _GetReplicaVisibleLengthResponseProto_default_instance_;
40class RefreshNamenodesRequestProtoDefaultTypeInternal {
41 public:
42 ::google::protobuf::internal::ExplicitlyConstructed<RefreshNamenodesRequestProto>
43 _instance;
44} _RefreshNamenodesRequestProto_default_instance_;
45class RefreshNamenodesResponseProtoDefaultTypeInternal {
46 public:
47 ::google::protobuf::internal::ExplicitlyConstructed<RefreshNamenodesResponseProto>
48 _instance;
49} _RefreshNamenodesResponseProto_default_instance_;
50class DeleteBlockPoolRequestProtoDefaultTypeInternal {
51 public:
52 ::google::protobuf::internal::ExplicitlyConstructed<DeleteBlockPoolRequestProto>
53 _instance;
54} _DeleteBlockPoolRequestProto_default_instance_;
55class DeleteBlockPoolResponseProtoDefaultTypeInternal {
56 public:
57 ::google::protobuf::internal::ExplicitlyConstructed<DeleteBlockPoolResponseProto>
58 _instance;
59} _DeleteBlockPoolResponseProto_default_instance_;
60class GetBlockLocalPathInfoRequestProtoDefaultTypeInternal {
61 public:
62 ::google::protobuf::internal::ExplicitlyConstructed<GetBlockLocalPathInfoRequestProto>
63 _instance;
64} _GetBlockLocalPathInfoRequestProto_default_instance_;
65class GetBlockLocalPathInfoResponseProtoDefaultTypeInternal {
66 public:
67 ::google::protobuf::internal::ExplicitlyConstructed<GetBlockLocalPathInfoResponseProto>
68 _instance;
69} _GetBlockLocalPathInfoResponseProto_default_instance_;
70class GetHdfsBlockLocationsRequestProtoDefaultTypeInternal {
71 public:
72 ::google::protobuf::internal::ExplicitlyConstructed<GetHdfsBlockLocationsRequestProto>
73 _instance;
74} _GetHdfsBlockLocationsRequestProto_default_instance_;
75class GetHdfsBlockLocationsResponseProtoDefaultTypeInternal {
76 public:
77 ::google::protobuf::internal::ExplicitlyConstructed<GetHdfsBlockLocationsResponseProto>
78 _instance;
79} _GetHdfsBlockLocationsResponseProto_default_instance_;
80} // namespace Internal
81} // namespace Hdfs
82namespace protobuf_ClientDatanodeProtocol_2eproto {
83static void InitDefaultsGetReplicaVisibleLengthRequestProto() {
84 GOOGLE_PROTOBUF_VERIFY_VERSION;
85
86 {
87 void* ptr = &::Hdfs::Internal::_GetReplicaVisibleLengthRequestProto_default_instance_;
88 new (ptr) ::Hdfs::Internal::GetReplicaVisibleLengthRequestProto();
89 ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
90 }
91 ::Hdfs::Internal::GetReplicaVisibleLengthRequestProto::InitAsDefaultInstance();
92}
93
94::google::protobuf::internal::SCCInfo<1> scc_info_GetReplicaVisibleLengthRequestProto =
95 {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 1, InitDefaultsGetReplicaVisibleLengthRequestProto}, {
96 &protobuf_hdfs_2eproto::scc_info_ExtendedBlockProto.base,}};
97
98static void InitDefaultsGetReplicaVisibleLengthResponseProto() {
99 GOOGLE_PROTOBUF_VERIFY_VERSION;
100
101 {
102 void* ptr = &::Hdfs::Internal::_GetReplicaVisibleLengthResponseProto_default_instance_;
103 new (ptr) ::Hdfs::Internal::GetReplicaVisibleLengthResponseProto();
104 ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
105 }
106 ::Hdfs::Internal::GetReplicaVisibleLengthResponseProto::InitAsDefaultInstance();
107}
108
109::google::protobuf::internal::SCCInfo<0> scc_info_GetReplicaVisibleLengthResponseProto =
110 {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsGetReplicaVisibleLengthResponseProto}, {}};
111
112static void InitDefaultsRefreshNamenodesRequestProto() {
113 GOOGLE_PROTOBUF_VERIFY_VERSION;
114
115 {
116 void* ptr = &::Hdfs::Internal::_RefreshNamenodesRequestProto_default_instance_;
117 new (ptr) ::Hdfs::Internal::RefreshNamenodesRequestProto();
118 ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
119 }
120 ::Hdfs::Internal::RefreshNamenodesRequestProto::InitAsDefaultInstance();
121}
122
123::google::protobuf::internal::SCCInfo<0> scc_info_RefreshNamenodesRequestProto =
124 {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsRefreshNamenodesRequestProto}, {}};
125
126static void InitDefaultsRefreshNamenodesResponseProto() {
127 GOOGLE_PROTOBUF_VERIFY_VERSION;
128
129 {
130 void* ptr = &::Hdfs::Internal::_RefreshNamenodesResponseProto_default_instance_;
131 new (ptr) ::Hdfs::Internal::RefreshNamenodesResponseProto();
132 ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
133 }
134 ::Hdfs::Internal::RefreshNamenodesResponseProto::InitAsDefaultInstance();
135}
136
137::google::protobuf::internal::SCCInfo<0> scc_info_RefreshNamenodesResponseProto =
138 {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsRefreshNamenodesResponseProto}, {}};
139
140static void InitDefaultsDeleteBlockPoolRequestProto() {
141 GOOGLE_PROTOBUF_VERIFY_VERSION;
142
143 {
144 void* ptr = &::Hdfs::Internal::_DeleteBlockPoolRequestProto_default_instance_;
145 new (ptr) ::Hdfs::Internal::DeleteBlockPoolRequestProto();
146 ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
147 }
148 ::Hdfs::Internal::DeleteBlockPoolRequestProto::InitAsDefaultInstance();
149}
150
151::google::protobuf::internal::SCCInfo<0> scc_info_DeleteBlockPoolRequestProto =
152 {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsDeleteBlockPoolRequestProto}, {}};
153
154static void InitDefaultsDeleteBlockPoolResponseProto() {
155 GOOGLE_PROTOBUF_VERIFY_VERSION;
156
157 {
158 void* ptr = &::Hdfs::Internal::_DeleteBlockPoolResponseProto_default_instance_;
159 new (ptr) ::Hdfs::Internal::DeleteBlockPoolResponseProto();
160 ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
161 }
162 ::Hdfs::Internal::DeleteBlockPoolResponseProto::InitAsDefaultInstance();
163}
164
165::google::protobuf::internal::SCCInfo<0> scc_info_DeleteBlockPoolResponseProto =
166 {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsDeleteBlockPoolResponseProto}, {}};
167
168static void InitDefaultsGetBlockLocalPathInfoRequestProto() {
169 GOOGLE_PROTOBUF_VERIFY_VERSION;
170
171 {
172 void* ptr = &::Hdfs::Internal::_GetBlockLocalPathInfoRequestProto_default_instance_;
173 new (ptr) ::Hdfs::Internal::GetBlockLocalPathInfoRequestProto();
174 ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
175 }
176 ::Hdfs::Internal::GetBlockLocalPathInfoRequestProto::InitAsDefaultInstance();
177}
178
179::google::protobuf::internal::SCCInfo<2> scc_info_GetBlockLocalPathInfoRequestProto =
180 {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 2, InitDefaultsGetBlockLocalPathInfoRequestProto}, {
181 &protobuf_hdfs_2eproto::scc_info_ExtendedBlockProto.base,
182 &protobuf_Security_2eproto::scc_info_TokenProto.base,}};
183
184static void InitDefaultsGetBlockLocalPathInfoResponseProto() {
185 GOOGLE_PROTOBUF_VERIFY_VERSION;
186
187 {
188 void* ptr = &::Hdfs::Internal::_GetBlockLocalPathInfoResponseProto_default_instance_;
189 new (ptr) ::Hdfs::Internal::GetBlockLocalPathInfoResponseProto();
190 ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
191 }
192 ::Hdfs::Internal::GetBlockLocalPathInfoResponseProto::InitAsDefaultInstance();
193}
194
195::google::protobuf::internal::SCCInfo<1> scc_info_GetBlockLocalPathInfoResponseProto =
196 {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 1, InitDefaultsGetBlockLocalPathInfoResponseProto}, {
197 &protobuf_hdfs_2eproto::scc_info_ExtendedBlockProto.base,}};
198
199static void InitDefaultsGetHdfsBlockLocationsRequestProto() {
200 GOOGLE_PROTOBUF_VERIFY_VERSION;
201
202 {
203 void* ptr = &::Hdfs::Internal::_GetHdfsBlockLocationsRequestProto_default_instance_;
204 new (ptr) ::Hdfs::Internal::GetHdfsBlockLocationsRequestProto();
205 ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
206 }
207 ::Hdfs::Internal::GetHdfsBlockLocationsRequestProto::InitAsDefaultInstance();
208}
209
210::google::protobuf::internal::SCCInfo<2> scc_info_GetHdfsBlockLocationsRequestProto =
211 {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 2, InitDefaultsGetHdfsBlockLocationsRequestProto}, {
212 &protobuf_hdfs_2eproto::scc_info_ExtendedBlockProto.base,
213 &protobuf_Security_2eproto::scc_info_TokenProto.base,}};
214
215static void InitDefaultsGetHdfsBlockLocationsResponseProto() {
216 GOOGLE_PROTOBUF_VERIFY_VERSION;
217
218 {
219 void* ptr = &::Hdfs::Internal::_GetHdfsBlockLocationsResponseProto_default_instance_;
220 new (ptr) ::Hdfs::Internal::GetHdfsBlockLocationsResponseProto();
221 ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
222 }
223 ::Hdfs::Internal::GetHdfsBlockLocationsResponseProto::InitAsDefaultInstance();
224}
225
226::google::protobuf::internal::SCCInfo<0> scc_info_GetHdfsBlockLocationsResponseProto =
227 {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsGetHdfsBlockLocationsResponseProto}, {}};
228
229void InitDefaults() {
230 ::google::protobuf::internal::InitSCC(&scc_info_GetReplicaVisibleLengthRequestProto.base);
231 ::google::protobuf::internal::InitSCC(&scc_info_GetReplicaVisibleLengthResponseProto.base);
232 ::google::protobuf::internal::InitSCC(&scc_info_RefreshNamenodesRequestProto.base);
233 ::google::protobuf::internal::InitSCC(&scc_info_RefreshNamenodesResponseProto.base);
234 ::google::protobuf::internal::InitSCC(&scc_info_DeleteBlockPoolRequestProto.base);
235 ::google::protobuf::internal::InitSCC(&scc_info_DeleteBlockPoolResponseProto.base);
236 ::google::protobuf::internal::InitSCC(&scc_info_GetBlockLocalPathInfoRequestProto.base);
237 ::google::protobuf::internal::InitSCC(&scc_info_GetBlockLocalPathInfoResponseProto.base);
238 ::google::protobuf::internal::InitSCC(&scc_info_GetHdfsBlockLocationsRequestProto.base);
239 ::google::protobuf::internal::InitSCC(&scc_info_GetHdfsBlockLocationsResponseProto.base);
240}
241
242::google::protobuf::Metadata file_level_metadata[10];
243const ::google::protobuf::ServiceDescriptor* file_level_service_descriptors[1];
244
245const ::google::protobuf::uint32 TableStruct::offsets[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
246 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetReplicaVisibleLengthRequestProto, _has_bits_),
247 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetReplicaVisibleLengthRequestProto, _internal_metadata_),
248 ~0u, // no _extensions_
249 ~0u, // no _oneof_case_
250 ~0u, // no _weak_field_map_
251 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetReplicaVisibleLengthRequestProto, block_),
252 0,
253 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetReplicaVisibleLengthResponseProto, _has_bits_),
254 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetReplicaVisibleLengthResponseProto, _internal_metadata_),
255 ~0u, // no _extensions_
256 ~0u, // no _oneof_case_
257 ~0u, // no _weak_field_map_
258 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetReplicaVisibleLengthResponseProto, length_),
259 0,
260 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::RefreshNamenodesRequestProto, _has_bits_),
261 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::RefreshNamenodesRequestProto, _internal_metadata_),
262 ~0u, // no _extensions_
263 ~0u, // no _oneof_case_
264 ~0u, // no _weak_field_map_
265 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::RefreshNamenodesResponseProto, _has_bits_),
266 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::RefreshNamenodesResponseProto, _internal_metadata_),
267 ~0u, // no _extensions_
268 ~0u, // no _oneof_case_
269 ~0u, // no _weak_field_map_
270 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::DeleteBlockPoolRequestProto, _has_bits_),
271 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::DeleteBlockPoolRequestProto, _internal_metadata_),
272 ~0u, // no _extensions_
273 ~0u, // no _oneof_case_
274 ~0u, // no _weak_field_map_
275 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::DeleteBlockPoolRequestProto, blockpool_),
276 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::DeleteBlockPoolRequestProto, force_),
277 0,
278 1,
279 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::DeleteBlockPoolResponseProto, _has_bits_),
280 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::DeleteBlockPoolResponseProto, _internal_metadata_),
281 ~0u, // no _extensions_
282 ~0u, // no _oneof_case_
283 ~0u, // no _weak_field_map_
284 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetBlockLocalPathInfoRequestProto, _has_bits_),
285 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetBlockLocalPathInfoRequestProto, _internal_metadata_),
286 ~0u, // no _extensions_
287 ~0u, // no _oneof_case_
288 ~0u, // no _weak_field_map_
289 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetBlockLocalPathInfoRequestProto, block_),
290 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetBlockLocalPathInfoRequestProto, token_),
291 0,
292 1,
293 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetBlockLocalPathInfoResponseProto, _has_bits_),
294 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetBlockLocalPathInfoResponseProto, _internal_metadata_),
295 ~0u, // no _extensions_
296 ~0u, // no _oneof_case_
297 ~0u, // no _weak_field_map_
298 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetBlockLocalPathInfoResponseProto, block_),
299 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetBlockLocalPathInfoResponseProto, localpath_),
300 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetBlockLocalPathInfoResponseProto, localmetapath_),
301 2,
302 0,
303 1,
304 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetHdfsBlockLocationsRequestProto, _has_bits_),
305 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetHdfsBlockLocationsRequestProto, _internal_metadata_),
306 ~0u, // no _extensions_
307 ~0u, // no _oneof_case_
308 ~0u, // no _weak_field_map_
309 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetHdfsBlockLocationsRequestProto, blocks_),
310 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetHdfsBlockLocationsRequestProto, tokens_),
311 ~0u,
312 ~0u,
313 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetHdfsBlockLocationsResponseProto, _has_bits_),
314 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetHdfsBlockLocationsResponseProto, _internal_metadata_),
315 ~0u, // no _extensions_
316 ~0u, // no _oneof_case_
317 ~0u, // no _weak_field_map_
318 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetHdfsBlockLocationsResponseProto, volumeids_),
319 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::GetHdfsBlockLocationsResponseProto, volumeindexes_),
320 ~0u,
321 ~0u,
322};
323static const ::google::protobuf::internal::MigrationSchema schemas[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
324 { 0, 6, sizeof(::Hdfs::Internal::GetReplicaVisibleLengthRequestProto)},
325 { 7, 13, sizeof(::Hdfs::Internal::GetReplicaVisibleLengthResponseProto)},
326 { 14, 19, sizeof(::Hdfs::Internal::RefreshNamenodesRequestProto)},
327 { 19, 24, sizeof(::Hdfs::Internal::RefreshNamenodesResponseProto)},
328 { 24, 31, sizeof(::Hdfs::Internal::DeleteBlockPoolRequestProto)},
329 { 33, 38, sizeof(::Hdfs::Internal::DeleteBlockPoolResponseProto)},
330 { 38, 45, sizeof(::Hdfs::Internal::GetBlockLocalPathInfoRequestProto)},
331 { 47, 55, sizeof(::Hdfs::Internal::GetBlockLocalPathInfoResponseProto)},
332 { 58, 65, sizeof(::Hdfs::Internal::GetHdfsBlockLocationsRequestProto)},
333 { 67, 74, sizeof(::Hdfs::Internal::GetHdfsBlockLocationsResponseProto)},
334};
335
336static ::google::protobuf::Message const * const file_default_instances[] = {
337 reinterpret_cast<const ::google::protobuf::Message*>(&::Hdfs::Internal::_GetReplicaVisibleLengthRequestProto_default_instance_),
338 reinterpret_cast<const ::google::protobuf::Message*>(&::Hdfs::Internal::_GetReplicaVisibleLengthResponseProto_default_instance_),
339 reinterpret_cast<const ::google::protobuf::Message*>(&::Hdfs::Internal::_RefreshNamenodesRequestProto_default_instance_),
340 reinterpret_cast<const ::google::protobuf::Message*>(&::Hdfs::Internal::_RefreshNamenodesResponseProto_default_instance_),
341 reinterpret_cast<const ::google::protobuf::Message*>(&::Hdfs::Internal::_DeleteBlockPoolRequestProto_default_instance_),
342 reinterpret_cast<const ::google::protobuf::Message*>(&::Hdfs::Internal::_DeleteBlockPoolResponseProto_default_instance_),
343 reinterpret_cast<const ::google::protobuf::Message*>(&::Hdfs::Internal::_GetBlockLocalPathInfoRequestProto_default_instance_),
344 reinterpret_cast<const ::google::protobuf::Message*>(&::Hdfs::Internal::_GetBlockLocalPathInfoResponseProto_default_instance_),
345 reinterpret_cast<const ::google::protobuf::Message*>(&::Hdfs::Internal::_GetHdfsBlockLocationsRequestProto_default_instance_),
346 reinterpret_cast<const ::google::protobuf::Message*>(&::Hdfs::Internal::_GetHdfsBlockLocationsResponseProto_default_instance_),
347};
348
349void protobuf_AssignDescriptors() {
350 AddDescriptors();
351 AssignDescriptors(
352 "ClientDatanodeProtocol.proto", schemas, file_default_instances, TableStruct::offsets,
353 file_level_metadata, NULL, file_level_service_descriptors);
354}
355
356void protobuf_AssignDescriptorsOnce() {
357 static ::google::protobuf::internal::once_flag once;
358 ::google::protobuf::internal::call_once(once, protobuf_AssignDescriptors);
359}
360
361void protobuf_RegisterTypes(const ::std::string&) GOOGLE_PROTOBUF_ATTRIBUTE_COLD;
362void protobuf_RegisterTypes(const ::std::string&) {
363 protobuf_AssignDescriptorsOnce();
364 ::google::protobuf::internal::RegisterAllTypes(file_level_metadata, 10);
365}
366
367void AddDescriptorsImpl() {
368 InitDefaults();
369 static const char descriptor[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
370 "\n\034ClientDatanodeProtocol.proto\022\rHdfs.Int"
371 "ernal\032\nhdfs.proto\032\016Security.proto\"W\n#Get"
372 "ReplicaVisibleLengthRequestProto\0220\n\005bloc"
373 "k\030\001 \002(\0132!.Hdfs.Internal.ExtendedBlockPro"
374 "to\"6\n$GetReplicaVisibleLengthResponsePro"
375 "to\022\016\n\006length\030\001 \002(\004\"\036\n\034RefreshNamenodesRe"
376 "questProto\"\037\n\035RefreshNamenodesResponsePr"
377 "oto\"\?\n\033DeleteBlockPoolRequestProto\022\021\n\tbl"
378 "ockPool\030\001 \002(\t\022\r\n\005force\030\002 \002(\010\"\036\n\034DeleteBl"
379 "ockPoolResponseProto\"\177\n!GetBlockLocalPat"
380 "hInfoRequestProto\0220\n\005block\030\001 \002(\0132!.Hdfs."
381 "Internal.ExtendedBlockProto\022(\n\005token\030\002 \002"
382 "(\0132\031.Hdfs.Internal.TokenProto\"\200\001\n\"GetBlo"
383 "ckLocalPathInfoResponseProto\0220\n\005block\030\001 "
384 "\002(\0132!.Hdfs.Internal.ExtendedBlockProto\022\021"
385 "\n\tlocalPath\030\002 \002(\t\022\025\n\rlocalMetaPath\030\003 \002(\t"
386 "\"\201\001\n!GetHdfsBlockLocationsRequestProto\0221"
387 "\n\006blocks\030\001 \003(\0132!.Hdfs.Internal.ExtendedB"
388 "lockProto\022)\n\006tokens\030\002 \003(\0132\031.Hdfs.Interna"
389 "l.TokenProto\"N\n\"GetHdfsBlockLocationsRes"
390 "ponseProto\022\021\n\tvolumeIds\030\001 \003(\014\022\025\n\rvolumeI"
391 "ndexes\030\002 \003(\r2\373\004\n\035ClientDatanodeProtocolS"
392 "ervice\022\202\001\n\027getReplicaVisibleLength\0222.Hdf"
393 "s.Internal.GetReplicaVisibleLengthReques"
394 "tProto\0323.Hdfs.Internal.GetReplicaVisible"
395 "LengthResponseProto\022m\n\020refreshNamenodes\022"
396 "+.Hdfs.Internal.RefreshNamenodesRequestP"
397 "roto\032,.Hdfs.Internal.RefreshNamenodesRes"
398 "ponseProto\022j\n\017deleteBlockPool\022*.Hdfs.Int"
399 "ernal.DeleteBlockPoolRequestProto\032+.Hdfs"
400 ".Internal.DeleteBlockPoolResponseProto\022|"
401 "\n\025getBlockLocalPathInfo\0220.Hdfs.Internal."
402 "GetBlockLocalPathInfoRequestProto\0321.Hdfs"
403 ".Internal.GetBlockLocalPathInfoResponseP"
404 "roto\022|\n\025getHdfsBlockLocations\0220.Hdfs.Int"
405 "ernal.GetHdfsBlockLocationsRequestProto\032"
406 "1.Hdfs.Internal.GetHdfsBlockLocationsRes"
407 "ponseProtoBN\n%org.apache.hadoop.hdfs.pro"
408 "tocol.protoB\034ClientDatanodeProtocolProto"
409 "s\200\001\001\210\001\001\240\001\001"
410 };
411 ::google::protobuf::DescriptorPool::InternalAddGeneratedFile(
412 descriptor, 1570);
413 ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(
414 "ClientDatanodeProtocol.proto", &protobuf_RegisterTypes);
415 ::protobuf_hdfs_2eproto::AddDescriptors();
416 ::protobuf_Security_2eproto::AddDescriptors();
417}
418
419void AddDescriptors() {
420 static ::google::protobuf::internal::once_flag once;
421 ::google::protobuf::internal::call_once(once, AddDescriptorsImpl);
422}
423// Force AddDescriptors() to be called at dynamic initialization time.
424struct StaticDescriptorInitializer {
425 StaticDescriptorInitializer() {
426 AddDescriptors();
427 }
428} static_descriptor_initializer;
429} // namespace protobuf_ClientDatanodeProtocol_2eproto
430namespace Hdfs {
431namespace Internal {
432
433// ===================================================================
434
435void GetReplicaVisibleLengthRequestProto::InitAsDefaultInstance() {
436 ::Hdfs::Internal::_GetReplicaVisibleLengthRequestProto_default_instance_._instance.get_mutable()->block_ = const_cast< ::Hdfs::Internal::ExtendedBlockProto*>(
437 ::Hdfs::Internal::ExtendedBlockProto::internal_default_instance());
438}
439void GetReplicaVisibleLengthRequestProto::clear_block() {
440 if (block_ != NULL) block_->Clear();
441 clear_has_block();
442}
443#if !defined(_MSC_VER) || _MSC_VER >= 1900
444const int GetReplicaVisibleLengthRequestProto::kBlockFieldNumber;
445#endif // !defined(_MSC_VER) || _MSC_VER >= 1900
446
447GetReplicaVisibleLengthRequestProto::GetReplicaVisibleLengthRequestProto()
448 : ::google::protobuf::Message(), _internal_metadata_(NULL) {
449 ::google::protobuf::internal::InitSCC(
450 &protobuf_ClientDatanodeProtocol_2eproto::scc_info_GetReplicaVisibleLengthRequestProto.base);
451 SharedCtor();
452 // @@protoc_insertion_point(constructor:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
453}
454GetReplicaVisibleLengthRequestProto::GetReplicaVisibleLengthRequestProto(const GetReplicaVisibleLengthRequestProto& from)
455 : ::google::protobuf::Message(),
456 _internal_metadata_(NULL),
457 _has_bits_(from._has_bits_) {
458 _internal_metadata_.MergeFrom(from._internal_metadata_);
459 if (from.has_block()) {
460 block_ = new ::Hdfs::Internal::ExtendedBlockProto(*from.block_);
461 } else {
462 block_ = NULL;
463 }
464 // @@protoc_insertion_point(copy_constructor:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
465}
466
467void GetReplicaVisibleLengthRequestProto::SharedCtor() {
468 block_ = NULL;
469}
470
471GetReplicaVisibleLengthRequestProto::~GetReplicaVisibleLengthRequestProto() {
472 // @@protoc_insertion_point(destructor:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
473 SharedDtor();
474}
475
476void GetReplicaVisibleLengthRequestProto::SharedDtor() {
477 if (this != internal_default_instance()) delete block_;
478}
479
480void GetReplicaVisibleLengthRequestProto::SetCachedSize(int size) const {
481 _cached_size_.Set(size);
482}
483const ::google::protobuf::Descriptor* GetReplicaVisibleLengthRequestProto::descriptor() {
484 ::protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
485 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
486}
487
488const GetReplicaVisibleLengthRequestProto& GetReplicaVisibleLengthRequestProto::default_instance() {
489 ::google::protobuf::internal::InitSCC(&protobuf_ClientDatanodeProtocol_2eproto::scc_info_GetReplicaVisibleLengthRequestProto.base);
490 return *internal_default_instance();
491}
492
493
494void GetReplicaVisibleLengthRequestProto::Clear() {
495// @@protoc_insertion_point(message_clear_start:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
496 ::google::protobuf::uint32 cached_has_bits = 0;
497 // Prevent compiler warnings about cached_has_bits being unused
498 (void) cached_has_bits;
499
500 cached_has_bits = _has_bits_[0];
501 if (cached_has_bits & 0x00000001u) {
502 GOOGLE_DCHECK(block_ != NULL);
503 block_->Clear();
504 }
505 _has_bits_.Clear();
506 _internal_metadata_.Clear();
507}
508
509bool GetReplicaVisibleLengthRequestProto::MergePartialFromCodedStream(
510 ::google::protobuf::io::CodedInputStream* input) {
511#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
512 ::google::protobuf::uint32 tag;
513 // @@protoc_insertion_point(parse_start:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
514 for (;;) {
515 ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
516 tag = p.first;
517 if (!p.second) goto handle_unusual;
518 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
519 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
520 case 1: {
521 if (static_cast< ::google::protobuf::uint8>(tag) ==
522 static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
523 DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
524 input, mutable_block()));
525 } else {
526 goto handle_unusual;
527 }
528 break;
529 }
530
531 default: {
532 handle_unusual:
533 if (tag == 0) {
534 goto success;
535 }
536 DO_(::google::protobuf::internal::WireFormat::SkipField(
537 input, tag, _internal_metadata_.mutable_unknown_fields()));
538 break;
539 }
540 }
541 }
542success:
543 // @@protoc_insertion_point(parse_success:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
544 return true;
545failure:
546 // @@protoc_insertion_point(parse_failure:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
547 return false;
548#undef DO_
549}
550
551void GetReplicaVisibleLengthRequestProto::SerializeWithCachedSizes(
552 ::google::protobuf::io::CodedOutputStream* output) const {
553 // @@protoc_insertion_point(serialize_start:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
554 ::google::protobuf::uint32 cached_has_bits = 0;
555 (void) cached_has_bits;
556
557 cached_has_bits = _has_bits_[0];
558 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
559 if (cached_has_bits & 0x00000001u) {
560 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
561 1, this->_internal_block(), output);
562 }
563
564 if (_internal_metadata_.have_unknown_fields()) {
565 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
566 _internal_metadata_.unknown_fields(), output);
567 }
568 // @@protoc_insertion_point(serialize_end:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
569}
570
571::google::protobuf::uint8* GetReplicaVisibleLengthRequestProto::InternalSerializeWithCachedSizesToArray(
572 bool deterministic, ::google::protobuf::uint8* target) const {
573 (void)deterministic; // Unused
574 // @@protoc_insertion_point(serialize_to_array_start:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
575 ::google::protobuf::uint32 cached_has_bits = 0;
576 (void) cached_has_bits;
577
578 cached_has_bits = _has_bits_[0];
579 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
580 if (cached_has_bits & 0x00000001u) {
581 target = ::google::protobuf::internal::WireFormatLite::
582 InternalWriteMessageToArray(
583 1, this->_internal_block(), deterministic, target);
584 }
585
586 if (_internal_metadata_.have_unknown_fields()) {
587 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
588 _internal_metadata_.unknown_fields(), target);
589 }
590 // @@protoc_insertion_point(serialize_to_array_end:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
591 return target;
592}
593
594size_t GetReplicaVisibleLengthRequestProto::ByteSizeLong() const {
595// @@protoc_insertion_point(message_byte_size_start:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
596 size_t total_size = 0;
597
598 if (_internal_metadata_.have_unknown_fields()) {
599 total_size +=
600 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
601 _internal_metadata_.unknown_fields());
602 }
603 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
604 if (has_block()) {
605 total_size += 1 +
606 ::google::protobuf::internal::WireFormatLite::MessageSize(
607 *block_);
608 }
609 int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
610 SetCachedSize(cached_size);
611 return total_size;
612}
613
614void GetReplicaVisibleLengthRequestProto::MergeFrom(const ::google::protobuf::Message& from) {
615// @@protoc_insertion_point(generalized_merge_from_start:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
616 GOOGLE_DCHECK_NE(&from, this);
617 const GetReplicaVisibleLengthRequestProto* source =
618 ::google::protobuf::internal::DynamicCastToGenerated<const GetReplicaVisibleLengthRequestProto>(
619 &from);
620 if (source == NULL) {
621 // @@protoc_insertion_point(generalized_merge_from_cast_fail:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
622 ::google::protobuf::internal::ReflectionOps::Merge(from, this);
623 } else {
624 // @@protoc_insertion_point(generalized_merge_from_cast_success:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
625 MergeFrom(*source);
626 }
627}
628
629void GetReplicaVisibleLengthRequestProto::MergeFrom(const GetReplicaVisibleLengthRequestProto& from) {
630// @@protoc_insertion_point(class_specific_merge_from_start:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
631 GOOGLE_DCHECK_NE(&from, this);
632 _internal_metadata_.MergeFrom(from._internal_metadata_);
633 ::google::protobuf::uint32 cached_has_bits = 0;
634 (void) cached_has_bits;
635
636 if (from.has_block()) {
637 mutable_block()->::Hdfs::Internal::ExtendedBlockProto::MergeFrom(from.block());
638 }
639}
640
641void GetReplicaVisibleLengthRequestProto::CopyFrom(const ::google::protobuf::Message& from) {
642// @@protoc_insertion_point(generalized_copy_from_start:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
643 if (&from == this) return;
644 Clear();
645 MergeFrom(from);
646}
647
648void GetReplicaVisibleLengthRequestProto::CopyFrom(const GetReplicaVisibleLengthRequestProto& from) {
649// @@protoc_insertion_point(class_specific_copy_from_start:Hdfs.Internal.GetReplicaVisibleLengthRequestProto)
650 if (&from == this) return;
651 Clear();
652 MergeFrom(from);
653}
654
655bool GetReplicaVisibleLengthRequestProto::IsInitialized() const {
656 if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false;
657 if (has_block()) {
658 if (!this->block_->IsInitialized()) return false;
659 }
660 return true;
661}
662
663void GetReplicaVisibleLengthRequestProto::Swap(GetReplicaVisibleLengthRequestProto* other) {
664 if (other == this) return;
665 InternalSwap(other);
666}
667void GetReplicaVisibleLengthRequestProto::InternalSwap(GetReplicaVisibleLengthRequestProto* other) {
668 using std::swap;
669 swap(block_, other->block_);
670 swap(_has_bits_[0], other->_has_bits_[0]);
671 _internal_metadata_.Swap(&other->_internal_metadata_);
672}
673
674::google::protobuf::Metadata GetReplicaVisibleLengthRequestProto::GetMetadata() const {
675 protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
676 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages];
677}
678
679
680// ===================================================================
681
682void GetReplicaVisibleLengthResponseProto::InitAsDefaultInstance() {
683}
684#if !defined(_MSC_VER) || _MSC_VER >= 1900
685const int GetReplicaVisibleLengthResponseProto::kLengthFieldNumber;
686#endif // !defined(_MSC_VER) || _MSC_VER >= 1900
687
688GetReplicaVisibleLengthResponseProto::GetReplicaVisibleLengthResponseProto()
689 : ::google::protobuf::Message(), _internal_metadata_(NULL) {
690 ::google::protobuf::internal::InitSCC(
691 &protobuf_ClientDatanodeProtocol_2eproto::scc_info_GetReplicaVisibleLengthResponseProto.base);
692 SharedCtor();
693 // @@protoc_insertion_point(constructor:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
694}
695GetReplicaVisibleLengthResponseProto::GetReplicaVisibleLengthResponseProto(const GetReplicaVisibleLengthResponseProto& from)
696 : ::google::protobuf::Message(),
697 _internal_metadata_(NULL),
698 _has_bits_(from._has_bits_) {
699 _internal_metadata_.MergeFrom(from._internal_metadata_);
700 length_ = from.length_;
701 // @@protoc_insertion_point(copy_constructor:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
702}
703
704void GetReplicaVisibleLengthResponseProto::SharedCtor() {
705 length_ = GOOGLE_ULONGLONG(0);
706}
707
708GetReplicaVisibleLengthResponseProto::~GetReplicaVisibleLengthResponseProto() {
709 // @@protoc_insertion_point(destructor:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
710 SharedDtor();
711}
712
713void GetReplicaVisibleLengthResponseProto::SharedDtor() {
714}
715
716void GetReplicaVisibleLengthResponseProto::SetCachedSize(int size) const {
717 _cached_size_.Set(size);
718}
719const ::google::protobuf::Descriptor* GetReplicaVisibleLengthResponseProto::descriptor() {
720 ::protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
721 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
722}
723
724const GetReplicaVisibleLengthResponseProto& GetReplicaVisibleLengthResponseProto::default_instance() {
725 ::google::protobuf::internal::InitSCC(&protobuf_ClientDatanodeProtocol_2eproto::scc_info_GetReplicaVisibleLengthResponseProto.base);
726 return *internal_default_instance();
727}
728
729
730void GetReplicaVisibleLengthResponseProto::Clear() {
731// @@protoc_insertion_point(message_clear_start:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
732 ::google::protobuf::uint32 cached_has_bits = 0;
733 // Prevent compiler warnings about cached_has_bits being unused
734 (void) cached_has_bits;
735
736 length_ = GOOGLE_ULONGLONG(0);
737 _has_bits_.Clear();
738 _internal_metadata_.Clear();
739}
740
741bool GetReplicaVisibleLengthResponseProto::MergePartialFromCodedStream(
742 ::google::protobuf::io::CodedInputStream* input) {
743#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
744 ::google::protobuf::uint32 tag;
745 // @@protoc_insertion_point(parse_start:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
746 for (;;) {
747 ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
748 tag = p.first;
749 if (!p.second) goto handle_unusual;
750 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
751 // required uint64 length = 1;
752 case 1: {
753 if (static_cast< ::google::protobuf::uint8>(tag) ==
754 static_cast< ::google::protobuf::uint8>(8u /* 8 & 0xFF */)) {
755 set_has_length();
756 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
757 ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>(
758 input, &length_)));
759 } else {
760 goto handle_unusual;
761 }
762 break;
763 }
764
765 default: {
766 handle_unusual:
767 if (tag == 0) {
768 goto success;
769 }
770 DO_(::google::protobuf::internal::WireFormat::SkipField(
771 input, tag, _internal_metadata_.mutable_unknown_fields()));
772 break;
773 }
774 }
775 }
776success:
777 // @@protoc_insertion_point(parse_success:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
778 return true;
779failure:
780 // @@protoc_insertion_point(parse_failure:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
781 return false;
782#undef DO_
783}
784
785void GetReplicaVisibleLengthResponseProto::SerializeWithCachedSizes(
786 ::google::protobuf::io::CodedOutputStream* output) const {
787 // @@protoc_insertion_point(serialize_start:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
788 ::google::protobuf::uint32 cached_has_bits = 0;
789 (void) cached_has_bits;
790
791 cached_has_bits = _has_bits_[0];
792 // required uint64 length = 1;
793 if (cached_has_bits & 0x00000001u) {
794 ::google::protobuf::internal::WireFormatLite::WriteUInt64(1, this->length(), output);
795 }
796
797 if (_internal_metadata_.have_unknown_fields()) {
798 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
799 _internal_metadata_.unknown_fields(), output);
800 }
801 // @@protoc_insertion_point(serialize_end:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
802}
803
804::google::protobuf::uint8* GetReplicaVisibleLengthResponseProto::InternalSerializeWithCachedSizesToArray(
805 bool deterministic, ::google::protobuf::uint8* target) const {
806 (void)deterministic; // Unused
807 // @@protoc_insertion_point(serialize_to_array_start:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
808 ::google::protobuf::uint32 cached_has_bits = 0;
809 (void) cached_has_bits;
810
811 cached_has_bits = _has_bits_[0];
812 // required uint64 length = 1;
813 if (cached_has_bits & 0x00000001u) {
814 target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(1, this->length(), target);
815 }
816
817 if (_internal_metadata_.have_unknown_fields()) {
818 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
819 _internal_metadata_.unknown_fields(), target);
820 }
821 // @@protoc_insertion_point(serialize_to_array_end:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
822 return target;
823}
824
825size_t GetReplicaVisibleLengthResponseProto::ByteSizeLong() const {
826// @@protoc_insertion_point(message_byte_size_start:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
827 size_t total_size = 0;
828
829 if (_internal_metadata_.have_unknown_fields()) {
830 total_size +=
831 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
832 _internal_metadata_.unknown_fields());
833 }
834 // required uint64 length = 1;
835 if (has_length()) {
836 total_size += 1 +
837 ::google::protobuf::internal::WireFormatLite::UInt64Size(
838 this->length());
839 }
840 int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
841 SetCachedSize(cached_size);
842 return total_size;
843}
844
845void GetReplicaVisibleLengthResponseProto::MergeFrom(const ::google::protobuf::Message& from) {
846// @@protoc_insertion_point(generalized_merge_from_start:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
847 GOOGLE_DCHECK_NE(&from, this);
848 const GetReplicaVisibleLengthResponseProto* source =
849 ::google::protobuf::internal::DynamicCastToGenerated<const GetReplicaVisibleLengthResponseProto>(
850 &from);
851 if (source == NULL) {
852 // @@protoc_insertion_point(generalized_merge_from_cast_fail:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
853 ::google::protobuf::internal::ReflectionOps::Merge(from, this);
854 } else {
855 // @@protoc_insertion_point(generalized_merge_from_cast_success:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
856 MergeFrom(*source);
857 }
858}
859
860void GetReplicaVisibleLengthResponseProto::MergeFrom(const GetReplicaVisibleLengthResponseProto& from) {
861// @@protoc_insertion_point(class_specific_merge_from_start:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
862 GOOGLE_DCHECK_NE(&from, this);
863 _internal_metadata_.MergeFrom(from._internal_metadata_);
864 ::google::protobuf::uint32 cached_has_bits = 0;
865 (void) cached_has_bits;
866
867 if (from.has_length()) {
868 set_length(from.length());
869 }
870}
871
872void GetReplicaVisibleLengthResponseProto::CopyFrom(const ::google::protobuf::Message& from) {
873// @@protoc_insertion_point(generalized_copy_from_start:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
874 if (&from == this) return;
875 Clear();
876 MergeFrom(from);
877}
878
879void GetReplicaVisibleLengthResponseProto::CopyFrom(const GetReplicaVisibleLengthResponseProto& from) {
880// @@protoc_insertion_point(class_specific_copy_from_start:Hdfs.Internal.GetReplicaVisibleLengthResponseProto)
881 if (&from == this) return;
882 Clear();
883 MergeFrom(from);
884}
885
886bool GetReplicaVisibleLengthResponseProto::IsInitialized() const {
887 if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false;
888 return true;
889}
890
891void GetReplicaVisibleLengthResponseProto::Swap(GetReplicaVisibleLengthResponseProto* other) {
892 if (other == this) return;
893 InternalSwap(other);
894}
895void GetReplicaVisibleLengthResponseProto::InternalSwap(GetReplicaVisibleLengthResponseProto* other) {
896 using std::swap;
897 swap(length_, other->length_);
898 swap(_has_bits_[0], other->_has_bits_[0]);
899 _internal_metadata_.Swap(&other->_internal_metadata_);
900}
901
902::google::protobuf::Metadata GetReplicaVisibleLengthResponseProto::GetMetadata() const {
903 protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
904 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages];
905}
906
907
908// ===================================================================
909
910void RefreshNamenodesRequestProto::InitAsDefaultInstance() {
911}
912#if !defined(_MSC_VER) || _MSC_VER >= 1900
913#endif // !defined(_MSC_VER) || _MSC_VER >= 1900
914
915RefreshNamenodesRequestProto::RefreshNamenodesRequestProto()
916 : ::google::protobuf::Message(), _internal_metadata_(NULL) {
917 ::google::protobuf::internal::InitSCC(
918 &protobuf_ClientDatanodeProtocol_2eproto::scc_info_RefreshNamenodesRequestProto.base);
919 SharedCtor();
920 // @@protoc_insertion_point(constructor:Hdfs.Internal.RefreshNamenodesRequestProto)
921}
922RefreshNamenodesRequestProto::RefreshNamenodesRequestProto(const RefreshNamenodesRequestProto& from)
923 : ::google::protobuf::Message(),
924 _internal_metadata_(NULL),
925 _has_bits_(from._has_bits_) {
926 _internal_metadata_.MergeFrom(from._internal_metadata_);
927 // @@protoc_insertion_point(copy_constructor:Hdfs.Internal.RefreshNamenodesRequestProto)
928}
929
930void RefreshNamenodesRequestProto::SharedCtor() {
931}
932
933RefreshNamenodesRequestProto::~RefreshNamenodesRequestProto() {
934 // @@protoc_insertion_point(destructor:Hdfs.Internal.RefreshNamenodesRequestProto)
935 SharedDtor();
936}
937
938void RefreshNamenodesRequestProto::SharedDtor() {
939}
940
941void RefreshNamenodesRequestProto::SetCachedSize(int size) const {
942 _cached_size_.Set(size);
943}
944const ::google::protobuf::Descriptor* RefreshNamenodesRequestProto::descriptor() {
945 ::protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
946 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
947}
948
949const RefreshNamenodesRequestProto& RefreshNamenodesRequestProto::default_instance() {
950 ::google::protobuf::internal::InitSCC(&protobuf_ClientDatanodeProtocol_2eproto::scc_info_RefreshNamenodesRequestProto.base);
951 return *internal_default_instance();
952}
953
954
955void RefreshNamenodesRequestProto::Clear() {
956// @@protoc_insertion_point(message_clear_start:Hdfs.Internal.RefreshNamenodesRequestProto)
957 ::google::protobuf::uint32 cached_has_bits = 0;
958 // Prevent compiler warnings about cached_has_bits being unused
959 (void) cached_has_bits;
960
961 _has_bits_.Clear();
962 _internal_metadata_.Clear();
963}
964
965bool RefreshNamenodesRequestProto::MergePartialFromCodedStream(
966 ::google::protobuf::io::CodedInputStream* input) {
967#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
968 ::google::protobuf::uint32 tag;
969 // @@protoc_insertion_point(parse_start:Hdfs.Internal.RefreshNamenodesRequestProto)
970 for (;;) {
971 ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
972 tag = p.first;
973 if (!p.second) goto handle_unusual;
974 handle_unusual:
975 if (tag == 0) {
976 goto success;
977 }
978 DO_(::google::protobuf::internal::WireFormat::SkipField(
979 input, tag, _internal_metadata_.mutable_unknown_fields()));
980 }
981success:
982 // @@protoc_insertion_point(parse_success:Hdfs.Internal.RefreshNamenodesRequestProto)
983 return true;
984failure:
985 // @@protoc_insertion_point(parse_failure:Hdfs.Internal.RefreshNamenodesRequestProto)
986 return false;
987#undef DO_
988}
989
990void RefreshNamenodesRequestProto::SerializeWithCachedSizes(
991 ::google::protobuf::io::CodedOutputStream* output) const {
992 // @@protoc_insertion_point(serialize_start:Hdfs.Internal.RefreshNamenodesRequestProto)
993 ::google::protobuf::uint32 cached_has_bits = 0;
994 (void) cached_has_bits;
995
996 if (_internal_metadata_.have_unknown_fields()) {
997 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
998 _internal_metadata_.unknown_fields(), output);
999 }
1000 // @@protoc_insertion_point(serialize_end:Hdfs.Internal.RefreshNamenodesRequestProto)
1001}
1002
1003::google::protobuf::uint8* RefreshNamenodesRequestProto::InternalSerializeWithCachedSizesToArray(
1004 bool deterministic, ::google::protobuf::uint8* target) const {
1005 (void)deterministic; // Unused
1006 // @@protoc_insertion_point(serialize_to_array_start:Hdfs.Internal.RefreshNamenodesRequestProto)
1007 ::google::protobuf::uint32 cached_has_bits = 0;
1008 (void) cached_has_bits;
1009
1010 if (_internal_metadata_.have_unknown_fields()) {
1011 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1012 _internal_metadata_.unknown_fields(), target);
1013 }
1014 // @@protoc_insertion_point(serialize_to_array_end:Hdfs.Internal.RefreshNamenodesRequestProto)
1015 return target;
1016}
1017
1018size_t RefreshNamenodesRequestProto::ByteSizeLong() const {
1019// @@protoc_insertion_point(message_byte_size_start:Hdfs.Internal.RefreshNamenodesRequestProto)
1020 size_t total_size = 0;
1021
1022 if (_internal_metadata_.have_unknown_fields()) {
1023 total_size +=
1024 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1025 _internal_metadata_.unknown_fields());
1026 }
1027 int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
1028 SetCachedSize(cached_size);
1029 return total_size;
1030}
1031
1032void RefreshNamenodesRequestProto::MergeFrom(const ::google::protobuf::Message& from) {
1033// @@protoc_insertion_point(generalized_merge_from_start:Hdfs.Internal.RefreshNamenodesRequestProto)
1034 GOOGLE_DCHECK_NE(&from, this);
1035 const RefreshNamenodesRequestProto* source =
1036 ::google::protobuf::internal::DynamicCastToGenerated<const RefreshNamenodesRequestProto>(
1037 &from);
1038 if (source == NULL) {
1039 // @@protoc_insertion_point(generalized_merge_from_cast_fail:Hdfs.Internal.RefreshNamenodesRequestProto)
1040 ::google::protobuf::internal::ReflectionOps::Merge(from, this);
1041 } else {
1042 // @@protoc_insertion_point(generalized_merge_from_cast_success:Hdfs.Internal.RefreshNamenodesRequestProto)
1043 MergeFrom(*source);
1044 }
1045}
1046
1047void RefreshNamenodesRequestProto::MergeFrom(const RefreshNamenodesRequestProto& from) {
1048// @@protoc_insertion_point(class_specific_merge_from_start:Hdfs.Internal.RefreshNamenodesRequestProto)
1049 GOOGLE_DCHECK_NE(&from, this);
1050 _internal_metadata_.MergeFrom(from._internal_metadata_);
1051 ::google::protobuf::uint32 cached_has_bits = 0;
1052 (void) cached_has_bits;
1053
1054}
1055
1056void RefreshNamenodesRequestProto::CopyFrom(const ::google::protobuf::Message& from) {
1057// @@protoc_insertion_point(generalized_copy_from_start:Hdfs.Internal.RefreshNamenodesRequestProto)
1058 if (&from == this) return;
1059 Clear();
1060 MergeFrom(from);
1061}
1062
1063void RefreshNamenodesRequestProto::CopyFrom(const RefreshNamenodesRequestProto& from) {
1064// @@protoc_insertion_point(class_specific_copy_from_start:Hdfs.Internal.RefreshNamenodesRequestProto)
1065 if (&from == this) return;
1066 Clear();
1067 MergeFrom(from);
1068}
1069
1070bool RefreshNamenodesRequestProto::IsInitialized() const {
1071 return true;
1072}
1073
1074void RefreshNamenodesRequestProto::Swap(RefreshNamenodesRequestProto* other) {
1075 if (other == this) return;
1076 InternalSwap(other);
1077}
1078void RefreshNamenodesRequestProto::InternalSwap(RefreshNamenodesRequestProto* other) {
1079 using std::swap;
1080 swap(_has_bits_[0], other->_has_bits_[0]);
1081 _internal_metadata_.Swap(&other->_internal_metadata_);
1082}
1083
1084::google::protobuf::Metadata RefreshNamenodesRequestProto::GetMetadata() const {
1085 protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
1086 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages];
1087}
1088
1089
1090// ===================================================================
1091
1092void RefreshNamenodesResponseProto::InitAsDefaultInstance() {
1093}
1094#if !defined(_MSC_VER) || _MSC_VER >= 1900
1095#endif // !defined(_MSC_VER) || _MSC_VER >= 1900
1096
1097RefreshNamenodesResponseProto::RefreshNamenodesResponseProto()
1098 : ::google::protobuf::Message(), _internal_metadata_(NULL) {
1099 ::google::protobuf::internal::InitSCC(
1100 &protobuf_ClientDatanodeProtocol_2eproto::scc_info_RefreshNamenodesResponseProto.base);
1101 SharedCtor();
1102 // @@protoc_insertion_point(constructor:Hdfs.Internal.RefreshNamenodesResponseProto)
1103}
1104RefreshNamenodesResponseProto::RefreshNamenodesResponseProto(const RefreshNamenodesResponseProto& from)
1105 : ::google::protobuf::Message(),
1106 _internal_metadata_(NULL),
1107 _has_bits_(from._has_bits_) {
1108 _internal_metadata_.MergeFrom(from._internal_metadata_);
1109 // @@protoc_insertion_point(copy_constructor:Hdfs.Internal.RefreshNamenodesResponseProto)
1110}
1111
1112void RefreshNamenodesResponseProto::SharedCtor() {
1113}
1114
1115RefreshNamenodesResponseProto::~RefreshNamenodesResponseProto() {
1116 // @@protoc_insertion_point(destructor:Hdfs.Internal.RefreshNamenodesResponseProto)
1117 SharedDtor();
1118}
1119
1120void RefreshNamenodesResponseProto::SharedDtor() {
1121}
1122
1123void RefreshNamenodesResponseProto::SetCachedSize(int size) const {
1124 _cached_size_.Set(size);
1125}
1126const ::google::protobuf::Descriptor* RefreshNamenodesResponseProto::descriptor() {
1127 ::protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
1128 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
1129}
1130
1131const RefreshNamenodesResponseProto& RefreshNamenodesResponseProto::default_instance() {
1132 ::google::protobuf::internal::InitSCC(&protobuf_ClientDatanodeProtocol_2eproto::scc_info_RefreshNamenodesResponseProto.base);
1133 return *internal_default_instance();
1134}
1135
1136
1137void RefreshNamenodesResponseProto::Clear() {
1138// @@protoc_insertion_point(message_clear_start:Hdfs.Internal.RefreshNamenodesResponseProto)
1139 ::google::protobuf::uint32 cached_has_bits = 0;
1140 // Prevent compiler warnings about cached_has_bits being unused
1141 (void) cached_has_bits;
1142
1143 _has_bits_.Clear();
1144 _internal_metadata_.Clear();
1145}
1146
1147bool RefreshNamenodesResponseProto::MergePartialFromCodedStream(
1148 ::google::protobuf::io::CodedInputStream* input) {
1149#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
1150 ::google::protobuf::uint32 tag;
1151 // @@protoc_insertion_point(parse_start:Hdfs.Internal.RefreshNamenodesResponseProto)
1152 for (;;) {
1153 ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
1154 tag = p.first;
1155 if (!p.second) goto handle_unusual;
1156 handle_unusual:
1157 if (tag == 0) {
1158 goto success;
1159 }
1160 DO_(::google::protobuf::internal::WireFormat::SkipField(
1161 input, tag, _internal_metadata_.mutable_unknown_fields()));
1162 }
1163success:
1164 // @@protoc_insertion_point(parse_success:Hdfs.Internal.RefreshNamenodesResponseProto)
1165 return true;
1166failure:
1167 // @@protoc_insertion_point(parse_failure:Hdfs.Internal.RefreshNamenodesResponseProto)
1168 return false;
1169#undef DO_
1170}
1171
1172void RefreshNamenodesResponseProto::SerializeWithCachedSizes(
1173 ::google::protobuf::io::CodedOutputStream* output) const {
1174 // @@protoc_insertion_point(serialize_start:Hdfs.Internal.RefreshNamenodesResponseProto)
1175 ::google::protobuf::uint32 cached_has_bits = 0;
1176 (void) cached_has_bits;
1177
1178 if (_internal_metadata_.have_unknown_fields()) {
1179 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1180 _internal_metadata_.unknown_fields(), output);
1181 }
1182 // @@protoc_insertion_point(serialize_end:Hdfs.Internal.RefreshNamenodesResponseProto)
1183}
1184
1185::google::protobuf::uint8* RefreshNamenodesResponseProto::InternalSerializeWithCachedSizesToArray(
1186 bool deterministic, ::google::protobuf::uint8* target) const {
1187 (void)deterministic; // Unused
1188 // @@protoc_insertion_point(serialize_to_array_start:Hdfs.Internal.RefreshNamenodesResponseProto)
1189 ::google::protobuf::uint32 cached_has_bits = 0;
1190 (void) cached_has_bits;
1191
1192 if (_internal_metadata_.have_unknown_fields()) {
1193 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1194 _internal_metadata_.unknown_fields(), target);
1195 }
1196 // @@protoc_insertion_point(serialize_to_array_end:Hdfs.Internal.RefreshNamenodesResponseProto)
1197 return target;
1198}
1199
1200size_t RefreshNamenodesResponseProto::ByteSizeLong() const {
1201// @@protoc_insertion_point(message_byte_size_start:Hdfs.Internal.RefreshNamenodesResponseProto)
1202 size_t total_size = 0;
1203
1204 if (_internal_metadata_.have_unknown_fields()) {
1205 total_size +=
1206 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1207 _internal_metadata_.unknown_fields());
1208 }
1209 int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
1210 SetCachedSize(cached_size);
1211 return total_size;
1212}
1213
1214void RefreshNamenodesResponseProto::MergeFrom(const ::google::protobuf::Message& from) {
1215// @@protoc_insertion_point(generalized_merge_from_start:Hdfs.Internal.RefreshNamenodesResponseProto)
1216 GOOGLE_DCHECK_NE(&from, this);
1217 const RefreshNamenodesResponseProto* source =
1218 ::google::protobuf::internal::DynamicCastToGenerated<const RefreshNamenodesResponseProto>(
1219 &from);
1220 if (source == NULL) {
1221 // @@protoc_insertion_point(generalized_merge_from_cast_fail:Hdfs.Internal.RefreshNamenodesResponseProto)
1222 ::google::protobuf::internal::ReflectionOps::Merge(from, this);
1223 } else {
1224 // @@protoc_insertion_point(generalized_merge_from_cast_success:Hdfs.Internal.RefreshNamenodesResponseProto)
1225 MergeFrom(*source);
1226 }
1227}
1228
1229void RefreshNamenodesResponseProto::MergeFrom(const RefreshNamenodesResponseProto& from) {
1230// @@protoc_insertion_point(class_specific_merge_from_start:Hdfs.Internal.RefreshNamenodesResponseProto)
1231 GOOGLE_DCHECK_NE(&from, this);
1232 _internal_metadata_.MergeFrom(from._internal_metadata_);
1233 ::google::protobuf::uint32 cached_has_bits = 0;
1234 (void) cached_has_bits;
1235
1236}
1237
1238void RefreshNamenodesResponseProto::CopyFrom(const ::google::protobuf::Message& from) {
1239// @@protoc_insertion_point(generalized_copy_from_start:Hdfs.Internal.RefreshNamenodesResponseProto)
1240 if (&from == this) return;
1241 Clear();
1242 MergeFrom(from);
1243}
1244
1245void RefreshNamenodesResponseProto::CopyFrom(const RefreshNamenodesResponseProto& from) {
1246// @@protoc_insertion_point(class_specific_copy_from_start:Hdfs.Internal.RefreshNamenodesResponseProto)
1247 if (&from == this) return;
1248 Clear();
1249 MergeFrom(from);
1250}
1251
1252bool RefreshNamenodesResponseProto::IsInitialized() const {
1253 return true;
1254}
1255
1256void RefreshNamenodesResponseProto::Swap(RefreshNamenodesResponseProto* other) {
1257 if (other == this) return;
1258 InternalSwap(other);
1259}
1260void RefreshNamenodesResponseProto::InternalSwap(RefreshNamenodesResponseProto* other) {
1261 using std::swap;
1262 swap(_has_bits_[0], other->_has_bits_[0]);
1263 _internal_metadata_.Swap(&other->_internal_metadata_);
1264}
1265
1266::google::protobuf::Metadata RefreshNamenodesResponseProto::GetMetadata() const {
1267 protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
1268 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages];
1269}
1270
1271
1272// ===================================================================
1273
1274void DeleteBlockPoolRequestProto::InitAsDefaultInstance() {
1275}
1276#if !defined(_MSC_VER) || _MSC_VER >= 1900
1277const int DeleteBlockPoolRequestProto::kBlockPoolFieldNumber;
1278const int DeleteBlockPoolRequestProto::kForceFieldNumber;
1279#endif // !defined(_MSC_VER) || _MSC_VER >= 1900
1280
1281DeleteBlockPoolRequestProto::DeleteBlockPoolRequestProto()
1282 : ::google::protobuf::Message(), _internal_metadata_(NULL) {
1283 ::google::protobuf::internal::InitSCC(
1284 &protobuf_ClientDatanodeProtocol_2eproto::scc_info_DeleteBlockPoolRequestProto.base);
1285 SharedCtor();
1286 // @@protoc_insertion_point(constructor:Hdfs.Internal.DeleteBlockPoolRequestProto)
1287}
1288DeleteBlockPoolRequestProto::DeleteBlockPoolRequestProto(const DeleteBlockPoolRequestProto& from)
1289 : ::google::protobuf::Message(),
1290 _internal_metadata_(NULL),
1291 _has_bits_(from._has_bits_) {
1292 _internal_metadata_.MergeFrom(from._internal_metadata_);
1293 blockpool_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1294 if (from.has_blockpool()) {
1295 blockpool_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.blockpool_);
1296 }
1297 force_ = from.force_;
1298 // @@protoc_insertion_point(copy_constructor:Hdfs.Internal.DeleteBlockPoolRequestProto)
1299}
1300
1301void DeleteBlockPoolRequestProto::SharedCtor() {
1302 blockpool_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1303 force_ = false;
1304}
1305
1306DeleteBlockPoolRequestProto::~DeleteBlockPoolRequestProto() {
1307 // @@protoc_insertion_point(destructor:Hdfs.Internal.DeleteBlockPoolRequestProto)
1308 SharedDtor();
1309}
1310
1311void DeleteBlockPoolRequestProto::SharedDtor() {
1312 blockpool_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1313}
1314
1315void DeleteBlockPoolRequestProto::SetCachedSize(int size) const {
1316 _cached_size_.Set(size);
1317}
1318const ::google::protobuf::Descriptor* DeleteBlockPoolRequestProto::descriptor() {
1319 ::protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
1320 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
1321}
1322
1323const DeleteBlockPoolRequestProto& DeleteBlockPoolRequestProto::default_instance() {
1324 ::google::protobuf::internal::InitSCC(&protobuf_ClientDatanodeProtocol_2eproto::scc_info_DeleteBlockPoolRequestProto.base);
1325 return *internal_default_instance();
1326}
1327
1328
1329void DeleteBlockPoolRequestProto::Clear() {
1330// @@protoc_insertion_point(message_clear_start:Hdfs.Internal.DeleteBlockPoolRequestProto)
1331 ::google::protobuf::uint32 cached_has_bits = 0;
1332 // Prevent compiler warnings about cached_has_bits being unused
1333 (void) cached_has_bits;
1334
1335 cached_has_bits = _has_bits_[0];
1336 if (cached_has_bits & 0x00000001u) {
1337 blockpool_.ClearNonDefaultToEmptyNoArena();
1338 }
1339 force_ = false;
1340 _has_bits_.Clear();
1341 _internal_metadata_.Clear();
1342}
1343
1344bool DeleteBlockPoolRequestProto::MergePartialFromCodedStream(
1345 ::google::protobuf::io::CodedInputStream* input) {
1346#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
1347 ::google::protobuf::uint32 tag;
1348 // @@protoc_insertion_point(parse_start:Hdfs.Internal.DeleteBlockPoolRequestProto)
1349 for (;;) {
1350 ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
1351 tag = p.first;
1352 if (!p.second) goto handle_unusual;
1353 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1354 // required string blockPool = 1;
1355 case 1: {
1356 if (static_cast< ::google::protobuf::uint8>(tag) ==
1357 static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
1358 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1359 input, this->mutable_blockpool()));
1360 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
1361 this->blockpool().data(), static_cast<int>(this->blockpool().length()),
1362 ::google::protobuf::internal::WireFormat::PARSE,
1363 "Hdfs.Internal.DeleteBlockPoolRequestProto.blockPool");
1364 } else {
1365 goto handle_unusual;
1366 }
1367 break;
1368 }
1369
1370 // required bool force = 2;
1371 case 2: {
1372 if (static_cast< ::google::protobuf::uint8>(tag) ==
1373 static_cast< ::google::protobuf::uint8>(16u /* 16 & 0xFF */)) {
1374 set_has_force();
1375 DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1376 bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
1377 input, &force_)));
1378 } else {
1379 goto handle_unusual;
1380 }
1381 break;
1382 }
1383
1384 default: {
1385 handle_unusual:
1386 if (tag == 0) {
1387 goto success;
1388 }
1389 DO_(::google::protobuf::internal::WireFormat::SkipField(
1390 input, tag, _internal_metadata_.mutable_unknown_fields()));
1391 break;
1392 }
1393 }
1394 }
1395success:
1396 // @@protoc_insertion_point(parse_success:Hdfs.Internal.DeleteBlockPoolRequestProto)
1397 return true;
1398failure:
1399 // @@protoc_insertion_point(parse_failure:Hdfs.Internal.DeleteBlockPoolRequestProto)
1400 return false;
1401#undef DO_
1402}
1403
1404void DeleteBlockPoolRequestProto::SerializeWithCachedSizes(
1405 ::google::protobuf::io::CodedOutputStream* output) const {
1406 // @@protoc_insertion_point(serialize_start:Hdfs.Internal.DeleteBlockPoolRequestProto)
1407 ::google::protobuf::uint32 cached_has_bits = 0;
1408 (void) cached_has_bits;
1409
1410 cached_has_bits = _has_bits_[0];
1411 // required string blockPool = 1;
1412 if (cached_has_bits & 0x00000001u) {
1413 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
1414 this->blockpool().data(), static_cast<int>(this->blockpool().length()),
1415 ::google::protobuf::internal::WireFormat::SERIALIZE,
1416 "Hdfs.Internal.DeleteBlockPoolRequestProto.blockPool");
1417 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
1418 1, this->blockpool(), output);
1419 }
1420
1421 // required bool force = 2;
1422 if (cached_has_bits & 0x00000002u) {
1423 ::google::protobuf::internal::WireFormatLite::WriteBool(2, this->force(), output);
1424 }
1425
1426 if (_internal_metadata_.have_unknown_fields()) {
1427 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1428 _internal_metadata_.unknown_fields(), output);
1429 }
1430 // @@protoc_insertion_point(serialize_end:Hdfs.Internal.DeleteBlockPoolRequestProto)
1431}
1432
1433::google::protobuf::uint8* DeleteBlockPoolRequestProto::InternalSerializeWithCachedSizesToArray(
1434 bool deterministic, ::google::protobuf::uint8* target) const {
1435 (void)deterministic; // Unused
1436 // @@protoc_insertion_point(serialize_to_array_start:Hdfs.Internal.DeleteBlockPoolRequestProto)
1437 ::google::protobuf::uint32 cached_has_bits = 0;
1438 (void) cached_has_bits;
1439
1440 cached_has_bits = _has_bits_[0];
1441 // required string blockPool = 1;
1442 if (cached_has_bits & 0x00000001u) {
1443 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
1444 this->blockpool().data(), static_cast<int>(this->blockpool().length()),
1445 ::google::protobuf::internal::WireFormat::SERIALIZE,
1446 "Hdfs.Internal.DeleteBlockPoolRequestProto.blockPool");
1447 target =
1448 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1449 1, this->blockpool(), target);
1450 }
1451
1452 // required bool force = 2;
1453 if (cached_has_bits & 0x00000002u) {
1454 target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->force(), target);
1455 }
1456
1457 if (_internal_metadata_.have_unknown_fields()) {
1458 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1459 _internal_metadata_.unknown_fields(), target);
1460 }
1461 // @@protoc_insertion_point(serialize_to_array_end:Hdfs.Internal.DeleteBlockPoolRequestProto)
1462 return target;
1463}
1464
1465size_t DeleteBlockPoolRequestProto::RequiredFieldsByteSizeFallback() const {
1466// @@protoc_insertion_point(required_fields_byte_size_fallback_start:Hdfs.Internal.DeleteBlockPoolRequestProto)
1467 size_t total_size = 0;
1468
1469 if (has_blockpool()) {
1470 // required string blockPool = 1;
1471 total_size += 1 +
1472 ::google::protobuf::internal::WireFormatLite::StringSize(
1473 this->blockpool());
1474 }
1475
1476 if (has_force()) {
1477 // required bool force = 2;
1478 total_size += 1 + 1;
1479 }
1480
1481 return total_size;
1482}
1483size_t DeleteBlockPoolRequestProto::ByteSizeLong() const {
1484// @@protoc_insertion_point(message_byte_size_start:Hdfs.Internal.DeleteBlockPoolRequestProto)
1485 size_t total_size = 0;
1486
1487 if (_internal_metadata_.have_unknown_fields()) {
1488 total_size +=
1489 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1490 _internal_metadata_.unknown_fields());
1491 }
1492 if (((_has_bits_[0] & 0x00000003) ^ 0x00000003) == 0) { // All required fields are present.
1493 // required string blockPool = 1;
1494 total_size += 1 +
1495 ::google::protobuf::internal::WireFormatLite::StringSize(
1496 this->blockpool());
1497
1498 // required bool force = 2;
1499 total_size += 1 + 1;
1500
1501 } else {
1502 total_size += RequiredFieldsByteSizeFallback();
1503 }
1504 int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
1505 SetCachedSize(cached_size);
1506 return total_size;
1507}
1508
1509void DeleteBlockPoolRequestProto::MergeFrom(const ::google::protobuf::Message& from) {
1510// @@protoc_insertion_point(generalized_merge_from_start:Hdfs.Internal.DeleteBlockPoolRequestProto)
1511 GOOGLE_DCHECK_NE(&from, this);
1512 const DeleteBlockPoolRequestProto* source =
1513 ::google::protobuf::internal::DynamicCastToGenerated<const DeleteBlockPoolRequestProto>(
1514 &from);
1515 if (source == NULL) {
1516 // @@protoc_insertion_point(generalized_merge_from_cast_fail:Hdfs.Internal.DeleteBlockPoolRequestProto)
1517 ::google::protobuf::internal::ReflectionOps::Merge(from, this);
1518 } else {
1519 // @@protoc_insertion_point(generalized_merge_from_cast_success:Hdfs.Internal.DeleteBlockPoolRequestProto)
1520 MergeFrom(*source);
1521 }
1522}
1523
1524void DeleteBlockPoolRequestProto::MergeFrom(const DeleteBlockPoolRequestProto& from) {
1525// @@protoc_insertion_point(class_specific_merge_from_start:Hdfs.Internal.DeleteBlockPoolRequestProto)
1526 GOOGLE_DCHECK_NE(&from, this);
1527 _internal_metadata_.MergeFrom(from._internal_metadata_);
1528 ::google::protobuf::uint32 cached_has_bits = 0;
1529 (void) cached_has_bits;
1530
1531 cached_has_bits = from._has_bits_[0];
1532 if (cached_has_bits & 3u) {
1533 if (cached_has_bits & 0x00000001u) {
1534 set_has_blockpool();
1535 blockpool_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.blockpool_);
1536 }
1537 if (cached_has_bits & 0x00000002u) {
1538 force_ = from.force_;
1539 }
1540 _has_bits_[0] |= cached_has_bits;
1541 }
1542}
1543
1544void DeleteBlockPoolRequestProto::CopyFrom(const ::google::protobuf::Message& from) {
1545// @@protoc_insertion_point(generalized_copy_from_start:Hdfs.Internal.DeleteBlockPoolRequestProto)
1546 if (&from == this) return;
1547 Clear();
1548 MergeFrom(from);
1549}
1550
1551void DeleteBlockPoolRequestProto::CopyFrom(const DeleteBlockPoolRequestProto& from) {
1552// @@protoc_insertion_point(class_specific_copy_from_start:Hdfs.Internal.DeleteBlockPoolRequestProto)
1553 if (&from == this) return;
1554 Clear();
1555 MergeFrom(from);
1556}
1557
1558bool DeleteBlockPoolRequestProto::IsInitialized() const {
1559 if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false;
1560 return true;
1561}
1562
1563void DeleteBlockPoolRequestProto::Swap(DeleteBlockPoolRequestProto* other) {
1564 if (other == this) return;
1565 InternalSwap(other);
1566}
1567void DeleteBlockPoolRequestProto::InternalSwap(DeleteBlockPoolRequestProto* other) {
1568 using std::swap;
1569 blockpool_.Swap(&other->blockpool_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(),
1570 GetArenaNoVirtual());
1571 swap(force_, other->force_);
1572 swap(_has_bits_[0], other->_has_bits_[0]);
1573 _internal_metadata_.Swap(&other->_internal_metadata_);
1574}
1575
1576::google::protobuf::Metadata DeleteBlockPoolRequestProto::GetMetadata() const {
1577 protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
1578 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages];
1579}
1580
1581
1582// ===================================================================
1583
1584void DeleteBlockPoolResponseProto::InitAsDefaultInstance() {
1585}
1586#if !defined(_MSC_VER) || _MSC_VER >= 1900
1587#endif // !defined(_MSC_VER) || _MSC_VER >= 1900
1588
1589DeleteBlockPoolResponseProto::DeleteBlockPoolResponseProto()
1590 : ::google::protobuf::Message(), _internal_metadata_(NULL) {
1591 ::google::protobuf::internal::InitSCC(
1592 &protobuf_ClientDatanodeProtocol_2eproto::scc_info_DeleteBlockPoolResponseProto.base);
1593 SharedCtor();
1594 // @@protoc_insertion_point(constructor:Hdfs.Internal.DeleteBlockPoolResponseProto)
1595}
1596DeleteBlockPoolResponseProto::DeleteBlockPoolResponseProto(const DeleteBlockPoolResponseProto& from)
1597 : ::google::protobuf::Message(),
1598 _internal_metadata_(NULL),
1599 _has_bits_(from._has_bits_) {
1600 _internal_metadata_.MergeFrom(from._internal_metadata_);
1601 // @@protoc_insertion_point(copy_constructor:Hdfs.Internal.DeleteBlockPoolResponseProto)
1602}
1603
1604void DeleteBlockPoolResponseProto::SharedCtor() {
1605}
1606
1607DeleteBlockPoolResponseProto::~DeleteBlockPoolResponseProto() {
1608 // @@protoc_insertion_point(destructor:Hdfs.Internal.DeleteBlockPoolResponseProto)
1609 SharedDtor();
1610}
1611
1612void DeleteBlockPoolResponseProto::SharedDtor() {
1613}
1614
1615void DeleteBlockPoolResponseProto::SetCachedSize(int size) const {
1616 _cached_size_.Set(size);
1617}
1618const ::google::protobuf::Descriptor* DeleteBlockPoolResponseProto::descriptor() {
1619 ::protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
1620 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
1621}
1622
1623const DeleteBlockPoolResponseProto& DeleteBlockPoolResponseProto::default_instance() {
1624 ::google::protobuf::internal::InitSCC(&protobuf_ClientDatanodeProtocol_2eproto::scc_info_DeleteBlockPoolResponseProto.base);
1625 return *internal_default_instance();
1626}
1627
1628
1629void DeleteBlockPoolResponseProto::Clear() {
1630// @@protoc_insertion_point(message_clear_start:Hdfs.Internal.DeleteBlockPoolResponseProto)
1631 ::google::protobuf::uint32 cached_has_bits = 0;
1632 // Prevent compiler warnings about cached_has_bits being unused
1633 (void) cached_has_bits;
1634
1635 _has_bits_.Clear();
1636 _internal_metadata_.Clear();
1637}
1638
1639bool DeleteBlockPoolResponseProto::MergePartialFromCodedStream(
1640 ::google::protobuf::io::CodedInputStream* input) {
1641#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
1642 ::google::protobuf::uint32 tag;
1643 // @@protoc_insertion_point(parse_start:Hdfs.Internal.DeleteBlockPoolResponseProto)
1644 for (;;) {
1645 ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
1646 tag = p.first;
1647 if (!p.second) goto handle_unusual;
1648 handle_unusual:
1649 if (tag == 0) {
1650 goto success;
1651 }
1652 DO_(::google::protobuf::internal::WireFormat::SkipField(
1653 input, tag, _internal_metadata_.mutable_unknown_fields()));
1654 }
1655success:
1656 // @@protoc_insertion_point(parse_success:Hdfs.Internal.DeleteBlockPoolResponseProto)
1657 return true;
1658failure:
1659 // @@protoc_insertion_point(parse_failure:Hdfs.Internal.DeleteBlockPoolResponseProto)
1660 return false;
1661#undef DO_
1662}
1663
1664void DeleteBlockPoolResponseProto::SerializeWithCachedSizes(
1665 ::google::protobuf::io::CodedOutputStream* output) const {
1666 // @@protoc_insertion_point(serialize_start:Hdfs.Internal.DeleteBlockPoolResponseProto)
1667 ::google::protobuf::uint32 cached_has_bits = 0;
1668 (void) cached_has_bits;
1669
1670 if (_internal_metadata_.have_unknown_fields()) {
1671 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1672 _internal_metadata_.unknown_fields(), output);
1673 }
1674 // @@protoc_insertion_point(serialize_end:Hdfs.Internal.DeleteBlockPoolResponseProto)
1675}
1676
1677::google::protobuf::uint8* DeleteBlockPoolResponseProto::InternalSerializeWithCachedSizesToArray(
1678 bool deterministic, ::google::protobuf::uint8* target) const {
1679 (void)deterministic; // Unused
1680 // @@protoc_insertion_point(serialize_to_array_start:Hdfs.Internal.DeleteBlockPoolResponseProto)
1681 ::google::protobuf::uint32 cached_has_bits = 0;
1682 (void) cached_has_bits;
1683
1684 if (_internal_metadata_.have_unknown_fields()) {
1685 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1686 _internal_metadata_.unknown_fields(), target);
1687 }
1688 // @@protoc_insertion_point(serialize_to_array_end:Hdfs.Internal.DeleteBlockPoolResponseProto)
1689 return target;
1690}
1691
1692size_t DeleteBlockPoolResponseProto::ByteSizeLong() const {
1693// @@protoc_insertion_point(message_byte_size_start:Hdfs.Internal.DeleteBlockPoolResponseProto)
1694 size_t total_size = 0;
1695
1696 if (_internal_metadata_.have_unknown_fields()) {
1697 total_size +=
1698 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1699 _internal_metadata_.unknown_fields());
1700 }
1701 int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
1702 SetCachedSize(cached_size);
1703 return total_size;
1704}
1705
1706void DeleteBlockPoolResponseProto::MergeFrom(const ::google::protobuf::Message& from) {
1707// @@protoc_insertion_point(generalized_merge_from_start:Hdfs.Internal.DeleteBlockPoolResponseProto)
1708 GOOGLE_DCHECK_NE(&from, this);
1709 const DeleteBlockPoolResponseProto* source =
1710 ::google::protobuf::internal::DynamicCastToGenerated<const DeleteBlockPoolResponseProto>(
1711 &from);
1712 if (source == NULL) {
1713 // @@protoc_insertion_point(generalized_merge_from_cast_fail:Hdfs.Internal.DeleteBlockPoolResponseProto)
1714 ::google::protobuf::internal::ReflectionOps::Merge(from, this);
1715 } else {
1716 // @@protoc_insertion_point(generalized_merge_from_cast_success:Hdfs.Internal.DeleteBlockPoolResponseProto)
1717 MergeFrom(*source);
1718 }
1719}
1720
1721void DeleteBlockPoolResponseProto::MergeFrom(const DeleteBlockPoolResponseProto& from) {
1722// @@protoc_insertion_point(class_specific_merge_from_start:Hdfs.Internal.DeleteBlockPoolResponseProto)
1723 GOOGLE_DCHECK_NE(&from, this);
1724 _internal_metadata_.MergeFrom(from._internal_metadata_);
1725 ::google::protobuf::uint32 cached_has_bits = 0;
1726 (void) cached_has_bits;
1727
1728}
1729
1730void DeleteBlockPoolResponseProto::CopyFrom(const ::google::protobuf::Message& from) {
1731// @@protoc_insertion_point(generalized_copy_from_start:Hdfs.Internal.DeleteBlockPoolResponseProto)
1732 if (&from == this) return;
1733 Clear();
1734 MergeFrom(from);
1735}
1736
1737void DeleteBlockPoolResponseProto::CopyFrom(const DeleteBlockPoolResponseProto& from) {
1738// @@protoc_insertion_point(class_specific_copy_from_start:Hdfs.Internal.DeleteBlockPoolResponseProto)
1739 if (&from == this) return;
1740 Clear();
1741 MergeFrom(from);
1742}
1743
1744bool DeleteBlockPoolResponseProto::IsInitialized() const {
1745 return true;
1746}
1747
1748void DeleteBlockPoolResponseProto::Swap(DeleteBlockPoolResponseProto* other) {
1749 if (other == this) return;
1750 InternalSwap(other);
1751}
1752void DeleteBlockPoolResponseProto::InternalSwap(DeleteBlockPoolResponseProto* other) {
1753 using std::swap;
1754 swap(_has_bits_[0], other->_has_bits_[0]);
1755 _internal_metadata_.Swap(&other->_internal_metadata_);
1756}
1757
1758::google::protobuf::Metadata DeleteBlockPoolResponseProto::GetMetadata() const {
1759 protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
1760 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages];
1761}
1762
1763
1764// ===================================================================
1765
1766void GetBlockLocalPathInfoRequestProto::InitAsDefaultInstance() {
1767 ::Hdfs::Internal::_GetBlockLocalPathInfoRequestProto_default_instance_._instance.get_mutable()->block_ = const_cast< ::Hdfs::Internal::ExtendedBlockProto*>(
1768 ::Hdfs::Internal::ExtendedBlockProto::internal_default_instance());
1769 ::Hdfs::Internal::_GetBlockLocalPathInfoRequestProto_default_instance_._instance.get_mutable()->token_ = const_cast< ::Hdfs::Internal::TokenProto*>(
1770 ::Hdfs::Internal::TokenProto::internal_default_instance());
1771}
1772void GetBlockLocalPathInfoRequestProto::clear_block() {
1773 if (block_ != NULL) block_->Clear();
1774 clear_has_block();
1775}
1776void GetBlockLocalPathInfoRequestProto::clear_token() {
1777 if (token_ != NULL) token_->Clear();
1778 clear_has_token();
1779}
1780#if !defined(_MSC_VER) || _MSC_VER >= 1900
1781const int GetBlockLocalPathInfoRequestProto::kBlockFieldNumber;
1782const int GetBlockLocalPathInfoRequestProto::kTokenFieldNumber;
1783#endif // !defined(_MSC_VER) || _MSC_VER >= 1900
1784
1785GetBlockLocalPathInfoRequestProto::GetBlockLocalPathInfoRequestProto()
1786 : ::google::protobuf::Message(), _internal_metadata_(NULL) {
1787 ::google::protobuf::internal::InitSCC(
1788 &protobuf_ClientDatanodeProtocol_2eproto::scc_info_GetBlockLocalPathInfoRequestProto.base);
1789 SharedCtor();
1790 // @@protoc_insertion_point(constructor:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1791}
1792GetBlockLocalPathInfoRequestProto::GetBlockLocalPathInfoRequestProto(const GetBlockLocalPathInfoRequestProto& from)
1793 : ::google::protobuf::Message(),
1794 _internal_metadata_(NULL),
1795 _has_bits_(from._has_bits_) {
1796 _internal_metadata_.MergeFrom(from._internal_metadata_);
1797 if (from.has_block()) {
1798 block_ = new ::Hdfs::Internal::ExtendedBlockProto(*from.block_);
1799 } else {
1800 block_ = NULL;
1801 }
1802 if (from.has_token()) {
1803 token_ = new ::Hdfs::Internal::TokenProto(*from.token_);
1804 } else {
1805 token_ = NULL;
1806 }
1807 // @@protoc_insertion_point(copy_constructor:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1808}
1809
1810void GetBlockLocalPathInfoRequestProto::SharedCtor() {
1811 ::memset(&block_, 0, static_cast<size_t>(
1812 reinterpret_cast<char*>(&token_) -
1813 reinterpret_cast<char*>(&block_)) + sizeof(token_));
1814}
1815
1816GetBlockLocalPathInfoRequestProto::~GetBlockLocalPathInfoRequestProto() {
1817 // @@protoc_insertion_point(destructor:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1818 SharedDtor();
1819}
1820
1821void GetBlockLocalPathInfoRequestProto::SharedDtor() {
1822 if (this != internal_default_instance()) delete block_;
1823 if (this != internal_default_instance()) delete token_;
1824}
1825
1826void GetBlockLocalPathInfoRequestProto::SetCachedSize(int size) const {
1827 _cached_size_.Set(size);
1828}
1829const ::google::protobuf::Descriptor* GetBlockLocalPathInfoRequestProto::descriptor() {
1830 ::protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
1831 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
1832}
1833
1834const GetBlockLocalPathInfoRequestProto& GetBlockLocalPathInfoRequestProto::default_instance() {
1835 ::google::protobuf::internal::InitSCC(&protobuf_ClientDatanodeProtocol_2eproto::scc_info_GetBlockLocalPathInfoRequestProto.base);
1836 return *internal_default_instance();
1837}
1838
1839
1840void GetBlockLocalPathInfoRequestProto::Clear() {
1841// @@protoc_insertion_point(message_clear_start:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1842 ::google::protobuf::uint32 cached_has_bits = 0;
1843 // Prevent compiler warnings about cached_has_bits being unused
1844 (void) cached_has_bits;
1845
1846 cached_has_bits = _has_bits_[0];
1847 if (cached_has_bits & 3u) {
1848 if (cached_has_bits & 0x00000001u) {
1849 GOOGLE_DCHECK(block_ != NULL);
1850 block_->Clear();
1851 }
1852 if (cached_has_bits & 0x00000002u) {
1853 GOOGLE_DCHECK(token_ != NULL);
1854 token_->Clear();
1855 }
1856 }
1857 _has_bits_.Clear();
1858 _internal_metadata_.Clear();
1859}
1860
1861bool GetBlockLocalPathInfoRequestProto::MergePartialFromCodedStream(
1862 ::google::protobuf::io::CodedInputStream* input) {
1863#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
1864 ::google::protobuf::uint32 tag;
1865 // @@protoc_insertion_point(parse_start:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1866 for (;;) {
1867 ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
1868 tag = p.first;
1869 if (!p.second) goto handle_unusual;
1870 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1871 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
1872 case 1: {
1873 if (static_cast< ::google::protobuf::uint8>(tag) ==
1874 static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
1875 DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
1876 input, mutable_block()));
1877 } else {
1878 goto handle_unusual;
1879 }
1880 break;
1881 }
1882
1883 // required .Hdfs.Internal.TokenProto token = 2;
1884 case 2: {
1885 if (static_cast< ::google::protobuf::uint8>(tag) ==
1886 static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {
1887 DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
1888 input, mutable_token()));
1889 } else {
1890 goto handle_unusual;
1891 }
1892 break;
1893 }
1894
1895 default: {
1896 handle_unusual:
1897 if (tag == 0) {
1898 goto success;
1899 }
1900 DO_(::google::protobuf::internal::WireFormat::SkipField(
1901 input, tag, _internal_metadata_.mutable_unknown_fields()));
1902 break;
1903 }
1904 }
1905 }
1906success:
1907 // @@protoc_insertion_point(parse_success:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1908 return true;
1909failure:
1910 // @@protoc_insertion_point(parse_failure:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1911 return false;
1912#undef DO_
1913}
1914
1915void GetBlockLocalPathInfoRequestProto::SerializeWithCachedSizes(
1916 ::google::protobuf::io::CodedOutputStream* output) const {
1917 // @@protoc_insertion_point(serialize_start:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1918 ::google::protobuf::uint32 cached_has_bits = 0;
1919 (void) cached_has_bits;
1920
1921 cached_has_bits = _has_bits_[0];
1922 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
1923 if (cached_has_bits & 0x00000001u) {
1924 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
1925 1, this->_internal_block(), output);
1926 }
1927
1928 // required .Hdfs.Internal.TokenProto token = 2;
1929 if (cached_has_bits & 0x00000002u) {
1930 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
1931 2, this->_internal_token(), output);
1932 }
1933
1934 if (_internal_metadata_.have_unknown_fields()) {
1935 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1936 _internal_metadata_.unknown_fields(), output);
1937 }
1938 // @@protoc_insertion_point(serialize_end:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1939}
1940
1941::google::protobuf::uint8* GetBlockLocalPathInfoRequestProto::InternalSerializeWithCachedSizesToArray(
1942 bool deterministic, ::google::protobuf::uint8* target) const {
1943 (void)deterministic; // Unused
1944 // @@protoc_insertion_point(serialize_to_array_start:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1945 ::google::protobuf::uint32 cached_has_bits = 0;
1946 (void) cached_has_bits;
1947
1948 cached_has_bits = _has_bits_[0];
1949 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
1950 if (cached_has_bits & 0x00000001u) {
1951 target = ::google::protobuf::internal::WireFormatLite::
1952 InternalWriteMessageToArray(
1953 1, this->_internal_block(), deterministic, target);
1954 }
1955
1956 // required .Hdfs.Internal.TokenProto token = 2;
1957 if (cached_has_bits & 0x00000002u) {
1958 target = ::google::protobuf::internal::WireFormatLite::
1959 InternalWriteMessageToArray(
1960 2, this->_internal_token(), deterministic, target);
1961 }
1962
1963 if (_internal_metadata_.have_unknown_fields()) {
1964 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1965 _internal_metadata_.unknown_fields(), target);
1966 }
1967 // @@protoc_insertion_point(serialize_to_array_end:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1968 return target;
1969}
1970
1971size_t GetBlockLocalPathInfoRequestProto::RequiredFieldsByteSizeFallback() const {
1972// @@protoc_insertion_point(required_fields_byte_size_fallback_start:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1973 size_t total_size = 0;
1974
1975 if (has_block()) {
1976 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
1977 total_size += 1 +
1978 ::google::protobuf::internal::WireFormatLite::MessageSize(
1979 *block_);
1980 }
1981
1982 if (has_token()) {
1983 // required .Hdfs.Internal.TokenProto token = 2;
1984 total_size += 1 +
1985 ::google::protobuf::internal::WireFormatLite::MessageSize(
1986 *token_);
1987 }
1988
1989 return total_size;
1990}
1991size_t GetBlockLocalPathInfoRequestProto::ByteSizeLong() const {
1992// @@protoc_insertion_point(message_byte_size_start:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
1993 size_t total_size = 0;
1994
1995 if (_internal_metadata_.have_unknown_fields()) {
1996 total_size +=
1997 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1998 _internal_metadata_.unknown_fields());
1999 }
2000 if (((_has_bits_[0] & 0x00000003) ^ 0x00000003) == 0) { // All required fields are present.
2001 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
2002 total_size += 1 +
2003 ::google::protobuf::internal::WireFormatLite::MessageSize(
2004 *block_);
2005
2006 // required .Hdfs.Internal.TokenProto token = 2;
2007 total_size += 1 +
2008 ::google::protobuf::internal::WireFormatLite::MessageSize(
2009 *token_);
2010
2011 } else {
2012 total_size += RequiredFieldsByteSizeFallback();
2013 }
2014 int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
2015 SetCachedSize(cached_size);
2016 return total_size;
2017}
2018
2019void GetBlockLocalPathInfoRequestProto::MergeFrom(const ::google::protobuf::Message& from) {
2020// @@protoc_insertion_point(generalized_merge_from_start:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
2021 GOOGLE_DCHECK_NE(&from, this);
2022 const GetBlockLocalPathInfoRequestProto* source =
2023 ::google::protobuf::internal::DynamicCastToGenerated<const GetBlockLocalPathInfoRequestProto>(
2024 &from);
2025 if (source == NULL) {
2026 // @@protoc_insertion_point(generalized_merge_from_cast_fail:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
2027 ::google::protobuf::internal::ReflectionOps::Merge(from, this);
2028 } else {
2029 // @@protoc_insertion_point(generalized_merge_from_cast_success:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
2030 MergeFrom(*source);
2031 }
2032}
2033
2034void GetBlockLocalPathInfoRequestProto::MergeFrom(const GetBlockLocalPathInfoRequestProto& from) {
2035// @@protoc_insertion_point(class_specific_merge_from_start:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
2036 GOOGLE_DCHECK_NE(&from, this);
2037 _internal_metadata_.MergeFrom(from._internal_metadata_);
2038 ::google::protobuf::uint32 cached_has_bits = 0;
2039 (void) cached_has_bits;
2040
2041 cached_has_bits = from._has_bits_[0];
2042 if (cached_has_bits & 3u) {
2043 if (cached_has_bits & 0x00000001u) {
2044 mutable_block()->::Hdfs::Internal::ExtendedBlockProto::MergeFrom(from.block());
2045 }
2046 if (cached_has_bits & 0x00000002u) {
2047 mutable_token()->::Hdfs::Internal::TokenProto::MergeFrom(from.token());
2048 }
2049 }
2050}
2051
2052void GetBlockLocalPathInfoRequestProto::CopyFrom(const ::google::protobuf::Message& from) {
2053// @@protoc_insertion_point(generalized_copy_from_start:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
2054 if (&from == this) return;
2055 Clear();
2056 MergeFrom(from);
2057}
2058
2059void GetBlockLocalPathInfoRequestProto::CopyFrom(const GetBlockLocalPathInfoRequestProto& from) {
2060// @@protoc_insertion_point(class_specific_copy_from_start:Hdfs.Internal.GetBlockLocalPathInfoRequestProto)
2061 if (&from == this) return;
2062 Clear();
2063 MergeFrom(from);
2064}
2065
2066bool GetBlockLocalPathInfoRequestProto::IsInitialized() const {
2067 if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false;
2068 if (has_block()) {
2069 if (!this->block_->IsInitialized()) return false;
2070 }
2071 if (has_token()) {
2072 if (!this->token_->IsInitialized()) return false;
2073 }
2074 return true;
2075}
2076
2077void GetBlockLocalPathInfoRequestProto::Swap(GetBlockLocalPathInfoRequestProto* other) {
2078 if (other == this) return;
2079 InternalSwap(other);
2080}
2081void GetBlockLocalPathInfoRequestProto::InternalSwap(GetBlockLocalPathInfoRequestProto* other) {
2082 using std::swap;
2083 swap(block_, other->block_);
2084 swap(token_, other->token_);
2085 swap(_has_bits_[0], other->_has_bits_[0]);
2086 _internal_metadata_.Swap(&other->_internal_metadata_);
2087}
2088
2089::google::protobuf::Metadata GetBlockLocalPathInfoRequestProto::GetMetadata() const {
2090 protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
2091 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages];
2092}
2093
2094
2095// ===================================================================
2096
2097void GetBlockLocalPathInfoResponseProto::InitAsDefaultInstance() {
2098 ::Hdfs::Internal::_GetBlockLocalPathInfoResponseProto_default_instance_._instance.get_mutable()->block_ = const_cast< ::Hdfs::Internal::ExtendedBlockProto*>(
2099 ::Hdfs::Internal::ExtendedBlockProto::internal_default_instance());
2100}
2101void GetBlockLocalPathInfoResponseProto::clear_block() {
2102 if (block_ != NULL) block_->Clear();
2103 clear_has_block();
2104}
2105#if !defined(_MSC_VER) || _MSC_VER >= 1900
2106const int GetBlockLocalPathInfoResponseProto::kBlockFieldNumber;
2107const int GetBlockLocalPathInfoResponseProto::kLocalPathFieldNumber;
2108const int GetBlockLocalPathInfoResponseProto::kLocalMetaPathFieldNumber;
2109#endif // !defined(_MSC_VER) || _MSC_VER >= 1900
2110
2111GetBlockLocalPathInfoResponseProto::GetBlockLocalPathInfoResponseProto()
2112 : ::google::protobuf::Message(), _internal_metadata_(NULL) {
2113 ::google::protobuf::internal::InitSCC(
2114 &protobuf_ClientDatanodeProtocol_2eproto::scc_info_GetBlockLocalPathInfoResponseProto.base);
2115 SharedCtor();
2116 // @@protoc_insertion_point(constructor:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2117}
2118GetBlockLocalPathInfoResponseProto::GetBlockLocalPathInfoResponseProto(const GetBlockLocalPathInfoResponseProto& from)
2119 : ::google::protobuf::Message(),
2120 _internal_metadata_(NULL),
2121 _has_bits_(from._has_bits_) {
2122 _internal_metadata_.MergeFrom(from._internal_metadata_);
2123 localpath_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2124 if (from.has_localpath()) {
2125 localpath_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.localpath_);
2126 }
2127 localmetapath_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2128 if (from.has_localmetapath()) {
2129 localmetapath_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.localmetapath_);
2130 }
2131 if (from.has_block()) {
2132 block_ = new ::Hdfs::Internal::ExtendedBlockProto(*from.block_);
2133 } else {
2134 block_ = NULL;
2135 }
2136 // @@protoc_insertion_point(copy_constructor:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2137}
2138
2139void GetBlockLocalPathInfoResponseProto::SharedCtor() {
2140 localpath_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2141 localmetapath_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2142 block_ = NULL;
2143}
2144
2145GetBlockLocalPathInfoResponseProto::~GetBlockLocalPathInfoResponseProto() {
2146 // @@protoc_insertion_point(destructor:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2147 SharedDtor();
2148}
2149
2150void GetBlockLocalPathInfoResponseProto::SharedDtor() {
2151 localpath_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2152 localmetapath_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2153 if (this != internal_default_instance()) delete block_;
2154}
2155
2156void GetBlockLocalPathInfoResponseProto::SetCachedSize(int size) const {
2157 _cached_size_.Set(size);
2158}
2159const ::google::protobuf::Descriptor* GetBlockLocalPathInfoResponseProto::descriptor() {
2160 ::protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
2161 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
2162}
2163
2164const GetBlockLocalPathInfoResponseProto& GetBlockLocalPathInfoResponseProto::default_instance() {
2165 ::google::protobuf::internal::InitSCC(&protobuf_ClientDatanodeProtocol_2eproto::scc_info_GetBlockLocalPathInfoResponseProto.base);
2166 return *internal_default_instance();
2167}
2168
2169
2170void GetBlockLocalPathInfoResponseProto::Clear() {
2171// @@protoc_insertion_point(message_clear_start:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2172 ::google::protobuf::uint32 cached_has_bits = 0;
2173 // Prevent compiler warnings about cached_has_bits being unused
2174 (void) cached_has_bits;
2175
2176 cached_has_bits = _has_bits_[0];
2177 if (cached_has_bits & 7u) {
2178 if (cached_has_bits & 0x00000001u) {
2179 localpath_.ClearNonDefaultToEmptyNoArena();
2180 }
2181 if (cached_has_bits & 0x00000002u) {
2182 localmetapath_.ClearNonDefaultToEmptyNoArena();
2183 }
2184 if (cached_has_bits & 0x00000004u) {
2185 GOOGLE_DCHECK(block_ != NULL);
2186 block_->Clear();
2187 }
2188 }
2189 _has_bits_.Clear();
2190 _internal_metadata_.Clear();
2191}
2192
2193bool GetBlockLocalPathInfoResponseProto::MergePartialFromCodedStream(
2194 ::google::protobuf::io::CodedInputStream* input) {
2195#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
2196 ::google::protobuf::uint32 tag;
2197 // @@protoc_insertion_point(parse_start:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2198 for (;;) {
2199 ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
2200 tag = p.first;
2201 if (!p.second) goto handle_unusual;
2202 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2203 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
2204 case 1: {
2205 if (static_cast< ::google::protobuf::uint8>(tag) ==
2206 static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
2207 DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
2208 input, mutable_block()));
2209 } else {
2210 goto handle_unusual;
2211 }
2212 break;
2213 }
2214
2215 // required string localPath = 2;
2216 case 2: {
2217 if (static_cast< ::google::protobuf::uint8>(tag) ==
2218 static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {
2219 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
2220 input, this->mutable_localpath()));
2221 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
2222 this->localpath().data(), static_cast<int>(this->localpath().length()),
2223 ::google::protobuf::internal::WireFormat::PARSE,
2224 "Hdfs.Internal.GetBlockLocalPathInfoResponseProto.localPath");
2225 } else {
2226 goto handle_unusual;
2227 }
2228 break;
2229 }
2230
2231 // required string localMetaPath = 3;
2232 case 3: {
2233 if (static_cast< ::google::protobuf::uint8>(tag) ==
2234 static_cast< ::google::protobuf::uint8>(26u /* 26 & 0xFF */)) {
2235 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
2236 input, this->mutable_localmetapath()));
2237 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
2238 this->localmetapath().data(), static_cast<int>(this->localmetapath().length()),
2239 ::google::protobuf::internal::WireFormat::PARSE,
2240 "Hdfs.Internal.GetBlockLocalPathInfoResponseProto.localMetaPath");
2241 } else {
2242 goto handle_unusual;
2243 }
2244 break;
2245 }
2246
2247 default: {
2248 handle_unusual:
2249 if (tag == 0) {
2250 goto success;
2251 }
2252 DO_(::google::protobuf::internal::WireFormat::SkipField(
2253 input, tag, _internal_metadata_.mutable_unknown_fields()));
2254 break;
2255 }
2256 }
2257 }
2258success:
2259 // @@protoc_insertion_point(parse_success:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2260 return true;
2261failure:
2262 // @@protoc_insertion_point(parse_failure:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2263 return false;
2264#undef DO_
2265}
2266
2267void GetBlockLocalPathInfoResponseProto::SerializeWithCachedSizes(
2268 ::google::protobuf::io::CodedOutputStream* output) const {
2269 // @@protoc_insertion_point(serialize_start:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2270 ::google::protobuf::uint32 cached_has_bits = 0;
2271 (void) cached_has_bits;
2272
2273 cached_has_bits = _has_bits_[0];
2274 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
2275 if (cached_has_bits & 0x00000004u) {
2276 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2277 1, this->_internal_block(), output);
2278 }
2279
2280 // required string localPath = 2;
2281 if (cached_has_bits & 0x00000001u) {
2282 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
2283 this->localpath().data(), static_cast<int>(this->localpath().length()),
2284 ::google::protobuf::internal::WireFormat::SERIALIZE,
2285 "Hdfs.Internal.GetBlockLocalPathInfoResponseProto.localPath");
2286 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
2287 2, this->localpath(), output);
2288 }
2289
2290 // required string localMetaPath = 3;
2291 if (cached_has_bits & 0x00000002u) {
2292 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
2293 this->localmetapath().data(), static_cast<int>(this->localmetapath().length()),
2294 ::google::protobuf::internal::WireFormat::SERIALIZE,
2295 "Hdfs.Internal.GetBlockLocalPathInfoResponseProto.localMetaPath");
2296 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
2297 3, this->localmetapath(), output);
2298 }
2299
2300 if (_internal_metadata_.have_unknown_fields()) {
2301 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2302 _internal_metadata_.unknown_fields(), output);
2303 }
2304 // @@protoc_insertion_point(serialize_end:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2305}
2306
2307::google::protobuf::uint8* GetBlockLocalPathInfoResponseProto::InternalSerializeWithCachedSizesToArray(
2308 bool deterministic, ::google::protobuf::uint8* target) const {
2309 (void)deterministic; // Unused
2310 // @@protoc_insertion_point(serialize_to_array_start:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2311 ::google::protobuf::uint32 cached_has_bits = 0;
2312 (void) cached_has_bits;
2313
2314 cached_has_bits = _has_bits_[0];
2315 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
2316 if (cached_has_bits & 0x00000004u) {
2317 target = ::google::protobuf::internal::WireFormatLite::
2318 InternalWriteMessageToArray(
2319 1, this->_internal_block(), deterministic, target);
2320 }
2321
2322 // required string localPath = 2;
2323 if (cached_has_bits & 0x00000001u) {
2324 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
2325 this->localpath().data(), static_cast<int>(this->localpath().length()),
2326 ::google::protobuf::internal::WireFormat::SERIALIZE,
2327 "Hdfs.Internal.GetBlockLocalPathInfoResponseProto.localPath");
2328 target =
2329 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
2330 2, this->localpath(), target);
2331 }
2332
2333 // required string localMetaPath = 3;
2334 if (cached_has_bits & 0x00000002u) {
2335 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
2336 this->localmetapath().data(), static_cast<int>(this->localmetapath().length()),
2337 ::google::protobuf::internal::WireFormat::SERIALIZE,
2338 "Hdfs.Internal.GetBlockLocalPathInfoResponseProto.localMetaPath");
2339 target =
2340 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
2341 3, this->localmetapath(), target);
2342 }
2343
2344 if (_internal_metadata_.have_unknown_fields()) {
2345 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2346 _internal_metadata_.unknown_fields(), target);
2347 }
2348 // @@protoc_insertion_point(serialize_to_array_end:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2349 return target;
2350}
2351
2352size_t GetBlockLocalPathInfoResponseProto::RequiredFieldsByteSizeFallback() const {
2353// @@protoc_insertion_point(required_fields_byte_size_fallback_start:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2354 size_t total_size = 0;
2355
2356 if (has_localpath()) {
2357 // required string localPath = 2;
2358 total_size += 1 +
2359 ::google::protobuf::internal::WireFormatLite::StringSize(
2360 this->localpath());
2361 }
2362
2363 if (has_localmetapath()) {
2364 // required string localMetaPath = 3;
2365 total_size += 1 +
2366 ::google::protobuf::internal::WireFormatLite::StringSize(
2367 this->localmetapath());
2368 }
2369
2370 if (has_block()) {
2371 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
2372 total_size += 1 +
2373 ::google::protobuf::internal::WireFormatLite::MessageSize(
2374 *block_);
2375 }
2376
2377 return total_size;
2378}
2379size_t GetBlockLocalPathInfoResponseProto::ByteSizeLong() const {
2380// @@protoc_insertion_point(message_byte_size_start:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2381 size_t total_size = 0;
2382
2383 if (_internal_metadata_.have_unknown_fields()) {
2384 total_size +=
2385 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2386 _internal_metadata_.unknown_fields());
2387 }
2388 if (((_has_bits_[0] & 0x00000007) ^ 0x00000007) == 0) { // All required fields are present.
2389 // required string localPath = 2;
2390 total_size += 1 +
2391 ::google::protobuf::internal::WireFormatLite::StringSize(
2392 this->localpath());
2393
2394 // required string localMetaPath = 3;
2395 total_size += 1 +
2396 ::google::protobuf::internal::WireFormatLite::StringSize(
2397 this->localmetapath());
2398
2399 // required .Hdfs.Internal.ExtendedBlockProto block = 1;
2400 total_size += 1 +
2401 ::google::protobuf::internal::WireFormatLite::MessageSize(
2402 *block_);
2403
2404 } else {
2405 total_size += RequiredFieldsByteSizeFallback();
2406 }
2407 int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
2408 SetCachedSize(cached_size);
2409 return total_size;
2410}
2411
2412void GetBlockLocalPathInfoResponseProto::MergeFrom(const ::google::protobuf::Message& from) {
2413// @@protoc_insertion_point(generalized_merge_from_start:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2414 GOOGLE_DCHECK_NE(&from, this);
2415 const GetBlockLocalPathInfoResponseProto* source =
2416 ::google::protobuf::internal::DynamicCastToGenerated<const GetBlockLocalPathInfoResponseProto>(
2417 &from);
2418 if (source == NULL) {
2419 // @@protoc_insertion_point(generalized_merge_from_cast_fail:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2420 ::google::protobuf::internal::ReflectionOps::Merge(from, this);
2421 } else {
2422 // @@protoc_insertion_point(generalized_merge_from_cast_success:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2423 MergeFrom(*source);
2424 }
2425}
2426
2427void GetBlockLocalPathInfoResponseProto::MergeFrom(const GetBlockLocalPathInfoResponseProto& from) {
2428// @@protoc_insertion_point(class_specific_merge_from_start:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2429 GOOGLE_DCHECK_NE(&from, this);
2430 _internal_metadata_.MergeFrom(from._internal_metadata_);
2431 ::google::protobuf::uint32 cached_has_bits = 0;
2432 (void) cached_has_bits;
2433
2434 cached_has_bits = from._has_bits_[0];
2435 if (cached_has_bits & 7u) {
2436 if (cached_has_bits & 0x00000001u) {
2437 set_has_localpath();
2438 localpath_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.localpath_);
2439 }
2440 if (cached_has_bits & 0x00000002u) {
2441 set_has_localmetapath();
2442 localmetapath_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.localmetapath_);
2443 }
2444 if (cached_has_bits & 0x00000004u) {
2445 mutable_block()->::Hdfs::Internal::ExtendedBlockProto::MergeFrom(from.block());
2446 }
2447 }
2448}
2449
2450void GetBlockLocalPathInfoResponseProto::CopyFrom(const ::google::protobuf::Message& from) {
2451// @@protoc_insertion_point(generalized_copy_from_start:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2452 if (&from == this) return;
2453 Clear();
2454 MergeFrom(from);
2455}
2456
2457void GetBlockLocalPathInfoResponseProto::CopyFrom(const GetBlockLocalPathInfoResponseProto& from) {
2458// @@protoc_insertion_point(class_specific_copy_from_start:Hdfs.Internal.GetBlockLocalPathInfoResponseProto)
2459 if (&from == this) return;
2460 Clear();
2461 MergeFrom(from);
2462}
2463
2464bool GetBlockLocalPathInfoResponseProto::IsInitialized() const {
2465 if ((_has_bits_[0] & 0x00000007) != 0x00000007) return false;
2466 if (has_block()) {
2467 if (!this->block_->IsInitialized()) return false;
2468 }
2469 return true;
2470}
2471
2472void GetBlockLocalPathInfoResponseProto::Swap(GetBlockLocalPathInfoResponseProto* other) {
2473 if (other == this) return;
2474 InternalSwap(other);
2475}
2476void GetBlockLocalPathInfoResponseProto::InternalSwap(GetBlockLocalPathInfoResponseProto* other) {
2477 using std::swap;
2478 localpath_.Swap(&other->localpath_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(),
2479 GetArenaNoVirtual());
2480 localmetapath_.Swap(&other->localmetapath_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(),
2481 GetArenaNoVirtual());
2482 swap(block_, other->block_);
2483 swap(_has_bits_[0], other->_has_bits_[0]);
2484 _internal_metadata_.Swap(&other->_internal_metadata_);
2485}
2486
2487::google::protobuf::Metadata GetBlockLocalPathInfoResponseProto::GetMetadata() const {
2488 protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
2489 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages];
2490}
2491
2492
2493// ===================================================================
2494
2495void GetHdfsBlockLocationsRequestProto::InitAsDefaultInstance() {
2496}
2497void GetHdfsBlockLocationsRequestProto::clear_blocks() {
2498 blocks_.Clear();
2499}
2500void GetHdfsBlockLocationsRequestProto::clear_tokens() {
2501 tokens_.Clear();
2502}
2503#if !defined(_MSC_VER) || _MSC_VER >= 1900
2504const int GetHdfsBlockLocationsRequestProto::kBlocksFieldNumber;
2505const int GetHdfsBlockLocationsRequestProto::kTokensFieldNumber;
2506#endif // !defined(_MSC_VER) || _MSC_VER >= 1900
2507
2508GetHdfsBlockLocationsRequestProto::GetHdfsBlockLocationsRequestProto()
2509 : ::google::protobuf::Message(), _internal_metadata_(NULL) {
2510 ::google::protobuf::internal::InitSCC(
2511 &protobuf_ClientDatanodeProtocol_2eproto::scc_info_GetHdfsBlockLocationsRequestProto.base);
2512 SharedCtor();
2513 // @@protoc_insertion_point(constructor:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2514}
2515GetHdfsBlockLocationsRequestProto::GetHdfsBlockLocationsRequestProto(const GetHdfsBlockLocationsRequestProto& from)
2516 : ::google::protobuf::Message(),
2517 _internal_metadata_(NULL),
2518 _has_bits_(from._has_bits_),
2519 blocks_(from.blocks_),
2520 tokens_(from.tokens_) {
2521 _internal_metadata_.MergeFrom(from._internal_metadata_);
2522 // @@protoc_insertion_point(copy_constructor:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2523}
2524
2525void GetHdfsBlockLocationsRequestProto::SharedCtor() {
2526}
2527
2528GetHdfsBlockLocationsRequestProto::~GetHdfsBlockLocationsRequestProto() {
2529 // @@protoc_insertion_point(destructor:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2530 SharedDtor();
2531}
2532
2533void GetHdfsBlockLocationsRequestProto::SharedDtor() {
2534}
2535
2536void GetHdfsBlockLocationsRequestProto::SetCachedSize(int size) const {
2537 _cached_size_.Set(size);
2538}
2539const ::google::protobuf::Descriptor* GetHdfsBlockLocationsRequestProto::descriptor() {
2540 ::protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
2541 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
2542}
2543
2544const GetHdfsBlockLocationsRequestProto& GetHdfsBlockLocationsRequestProto::default_instance() {
2545 ::google::protobuf::internal::InitSCC(&protobuf_ClientDatanodeProtocol_2eproto::scc_info_GetHdfsBlockLocationsRequestProto.base);
2546 return *internal_default_instance();
2547}
2548
2549
2550void GetHdfsBlockLocationsRequestProto::Clear() {
2551// @@protoc_insertion_point(message_clear_start:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2552 ::google::protobuf::uint32 cached_has_bits = 0;
2553 // Prevent compiler warnings about cached_has_bits being unused
2554 (void) cached_has_bits;
2555
2556 blocks_.Clear();
2557 tokens_.Clear();
2558 _has_bits_.Clear();
2559 _internal_metadata_.Clear();
2560}
2561
2562bool GetHdfsBlockLocationsRequestProto::MergePartialFromCodedStream(
2563 ::google::protobuf::io::CodedInputStream* input) {
2564#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
2565 ::google::protobuf::uint32 tag;
2566 // @@protoc_insertion_point(parse_start:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2567 for (;;) {
2568 ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
2569 tag = p.first;
2570 if (!p.second) goto handle_unusual;
2571 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2572 // repeated .Hdfs.Internal.ExtendedBlockProto blocks = 1;
2573 case 1: {
2574 if (static_cast< ::google::protobuf::uint8>(tag) ==
2575 static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
2576 DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
2577 input, add_blocks()));
2578 } else {
2579 goto handle_unusual;
2580 }
2581 break;
2582 }
2583
2584 // repeated .Hdfs.Internal.TokenProto tokens = 2;
2585 case 2: {
2586 if (static_cast< ::google::protobuf::uint8>(tag) ==
2587 static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {
2588 DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
2589 input, add_tokens()));
2590 } else {
2591 goto handle_unusual;
2592 }
2593 break;
2594 }
2595
2596 default: {
2597 handle_unusual:
2598 if (tag == 0) {
2599 goto success;
2600 }
2601 DO_(::google::protobuf::internal::WireFormat::SkipField(
2602 input, tag, _internal_metadata_.mutable_unknown_fields()));
2603 break;
2604 }
2605 }
2606 }
2607success:
2608 // @@protoc_insertion_point(parse_success:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2609 return true;
2610failure:
2611 // @@protoc_insertion_point(parse_failure:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2612 return false;
2613#undef DO_
2614}
2615
2616void GetHdfsBlockLocationsRequestProto::SerializeWithCachedSizes(
2617 ::google::protobuf::io::CodedOutputStream* output) const {
2618 // @@protoc_insertion_point(serialize_start:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2619 ::google::protobuf::uint32 cached_has_bits = 0;
2620 (void) cached_has_bits;
2621
2622 // repeated .Hdfs.Internal.ExtendedBlockProto blocks = 1;
2623 for (unsigned int i = 0,
2624 n = static_cast<unsigned int>(this->blocks_size()); i < n; i++) {
2625 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2626 1,
2627 this->blocks(static_cast<int>(i)),
2628 output);
2629 }
2630
2631 // repeated .Hdfs.Internal.TokenProto tokens = 2;
2632 for (unsigned int i = 0,
2633 n = static_cast<unsigned int>(this->tokens_size()); i < n; i++) {
2634 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2635 2,
2636 this->tokens(static_cast<int>(i)),
2637 output);
2638 }
2639
2640 if (_internal_metadata_.have_unknown_fields()) {
2641 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2642 _internal_metadata_.unknown_fields(), output);
2643 }
2644 // @@protoc_insertion_point(serialize_end:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2645}
2646
2647::google::protobuf::uint8* GetHdfsBlockLocationsRequestProto::InternalSerializeWithCachedSizesToArray(
2648 bool deterministic, ::google::protobuf::uint8* target) const {
2649 (void)deterministic; // Unused
2650 // @@protoc_insertion_point(serialize_to_array_start:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2651 ::google::protobuf::uint32 cached_has_bits = 0;
2652 (void) cached_has_bits;
2653
2654 // repeated .Hdfs.Internal.ExtendedBlockProto blocks = 1;
2655 for (unsigned int i = 0,
2656 n = static_cast<unsigned int>(this->blocks_size()); i < n; i++) {
2657 target = ::google::protobuf::internal::WireFormatLite::
2658 InternalWriteMessageToArray(
2659 1, this->blocks(static_cast<int>(i)), deterministic, target);
2660 }
2661
2662 // repeated .Hdfs.Internal.TokenProto tokens = 2;
2663 for (unsigned int i = 0,
2664 n = static_cast<unsigned int>(this->tokens_size()); i < n; i++) {
2665 target = ::google::protobuf::internal::WireFormatLite::
2666 InternalWriteMessageToArray(
2667 2, this->tokens(static_cast<int>(i)), deterministic, target);
2668 }
2669
2670 if (_internal_metadata_.have_unknown_fields()) {
2671 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2672 _internal_metadata_.unknown_fields(), target);
2673 }
2674 // @@protoc_insertion_point(serialize_to_array_end:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2675 return target;
2676}
2677
2678size_t GetHdfsBlockLocationsRequestProto::ByteSizeLong() const {
2679// @@protoc_insertion_point(message_byte_size_start:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2680 size_t total_size = 0;
2681
2682 if (_internal_metadata_.have_unknown_fields()) {
2683 total_size +=
2684 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2685 _internal_metadata_.unknown_fields());
2686 }
2687 // repeated .Hdfs.Internal.ExtendedBlockProto blocks = 1;
2688 {
2689 unsigned int count = static_cast<unsigned int>(this->blocks_size());
2690 total_size += 1UL * count;
2691 for (unsigned int i = 0; i < count; i++) {
2692 total_size +=
2693 ::google::protobuf::internal::WireFormatLite::MessageSize(
2694 this->blocks(static_cast<int>(i)));
2695 }
2696 }
2697
2698 // repeated .Hdfs.Internal.TokenProto tokens = 2;
2699 {
2700 unsigned int count = static_cast<unsigned int>(this->tokens_size());
2701 total_size += 1UL * count;
2702 for (unsigned int i = 0; i < count; i++) {
2703 total_size +=
2704 ::google::protobuf::internal::WireFormatLite::MessageSize(
2705 this->tokens(static_cast<int>(i)));
2706 }
2707 }
2708
2709 int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
2710 SetCachedSize(cached_size);
2711 return total_size;
2712}
2713
2714void GetHdfsBlockLocationsRequestProto::MergeFrom(const ::google::protobuf::Message& from) {
2715// @@protoc_insertion_point(generalized_merge_from_start:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2716 GOOGLE_DCHECK_NE(&from, this);
2717 const GetHdfsBlockLocationsRequestProto* source =
2718 ::google::protobuf::internal::DynamicCastToGenerated<const GetHdfsBlockLocationsRequestProto>(
2719 &from);
2720 if (source == NULL) {
2721 // @@protoc_insertion_point(generalized_merge_from_cast_fail:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2722 ::google::protobuf::internal::ReflectionOps::Merge(from, this);
2723 } else {
2724 // @@protoc_insertion_point(generalized_merge_from_cast_success:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2725 MergeFrom(*source);
2726 }
2727}
2728
2729void GetHdfsBlockLocationsRequestProto::MergeFrom(const GetHdfsBlockLocationsRequestProto& from) {
2730// @@protoc_insertion_point(class_specific_merge_from_start:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2731 GOOGLE_DCHECK_NE(&from, this);
2732 _internal_metadata_.MergeFrom(from._internal_metadata_);
2733 ::google::protobuf::uint32 cached_has_bits = 0;
2734 (void) cached_has_bits;
2735
2736 blocks_.MergeFrom(from.blocks_);
2737 tokens_.MergeFrom(from.tokens_);
2738}
2739
2740void GetHdfsBlockLocationsRequestProto::CopyFrom(const ::google::protobuf::Message& from) {
2741// @@protoc_insertion_point(generalized_copy_from_start:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2742 if (&from == this) return;
2743 Clear();
2744 MergeFrom(from);
2745}
2746
2747void GetHdfsBlockLocationsRequestProto::CopyFrom(const GetHdfsBlockLocationsRequestProto& from) {
2748// @@protoc_insertion_point(class_specific_copy_from_start:Hdfs.Internal.GetHdfsBlockLocationsRequestProto)
2749 if (&from == this) return;
2750 Clear();
2751 MergeFrom(from);
2752}
2753
2754bool GetHdfsBlockLocationsRequestProto::IsInitialized() const {
2755 if (!::google::protobuf::internal::AllAreInitialized(this->blocks())) return false;
2756 if (!::google::protobuf::internal::AllAreInitialized(this->tokens())) return false;
2757 return true;
2758}
2759
2760void GetHdfsBlockLocationsRequestProto::Swap(GetHdfsBlockLocationsRequestProto* other) {
2761 if (other == this) return;
2762 InternalSwap(other);
2763}
2764void GetHdfsBlockLocationsRequestProto::InternalSwap(GetHdfsBlockLocationsRequestProto* other) {
2765 using std::swap;
2766 CastToBase(&blocks_)->InternalSwap(CastToBase(&other->blocks_));
2767 CastToBase(&tokens_)->InternalSwap(CastToBase(&other->tokens_));
2768 swap(_has_bits_[0], other->_has_bits_[0]);
2769 _internal_metadata_.Swap(&other->_internal_metadata_);
2770}
2771
2772::google::protobuf::Metadata GetHdfsBlockLocationsRequestProto::GetMetadata() const {
2773 protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
2774 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages];
2775}
2776
2777
2778// ===================================================================
2779
2780void GetHdfsBlockLocationsResponseProto::InitAsDefaultInstance() {
2781}
2782#if !defined(_MSC_VER) || _MSC_VER >= 1900
2783const int GetHdfsBlockLocationsResponseProto::kVolumeIdsFieldNumber;
2784const int GetHdfsBlockLocationsResponseProto::kVolumeIndexesFieldNumber;
2785#endif // !defined(_MSC_VER) || _MSC_VER >= 1900
2786
2787GetHdfsBlockLocationsResponseProto::GetHdfsBlockLocationsResponseProto()
2788 : ::google::protobuf::Message(), _internal_metadata_(NULL) {
2789 ::google::protobuf::internal::InitSCC(
2790 &protobuf_ClientDatanodeProtocol_2eproto::scc_info_GetHdfsBlockLocationsResponseProto.base);
2791 SharedCtor();
2792 // @@protoc_insertion_point(constructor:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2793}
2794GetHdfsBlockLocationsResponseProto::GetHdfsBlockLocationsResponseProto(const GetHdfsBlockLocationsResponseProto& from)
2795 : ::google::protobuf::Message(),
2796 _internal_metadata_(NULL),
2797 _has_bits_(from._has_bits_),
2798 volumeids_(from.volumeids_),
2799 volumeindexes_(from.volumeindexes_) {
2800 _internal_metadata_.MergeFrom(from._internal_metadata_);
2801 // @@protoc_insertion_point(copy_constructor:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2802}
2803
2804void GetHdfsBlockLocationsResponseProto::SharedCtor() {
2805}
2806
2807GetHdfsBlockLocationsResponseProto::~GetHdfsBlockLocationsResponseProto() {
2808 // @@protoc_insertion_point(destructor:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2809 SharedDtor();
2810}
2811
2812void GetHdfsBlockLocationsResponseProto::SharedDtor() {
2813}
2814
2815void GetHdfsBlockLocationsResponseProto::SetCachedSize(int size) const {
2816 _cached_size_.Set(size);
2817}
2818const ::google::protobuf::Descriptor* GetHdfsBlockLocationsResponseProto::descriptor() {
2819 ::protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
2820 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
2821}
2822
2823const GetHdfsBlockLocationsResponseProto& GetHdfsBlockLocationsResponseProto::default_instance() {
2824 ::google::protobuf::internal::InitSCC(&protobuf_ClientDatanodeProtocol_2eproto::scc_info_GetHdfsBlockLocationsResponseProto.base);
2825 return *internal_default_instance();
2826}
2827
2828
2829void GetHdfsBlockLocationsResponseProto::Clear() {
2830// @@protoc_insertion_point(message_clear_start:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2831 ::google::protobuf::uint32 cached_has_bits = 0;
2832 // Prevent compiler warnings about cached_has_bits being unused
2833 (void) cached_has_bits;
2834
2835 volumeids_.Clear();
2836 volumeindexes_.Clear();
2837 _has_bits_.Clear();
2838 _internal_metadata_.Clear();
2839}
2840
2841bool GetHdfsBlockLocationsResponseProto::MergePartialFromCodedStream(
2842 ::google::protobuf::io::CodedInputStream* input) {
2843#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
2844 ::google::protobuf::uint32 tag;
2845 // @@protoc_insertion_point(parse_start:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2846 for (;;) {
2847 ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
2848 tag = p.first;
2849 if (!p.second) goto handle_unusual;
2850 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2851 // repeated bytes volumeIds = 1;
2852 case 1: {
2853 if (static_cast< ::google::protobuf::uint8>(tag) ==
2854 static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
2855 DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
2856 input, this->add_volumeids()));
2857 } else {
2858 goto handle_unusual;
2859 }
2860 break;
2861 }
2862
2863 // repeated uint32 volumeIndexes = 2;
2864 case 2: {
2865 if (static_cast< ::google::protobuf::uint8>(tag) ==
2866 static_cast< ::google::protobuf::uint8>(16u /* 16 & 0xFF */)) {
2867 DO_((::google::protobuf::internal::WireFormatLite::ReadRepeatedPrimitive<
2868 ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
2869 1, 16u, input, this->mutable_volumeindexes())));
2870 } else if (
2871 static_cast< ::google::protobuf::uint8>(tag) ==
2872 static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {
2873 DO_((::google::protobuf::internal::WireFormatLite::ReadPackedPrimitiveNoInline<
2874 ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
2875 input, this->mutable_volumeindexes())));
2876 } else {
2877 goto handle_unusual;
2878 }
2879 break;
2880 }
2881
2882 default: {
2883 handle_unusual:
2884 if (tag == 0) {
2885 goto success;
2886 }
2887 DO_(::google::protobuf::internal::WireFormat::SkipField(
2888 input, tag, _internal_metadata_.mutable_unknown_fields()));
2889 break;
2890 }
2891 }
2892 }
2893success:
2894 // @@protoc_insertion_point(parse_success:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2895 return true;
2896failure:
2897 // @@protoc_insertion_point(parse_failure:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2898 return false;
2899#undef DO_
2900}
2901
2902void GetHdfsBlockLocationsResponseProto::SerializeWithCachedSizes(
2903 ::google::protobuf::io::CodedOutputStream* output) const {
2904 // @@protoc_insertion_point(serialize_start:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2905 ::google::protobuf::uint32 cached_has_bits = 0;
2906 (void) cached_has_bits;
2907
2908 // repeated bytes volumeIds = 1;
2909 for (int i = 0, n = this->volumeids_size(); i < n; i++) {
2910 ::google::protobuf::internal::WireFormatLite::WriteBytes(
2911 1, this->volumeids(i), output);
2912 }
2913
2914 // repeated uint32 volumeIndexes = 2;
2915 for (int i = 0, n = this->volumeindexes_size(); i < n; i++) {
2916 ::google::protobuf::internal::WireFormatLite::WriteUInt32(
2917 2, this->volumeindexes(i), output);
2918 }
2919
2920 if (_internal_metadata_.have_unknown_fields()) {
2921 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2922 _internal_metadata_.unknown_fields(), output);
2923 }
2924 // @@protoc_insertion_point(serialize_end:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2925}
2926
2927::google::protobuf::uint8* GetHdfsBlockLocationsResponseProto::InternalSerializeWithCachedSizesToArray(
2928 bool deterministic, ::google::protobuf::uint8* target) const {
2929 (void)deterministic; // Unused
2930 // @@protoc_insertion_point(serialize_to_array_start:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2931 ::google::protobuf::uint32 cached_has_bits = 0;
2932 (void) cached_has_bits;
2933
2934 // repeated bytes volumeIds = 1;
2935 for (int i = 0, n = this->volumeids_size(); i < n; i++) {
2936 target = ::google::protobuf::internal::WireFormatLite::
2937 WriteBytesToArray(1, this->volumeids(i), target);
2938 }
2939
2940 // repeated uint32 volumeIndexes = 2;
2941 target = ::google::protobuf::internal::WireFormatLite::
2942 WriteUInt32ToArray(2, this->volumeindexes_, target);
2943
2944 if (_internal_metadata_.have_unknown_fields()) {
2945 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2946 _internal_metadata_.unknown_fields(), target);
2947 }
2948 // @@protoc_insertion_point(serialize_to_array_end:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2949 return target;
2950}
2951
2952size_t GetHdfsBlockLocationsResponseProto::ByteSizeLong() const {
2953// @@protoc_insertion_point(message_byte_size_start:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2954 size_t total_size = 0;
2955
2956 if (_internal_metadata_.have_unknown_fields()) {
2957 total_size +=
2958 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2959 _internal_metadata_.unknown_fields());
2960 }
2961 // repeated bytes volumeIds = 1;
2962 total_size += 1 *
2963 ::google::protobuf::internal::FromIntSize(this->volumeids_size());
2964 for (int i = 0, n = this->volumeids_size(); i < n; i++) {
2965 total_size += ::google::protobuf::internal::WireFormatLite::BytesSize(
2966 this->volumeids(i));
2967 }
2968
2969 // repeated uint32 volumeIndexes = 2;
2970 {
2971 size_t data_size = ::google::protobuf::internal::WireFormatLite::
2972 UInt32Size(this->volumeindexes_);
2973 total_size += 1 *
2974 ::google::protobuf::internal::FromIntSize(this->volumeindexes_size());
2975 total_size += data_size;
2976 }
2977
2978 int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
2979 SetCachedSize(cached_size);
2980 return total_size;
2981}
2982
2983void GetHdfsBlockLocationsResponseProto::MergeFrom(const ::google::protobuf::Message& from) {
2984// @@protoc_insertion_point(generalized_merge_from_start:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2985 GOOGLE_DCHECK_NE(&from, this);
2986 const GetHdfsBlockLocationsResponseProto* source =
2987 ::google::protobuf::internal::DynamicCastToGenerated<const GetHdfsBlockLocationsResponseProto>(
2988 &from);
2989 if (source == NULL) {
2990 // @@protoc_insertion_point(generalized_merge_from_cast_fail:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2991 ::google::protobuf::internal::ReflectionOps::Merge(from, this);
2992 } else {
2993 // @@protoc_insertion_point(generalized_merge_from_cast_success:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
2994 MergeFrom(*source);
2995 }
2996}
2997
2998void GetHdfsBlockLocationsResponseProto::MergeFrom(const GetHdfsBlockLocationsResponseProto& from) {
2999// @@protoc_insertion_point(class_specific_merge_from_start:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
3000 GOOGLE_DCHECK_NE(&from, this);
3001 _internal_metadata_.MergeFrom(from._internal_metadata_);
3002 ::google::protobuf::uint32 cached_has_bits = 0;
3003 (void) cached_has_bits;
3004
3005 volumeids_.MergeFrom(from.volumeids_);
3006 volumeindexes_.MergeFrom(from.volumeindexes_);
3007}
3008
3009void GetHdfsBlockLocationsResponseProto::CopyFrom(const ::google::protobuf::Message& from) {
3010// @@protoc_insertion_point(generalized_copy_from_start:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
3011 if (&from == this) return;
3012 Clear();
3013 MergeFrom(from);
3014}
3015
3016void GetHdfsBlockLocationsResponseProto::CopyFrom(const GetHdfsBlockLocationsResponseProto& from) {
3017// @@protoc_insertion_point(class_specific_copy_from_start:Hdfs.Internal.GetHdfsBlockLocationsResponseProto)
3018 if (&from == this) return;
3019 Clear();
3020 MergeFrom(from);
3021}
3022
3023bool GetHdfsBlockLocationsResponseProto::IsInitialized() const {
3024 return true;
3025}
3026
3027void GetHdfsBlockLocationsResponseProto::Swap(GetHdfsBlockLocationsResponseProto* other) {
3028 if (other == this) return;
3029 InternalSwap(other);
3030}
3031void GetHdfsBlockLocationsResponseProto::InternalSwap(GetHdfsBlockLocationsResponseProto* other) {
3032 using std::swap;
3033 volumeids_.InternalSwap(CastToBase(&other->volumeids_));
3034 volumeindexes_.InternalSwap(&other->volumeindexes_);
3035 swap(_has_bits_[0], other->_has_bits_[0]);
3036 _internal_metadata_.Swap(&other->_internal_metadata_);
3037}
3038
3039::google::protobuf::Metadata GetHdfsBlockLocationsResponseProto::GetMetadata() const {
3040 protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
3041 return ::protobuf_ClientDatanodeProtocol_2eproto::file_level_metadata[kIndexInFileMessages];
3042}
3043
3044
3045// ===================================================================
3046
3047ClientDatanodeProtocolService::~ClientDatanodeProtocolService() {}
3048
3049const ::google::protobuf::ServiceDescriptor* ClientDatanodeProtocolService::descriptor() {
3050 protobuf_ClientDatanodeProtocol_2eproto::protobuf_AssignDescriptorsOnce();
3051 return protobuf_ClientDatanodeProtocol_2eproto::file_level_service_descriptors[0];
3052}
3053
3054const ::google::protobuf::ServiceDescriptor* ClientDatanodeProtocolService::GetDescriptor() {
3055 return descriptor();
3056}
3057
3058void ClientDatanodeProtocolService::getReplicaVisibleLength(::google::protobuf::RpcController* controller,
3059 const ::Hdfs::Internal::GetReplicaVisibleLengthRequestProto*,
3060 ::Hdfs::Internal::GetReplicaVisibleLengthResponseProto*,
3061 ::google::protobuf::Closure* done) {
3062 controller->SetFailed("Method getReplicaVisibleLength() not implemented.");
3063 done->Run();
3064}
3065
3066void ClientDatanodeProtocolService::refreshNamenodes(::google::protobuf::RpcController* controller,
3067 const ::Hdfs::Internal::RefreshNamenodesRequestProto*,
3068 ::Hdfs::Internal::RefreshNamenodesResponseProto*,
3069 ::google::protobuf::Closure* done) {
3070 controller->SetFailed("Method refreshNamenodes() not implemented.");
3071 done->Run();
3072}
3073
3074void ClientDatanodeProtocolService::deleteBlockPool(::google::protobuf::RpcController* controller,
3075 const ::Hdfs::Internal::DeleteBlockPoolRequestProto*,
3076 ::Hdfs::Internal::DeleteBlockPoolResponseProto*,
3077 ::google::protobuf::Closure* done) {
3078 controller->SetFailed("Method deleteBlockPool() not implemented.");
3079 done->Run();
3080}
3081
3082void ClientDatanodeProtocolService::getBlockLocalPathInfo(::google::protobuf::RpcController* controller,
3083 const ::Hdfs::Internal::GetBlockLocalPathInfoRequestProto*,
3084 ::Hdfs::Internal::GetBlockLocalPathInfoResponseProto*,
3085 ::google::protobuf::Closure* done) {
3086 controller->SetFailed("Method getBlockLocalPathInfo() not implemented.");
3087 done->Run();
3088}
3089
3090void ClientDatanodeProtocolService::getHdfsBlockLocations(::google::protobuf::RpcController* controller,
3091 const ::Hdfs::Internal::GetHdfsBlockLocationsRequestProto*,
3092 ::Hdfs::Internal::GetHdfsBlockLocationsResponseProto*,
3093 ::google::protobuf::Closure* done) {
3094 controller->SetFailed("Method getHdfsBlockLocations() not implemented.");
3095 done->Run();
3096}
3097
3098void ClientDatanodeProtocolService::CallMethod(const ::google::protobuf::MethodDescriptor* method,
3099 ::google::protobuf::RpcController* controller,
3100 const ::google::protobuf::Message* request,
3101 ::google::protobuf::Message* response,
3102 ::google::protobuf::Closure* done) {
3103 GOOGLE_DCHECK_EQ(method->service(), protobuf_ClientDatanodeProtocol_2eproto::file_level_service_descriptors[0]);
3104 switch(method->index()) {
3105 case 0:
3106 getReplicaVisibleLength(controller,
3107 ::google::protobuf::down_cast<const ::Hdfs::Internal::GetReplicaVisibleLengthRequestProto*>(request),
3108 ::google::protobuf::down_cast< ::Hdfs::Internal::GetReplicaVisibleLengthResponseProto*>(response),
3109 done);
3110 break;
3111 case 1:
3112 refreshNamenodes(controller,
3113 ::google::protobuf::down_cast<const ::Hdfs::Internal::RefreshNamenodesRequestProto*>(request),
3114 ::google::protobuf::down_cast< ::Hdfs::Internal::RefreshNamenodesResponseProto*>(response),
3115 done);
3116 break;
3117 case 2:
3118 deleteBlockPool(controller,
3119 ::google::protobuf::down_cast<const ::Hdfs::Internal::DeleteBlockPoolRequestProto*>(request),
3120 ::google::protobuf::down_cast< ::Hdfs::Internal::DeleteBlockPoolResponseProto*>(response),
3121 done);
3122 break;
3123 case 3:
3124 getBlockLocalPathInfo(controller,
3125 ::google::protobuf::down_cast<const ::Hdfs::Internal::GetBlockLocalPathInfoRequestProto*>(request),
3126 ::google::protobuf::down_cast< ::Hdfs::Internal::GetBlockLocalPathInfoResponseProto*>(response),
3127 done);
3128 break;
3129 case 4:
3130 getHdfsBlockLocations(controller,
3131 ::google::protobuf::down_cast<const ::Hdfs::Internal::GetHdfsBlockLocationsRequestProto*>(request),
3132 ::google::protobuf::down_cast< ::Hdfs::Internal::GetHdfsBlockLocationsResponseProto*>(response),
3133 done);
3134 break;
3135 default:
3136 GOOGLE_LOG(FATAL) << "Bad method index; this should never happen.";
3137 break;
3138 }
3139}
3140
3141const ::google::protobuf::Message& ClientDatanodeProtocolService::GetRequestPrototype(
3142 const ::google::protobuf::MethodDescriptor* method) const {
3143 GOOGLE_DCHECK_EQ(method->service(), descriptor());
3144 switch(method->index()) {
3145 case 0:
3146 return ::Hdfs::Internal::GetReplicaVisibleLengthRequestProto::default_instance();
3147 case 1:
3148 return ::Hdfs::Internal::RefreshNamenodesRequestProto::default_instance();
3149 case 2:
3150 return ::Hdfs::Internal::DeleteBlockPoolRequestProto::default_instance();
3151 case 3:
3152 return ::Hdfs::Internal::GetBlockLocalPathInfoRequestProto::default_instance();
3153 case 4:
3154 return ::Hdfs::Internal::GetHdfsBlockLocationsRequestProto::default_instance();
3155 default:
3156 GOOGLE_LOG(FATAL) << "Bad method index; this should never happen.";
3157 return *::google::protobuf::MessageFactory::generated_factory()
3158 ->GetPrototype(method->input_type());
3159 }
3160}
3161
3162const ::google::protobuf::Message& ClientDatanodeProtocolService::GetResponsePrototype(
3163 const ::google::protobuf::MethodDescriptor* method) const {
3164 GOOGLE_DCHECK_EQ(method->service(), descriptor());
3165 switch(method->index()) {
3166 case 0:
3167 return ::Hdfs::Internal::GetReplicaVisibleLengthResponseProto::default_instance();
3168 case 1:
3169 return ::Hdfs::Internal::RefreshNamenodesResponseProto::default_instance();
3170 case 2:
3171 return ::Hdfs::Internal::DeleteBlockPoolResponseProto::default_instance();
3172 case 3:
3173 return ::Hdfs::Internal::GetBlockLocalPathInfoResponseProto::default_instance();
3174 case 4:
3175 return ::Hdfs::Internal::GetHdfsBlockLocationsResponseProto::default_instance();
3176 default:
3177 GOOGLE_LOG(FATAL) << "Bad method index; this should never happen.";
3178 return *::google::protobuf::MessageFactory::generated_factory()
3179 ->GetPrototype(method->output_type());
3180 }
3181}
3182
3183ClientDatanodeProtocolService_Stub::ClientDatanodeProtocolService_Stub(::google::protobuf::RpcChannel* channel)
3184 : channel_(channel), owns_channel_(false) {}
3185ClientDatanodeProtocolService_Stub::ClientDatanodeProtocolService_Stub(
3186 ::google::protobuf::RpcChannel* channel,
3187 ::google::protobuf::Service::ChannelOwnership ownership)
3188 : channel_(channel),
3189 owns_channel_(ownership == ::google::protobuf::Service::STUB_OWNS_CHANNEL) {}
3190ClientDatanodeProtocolService_Stub::~ClientDatanodeProtocolService_Stub() {
3191 if (owns_channel_) delete channel_;
3192}
3193
3194void ClientDatanodeProtocolService_Stub::getReplicaVisibleLength(::google::protobuf::RpcController* controller,
3195 const ::Hdfs::Internal::GetReplicaVisibleLengthRequestProto* request,
3196 ::Hdfs::Internal::GetReplicaVisibleLengthResponseProto* response,
3197 ::google::protobuf::Closure* done) {
3198 channel_->CallMethod(descriptor()->method(0),
3199 controller, request, response, done);
3200}
3201void ClientDatanodeProtocolService_Stub::refreshNamenodes(::google::protobuf::RpcController* controller,
3202 const ::Hdfs::Internal::RefreshNamenodesRequestProto* request,
3203 ::Hdfs::Internal::RefreshNamenodesResponseProto* response,
3204 ::google::protobuf::Closure* done) {
3205 channel_->CallMethod(descriptor()->method(1),
3206 controller, request, response, done);
3207}
3208void ClientDatanodeProtocolService_Stub::deleteBlockPool(::google::protobuf::RpcController* controller,
3209 const ::Hdfs::Internal::DeleteBlockPoolRequestProto* request,
3210 ::Hdfs::Internal::DeleteBlockPoolResponseProto* response,
3211 ::google::protobuf::Closure* done) {
3212 channel_->CallMethod(descriptor()->method(2),
3213 controller, request, response, done);
3214}
3215void ClientDatanodeProtocolService_Stub::getBlockLocalPathInfo(::google::protobuf::RpcController* controller,
3216 const ::Hdfs::Internal::GetBlockLocalPathInfoRequestProto* request,
3217 ::Hdfs::Internal::GetBlockLocalPathInfoResponseProto* response,
3218 ::google::protobuf::Closure* done) {
3219 channel_->CallMethod(descriptor()->method(3),
3220 controller, request, response, done);
3221}
3222void ClientDatanodeProtocolService_Stub::getHdfsBlockLocations(::google::protobuf::RpcController* controller,
3223 const ::Hdfs::Internal::GetHdfsBlockLocationsRequestProto* request,
3224 ::Hdfs::Internal::GetHdfsBlockLocationsResponseProto* response,
3225 ::google::protobuf::Closure* done) {
3226 channel_->CallMethod(descriptor()->method(4),
3227 controller, request, response, done);
3228}
3229
3230// @@protoc_insertion_point(namespace_scope)
3231} // namespace Internal
3232} // namespace Hdfs
3233namespace google {
3234namespace protobuf {
3235template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::Hdfs::Internal::GetReplicaVisibleLengthRequestProto* Arena::CreateMaybeMessage< ::Hdfs::Internal::GetReplicaVisibleLengthRequestProto >(Arena* arena) {
3236 return Arena::CreateInternal< ::Hdfs::Internal::GetReplicaVisibleLengthRequestProto >(arena);
3237}
3238template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::Hdfs::Internal::GetReplicaVisibleLengthResponseProto* Arena::CreateMaybeMessage< ::Hdfs::Internal::GetReplicaVisibleLengthResponseProto >(Arena* arena) {
3239 return Arena::CreateInternal< ::Hdfs::Internal::GetReplicaVisibleLengthResponseProto >(arena);
3240}
3241template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::Hdfs::Internal::RefreshNamenodesRequestProto* Arena::CreateMaybeMessage< ::Hdfs::Internal::RefreshNamenodesRequestProto >(Arena* arena) {
3242 return Arena::CreateInternal< ::Hdfs::Internal::RefreshNamenodesRequestProto >(arena);
3243}
3244template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::Hdfs::Internal::RefreshNamenodesResponseProto* Arena::CreateMaybeMessage< ::Hdfs::Internal::RefreshNamenodesResponseProto >(Arena* arena) {
3245 return Arena::CreateInternal< ::Hdfs::Internal::RefreshNamenodesResponseProto >(arena);
3246}
3247template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::Hdfs::Internal::DeleteBlockPoolRequestProto* Arena::CreateMaybeMessage< ::Hdfs::Internal::DeleteBlockPoolRequestProto >(Arena* arena) {
3248 return Arena::CreateInternal< ::Hdfs::Internal::DeleteBlockPoolRequestProto >(arena);
3249}
3250template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::Hdfs::Internal::DeleteBlockPoolResponseProto* Arena::CreateMaybeMessage< ::Hdfs::Internal::DeleteBlockPoolResponseProto >(Arena* arena) {
3251 return Arena::CreateInternal< ::Hdfs::Internal::DeleteBlockPoolResponseProto >(arena);
3252}
3253template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::Hdfs::Internal::GetBlockLocalPathInfoRequestProto* Arena::CreateMaybeMessage< ::Hdfs::Internal::GetBlockLocalPathInfoRequestProto >(Arena* arena) {
3254 return Arena::CreateInternal< ::Hdfs::Internal::GetBlockLocalPathInfoRequestProto >(arena);
3255}
3256template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::Hdfs::Internal::GetBlockLocalPathInfoResponseProto* Arena::CreateMaybeMessage< ::Hdfs::Internal::GetBlockLocalPathInfoResponseProto >(Arena* arena) {
3257 return Arena::CreateInternal< ::Hdfs::Internal::GetBlockLocalPathInfoResponseProto >(arena);
3258}
3259template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::Hdfs::Internal::GetHdfsBlockLocationsRequestProto* Arena::CreateMaybeMessage< ::Hdfs::Internal::GetHdfsBlockLocationsRequestProto >(Arena* arena) {
3260 return Arena::CreateInternal< ::Hdfs::Internal::GetHdfsBlockLocationsRequestProto >(arena);
3261}
3262template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::Hdfs::Internal::GetHdfsBlockLocationsResponseProto* Arena::CreateMaybeMessage< ::Hdfs::Internal::GetHdfsBlockLocationsResponseProto >(Arena* arena) {
3263 return Arena::CreateInternal< ::Hdfs::Internal::GetHdfsBlockLocationsResponseProto >(arena);
3264}
3265} // namespace protobuf
3266} // namespace google
3267
3268// @@protoc_insertion_point(global_scope)
3269