1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: datatransfer.proto 3 4package hadoop_hdfs 5 6import proto "github.com/golang/protobuf/proto" 7import fmt "fmt" 8import math "math" 9import hadoop_common "github.com/colinmarc/hdfs/v2/internal/protocol/hadoop_common" 10 11// Reference imports to suppress errors if they are not otherwise used. 12var _ = proto.Marshal 13var _ = fmt.Errorf 14var _ = math.Inf 15 16// Status is a 4-bit enum 17type Status int32 18 19const ( 20 Status_SUCCESS Status = 0 21 Status_ERROR Status = 1 22 Status_ERROR_CHECKSUM Status = 2 23 Status_ERROR_INVALID Status = 3 24 Status_ERROR_EXISTS Status = 4 25 Status_ERROR_ACCESS_TOKEN Status = 5 26 Status_CHECKSUM_OK Status = 6 27 Status_ERROR_UNSUPPORTED Status = 7 28 Status_OOB_RESTART Status = 8 29 Status_OOB_RESERVED1 Status = 9 30 Status_OOB_RESERVED2 Status = 10 31 Status_OOB_RESERVED3 Status = 11 32 Status_IN_PROGRESS Status = 12 33) 34 35var Status_name = map[int32]string{ 36 0: "SUCCESS", 37 1: "ERROR", 38 2: "ERROR_CHECKSUM", 39 3: "ERROR_INVALID", 40 4: "ERROR_EXISTS", 41 5: "ERROR_ACCESS_TOKEN", 42 6: "CHECKSUM_OK", 43 7: "ERROR_UNSUPPORTED", 44 8: "OOB_RESTART", 45 9: "OOB_RESERVED1", 46 10: "OOB_RESERVED2", 47 11: "OOB_RESERVED3", 48 12: "IN_PROGRESS", 49} 50var Status_value = map[string]int32{ 51 "SUCCESS": 0, 52 "ERROR": 1, 53 "ERROR_CHECKSUM": 2, 54 "ERROR_INVALID": 3, 55 "ERROR_EXISTS": 4, 56 "ERROR_ACCESS_TOKEN": 5, 57 "CHECKSUM_OK": 6, 58 "ERROR_UNSUPPORTED": 7, 59 "OOB_RESTART": 8, 60 "OOB_RESERVED1": 9, 61 "OOB_RESERVED2": 10, 62 "OOB_RESERVED3": 11, 63 "IN_PROGRESS": 12, 64} 65 66func (x Status) Enum() *Status { 67 p := new(Status) 68 *p = x 69 return p 70} 71func (x Status) String() string { 72 return proto.EnumName(Status_name, int32(x)) 73} 74func (x *Status) UnmarshalJSON(data []byte) error { 75 value, err := proto.UnmarshalJSONEnum(Status_value, data, "Status") 76 if err != nil { 77 return err 78 } 79 *x = Status(value) 80 return nil 81} 82func (Status) EnumDescriptor() ([]byte, []int) { return fileDescriptor5, []int{0} } 83 84type ShortCircuitFdResponse int32 85 86const ( 87 ShortCircuitFdResponse_DO_NOT_USE_RECEIPT_VERIFICATION ShortCircuitFdResponse = 0 88 ShortCircuitFdResponse_USE_RECEIPT_VERIFICATION ShortCircuitFdResponse = 1 89) 90 91var ShortCircuitFdResponse_name = map[int32]string{ 92 0: "DO_NOT_USE_RECEIPT_VERIFICATION", 93 1: "USE_RECEIPT_VERIFICATION", 94} 95var ShortCircuitFdResponse_value = map[string]int32{ 96 "DO_NOT_USE_RECEIPT_VERIFICATION": 0, 97 "USE_RECEIPT_VERIFICATION": 1, 98} 99 100func (x ShortCircuitFdResponse) Enum() *ShortCircuitFdResponse { 101 p := new(ShortCircuitFdResponse) 102 *p = x 103 return p 104} 105func (x ShortCircuitFdResponse) String() string { 106 return proto.EnumName(ShortCircuitFdResponse_name, int32(x)) 107} 108func (x *ShortCircuitFdResponse) UnmarshalJSON(data []byte) error { 109 value, err := proto.UnmarshalJSONEnum(ShortCircuitFdResponse_value, data, "ShortCircuitFdResponse") 110 if err != nil { 111 return err 112 } 113 *x = ShortCircuitFdResponse(value) 114 return nil 115} 116func (ShortCircuitFdResponse) EnumDescriptor() ([]byte, []int) { return fileDescriptor5, []int{1} } 117 118type DataTransferEncryptorMessageProto_DataTransferEncryptorStatus int32 119 120const ( 121 DataTransferEncryptorMessageProto_SUCCESS DataTransferEncryptorMessageProto_DataTransferEncryptorStatus = 0 122 DataTransferEncryptorMessageProto_ERROR_UNKNOWN_KEY DataTransferEncryptorMessageProto_DataTransferEncryptorStatus = 1 123 DataTransferEncryptorMessageProto_ERROR DataTransferEncryptorMessageProto_DataTransferEncryptorStatus = 2 124) 125 126var DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_name = map[int32]string{ 127 0: "SUCCESS", 128 1: "ERROR_UNKNOWN_KEY", 129 2: "ERROR", 130} 131var DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_value = map[string]int32{ 132 "SUCCESS": 0, 133 "ERROR_UNKNOWN_KEY": 1, 134 "ERROR": 2, 135} 136 137func (x DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) Enum() *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus { 138 p := new(DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) 139 *p = x 140 return p 141} 142func (x DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) String() string { 143 return proto.EnumName(DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_name, int32(x)) 144} 145func (x *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) UnmarshalJSON(data []byte) error { 146 value, err := proto.UnmarshalJSONEnum(DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_value, data, "DataTransferEncryptorMessageProto_DataTransferEncryptorStatus") 147 if err != nil { 148 return err 149 } 150 *x = DataTransferEncryptorMessageProto_DataTransferEncryptorStatus(value) 151 return nil 152} 153func (DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) EnumDescriptor() ([]byte, []int) { 154 return fileDescriptor5, []int{0, 0} 155} 156 157type OpWriteBlockProto_BlockConstructionStage int32 158 159const ( 160 OpWriteBlockProto_PIPELINE_SETUP_APPEND OpWriteBlockProto_BlockConstructionStage = 0 161 // pipeline set up for failed PIPELINE_SETUP_APPEND recovery 162 OpWriteBlockProto_PIPELINE_SETUP_APPEND_RECOVERY OpWriteBlockProto_BlockConstructionStage = 1 163 // data streaming 164 OpWriteBlockProto_DATA_STREAMING OpWriteBlockProto_BlockConstructionStage = 2 165 // pipeline setup for failed data streaming recovery 166 OpWriteBlockProto_PIPELINE_SETUP_STREAMING_RECOVERY OpWriteBlockProto_BlockConstructionStage = 3 167 // close the block and pipeline 168 OpWriteBlockProto_PIPELINE_CLOSE OpWriteBlockProto_BlockConstructionStage = 4 169 // Recover a failed PIPELINE_CLOSE 170 OpWriteBlockProto_PIPELINE_CLOSE_RECOVERY OpWriteBlockProto_BlockConstructionStage = 5 171 // pipeline set up for block creation 172 OpWriteBlockProto_PIPELINE_SETUP_CREATE OpWriteBlockProto_BlockConstructionStage = 6 173 // transfer RBW for adding datanodes 174 OpWriteBlockProto_TRANSFER_RBW OpWriteBlockProto_BlockConstructionStage = 7 175 // transfer Finalized for adding datanodes 176 OpWriteBlockProto_TRANSFER_FINALIZED OpWriteBlockProto_BlockConstructionStage = 8 177) 178 179var OpWriteBlockProto_BlockConstructionStage_name = map[int32]string{ 180 0: "PIPELINE_SETUP_APPEND", 181 1: "PIPELINE_SETUP_APPEND_RECOVERY", 182 2: "DATA_STREAMING", 183 3: "PIPELINE_SETUP_STREAMING_RECOVERY", 184 4: "PIPELINE_CLOSE", 185 5: "PIPELINE_CLOSE_RECOVERY", 186 6: "PIPELINE_SETUP_CREATE", 187 7: "TRANSFER_RBW", 188 8: "TRANSFER_FINALIZED", 189} 190var OpWriteBlockProto_BlockConstructionStage_value = map[string]int32{ 191 "PIPELINE_SETUP_APPEND": 0, 192 "PIPELINE_SETUP_APPEND_RECOVERY": 1, 193 "DATA_STREAMING": 2, 194 "PIPELINE_SETUP_STREAMING_RECOVERY": 3, 195 "PIPELINE_CLOSE": 4, 196 "PIPELINE_CLOSE_RECOVERY": 5, 197 "PIPELINE_SETUP_CREATE": 6, 198 "TRANSFER_RBW": 7, 199 "TRANSFER_FINALIZED": 8, 200} 201 202func (x OpWriteBlockProto_BlockConstructionStage) Enum() *OpWriteBlockProto_BlockConstructionStage { 203 p := new(OpWriteBlockProto_BlockConstructionStage) 204 *p = x 205 return p 206} 207func (x OpWriteBlockProto_BlockConstructionStage) String() string { 208 return proto.EnumName(OpWriteBlockProto_BlockConstructionStage_name, int32(x)) 209} 210func (x *OpWriteBlockProto_BlockConstructionStage) UnmarshalJSON(data []byte) error { 211 value, err := proto.UnmarshalJSONEnum(OpWriteBlockProto_BlockConstructionStage_value, data, "OpWriteBlockProto_BlockConstructionStage") 212 if err != nil { 213 return err 214 } 215 *x = OpWriteBlockProto_BlockConstructionStage(value) 216 return nil 217} 218func (OpWriteBlockProto_BlockConstructionStage) EnumDescriptor() ([]byte, []int) { 219 return fileDescriptor5, []int{7, 0} 220} 221 222type DataTransferEncryptorMessageProto struct { 223 Status *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus `protobuf:"varint,1,req,name=status,enum=hadoop.hdfs.DataTransferEncryptorMessageProto_DataTransferEncryptorStatus" json:"status,omitempty"` 224 Payload []byte `protobuf:"bytes,2,opt,name=payload" json:"payload,omitempty"` 225 Message *string `protobuf:"bytes,3,opt,name=message" json:"message,omitempty"` 226 CipherOption []*CipherOptionProto `protobuf:"bytes,4,rep,name=cipherOption" json:"cipherOption,omitempty"` 227 XXX_unrecognized []byte `json:"-"` 228} 229 230func (m *DataTransferEncryptorMessageProto) Reset() { *m = DataTransferEncryptorMessageProto{} } 231func (m *DataTransferEncryptorMessageProto) String() string { return proto.CompactTextString(m) } 232func (*DataTransferEncryptorMessageProto) ProtoMessage() {} 233func (*DataTransferEncryptorMessageProto) Descriptor() ([]byte, []int) { 234 return fileDescriptor5, []int{0} 235} 236 237func (m *DataTransferEncryptorMessageProto) GetStatus() DataTransferEncryptorMessageProto_DataTransferEncryptorStatus { 238 if m != nil && m.Status != nil { 239 return *m.Status 240 } 241 return DataTransferEncryptorMessageProto_SUCCESS 242} 243 244func (m *DataTransferEncryptorMessageProto) GetPayload() []byte { 245 if m != nil { 246 return m.Payload 247 } 248 return nil 249} 250 251func (m *DataTransferEncryptorMessageProto) GetMessage() string { 252 if m != nil && m.Message != nil { 253 return *m.Message 254 } 255 return "" 256} 257 258func (m *DataTransferEncryptorMessageProto) GetCipherOption() []*CipherOptionProto { 259 if m != nil { 260 return m.CipherOption 261 } 262 return nil 263} 264 265type BaseHeaderProto struct { 266 Block *ExtendedBlockProto `protobuf:"bytes,1,req,name=block" json:"block,omitempty"` 267 Token *hadoop_common.TokenProto `protobuf:"bytes,2,opt,name=token" json:"token,omitempty"` 268 TraceInfo *DataTransferTraceInfoProto `protobuf:"bytes,3,opt,name=traceInfo" json:"traceInfo,omitempty"` 269 XXX_unrecognized []byte `json:"-"` 270} 271 272func (m *BaseHeaderProto) Reset() { *m = BaseHeaderProto{} } 273func (m *BaseHeaderProto) String() string { return proto.CompactTextString(m) } 274func (*BaseHeaderProto) ProtoMessage() {} 275func (*BaseHeaderProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{1} } 276 277func (m *BaseHeaderProto) GetBlock() *ExtendedBlockProto { 278 if m != nil { 279 return m.Block 280 } 281 return nil 282} 283 284func (m *BaseHeaderProto) GetToken() *hadoop_common.TokenProto { 285 if m != nil { 286 return m.Token 287 } 288 return nil 289} 290 291func (m *BaseHeaderProto) GetTraceInfo() *DataTransferTraceInfoProto { 292 if m != nil { 293 return m.TraceInfo 294 } 295 return nil 296} 297 298type DataTransferTraceInfoProto struct { 299 TraceId *uint64 `protobuf:"varint,1,req,name=traceId" json:"traceId,omitempty"` 300 ParentId *uint64 `protobuf:"varint,2,req,name=parentId" json:"parentId,omitempty"` 301 XXX_unrecognized []byte `json:"-"` 302} 303 304func (m *DataTransferTraceInfoProto) Reset() { *m = DataTransferTraceInfoProto{} } 305func (m *DataTransferTraceInfoProto) String() string { return proto.CompactTextString(m) } 306func (*DataTransferTraceInfoProto) ProtoMessage() {} 307func (*DataTransferTraceInfoProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{2} } 308 309func (m *DataTransferTraceInfoProto) GetTraceId() uint64 { 310 if m != nil && m.TraceId != nil { 311 return *m.TraceId 312 } 313 return 0 314} 315 316func (m *DataTransferTraceInfoProto) GetParentId() uint64 { 317 if m != nil && m.ParentId != nil { 318 return *m.ParentId 319 } 320 return 0 321} 322 323type ClientOperationHeaderProto struct { 324 BaseHeader *BaseHeaderProto `protobuf:"bytes,1,req,name=baseHeader" json:"baseHeader,omitempty"` 325 ClientName *string `protobuf:"bytes,2,req,name=clientName" json:"clientName,omitempty"` 326 XXX_unrecognized []byte `json:"-"` 327} 328 329func (m *ClientOperationHeaderProto) Reset() { *m = ClientOperationHeaderProto{} } 330func (m *ClientOperationHeaderProto) String() string { return proto.CompactTextString(m) } 331func (*ClientOperationHeaderProto) ProtoMessage() {} 332func (*ClientOperationHeaderProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{3} } 333 334func (m *ClientOperationHeaderProto) GetBaseHeader() *BaseHeaderProto { 335 if m != nil { 336 return m.BaseHeader 337 } 338 return nil 339} 340 341func (m *ClientOperationHeaderProto) GetClientName() string { 342 if m != nil && m.ClientName != nil { 343 return *m.ClientName 344 } 345 return "" 346} 347 348type CachingStrategyProto struct { 349 DropBehind *bool `protobuf:"varint,1,opt,name=dropBehind" json:"dropBehind,omitempty"` 350 Readahead *int64 `protobuf:"varint,2,opt,name=readahead" json:"readahead,omitempty"` 351 XXX_unrecognized []byte `json:"-"` 352} 353 354func (m *CachingStrategyProto) Reset() { *m = CachingStrategyProto{} } 355func (m *CachingStrategyProto) String() string { return proto.CompactTextString(m) } 356func (*CachingStrategyProto) ProtoMessage() {} 357func (*CachingStrategyProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{4} } 358 359func (m *CachingStrategyProto) GetDropBehind() bool { 360 if m != nil && m.DropBehind != nil { 361 return *m.DropBehind 362 } 363 return false 364} 365 366func (m *CachingStrategyProto) GetReadahead() int64 { 367 if m != nil && m.Readahead != nil { 368 return *m.Readahead 369 } 370 return 0 371} 372 373type OpReadBlockProto struct { 374 Header *ClientOperationHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"` 375 Offset *uint64 `protobuf:"varint,2,req,name=offset" json:"offset,omitempty"` 376 Len *uint64 `protobuf:"varint,3,req,name=len" json:"len,omitempty"` 377 SendChecksums *bool `protobuf:"varint,4,opt,name=sendChecksums,def=1" json:"sendChecksums,omitempty"` 378 CachingStrategy *CachingStrategyProto `protobuf:"bytes,5,opt,name=cachingStrategy" json:"cachingStrategy,omitempty"` 379 XXX_unrecognized []byte `json:"-"` 380} 381 382func (m *OpReadBlockProto) Reset() { *m = OpReadBlockProto{} } 383func (m *OpReadBlockProto) String() string { return proto.CompactTextString(m) } 384func (*OpReadBlockProto) ProtoMessage() {} 385func (*OpReadBlockProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{5} } 386 387const Default_OpReadBlockProto_SendChecksums bool = true 388 389func (m *OpReadBlockProto) GetHeader() *ClientOperationHeaderProto { 390 if m != nil { 391 return m.Header 392 } 393 return nil 394} 395 396func (m *OpReadBlockProto) GetOffset() uint64 { 397 if m != nil && m.Offset != nil { 398 return *m.Offset 399 } 400 return 0 401} 402 403func (m *OpReadBlockProto) GetLen() uint64 { 404 if m != nil && m.Len != nil { 405 return *m.Len 406 } 407 return 0 408} 409 410func (m *OpReadBlockProto) GetSendChecksums() bool { 411 if m != nil && m.SendChecksums != nil { 412 return *m.SendChecksums 413 } 414 return Default_OpReadBlockProto_SendChecksums 415} 416 417func (m *OpReadBlockProto) GetCachingStrategy() *CachingStrategyProto { 418 if m != nil { 419 return m.CachingStrategy 420 } 421 return nil 422} 423 424type ChecksumProto struct { 425 Type *ChecksumTypeProto `protobuf:"varint,1,req,name=type,enum=hadoop.hdfs.ChecksumTypeProto" json:"type,omitempty"` 426 BytesPerChecksum *uint32 `protobuf:"varint,2,req,name=bytesPerChecksum" json:"bytesPerChecksum,omitempty"` 427 XXX_unrecognized []byte `json:"-"` 428} 429 430func (m *ChecksumProto) Reset() { *m = ChecksumProto{} } 431func (m *ChecksumProto) String() string { return proto.CompactTextString(m) } 432func (*ChecksumProto) ProtoMessage() {} 433func (*ChecksumProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{6} } 434 435func (m *ChecksumProto) GetType() ChecksumTypeProto { 436 if m != nil && m.Type != nil { 437 return *m.Type 438 } 439 return ChecksumTypeProto_CHECKSUM_NULL 440} 441 442func (m *ChecksumProto) GetBytesPerChecksum() uint32 { 443 if m != nil && m.BytesPerChecksum != nil { 444 return *m.BytesPerChecksum 445 } 446 return 0 447} 448 449type OpWriteBlockProto struct { 450 Header *ClientOperationHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"` 451 Targets []*DatanodeInfoProto `protobuf:"bytes,2,rep,name=targets" json:"targets,omitempty"` 452 Source *DatanodeInfoProto `protobuf:"bytes,3,opt,name=source" json:"source,omitempty"` 453 Stage *OpWriteBlockProto_BlockConstructionStage `protobuf:"varint,4,req,name=stage,enum=hadoop.hdfs.OpWriteBlockProto_BlockConstructionStage" json:"stage,omitempty"` 454 PipelineSize *uint32 `protobuf:"varint,5,req,name=pipelineSize" json:"pipelineSize,omitempty"` 455 MinBytesRcvd *uint64 `protobuf:"varint,6,req,name=minBytesRcvd" json:"minBytesRcvd,omitempty"` 456 MaxBytesRcvd *uint64 `protobuf:"varint,7,req,name=maxBytesRcvd" json:"maxBytesRcvd,omitempty"` 457 LatestGenerationStamp *uint64 `protobuf:"varint,8,req,name=latestGenerationStamp" json:"latestGenerationStamp,omitempty"` 458 // * 459 // The requested checksum mechanism for this block write. 460 RequestedChecksum *ChecksumProto `protobuf:"bytes,9,req,name=requestedChecksum" json:"requestedChecksum,omitempty"` 461 CachingStrategy *CachingStrategyProto `protobuf:"bytes,10,opt,name=cachingStrategy" json:"cachingStrategy,omitempty"` 462 StorageType *StorageTypeProto `protobuf:"varint,11,opt,name=storageType,enum=hadoop.hdfs.StorageTypeProto,def=1" json:"storageType,omitempty"` 463 TargetStorageTypes []StorageTypeProto `protobuf:"varint,12,rep,name=targetStorageTypes,enum=hadoop.hdfs.StorageTypeProto" json:"targetStorageTypes,omitempty"` 464 // * 465 // Hint to the DataNode that the block can be allocated on transient 466 // storage i.e. memory and written to disk lazily. The DataNode is free 467 // to ignore this hint. 468 AllowLazyPersist *bool `protobuf:"varint,13,opt,name=allowLazyPersist,def=0" json:"allowLazyPersist,omitempty"` 469 // whether to pin the block, so Balancer won't move it. 470 Pinning *bool `protobuf:"varint,14,opt,name=pinning,def=0" json:"pinning,omitempty"` 471 TargetPinnings []bool `protobuf:"varint,15,rep,name=targetPinnings" json:"targetPinnings,omitempty"` 472 XXX_unrecognized []byte `json:"-"` 473} 474 475func (m *OpWriteBlockProto) Reset() { *m = OpWriteBlockProto{} } 476func (m *OpWriteBlockProto) String() string { return proto.CompactTextString(m) } 477func (*OpWriteBlockProto) ProtoMessage() {} 478func (*OpWriteBlockProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{7} } 479 480const Default_OpWriteBlockProto_StorageType StorageTypeProto = StorageTypeProto_DISK 481const Default_OpWriteBlockProto_AllowLazyPersist bool = false 482const Default_OpWriteBlockProto_Pinning bool = false 483 484func (m *OpWriteBlockProto) GetHeader() *ClientOperationHeaderProto { 485 if m != nil { 486 return m.Header 487 } 488 return nil 489} 490 491func (m *OpWriteBlockProto) GetTargets() []*DatanodeInfoProto { 492 if m != nil { 493 return m.Targets 494 } 495 return nil 496} 497 498func (m *OpWriteBlockProto) GetSource() *DatanodeInfoProto { 499 if m != nil { 500 return m.Source 501 } 502 return nil 503} 504 505func (m *OpWriteBlockProto) GetStage() OpWriteBlockProto_BlockConstructionStage { 506 if m != nil && m.Stage != nil { 507 return *m.Stage 508 } 509 return OpWriteBlockProto_PIPELINE_SETUP_APPEND 510} 511 512func (m *OpWriteBlockProto) GetPipelineSize() uint32 { 513 if m != nil && m.PipelineSize != nil { 514 return *m.PipelineSize 515 } 516 return 0 517} 518 519func (m *OpWriteBlockProto) GetMinBytesRcvd() uint64 { 520 if m != nil && m.MinBytesRcvd != nil { 521 return *m.MinBytesRcvd 522 } 523 return 0 524} 525 526func (m *OpWriteBlockProto) GetMaxBytesRcvd() uint64 { 527 if m != nil && m.MaxBytesRcvd != nil { 528 return *m.MaxBytesRcvd 529 } 530 return 0 531} 532 533func (m *OpWriteBlockProto) GetLatestGenerationStamp() uint64 { 534 if m != nil && m.LatestGenerationStamp != nil { 535 return *m.LatestGenerationStamp 536 } 537 return 0 538} 539 540func (m *OpWriteBlockProto) GetRequestedChecksum() *ChecksumProto { 541 if m != nil { 542 return m.RequestedChecksum 543 } 544 return nil 545} 546 547func (m *OpWriteBlockProto) GetCachingStrategy() *CachingStrategyProto { 548 if m != nil { 549 return m.CachingStrategy 550 } 551 return nil 552} 553 554func (m *OpWriteBlockProto) GetStorageType() StorageTypeProto { 555 if m != nil && m.StorageType != nil { 556 return *m.StorageType 557 } 558 return Default_OpWriteBlockProto_StorageType 559} 560 561func (m *OpWriteBlockProto) GetTargetStorageTypes() []StorageTypeProto { 562 if m != nil { 563 return m.TargetStorageTypes 564 } 565 return nil 566} 567 568func (m *OpWriteBlockProto) GetAllowLazyPersist() bool { 569 if m != nil && m.AllowLazyPersist != nil { 570 return *m.AllowLazyPersist 571 } 572 return Default_OpWriteBlockProto_AllowLazyPersist 573} 574 575func (m *OpWriteBlockProto) GetPinning() bool { 576 if m != nil && m.Pinning != nil { 577 return *m.Pinning 578 } 579 return Default_OpWriteBlockProto_Pinning 580} 581 582func (m *OpWriteBlockProto) GetTargetPinnings() []bool { 583 if m != nil { 584 return m.TargetPinnings 585 } 586 return nil 587} 588 589type OpTransferBlockProto struct { 590 Header *ClientOperationHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"` 591 Targets []*DatanodeInfoProto `protobuf:"bytes,2,rep,name=targets" json:"targets,omitempty"` 592 TargetStorageTypes []StorageTypeProto `protobuf:"varint,3,rep,name=targetStorageTypes,enum=hadoop.hdfs.StorageTypeProto" json:"targetStorageTypes,omitempty"` 593 XXX_unrecognized []byte `json:"-"` 594} 595 596func (m *OpTransferBlockProto) Reset() { *m = OpTransferBlockProto{} } 597func (m *OpTransferBlockProto) String() string { return proto.CompactTextString(m) } 598func (*OpTransferBlockProto) ProtoMessage() {} 599func (*OpTransferBlockProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{8} } 600 601func (m *OpTransferBlockProto) GetHeader() *ClientOperationHeaderProto { 602 if m != nil { 603 return m.Header 604 } 605 return nil 606} 607 608func (m *OpTransferBlockProto) GetTargets() []*DatanodeInfoProto { 609 if m != nil { 610 return m.Targets 611 } 612 return nil 613} 614 615func (m *OpTransferBlockProto) GetTargetStorageTypes() []StorageTypeProto { 616 if m != nil { 617 return m.TargetStorageTypes 618 } 619 return nil 620} 621 622type OpReplaceBlockProto struct { 623 Header *BaseHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"` 624 DelHint *string `protobuf:"bytes,2,req,name=delHint" json:"delHint,omitempty"` 625 Source *DatanodeInfoProto `protobuf:"bytes,3,req,name=source" json:"source,omitempty"` 626 StorageType *StorageTypeProto `protobuf:"varint,4,opt,name=storageType,enum=hadoop.hdfs.StorageTypeProto,def=1" json:"storageType,omitempty"` 627 XXX_unrecognized []byte `json:"-"` 628} 629 630func (m *OpReplaceBlockProto) Reset() { *m = OpReplaceBlockProto{} } 631func (m *OpReplaceBlockProto) String() string { return proto.CompactTextString(m) } 632func (*OpReplaceBlockProto) ProtoMessage() {} 633func (*OpReplaceBlockProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{9} } 634 635const Default_OpReplaceBlockProto_StorageType StorageTypeProto = StorageTypeProto_DISK 636 637func (m *OpReplaceBlockProto) GetHeader() *BaseHeaderProto { 638 if m != nil { 639 return m.Header 640 } 641 return nil 642} 643 644func (m *OpReplaceBlockProto) GetDelHint() string { 645 if m != nil && m.DelHint != nil { 646 return *m.DelHint 647 } 648 return "" 649} 650 651func (m *OpReplaceBlockProto) GetSource() *DatanodeInfoProto { 652 if m != nil { 653 return m.Source 654 } 655 return nil 656} 657 658func (m *OpReplaceBlockProto) GetStorageType() StorageTypeProto { 659 if m != nil && m.StorageType != nil { 660 return *m.StorageType 661 } 662 return Default_OpReplaceBlockProto_StorageType 663} 664 665type OpCopyBlockProto struct { 666 Header *BaseHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"` 667 XXX_unrecognized []byte `json:"-"` 668} 669 670func (m *OpCopyBlockProto) Reset() { *m = OpCopyBlockProto{} } 671func (m *OpCopyBlockProto) String() string { return proto.CompactTextString(m) } 672func (*OpCopyBlockProto) ProtoMessage() {} 673func (*OpCopyBlockProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{10} } 674 675func (m *OpCopyBlockProto) GetHeader() *BaseHeaderProto { 676 if m != nil { 677 return m.Header 678 } 679 return nil 680} 681 682type OpBlockChecksumProto struct { 683 Header *BaseHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"` 684 XXX_unrecognized []byte `json:"-"` 685} 686 687func (m *OpBlockChecksumProto) Reset() { *m = OpBlockChecksumProto{} } 688func (m *OpBlockChecksumProto) String() string { return proto.CompactTextString(m) } 689func (*OpBlockChecksumProto) ProtoMessage() {} 690func (*OpBlockChecksumProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{11} } 691 692func (m *OpBlockChecksumProto) GetHeader() *BaseHeaderProto { 693 if m != nil { 694 return m.Header 695 } 696 return nil 697} 698 699type OpBlockGroupChecksumProto struct { 700 Header *BaseHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"` 701 Datanodes *DatanodeInfosProto `protobuf:"bytes,2,req,name=datanodes" json:"datanodes,omitempty"` 702 // each internal block has a block token 703 BlockTokens []*hadoop_common.TokenProto `protobuf:"bytes,3,rep,name=blockTokens" json:"blockTokens,omitempty"` 704 EcPolicy *ErasureCodingPolicyProto `protobuf:"bytes,4,req,name=ecPolicy" json:"ecPolicy,omitempty"` 705 XXX_unrecognized []byte `json:"-"` 706} 707 708func (m *OpBlockGroupChecksumProto) Reset() { *m = OpBlockGroupChecksumProto{} } 709func (m *OpBlockGroupChecksumProto) String() string { return proto.CompactTextString(m) } 710func (*OpBlockGroupChecksumProto) ProtoMessage() {} 711func (*OpBlockGroupChecksumProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{12} } 712 713func (m *OpBlockGroupChecksumProto) GetHeader() *BaseHeaderProto { 714 if m != nil { 715 return m.Header 716 } 717 return nil 718} 719 720func (m *OpBlockGroupChecksumProto) GetDatanodes() *DatanodeInfosProto { 721 if m != nil { 722 return m.Datanodes 723 } 724 return nil 725} 726 727func (m *OpBlockGroupChecksumProto) GetBlockTokens() []*hadoop_common.TokenProto { 728 if m != nil { 729 return m.BlockTokens 730 } 731 return nil 732} 733 734func (m *OpBlockGroupChecksumProto) GetEcPolicy() *ErasureCodingPolicyProto { 735 if m != nil { 736 return m.EcPolicy 737 } 738 return nil 739} 740 741// * 742// An ID uniquely identifying a shared memory segment. 743type ShortCircuitShmIdProto struct { 744 Hi *int64 `protobuf:"varint,1,req,name=hi" json:"hi,omitempty"` 745 Lo *int64 `protobuf:"varint,2,req,name=lo" json:"lo,omitempty"` 746 XXX_unrecognized []byte `json:"-"` 747} 748 749func (m *ShortCircuitShmIdProto) Reset() { *m = ShortCircuitShmIdProto{} } 750func (m *ShortCircuitShmIdProto) String() string { return proto.CompactTextString(m) } 751func (*ShortCircuitShmIdProto) ProtoMessage() {} 752func (*ShortCircuitShmIdProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{13} } 753 754func (m *ShortCircuitShmIdProto) GetHi() int64 { 755 if m != nil && m.Hi != nil { 756 return *m.Hi 757 } 758 return 0 759} 760 761func (m *ShortCircuitShmIdProto) GetLo() int64 { 762 if m != nil && m.Lo != nil { 763 return *m.Lo 764 } 765 return 0 766} 767 768// * 769// An ID uniquely identifying a slot within a shared memory segment. 770type ShortCircuitShmSlotProto struct { 771 ShmId *ShortCircuitShmIdProto `protobuf:"bytes,1,req,name=shmId" json:"shmId,omitempty"` 772 SlotIdx *int32 `protobuf:"varint,2,req,name=slotIdx" json:"slotIdx,omitempty"` 773 XXX_unrecognized []byte `json:"-"` 774} 775 776func (m *ShortCircuitShmSlotProto) Reset() { *m = ShortCircuitShmSlotProto{} } 777func (m *ShortCircuitShmSlotProto) String() string { return proto.CompactTextString(m) } 778func (*ShortCircuitShmSlotProto) ProtoMessage() {} 779func (*ShortCircuitShmSlotProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{14} } 780 781func (m *ShortCircuitShmSlotProto) GetShmId() *ShortCircuitShmIdProto { 782 if m != nil { 783 return m.ShmId 784 } 785 return nil 786} 787 788func (m *ShortCircuitShmSlotProto) GetSlotIdx() int32 { 789 if m != nil && m.SlotIdx != nil { 790 return *m.SlotIdx 791 } 792 return 0 793} 794 795type OpRequestShortCircuitAccessProto struct { 796 Header *BaseHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"` 797 // * In order to get short-circuit access to block data, clients must set this 798 // to the highest version of the block data that they can understand. 799 // Currently 1 is the only version, but more versions may exist in the future 800 // if the on-disk format changes. 801 MaxVersion *uint32 `protobuf:"varint,2,req,name=maxVersion" json:"maxVersion,omitempty"` 802 // * 803 // The shared memory slot to use, if we are using one. 804 SlotId *ShortCircuitShmSlotProto `protobuf:"bytes,3,opt,name=slotId" json:"slotId,omitempty"` 805 // * 806 // True if the client supports verifying that the file descriptor has been 807 // sent successfully. 808 SupportsReceiptVerification *bool `protobuf:"varint,4,opt,name=supportsReceiptVerification,def=0" json:"supportsReceiptVerification,omitempty"` 809 XXX_unrecognized []byte `json:"-"` 810} 811 812func (m *OpRequestShortCircuitAccessProto) Reset() { *m = OpRequestShortCircuitAccessProto{} } 813func (m *OpRequestShortCircuitAccessProto) String() string { return proto.CompactTextString(m) } 814func (*OpRequestShortCircuitAccessProto) ProtoMessage() {} 815func (*OpRequestShortCircuitAccessProto) Descriptor() ([]byte, []int) { 816 return fileDescriptor5, []int{15} 817} 818 819const Default_OpRequestShortCircuitAccessProto_SupportsReceiptVerification bool = false 820 821func (m *OpRequestShortCircuitAccessProto) GetHeader() *BaseHeaderProto { 822 if m != nil { 823 return m.Header 824 } 825 return nil 826} 827 828func (m *OpRequestShortCircuitAccessProto) GetMaxVersion() uint32 { 829 if m != nil && m.MaxVersion != nil { 830 return *m.MaxVersion 831 } 832 return 0 833} 834 835func (m *OpRequestShortCircuitAccessProto) GetSlotId() *ShortCircuitShmSlotProto { 836 if m != nil { 837 return m.SlotId 838 } 839 return nil 840} 841 842func (m *OpRequestShortCircuitAccessProto) GetSupportsReceiptVerification() bool { 843 if m != nil && m.SupportsReceiptVerification != nil { 844 return *m.SupportsReceiptVerification 845 } 846 return Default_OpRequestShortCircuitAccessProto_SupportsReceiptVerification 847} 848 849type ReleaseShortCircuitAccessRequestProto struct { 850 SlotId *ShortCircuitShmSlotProto `protobuf:"bytes,1,req,name=slotId" json:"slotId,omitempty"` 851 TraceInfo *DataTransferTraceInfoProto `protobuf:"bytes,2,opt,name=traceInfo" json:"traceInfo,omitempty"` 852 XXX_unrecognized []byte `json:"-"` 853} 854 855func (m *ReleaseShortCircuitAccessRequestProto) Reset() { *m = ReleaseShortCircuitAccessRequestProto{} } 856func (m *ReleaseShortCircuitAccessRequestProto) String() string { return proto.CompactTextString(m) } 857func (*ReleaseShortCircuitAccessRequestProto) ProtoMessage() {} 858func (*ReleaseShortCircuitAccessRequestProto) Descriptor() ([]byte, []int) { 859 return fileDescriptor5, []int{16} 860} 861 862func (m *ReleaseShortCircuitAccessRequestProto) GetSlotId() *ShortCircuitShmSlotProto { 863 if m != nil { 864 return m.SlotId 865 } 866 return nil 867} 868 869func (m *ReleaseShortCircuitAccessRequestProto) GetTraceInfo() *DataTransferTraceInfoProto { 870 if m != nil { 871 return m.TraceInfo 872 } 873 return nil 874} 875 876type ReleaseShortCircuitAccessResponseProto struct { 877 Status *Status `protobuf:"varint,1,req,name=status,enum=hadoop.hdfs.Status" json:"status,omitempty"` 878 Error *string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` 879 XXX_unrecognized []byte `json:"-"` 880} 881 882func (m *ReleaseShortCircuitAccessResponseProto) Reset() { 883 *m = ReleaseShortCircuitAccessResponseProto{} 884} 885func (m *ReleaseShortCircuitAccessResponseProto) String() string { return proto.CompactTextString(m) } 886func (*ReleaseShortCircuitAccessResponseProto) ProtoMessage() {} 887func (*ReleaseShortCircuitAccessResponseProto) Descriptor() ([]byte, []int) { 888 return fileDescriptor5, []int{17} 889} 890 891func (m *ReleaseShortCircuitAccessResponseProto) GetStatus() Status { 892 if m != nil && m.Status != nil { 893 return *m.Status 894 } 895 return Status_SUCCESS 896} 897 898func (m *ReleaseShortCircuitAccessResponseProto) GetError() string { 899 if m != nil && m.Error != nil { 900 return *m.Error 901 } 902 return "" 903} 904 905type ShortCircuitShmRequestProto struct { 906 // The name of the client requesting the shared memory segment. This is 907 // purely for logging / debugging purposes. 908 ClientName *string `protobuf:"bytes,1,req,name=clientName" json:"clientName,omitempty"` 909 TraceInfo *DataTransferTraceInfoProto `protobuf:"bytes,2,opt,name=traceInfo" json:"traceInfo,omitempty"` 910 XXX_unrecognized []byte `json:"-"` 911} 912 913func (m *ShortCircuitShmRequestProto) Reset() { *m = ShortCircuitShmRequestProto{} } 914func (m *ShortCircuitShmRequestProto) String() string { return proto.CompactTextString(m) } 915func (*ShortCircuitShmRequestProto) ProtoMessage() {} 916func (*ShortCircuitShmRequestProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{18} } 917 918func (m *ShortCircuitShmRequestProto) GetClientName() string { 919 if m != nil && m.ClientName != nil { 920 return *m.ClientName 921 } 922 return "" 923} 924 925func (m *ShortCircuitShmRequestProto) GetTraceInfo() *DataTransferTraceInfoProto { 926 if m != nil { 927 return m.TraceInfo 928 } 929 return nil 930} 931 932type ShortCircuitShmResponseProto struct { 933 Status *Status `protobuf:"varint,1,req,name=status,enum=hadoop.hdfs.Status" json:"status,omitempty"` 934 Error *string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` 935 Id *ShortCircuitShmIdProto `protobuf:"bytes,3,opt,name=id" json:"id,omitempty"` 936 XXX_unrecognized []byte `json:"-"` 937} 938 939func (m *ShortCircuitShmResponseProto) Reset() { *m = ShortCircuitShmResponseProto{} } 940func (m *ShortCircuitShmResponseProto) String() string { return proto.CompactTextString(m) } 941func (*ShortCircuitShmResponseProto) ProtoMessage() {} 942func (*ShortCircuitShmResponseProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{19} } 943 944func (m *ShortCircuitShmResponseProto) GetStatus() Status { 945 if m != nil && m.Status != nil { 946 return *m.Status 947 } 948 return Status_SUCCESS 949} 950 951func (m *ShortCircuitShmResponseProto) GetError() string { 952 if m != nil && m.Error != nil { 953 return *m.Error 954 } 955 return "" 956} 957 958func (m *ShortCircuitShmResponseProto) GetId() *ShortCircuitShmIdProto { 959 if m != nil { 960 return m.Id 961 } 962 return nil 963} 964 965type PacketHeaderProto struct { 966 // All fields must be fixed-length! 967 OffsetInBlock *int64 `protobuf:"fixed64,1,req,name=offsetInBlock" json:"offsetInBlock,omitempty"` 968 Seqno *int64 `protobuf:"fixed64,2,req,name=seqno" json:"seqno,omitempty"` 969 LastPacketInBlock *bool `protobuf:"varint,3,req,name=lastPacketInBlock" json:"lastPacketInBlock,omitempty"` 970 DataLen *int32 `protobuf:"fixed32,4,req,name=dataLen" json:"dataLen,omitempty"` 971 SyncBlock *bool `protobuf:"varint,5,opt,name=syncBlock,def=0" json:"syncBlock,omitempty"` 972 XXX_unrecognized []byte `json:"-"` 973} 974 975func (m *PacketHeaderProto) Reset() { *m = PacketHeaderProto{} } 976func (m *PacketHeaderProto) String() string { return proto.CompactTextString(m) } 977func (*PacketHeaderProto) ProtoMessage() {} 978func (*PacketHeaderProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{20} } 979 980const Default_PacketHeaderProto_SyncBlock bool = false 981 982func (m *PacketHeaderProto) GetOffsetInBlock() int64 { 983 if m != nil && m.OffsetInBlock != nil { 984 return *m.OffsetInBlock 985 } 986 return 0 987} 988 989func (m *PacketHeaderProto) GetSeqno() int64 { 990 if m != nil && m.Seqno != nil { 991 return *m.Seqno 992 } 993 return 0 994} 995 996func (m *PacketHeaderProto) GetLastPacketInBlock() bool { 997 if m != nil && m.LastPacketInBlock != nil { 998 return *m.LastPacketInBlock 999 } 1000 return false 1001} 1002 1003func (m *PacketHeaderProto) GetDataLen() int32 { 1004 if m != nil && m.DataLen != nil { 1005 return *m.DataLen 1006 } 1007 return 0 1008} 1009 1010func (m *PacketHeaderProto) GetSyncBlock() bool { 1011 if m != nil && m.SyncBlock != nil { 1012 return *m.SyncBlock 1013 } 1014 return Default_PacketHeaderProto_SyncBlock 1015} 1016 1017type PipelineAckProto struct { 1018 Seqno *int64 `protobuf:"zigzag64,1,req,name=seqno" json:"seqno,omitempty"` 1019 Reply []Status `protobuf:"varint,2,rep,name=reply,enum=hadoop.hdfs.Status" json:"reply,omitempty"` 1020 DownstreamAckTimeNanos *uint64 `protobuf:"varint,3,opt,name=downstreamAckTimeNanos,def=0" json:"downstreamAckTimeNanos,omitempty"` 1021 Flag []uint32 `protobuf:"varint,4,rep,packed,name=flag" json:"flag,omitempty"` 1022 XXX_unrecognized []byte `json:"-"` 1023} 1024 1025func (m *PipelineAckProto) Reset() { *m = PipelineAckProto{} } 1026func (m *PipelineAckProto) String() string { return proto.CompactTextString(m) } 1027func (*PipelineAckProto) ProtoMessage() {} 1028func (*PipelineAckProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{21} } 1029 1030const Default_PipelineAckProto_DownstreamAckTimeNanos uint64 = 0 1031 1032func (m *PipelineAckProto) GetSeqno() int64 { 1033 if m != nil && m.Seqno != nil { 1034 return *m.Seqno 1035 } 1036 return 0 1037} 1038 1039func (m *PipelineAckProto) GetReply() []Status { 1040 if m != nil { 1041 return m.Reply 1042 } 1043 return nil 1044} 1045 1046func (m *PipelineAckProto) GetDownstreamAckTimeNanos() uint64 { 1047 if m != nil && m.DownstreamAckTimeNanos != nil { 1048 return *m.DownstreamAckTimeNanos 1049 } 1050 return Default_PipelineAckProto_DownstreamAckTimeNanos 1051} 1052 1053func (m *PipelineAckProto) GetFlag() []uint32 { 1054 if m != nil { 1055 return m.Flag 1056 } 1057 return nil 1058} 1059 1060// * 1061// Sent as part of the BlockOpResponseProto 1062// for READ_BLOCK and COPY_BLOCK operations. 1063type ReadOpChecksumInfoProto struct { 1064 Checksum *ChecksumProto `protobuf:"bytes,1,req,name=checksum" json:"checksum,omitempty"` 1065 // * 1066 // The offset into the block at which the first packet 1067 // will start. This is necessary since reads will align 1068 // backwards to a checksum chunk boundary. 1069 ChunkOffset *uint64 `protobuf:"varint,2,req,name=chunkOffset" json:"chunkOffset,omitempty"` 1070 XXX_unrecognized []byte `json:"-"` 1071} 1072 1073func (m *ReadOpChecksumInfoProto) Reset() { *m = ReadOpChecksumInfoProto{} } 1074func (m *ReadOpChecksumInfoProto) String() string { return proto.CompactTextString(m) } 1075func (*ReadOpChecksumInfoProto) ProtoMessage() {} 1076func (*ReadOpChecksumInfoProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{22} } 1077 1078func (m *ReadOpChecksumInfoProto) GetChecksum() *ChecksumProto { 1079 if m != nil { 1080 return m.Checksum 1081 } 1082 return nil 1083} 1084 1085func (m *ReadOpChecksumInfoProto) GetChunkOffset() uint64 { 1086 if m != nil && m.ChunkOffset != nil { 1087 return *m.ChunkOffset 1088 } 1089 return 0 1090} 1091 1092type BlockOpResponseProto struct { 1093 Status *Status `protobuf:"varint,1,req,name=status,enum=hadoop.hdfs.Status" json:"status,omitempty"` 1094 FirstBadLink *string `protobuf:"bytes,2,opt,name=firstBadLink" json:"firstBadLink,omitempty"` 1095 ChecksumResponse *OpBlockChecksumResponseProto `protobuf:"bytes,3,opt,name=checksumResponse" json:"checksumResponse,omitempty"` 1096 ReadOpChecksumInfo *ReadOpChecksumInfoProto `protobuf:"bytes,4,opt,name=readOpChecksumInfo" json:"readOpChecksumInfo,omitempty"` 1097 // * explanatory text which may be useful to log on the client side 1098 Message *string `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"` 1099 // * If the server chooses to agree to the request of a client for 1100 // short-circuit access, it will send a response message with the relevant 1101 // file descriptors attached. 1102 // 1103 // In the body of the message, this version number will be set to the 1104 // specific version number of the block data that the client is about to 1105 // read. 1106 ShortCircuitAccessVersion *uint32 `protobuf:"varint,6,opt,name=shortCircuitAccessVersion" json:"shortCircuitAccessVersion,omitempty"` 1107 XXX_unrecognized []byte `json:"-"` 1108} 1109 1110func (m *BlockOpResponseProto) Reset() { *m = BlockOpResponseProto{} } 1111func (m *BlockOpResponseProto) String() string { return proto.CompactTextString(m) } 1112func (*BlockOpResponseProto) ProtoMessage() {} 1113func (*BlockOpResponseProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{23} } 1114 1115func (m *BlockOpResponseProto) GetStatus() Status { 1116 if m != nil && m.Status != nil { 1117 return *m.Status 1118 } 1119 return Status_SUCCESS 1120} 1121 1122func (m *BlockOpResponseProto) GetFirstBadLink() string { 1123 if m != nil && m.FirstBadLink != nil { 1124 return *m.FirstBadLink 1125 } 1126 return "" 1127} 1128 1129func (m *BlockOpResponseProto) GetChecksumResponse() *OpBlockChecksumResponseProto { 1130 if m != nil { 1131 return m.ChecksumResponse 1132 } 1133 return nil 1134} 1135 1136func (m *BlockOpResponseProto) GetReadOpChecksumInfo() *ReadOpChecksumInfoProto { 1137 if m != nil { 1138 return m.ReadOpChecksumInfo 1139 } 1140 return nil 1141} 1142 1143func (m *BlockOpResponseProto) GetMessage() string { 1144 if m != nil && m.Message != nil { 1145 return *m.Message 1146 } 1147 return "" 1148} 1149 1150func (m *BlockOpResponseProto) GetShortCircuitAccessVersion() uint32 { 1151 if m != nil && m.ShortCircuitAccessVersion != nil { 1152 return *m.ShortCircuitAccessVersion 1153 } 1154 return 0 1155} 1156 1157// * 1158// Message sent from the client to the DN after reading the entire 1159// read request. 1160type ClientReadStatusProto struct { 1161 Status *Status `protobuf:"varint,1,req,name=status,enum=hadoop.hdfs.Status" json:"status,omitempty"` 1162 XXX_unrecognized []byte `json:"-"` 1163} 1164 1165func (m *ClientReadStatusProto) Reset() { *m = ClientReadStatusProto{} } 1166func (m *ClientReadStatusProto) String() string { return proto.CompactTextString(m) } 1167func (*ClientReadStatusProto) ProtoMessage() {} 1168func (*ClientReadStatusProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{24} } 1169 1170func (m *ClientReadStatusProto) GetStatus() Status { 1171 if m != nil && m.Status != nil { 1172 return *m.Status 1173 } 1174 return Status_SUCCESS 1175} 1176 1177type DNTransferAckProto struct { 1178 Status *Status `protobuf:"varint,1,req,name=status,enum=hadoop.hdfs.Status" json:"status,omitempty"` 1179 XXX_unrecognized []byte `json:"-"` 1180} 1181 1182func (m *DNTransferAckProto) Reset() { *m = DNTransferAckProto{} } 1183func (m *DNTransferAckProto) String() string { return proto.CompactTextString(m) } 1184func (*DNTransferAckProto) ProtoMessage() {} 1185func (*DNTransferAckProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{25} } 1186 1187func (m *DNTransferAckProto) GetStatus() Status { 1188 if m != nil && m.Status != nil { 1189 return *m.Status 1190 } 1191 return Status_SUCCESS 1192} 1193 1194type OpBlockChecksumResponseProto struct { 1195 BytesPerCrc *uint32 `protobuf:"varint,1,req,name=bytesPerCrc" json:"bytesPerCrc,omitempty"` 1196 CrcPerBlock *uint64 `protobuf:"varint,2,req,name=crcPerBlock" json:"crcPerBlock,omitempty"` 1197 Md5 []byte `protobuf:"bytes,3,req,name=md5" json:"md5,omitempty"` 1198 CrcType *ChecksumTypeProto `protobuf:"varint,4,opt,name=crcType,enum=hadoop.hdfs.ChecksumTypeProto" json:"crcType,omitempty"` 1199 XXX_unrecognized []byte `json:"-"` 1200} 1201 1202func (m *OpBlockChecksumResponseProto) Reset() { *m = OpBlockChecksumResponseProto{} } 1203func (m *OpBlockChecksumResponseProto) String() string { return proto.CompactTextString(m) } 1204func (*OpBlockChecksumResponseProto) ProtoMessage() {} 1205func (*OpBlockChecksumResponseProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{26} } 1206 1207func (m *OpBlockChecksumResponseProto) GetBytesPerCrc() uint32 { 1208 if m != nil && m.BytesPerCrc != nil { 1209 return *m.BytesPerCrc 1210 } 1211 return 0 1212} 1213 1214func (m *OpBlockChecksumResponseProto) GetCrcPerBlock() uint64 { 1215 if m != nil && m.CrcPerBlock != nil { 1216 return *m.CrcPerBlock 1217 } 1218 return 0 1219} 1220 1221func (m *OpBlockChecksumResponseProto) GetMd5() []byte { 1222 if m != nil { 1223 return m.Md5 1224 } 1225 return nil 1226} 1227 1228func (m *OpBlockChecksumResponseProto) GetCrcType() ChecksumTypeProto { 1229 if m != nil && m.CrcType != nil { 1230 return *m.CrcType 1231 } 1232 return ChecksumTypeProto_CHECKSUM_NULL 1233} 1234 1235type OpCustomProto struct { 1236 CustomId *string `protobuf:"bytes,1,req,name=customId" json:"customId,omitempty"` 1237 XXX_unrecognized []byte `json:"-"` 1238} 1239 1240func (m *OpCustomProto) Reset() { *m = OpCustomProto{} } 1241func (m *OpCustomProto) String() string { return proto.CompactTextString(m) } 1242func (*OpCustomProto) ProtoMessage() {} 1243func (*OpCustomProto) Descriptor() ([]byte, []int) { return fileDescriptor5, []int{27} } 1244 1245func (m *OpCustomProto) GetCustomId() string { 1246 if m != nil && m.CustomId != nil { 1247 return *m.CustomId 1248 } 1249 return "" 1250} 1251 1252func init() { 1253 proto.RegisterType((*DataTransferEncryptorMessageProto)(nil), "hadoop.hdfs.DataTransferEncryptorMessageProto") 1254 proto.RegisterType((*BaseHeaderProto)(nil), "hadoop.hdfs.BaseHeaderProto") 1255 proto.RegisterType((*DataTransferTraceInfoProto)(nil), "hadoop.hdfs.DataTransferTraceInfoProto") 1256 proto.RegisterType((*ClientOperationHeaderProto)(nil), "hadoop.hdfs.ClientOperationHeaderProto") 1257 proto.RegisterType((*CachingStrategyProto)(nil), "hadoop.hdfs.CachingStrategyProto") 1258 proto.RegisterType((*OpReadBlockProto)(nil), "hadoop.hdfs.OpReadBlockProto") 1259 proto.RegisterType((*ChecksumProto)(nil), "hadoop.hdfs.ChecksumProto") 1260 proto.RegisterType((*OpWriteBlockProto)(nil), "hadoop.hdfs.OpWriteBlockProto") 1261 proto.RegisterType((*OpTransferBlockProto)(nil), "hadoop.hdfs.OpTransferBlockProto") 1262 proto.RegisterType((*OpReplaceBlockProto)(nil), "hadoop.hdfs.OpReplaceBlockProto") 1263 proto.RegisterType((*OpCopyBlockProto)(nil), "hadoop.hdfs.OpCopyBlockProto") 1264 proto.RegisterType((*OpBlockChecksumProto)(nil), "hadoop.hdfs.OpBlockChecksumProto") 1265 proto.RegisterType((*OpBlockGroupChecksumProto)(nil), "hadoop.hdfs.OpBlockGroupChecksumProto") 1266 proto.RegisterType((*ShortCircuitShmIdProto)(nil), "hadoop.hdfs.ShortCircuitShmIdProto") 1267 proto.RegisterType((*ShortCircuitShmSlotProto)(nil), "hadoop.hdfs.ShortCircuitShmSlotProto") 1268 proto.RegisterType((*OpRequestShortCircuitAccessProto)(nil), "hadoop.hdfs.OpRequestShortCircuitAccessProto") 1269 proto.RegisterType((*ReleaseShortCircuitAccessRequestProto)(nil), "hadoop.hdfs.ReleaseShortCircuitAccessRequestProto") 1270 proto.RegisterType((*ReleaseShortCircuitAccessResponseProto)(nil), "hadoop.hdfs.ReleaseShortCircuitAccessResponseProto") 1271 proto.RegisterType((*ShortCircuitShmRequestProto)(nil), "hadoop.hdfs.ShortCircuitShmRequestProto") 1272 proto.RegisterType((*ShortCircuitShmResponseProto)(nil), "hadoop.hdfs.ShortCircuitShmResponseProto") 1273 proto.RegisterType((*PacketHeaderProto)(nil), "hadoop.hdfs.PacketHeaderProto") 1274 proto.RegisterType((*PipelineAckProto)(nil), "hadoop.hdfs.PipelineAckProto") 1275 proto.RegisterType((*ReadOpChecksumInfoProto)(nil), "hadoop.hdfs.ReadOpChecksumInfoProto") 1276 proto.RegisterType((*BlockOpResponseProto)(nil), "hadoop.hdfs.BlockOpResponseProto") 1277 proto.RegisterType((*ClientReadStatusProto)(nil), "hadoop.hdfs.ClientReadStatusProto") 1278 proto.RegisterType((*DNTransferAckProto)(nil), "hadoop.hdfs.DNTransferAckProto") 1279 proto.RegisterType((*OpBlockChecksumResponseProto)(nil), "hadoop.hdfs.OpBlockChecksumResponseProto") 1280 proto.RegisterType((*OpCustomProto)(nil), "hadoop.hdfs.OpCustomProto") 1281 proto.RegisterEnum("hadoop.hdfs.Status", Status_name, Status_value) 1282 proto.RegisterEnum("hadoop.hdfs.ShortCircuitFdResponse", ShortCircuitFdResponse_name, ShortCircuitFdResponse_value) 1283 proto.RegisterEnum("hadoop.hdfs.DataTransferEncryptorMessageProto_DataTransferEncryptorStatus", DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_name, DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_value) 1284 proto.RegisterEnum("hadoop.hdfs.OpWriteBlockProto_BlockConstructionStage", OpWriteBlockProto_BlockConstructionStage_name, OpWriteBlockProto_BlockConstructionStage_value) 1285} 1286 1287func init() { proto.RegisterFile("datatransfer.proto", fileDescriptor5) } 1288 1289var fileDescriptor5 = []byte{ 1290 // 2039 bytes of a gzipped FileDescriptorProto 1291 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xcc, 0x58, 0x4b, 0x73, 0xdc, 0xc6, 1292 0xf1, 0x17, 0xf6, 0x41, 0xee, 0xf6, 0x92, 0x14, 0x38, 0x96, 0x68, 0x88, 0xd2, 0x5f, 0xa2, 0x20, 1293 0xcb, 0x7f, 0x5a, 0x4e, 0x31, 0x31, 0x6d, 0xb9, 0x6c, 0xc5, 0x4e, 0x6a, 0x1f, 0x90, 0xb4, 0x21, 1294 0xb5, 0xd8, 0x1a, 0x2c, 0xa9, 0x3c, 0x0e, 0x5b, 0x23, 0x60, 0xc8, 0x45, 0x11, 0x0b, 0xc0, 0x98, 1295 0xd9, 0x58, 0xab, 0x53, 0x0e, 0x39, 0xe4, 0x98, 0x53, 0xce, 0x39, 0xe5, 0x96, 0x7c, 0x82, 0x1c, 1296 0xf2, 0x05, 0xf2, 0x1d, 0x72, 0xc8, 0x25, 0x55, 0x39, 0xa6, 0x72, 0x4e, 0xcd, 0x0c, 0xb0, 0x04, 1297 0x96, 0x4b, 0x32, 0xa2, 0x75, 0xc8, 0x0d, 0xd3, 0xd3, 0xdd, 0xe8, 0xfe, 0x4d, 0x4f, 0x3f, 0x06, 1298 0x90, 0x47, 0x38, 0xe1, 0x09, 0x09, 0xd9, 0x11, 0x4d, 0x76, 0xe2, 0x24, 0xe2, 0x11, 0x6a, 0x8c, 1299 0x88, 0x17, 0x45, 0xf1, 0xce, 0xc8, 0x3b, 0x62, 0x9b, 0x6b, 0x0e, 0x75, 0x27, 0x89, 0xcf, 0xa7, 1300 0x6a, 0x73, 0x13, 0x04, 0x55, 0x7d, 0x9b, 0x7f, 0x2d, 0xc1, 0xfd, 0x0e, 0xe1, 0x64, 0x90, 0xca, 1301 0x5b, 0xa1, 0x9b, 0x4c, 0x63, 0x1e, 0x25, 0x2f, 0x28, 0x63, 0xe4, 0x98, 0xf6, 0xa5, 0xba, 0x57, 1302 0xb0, 0xc4, 0x38, 0xe1, 0x13, 0x66, 0x68, 0x5b, 0xa5, 0xed, 0xb5, 0xdd, 0x9f, 0xec, 0xe4, 0xf4, 1303 0xef, 0x5c, 0x2a, 0xbf, 0x98, 0xc3, 0x91, 0x1a, 0x71, 0xaa, 0x19, 0x19, 0xb0, 0x1c, 0x93, 0x69, 1304 0x10, 0x11, 0xcf, 0x28, 0x6d, 0x69, 0xdb, 0x2b, 0x38, 0x5b, 0x8a, 0x9d, 0xb1, 0xd2, 0x66, 0x94, 1305 0xb7, 0xb4, 0xed, 0x3a, 0xce, 0x96, 0xa8, 0x05, 0x2b, 0xae, 0x1f, 0x8f, 0x68, 0x62, 0xc7, 0xdc, 1306 0x8f, 0x42, 0xa3, 0xb2, 0x55, 0xde, 0x6e, 0xec, 0xde, 0x2d, 0x58, 0xd7, 0xce, 0x31, 0x48, 0x6b, 1307 0x70, 0x41, 0xc6, 0xdc, 0x87, 0xdb, 0x17, 0x98, 0x87, 0x1a, 0xb0, 0xec, 0x1c, 0xb4, 0xdb, 0x96, 1308 0xe3, 0xe8, 0xd7, 0xd0, 0x4d, 0x58, 0xb7, 0x30, 0xb6, 0xf1, 0xf0, 0xa0, 0xb7, 0xd7, 0xb3, 0x5f, 1309 0xf6, 0x86, 0x7b, 0xd6, 0xcf, 0x74, 0x0d, 0xd5, 0xa1, 0x2a, 0xc9, 0x7a, 0xc9, 0xfc, 0x8b, 0x06, 1310 0xd7, 0x5b, 0x84, 0xd1, 0xe7, 0x94, 0x78, 0x34, 0x51, 0xe8, 0x3d, 0x86, 0xea, 0xab, 0x20, 0x72, 1311 0x4f, 0x24, 0x78, 0x8d, 0xdd, 0x7b, 0x05, 0xf3, 0xac, 0xd7, 0x9c, 0x86, 0x1e, 0xf5, 0x5a, 0x82, 1312 0x43, 0xd9, 0xa7, 0xb8, 0xd1, 0xf7, 0xa1, 0xca, 0xa3, 0x13, 0x1a, 0x4a, 0x38, 0x1a, 0xbb, 0xb7, 1313 0x32, 0x31, 0x37, 0x1a, 0x8f, 0xa3, 0x70, 0x67, 0x20, 0xf6, 0x52, 0x01, 0xc9, 0x87, 0x2c, 0xa8, 1314 0xf3, 0x84, 0xb8, 0xb4, 0x1b, 0x1e, 0x45, 0x12, 0xa9, 0xc6, 0xee, 0xff, 0x9f, 0x7b, 0x50, 0x83, 1315 0x8c, 0x53, 0xa9, 0x38, 0x95, 0x34, 0x31, 0x6c, 0x9e, 0xcf, 0x28, 0x0e, 0x43, 0xb1, 0x7a, 0xd2, 1316 0x9d, 0x0a, 0xce, 0x96, 0x68, 0x13, 0x6a, 0x31, 0x49, 0x68, 0xc8, 0xbb, 0xe2, 0x04, 0xc5, 0xd6, 1317 0x6c, 0x6d, 0xbe, 0x81, 0xcd, 0x76, 0xe0, 0xd3, 0x90, 0xdb, 0x31, 0x4d, 0x88, 0xc0, 0x3d, 0x0f, 1318 0xd0, 0x57, 0x00, 0xaf, 0x66, 0x98, 0xa5, 0x28, 0xdd, 0x29, 0x58, 0x3e, 0x07, 0x29, 0xce, 0xf1, 1319 0xa3, 0xbb, 0x00, 0xae, 0xd4, 0xdd, 0x23, 0x63, 0x2a, 0xff, 0x5c, 0xc7, 0x39, 0x8a, 0x39, 0x80, 1320 0x1b, 0x6d, 0xe2, 0x8e, 0xfc, 0xf0, 0xd8, 0xe1, 0x09, 0xe1, 0xf4, 0x78, 0xaa, 0xfe, 0x7a, 0x17, 1321 0xc0, 0x4b, 0xa2, 0xb8, 0x45, 0x47, 0x7e, 0x28, 0x9c, 0xd1, 0xb6, 0x6b, 0x38, 0x47, 0x41, 0x77, 1322 0xa0, 0x9e, 0x50, 0xe2, 0x91, 0x11, 0x4d, 0x43, 0xb2, 0x8c, 0x4f, 0x09, 0xe6, 0xbf, 0x35, 0xd0, 1323 0xed, 0x18, 0x53, 0x92, 0x3b, 0x39, 0xf4, 0x63, 0x58, 0x1a, 0xe5, 0x9d, 0x28, 0xc2, 0x7f, 0x3e, 1324 0x02, 0x38, 0x15, 0x43, 0x1b, 0xb0, 0x14, 0x1d, 0x1d, 0x31, 0xca, 0x53, 0x04, 0xd3, 0x15, 0xd2, 1325 0xa1, 0x1c, 0xd0, 0xd0, 0x28, 0x4b, 0xa2, 0xf8, 0x44, 0x8f, 0x60, 0x95, 0xd1, 0xd0, 0x6b, 0x8f, 1326 0xa8, 0x7b, 0xc2, 0x26, 0x63, 0x66, 0x54, 0x84, 0x03, 0x4f, 0x2a, 0x3c, 0x99, 0x50, 0x5c, 0xdc, 1327 0x42, 0x7b, 0x70, 0xdd, 0x2d, 0x22, 0x60, 0x54, 0x65, 0x78, 0xdc, 0x2f, 0xda, 0xb7, 0x00, 0x25, 1328 0x3c, 0x2f, 0x69, 0x46, 0xb0, 0x9a, 0x69, 0x56, 0x4e, 0xef, 0x42, 0x85, 0x4f, 0x63, 0x9a, 0xa6, 1329 0x86, 0xb9, 0xcb, 0x97, 0x72, 0x0e, 0xa6, 0xb1, 0x4a, 0x05, 0x58, 0xf2, 0xa2, 0x47, 0xa0, 0xbf, 1330 0x9a, 0x72, 0xca, 0xfa, 0x34, 0xc9, 0x58, 0xa4, 0xc7, 0xab, 0xf8, 0x0c, 0xdd, 0xfc, 0x47, 0x0d, 1331 0xd6, 0xed, 0xf8, 0x65, 0xe2, 0x73, 0xfa, 0x2e, 0xa1, 0xfe, 0x02, 0x96, 0x39, 0x49, 0x8e, 0x29, 1332 0x67, 0x46, 0x69, 0x41, 0xda, 0x10, 0x57, 0x20, 0x8c, 0xbc, 0xdc, 0x15, 0xc9, 0xd8, 0xd1, 0xe7, 1333 0xb0, 0xc4, 0xa2, 0x49, 0xe2, 0xd2, 0xf4, 0x92, 0x5d, 0x26, 0x98, 0x72, 0xa3, 0x3d, 0xa8, 0x32, 1334 0x2e, 0xb2, 0x58, 0x45, 0x22, 0xf5, 0xb8, 0x20, 0x76, 0xc6, 0xc3, 0x1d, 0xf9, 0xd9, 0x8e, 0x42, 1335 0xc6, 0x93, 0x89, 0x2b, 0xbc, 0x70, 0x84, 0x30, 0x56, 0x3a, 0x90, 0x09, 0x2b, 0xb1, 0x1f, 0xd3, 1336 0xc0, 0x0f, 0xa9, 0xe3, 0xbf, 0xa1, 0x46, 0x55, 0xa2, 0x57, 0xa0, 0x09, 0x9e, 0xb1, 0x1f, 0xb6, 1337 0x04, 0xa0, 0xd8, 0xfd, 0xa5, 0x67, 0x2c, 0xc9, 0xf0, 0x29, 0xd0, 0x24, 0x0f, 0x79, 0x7d, 0xca, 1338 0xb3, 0x9c, 0xf2, 0xe4, 0x68, 0xe8, 0x33, 0xb8, 0x19, 0x10, 0x4e, 0x19, 0x7f, 0x46, 0xc3, 0x14, 1339 0x51, 0x87, 0x93, 0x71, 0x6c, 0xd4, 0x24, 0xf3, 0xe2, 0x4d, 0xf4, 0x1c, 0xd6, 0x13, 0xfa, 0xcd, 1340 0x84, 0x32, 0x4e, 0x67, 0xb1, 0x68, 0xd4, 0xe5, 0x61, 0x6d, 0x2e, 0x0c, 0x12, 0x85, 0xd6, 0x59, 1341 0xa1, 0x45, 0xf1, 0x0b, 0x57, 0x8d, 0x5f, 0x64, 0x41, 0x83, 0xf1, 0x28, 0x21, 0xc7, 0x54, 0x04, 1342 0xa5, 0xd1, 0xd8, 0xd2, 0xb6, 0xd7, 0x76, 0xff, 0xaf, 0xa0, 0xc8, 0x39, 0xdd, 0x97, 0x4a, 0x9e, 1343 0x54, 0x3a, 0x5d, 0x67, 0x0f, 0xe7, 0xe5, 0xd0, 0x0b, 0x40, 0x2a, 0x1e, 0x72, 0xcc, 0xcc, 0x58, 1344 0xd9, 0x2a, 0x5f, 0xaa, 0x0d, 0x2f, 0x10, 0x44, 0x9f, 0x80, 0x4e, 0x82, 0x20, 0xfa, 0x76, 0x9f, 1345 0xbc, 0x99, 0xf6, 0x69, 0xc2, 0x7c, 0xc6, 0x8d, 0x55, 0x79, 0xa3, 0xab, 0x47, 0x24, 0x60, 0x14, 1346 0x9f, 0xd9, 0x46, 0xf7, 0x60, 0x39, 0xf6, 0xc3, 0xd0, 0x0f, 0x8f, 0x8d, 0xb5, 0x3c, 0x67, 0x46, 1347 0x45, 0x1f, 0xc2, 0x9a, 0xfa, 0x53, 0x5f, 0x11, 0x98, 0x71, 0x7d, 0xab, 0xbc, 0x5d, 0xc3, 0x73, 1348 0x54, 0xf3, 0x37, 0x25, 0xd8, 0x58, 0x1c, 0x6c, 0xe8, 0x16, 0xdc, 0xec, 0x77, 0xfb, 0xd6, 0x7e, 1349 0xb7, 0x67, 0x0d, 0x1d, 0x6b, 0x70, 0xd0, 0x1f, 0x36, 0xfb, 0x7d, 0xab, 0xd7, 0xd1, 0xaf, 0x21, 1350 0x13, 0xee, 0x2e, 0xdc, 0x1a, 0x62, 0xab, 0x6d, 0x1f, 0x5a, 0x58, 0x14, 0x46, 0x04, 0x6b, 0x9d, 1351 0xe6, 0xa0, 0x39, 0x74, 0x06, 0xd8, 0x6a, 0xbe, 0xe8, 0xf6, 0x9e, 0xe9, 0x25, 0xf4, 0x10, 0xee, 1352 0xcf, 0xc9, 0xcd, 0x76, 0x4f, 0x45, 0xcb, 0x42, 0x74, 0xc6, 0xd6, 0xde, 0xb7, 0x1d, 0x4b, 0xaf, 1353 0xa0, 0xdb, 0xf0, 0x7e, 0x91, 0x76, 0x2a, 0x50, 0x5d, 0x60, 0x6a, 0x1b, 0x5b, 0xcd, 0x81, 0xa5, 1354 0x2f, 0x21, 0x1d, 0x56, 0x06, 0xb8, 0xd9, 0x73, 0x9e, 0x5a, 0x78, 0x88, 0x5b, 0x2f, 0xf5, 0x65, 1355 0xb4, 0x01, 0x68, 0x46, 0x79, 0xda, 0xed, 0x35, 0xf7, 0xbb, 0x3f, 0xb7, 0x3a, 0x7a, 0xcd, 0xfc, 1356 0x9b, 0x06, 0x37, 0xec, 0x38, 0x2b, 0x7d, 0xff, 0x1b, 0xe9, 0x66, 0x71, 0xa4, 0x95, 0xaf, 0x18, 1357 0x69, 0xe6, 0xdf, 0x35, 0x78, 0x4f, 0x14, 0xae, 0x38, 0x20, 0x6e, 0x3e, 0xa1, 0x7e, 0x36, 0xe7, 1358 0xe1, 0xc5, 0x05, 0x38, 0x73, 0xcb, 0x80, 0x65, 0x8f, 0x06, 0xcf, 0xfd, 0x90, 0xa7, 0x95, 0x37, 1359 0x5b, 0x16, 0xb2, 0x64, 0xe9, 0x2d, 0xb2, 0xe4, 0xdc, 0xfd, 0xac, 0x5c, 0xed, 0x7e, 0x9a, 0xcf, 1360 0x45, 0x79, 0x6e, 0x47, 0xf1, 0xf4, 0xbb, 0xba, 0x68, 0xee, 0x8b, 0x90, 0x50, 0xf7, 0xa3, 0x50, 1361 0xf7, 0xae, 0xa6, 0xed, 0xb7, 0x25, 0xb8, 0x95, 0xaa, 0x7b, 0x96, 0x44, 0x93, 0xf8, 0x1d, 0xe8, 1362 0x44, 0x5f, 0x43, 0xdd, 0x4b, 0xf1, 0x64, 0xf2, 0x18, 0xe6, 0x9b, 0xcc, 0x3c, 0xda, 0x2c, 0x6d, 1363 0xf8, 0x66, 0x12, 0xe8, 0x87, 0xd0, 0x90, 0x1d, 0xa7, 0xec, 0x28, 0x55, 0x64, 0x5d, 0xd8, 0x6e, 1364 0xe6, 0xb9, 0x51, 0x13, 0x6a, 0xd4, 0xed, 0x47, 0x81, 0xef, 0x4e, 0x65, 0x5d, 0x6b, 0xec, 0x3e, 1365 0x2c, 0xf6, 0xb7, 0x09, 0x61, 0x93, 0x84, 0xb6, 0x23, 0xcf, 0x0f, 0x8f, 0x15, 0x9f, 0xd2, 0x32, 1366 0x13, 0x33, 0xbf, 0x80, 0x0d, 0x67, 0x14, 0x25, 0xbc, 0xed, 0x27, 0xee, 0xc4, 0xe7, 0xce, 0x68, 1367 0xdc, 0xf5, 0x14, 0x1c, 0x6b, 0x50, 0x1a, 0xf9, 0x12, 0x8a, 0x32, 0x2e, 0x8d, 0x7c, 0xb1, 0x0e, 1368 0x22, 0xe9, 0x61, 0x19, 0x97, 0x82, 0xc8, 0x8c, 0xc0, 0x98, 0x93, 0x74, 0x82, 0x88, 0x2b, 0xd9, 1369 0x2f, 0xa1, 0xca, 0x84, 0xa6, 0x14, 0xc9, 0x07, 0xc5, 0x08, 0x5a, 0xf8, 0x3f, 0xac, 0x24, 0x44, 1370 0x50, 0xb3, 0x20, 0xe2, 0x5d, 0xef, 0xb5, 0xfc, 0x57, 0x15, 0x67, 0x4b, 0xf3, 0x57, 0x25, 0xd8, 1371 0x12, 0x97, 0x47, 0x56, 0xa8, 0xbc, 0x92, 0xa6, 0xeb, 0x52, 0xc6, 0xbe, 0xcb, 0x21, 0xde, 0x05, 1372 0x18, 0x93, 0xd7, 0x87, 0x22, 0xb9, 0x47, 0x61, 0xda, 0x0c, 0xe5, 0x28, 0xe8, 0x6b, 0x58, 0x52, 1373 0x56, 0xa4, 0x5d, 0xc7, 0xc3, 0x8b, 0x1c, 0x9a, 0xc1, 0x80, 0x53, 0x21, 0xf4, 0x0c, 0x6e, 0xb3, 1374 0x49, 0x1c, 0x47, 0x09, 0x67, 0x98, 0xba, 0xd4, 0x8f, 0xf9, 0x21, 0x4d, 0xfc, 0x23, 0xdf, 0x25, 1375 0xe9, 0xe4, 0x94, 0xab, 0x20, 0x17, 0x71, 0x9a, 0x7f, 0xd4, 0xe0, 0x21, 0xa6, 0x01, 0x25, 0x8c, 1376 0x9e, 0x05, 0x20, 0x45, 0x46, 0xe1, 0x70, 0x6a, 0xb1, 0xb6, 0x20, 0x30, 0x2e, 0xb5, 0xb8, 0x30, 1377 0xce, 0x94, 0xae, 0x3c, 0xce, 0x9c, 0xc0, 0x87, 0x17, 0x98, 0xcb, 0xe2, 0x28, 0x64, 0xe9, 0x94, 1378 0xfb, 0xf1, 0xdc, 0x94, 0xfb, 0xde, 0x5c, 0xd2, 0x29, 0x8c, 0xab, 0x37, 0xa0, 0x4a, 0x93, 0x24, 1379 0x4a, 0xa4, 0x65, 0x75, 0xac, 0x16, 0xe6, 0xaf, 0x35, 0xb8, 0x3d, 0xe7, 0x58, 0x01, 0x92, 0xe2, 1380 0xac, 0xa2, 0xcd, 0xcf, 0x2a, 0xef, 0xca, 0xe7, 0xdf, 0x69, 0x70, 0xe7, 0x8c, 0x19, 0xef, 0xd6, 1381 0x55, 0xf4, 0x29, 0x94, 0xfc, 0x2c, 0x16, 0xff, 0xab, 0xcb, 0x55, 0xf2, 0x3d, 0xf3, 0xcf, 0x1a, 1382 0xac, 0xf7, 0x89, 0x7b, 0x42, 0x79, 0x7e, 0xfe, 0xfb, 0x00, 0x56, 0xd5, 0x9c, 0xd3, 0x0d, 0x5b, 1383 0xb3, 0x41, 0x59, 0xc7, 0x45, 0xa2, 0x30, 0x83, 0xd1, 0x6f, 0x42, 0x75, 0xff, 0x75, 0xac, 0x16, 1384 0xe8, 0x7b, 0xb0, 0x1e, 0x10, 0xc6, 0x95, 0xd2, 0x4c, 0x5e, 0x54, 0x9c, 0x1a, 0x3e, 0xbb, 0x21, 1385 0xcb, 0x15, 0xe1, 0x64, 0x9f, 0x86, 0x32, 0x59, 0x5d, 0xc7, 0xd9, 0x12, 0x3d, 0x80, 0x3a, 0x9b, 1386 0x86, 0xae, 0x92, 0xaf, 0xe6, 0x6f, 0xc3, 0x29, 0xdd, 0xfc, 0x83, 0x06, 0x7a, 0x3f, 0xed, 0xb0, 1387 0x9b, 0x59, 0x55, 0x99, 0xd9, 0x25, 0xac, 0x46, 0x99, 0x5d, 0x1f, 0x41, 0x35, 0xa1, 0x71, 0x30, 1388 0x95, 0xd5, 0xfe, 0x1c, 0x80, 0x15, 0x07, 0xfa, 0x12, 0x36, 0xbc, 0xe8, 0x5b, 0xd1, 0x7a, 0x51, 1389 0x32, 0x6e, 0xba, 0x27, 0x03, 0x7f, 0x4c, 0x7b, 0x24, 0x8c, 0x98, 0x44, 0xb7, 0xf2, 0x44, 0xfb, 1390 0x01, 0x3e, 0x87, 0x01, 0x6d, 0x40, 0xe5, 0x28, 0x20, 0xc7, 0xf2, 0xe1, 0x63, 0xb5, 0x55, 0xd2, 1391 0x35, 0x2c, 0xd7, 0x26, 0x83, 0xf7, 0xc5, 0x68, 0x6a, 0xcf, 0xca, 0xcb, 0xe9, 0x00, 0xff, 0x39, 1392 0xd4, 0xdc, 0xac, 0x1b, 0xd7, 0x2e, 0xed, 0xc6, 0x67, 0xbc, 0x68, 0x0b, 0x1a, 0xee, 0x68, 0x12, 1393 0x9e, 0xd8, 0xf9, 0xf9, 0x34, 0x4f, 0x32, 0xff, 0x59, 0x82, 0x1b, 0x12, 0x27, 0x91, 0x21, 0xaf, 1394 0x1c, 0x6d, 0x26, 0xac, 0x1c, 0xf9, 0x09, 0xe3, 0x2d, 0xe2, 0xed, 0xfb, 0xe1, 0x49, 0x1a, 0x74, 1395 0x05, 0x1a, 0x3a, 0x00, 0x3d, 0xb3, 0x2b, 0xfb, 0x53, 0x1a, 0x89, 0x1f, 0xcd, 0x0d, 0x55, 0x85, 1396 0xba, 0x5d, 0xb0, 0x0a, 0x9f, 0x51, 0x81, 0x06, 0x80, 0x92, 0x33, 0xa8, 0xc9, 0xd4, 0xd8, 0xd8, 1397 0xfd, 0xa0, 0xa0, 0xf8, 0x1c, 0x70, 0xf1, 0x02, 0xf9, 0xfc, 0xf3, 0x55, 0xb5, 0xf8, 0x7c, 0xf5, 1398 0x15, 0xdc, 0x62, 0x67, 0x72, 0x52, 0x56, 0x01, 0x96, 0xb6, 0xb4, 0xed, 0x55, 0x7c, 0x3e, 0x83, 1399 0xd9, 0x81, 0x9b, 0xaa, 0xef, 0x14, 0xc6, 0x28, 0x10, 0xdf, 0x1e, 0x6e, 0xb3, 0x09, 0xa8, 0xd3, 1400 0xcb, 0x32, 0xca, 0x2c, 0xa6, 0xdf, 0x4a, 0xc5, 0x9f, 0x34, 0xb8, 0x73, 0x11, 0xd2, 0x22, 0x74, 1401 0x66, 0x53, 0x7d, 0xe2, 0x4a, 0x95, 0xab, 0x38, 0x4f, 0x92, 0xc1, 0x95, 0xb8, 0xfd, 0xb4, 0xe5, 1402 0x9e, 0x05, 0xd7, 0x29, 0x09, 0xe9, 0x50, 0x1e, 0x7b, 0x8f, 0xe5, 0xcd, 0x5e, 0xc1, 0xe2, 0x53, 1403 0x74, 0xd4, 0x6e, 0xe2, 0xe6, 0x9a, 0xc4, 0xcb, 0x9e, 0x1e, 0x32, 0x76, 0xf3, 0x63, 0x58, 0xb5, 1404 0xe3, 0xf6, 0x84, 0xf1, 0x28, 0x6d, 0xbb, 0x36, 0xa1, 0xe6, 0xca, 0x65, 0x5a, 0xab, 0xea, 0x78, 1405 0xb6, 0x7e, 0xf4, 0x2f, 0x0d, 0x96, 0x16, 0xbd, 0x05, 0xce, 0x1e, 0xfd, 0xe4, 0x98, 0xa3, 0x9e, 1406 0x05, 0xdb, 0xcf, 0xad, 0xf6, 0x9e, 0x73, 0xf0, 0x42, 0x2f, 0xa1, 0x75, 0x58, 0x55, 0xb4, 0x6e, 1407 0xef, 0xb0, 0xb9, 0xdf, 0xed, 0xe8, 0x65, 0x31, 0x86, 0x28, 0x92, 0xf5, 0xd3, 0xae, 0x33, 0x70, 1408 0xf4, 0x8a, 0x18, 0x43, 0x14, 0xa5, 0x29, 0xb5, 0x0e, 0x07, 0xf6, 0x9e, 0xd5, 0xd3, 0xab, 0xe8, 1409 0x3a, 0x34, 0x32, 0x55, 0x43, 0x7b, 0x4f, 0x5f, 0xca, 0x3f, 0x3c, 0x3a, 0x07, 0xfd, 0xbe, 0x8d, 1410 0x07, 0x56, 0x47, 0x5f, 0x16, 0x7c, 0xb6, 0xdd, 0x1a, 0x62, 0xcb, 0x19, 0x34, 0xf1, 0x40, 0xaf, 1411 0x89, 0xbf, 0xa6, 0x04, 0x0b, 0x1f, 0x5a, 0x9d, 0x4f, 0xf4, 0xfa, 0x3c, 0x69, 0x57, 0x87, 0x79, 1412 0xd2, 0xa7, 0x7a, 0x43, 0x68, 0xea, 0xf6, 0x86, 0x7d, 0x6c, 0x3f, 0xc3, 0xc2, 0xbd, 0x95, 0x47, 1413 0xbf, 0x28, 0x36, 0x65, 0x4f, 0xbd, 0xd9, 0x2d, 0x79, 0x00, 0xf7, 0x3a, 0xf6, 0xb0, 0x67, 0x0f, 1414 0x86, 0x07, 0x6a, 0x02, 0xb3, 0xba, 0xfd, 0xc1, 0xf0, 0xd0, 0xc2, 0xdd, 0xa7, 0xdd, 0x76, 0x73, 1415 0xd0, 0xb5, 0x7b, 0xfa, 0x35, 0x74, 0x07, 0x8c, 0x73, 0x77, 0xb5, 0xd6, 0x8f, 0xe0, 0x61, 0x94, 1416 0x1c, 0xef, 0x90, 0x98, 0xb8, 0x23, 0x5a, 0x38, 0x35, 0xf9, 0x2a, 0xed, 0x46, 0x81, 0xfa, 0x68, 1417 0xa1, 0x7c, 0xbd, 0x93, 0x67, 0xc5, 0x7e, 0xaf, 0x69, 0xff, 0x09, 0x00, 0x00, 0xff, 0xff, 0xfa, 1418 0x1e, 0x11, 0x57, 0xf3, 0x16, 0x00, 0x00, 1419} 1420