001// Generated by the protocol buffer compiler. DO NOT EDIT! 002// source: ns_protocol.proto 003 004package org.apache.reef.io.network.proto; 005 006public final class ReefNetworkServiceProtos { 007 private ReefNetworkServiceProtos() {} 008 public static void registerAllExtensions( 009 com.google.protobuf.ExtensionRegistry registry) { 010 } 011 public interface NSMessagePBufOrBuilder 012 extends com.google.protobuf.MessageOrBuilder { 013 014 // required string srcid = 2; 015 /** 016 * <code>required string srcid = 2;</code> 017 */ 018 boolean hasSrcid(); 019 /** 020 * <code>required string srcid = 2;</code> 021 */ 022 java.lang.String getSrcid(); 023 /** 024 * <code>required string srcid = 2;</code> 025 */ 026 com.google.protobuf.ByteString 027 getSrcidBytes(); 028 029 // required string destid = 3; 030 /** 031 * <code>required string destid = 3;</code> 032 */ 033 boolean hasDestid(); 034 /** 035 * <code>required string destid = 3;</code> 036 */ 037 java.lang.String getDestid(); 038 /** 039 * <code>required string destid = 3;</code> 040 */ 041 com.google.protobuf.ByteString 042 getDestidBytes(); 043 044 // repeated .NSRecordPBuf msgs = 4; 045 /** 046 * <code>repeated .NSRecordPBuf msgs = 4;</code> 047 */ 048 java.util.List<org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf> 049 getMsgsList(); 050 /** 051 * <code>repeated .NSRecordPBuf msgs = 4;</code> 052 */ 053 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf getMsgs(int index); 054 /** 055 * <code>repeated .NSRecordPBuf msgs = 4;</code> 056 */ 057 int getMsgsCount(); 058 /** 059 * <code>repeated .NSRecordPBuf msgs = 4;</code> 060 */ 061 java.util.List<? extends org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder> 062 getMsgsOrBuilderList(); 063 /** 064 * <code>repeated .NSRecordPBuf msgs = 4;</code> 065 */ 066 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder getMsgsOrBuilder( 067 int index); 068 } 069 /** 070 * Protobuf type {@code NSMessagePBuf} 071 */ 072 public static final class NSMessagePBuf extends 073 com.google.protobuf.GeneratedMessage 074 implements NSMessagePBufOrBuilder { 075 // Use NSMessagePBuf.newBuilder() to construct. 076 private NSMessagePBuf(com.google.protobuf.GeneratedMessage.Builder<?> builder) { 077 super(builder); 078 this.unknownFields = builder.getUnknownFields(); 079 } 080 private NSMessagePBuf(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } 081 082 private static final NSMessagePBuf defaultInstance; 083 public static NSMessagePBuf getDefaultInstance() { 084 return defaultInstance; 085 } 086 087 public NSMessagePBuf getDefaultInstanceForType() { 088 return defaultInstance; 089 } 090 091 private final com.google.protobuf.UnknownFieldSet unknownFields; 092 @java.lang.Override 093 public final com.google.protobuf.UnknownFieldSet 094 getUnknownFields() { 095 return this.unknownFields; 096 } 097 private NSMessagePBuf( 098 com.google.protobuf.CodedInputStream input, 099 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 100 throws com.google.protobuf.InvalidProtocolBufferException { 101 initFields(); 102 int mutable_bitField0_ = 0; 103 com.google.protobuf.UnknownFieldSet.Builder unknownFields = 104 com.google.protobuf.UnknownFieldSet.newBuilder(); 105 try { 106 boolean done = false; 107 while (!done) { 108 int tag = input.readTag(); 109 switch (tag) { 110 case 0: 111 done = true; 112 break; 113 default: { 114 if (!parseUnknownField(input, unknownFields, 115 extensionRegistry, tag)) { 116 done = true; 117 } 118 break; 119 } 120 case 18: { 121 bitField0_ |= 0x00000001; 122 srcid_ = input.readBytes(); 123 break; 124 } 125 case 26: { 126 bitField0_ |= 0x00000002; 127 destid_ = input.readBytes(); 128 break; 129 } 130 case 34: { 131 if (!((mutable_bitField0_ & 0x00000004) == 0x00000004)) { 132 msgs_ = new java.util.ArrayList<org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf>(); 133 mutable_bitField0_ |= 0x00000004; 134 } 135 msgs_.add(input.readMessage(org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.PARSER, extensionRegistry)); 136 break; 137 } 138 } 139 } 140 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 141 throw e.setUnfinishedMessage(this); 142 } catch (java.io.IOException e) { 143 throw new com.google.protobuf.InvalidProtocolBufferException( 144 e.getMessage()).setUnfinishedMessage(this); 145 } finally { 146 if (((mutable_bitField0_ & 0x00000004) == 0x00000004)) { 147 msgs_ = java.util.Collections.unmodifiableList(msgs_); 148 } 149 this.unknownFields = unknownFields.build(); 150 makeExtensionsImmutable(); 151 } 152 } 153 public static final com.google.protobuf.Descriptors.Descriptor 154 getDescriptor() { 155 return org.apache.reef.io.network.proto.ReefNetworkServiceProtos.internal_static_NSMessagePBuf_descriptor; 156 } 157 158 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 159 internalGetFieldAccessorTable() { 160 return org.apache.reef.io.network.proto.ReefNetworkServiceProtos.internal_static_NSMessagePBuf_fieldAccessorTable 161 .ensureFieldAccessorsInitialized( 162 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.class, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder.class); 163 } 164 165 public static com.google.protobuf.Parser<NSMessagePBuf> PARSER = 166 new com.google.protobuf.AbstractParser<NSMessagePBuf>() { 167 public NSMessagePBuf parsePartialFrom( 168 com.google.protobuf.CodedInputStream input, 169 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 170 throws com.google.protobuf.InvalidProtocolBufferException { 171 return new NSMessagePBuf(input, extensionRegistry); 172 } 173 }; 174 175 @java.lang.Override 176 public com.google.protobuf.Parser<NSMessagePBuf> getParserForType() { 177 return PARSER; 178 } 179 180 private int bitField0_; 181 // required string srcid = 2; 182 public static final int SRCID_FIELD_NUMBER = 2; 183 private java.lang.Object srcid_; 184 /** 185 * <code>required string srcid = 2;</code> 186 */ 187 public boolean hasSrcid() { 188 return ((bitField0_ & 0x00000001) == 0x00000001); 189 } 190 /** 191 * <code>required string srcid = 2;</code> 192 */ 193 public java.lang.String getSrcid() { 194 java.lang.Object ref = srcid_; 195 if (ref instanceof java.lang.String) { 196 return (java.lang.String) ref; 197 } else { 198 com.google.protobuf.ByteString bs = 199 (com.google.protobuf.ByteString) ref; 200 java.lang.String s = bs.toStringUtf8(); 201 if (bs.isValidUtf8()) { 202 srcid_ = s; 203 } 204 return s; 205 } 206 } 207 /** 208 * <code>required string srcid = 2;</code> 209 */ 210 public com.google.protobuf.ByteString 211 getSrcidBytes() { 212 java.lang.Object ref = srcid_; 213 if (ref instanceof java.lang.String) { 214 com.google.protobuf.ByteString b = 215 com.google.protobuf.ByteString.copyFromUtf8( 216 (java.lang.String) ref); 217 srcid_ = b; 218 return b; 219 } else { 220 return (com.google.protobuf.ByteString) ref; 221 } 222 } 223 224 // required string destid = 3; 225 public static final int DESTID_FIELD_NUMBER = 3; 226 private java.lang.Object destid_; 227 /** 228 * <code>required string destid = 3;</code> 229 */ 230 public boolean hasDestid() { 231 return ((bitField0_ & 0x00000002) == 0x00000002); 232 } 233 /** 234 * <code>required string destid = 3;</code> 235 */ 236 public java.lang.String getDestid() { 237 java.lang.Object ref = destid_; 238 if (ref instanceof java.lang.String) { 239 return (java.lang.String) ref; 240 } else { 241 com.google.protobuf.ByteString bs = 242 (com.google.protobuf.ByteString) ref; 243 java.lang.String s = bs.toStringUtf8(); 244 if (bs.isValidUtf8()) { 245 destid_ = s; 246 } 247 return s; 248 } 249 } 250 /** 251 * <code>required string destid = 3;</code> 252 */ 253 public com.google.protobuf.ByteString 254 getDestidBytes() { 255 java.lang.Object ref = destid_; 256 if (ref instanceof java.lang.String) { 257 com.google.protobuf.ByteString b = 258 com.google.protobuf.ByteString.copyFromUtf8( 259 (java.lang.String) ref); 260 destid_ = b; 261 return b; 262 } else { 263 return (com.google.protobuf.ByteString) ref; 264 } 265 } 266 267 // repeated .NSRecordPBuf msgs = 4; 268 public static final int MSGS_FIELD_NUMBER = 4; 269 private java.util.List<org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf> msgs_; 270 /** 271 * <code>repeated .NSRecordPBuf msgs = 4;</code> 272 */ 273 public java.util.List<org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf> getMsgsList() { 274 return msgs_; 275 } 276 /** 277 * <code>repeated .NSRecordPBuf msgs = 4;</code> 278 */ 279 public java.util.List<? extends org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder> 280 getMsgsOrBuilderList() { 281 return msgs_; 282 } 283 /** 284 * <code>repeated .NSRecordPBuf msgs = 4;</code> 285 */ 286 public int getMsgsCount() { 287 return msgs_.size(); 288 } 289 /** 290 * <code>repeated .NSRecordPBuf msgs = 4;</code> 291 */ 292 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf getMsgs(int index) { 293 return msgs_.get(index); 294 } 295 /** 296 * <code>repeated .NSRecordPBuf msgs = 4;</code> 297 */ 298 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder getMsgsOrBuilder( 299 int index) { 300 return msgs_.get(index); 301 } 302 303 private void initFields() { 304 srcid_ = ""; 305 destid_ = ""; 306 msgs_ = java.util.Collections.emptyList(); 307 } 308 private byte memoizedIsInitialized = -1; 309 public final boolean isInitialized() { 310 byte isInitialized = memoizedIsInitialized; 311 if (isInitialized != -1) return isInitialized == 1; 312 313 if (!hasSrcid()) { 314 memoizedIsInitialized = 0; 315 return false; 316 } 317 if (!hasDestid()) { 318 memoizedIsInitialized = 0; 319 return false; 320 } 321 for (int i = 0; i < getMsgsCount(); i++) { 322 if (!getMsgs(i).isInitialized()) { 323 memoizedIsInitialized = 0; 324 return false; 325 } 326 } 327 memoizedIsInitialized = 1; 328 return true; 329 } 330 331 public void writeTo(com.google.protobuf.CodedOutputStream output) 332 throws java.io.IOException { 333 getSerializedSize(); 334 if (((bitField0_ & 0x00000001) == 0x00000001)) { 335 output.writeBytes(2, getSrcidBytes()); 336 } 337 if (((bitField0_ & 0x00000002) == 0x00000002)) { 338 output.writeBytes(3, getDestidBytes()); 339 } 340 for (int i = 0; i < msgs_.size(); i++) { 341 output.writeMessage(4, msgs_.get(i)); 342 } 343 getUnknownFields().writeTo(output); 344 } 345 346 private int memoizedSerializedSize = -1; 347 public int getSerializedSize() { 348 int size = memoizedSerializedSize; 349 if (size != -1) return size; 350 351 size = 0; 352 if (((bitField0_ & 0x00000001) == 0x00000001)) { 353 size += com.google.protobuf.CodedOutputStream 354 .computeBytesSize(2, getSrcidBytes()); 355 } 356 if (((bitField0_ & 0x00000002) == 0x00000002)) { 357 size += com.google.protobuf.CodedOutputStream 358 .computeBytesSize(3, getDestidBytes()); 359 } 360 for (int i = 0; i < msgs_.size(); i++) { 361 size += com.google.protobuf.CodedOutputStream 362 .computeMessageSize(4, msgs_.get(i)); 363 } 364 size += getUnknownFields().getSerializedSize(); 365 memoizedSerializedSize = size; 366 return size; 367 } 368 369 private static final long serialVersionUID = 0L; 370 @java.lang.Override 371 protected java.lang.Object writeReplace() 372 throws java.io.ObjectStreamException { 373 return super.writeReplace(); 374 } 375 376 @java.lang.Override 377 public boolean equals(final java.lang.Object obj) { 378 if (obj == this) { 379 return true; 380 } 381 if (!(obj instanceof org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf)) { 382 return super.equals(obj); 383 } 384 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf other = (org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf) obj; 385 386 boolean result = true; 387 result = result && (hasSrcid() == other.hasSrcid()); 388 if (hasSrcid()) { 389 result = result && getSrcid() 390 .equals(other.getSrcid()); 391 } 392 result = result && (hasDestid() == other.hasDestid()); 393 if (hasDestid()) { 394 result = result && getDestid() 395 .equals(other.getDestid()); 396 } 397 result = result && getMsgsList() 398 .equals(other.getMsgsList()); 399 result = result && 400 getUnknownFields().equals(other.getUnknownFields()); 401 return result; 402 } 403 404 private int memoizedHashCode = 0; 405 @java.lang.Override 406 public int hashCode() { 407 if (memoizedHashCode != 0) { 408 return memoizedHashCode; 409 } 410 int hash = 41; 411 hash = (19 * hash) + getDescriptorForType().hashCode(); 412 if (hasSrcid()) { 413 hash = (37 * hash) + SRCID_FIELD_NUMBER; 414 hash = (53 * hash) + getSrcid().hashCode(); 415 } 416 if (hasDestid()) { 417 hash = (37 * hash) + DESTID_FIELD_NUMBER; 418 hash = (53 * hash) + getDestid().hashCode(); 419 } 420 if (getMsgsCount() > 0) { 421 hash = (37 * hash) + MSGS_FIELD_NUMBER; 422 hash = (53 * hash) + getMsgsList().hashCode(); 423 } 424 hash = (29 * hash) + getUnknownFields().hashCode(); 425 memoizedHashCode = hash; 426 return hash; 427 } 428 429 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf parseFrom( 430 com.google.protobuf.ByteString data) 431 throws com.google.protobuf.InvalidProtocolBufferException { 432 return PARSER.parseFrom(data); 433 } 434 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf parseFrom( 435 com.google.protobuf.ByteString data, 436 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 437 throws com.google.protobuf.InvalidProtocolBufferException { 438 return PARSER.parseFrom(data, extensionRegistry); 439 } 440 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf parseFrom(byte[] data) 441 throws com.google.protobuf.InvalidProtocolBufferException { 442 return PARSER.parseFrom(data); 443 } 444 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf parseFrom( 445 byte[] data, 446 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 447 throws com.google.protobuf.InvalidProtocolBufferException { 448 return PARSER.parseFrom(data, extensionRegistry); 449 } 450 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf parseFrom(java.io.InputStream input) 451 throws java.io.IOException { 452 return PARSER.parseFrom(input); 453 } 454 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf parseFrom( 455 java.io.InputStream input, 456 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 457 throws java.io.IOException { 458 return PARSER.parseFrom(input, extensionRegistry); 459 } 460 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf parseDelimitedFrom(java.io.InputStream input) 461 throws java.io.IOException { 462 return PARSER.parseDelimitedFrom(input); 463 } 464 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf parseDelimitedFrom( 465 java.io.InputStream input, 466 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 467 throws java.io.IOException { 468 return PARSER.parseDelimitedFrom(input, extensionRegistry); 469 } 470 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf parseFrom( 471 com.google.protobuf.CodedInputStream input) 472 throws java.io.IOException { 473 return PARSER.parseFrom(input); 474 } 475 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf parseFrom( 476 com.google.protobuf.CodedInputStream input, 477 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 478 throws java.io.IOException { 479 return PARSER.parseFrom(input, extensionRegistry); 480 } 481 482 public static Builder newBuilder() { return Builder.create(); } 483 public Builder newBuilderForType() { return newBuilder(); } 484 public static Builder newBuilder(org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf prototype) { 485 return newBuilder().mergeFrom(prototype); 486 } 487 public Builder toBuilder() { return newBuilder(this); } 488 489 @java.lang.Override 490 protected Builder newBuilderForType( 491 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 492 Builder builder = new Builder(parent); 493 return builder; 494 } 495 /** 496 * Protobuf type {@code NSMessagePBuf} 497 */ 498 public static final class Builder extends 499 com.google.protobuf.GeneratedMessage.Builder<Builder> 500 implements org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBufOrBuilder { 501 public static final com.google.protobuf.Descriptors.Descriptor 502 getDescriptor() { 503 return org.apache.reef.io.network.proto.ReefNetworkServiceProtos.internal_static_NSMessagePBuf_descriptor; 504 } 505 506 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 507 internalGetFieldAccessorTable() { 508 return org.apache.reef.io.network.proto.ReefNetworkServiceProtos.internal_static_NSMessagePBuf_fieldAccessorTable 509 .ensureFieldAccessorsInitialized( 510 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.class, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder.class); 511 } 512 513 // Construct using org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.newBuilder() 514 private Builder() { 515 maybeForceBuilderInitialization(); 516 } 517 518 private Builder( 519 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 520 super(parent); 521 maybeForceBuilderInitialization(); 522 } 523 private void maybeForceBuilderInitialization() { 524 if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { 525 getMsgsFieldBuilder(); 526 } 527 } 528 private static Builder create() { 529 return new Builder(); 530 } 531 532 public Builder clear() { 533 super.clear(); 534 srcid_ = ""; 535 bitField0_ = (bitField0_ & ~0x00000001); 536 destid_ = ""; 537 bitField0_ = (bitField0_ & ~0x00000002); 538 if (msgsBuilder_ == null) { 539 msgs_ = java.util.Collections.emptyList(); 540 bitField0_ = (bitField0_ & ~0x00000004); 541 } else { 542 msgsBuilder_.clear(); 543 } 544 return this; 545 } 546 547 public Builder clone() { 548 return create().mergeFrom(buildPartial()); 549 } 550 551 public com.google.protobuf.Descriptors.Descriptor 552 getDescriptorForType() { 553 return org.apache.reef.io.network.proto.ReefNetworkServiceProtos.internal_static_NSMessagePBuf_descriptor; 554 } 555 556 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf getDefaultInstanceForType() { 557 return org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.getDefaultInstance(); 558 } 559 560 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf build() { 561 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf result = buildPartial(); 562 if (!result.isInitialized()) { 563 throw newUninitializedMessageException(result); 564 } 565 return result; 566 } 567 568 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf buildPartial() { 569 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf result = new org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf(this); 570 int from_bitField0_ = bitField0_; 571 int to_bitField0_ = 0; 572 if (((from_bitField0_ & 0x00000001) == 0x00000001)) { 573 to_bitField0_ |= 0x00000001; 574 } 575 result.srcid_ = srcid_; 576 if (((from_bitField0_ & 0x00000002) == 0x00000002)) { 577 to_bitField0_ |= 0x00000002; 578 } 579 result.destid_ = destid_; 580 if (msgsBuilder_ == null) { 581 if (((bitField0_ & 0x00000004) == 0x00000004)) { 582 msgs_ = java.util.Collections.unmodifiableList(msgs_); 583 bitField0_ = (bitField0_ & ~0x00000004); 584 } 585 result.msgs_ = msgs_; 586 } else { 587 result.msgs_ = msgsBuilder_.build(); 588 } 589 result.bitField0_ = to_bitField0_; 590 onBuilt(); 591 return result; 592 } 593 594 public Builder mergeFrom(com.google.protobuf.Message other) { 595 if (other instanceof org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf) { 596 return mergeFrom((org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf)other); 597 } else { 598 super.mergeFrom(other); 599 return this; 600 } 601 } 602 603 public Builder mergeFrom(org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf other) { 604 if (other == org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.getDefaultInstance()) return this; 605 if (other.hasSrcid()) { 606 bitField0_ |= 0x00000001; 607 srcid_ = other.srcid_; 608 onChanged(); 609 } 610 if (other.hasDestid()) { 611 bitField0_ |= 0x00000002; 612 destid_ = other.destid_; 613 onChanged(); 614 } 615 if (msgsBuilder_ == null) { 616 if (!other.msgs_.isEmpty()) { 617 if (msgs_.isEmpty()) { 618 msgs_ = other.msgs_; 619 bitField0_ = (bitField0_ & ~0x00000004); 620 } else { 621 ensureMsgsIsMutable(); 622 msgs_.addAll(other.msgs_); 623 } 624 onChanged(); 625 } 626 } else { 627 if (!other.msgs_.isEmpty()) { 628 if (msgsBuilder_.isEmpty()) { 629 msgsBuilder_.dispose(); 630 msgsBuilder_ = null; 631 msgs_ = other.msgs_; 632 bitField0_ = (bitField0_ & ~0x00000004); 633 msgsBuilder_ = 634 com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ? 635 getMsgsFieldBuilder() : null; 636 } else { 637 msgsBuilder_.addAllMessages(other.msgs_); 638 } 639 } 640 } 641 this.mergeUnknownFields(other.getUnknownFields()); 642 return this; 643 } 644 645 public final boolean isInitialized() { 646 if (!hasSrcid()) { 647 648 return false; 649 } 650 if (!hasDestid()) { 651 652 return false; 653 } 654 for (int i = 0; i < getMsgsCount(); i++) { 655 if (!getMsgs(i).isInitialized()) { 656 657 return false; 658 } 659 } 660 return true; 661 } 662 663 public Builder mergeFrom( 664 com.google.protobuf.CodedInputStream input, 665 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 666 throws java.io.IOException { 667 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf parsedMessage = null; 668 try { 669 parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); 670 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 671 parsedMessage = (org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf) e.getUnfinishedMessage(); 672 throw e; 673 } finally { 674 if (parsedMessage != null) { 675 mergeFrom(parsedMessage); 676 } 677 } 678 return this; 679 } 680 private int bitField0_; 681 682 // required string srcid = 2; 683 private java.lang.Object srcid_ = ""; 684 /** 685 * <code>required string srcid = 2;</code> 686 */ 687 public boolean hasSrcid() { 688 return ((bitField0_ & 0x00000001) == 0x00000001); 689 } 690 /** 691 * <code>required string srcid = 2;</code> 692 */ 693 public java.lang.String getSrcid() { 694 java.lang.Object ref = srcid_; 695 if (!(ref instanceof java.lang.String)) { 696 java.lang.String s = ((com.google.protobuf.ByteString) ref) 697 .toStringUtf8(); 698 srcid_ = s; 699 return s; 700 } else { 701 return (java.lang.String) ref; 702 } 703 } 704 /** 705 * <code>required string srcid = 2;</code> 706 */ 707 public com.google.protobuf.ByteString 708 getSrcidBytes() { 709 java.lang.Object ref = srcid_; 710 if (ref instanceof String) { 711 com.google.protobuf.ByteString b = 712 com.google.protobuf.ByteString.copyFromUtf8( 713 (java.lang.String) ref); 714 srcid_ = b; 715 return b; 716 } else { 717 return (com.google.protobuf.ByteString) ref; 718 } 719 } 720 /** 721 * <code>required string srcid = 2;</code> 722 */ 723 public Builder setSrcid( 724 java.lang.String value) { 725 if (value == null) { 726 throw new NullPointerException(); 727 } 728 bitField0_ |= 0x00000001; 729 srcid_ = value; 730 onChanged(); 731 return this; 732 } 733 /** 734 * <code>required string srcid = 2;</code> 735 */ 736 public Builder clearSrcid() { 737 bitField0_ = (bitField0_ & ~0x00000001); 738 srcid_ = getDefaultInstance().getSrcid(); 739 onChanged(); 740 return this; 741 } 742 /** 743 * <code>required string srcid = 2;</code> 744 */ 745 public Builder setSrcidBytes( 746 com.google.protobuf.ByteString value) { 747 if (value == null) { 748 throw new NullPointerException(); 749 } 750 bitField0_ |= 0x00000001; 751 srcid_ = value; 752 onChanged(); 753 return this; 754 } 755 756 // required string destid = 3; 757 private java.lang.Object destid_ = ""; 758 /** 759 * <code>required string destid = 3;</code> 760 */ 761 public boolean hasDestid() { 762 return ((bitField0_ & 0x00000002) == 0x00000002); 763 } 764 /** 765 * <code>required string destid = 3;</code> 766 */ 767 public java.lang.String getDestid() { 768 java.lang.Object ref = destid_; 769 if (!(ref instanceof java.lang.String)) { 770 java.lang.String s = ((com.google.protobuf.ByteString) ref) 771 .toStringUtf8(); 772 destid_ = s; 773 return s; 774 } else { 775 return (java.lang.String) ref; 776 } 777 } 778 /** 779 * <code>required string destid = 3;</code> 780 */ 781 public com.google.protobuf.ByteString 782 getDestidBytes() { 783 java.lang.Object ref = destid_; 784 if (ref instanceof String) { 785 com.google.protobuf.ByteString b = 786 com.google.protobuf.ByteString.copyFromUtf8( 787 (java.lang.String) ref); 788 destid_ = b; 789 return b; 790 } else { 791 return (com.google.protobuf.ByteString) ref; 792 } 793 } 794 /** 795 * <code>required string destid = 3;</code> 796 */ 797 public Builder setDestid( 798 java.lang.String value) { 799 if (value == null) { 800 throw new NullPointerException(); 801 } 802 bitField0_ |= 0x00000002; 803 destid_ = value; 804 onChanged(); 805 return this; 806 } 807 /** 808 * <code>required string destid = 3;</code> 809 */ 810 public Builder clearDestid() { 811 bitField0_ = (bitField0_ & ~0x00000002); 812 destid_ = getDefaultInstance().getDestid(); 813 onChanged(); 814 return this; 815 } 816 /** 817 * <code>required string destid = 3;</code> 818 */ 819 public Builder setDestidBytes( 820 com.google.protobuf.ByteString value) { 821 if (value == null) { 822 throw new NullPointerException(); 823 } 824 bitField0_ |= 0x00000002; 825 destid_ = value; 826 onChanged(); 827 return this; 828 } 829 830 // repeated .NSRecordPBuf msgs = 4; 831 private java.util.List<org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf> msgs_ = 832 java.util.Collections.emptyList(); 833 private void ensureMsgsIsMutable() { 834 if (!((bitField0_ & 0x00000004) == 0x00000004)) { 835 msgs_ = new java.util.ArrayList<org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf>(msgs_); 836 bitField0_ |= 0x00000004; 837 } 838 } 839 840 private com.google.protobuf.RepeatedFieldBuilder< 841 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder> msgsBuilder_; 842 843 /** 844 * <code>repeated .NSRecordPBuf msgs = 4;</code> 845 */ 846 public java.util.List<org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf> getMsgsList() { 847 if (msgsBuilder_ == null) { 848 return java.util.Collections.unmodifiableList(msgs_); 849 } else { 850 return msgsBuilder_.getMessageList(); 851 } 852 } 853 /** 854 * <code>repeated .NSRecordPBuf msgs = 4;</code> 855 */ 856 public int getMsgsCount() { 857 if (msgsBuilder_ == null) { 858 return msgs_.size(); 859 } else { 860 return msgsBuilder_.getCount(); 861 } 862 } 863 /** 864 * <code>repeated .NSRecordPBuf msgs = 4;</code> 865 */ 866 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf getMsgs(int index) { 867 if (msgsBuilder_ == null) { 868 return msgs_.get(index); 869 } else { 870 return msgsBuilder_.getMessage(index); 871 } 872 } 873 /** 874 * <code>repeated .NSRecordPBuf msgs = 4;</code> 875 */ 876 public Builder setMsgs( 877 int index, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf value) { 878 if (msgsBuilder_ == null) { 879 if (value == null) { 880 throw new NullPointerException(); 881 } 882 ensureMsgsIsMutable(); 883 msgs_.set(index, value); 884 onChanged(); 885 } else { 886 msgsBuilder_.setMessage(index, value); 887 } 888 return this; 889 } 890 /** 891 * <code>repeated .NSRecordPBuf msgs = 4;</code> 892 */ 893 public Builder setMsgs( 894 int index, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder builderForValue) { 895 if (msgsBuilder_ == null) { 896 ensureMsgsIsMutable(); 897 msgs_.set(index, builderForValue.build()); 898 onChanged(); 899 } else { 900 msgsBuilder_.setMessage(index, builderForValue.build()); 901 } 902 return this; 903 } 904 /** 905 * <code>repeated .NSRecordPBuf msgs = 4;</code> 906 */ 907 public Builder addMsgs(org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf value) { 908 if (msgsBuilder_ == null) { 909 if (value == null) { 910 throw new NullPointerException(); 911 } 912 ensureMsgsIsMutable(); 913 msgs_.add(value); 914 onChanged(); 915 } else { 916 msgsBuilder_.addMessage(value); 917 } 918 return this; 919 } 920 /** 921 * <code>repeated .NSRecordPBuf msgs = 4;</code> 922 */ 923 public Builder addMsgs( 924 int index, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf value) { 925 if (msgsBuilder_ == null) { 926 if (value == null) { 927 throw new NullPointerException(); 928 } 929 ensureMsgsIsMutable(); 930 msgs_.add(index, value); 931 onChanged(); 932 } else { 933 msgsBuilder_.addMessage(index, value); 934 } 935 return this; 936 } 937 /** 938 * <code>repeated .NSRecordPBuf msgs = 4;</code> 939 */ 940 public Builder addMsgs( 941 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder builderForValue) { 942 if (msgsBuilder_ == null) { 943 ensureMsgsIsMutable(); 944 msgs_.add(builderForValue.build()); 945 onChanged(); 946 } else { 947 msgsBuilder_.addMessage(builderForValue.build()); 948 } 949 return this; 950 } 951 /** 952 * <code>repeated .NSRecordPBuf msgs = 4;</code> 953 */ 954 public Builder addMsgs( 955 int index, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder builderForValue) { 956 if (msgsBuilder_ == null) { 957 ensureMsgsIsMutable(); 958 msgs_.add(index, builderForValue.build()); 959 onChanged(); 960 } else { 961 msgsBuilder_.addMessage(index, builderForValue.build()); 962 } 963 return this; 964 } 965 /** 966 * <code>repeated .NSRecordPBuf msgs = 4;</code> 967 */ 968 public Builder addAllMsgs( 969 java.lang.Iterable<? extends org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf> values) { 970 if (msgsBuilder_ == null) { 971 ensureMsgsIsMutable(); 972 super.addAll(values, msgs_); 973 onChanged(); 974 } else { 975 msgsBuilder_.addAllMessages(values); 976 } 977 return this; 978 } 979 /** 980 * <code>repeated .NSRecordPBuf msgs = 4;</code> 981 */ 982 public Builder clearMsgs() { 983 if (msgsBuilder_ == null) { 984 msgs_ = java.util.Collections.emptyList(); 985 bitField0_ = (bitField0_ & ~0x00000004); 986 onChanged(); 987 } else { 988 msgsBuilder_.clear(); 989 } 990 return this; 991 } 992 /** 993 * <code>repeated .NSRecordPBuf msgs = 4;</code> 994 */ 995 public Builder removeMsgs(int index) { 996 if (msgsBuilder_ == null) { 997 ensureMsgsIsMutable(); 998 msgs_.remove(index); 999 onChanged(); 1000 } else { 1001 msgsBuilder_.remove(index); 1002 } 1003 return this; 1004 } 1005 /** 1006 * <code>repeated .NSRecordPBuf msgs = 4;</code> 1007 */ 1008 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder getMsgsBuilder( 1009 int index) { 1010 return getMsgsFieldBuilder().getBuilder(index); 1011 } 1012 /** 1013 * <code>repeated .NSRecordPBuf msgs = 4;</code> 1014 */ 1015 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder getMsgsOrBuilder( 1016 int index) { 1017 if (msgsBuilder_ == null) { 1018 return msgs_.get(index); } else { 1019 return msgsBuilder_.getMessageOrBuilder(index); 1020 } 1021 } 1022 /** 1023 * <code>repeated .NSRecordPBuf msgs = 4;</code> 1024 */ 1025 public java.util.List<? extends org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder> 1026 getMsgsOrBuilderList() { 1027 if (msgsBuilder_ != null) { 1028 return msgsBuilder_.getMessageOrBuilderList(); 1029 } else { 1030 return java.util.Collections.unmodifiableList(msgs_); 1031 } 1032 } 1033 /** 1034 * <code>repeated .NSRecordPBuf msgs = 4;</code> 1035 */ 1036 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder addMsgsBuilder() { 1037 return getMsgsFieldBuilder().addBuilder( 1038 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.getDefaultInstance()); 1039 } 1040 /** 1041 * <code>repeated .NSRecordPBuf msgs = 4;</code> 1042 */ 1043 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder addMsgsBuilder( 1044 int index) { 1045 return getMsgsFieldBuilder().addBuilder( 1046 index, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.getDefaultInstance()); 1047 } 1048 /** 1049 * <code>repeated .NSRecordPBuf msgs = 4;</code> 1050 */ 1051 public java.util.List<org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder> 1052 getMsgsBuilderList() { 1053 return getMsgsFieldBuilder().getBuilderList(); 1054 } 1055 private com.google.protobuf.RepeatedFieldBuilder< 1056 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder> 1057 getMsgsFieldBuilder() { 1058 if (msgsBuilder_ == null) { 1059 msgsBuilder_ = new com.google.protobuf.RepeatedFieldBuilder< 1060 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder>( 1061 msgs_, 1062 ((bitField0_ & 0x00000004) == 0x00000004), 1063 getParentForChildren(), 1064 isClean()); 1065 msgs_ = null; 1066 } 1067 return msgsBuilder_; 1068 } 1069 1070 // @@protoc_insertion_point(builder_scope:NSMessagePBuf) 1071 } 1072 1073 static { 1074 defaultInstance = new NSMessagePBuf(true); 1075 defaultInstance.initFields(); 1076 } 1077 1078 // @@protoc_insertion_point(class_scope:NSMessagePBuf) 1079 } 1080 1081 public interface NSRecordPBufOrBuilder 1082 extends com.google.protobuf.MessageOrBuilder { 1083 1084 // required bytes data = 1; 1085 /** 1086 * <code>required bytes data = 1;</code> 1087 */ 1088 boolean hasData(); 1089 /** 1090 * <code>required bytes data = 1;</code> 1091 */ 1092 com.google.protobuf.ByteString getData(); 1093 } 1094 /** 1095 * Protobuf type {@code NSRecordPBuf} 1096 */ 1097 public static final class NSRecordPBuf extends 1098 com.google.protobuf.GeneratedMessage 1099 implements NSRecordPBufOrBuilder { 1100 // Use NSRecordPBuf.newBuilder() to construct. 1101 private NSRecordPBuf(com.google.protobuf.GeneratedMessage.Builder<?> builder) { 1102 super(builder); 1103 this.unknownFields = builder.getUnknownFields(); 1104 } 1105 private NSRecordPBuf(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } 1106 1107 private static final NSRecordPBuf defaultInstance; 1108 public static NSRecordPBuf getDefaultInstance() { 1109 return defaultInstance; 1110 } 1111 1112 public NSRecordPBuf getDefaultInstanceForType() { 1113 return defaultInstance; 1114 } 1115 1116 private final com.google.protobuf.UnknownFieldSet unknownFields; 1117 @java.lang.Override 1118 public final com.google.protobuf.UnknownFieldSet 1119 getUnknownFields() { 1120 return this.unknownFields; 1121 } 1122 private NSRecordPBuf( 1123 com.google.protobuf.CodedInputStream input, 1124 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1125 throws com.google.protobuf.InvalidProtocolBufferException { 1126 initFields(); 1127 int mutable_bitField0_ = 0; 1128 com.google.protobuf.UnknownFieldSet.Builder unknownFields = 1129 com.google.protobuf.UnknownFieldSet.newBuilder(); 1130 try { 1131 boolean done = false; 1132 while (!done) { 1133 int tag = input.readTag(); 1134 switch (tag) { 1135 case 0: 1136 done = true; 1137 break; 1138 default: { 1139 if (!parseUnknownField(input, unknownFields, 1140 extensionRegistry, tag)) { 1141 done = true; 1142 } 1143 break; 1144 } 1145 case 10: { 1146 bitField0_ |= 0x00000001; 1147 data_ = input.readBytes(); 1148 break; 1149 } 1150 } 1151 } 1152 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 1153 throw e.setUnfinishedMessage(this); 1154 } catch (java.io.IOException e) { 1155 throw new com.google.protobuf.InvalidProtocolBufferException( 1156 e.getMessage()).setUnfinishedMessage(this); 1157 } finally { 1158 this.unknownFields = unknownFields.build(); 1159 makeExtensionsImmutable(); 1160 } 1161 } 1162 public static final com.google.protobuf.Descriptors.Descriptor 1163 getDescriptor() { 1164 return org.apache.reef.io.network.proto.ReefNetworkServiceProtos.internal_static_NSRecordPBuf_descriptor; 1165 } 1166 1167 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 1168 internalGetFieldAccessorTable() { 1169 return org.apache.reef.io.network.proto.ReefNetworkServiceProtos.internal_static_NSRecordPBuf_fieldAccessorTable 1170 .ensureFieldAccessorsInitialized( 1171 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.class, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder.class); 1172 } 1173 1174 public static com.google.protobuf.Parser<NSRecordPBuf> PARSER = 1175 new com.google.protobuf.AbstractParser<NSRecordPBuf>() { 1176 public NSRecordPBuf parsePartialFrom( 1177 com.google.protobuf.CodedInputStream input, 1178 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1179 throws com.google.protobuf.InvalidProtocolBufferException { 1180 return new NSRecordPBuf(input, extensionRegistry); 1181 } 1182 }; 1183 1184 @java.lang.Override 1185 public com.google.protobuf.Parser<NSRecordPBuf> getParserForType() { 1186 return PARSER; 1187 } 1188 1189 private int bitField0_; 1190 // required bytes data = 1; 1191 public static final int DATA_FIELD_NUMBER = 1; 1192 private com.google.protobuf.ByteString data_; 1193 /** 1194 * <code>required bytes data = 1;</code> 1195 */ 1196 public boolean hasData() { 1197 return ((bitField0_ & 0x00000001) == 0x00000001); 1198 } 1199 /** 1200 * <code>required bytes data = 1;</code> 1201 */ 1202 public com.google.protobuf.ByteString getData() { 1203 return data_; 1204 } 1205 1206 private void initFields() { 1207 data_ = com.google.protobuf.ByteString.EMPTY; 1208 } 1209 private byte memoizedIsInitialized = -1; 1210 public final boolean isInitialized() { 1211 byte isInitialized = memoizedIsInitialized; 1212 if (isInitialized != -1) return isInitialized == 1; 1213 1214 if (!hasData()) { 1215 memoizedIsInitialized = 0; 1216 return false; 1217 } 1218 memoizedIsInitialized = 1; 1219 return true; 1220 } 1221 1222 public void writeTo(com.google.protobuf.CodedOutputStream output) 1223 throws java.io.IOException { 1224 getSerializedSize(); 1225 if (((bitField0_ & 0x00000001) == 0x00000001)) { 1226 output.writeBytes(1, data_); 1227 } 1228 getUnknownFields().writeTo(output); 1229 } 1230 1231 private int memoizedSerializedSize = -1; 1232 public int getSerializedSize() { 1233 int size = memoizedSerializedSize; 1234 if (size != -1) return size; 1235 1236 size = 0; 1237 if (((bitField0_ & 0x00000001) == 0x00000001)) { 1238 size += com.google.protobuf.CodedOutputStream 1239 .computeBytesSize(1, data_); 1240 } 1241 size += getUnknownFields().getSerializedSize(); 1242 memoizedSerializedSize = size; 1243 return size; 1244 } 1245 1246 private static final long serialVersionUID = 0L; 1247 @java.lang.Override 1248 protected java.lang.Object writeReplace() 1249 throws java.io.ObjectStreamException { 1250 return super.writeReplace(); 1251 } 1252 1253 @java.lang.Override 1254 public boolean equals(final java.lang.Object obj) { 1255 if (obj == this) { 1256 return true; 1257 } 1258 if (!(obj instanceof org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf)) { 1259 return super.equals(obj); 1260 } 1261 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf other = (org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf) obj; 1262 1263 boolean result = true; 1264 result = result && (hasData() == other.hasData()); 1265 if (hasData()) { 1266 result = result && getData() 1267 .equals(other.getData()); 1268 } 1269 result = result && 1270 getUnknownFields().equals(other.getUnknownFields()); 1271 return result; 1272 } 1273 1274 private int memoizedHashCode = 0; 1275 @java.lang.Override 1276 public int hashCode() { 1277 if (memoizedHashCode != 0) { 1278 return memoizedHashCode; 1279 } 1280 int hash = 41; 1281 hash = (19 * hash) + getDescriptorForType().hashCode(); 1282 if (hasData()) { 1283 hash = (37 * hash) + DATA_FIELD_NUMBER; 1284 hash = (53 * hash) + getData().hashCode(); 1285 } 1286 hash = (29 * hash) + getUnknownFields().hashCode(); 1287 memoizedHashCode = hash; 1288 return hash; 1289 } 1290 1291 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf parseFrom( 1292 com.google.protobuf.ByteString data) 1293 throws com.google.protobuf.InvalidProtocolBufferException { 1294 return PARSER.parseFrom(data); 1295 } 1296 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf parseFrom( 1297 com.google.protobuf.ByteString data, 1298 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1299 throws com.google.protobuf.InvalidProtocolBufferException { 1300 return PARSER.parseFrom(data, extensionRegistry); 1301 } 1302 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf parseFrom(byte[] data) 1303 throws com.google.protobuf.InvalidProtocolBufferException { 1304 return PARSER.parseFrom(data); 1305 } 1306 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf parseFrom( 1307 byte[] data, 1308 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1309 throws com.google.protobuf.InvalidProtocolBufferException { 1310 return PARSER.parseFrom(data, extensionRegistry); 1311 } 1312 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf parseFrom(java.io.InputStream input) 1313 throws java.io.IOException { 1314 return PARSER.parseFrom(input); 1315 } 1316 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf parseFrom( 1317 java.io.InputStream input, 1318 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1319 throws java.io.IOException { 1320 return PARSER.parseFrom(input, extensionRegistry); 1321 } 1322 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf parseDelimitedFrom(java.io.InputStream input) 1323 throws java.io.IOException { 1324 return PARSER.parseDelimitedFrom(input); 1325 } 1326 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf parseDelimitedFrom( 1327 java.io.InputStream input, 1328 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1329 throws java.io.IOException { 1330 return PARSER.parseDelimitedFrom(input, extensionRegistry); 1331 } 1332 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf parseFrom( 1333 com.google.protobuf.CodedInputStream input) 1334 throws java.io.IOException { 1335 return PARSER.parseFrom(input); 1336 } 1337 public static org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf parseFrom( 1338 com.google.protobuf.CodedInputStream input, 1339 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1340 throws java.io.IOException { 1341 return PARSER.parseFrom(input, extensionRegistry); 1342 } 1343 1344 public static Builder newBuilder() { return Builder.create(); } 1345 public Builder newBuilderForType() { return newBuilder(); } 1346 public static Builder newBuilder(org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf prototype) { 1347 return newBuilder().mergeFrom(prototype); 1348 } 1349 public Builder toBuilder() { return newBuilder(this); } 1350 1351 @java.lang.Override 1352 protected Builder newBuilderForType( 1353 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 1354 Builder builder = new Builder(parent); 1355 return builder; 1356 } 1357 /** 1358 * Protobuf type {@code NSRecordPBuf} 1359 */ 1360 public static final class Builder extends 1361 com.google.protobuf.GeneratedMessage.Builder<Builder> 1362 implements org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder { 1363 public static final com.google.protobuf.Descriptors.Descriptor 1364 getDescriptor() { 1365 return org.apache.reef.io.network.proto.ReefNetworkServiceProtos.internal_static_NSRecordPBuf_descriptor; 1366 } 1367 1368 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 1369 internalGetFieldAccessorTable() { 1370 return org.apache.reef.io.network.proto.ReefNetworkServiceProtos.internal_static_NSRecordPBuf_fieldAccessorTable 1371 .ensureFieldAccessorsInitialized( 1372 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.class, org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder.class); 1373 } 1374 1375 // Construct using org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.newBuilder() 1376 private Builder() { 1377 maybeForceBuilderInitialization(); 1378 } 1379 1380 private Builder( 1381 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 1382 super(parent); 1383 maybeForceBuilderInitialization(); 1384 } 1385 private void maybeForceBuilderInitialization() { 1386 if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { 1387 } 1388 } 1389 private static Builder create() { 1390 return new Builder(); 1391 } 1392 1393 public Builder clear() { 1394 super.clear(); 1395 data_ = com.google.protobuf.ByteString.EMPTY; 1396 bitField0_ = (bitField0_ & ~0x00000001); 1397 return this; 1398 } 1399 1400 public Builder clone() { 1401 return create().mergeFrom(buildPartial()); 1402 } 1403 1404 public com.google.protobuf.Descriptors.Descriptor 1405 getDescriptorForType() { 1406 return org.apache.reef.io.network.proto.ReefNetworkServiceProtos.internal_static_NSRecordPBuf_descriptor; 1407 } 1408 1409 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf getDefaultInstanceForType() { 1410 return org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.getDefaultInstance(); 1411 } 1412 1413 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf build() { 1414 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf result = buildPartial(); 1415 if (!result.isInitialized()) { 1416 throw newUninitializedMessageException(result); 1417 } 1418 return result; 1419 } 1420 1421 public org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf buildPartial() { 1422 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf result = new org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf(this); 1423 int from_bitField0_ = bitField0_; 1424 int to_bitField0_ = 0; 1425 if (((from_bitField0_ & 0x00000001) == 0x00000001)) { 1426 to_bitField0_ |= 0x00000001; 1427 } 1428 result.data_ = data_; 1429 result.bitField0_ = to_bitField0_; 1430 onBuilt(); 1431 return result; 1432 } 1433 1434 public Builder mergeFrom(com.google.protobuf.Message other) { 1435 if (other instanceof org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf) { 1436 return mergeFrom((org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf)other); 1437 } else { 1438 super.mergeFrom(other); 1439 return this; 1440 } 1441 } 1442 1443 public Builder mergeFrom(org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf other) { 1444 if (other == org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.getDefaultInstance()) return this; 1445 if (other.hasData()) { 1446 setData(other.getData()); 1447 } 1448 this.mergeUnknownFields(other.getUnknownFields()); 1449 return this; 1450 } 1451 1452 public final boolean isInitialized() { 1453 if (!hasData()) { 1454 1455 return false; 1456 } 1457 return true; 1458 } 1459 1460 public Builder mergeFrom( 1461 com.google.protobuf.CodedInputStream input, 1462 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1463 throws java.io.IOException { 1464 org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf parsedMessage = null; 1465 try { 1466 parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); 1467 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 1468 parsedMessage = (org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf) e.getUnfinishedMessage(); 1469 throw e; 1470 } finally { 1471 if (parsedMessage != null) { 1472 mergeFrom(parsedMessage); 1473 } 1474 } 1475 return this; 1476 } 1477 private int bitField0_; 1478 1479 // required bytes data = 1; 1480 private com.google.protobuf.ByteString data_ = com.google.protobuf.ByteString.EMPTY; 1481 /** 1482 * <code>required bytes data = 1;</code> 1483 */ 1484 public boolean hasData() { 1485 return ((bitField0_ & 0x00000001) == 0x00000001); 1486 } 1487 /** 1488 * <code>required bytes data = 1;</code> 1489 */ 1490 public com.google.protobuf.ByteString getData() { 1491 return data_; 1492 } 1493 /** 1494 * <code>required bytes data = 1;</code> 1495 */ 1496 public Builder setData(com.google.protobuf.ByteString value) { 1497 if (value == null) { 1498 throw new NullPointerException(); 1499 } 1500 bitField0_ |= 0x00000001; 1501 data_ = value; 1502 onChanged(); 1503 return this; 1504 } 1505 /** 1506 * <code>required bytes data = 1;</code> 1507 */ 1508 public Builder clearData() { 1509 bitField0_ = (bitField0_ & ~0x00000001); 1510 data_ = getDefaultInstance().getData(); 1511 onChanged(); 1512 return this; 1513 } 1514 1515 // @@protoc_insertion_point(builder_scope:NSRecordPBuf) 1516 } 1517 1518 static { 1519 defaultInstance = new NSRecordPBuf(true); 1520 defaultInstance.initFields(); 1521 } 1522 1523 // @@protoc_insertion_point(class_scope:NSRecordPBuf) 1524 } 1525 1526 private static com.google.protobuf.Descriptors.Descriptor 1527 internal_static_NSMessagePBuf_descriptor; 1528 private static 1529 com.google.protobuf.GeneratedMessage.FieldAccessorTable 1530 internal_static_NSMessagePBuf_fieldAccessorTable; 1531 private static com.google.protobuf.Descriptors.Descriptor 1532 internal_static_NSRecordPBuf_descriptor; 1533 private static 1534 com.google.protobuf.GeneratedMessage.FieldAccessorTable 1535 internal_static_NSRecordPBuf_fieldAccessorTable; 1536 1537 public static com.google.protobuf.Descriptors.FileDescriptor 1538 getDescriptor() { 1539 return descriptor; 1540 } 1541 private static com.google.protobuf.Descriptors.FileDescriptor 1542 descriptor; 1543 static { 1544 java.lang.String[] descriptorData = { 1545 "\n\021ns_protocol.proto\"K\n\rNSMessagePBuf\022\r\n\005" + 1546 "srcid\030\002 \002(\t\022\016\n\006destid\030\003 \002(\t\022\033\n\004msgs\030\004 \003(" + 1547 "\0132\r.NSRecordPBuf\"\034\n\014NSRecordPBuf\022\014\n\004data" + 1548 "\030\001 \002(\014BB\n org.apache.reef.io.network.pro" + 1549 "toB\030ReefNetworkServiceProtos\210\001\001\240\001\001" 1550 }; 1551 com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = 1552 new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { 1553 public com.google.protobuf.ExtensionRegistry assignDescriptors( 1554 com.google.protobuf.Descriptors.FileDescriptor root) { 1555 descriptor = root; 1556 internal_static_NSMessagePBuf_descriptor = 1557 getDescriptor().getMessageTypes().get(0); 1558 internal_static_NSMessagePBuf_fieldAccessorTable = new 1559 com.google.protobuf.GeneratedMessage.FieldAccessorTable( 1560 internal_static_NSMessagePBuf_descriptor, 1561 new java.lang.String[] { "Srcid", "Destid", "Msgs", }); 1562 internal_static_NSRecordPBuf_descriptor = 1563 getDescriptor().getMessageTypes().get(1); 1564 internal_static_NSRecordPBuf_fieldAccessorTable = new 1565 com.google.protobuf.GeneratedMessage.FieldAccessorTable( 1566 internal_static_NSRecordPBuf_descriptor, 1567 new java.lang.String[] { "Data", }); 1568 return null; 1569 } 1570 }; 1571 com.google.protobuf.Descriptors.FileDescriptor 1572 .internalBuildGeneratedFileFrom(descriptorData, 1573 new com.google.protobuf.Descriptors.FileDescriptor[] { 1574 }, assigner); 1575 } 1576 1577 // @@protoc_insertion_point(outer_class_scope) 1578}