Fix checkstyle whitespace issues - WHITESPACE ONLY
Change-Id: Ic205c1afd639c6008d61d9de95cb764eeb6238ca
diff --git a/src/main/java/net/onrc/onos/core/datastore/DataStoreClient.java b/src/main/java/net/onrc/onos/core/datastore/DataStoreClient.java
index 7ec6251..be9fce5 100644
--- a/src/main/java/net/onrc/onos/core/datastore/DataStoreClient.java
+++ b/src/main/java/net/onrc/onos/core/datastore/DataStoreClient.java
@@ -8,17 +8,18 @@
private static final String BACKEND = System.getProperty("net.onrc.onos.core.datastore.backend", "hazelcast");
// Suppresses default constructor, ensuring non-instantiability.
- private DataStoreClient() {}
+ private DataStoreClient() {
+ }
public static IKVClient getClient() {
// TODO read config and return appropriate IKVClient
switch (BACKEND) {
- case "ramcloud":
- return RCClient.getClient();
- case "hazelcast":
- return HZClient.getClient();
- default:
- return HZClient.getClient();
+ case "ramcloud":
+ return RCClient.getClient();
+ case "hazelcast":
+ return HZClient.getClient();
+ default:
+ return HZClient.getClient();
}
}
diff --git a/src/main/java/net/onrc/onos/core/datastore/IKVClient.java b/src/main/java/net/onrc/onos/core/datastore/IKVClient.java
index e298548..50bdf92 100644
--- a/src/main/java/net/onrc/onos/core/datastore/IKVClient.java
+++ b/src/main/java/net/onrc/onos/core/datastore/IKVClient.java
@@ -14,7 +14,7 @@
/**
* Drop table.
- *
+ * <p/>
* Behavior of IKVTable instances accessing dropped table is undefined.
*
* @param table IKVTable to drop.
@@ -58,8 +58,7 @@
* @param tableId
* @param key
* @param value
- * @param version
- * expected version in the data store
+ * @param version expected version in the data store
* @return version after update
* @throws ObjectDoesntExistException
* @throws WrongVersionException
@@ -69,8 +68,9 @@
/**
* Update an existing Key-Value entry in table, without checking version.
- *
+ * <p/>
* FIXME remove this method and use forceCreate for this purpose?
+ *
* @param tableId
* @param key
* @param value
@@ -83,13 +83,13 @@
// TODO Adding serialized value as parameter to this interface may
// give an option to improve performance on some backends.
+
/**
* Remove an existing Key-Value entry in table
*
* @param tableId
* @param key
- * @param version
- * expected version in the data store
+ * @param version expected version in the data store
* @return version of removed object
* @throws ObjectDoesntExistException
* @throws WrongVersionException
@@ -108,35 +108,34 @@
/**
* Get all the entries in table.
+ *
* @param tableId
* @return entries in this table.
*/
public Iterable<IKVEntry> getAllEntries(IKVTableID tableId);
/**
- *
- * @see #create(IKVTableID, byte[], byte[])
- *
* @return IMultiOpEntry for this operation
- *
+ * @see #create(IKVTableID, byte[], byte[])
*/
public IMultiEntryOperation createOp(IKVTableID tableId, byte[] key, byte[] value);
public IMultiEntryOperation forceCreateOp(IKVTableID tableId, byte[] key,
- byte[] value);
+ byte[] value);
public IMultiEntryOperation readOp(IKVTableID tableId, byte[] key);
public IMultiEntryOperation updateOp(IKVTableID tableId, byte[] key, byte[] value,
- long version);
+ long version);
public IMultiEntryOperation deleteOp(IKVTableID tableId, byte[] key, byte[] value,
- long version);
+ long version);
public IMultiEntryOperation forceDeleteOp(IKVTableID tableId, byte[] key);
/**
* Batch delete operation
+ *
* @param ops delete operations
* @return true if failed operation exists
*/
@@ -144,6 +143,7 @@
/**
* Batch write operation
+ *
* @param ops write operations
* @return true if failed operation exists
*/
@@ -151,6 +151,7 @@
/**
* Batch read operation
+ *
* @param ops read operations
* @return true if failed operation exists
*/
diff --git a/src/main/java/net/onrc/onos/core/datastore/IKVTable.java b/src/main/java/net/onrc/onos/core/datastore/IKVTable.java
index 864b270..2260ad0 100644
--- a/src/main/java/net/onrc/onos/core/datastore/IKVTable.java
+++ b/src/main/java/net/onrc/onos/core/datastore/IKVTable.java
@@ -63,8 +63,7 @@
*
* @param key
* @param value
- * @param version
- * expected version in the data store
+ * @param version expected version in the data store
* @return version after update
* @throws ObjectDoesntExistException
* @throws WrongVersionException
@@ -87,8 +86,7 @@
* Remove an existing Key-Value entry in table
*
* @param key
- * @param version
- * expected version in the data store
+ * @param version expected version in the data store
* @return version of removed object
* @throws ObjectDoesntExistException
* @throws WrongVersionException
@@ -106,6 +104,7 @@
/**
* Get all the entries in table.
+ *
* @return entries in this table.
*/
public Iterable<IKVEntry> getAllEntries();
diff --git a/src/main/java/net/onrc/onos/core/datastore/ObjectDoesntExistException.java b/src/main/java/net/onrc/onos/core/datastore/ObjectDoesntExistException.java
index 06d21ca..354cd9c 100644
--- a/src/main/java/net/onrc/onos/core/datastore/ObjectDoesntExistException.java
+++ b/src/main/java/net/onrc/onos/core/datastore/ObjectDoesntExistException.java
@@ -13,7 +13,7 @@
}
public ObjectDoesntExistException(final IKVTableID tableID,
- final byte[] key, final Throwable cause) {
+ final byte[] key, final Throwable cause) {
super(ByteArrayUtil.toHexStringBuffer(key, ":")
+ " did not exist on table:" + tableID, cause);
}
diff --git a/src/main/java/net/onrc/onos/core/datastore/ObjectExistsException.java b/src/main/java/net/onrc/onos/core/datastore/ObjectExistsException.java
index 75c4e4d..08be74f 100644
--- a/src/main/java/net/onrc/onos/core/datastore/ObjectExistsException.java
+++ b/src/main/java/net/onrc/onos/core/datastore/ObjectExistsException.java
@@ -13,7 +13,7 @@
}
public ObjectExistsException(final IKVTableID tableID, final byte[] key,
- final Throwable cause) {
+ final Throwable cause) {
super(ByteArrayUtil.toHexStringBuffer(key, ":")
+ " already exist on table:" + tableID, cause);
}
diff --git a/src/main/java/net/onrc/onos/core/datastore/RCProtos.java b/src/main/java/net/onrc/onos/core/datastore/RCProtos.java
index 5e823ee..44b6934 100644
--- a/src/main/java/net/onrc/onos/core/datastore/RCProtos.java
+++ b/src/main/java/net/onrc/onos/core/datastore/RCProtos.java
@@ -4,2174 +4,2388 @@
package net.onrc.onos.core.datastore;
public final class RCProtos {
- private RCProtos() {}
- public static void registerAllExtensions(
- com.google.protobuf.ExtensionRegistry registry) {
- }
- public interface SwitchPropertyOrBuilder
- extends com.google.protobuf.MessageOrBuilder {
-
- // required int64 dpid = 1;
- /**
- * <code>required int64 dpid = 1;</code>
- */
- boolean hasDpid();
- /**
- * <code>required int64 dpid = 1;</code>
- */
- long getDpid();
-
- // required int32 status = 2;
- /**
- * <code>required int32 status = 2;</code>
- */
- boolean hasStatus();
- /**
- * <code>required int32 status = 2;</code>
- */
- int getStatus();
-
- // optional bytes value = 3;
- /**
- * <code>optional bytes value = 3;</code>
- */
- boolean hasValue();
- /**
- * <code>optional bytes value = 3;</code>
- */
- com.google.protobuf.ByteString getValue();
- }
- /**
- * Protobuf type {@code RCProtos.SwitchProperty}
- */
- public static final class SwitchProperty extends
- com.google.protobuf.GeneratedMessage
- implements SwitchPropertyOrBuilder {
- // Use SwitchProperty.newBuilder() to construct.
- private SwitchProperty(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
- super(builder);
- this.unknownFields = builder.getUnknownFields();
- }
- private SwitchProperty(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
-
- private static final SwitchProperty defaultInstance;
- public static SwitchProperty getDefaultInstance() {
- return defaultInstance;
+ private RCProtos() {
}
- public SwitchProperty getDefaultInstanceForType() {
- return defaultInstance;
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistry registry) {
}
- private final com.google.protobuf.UnknownFieldSet unknownFields;
- @java.lang.Override
- public final com.google.protobuf.UnknownFieldSet
- getUnknownFields() {
- return this.unknownFields;
- }
- private SwitchProperty(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- initFields();
- int mutable_bitField0_ = 0;
- com.google.protobuf.UnknownFieldSet.Builder unknownFields =
- com.google.protobuf.UnknownFieldSet.newBuilder();
- try {
- boolean done = false;
- while (!done) {
- int tag = input.readTag();
- switch (tag) {
- case 0:
- done = true;
- break;
- default: {
- if (!parseUnknownField(input, unknownFields,
- extensionRegistry, tag)) {
- done = true;
- }
- break;
- }
- case 8: {
- bitField0_ |= 0x00000001;
- dpid_ = input.readInt64();
- break;
- }
- case 16: {
- bitField0_ |= 0x00000002;
- status_ = input.readInt32();
- break;
- }
- case 26: {
- bitField0_ |= 0x00000004;
- value_ = input.readBytes();
- break;
- }
- }
- }
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- throw e.setUnfinishedMessage(this);
- } catch (java.io.IOException e) {
- throw new com.google.protobuf.InvalidProtocolBufferException(
- e.getMessage()).setUnfinishedMessage(this);
- } finally {
- this.unknownFields = unknownFields.build();
- makeExtensionsImmutable();
- }
- }
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_SwitchProperty_descriptor;
+ public interface SwitchPropertyOrBuilder
+ extends com.google.protobuf.MessageOrBuilder {
+
+ // required int64 dpid = 1;
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ boolean hasDpid();
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ long getDpid();
+
+ // required int32 status = 2;
+
+ /**
+ * <code>required int32 status = 2;</code>
+ */
+ boolean hasStatus();
+
+ /**
+ * <code>required int32 status = 2;</code>
+ */
+ int getStatus();
+
+ // optional bytes value = 3;
+
+ /**
+ * <code>optional bytes value = 3;</code>
+ */
+ boolean hasValue();
+
+ /**
+ * <code>optional bytes value = 3;</code>
+ */
+ com.google.protobuf.ByteString getValue();
}
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_SwitchProperty_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- net.onrc.onos.core.datastore.RCProtos.SwitchProperty.class, net.onrc.onos.core.datastore.RCProtos.SwitchProperty.Builder.class);
- }
-
- public static com.google.protobuf.Parser<SwitchProperty> PARSER =
- new com.google.protobuf.AbstractParser<SwitchProperty>() {
- public SwitchProperty parsePartialFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return new SwitchProperty(input, extensionRegistry);
- }
- };
-
- @java.lang.Override
- public com.google.protobuf.Parser<SwitchProperty> getParserForType() {
- return PARSER;
- }
-
- private int bitField0_;
- // required int64 dpid = 1;
- public static final int DPID_FIELD_NUMBER = 1;
- private long dpid_;
- /**
- * <code>required int64 dpid = 1;</code>
- */
- public boolean hasDpid() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * <code>required int64 dpid = 1;</code>
- */
- public long getDpid() {
- return dpid_;
- }
-
- // required int32 status = 2;
- public static final int STATUS_FIELD_NUMBER = 2;
- private int status_;
- /**
- * <code>required int32 status = 2;</code>
- */
- public boolean hasStatus() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * <code>required int32 status = 2;</code>
- */
- public int getStatus() {
- return status_;
- }
-
- // optional bytes value = 3;
- public static final int VALUE_FIELD_NUMBER = 3;
- private com.google.protobuf.ByteString value_;
- /**
- * <code>optional bytes value = 3;</code>
- */
- public boolean hasValue() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
- }
- /**
- * <code>optional bytes value = 3;</code>
- */
- public com.google.protobuf.ByteString getValue() {
- return value_;
- }
-
- private void initFields() {
- dpid_ = 0L;
- status_ = 0;
- value_ = com.google.protobuf.ByteString.EMPTY;
- }
- private byte memoizedIsInitialized = -1;
- public final boolean isInitialized() {
- byte isInitialized = memoizedIsInitialized;
- if (isInitialized != -1) return isInitialized == 1;
-
- if (!hasDpid()) {
- memoizedIsInitialized = 0;
- return false;
- }
- if (!hasStatus()) {
- memoizedIsInitialized = 0;
- return false;
- }
- memoizedIsInitialized = 1;
- return true;
- }
-
- public void writeTo(com.google.protobuf.CodedOutputStream output)
- throws java.io.IOException {
- getSerializedSize();
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- output.writeInt64(1, dpid_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- output.writeInt32(2, status_);
- }
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
- output.writeBytes(3, value_);
- }
- getUnknownFields().writeTo(output);
- }
-
- private int memoizedSerializedSize = -1;
- public int getSerializedSize() {
- int size = memoizedSerializedSize;
- if (size != -1) return size;
-
- size = 0;
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt64Size(1, dpid_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt32Size(2, status_);
- }
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(3, value_);
- }
- size += getUnknownFields().getSerializedSize();
- memoizedSerializedSize = size;
- return size;
- }
-
- private static final long serialVersionUID = 0L;
- @java.lang.Override
- protected java.lang.Object writeReplace()
- throws java.io.ObjectStreamException {
- return super.writeReplace();
- }
-
- public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(
- com.google.protobuf.ByteString data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(
- com.google.protobuf.ByteString data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(byte[] data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(
- byte[] data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
- public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseDelimitedFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input);
- }
- public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseDelimitedFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input, extensionRegistry);
- }
- public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(
- com.google.protobuf.CodedInputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
-
- public static Builder newBuilder() { return Builder.create(); }
- public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder(net.onrc.onos.core.datastore.RCProtos.SwitchProperty prototype) {
- return newBuilder().mergeFrom(prototype);
- }
- public Builder toBuilder() { return newBuilder(this); }
-
- @java.lang.Override
- protected Builder newBuilderForType(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- Builder builder = new Builder(parent);
- return builder;
- }
/**
* Protobuf type {@code RCProtos.SwitchProperty}
*/
- public static final class Builder extends
- com.google.protobuf.GeneratedMessage.Builder<Builder>
- implements net.onrc.onos.core.datastore.RCProtos.SwitchPropertyOrBuilder {
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_SwitchProperty_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_SwitchProperty_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- net.onrc.onos.core.datastore.RCProtos.SwitchProperty.class, net.onrc.onos.core.datastore.RCProtos.SwitchProperty.Builder.class);
- }
-
- // Construct using net.onrc.onos.core.datastore.RCProtos.SwitchProperty.newBuilder()
- private Builder() {
- maybeForceBuilderInitialization();
- }
-
- private Builder(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- super(parent);
- maybeForceBuilderInitialization();
- }
- private void maybeForceBuilderInitialization() {
- if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
+ public static final class SwitchProperty extends
+ com.google.protobuf.GeneratedMessage
+ implements SwitchPropertyOrBuilder {
+ // Use SwitchProperty.newBuilder() to construct.
+ private SwitchProperty(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
+ super(builder);
+ this.unknownFields = builder.getUnknownFields();
}
- }
- private static Builder create() {
- return new Builder();
- }
- public Builder clear() {
- super.clear();
- dpid_ = 0L;
- bitField0_ = (bitField0_ & ~0x00000001);
- status_ = 0;
- bitField0_ = (bitField0_ & ~0x00000002);
- value_ = com.google.protobuf.ByteString.EMPTY;
- bitField0_ = (bitField0_ & ~0x00000004);
- return this;
- }
-
- public Builder clone() {
- return create().mergeFrom(buildPartial());
- }
-
- public com.google.protobuf.Descriptors.Descriptor
- getDescriptorForType() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_SwitchProperty_descriptor;
- }
-
- public net.onrc.onos.core.datastore.RCProtos.SwitchProperty getDefaultInstanceForType() {
- return net.onrc.onos.core.datastore.RCProtos.SwitchProperty.getDefaultInstance();
- }
-
- public net.onrc.onos.core.datastore.RCProtos.SwitchProperty build() {
- net.onrc.onos.core.datastore.RCProtos.SwitchProperty result = buildPartial();
- if (!result.isInitialized()) {
- throw newUninitializedMessageException(result);
+ private SwitchProperty(boolean noInit) {
+ this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance();
}
- return result;
- }
- public net.onrc.onos.core.datastore.RCProtos.SwitchProperty buildPartial() {
- net.onrc.onos.core.datastore.RCProtos.SwitchProperty result = new net.onrc.onos.core.datastore.RCProtos.SwitchProperty(this);
- int from_bitField0_ = bitField0_;
- int to_bitField0_ = 0;
- if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
- to_bitField0_ |= 0x00000001;
+ private static final SwitchProperty defaultInstance;
+
+ public static SwitchProperty getDefaultInstance() {
+ return defaultInstance;
}
- result.dpid_ = dpid_;
- if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
- to_bitField0_ |= 0x00000002;
+
+ public SwitchProperty getDefaultInstanceForType() {
+ return defaultInstance;
}
- result.status_ = status_;
- if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
- to_bitField0_ |= 0x00000004;
- }
- result.value_ = value_;
- result.bitField0_ = to_bitField0_;
- onBuilt();
- return result;
- }
- public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof net.onrc.onos.core.datastore.RCProtos.SwitchProperty) {
- return mergeFrom((net.onrc.onos.core.datastore.RCProtos.SwitchProperty)other);
- } else {
- super.mergeFrom(other);
- return this;
- }
- }
+ private final com.google.protobuf.UnknownFieldSet unknownFields;
- public Builder mergeFrom(net.onrc.onos.core.datastore.RCProtos.SwitchProperty other) {
- if (other == net.onrc.onos.core.datastore.RCProtos.SwitchProperty.getDefaultInstance()) return this;
- if (other.hasDpid()) {
- setDpid(other.getDpid());
- }
- if (other.hasStatus()) {
- setStatus(other.getStatus());
- }
- if (other.hasValue()) {
- setValue(other.getValue());
- }
- this.mergeUnknownFields(other.getUnknownFields());
- return this;
- }
-
- public final boolean isInitialized() {
- if (!hasDpid()) {
-
- return false;
- }
- if (!hasStatus()) {
-
- return false;
- }
- return true;
- }
-
- public Builder mergeFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- net.onrc.onos.core.datastore.RCProtos.SwitchProperty parsedMessage = null;
- try {
- parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (net.onrc.onos.core.datastore.RCProtos.SwitchProperty) e.getUnfinishedMessage();
- throw e;
- } finally {
- if (parsedMessage != null) {
- mergeFrom(parsedMessage);
- }
- }
- return this;
- }
- private int bitField0_;
-
- // required int64 dpid = 1;
- private long dpid_ ;
- /**
- * <code>required int64 dpid = 1;</code>
- */
- public boolean hasDpid() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * <code>required int64 dpid = 1;</code>
- */
- public long getDpid() {
- return dpid_;
- }
- /**
- * <code>required int64 dpid = 1;</code>
- */
- public Builder setDpid(long value) {
- bitField0_ |= 0x00000001;
- dpid_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>required int64 dpid = 1;</code>
- */
- public Builder clearDpid() {
- bitField0_ = (bitField0_ & ~0x00000001);
- dpid_ = 0L;
- onChanged();
- return this;
- }
-
- // required int32 status = 2;
- private int status_ ;
- /**
- * <code>required int32 status = 2;</code>
- */
- public boolean hasStatus() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * <code>required int32 status = 2;</code>
- */
- public int getStatus() {
- return status_;
- }
- /**
- * <code>required int32 status = 2;</code>
- */
- public Builder setStatus(int value) {
- bitField0_ |= 0x00000002;
- status_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>required int32 status = 2;</code>
- */
- public Builder clearStatus() {
- bitField0_ = (bitField0_ & ~0x00000002);
- status_ = 0;
- onChanged();
- return this;
- }
-
- // optional bytes value = 3;
- private com.google.protobuf.ByteString value_ = com.google.protobuf.ByteString.EMPTY;
- /**
- * <code>optional bytes value = 3;</code>
- */
- public boolean hasValue() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
- }
- /**
- * <code>optional bytes value = 3;</code>
- */
- public com.google.protobuf.ByteString getValue() {
- return value_;
- }
- /**
- * <code>optional bytes value = 3;</code>
- */
- public Builder setValue(com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000004;
- value_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>optional bytes value = 3;</code>
- */
- public Builder clearValue() {
- bitField0_ = (bitField0_ & ~0x00000004);
- value_ = getDefaultInstance().getValue();
- onChanged();
- return this;
- }
-
- // @@protoc_insertion_point(builder_scope:RCProtos.SwitchProperty)
- }
-
- static {
- defaultInstance = new SwitchProperty(true);
- defaultInstance.initFields();
- }
-
- // @@protoc_insertion_point(class_scope:RCProtos.SwitchProperty)
- }
-
- public interface PortPropertyOrBuilder
- extends com.google.protobuf.MessageOrBuilder {
-
- // required int64 dpid = 1;
- /**
- * <code>required int64 dpid = 1;</code>
- */
- boolean hasDpid();
- /**
- * <code>required int64 dpid = 1;</code>
- */
- long getDpid();
-
- // required int64 number = 2;
- /**
- * <code>required int64 number = 2;</code>
- */
- boolean hasNumber();
- /**
- * <code>required int64 number = 2;</code>
- */
- long getNumber();
-
- // required int32 status = 3;
- /**
- * <code>required int32 status = 3;</code>
- */
- boolean hasStatus();
- /**
- * <code>required int32 status = 3;</code>
- */
- int getStatus();
-
- // optional bytes value = 4;
- /**
- * <code>optional bytes value = 4;</code>
- */
- boolean hasValue();
- /**
- * <code>optional bytes value = 4;</code>
- */
- com.google.protobuf.ByteString getValue();
- }
- /**
- * Protobuf type {@code RCProtos.PortProperty}
- */
- public static final class PortProperty extends
- com.google.protobuf.GeneratedMessage
- implements PortPropertyOrBuilder {
- // Use PortProperty.newBuilder() to construct.
- private PortProperty(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
- super(builder);
- this.unknownFields = builder.getUnknownFields();
- }
- private PortProperty(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
-
- private static final PortProperty defaultInstance;
- public static PortProperty getDefaultInstance() {
- return defaultInstance;
- }
-
- public PortProperty getDefaultInstanceForType() {
- return defaultInstance;
- }
-
- private final com.google.protobuf.UnknownFieldSet unknownFields;
- @java.lang.Override
- public final com.google.protobuf.UnknownFieldSet
+ @java.lang.Override
+ public final com.google.protobuf.UnknownFieldSet
getUnknownFields() {
- return this.unknownFields;
- }
- private PortProperty(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- initFields();
- int mutable_bitField0_ = 0;
- com.google.protobuf.UnknownFieldSet.Builder unknownFields =
- com.google.protobuf.UnknownFieldSet.newBuilder();
- try {
- boolean done = false;
- while (!done) {
- int tag = input.readTag();
- switch (tag) {
- case 0:
- done = true;
- break;
- default: {
- if (!parseUnknownField(input, unknownFields,
- extensionRegistry, tag)) {
- done = true;
- }
- break;
- }
- case 8: {
- bitField0_ |= 0x00000001;
- dpid_ = input.readInt64();
- break;
- }
- case 16: {
- bitField0_ |= 0x00000002;
- number_ = input.readInt64();
- break;
- }
- case 24: {
- bitField0_ |= 0x00000004;
- status_ = input.readInt32();
- break;
- }
- case 34: {
- bitField0_ |= 0x00000008;
- value_ = input.readBytes();
- break;
- }
- }
+ return this.unknownFields;
}
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- throw e.setUnfinishedMessage(this);
- } catch (java.io.IOException e) {
- throw new com.google.protobuf.InvalidProtocolBufferException(
- e.getMessage()).setUnfinishedMessage(this);
- } finally {
- this.unknownFields = unknownFields.build();
- makeExtensionsImmutable();
- }
- }
- public static final com.google.protobuf.Descriptors.Descriptor
+
+ private SwitchProperty(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ initFields();
+ int mutable_bitField0_ = 0;
+ com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+ com.google.protobuf.UnknownFieldSet.newBuilder();
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ default: {
+ if (!parseUnknownField(input, unknownFields,
+ extensionRegistry, tag)) {
+ done = true;
+ }
+ break;
+ }
+ case 8: {
+ bitField0_ |= 0x00000001;
+ dpid_ = input.readInt64();
+ break;
+ }
+ case 16: {
+ bitField0_ |= 0x00000002;
+ status_ = input.readInt32();
+ break;
+ }
+ case 26: {
+ bitField0_ |= 0x00000004;
+ value_ = input.readBytes();
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.setUnfinishedMessage(this);
+ } catch (java.io.IOException e) {
+ throw new com.google.protobuf.InvalidProtocolBufferException(
+ e.getMessage()).setUnfinishedMessage(this);
+ } finally {
+ this.unknownFields = unknownFields.build();
+ makeExtensionsImmutable();
+ }
+ }
+
+ public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_PortProperty_descriptor;
- }
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_SwitchProperty_descriptor;
+ }
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_PortProperty_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- net.onrc.onos.core.datastore.RCProtos.PortProperty.class, net.onrc.onos.core.datastore.RCProtos.PortProperty.Builder.class);
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_SwitchProperty_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ net.onrc.onos.core.datastore.RCProtos.SwitchProperty.class, net.onrc.onos.core.datastore.RCProtos.SwitchProperty.Builder.class);
+ }
+
+ public static com.google.protobuf.Parser<SwitchProperty> PARSER =
+ new com.google.protobuf.AbstractParser<SwitchProperty>() {
+ public SwitchProperty parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return new SwitchProperty(input, extensionRegistry);
+ }
+ };
+
+ @java.lang.Override
+ public com.google.protobuf.Parser<SwitchProperty> getParserForType() {
+ return PARSER;
+ }
+
+ private int bitField0_;
+ // required int64 dpid = 1;
+ public static final int DPID_FIELD_NUMBER = 1;
+ private long dpid_;
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ public boolean hasDpid() {
+ return ((bitField0_ & 0x00000001) == 0x00000001);
+ }
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ public long getDpid() {
+ return dpid_;
+ }
+
+ // required int32 status = 2;
+ public static final int STATUS_FIELD_NUMBER = 2;
+ private int status_;
+
+ /**
+ * <code>required int32 status = 2;</code>
+ */
+ public boolean hasStatus() {
+ return ((bitField0_ & 0x00000002) == 0x00000002);
+ }
+
+ /**
+ * <code>required int32 status = 2;</code>
+ */
+ public int getStatus() {
+ return status_;
+ }
+
+ // optional bytes value = 3;
+ public static final int VALUE_FIELD_NUMBER = 3;
+ private com.google.protobuf.ByteString value_;
+
+ /**
+ * <code>optional bytes value = 3;</code>
+ */
+ public boolean hasValue() {
+ return ((bitField0_ & 0x00000004) == 0x00000004);
+ }
+
+ /**
+ * <code>optional bytes value = 3;</code>
+ */
+ public com.google.protobuf.ByteString getValue() {
+ return value_;
+ }
+
+ private void initFields() {
+ dpid_ = 0L;
+ status_ = 0;
+ value_ = com.google.protobuf.ByteString.EMPTY;
+ }
+
+ private byte memoizedIsInitialized = -1;
+
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized != -1) return isInitialized == 1;
+
+ if (!hasDpid()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ if (!hasStatus()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ getSerializedSize();
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ output.writeInt64(1, dpid_);
+ }
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ output.writeInt32(2, status_);
+ }
+ if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ output.writeBytes(3, value_);
+ }
+ getUnknownFields().writeTo(output);
+ }
+
+ private int memoizedSerializedSize = -1;
+
+ public int getSerializedSize() {
+ int size = memoizedSerializedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt64Size(1, dpid_);
+ }
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(2, status_);
+ }
+ if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeBytesSize(3, value_);
+ }
+ size += getUnknownFields().getSerializedSize();
+ memoizedSerializedSize = size;
+ return size;
+ }
+
+ private static final long serialVersionUID = 0L;
+
+ @java.lang.Override
+ protected java.lang.Object writeReplace()
+ throws java.io.ObjectStreamException {
+ return super.writeReplace();
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input, extensionRegistry);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.SwitchProperty parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public static Builder newBuilder() {
+ return Builder.create();
+ }
+
+ public Builder newBuilderForType() {
+ return newBuilder();
+ }
+
+ public static Builder newBuilder(net.onrc.onos.core.datastore.RCProtos.SwitchProperty prototype) {
+ return newBuilder().mergeFrom(prototype);
+ }
+
+ public Builder toBuilder() {
+ return newBuilder(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+
+ /**
+ * Protobuf type {@code RCProtos.SwitchProperty}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessage.Builder<Builder>
+ implements net.onrc.onos.core.datastore.RCProtos.SwitchPropertyOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_SwitchProperty_descriptor;
+ }
+
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_SwitchProperty_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ net.onrc.onos.core.datastore.RCProtos.SwitchProperty.class, net.onrc.onos.core.datastore.RCProtos.SwitchProperty.Builder.class);
+ }
+
+ // Construct using net.onrc.onos.core.datastore.RCProtos.SwitchProperty.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
+
+ private Builder(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
+ }
+ }
+
+ private static Builder create() {
+ return new Builder();
+ }
+
+ public Builder clear() {
+ super.clear();
+ dpid_ = 0L;
+ bitField0_ = (bitField0_ & ~0x00000001);
+ status_ = 0;
+ bitField0_ = (bitField0_ & ~0x00000002);
+ value_ = com.google.protobuf.ByteString.EMPTY;
+ bitField0_ = (bitField0_ & ~0x00000004);
+ return this;
+ }
+
+ public Builder clone() {
+ return create().mergeFrom(buildPartial());
+ }
+
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_SwitchProperty_descriptor;
+ }
+
+ public net.onrc.onos.core.datastore.RCProtos.SwitchProperty getDefaultInstanceForType() {
+ return net.onrc.onos.core.datastore.RCProtos.SwitchProperty.getDefaultInstance();
+ }
+
+ public net.onrc.onos.core.datastore.RCProtos.SwitchProperty build() {
+ net.onrc.onos.core.datastore.RCProtos.SwitchProperty result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ public net.onrc.onos.core.datastore.RCProtos.SwitchProperty buildPartial() {
+ net.onrc.onos.core.datastore.RCProtos.SwitchProperty result = new net.onrc.onos.core.datastore.RCProtos.SwitchProperty(this);
+ int from_bitField0_ = bitField0_;
+ int to_bitField0_ = 0;
+ if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
+ to_bitField0_ |= 0x00000001;
+ }
+ result.dpid_ = dpid_;
+ if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
+ to_bitField0_ |= 0x00000002;
+ }
+ result.status_ = status_;
+ if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
+ to_bitField0_ |= 0x00000004;
+ }
+ result.value_ = value_;
+ result.bitField0_ = to_bitField0_;
+ onBuilt();
+ return result;
+ }
+
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof net.onrc.onos.core.datastore.RCProtos.SwitchProperty) {
+ return mergeFrom((net.onrc.onos.core.datastore.RCProtos.SwitchProperty) other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(net.onrc.onos.core.datastore.RCProtos.SwitchProperty other) {
+ if (other == net.onrc.onos.core.datastore.RCProtos.SwitchProperty.getDefaultInstance())
+ return this;
+ if (other.hasDpid()) {
+ setDpid(other.getDpid());
+ }
+ if (other.hasStatus()) {
+ setStatus(other.getStatus());
+ }
+ if (other.hasValue()) {
+ setValue(other.getValue());
+ }
+ this.mergeUnknownFields(other.getUnknownFields());
+ return this;
+ }
+
+ public final boolean isInitialized() {
+ if (!hasDpid()) {
+
+ return false;
+ }
+ if (!hasStatus()) {
+
+ return false;
+ }
+ return true;
+ }
+
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ net.onrc.onos.core.datastore.RCProtos.SwitchProperty parsedMessage = null;
+ try {
+ parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ parsedMessage = (net.onrc.onos.core.datastore.RCProtos.SwitchProperty) e.getUnfinishedMessage();
+ throw e;
+ } finally {
+ if (parsedMessage != null) {
+ mergeFrom(parsedMessage);
+ }
+ }
+ return this;
+ }
+
+ private int bitField0_;
+
+ // required int64 dpid = 1;
+ private long dpid_;
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ public boolean hasDpid() {
+ return ((bitField0_ & 0x00000001) == 0x00000001);
+ }
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ public long getDpid() {
+ return dpid_;
+ }
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ public Builder setDpid(long value) {
+ bitField0_ |= 0x00000001;
+ dpid_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ public Builder clearDpid() {
+ bitField0_ = (bitField0_ & ~0x00000001);
+ dpid_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ // required int32 status = 2;
+ private int status_;
+
+ /**
+ * <code>required int32 status = 2;</code>
+ */
+ public boolean hasStatus() {
+ return ((bitField0_ & 0x00000002) == 0x00000002);
+ }
+
+ /**
+ * <code>required int32 status = 2;</code>
+ */
+ public int getStatus() {
+ return status_;
+ }
+
+ /**
+ * <code>required int32 status = 2;</code>
+ */
+ public Builder setStatus(int value) {
+ bitField0_ |= 0x00000002;
+ status_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>required int32 status = 2;</code>
+ */
+ public Builder clearStatus() {
+ bitField0_ = (bitField0_ & ~0x00000002);
+ status_ = 0;
+ onChanged();
+ return this;
+ }
+
+ // optional bytes value = 3;
+ private com.google.protobuf.ByteString value_ = com.google.protobuf.ByteString.EMPTY;
+
+ /**
+ * <code>optional bytes value = 3;</code>
+ */
+ public boolean hasValue() {
+ return ((bitField0_ & 0x00000004) == 0x00000004);
+ }
+
+ /**
+ * <code>optional bytes value = 3;</code>
+ */
+ public com.google.protobuf.ByteString getValue() {
+ return value_;
+ }
+
+ /**
+ * <code>optional bytes value = 3;</code>
+ */
+ public Builder setValue(com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000004;
+ value_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>optional bytes value = 3;</code>
+ */
+ public Builder clearValue() {
+ bitField0_ = (bitField0_ & ~0x00000004);
+ value_ = getDefaultInstance().getValue();
+ onChanged();
+ return this;
+ }
+
+ // @@protoc_insertion_point(builder_scope:RCProtos.SwitchProperty)
+ }
+
+ static {
+ defaultInstance = new SwitchProperty(true);
+ defaultInstance.initFields();
+ }
+
+ // @@protoc_insertion_point(class_scope:RCProtos.SwitchProperty)
}
- public static com.google.protobuf.Parser<PortProperty> PARSER =
- new com.google.protobuf.AbstractParser<PortProperty>() {
- public PortProperty parsePartialFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return new PortProperty(input, extensionRegistry);
- }
- };
+ public interface PortPropertyOrBuilder
+ extends com.google.protobuf.MessageOrBuilder {
- @java.lang.Override
- public com.google.protobuf.Parser<PortProperty> getParserForType() {
- return PARSER;
+ // required int64 dpid = 1;
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ boolean hasDpid();
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ long getDpid();
+
+ // required int64 number = 2;
+
+ /**
+ * <code>required int64 number = 2;</code>
+ */
+ boolean hasNumber();
+
+ /**
+ * <code>required int64 number = 2;</code>
+ */
+ long getNumber();
+
+ // required int32 status = 3;
+
+ /**
+ * <code>required int32 status = 3;</code>
+ */
+ boolean hasStatus();
+
+ /**
+ * <code>required int32 status = 3;</code>
+ */
+ int getStatus();
+
+ // optional bytes value = 4;
+
+ /**
+ * <code>optional bytes value = 4;</code>
+ */
+ boolean hasValue();
+
+ /**
+ * <code>optional bytes value = 4;</code>
+ */
+ com.google.protobuf.ByteString getValue();
}
- private int bitField0_;
- // required int64 dpid = 1;
- public static final int DPID_FIELD_NUMBER = 1;
- private long dpid_;
- /**
- * <code>required int64 dpid = 1;</code>
- */
- public boolean hasDpid() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * <code>required int64 dpid = 1;</code>
- */
- public long getDpid() {
- return dpid_;
- }
-
- // required int64 number = 2;
- public static final int NUMBER_FIELD_NUMBER = 2;
- private long number_;
- /**
- * <code>required int64 number = 2;</code>
- */
- public boolean hasNumber() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * <code>required int64 number = 2;</code>
- */
- public long getNumber() {
- return number_;
- }
-
- // required int32 status = 3;
- public static final int STATUS_FIELD_NUMBER = 3;
- private int status_;
- /**
- * <code>required int32 status = 3;</code>
- */
- public boolean hasStatus() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
- }
- /**
- * <code>required int32 status = 3;</code>
- */
- public int getStatus() {
- return status_;
- }
-
- // optional bytes value = 4;
- public static final int VALUE_FIELD_NUMBER = 4;
- private com.google.protobuf.ByteString value_;
- /**
- * <code>optional bytes value = 4;</code>
- */
- public boolean hasValue() {
- return ((bitField0_ & 0x00000008) == 0x00000008);
- }
- /**
- * <code>optional bytes value = 4;</code>
- */
- public com.google.protobuf.ByteString getValue() {
- return value_;
- }
-
- private void initFields() {
- dpid_ = 0L;
- number_ = 0L;
- status_ = 0;
- value_ = com.google.protobuf.ByteString.EMPTY;
- }
- private byte memoizedIsInitialized = -1;
- public final boolean isInitialized() {
- byte isInitialized = memoizedIsInitialized;
- if (isInitialized != -1) return isInitialized == 1;
-
- if (!hasDpid()) {
- memoizedIsInitialized = 0;
- return false;
- }
- if (!hasNumber()) {
- memoizedIsInitialized = 0;
- return false;
- }
- if (!hasStatus()) {
- memoizedIsInitialized = 0;
- return false;
- }
- memoizedIsInitialized = 1;
- return true;
- }
-
- public void writeTo(com.google.protobuf.CodedOutputStream output)
- throws java.io.IOException {
- getSerializedSize();
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- output.writeInt64(1, dpid_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- output.writeInt64(2, number_);
- }
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
- output.writeInt32(3, status_);
- }
- if (((bitField0_ & 0x00000008) == 0x00000008)) {
- output.writeBytes(4, value_);
- }
- getUnknownFields().writeTo(output);
- }
-
- private int memoizedSerializedSize = -1;
- public int getSerializedSize() {
- int size = memoizedSerializedSize;
- if (size != -1) return size;
-
- size = 0;
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt64Size(1, dpid_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt64Size(2, number_);
- }
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt32Size(3, status_);
- }
- if (((bitField0_ & 0x00000008) == 0x00000008)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(4, value_);
- }
- size += getUnknownFields().getSerializedSize();
- memoizedSerializedSize = size;
- return size;
- }
-
- private static final long serialVersionUID = 0L;
- @java.lang.Override
- protected java.lang.Object writeReplace()
- throws java.io.ObjectStreamException {
- return super.writeReplace();
- }
-
- public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(
- com.google.protobuf.ByteString data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(
- com.google.protobuf.ByteString data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(byte[] data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(
- byte[] data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
- public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseDelimitedFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input);
- }
- public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseDelimitedFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input, extensionRegistry);
- }
- public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(
- com.google.protobuf.CodedInputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
-
- public static Builder newBuilder() { return Builder.create(); }
- public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder(net.onrc.onos.core.datastore.RCProtos.PortProperty prototype) {
- return newBuilder().mergeFrom(prototype);
- }
- public Builder toBuilder() { return newBuilder(this); }
-
- @java.lang.Override
- protected Builder newBuilderForType(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- Builder builder = new Builder(parent);
- return builder;
- }
/**
* Protobuf type {@code RCProtos.PortProperty}
*/
- public static final class Builder extends
- com.google.protobuf.GeneratedMessage.Builder<Builder>
- implements net.onrc.onos.core.datastore.RCProtos.PortPropertyOrBuilder {
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_PortProperty_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_PortProperty_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- net.onrc.onos.core.datastore.RCProtos.PortProperty.class, net.onrc.onos.core.datastore.RCProtos.PortProperty.Builder.class);
- }
-
- // Construct using net.onrc.onos.core.datastore.RCProtos.PortProperty.newBuilder()
- private Builder() {
- maybeForceBuilderInitialization();
- }
-
- private Builder(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- super(parent);
- maybeForceBuilderInitialization();
- }
- private void maybeForceBuilderInitialization() {
- if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
+ public static final class PortProperty extends
+ com.google.protobuf.GeneratedMessage
+ implements PortPropertyOrBuilder {
+ // Use PortProperty.newBuilder() to construct.
+ private PortProperty(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
+ super(builder);
+ this.unknownFields = builder.getUnknownFields();
}
- }
- private static Builder create() {
- return new Builder();
- }
- public Builder clear() {
- super.clear();
- dpid_ = 0L;
- bitField0_ = (bitField0_ & ~0x00000001);
- number_ = 0L;
- bitField0_ = (bitField0_ & ~0x00000002);
- status_ = 0;
- bitField0_ = (bitField0_ & ~0x00000004);
- value_ = com.google.protobuf.ByteString.EMPTY;
- bitField0_ = (bitField0_ & ~0x00000008);
- return this;
- }
-
- public Builder clone() {
- return create().mergeFrom(buildPartial());
- }
-
- public com.google.protobuf.Descriptors.Descriptor
- getDescriptorForType() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_PortProperty_descriptor;
- }
-
- public net.onrc.onos.core.datastore.RCProtos.PortProperty getDefaultInstanceForType() {
- return net.onrc.onos.core.datastore.RCProtos.PortProperty.getDefaultInstance();
- }
-
- public net.onrc.onos.core.datastore.RCProtos.PortProperty build() {
- net.onrc.onos.core.datastore.RCProtos.PortProperty result = buildPartial();
- if (!result.isInitialized()) {
- throw newUninitializedMessageException(result);
+ private PortProperty(boolean noInit) {
+ this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance();
}
- return result;
- }
- public net.onrc.onos.core.datastore.RCProtos.PortProperty buildPartial() {
- net.onrc.onos.core.datastore.RCProtos.PortProperty result = new net.onrc.onos.core.datastore.RCProtos.PortProperty(this);
- int from_bitField0_ = bitField0_;
- int to_bitField0_ = 0;
- if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
- to_bitField0_ |= 0x00000001;
+ private static final PortProperty defaultInstance;
+
+ public static PortProperty getDefaultInstance() {
+ return defaultInstance;
}
- result.dpid_ = dpid_;
- if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
- to_bitField0_ |= 0x00000002;
+
+ public PortProperty getDefaultInstanceForType() {
+ return defaultInstance;
}
- result.number_ = number_;
- if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
- to_bitField0_ |= 0x00000004;
- }
- result.status_ = status_;
- if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
- to_bitField0_ |= 0x00000008;
- }
- result.value_ = value_;
- result.bitField0_ = to_bitField0_;
- onBuilt();
- return result;
- }
- public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof net.onrc.onos.core.datastore.RCProtos.PortProperty) {
- return mergeFrom((net.onrc.onos.core.datastore.RCProtos.PortProperty)other);
- } else {
- super.mergeFrom(other);
- return this;
- }
- }
+ private final com.google.protobuf.UnknownFieldSet unknownFields;
- public Builder mergeFrom(net.onrc.onos.core.datastore.RCProtos.PortProperty other) {
- if (other == net.onrc.onos.core.datastore.RCProtos.PortProperty.getDefaultInstance()) return this;
- if (other.hasDpid()) {
- setDpid(other.getDpid());
- }
- if (other.hasNumber()) {
- setNumber(other.getNumber());
- }
- if (other.hasStatus()) {
- setStatus(other.getStatus());
- }
- if (other.hasValue()) {
- setValue(other.getValue());
- }
- this.mergeUnknownFields(other.getUnknownFields());
- return this;
- }
-
- public final boolean isInitialized() {
- if (!hasDpid()) {
-
- return false;
- }
- if (!hasNumber()) {
-
- return false;
- }
- if (!hasStatus()) {
-
- return false;
- }
- return true;
- }
-
- public Builder mergeFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- net.onrc.onos.core.datastore.RCProtos.PortProperty parsedMessage = null;
- try {
- parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (net.onrc.onos.core.datastore.RCProtos.PortProperty) e.getUnfinishedMessage();
- throw e;
- } finally {
- if (parsedMessage != null) {
- mergeFrom(parsedMessage);
- }
- }
- return this;
- }
- private int bitField0_;
-
- // required int64 dpid = 1;
- private long dpid_ ;
- /**
- * <code>required int64 dpid = 1;</code>
- */
- public boolean hasDpid() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * <code>required int64 dpid = 1;</code>
- */
- public long getDpid() {
- return dpid_;
- }
- /**
- * <code>required int64 dpid = 1;</code>
- */
- public Builder setDpid(long value) {
- bitField0_ |= 0x00000001;
- dpid_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>required int64 dpid = 1;</code>
- */
- public Builder clearDpid() {
- bitField0_ = (bitField0_ & ~0x00000001);
- dpid_ = 0L;
- onChanged();
- return this;
- }
-
- // required int64 number = 2;
- private long number_ ;
- /**
- * <code>required int64 number = 2;</code>
- */
- public boolean hasNumber() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * <code>required int64 number = 2;</code>
- */
- public long getNumber() {
- return number_;
- }
- /**
- * <code>required int64 number = 2;</code>
- */
- public Builder setNumber(long value) {
- bitField0_ |= 0x00000002;
- number_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>required int64 number = 2;</code>
- */
- public Builder clearNumber() {
- bitField0_ = (bitField0_ & ~0x00000002);
- number_ = 0L;
- onChanged();
- return this;
- }
-
- // required int32 status = 3;
- private int status_ ;
- /**
- * <code>required int32 status = 3;</code>
- */
- public boolean hasStatus() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
- }
- /**
- * <code>required int32 status = 3;</code>
- */
- public int getStatus() {
- return status_;
- }
- /**
- * <code>required int32 status = 3;</code>
- */
- public Builder setStatus(int value) {
- bitField0_ |= 0x00000004;
- status_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>required int32 status = 3;</code>
- */
- public Builder clearStatus() {
- bitField0_ = (bitField0_ & ~0x00000004);
- status_ = 0;
- onChanged();
- return this;
- }
-
- // optional bytes value = 4;
- private com.google.protobuf.ByteString value_ = com.google.protobuf.ByteString.EMPTY;
- /**
- * <code>optional bytes value = 4;</code>
- */
- public boolean hasValue() {
- return ((bitField0_ & 0x00000008) == 0x00000008);
- }
- /**
- * <code>optional bytes value = 4;</code>
- */
- public com.google.protobuf.ByteString getValue() {
- return value_;
- }
- /**
- * <code>optional bytes value = 4;</code>
- */
- public Builder setValue(com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000008;
- value_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>optional bytes value = 4;</code>
- */
- public Builder clearValue() {
- bitField0_ = (bitField0_ & ~0x00000008);
- value_ = getDefaultInstance().getValue();
- onChanged();
- return this;
- }
-
- // @@protoc_insertion_point(builder_scope:RCProtos.PortProperty)
- }
-
- static {
- defaultInstance = new PortProperty(true);
- defaultInstance.initFields();
- }
-
- // @@protoc_insertion_point(class_scope:RCProtos.PortProperty)
- }
-
- public interface LinkPropertyOrBuilder
- extends com.google.protobuf.MessageOrBuilder {
-
- // required bytes srcSwId = 1;
- /**
- * <code>required bytes srcSwId = 1;</code>
- */
- boolean hasSrcSwId();
- /**
- * <code>required bytes srcSwId = 1;</code>
- */
- com.google.protobuf.ByteString getSrcSwId();
-
- // required bytes srcPortId = 2;
- /**
- * <code>required bytes srcPortId = 2;</code>
- */
- boolean hasSrcPortId();
- /**
- * <code>required bytes srcPortId = 2;</code>
- */
- com.google.protobuf.ByteString getSrcPortId();
-
- // required bytes dstSwId = 3;
- /**
- * <code>required bytes dstSwId = 3;</code>
- */
- boolean hasDstSwId();
- /**
- * <code>required bytes dstSwId = 3;</code>
- */
- com.google.protobuf.ByteString getDstSwId();
-
- // required bytes dstPortId = 4;
- /**
- * <code>required bytes dstPortId = 4;</code>
- */
- boolean hasDstPortId();
- /**
- * <code>required bytes dstPortId = 4;</code>
- */
- com.google.protobuf.ByteString getDstPortId();
-
- // required int32 status = 5;
- /**
- * <code>required int32 status = 5;</code>
- */
- boolean hasStatus();
- /**
- * <code>required int32 status = 5;</code>
- */
- int getStatus();
-
- // optional bytes value = 6;
- /**
- * <code>optional bytes value = 6;</code>
- */
- boolean hasValue();
- /**
- * <code>optional bytes value = 6;</code>
- */
- com.google.protobuf.ByteString getValue();
- }
- /**
- * Protobuf type {@code RCProtos.LinkProperty}
- */
- public static final class LinkProperty extends
- com.google.protobuf.GeneratedMessage
- implements LinkPropertyOrBuilder {
- // Use LinkProperty.newBuilder() to construct.
- private LinkProperty(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
- super(builder);
- this.unknownFields = builder.getUnknownFields();
- }
- private LinkProperty(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
-
- private static final LinkProperty defaultInstance;
- public static LinkProperty getDefaultInstance() {
- return defaultInstance;
- }
-
- public LinkProperty getDefaultInstanceForType() {
- return defaultInstance;
- }
-
- private final com.google.protobuf.UnknownFieldSet unknownFields;
- @java.lang.Override
- public final com.google.protobuf.UnknownFieldSet
+ @java.lang.Override
+ public final com.google.protobuf.UnknownFieldSet
getUnknownFields() {
- return this.unknownFields;
- }
- private LinkProperty(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- initFields();
- int mutable_bitField0_ = 0;
- com.google.protobuf.UnknownFieldSet.Builder unknownFields =
- com.google.protobuf.UnknownFieldSet.newBuilder();
- try {
- boolean done = false;
- while (!done) {
- int tag = input.readTag();
- switch (tag) {
- case 0:
- done = true;
- break;
- default: {
- if (!parseUnknownField(input, unknownFields,
- extensionRegistry, tag)) {
- done = true;
- }
- break;
- }
- case 10: {
- bitField0_ |= 0x00000001;
- srcSwId_ = input.readBytes();
- break;
- }
- case 18: {
- bitField0_ |= 0x00000002;
- srcPortId_ = input.readBytes();
- break;
- }
- case 26: {
- bitField0_ |= 0x00000004;
- dstSwId_ = input.readBytes();
- break;
- }
- case 34: {
- bitField0_ |= 0x00000008;
- dstPortId_ = input.readBytes();
- break;
- }
- case 40: {
- bitField0_ |= 0x00000010;
- status_ = input.readInt32();
- break;
- }
- case 50: {
- bitField0_ |= 0x00000020;
- value_ = input.readBytes();
- break;
- }
- }
+ return this.unknownFields;
}
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- throw e.setUnfinishedMessage(this);
- } catch (java.io.IOException e) {
- throw new com.google.protobuf.InvalidProtocolBufferException(
- e.getMessage()).setUnfinishedMessage(this);
- } finally {
- this.unknownFields = unknownFields.build();
- makeExtensionsImmutable();
- }
- }
- public static final com.google.protobuf.Descriptors.Descriptor
+
+ private PortProperty(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ initFields();
+ int mutable_bitField0_ = 0;
+ com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+ com.google.protobuf.UnknownFieldSet.newBuilder();
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ default: {
+ if (!parseUnknownField(input, unknownFields,
+ extensionRegistry, tag)) {
+ done = true;
+ }
+ break;
+ }
+ case 8: {
+ bitField0_ |= 0x00000001;
+ dpid_ = input.readInt64();
+ break;
+ }
+ case 16: {
+ bitField0_ |= 0x00000002;
+ number_ = input.readInt64();
+ break;
+ }
+ case 24: {
+ bitField0_ |= 0x00000004;
+ status_ = input.readInt32();
+ break;
+ }
+ case 34: {
+ bitField0_ |= 0x00000008;
+ value_ = input.readBytes();
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.setUnfinishedMessage(this);
+ } catch (java.io.IOException e) {
+ throw new com.google.protobuf.InvalidProtocolBufferException(
+ e.getMessage()).setUnfinishedMessage(this);
+ } finally {
+ this.unknownFields = unknownFields.build();
+ makeExtensionsImmutable();
+ }
+ }
+
+ public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_LinkProperty_descriptor;
- }
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_PortProperty_descriptor;
+ }
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_LinkProperty_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- net.onrc.onos.core.datastore.RCProtos.LinkProperty.class, net.onrc.onos.core.datastore.RCProtos.LinkProperty.Builder.class);
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_PortProperty_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ net.onrc.onos.core.datastore.RCProtos.PortProperty.class, net.onrc.onos.core.datastore.RCProtos.PortProperty.Builder.class);
+ }
+
+ public static com.google.protobuf.Parser<PortProperty> PARSER =
+ new com.google.protobuf.AbstractParser<PortProperty>() {
+ public PortProperty parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return new PortProperty(input, extensionRegistry);
+ }
+ };
+
+ @java.lang.Override
+ public com.google.protobuf.Parser<PortProperty> getParserForType() {
+ return PARSER;
+ }
+
+ private int bitField0_;
+ // required int64 dpid = 1;
+ public static final int DPID_FIELD_NUMBER = 1;
+ private long dpid_;
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ public boolean hasDpid() {
+ return ((bitField0_ & 0x00000001) == 0x00000001);
+ }
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ public long getDpid() {
+ return dpid_;
+ }
+
+ // required int64 number = 2;
+ public static final int NUMBER_FIELD_NUMBER = 2;
+ private long number_;
+
+ /**
+ * <code>required int64 number = 2;</code>
+ */
+ public boolean hasNumber() {
+ return ((bitField0_ & 0x00000002) == 0x00000002);
+ }
+
+ /**
+ * <code>required int64 number = 2;</code>
+ */
+ public long getNumber() {
+ return number_;
+ }
+
+ // required int32 status = 3;
+ public static final int STATUS_FIELD_NUMBER = 3;
+ private int status_;
+
+ /**
+ * <code>required int32 status = 3;</code>
+ */
+ public boolean hasStatus() {
+ return ((bitField0_ & 0x00000004) == 0x00000004);
+ }
+
+ /**
+ * <code>required int32 status = 3;</code>
+ */
+ public int getStatus() {
+ return status_;
+ }
+
+ // optional bytes value = 4;
+ public static final int VALUE_FIELD_NUMBER = 4;
+ private com.google.protobuf.ByteString value_;
+
+ /**
+ * <code>optional bytes value = 4;</code>
+ */
+ public boolean hasValue() {
+ return ((bitField0_ & 0x00000008) == 0x00000008);
+ }
+
+ /**
+ * <code>optional bytes value = 4;</code>
+ */
+ public com.google.protobuf.ByteString getValue() {
+ return value_;
+ }
+
+ private void initFields() {
+ dpid_ = 0L;
+ number_ = 0L;
+ status_ = 0;
+ value_ = com.google.protobuf.ByteString.EMPTY;
+ }
+
+ private byte memoizedIsInitialized = -1;
+
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized != -1) return isInitialized == 1;
+
+ if (!hasDpid()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ if (!hasNumber()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ if (!hasStatus()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ getSerializedSize();
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ output.writeInt64(1, dpid_);
+ }
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ output.writeInt64(2, number_);
+ }
+ if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ output.writeInt32(3, status_);
+ }
+ if (((bitField0_ & 0x00000008) == 0x00000008)) {
+ output.writeBytes(4, value_);
+ }
+ getUnknownFields().writeTo(output);
+ }
+
+ private int memoizedSerializedSize = -1;
+
+ public int getSerializedSize() {
+ int size = memoizedSerializedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt64Size(1, dpid_);
+ }
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt64Size(2, number_);
+ }
+ if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(3, status_);
+ }
+ if (((bitField0_ & 0x00000008) == 0x00000008)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeBytesSize(4, value_);
+ }
+ size += getUnknownFields().getSerializedSize();
+ memoizedSerializedSize = size;
+ return size;
+ }
+
+ private static final long serialVersionUID = 0L;
+
+ @java.lang.Override
+ protected java.lang.Object writeReplace()
+ throws java.io.ObjectStreamException {
+ return super.writeReplace();
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input, extensionRegistry);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.PortProperty parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public static Builder newBuilder() {
+ return Builder.create();
+ }
+
+ public Builder newBuilderForType() {
+ return newBuilder();
+ }
+
+ public static Builder newBuilder(net.onrc.onos.core.datastore.RCProtos.PortProperty prototype) {
+ return newBuilder().mergeFrom(prototype);
+ }
+
+ public Builder toBuilder() {
+ return newBuilder(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+
+ /**
+ * Protobuf type {@code RCProtos.PortProperty}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessage.Builder<Builder>
+ implements net.onrc.onos.core.datastore.RCProtos.PortPropertyOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_PortProperty_descriptor;
+ }
+
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_PortProperty_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ net.onrc.onos.core.datastore.RCProtos.PortProperty.class, net.onrc.onos.core.datastore.RCProtos.PortProperty.Builder.class);
+ }
+
+ // Construct using net.onrc.onos.core.datastore.RCProtos.PortProperty.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
+
+ private Builder(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
+ }
+ }
+
+ private static Builder create() {
+ return new Builder();
+ }
+
+ public Builder clear() {
+ super.clear();
+ dpid_ = 0L;
+ bitField0_ = (bitField0_ & ~0x00000001);
+ number_ = 0L;
+ bitField0_ = (bitField0_ & ~0x00000002);
+ status_ = 0;
+ bitField0_ = (bitField0_ & ~0x00000004);
+ value_ = com.google.protobuf.ByteString.EMPTY;
+ bitField0_ = (bitField0_ & ~0x00000008);
+ return this;
+ }
+
+ public Builder clone() {
+ return create().mergeFrom(buildPartial());
+ }
+
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_PortProperty_descriptor;
+ }
+
+ public net.onrc.onos.core.datastore.RCProtos.PortProperty getDefaultInstanceForType() {
+ return net.onrc.onos.core.datastore.RCProtos.PortProperty.getDefaultInstance();
+ }
+
+ public net.onrc.onos.core.datastore.RCProtos.PortProperty build() {
+ net.onrc.onos.core.datastore.RCProtos.PortProperty result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ public net.onrc.onos.core.datastore.RCProtos.PortProperty buildPartial() {
+ net.onrc.onos.core.datastore.RCProtos.PortProperty result = new net.onrc.onos.core.datastore.RCProtos.PortProperty(this);
+ int from_bitField0_ = bitField0_;
+ int to_bitField0_ = 0;
+ if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
+ to_bitField0_ |= 0x00000001;
+ }
+ result.dpid_ = dpid_;
+ if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
+ to_bitField0_ |= 0x00000002;
+ }
+ result.number_ = number_;
+ if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
+ to_bitField0_ |= 0x00000004;
+ }
+ result.status_ = status_;
+ if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
+ to_bitField0_ |= 0x00000008;
+ }
+ result.value_ = value_;
+ result.bitField0_ = to_bitField0_;
+ onBuilt();
+ return result;
+ }
+
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof net.onrc.onos.core.datastore.RCProtos.PortProperty) {
+ return mergeFrom((net.onrc.onos.core.datastore.RCProtos.PortProperty) other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(net.onrc.onos.core.datastore.RCProtos.PortProperty other) {
+ if (other == net.onrc.onos.core.datastore.RCProtos.PortProperty.getDefaultInstance())
+ return this;
+ if (other.hasDpid()) {
+ setDpid(other.getDpid());
+ }
+ if (other.hasNumber()) {
+ setNumber(other.getNumber());
+ }
+ if (other.hasStatus()) {
+ setStatus(other.getStatus());
+ }
+ if (other.hasValue()) {
+ setValue(other.getValue());
+ }
+ this.mergeUnknownFields(other.getUnknownFields());
+ return this;
+ }
+
+ public final boolean isInitialized() {
+ if (!hasDpid()) {
+
+ return false;
+ }
+ if (!hasNumber()) {
+
+ return false;
+ }
+ if (!hasStatus()) {
+
+ return false;
+ }
+ return true;
+ }
+
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ net.onrc.onos.core.datastore.RCProtos.PortProperty parsedMessage = null;
+ try {
+ parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ parsedMessage = (net.onrc.onos.core.datastore.RCProtos.PortProperty) e.getUnfinishedMessage();
+ throw e;
+ } finally {
+ if (parsedMessage != null) {
+ mergeFrom(parsedMessage);
+ }
+ }
+ return this;
+ }
+
+ private int bitField0_;
+
+ // required int64 dpid = 1;
+ private long dpid_;
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ public boolean hasDpid() {
+ return ((bitField0_ & 0x00000001) == 0x00000001);
+ }
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ public long getDpid() {
+ return dpid_;
+ }
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ public Builder setDpid(long value) {
+ bitField0_ |= 0x00000001;
+ dpid_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>required int64 dpid = 1;</code>
+ */
+ public Builder clearDpid() {
+ bitField0_ = (bitField0_ & ~0x00000001);
+ dpid_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ // required int64 number = 2;
+ private long number_;
+
+ /**
+ * <code>required int64 number = 2;</code>
+ */
+ public boolean hasNumber() {
+ return ((bitField0_ & 0x00000002) == 0x00000002);
+ }
+
+ /**
+ * <code>required int64 number = 2;</code>
+ */
+ public long getNumber() {
+ return number_;
+ }
+
+ /**
+ * <code>required int64 number = 2;</code>
+ */
+ public Builder setNumber(long value) {
+ bitField0_ |= 0x00000002;
+ number_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>required int64 number = 2;</code>
+ */
+ public Builder clearNumber() {
+ bitField0_ = (bitField0_ & ~0x00000002);
+ number_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ // required int32 status = 3;
+ private int status_;
+
+ /**
+ * <code>required int32 status = 3;</code>
+ */
+ public boolean hasStatus() {
+ return ((bitField0_ & 0x00000004) == 0x00000004);
+ }
+
+ /**
+ * <code>required int32 status = 3;</code>
+ */
+ public int getStatus() {
+ return status_;
+ }
+
+ /**
+ * <code>required int32 status = 3;</code>
+ */
+ public Builder setStatus(int value) {
+ bitField0_ |= 0x00000004;
+ status_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>required int32 status = 3;</code>
+ */
+ public Builder clearStatus() {
+ bitField0_ = (bitField0_ & ~0x00000004);
+ status_ = 0;
+ onChanged();
+ return this;
+ }
+
+ // optional bytes value = 4;
+ private com.google.protobuf.ByteString value_ = com.google.protobuf.ByteString.EMPTY;
+
+ /**
+ * <code>optional bytes value = 4;</code>
+ */
+ public boolean hasValue() {
+ return ((bitField0_ & 0x00000008) == 0x00000008);
+ }
+
+ /**
+ * <code>optional bytes value = 4;</code>
+ */
+ public com.google.protobuf.ByteString getValue() {
+ return value_;
+ }
+
+ /**
+ * <code>optional bytes value = 4;</code>
+ */
+ public Builder setValue(com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000008;
+ value_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>optional bytes value = 4;</code>
+ */
+ public Builder clearValue() {
+ bitField0_ = (bitField0_ & ~0x00000008);
+ value_ = getDefaultInstance().getValue();
+ onChanged();
+ return this;
+ }
+
+ // @@protoc_insertion_point(builder_scope:RCProtos.PortProperty)
+ }
+
+ static {
+ defaultInstance = new PortProperty(true);
+ defaultInstance.initFields();
+ }
+
+ // @@protoc_insertion_point(class_scope:RCProtos.PortProperty)
}
- public static com.google.protobuf.Parser<LinkProperty> PARSER =
- new com.google.protobuf.AbstractParser<LinkProperty>() {
- public LinkProperty parsePartialFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return new LinkProperty(input, extensionRegistry);
- }
- };
+ public interface LinkPropertyOrBuilder
+ extends com.google.protobuf.MessageOrBuilder {
- @java.lang.Override
- public com.google.protobuf.Parser<LinkProperty> getParserForType() {
- return PARSER;
+ // required bytes srcSwId = 1;
+
+ /**
+ * <code>required bytes srcSwId = 1;</code>
+ */
+ boolean hasSrcSwId();
+
+ /**
+ * <code>required bytes srcSwId = 1;</code>
+ */
+ com.google.protobuf.ByteString getSrcSwId();
+
+ // required bytes srcPortId = 2;
+
+ /**
+ * <code>required bytes srcPortId = 2;</code>
+ */
+ boolean hasSrcPortId();
+
+ /**
+ * <code>required bytes srcPortId = 2;</code>
+ */
+ com.google.protobuf.ByteString getSrcPortId();
+
+ // required bytes dstSwId = 3;
+
+ /**
+ * <code>required bytes dstSwId = 3;</code>
+ */
+ boolean hasDstSwId();
+
+ /**
+ * <code>required bytes dstSwId = 3;</code>
+ */
+ com.google.protobuf.ByteString getDstSwId();
+
+ // required bytes dstPortId = 4;
+
+ /**
+ * <code>required bytes dstPortId = 4;</code>
+ */
+ boolean hasDstPortId();
+
+ /**
+ * <code>required bytes dstPortId = 4;</code>
+ */
+ com.google.protobuf.ByteString getDstPortId();
+
+ // required int32 status = 5;
+
+ /**
+ * <code>required int32 status = 5;</code>
+ */
+ boolean hasStatus();
+
+ /**
+ * <code>required int32 status = 5;</code>
+ */
+ int getStatus();
+
+ // optional bytes value = 6;
+
+ /**
+ * <code>optional bytes value = 6;</code>
+ */
+ boolean hasValue();
+
+ /**
+ * <code>optional bytes value = 6;</code>
+ */
+ com.google.protobuf.ByteString getValue();
}
- private int bitField0_;
- // required bytes srcSwId = 1;
- public static final int SRCSWID_FIELD_NUMBER = 1;
- private com.google.protobuf.ByteString srcSwId_;
- /**
- * <code>required bytes srcSwId = 1;</code>
- */
- public boolean hasSrcSwId() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * <code>required bytes srcSwId = 1;</code>
- */
- public com.google.protobuf.ByteString getSrcSwId() {
- return srcSwId_;
- }
-
- // required bytes srcPortId = 2;
- public static final int SRCPORTID_FIELD_NUMBER = 2;
- private com.google.protobuf.ByteString srcPortId_;
- /**
- * <code>required bytes srcPortId = 2;</code>
- */
- public boolean hasSrcPortId() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * <code>required bytes srcPortId = 2;</code>
- */
- public com.google.protobuf.ByteString getSrcPortId() {
- return srcPortId_;
- }
-
- // required bytes dstSwId = 3;
- public static final int DSTSWID_FIELD_NUMBER = 3;
- private com.google.protobuf.ByteString dstSwId_;
- /**
- * <code>required bytes dstSwId = 3;</code>
- */
- public boolean hasDstSwId() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
- }
- /**
- * <code>required bytes dstSwId = 3;</code>
- */
- public com.google.protobuf.ByteString getDstSwId() {
- return dstSwId_;
- }
-
- // required bytes dstPortId = 4;
- public static final int DSTPORTID_FIELD_NUMBER = 4;
- private com.google.protobuf.ByteString dstPortId_;
- /**
- * <code>required bytes dstPortId = 4;</code>
- */
- public boolean hasDstPortId() {
- return ((bitField0_ & 0x00000008) == 0x00000008);
- }
- /**
- * <code>required bytes dstPortId = 4;</code>
- */
- public com.google.protobuf.ByteString getDstPortId() {
- return dstPortId_;
- }
-
- // required int32 status = 5;
- public static final int STATUS_FIELD_NUMBER = 5;
- private int status_;
- /**
- * <code>required int32 status = 5;</code>
- */
- public boolean hasStatus() {
- return ((bitField0_ & 0x00000010) == 0x00000010);
- }
- /**
- * <code>required int32 status = 5;</code>
- */
- public int getStatus() {
- return status_;
- }
-
- // optional bytes value = 6;
- public static final int VALUE_FIELD_NUMBER = 6;
- private com.google.protobuf.ByteString value_;
- /**
- * <code>optional bytes value = 6;</code>
- */
- public boolean hasValue() {
- return ((bitField0_ & 0x00000020) == 0x00000020);
- }
- /**
- * <code>optional bytes value = 6;</code>
- */
- public com.google.protobuf.ByteString getValue() {
- return value_;
- }
-
- private void initFields() {
- srcSwId_ = com.google.protobuf.ByteString.EMPTY;
- srcPortId_ = com.google.protobuf.ByteString.EMPTY;
- dstSwId_ = com.google.protobuf.ByteString.EMPTY;
- dstPortId_ = com.google.protobuf.ByteString.EMPTY;
- status_ = 0;
- value_ = com.google.protobuf.ByteString.EMPTY;
- }
- private byte memoizedIsInitialized = -1;
- public final boolean isInitialized() {
- byte isInitialized = memoizedIsInitialized;
- if (isInitialized != -1) return isInitialized == 1;
-
- if (!hasSrcSwId()) {
- memoizedIsInitialized = 0;
- return false;
- }
- if (!hasSrcPortId()) {
- memoizedIsInitialized = 0;
- return false;
- }
- if (!hasDstSwId()) {
- memoizedIsInitialized = 0;
- return false;
- }
- if (!hasDstPortId()) {
- memoizedIsInitialized = 0;
- return false;
- }
- if (!hasStatus()) {
- memoizedIsInitialized = 0;
- return false;
- }
- memoizedIsInitialized = 1;
- return true;
- }
-
- public void writeTo(com.google.protobuf.CodedOutputStream output)
- throws java.io.IOException {
- getSerializedSize();
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- output.writeBytes(1, srcSwId_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- output.writeBytes(2, srcPortId_);
- }
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
- output.writeBytes(3, dstSwId_);
- }
- if (((bitField0_ & 0x00000008) == 0x00000008)) {
- output.writeBytes(4, dstPortId_);
- }
- if (((bitField0_ & 0x00000010) == 0x00000010)) {
- output.writeInt32(5, status_);
- }
- if (((bitField0_ & 0x00000020) == 0x00000020)) {
- output.writeBytes(6, value_);
- }
- getUnknownFields().writeTo(output);
- }
-
- private int memoizedSerializedSize = -1;
- public int getSerializedSize() {
- int size = memoizedSerializedSize;
- if (size != -1) return size;
-
- size = 0;
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(1, srcSwId_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(2, srcPortId_);
- }
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(3, dstSwId_);
- }
- if (((bitField0_ & 0x00000008) == 0x00000008)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(4, dstPortId_);
- }
- if (((bitField0_ & 0x00000010) == 0x00000010)) {
- size += com.google.protobuf.CodedOutputStream
- .computeInt32Size(5, status_);
- }
- if (((bitField0_ & 0x00000020) == 0x00000020)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(6, value_);
- }
- size += getUnknownFields().getSerializedSize();
- memoizedSerializedSize = size;
- return size;
- }
-
- private static final long serialVersionUID = 0L;
- @java.lang.Override
- protected java.lang.Object writeReplace()
- throws java.io.ObjectStreamException {
- return super.writeReplace();
- }
-
- public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(
- com.google.protobuf.ByteString data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(
- com.google.protobuf.ByteString data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(byte[] data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(
- byte[] data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
- public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseDelimitedFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input);
- }
- public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseDelimitedFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input, extensionRegistry);
- }
- public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(
- com.google.protobuf.CodedInputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
-
- public static Builder newBuilder() { return Builder.create(); }
- public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder(net.onrc.onos.core.datastore.RCProtos.LinkProperty prototype) {
- return newBuilder().mergeFrom(prototype);
- }
- public Builder toBuilder() { return newBuilder(this); }
-
- @java.lang.Override
- protected Builder newBuilderForType(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- Builder builder = new Builder(parent);
- return builder;
- }
/**
* Protobuf type {@code RCProtos.LinkProperty}
*/
- public static final class Builder extends
- com.google.protobuf.GeneratedMessage.Builder<Builder>
- implements net.onrc.onos.core.datastore.RCProtos.LinkPropertyOrBuilder {
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_LinkProperty_descriptor;
- }
+ public static final class LinkProperty extends
+ com.google.protobuf.GeneratedMessage
+ implements LinkPropertyOrBuilder {
+ // Use LinkProperty.newBuilder() to construct.
+ private LinkProperty(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
+ super(builder);
+ this.unknownFields = builder.getUnknownFields();
+ }
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_LinkProperty_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- net.onrc.onos.core.datastore.RCProtos.LinkProperty.class, net.onrc.onos.core.datastore.RCProtos.LinkProperty.Builder.class);
- }
+ private LinkProperty(boolean noInit) {
+ this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance();
+ }
- // Construct using net.onrc.onos.core.datastore.RCProtos.LinkProperty.newBuilder()
- private Builder() {
- maybeForceBuilderInitialization();
- }
+ private static final LinkProperty defaultInstance;
- private Builder(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- super(parent);
- maybeForceBuilderInitialization();
- }
- private void maybeForceBuilderInitialization() {
- if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
+ public static LinkProperty getDefaultInstance() {
+ return defaultInstance;
}
- }
- private static Builder create() {
- return new Builder();
- }
- public Builder clear() {
- super.clear();
- srcSwId_ = com.google.protobuf.ByteString.EMPTY;
- bitField0_ = (bitField0_ & ~0x00000001);
- srcPortId_ = com.google.protobuf.ByteString.EMPTY;
- bitField0_ = (bitField0_ & ~0x00000002);
- dstSwId_ = com.google.protobuf.ByteString.EMPTY;
- bitField0_ = (bitField0_ & ~0x00000004);
- dstPortId_ = com.google.protobuf.ByteString.EMPTY;
- bitField0_ = (bitField0_ & ~0x00000008);
- status_ = 0;
- bitField0_ = (bitField0_ & ~0x00000010);
- value_ = com.google.protobuf.ByteString.EMPTY;
- bitField0_ = (bitField0_ & ~0x00000020);
- return this;
- }
+ public LinkProperty getDefaultInstanceForType() {
+ return defaultInstance;
+ }
- public Builder clone() {
- return create().mergeFrom(buildPartial());
- }
+ private final com.google.protobuf.UnknownFieldSet unknownFields;
- public com.google.protobuf.Descriptors.Descriptor
- getDescriptorForType() {
- return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_LinkProperty_descriptor;
- }
+ @java.lang.Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return this.unknownFields;
+ }
- public net.onrc.onos.core.datastore.RCProtos.LinkProperty getDefaultInstanceForType() {
- return net.onrc.onos.core.datastore.RCProtos.LinkProperty.getDefaultInstance();
- }
+ private LinkProperty(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ initFields();
+ int mutable_bitField0_ = 0;
+ com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+ com.google.protobuf.UnknownFieldSet.newBuilder();
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ default: {
+ if (!parseUnknownField(input, unknownFields,
+ extensionRegistry, tag)) {
+ done = true;
+ }
+ break;
+ }
+ case 10: {
+ bitField0_ |= 0x00000001;
+ srcSwId_ = input.readBytes();
+ break;
+ }
+ case 18: {
+ bitField0_ |= 0x00000002;
+ srcPortId_ = input.readBytes();
+ break;
+ }
+ case 26: {
+ bitField0_ |= 0x00000004;
+ dstSwId_ = input.readBytes();
+ break;
+ }
+ case 34: {
+ bitField0_ |= 0x00000008;
+ dstPortId_ = input.readBytes();
+ break;
+ }
+ case 40: {
+ bitField0_ |= 0x00000010;
+ status_ = input.readInt32();
+ break;
+ }
+ case 50: {
+ bitField0_ |= 0x00000020;
+ value_ = input.readBytes();
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.setUnfinishedMessage(this);
+ } catch (java.io.IOException e) {
+ throw new com.google.protobuf.InvalidProtocolBufferException(
+ e.getMessage()).setUnfinishedMessage(this);
+ } finally {
+ this.unknownFields = unknownFields.build();
+ makeExtensionsImmutable();
+ }
+ }
- public net.onrc.onos.core.datastore.RCProtos.LinkProperty build() {
- net.onrc.onos.core.datastore.RCProtos.LinkProperty result = buildPartial();
- if (!result.isInitialized()) {
- throw newUninitializedMessageException(result);
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_LinkProperty_descriptor;
}
- return result;
- }
- public net.onrc.onos.core.datastore.RCProtos.LinkProperty buildPartial() {
- net.onrc.onos.core.datastore.RCProtos.LinkProperty result = new net.onrc.onos.core.datastore.RCProtos.LinkProperty(this);
- int from_bitField0_ = bitField0_;
- int to_bitField0_ = 0;
- if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
- to_bitField0_ |= 0x00000001;
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_LinkProperty_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ net.onrc.onos.core.datastore.RCProtos.LinkProperty.class, net.onrc.onos.core.datastore.RCProtos.LinkProperty.Builder.class);
}
- result.srcSwId_ = srcSwId_;
- if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
- to_bitField0_ |= 0x00000002;
- }
- result.srcPortId_ = srcPortId_;
- if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
- to_bitField0_ |= 0x00000004;
- }
- result.dstSwId_ = dstSwId_;
- if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
- to_bitField0_ |= 0x00000008;
- }
- result.dstPortId_ = dstPortId_;
- if (((from_bitField0_ & 0x00000010) == 0x00000010)) {
- to_bitField0_ |= 0x00000010;
- }
- result.status_ = status_;
- if (((from_bitField0_ & 0x00000020) == 0x00000020)) {
- to_bitField0_ |= 0x00000020;
- }
- result.value_ = value_;
- result.bitField0_ = to_bitField0_;
- onBuilt();
- return result;
- }
- public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof net.onrc.onos.core.datastore.RCProtos.LinkProperty) {
- return mergeFrom((net.onrc.onos.core.datastore.RCProtos.LinkProperty)other);
- } else {
- super.mergeFrom(other);
- return this;
- }
- }
+ public static com.google.protobuf.Parser<LinkProperty> PARSER =
+ new com.google.protobuf.AbstractParser<LinkProperty>() {
+ public LinkProperty parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return new LinkProperty(input, extensionRegistry);
+ }
+ };
- public Builder mergeFrom(net.onrc.onos.core.datastore.RCProtos.LinkProperty other) {
- if (other == net.onrc.onos.core.datastore.RCProtos.LinkProperty.getDefaultInstance()) return this;
- if (other.hasSrcSwId()) {
- setSrcSwId(other.getSrcSwId());
+ @java.lang.Override
+ public com.google.protobuf.Parser<LinkProperty> getParserForType() {
+ return PARSER;
}
- if (other.hasSrcPortId()) {
- setSrcPortId(other.getSrcPortId());
- }
- if (other.hasDstSwId()) {
- setDstSwId(other.getDstSwId());
- }
- if (other.hasDstPortId()) {
- setDstPortId(other.getDstPortId());
- }
- if (other.hasStatus()) {
- setStatus(other.getStatus());
- }
- if (other.hasValue()) {
- setValue(other.getValue());
- }
- this.mergeUnknownFields(other.getUnknownFields());
- return this;
- }
- public final boolean isInitialized() {
- if (!hasSrcSwId()) {
-
- return false;
+ private int bitField0_;
+ // required bytes srcSwId = 1;
+ public static final int SRCSWID_FIELD_NUMBER = 1;
+ private com.google.protobuf.ByteString srcSwId_;
+
+ /**
+ * <code>required bytes srcSwId = 1;</code>
+ */
+ public boolean hasSrcSwId() {
+ return ((bitField0_ & 0x00000001) == 0x00000001);
}
- if (!hasSrcPortId()) {
-
- return false;
+
+ /**
+ * <code>required bytes srcSwId = 1;</code>
+ */
+ public com.google.protobuf.ByteString getSrcSwId() {
+ return srcSwId_;
}
- if (!hasDstSwId()) {
-
- return false;
+
+ // required bytes srcPortId = 2;
+ public static final int SRCPORTID_FIELD_NUMBER = 2;
+ private com.google.protobuf.ByteString srcPortId_;
+
+ /**
+ * <code>required bytes srcPortId = 2;</code>
+ */
+ public boolean hasSrcPortId() {
+ return ((bitField0_ & 0x00000002) == 0x00000002);
}
- if (!hasDstPortId()) {
-
- return false;
+
+ /**
+ * <code>required bytes srcPortId = 2;</code>
+ */
+ public com.google.protobuf.ByteString getSrcPortId() {
+ return srcPortId_;
}
- if (!hasStatus()) {
-
- return false;
+
+ // required bytes dstSwId = 3;
+ public static final int DSTSWID_FIELD_NUMBER = 3;
+ private com.google.protobuf.ByteString dstSwId_;
+
+ /**
+ * <code>required bytes dstSwId = 3;</code>
+ */
+ public boolean hasDstSwId() {
+ return ((bitField0_ & 0x00000004) == 0x00000004);
}
- return true;
- }
- public Builder mergeFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- net.onrc.onos.core.datastore.RCProtos.LinkProperty parsedMessage = null;
- try {
- parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (net.onrc.onos.core.datastore.RCProtos.LinkProperty) e.getUnfinishedMessage();
- throw e;
- } finally {
- if (parsedMessage != null) {
- mergeFrom(parsedMessage);
- }
+ /**
+ * <code>required bytes dstSwId = 3;</code>
+ */
+ public com.google.protobuf.ByteString getDstSwId() {
+ return dstSwId_;
}
- return this;
- }
- private int bitField0_;
- // required bytes srcSwId = 1;
- private com.google.protobuf.ByteString srcSwId_ = com.google.protobuf.ByteString.EMPTY;
- /**
- * <code>required bytes srcSwId = 1;</code>
- */
- public boolean hasSrcSwId() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * <code>required bytes srcSwId = 1;</code>
- */
- public com.google.protobuf.ByteString getSrcSwId() {
- return srcSwId_;
- }
- /**
- * <code>required bytes srcSwId = 1;</code>
- */
- public Builder setSrcSwId(com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000001;
- srcSwId_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>required bytes srcSwId = 1;</code>
- */
- public Builder clearSrcSwId() {
- bitField0_ = (bitField0_ & ~0x00000001);
- srcSwId_ = getDefaultInstance().getSrcSwId();
- onChanged();
- return this;
- }
+ // required bytes dstPortId = 4;
+ public static final int DSTPORTID_FIELD_NUMBER = 4;
+ private com.google.protobuf.ByteString dstPortId_;
- // required bytes srcPortId = 2;
- private com.google.protobuf.ByteString srcPortId_ = com.google.protobuf.ByteString.EMPTY;
- /**
- * <code>required bytes srcPortId = 2;</code>
- */
- public boolean hasSrcPortId() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * <code>required bytes srcPortId = 2;</code>
- */
- public com.google.protobuf.ByteString getSrcPortId() {
- return srcPortId_;
- }
- /**
- * <code>required bytes srcPortId = 2;</code>
- */
- public Builder setSrcPortId(com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000002;
- srcPortId_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>required bytes srcPortId = 2;</code>
- */
- public Builder clearSrcPortId() {
- bitField0_ = (bitField0_ & ~0x00000002);
- srcPortId_ = getDefaultInstance().getSrcPortId();
- onChanged();
- return this;
- }
+ /**
+ * <code>required bytes dstPortId = 4;</code>
+ */
+ public boolean hasDstPortId() {
+ return ((bitField0_ & 0x00000008) == 0x00000008);
+ }
- // required bytes dstSwId = 3;
- private com.google.protobuf.ByteString dstSwId_ = com.google.protobuf.ByteString.EMPTY;
- /**
- * <code>required bytes dstSwId = 3;</code>
- */
- public boolean hasDstSwId() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
- }
- /**
- * <code>required bytes dstSwId = 3;</code>
- */
- public com.google.protobuf.ByteString getDstSwId() {
- return dstSwId_;
- }
- /**
- * <code>required bytes dstSwId = 3;</code>
- */
- public Builder setDstSwId(com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000004;
- dstSwId_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>required bytes dstSwId = 3;</code>
- */
- public Builder clearDstSwId() {
- bitField0_ = (bitField0_ & ~0x00000004);
- dstSwId_ = getDefaultInstance().getDstSwId();
- onChanged();
- return this;
- }
+ /**
+ * <code>required bytes dstPortId = 4;</code>
+ */
+ public com.google.protobuf.ByteString getDstPortId() {
+ return dstPortId_;
+ }
- // required bytes dstPortId = 4;
- private com.google.protobuf.ByteString dstPortId_ = com.google.protobuf.ByteString.EMPTY;
- /**
- * <code>required bytes dstPortId = 4;</code>
- */
- public boolean hasDstPortId() {
- return ((bitField0_ & 0x00000008) == 0x00000008);
- }
- /**
- * <code>required bytes dstPortId = 4;</code>
- */
- public com.google.protobuf.ByteString getDstPortId() {
- return dstPortId_;
- }
- /**
- * <code>required bytes dstPortId = 4;</code>
- */
- public Builder setDstPortId(com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000008;
- dstPortId_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>required bytes dstPortId = 4;</code>
- */
- public Builder clearDstPortId() {
- bitField0_ = (bitField0_ & ~0x00000008);
- dstPortId_ = getDefaultInstance().getDstPortId();
- onChanged();
- return this;
- }
+ // required int32 status = 5;
+ public static final int STATUS_FIELD_NUMBER = 5;
+ private int status_;
- // required int32 status = 5;
- private int status_ ;
- /**
- * <code>required int32 status = 5;</code>
- */
- public boolean hasStatus() {
- return ((bitField0_ & 0x00000010) == 0x00000010);
- }
- /**
- * <code>required int32 status = 5;</code>
- */
- public int getStatus() {
- return status_;
- }
- /**
- * <code>required int32 status = 5;</code>
- */
- public Builder setStatus(int value) {
- bitField0_ |= 0x00000010;
- status_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>required int32 status = 5;</code>
- */
- public Builder clearStatus() {
- bitField0_ = (bitField0_ & ~0x00000010);
- status_ = 0;
- onChanged();
- return this;
- }
+ /**
+ * <code>required int32 status = 5;</code>
+ */
+ public boolean hasStatus() {
+ return ((bitField0_ & 0x00000010) == 0x00000010);
+ }
- // optional bytes value = 6;
- private com.google.protobuf.ByteString value_ = com.google.protobuf.ByteString.EMPTY;
- /**
- * <code>optional bytes value = 6;</code>
- */
- public boolean hasValue() {
- return ((bitField0_ & 0x00000020) == 0x00000020);
- }
- /**
- * <code>optional bytes value = 6;</code>
- */
- public com.google.protobuf.ByteString getValue() {
- return value_;
- }
- /**
- * <code>optional bytes value = 6;</code>
- */
- public Builder setValue(com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000020;
- value_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>optional bytes value = 6;</code>
- */
- public Builder clearValue() {
- bitField0_ = (bitField0_ & ~0x00000020);
- value_ = getDefaultInstance().getValue();
- onChanged();
- return this;
- }
+ /**
+ * <code>required int32 status = 5;</code>
+ */
+ public int getStatus() {
+ return status_;
+ }
- // @@protoc_insertion_point(builder_scope:RCProtos.LinkProperty)
+ // optional bytes value = 6;
+ public static final int VALUE_FIELD_NUMBER = 6;
+ private com.google.protobuf.ByteString value_;
+
+ /**
+ * <code>optional bytes value = 6;</code>
+ */
+ public boolean hasValue() {
+ return ((bitField0_ & 0x00000020) == 0x00000020);
+ }
+
+ /**
+ * <code>optional bytes value = 6;</code>
+ */
+ public com.google.protobuf.ByteString getValue() {
+ return value_;
+ }
+
+ private void initFields() {
+ srcSwId_ = com.google.protobuf.ByteString.EMPTY;
+ srcPortId_ = com.google.protobuf.ByteString.EMPTY;
+ dstSwId_ = com.google.protobuf.ByteString.EMPTY;
+ dstPortId_ = com.google.protobuf.ByteString.EMPTY;
+ status_ = 0;
+ value_ = com.google.protobuf.ByteString.EMPTY;
+ }
+
+ private byte memoizedIsInitialized = -1;
+
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized != -1) return isInitialized == 1;
+
+ if (!hasSrcSwId()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ if (!hasSrcPortId()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ if (!hasDstSwId()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ if (!hasDstPortId()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ if (!hasStatus()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ getSerializedSize();
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ output.writeBytes(1, srcSwId_);
+ }
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ output.writeBytes(2, srcPortId_);
+ }
+ if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ output.writeBytes(3, dstSwId_);
+ }
+ if (((bitField0_ & 0x00000008) == 0x00000008)) {
+ output.writeBytes(4, dstPortId_);
+ }
+ if (((bitField0_ & 0x00000010) == 0x00000010)) {
+ output.writeInt32(5, status_);
+ }
+ if (((bitField0_ & 0x00000020) == 0x00000020)) {
+ output.writeBytes(6, value_);
+ }
+ getUnknownFields().writeTo(output);
+ }
+
+ private int memoizedSerializedSize = -1;
+
+ public int getSerializedSize() {
+ int size = memoizedSerializedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeBytesSize(1, srcSwId_);
+ }
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeBytesSize(2, srcPortId_);
+ }
+ if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeBytesSize(3, dstSwId_);
+ }
+ if (((bitField0_ & 0x00000008) == 0x00000008)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeBytesSize(4, dstPortId_);
+ }
+ if (((bitField0_ & 0x00000010) == 0x00000010)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(5, status_);
+ }
+ if (((bitField0_ & 0x00000020) == 0x00000020)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeBytesSize(6, value_);
+ }
+ size += getUnknownFields().getSerializedSize();
+ memoizedSerializedSize = size;
+ return size;
+ }
+
+ private static final long serialVersionUID = 0L;
+
+ @java.lang.Override
+ protected java.lang.Object writeReplace()
+ throws java.io.ObjectStreamException {
+ return super.writeReplace();
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input, extensionRegistry);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+
+ public static net.onrc.onos.core.datastore.RCProtos.LinkProperty parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public static Builder newBuilder() {
+ return Builder.create();
+ }
+
+ public Builder newBuilderForType() {
+ return newBuilder();
+ }
+
+ public static Builder newBuilder(net.onrc.onos.core.datastore.RCProtos.LinkProperty prototype) {
+ return newBuilder().mergeFrom(prototype);
+ }
+
+ public Builder toBuilder() {
+ return newBuilder(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+
+ /**
+ * Protobuf type {@code RCProtos.LinkProperty}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessage.Builder<Builder>
+ implements net.onrc.onos.core.datastore.RCProtos.LinkPropertyOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_LinkProperty_descriptor;
+ }
+
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_LinkProperty_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ net.onrc.onos.core.datastore.RCProtos.LinkProperty.class, net.onrc.onos.core.datastore.RCProtos.LinkProperty.Builder.class);
+ }
+
+ // Construct using net.onrc.onos.core.datastore.RCProtos.LinkProperty.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
+
+ private Builder(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
+ }
+ }
+
+ private static Builder create() {
+ return new Builder();
+ }
+
+ public Builder clear() {
+ super.clear();
+ srcSwId_ = com.google.protobuf.ByteString.EMPTY;
+ bitField0_ = (bitField0_ & ~0x00000001);
+ srcPortId_ = com.google.protobuf.ByteString.EMPTY;
+ bitField0_ = (bitField0_ & ~0x00000002);
+ dstSwId_ = com.google.protobuf.ByteString.EMPTY;
+ bitField0_ = (bitField0_ & ~0x00000004);
+ dstPortId_ = com.google.protobuf.ByteString.EMPTY;
+ bitField0_ = (bitField0_ & ~0x00000008);
+ status_ = 0;
+ bitField0_ = (bitField0_ & ~0x00000010);
+ value_ = com.google.protobuf.ByteString.EMPTY;
+ bitField0_ = (bitField0_ & ~0x00000020);
+ return this;
+ }
+
+ public Builder clone() {
+ return create().mergeFrom(buildPartial());
+ }
+
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return net.onrc.onos.core.datastore.RCProtos.internal_static_ProtoBuffer_LinkProperty_descriptor;
+ }
+
+ public net.onrc.onos.core.datastore.RCProtos.LinkProperty getDefaultInstanceForType() {
+ return net.onrc.onos.core.datastore.RCProtos.LinkProperty.getDefaultInstance();
+ }
+
+ public net.onrc.onos.core.datastore.RCProtos.LinkProperty build() {
+ net.onrc.onos.core.datastore.RCProtos.LinkProperty result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ public net.onrc.onos.core.datastore.RCProtos.LinkProperty buildPartial() {
+ net.onrc.onos.core.datastore.RCProtos.LinkProperty result = new net.onrc.onos.core.datastore.RCProtos.LinkProperty(this);
+ int from_bitField0_ = bitField0_;
+ int to_bitField0_ = 0;
+ if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
+ to_bitField0_ |= 0x00000001;
+ }
+ result.srcSwId_ = srcSwId_;
+ if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
+ to_bitField0_ |= 0x00000002;
+ }
+ result.srcPortId_ = srcPortId_;
+ if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
+ to_bitField0_ |= 0x00000004;
+ }
+ result.dstSwId_ = dstSwId_;
+ if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
+ to_bitField0_ |= 0x00000008;
+ }
+ result.dstPortId_ = dstPortId_;
+ if (((from_bitField0_ & 0x00000010) == 0x00000010)) {
+ to_bitField0_ |= 0x00000010;
+ }
+ result.status_ = status_;
+ if (((from_bitField0_ & 0x00000020) == 0x00000020)) {
+ to_bitField0_ |= 0x00000020;
+ }
+ result.value_ = value_;
+ result.bitField0_ = to_bitField0_;
+ onBuilt();
+ return result;
+ }
+
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof net.onrc.onos.core.datastore.RCProtos.LinkProperty) {
+ return mergeFrom((net.onrc.onos.core.datastore.RCProtos.LinkProperty) other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(net.onrc.onos.core.datastore.RCProtos.LinkProperty other) {
+ if (other == net.onrc.onos.core.datastore.RCProtos.LinkProperty.getDefaultInstance())
+ return this;
+ if (other.hasSrcSwId()) {
+ setSrcSwId(other.getSrcSwId());
+ }
+ if (other.hasSrcPortId()) {
+ setSrcPortId(other.getSrcPortId());
+ }
+ if (other.hasDstSwId()) {
+ setDstSwId(other.getDstSwId());
+ }
+ if (other.hasDstPortId()) {
+ setDstPortId(other.getDstPortId());
+ }
+ if (other.hasStatus()) {
+ setStatus(other.getStatus());
+ }
+ if (other.hasValue()) {
+ setValue(other.getValue());
+ }
+ this.mergeUnknownFields(other.getUnknownFields());
+ return this;
+ }
+
+ public final boolean isInitialized() {
+ if (!hasSrcSwId()) {
+
+ return false;
+ }
+ if (!hasSrcPortId()) {
+
+ return false;
+ }
+ if (!hasDstSwId()) {
+
+ return false;
+ }
+ if (!hasDstPortId()) {
+
+ return false;
+ }
+ if (!hasStatus()) {
+
+ return false;
+ }
+ return true;
+ }
+
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ net.onrc.onos.core.datastore.RCProtos.LinkProperty parsedMessage = null;
+ try {
+ parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ parsedMessage = (net.onrc.onos.core.datastore.RCProtos.LinkProperty) e.getUnfinishedMessage();
+ throw e;
+ } finally {
+ if (parsedMessage != null) {
+ mergeFrom(parsedMessage);
+ }
+ }
+ return this;
+ }
+
+ private int bitField0_;
+
+ // required bytes srcSwId = 1;
+ private com.google.protobuf.ByteString srcSwId_ = com.google.protobuf.ByteString.EMPTY;
+
+ /**
+ * <code>required bytes srcSwId = 1;</code>
+ */
+ public boolean hasSrcSwId() {
+ return ((bitField0_ & 0x00000001) == 0x00000001);
+ }
+
+ /**
+ * <code>required bytes srcSwId = 1;</code>
+ */
+ public com.google.protobuf.ByteString getSrcSwId() {
+ return srcSwId_;
+ }
+
+ /**
+ * <code>required bytes srcSwId = 1;</code>
+ */
+ public Builder setSrcSwId(com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000001;
+ srcSwId_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>required bytes srcSwId = 1;</code>
+ */
+ public Builder clearSrcSwId() {
+ bitField0_ = (bitField0_ & ~0x00000001);
+ srcSwId_ = getDefaultInstance().getSrcSwId();
+ onChanged();
+ return this;
+ }
+
+ // required bytes srcPortId = 2;
+ private com.google.protobuf.ByteString srcPortId_ = com.google.protobuf.ByteString.EMPTY;
+
+ /**
+ * <code>required bytes srcPortId = 2;</code>
+ */
+ public boolean hasSrcPortId() {
+ return ((bitField0_ & 0x00000002) == 0x00000002);
+ }
+
+ /**
+ * <code>required bytes srcPortId = 2;</code>
+ */
+ public com.google.protobuf.ByteString getSrcPortId() {
+ return srcPortId_;
+ }
+
+ /**
+ * <code>required bytes srcPortId = 2;</code>
+ */
+ public Builder setSrcPortId(com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000002;
+ srcPortId_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>required bytes srcPortId = 2;</code>
+ */
+ public Builder clearSrcPortId() {
+ bitField0_ = (bitField0_ & ~0x00000002);
+ srcPortId_ = getDefaultInstance().getSrcPortId();
+ onChanged();
+ return this;
+ }
+
+ // required bytes dstSwId = 3;
+ private com.google.protobuf.ByteString dstSwId_ = com.google.protobuf.ByteString.EMPTY;
+
+ /**
+ * <code>required bytes dstSwId = 3;</code>
+ */
+ public boolean hasDstSwId() {
+ return ((bitField0_ & 0x00000004) == 0x00000004);
+ }
+
+ /**
+ * <code>required bytes dstSwId = 3;</code>
+ */
+ public com.google.protobuf.ByteString getDstSwId() {
+ return dstSwId_;
+ }
+
+ /**
+ * <code>required bytes dstSwId = 3;</code>
+ */
+ public Builder setDstSwId(com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000004;
+ dstSwId_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>required bytes dstSwId = 3;</code>
+ */
+ public Builder clearDstSwId() {
+ bitField0_ = (bitField0_ & ~0x00000004);
+ dstSwId_ = getDefaultInstance().getDstSwId();
+ onChanged();
+ return this;
+ }
+
+ // required bytes dstPortId = 4;
+ private com.google.protobuf.ByteString dstPortId_ = com.google.protobuf.ByteString.EMPTY;
+
+ /**
+ * <code>required bytes dstPortId = 4;</code>
+ */
+ public boolean hasDstPortId() {
+ return ((bitField0_ & 0x00000008) == 0x00000008);
+ }
+
+ /**
+ * <code>required bytes dstPortId = 4;</code>
+ */
+ public com.google.protobuf.ByteString getDstPortId() {
+ return dstPortId_;
+ }
+
+ /**
+ * <code>required bytes dstPortId = 4;</code>
+ */
+ public Builder setDstPortId(com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000008;
+ dstPortId_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>required bytes dstPortId = 4;</code>
+ */
+ public Builder clearDstPortId() {
+ bitField0_ = (bitField0_ & ~0x00000008);
+ dstPortId_ = getDefaultInstance().getDstPortId();
+ onChanged();
+ return this;
+ }
+
+ // required int32 status = 5;
+ private int status_;
+
+ /**
+ * <code>required int32 status = 5;</code>
+ */
+ public boolean hasStatus() {
+ return ((bitField0_ & 0x00000010) == 0x00000010);
+ }
+
+ /**
+ * <code>required int32 status = 5;</code>
+ */
+ public int getStatus() {
+ return status_;
+ }
+
+ /**
+ * <code>required int32 status = 5;</code>
+ */
+ public Builder setStatus(int value) {
+ bitField0_ |= 0x00000010;
+ status_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>required int32 status = 5;</code>
+ */
+ public Builder clearStatus() {
+ bitField0_ = (bitField0_ & ~0x00000010);
+ status_ = 0;
+ onChanged();
+ return this;
+ }
+
+ // optional bytes value = 6;
+ private com.google.protobuf.ByteString value_ = com.google.protobuf.ByteString.EMPTY;
+
+ /**
+ * <code>optional bytes value = 6;</code>
+ */
+ public boolean hasValue() {
+ return ((bitField0_ & 0x00000020) == 0x00000020);
+ }
+
+ /**
+ * <code>optional bytes value = 6;</code>
+ */
+ public com.google.protobuf.ByteString getValue() {
+ return value_;
+ }
+
+ /**
+ * <code>optional bytes value = 6;</code>
+ */
+ public Builder setValue(com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000020;
+ value_ = value;
+ onChanged();
+ return this;
+ }
+
+ /**
+ * <code>optional bytes value = 6;</code>
+ */
+ public Builder clearValue() {
+ bitField0_ = (bitField0_ & ~0x00000020);
+ value_ = getDefaultInstance().getValue();
+ onChanged();
+ return this;
+ }
+
+ // @@protoc_insertion_point(builder_scope:RCProtos.LinkProperty)
+ }
+
+ static {
+ defaultInstance = new LinkProperty(true);
+ defaultInstance.initFields();
+ }
+
+ // @@protoc_insertion_point(class_scope:RCProtos.LinkProperty)
}
+ private static com.google.protobuf.Descriptors.Descriptor
+ internal_static_ProtoBuffer_SwitchProperty_descriptor;
+ private static
+ com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internal_static_ProtoBuffer_SwitchProperty_fieldAccessorTable;
+ private static com.google.protobuf.Descriptors.Descriptor
+ internal_static_ProtoBuffer_PortProperty_descriptor;
+ private static
+ com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internal_static_ProtoBuffer_PortProperty_fieldAccessorTable;
+ private static com.google.protobuf.Descriptors.Descriptor
+ internal_static_ProtoBuffer_LinkProperty_descriptor;
+ private static
+ com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internal_static_ProtoBuffer_LinkProperty_fieldAccessorTable;
+
+ public static com.google.protobuf.Descriptors.FileDescriptor
+ getDescriptor() {
+ return descriptor;
+ }
+
+ private static com.google.protobuf.Descriptors.FileDescriptor
+ descriptor;
+
static {
- defaultInstance = new LinkProperty(true);
- defaultInstance.initFields();
+ java.lang.String[] descriptorData = {
+ "\n\027protobuf/ramcloud.proto\022\013ProtoBuffer\"=" +
+ "\n\016SwitchProperty\022\014\n\004dpid\030\001 \002(\003\022\016\n\006status" +
+ "\030\002 \002(\005\022\r\n\005value\030\003 \001(\014\"K\n\014PortProperty\022\014\n" +
+ "\004dpid\030\001 \002(\003\022\016\n\006number\030\002 \002(\003\022\016\n\006status\030\003 " +
+ "\002(\005\022\r\n\005value\030\004 \001(\014\"u\n\014LinkProperty\022\017\n\007sr" +
+ "cSwId\030\001 \002(\014\022\021\n\tsrcPortId\030\002 \002(\014\022\017\n\007dstSwI" +
+ "d\030\003 \002(\014\022\021\n\tdstPortId\030\004 \002(\014\022\016\n\006status\030\005 \002" +
+ "(\005\022\r\n\005value\030\006 \001(\014B&\n\027net.onrc.onos.datas" +
+ "toreB\013ProtoBuffer"
+ };
+ com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
+ new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
+ public com.google.protobuf.ExtensionRegistry assignDescriptors(
+ com.google.protobuf.Descriptors.FileDescriptor root) {
+ descriptor = root;
+ internal_static_ProtoBuffer_SwitchProperty_descriptor =
+ getDescriptor().getMessageTypes().get(0);
+ internal_static_ProtoBuffer_SwitchProperty_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessage.FieldAccessorTable(
+ internal_static_ProtoBuffer_SwitchProperty_descriptor,
+ new java.lang.String[]{"Dpid", "Status", "Value",});
+ internal_static_ProtoBuffer_PortProperty_descriptor =
+ getDescriptor().getMessageTypes().get(1);
+ internal_static_ProtoBuffer_PortProperty_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessage.FieldAccessorTable(
+ internal_static_ProtoBuffer_PortProperty_descriptor,
+ new java.lang.String[]{"Dpid", "Number", "Status", "Value",});
+ internal_static_ProtoBuffer_LinkProperty_descriptor =
+ getDescriptor().getMessageTypes().get(2);
+ internal_static_ProtoBuffer_LinkProperty_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessage.FieldAccessorTable(
+ internal_static_ProtoBuffer_LinkProperty_descriptor,
+ new java.lang.String[]{"SrcSwId", "SrcPortId", "DstSwId", "DstPortId", "Status", "Value",});
+ return null;
+ }
+ };
+ com.google.protobuf.Descriptors.FileDescriptor
+ .internalBuildGeneratedFileFrom(descriptorData,
+ new com.google.protobuf.Descriptors.FileDescriptor[]{
+ }, assigner);
}
- // @@protoc_insertion_point(class_scope:RCProtos.LinkProperty)
- }
-
- private static com.google.protobuf.Descriptors.Descriptor
- internal_static_ProtoBuffer_SwitchProperty_descriptor;
- private static
- com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internal_static_ProtoBuffer_SwitchProperty_fieldAccessorTable;
- private static com.google.protobuf.Descriptors.Descriptor
- internal_static_ProtoBuffer_PortProperty_descriptor;
- private static
- com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internal_static_ProtoBuffer_PortProperty_fieldAccessorTable;
- private static com.google.protobuf.Descriptors.Descriptor
- internal_static_ProtoBuffer_LinkProperty_descriptor;
- private static
- com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internal_static_ProtoBuffer_LinkProperty_fieldAccessorTable;
-
- public static com.google.protobuf.Descriptors.FileDescriptor
- getDescriptor() {
- return descriptor;
- }
- private static com.google.protobuf.Descriptors.FileDescriptor
- descriptor;
- static {
- java.lang.String[] descriptorData = {
- "\n\027protobuf/ramcloud.proto\022\013ProtoBuffer\"=" +
- "\n\016SwitchProperty\022\014\n\004dpid\030\001 \002(\003\022\016\n\006status" +
- "\030\002 \002(\005\022\r\n\005value\030\003 \001(\014\"K\n\014PortProperty\022\014\n" +
- "\004dpid\030\001 \002(\003\022\016\n\006number\030\002 \002(\003\022\016\n\006status\030\003 " +
- "\002(\005\022\r\n\005value\030\004 \001(\014\"u\n\014LinkProperty\022\017\n\007sr" +
- "cSwId\030\001 \002(\014\022\021\n\tsrcPortId\030\002 \002(\014\022\017\n\007dstSwI" +
- "d\030\003 \002(\014\022\021\n\tdstPortId\030\004 \002(\014\022\016\n\006status\030\005 \002" +
- "(\005\022\r\n\005value\030\006 \001(\014B&\n\027net.onrc.onos.datas" +
- "toreB\013ProtoBuffer"
- };
- com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
- new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
- public com.google.protobuf.ExtensionRegistry assignDescriptors(
- com.google.protobuf.Descriptors.FileDescriptor root) {
- descriptor = root;
- internal_static_ProtoBuffer_SwitchProperty_descriptor =
- getDescriptor().getMessageTypes().get(0);
- internal_static_ProtoBuffer_SwitchProperty_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessage.FieldAccessorTable(
- internal_static_ProtoBuffer_SwitchProperty_descriptor,
- new java.lang.String[] { "Dpid", "Status", "Value", });
- internal_static_ProtoBuffer_PortProperty_descriptor =
- getDescriptor().getMessageTypes().get(1);
- internal_static_ProtoBuffer_PortProperty_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessage.FieldAccessorTable(
- internal_static_ProtoBuffer_PortProperty_descriptor,
- new java.lang.String[] { "Dpid", "Number", "Status", "Value", });
- internal_static_ProtoBuffer_LinkProperty_descriptor =
- getDescriptor().getMessageTypes().get(2);
- internal_static_ProtoBuffer_LinkProperty_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessage.FieldAccessorTable(
- internal_static_ProtoBuffer_LinkProperty_descriptor,
- new java.lang.String[] { "SrcSwId", "SrcPortId", "DstSwId", "DstPortId", "Status", "Value", });
- return null;
- }
- };
- com.google.protobuf.Descriptors.FileDescriptor
- .internalBuildGeneratedFileFrom(descriptorData,
- new com.google.protobuf.Descriptors.FileDescriptor[] {
- }, assigner);
- }
-
- // @@protoc_insertion_point(outer_class_scope)
+ // @@protoc_insertion_point(outer_class_scope)
}
diff --git a/src/main/java/net/onrc/onos/core/datastore/RejectRulesException.java b/src/main/java/net/onrc/onos/core/datastore/RejectRulesException.java
index 351d1a1..4ce1610 100644
--- a/src/main/java/net/onrc/onos/core/datastore/RejectRulesException.java
+++ b/src/main/java/net/onrc/onos/core/datastore/RejectRulesException.java
@@ -4,6 +4,7 @@
// Not sure if we really need this base class.
// Just copied hierarchy from RAMCloud.
//
+
/**
* Base exception class for conditional write, etc. failure.
*/
diff --git a/src/main/java/net/onrc/onos/core/datastore/WrongVersionException.java b/src/main/java/net/onrc/onos/core/datastore/WrongVersionException.java
index 568f5e1..4fd0529 100644
--- a/src/main/java/net/onrc/onos/core/datastore/WrongVersionException.java
+++ b/src/main/java/net/onrc/onos/core/datastore/WrongVersionException.java
@@ -13,7 +13,7 @@
}
public WrongVersionException(final IKVTableID tableID, final byte[] key,
- final long expectedVersion, final Throwable cause) {
+ final long expectedVersion, final Throwable cause) {
// It will be best if {@code cause} has actual version encountered, but
// doesn't currently.
super(ByteArrayUtil.toHexStringBuffer(key, ":") + " on table:"
@@ -22,7 +22,7 @@
}
public WrongVersionException(final IKVTableID tableID, final byte[] key,
- final long expectedVersion, final long encounteredVersion) {
+ final long expectedVersion, final long encounteredVersion) {
super(ByteArrayUtil.toHexStringBuffer(key, ":") + " on table:"
+ tableID + " was expected to be version:" + expectedVersion
+ " but found:" + encounteredVersion);
diff --git a/src/main/java/net/onrc/onos/core/datastore/hazelcast/HZClient.java b/src/main/java/net/onrc/onos/core/datastore/hazelcast/HZClient.java
index d5107da..cbe10be 100644
--- a/src/main/java/net/onrc/onos/core/datastore/hazelcast/HZClient.java
+++ b/src/main/java/net/onrc/onos/core/datastore/hazelcast/HZClient.java
@@ -62,7 +62,7 @@
baseHzConfig = new FileSystemXmlConfig(hazelcastConfigFileName);
} catch (FileNotFoundException e) {
log.error("Error opening Hazelcast XML configuration. File not found: " + hazelcastConfigFileName, e);
- throw new Error("Cannot find Hazelcast configuration: " + hazelcastConfigFileName , e);
+ throw new Error("Cannot find Hazelcast configuration: " + hazelcastConfigFileName, e);
}
// use xml config if present, if not use System.property
@@ -118,6 +118,7 @@
/**
* Register serializer for VersionedValue class used to imitate value version.
+ *
* @param config
*/
private static void registerSerializer(final SerializationConfig config) {
@@ -178,7 +179,7 @@
@Override
public long update(final IKVTableID tableId, final byte[] key, final byte[] value,
- final long version) throws ObjectDoesntExistException,
+ final long version) throws ObjectDoesntExistException,
WrongVersionException {
IKVTable table = (IKVTable) tableId;
return table.update(key, value, version);
@@ -212,13 +213,13 @@
@Override
public IMultiEntryOperation createOp(final IKVTableID tableId, final byte[] key,
- final byte[] value) {
+ final byte[] value) {
return new HZMultiEntryOperation((HZTable) tableId, key, value, HZClient.VERSION_NONEXISTENT, OPERATION.CREATE);
}
@Override
public IMultiEntryOperation forceCreateOp(final IKVTableID tableId, final byte[] key,
- final byte[] value) {
+ final byte[] value) {
return new HZMultiEntryOperation((HZTable) tableId, key, value, HZClient.VERSION_NONEXISTENT, OPERATION.FORCE_CREATE);
}
@@ -229,13 +230,13 @@
@Override
public IMultiEntryOperation updateOp(final IKVTableID tableId, final byte[] key,
- final byte[] value, final long version) {
+ final byte[] value, final long version) {
return new HZMultiEntryOperation((HZTable) tableId, key, value, version, OPERATION.UPDATE);
}
@Override
public IMultiEntryOperation deleteOp(final IKVTableID tableId, final byte[] key,
- final byte[] value, final long version) {
+ final byte[] value, final long version) {
return new HZMultiEntryOperation((HZTable) tableId, key, value, version, OPERATION.DELETE);
}
@@ -250,24 +251,24 @@
for (IMultiEntryOperation op : ops) {
HZMultiEntryOperation mop = (HZMultiEntryOperation) op;
switch (mop.getOperation()) {
- case DELETE:
- try {
- final long version = delete(mop.getTableId(), mop.getKey(), mop.getVersion());
+ case DELETE:
+ try {
+ final long version = delete(mop.getTableId(), mop.getKey(), mop.getVersion());
+ mop.setVersion(version);
+ mop.setStatus(STATUS.SUCCESS);
+ } catch (ObjectDoesntExistException | WrongVersionException e) {
+ log.error(mop + " failed.", e);
+ mop.setStatus(STATUS.FAILED);
+ failExists = true;
+ }
+ break;
+ case FORCE_DELETE:
+ final long version = forceDelete(mop.getTableId(), mop.getKey());
mop.setVersion(version);
mop.setStatus(STATUS.SUCCESS);
- } catch (ObjectDoesntExistException | WrongVersionException e) {
- log.error(mop + " failed.", e);
- mop.setStatus(STATUS.FAILED);
- failExists = true;
- }
- break;
- case FORCE_DELETE:
- final long version = forceDelete(mop.getTableId(), mop.getKey());
- mop.setVersion(version);
- mop.setStatus(STATUS.SUCCESS);
- break;
- default:
- throw new UnsupportedOperationException(mop.toString());
+ break;
+ default:
+ throw new UnsupportedOperationException(mop.toString());
}
}
return failExists;
@@ -280,37 +281,36 @@
for (IMultiEntryOperation op : ops) {
IModifiableMultiEntryOperation mop = (IModifiableMultiEntryOperation) op;
switch (mop.getOperation()) {
- case CREATE:
- try {
- long version = create(mop.getTableId(), mop.getKey(), mop.getValue());
+ case CREATE:
+ try {
+ long version = create(mop.getTableId(), mop.getKey(), mop.getValue());
+ mop.setVersion(version);
+ mop.setStatus(STATUS.SUCCESS);
+ } catch (ObjectExistsException e) {
+ log.error(mop + " failed.", e);
+ mop.setStatus(STATUS.FAILED);
+ failExists = true;
+ }
+ break;
+ case FORCE_CREATE: {
+ final long version = forceCreate(mop.getTableId(), mop.getKey(), mop.getValue());
mop.setVersion(version);
mop.setStatus(STATUS.SUCCESS);
- } catch (ObjectExistsException e) {
- log.error(mop + " failed.", e);
- mop.setStatus(STATUS.FAILED);
- failExists = true;
+ break;
}
- break;
- case FORCE_CREATE:
- {
- final long version = forceCreate(mop.getTableId(), mop.getKey(), mop.getValue());
- mop.setVersion(version);
- mop.setStatus(STATUS.SUCCESS);
- break;
- }
- case UPDATE:
- try {
- long version = update(mop.getTableId(), mop.getKey(), mop.getValue(), mop.getVersion());
- mop.setVersion(version);
- mop.setStatus(STATUS.SUCCESS);
- } catch (ObjectDoesntExistException | WrongVersionException e) {
- log.error(mop + " failed.", e);
- mop.setStatus(STATUS.FAILED);
- failExists = true;
- }
- break;
- default:
- throw new UnsupportedOperationException(mop.toString());
+ case UPDATE:
+ try {
+ long version = update(mop.getTableId(), mop.getKey(), mop.getValue(), mop.getVersion());
+ mop.setVersion(version);
+ mop.setStatus(STATUS.SUCCESS);
+ } catch (ObjectDoesntExistException | WrongVersionException e) {
+ log.error(mop + " failed.", e);
+ mop.setStatus(STATUS.FAILED);
+ failExists = true;
+ }
+ break;
+ default:
+ throw new UnsupportedOperationException(mop.toString());
}
}
return failExists;
diff --git a/src/main/java/net/onrc/onos/core/datastore/hazelcast/HZMultiEntryOperation.java b/src/main/java/net/onrc/onos/core/datastore/hazelcast/HZMultiEntryOperation.java
index 105fc16..88649e7 100644
--- a/src/main/java/net/onrc/onos/core/datastore/hazelcast/HZMultiEntryOperation.java
+++ b/src/main/java/net/onrc/onos/core/datastore/hazelcast/HZMultiEntryOperation.java
@@ -28,6 +28,7 @@
/**
* Constructor for Read/ForceDelete Operation.
+ *
* @param table
* @param key
* @param operation
@@ -44,6 +45,7 @@
/**
* Constructor for Other Operations.
+ *
* @param table
* @param key
* @param value
@@ -108,6 +110,7 @@
/**
* Evaluate Future object and set Status and Value+Version.
+ *
* @return the value read or null on failure.
*/
private VersionedValue get() {
diff --git a/src/main/java/net/onrc/onos/core/datastore/hazelcast/HZTable.java b/src/main/java/net/onrc/onos/core/datastore/hazelcast/HZTable.java
index f071ecc..6cba576 100644
--- a/src/main/java/net/onrc/onos/core/datastore/hazelcast/HZTable.java
+++ b/src/main/java/net/onrc/onos/core/datastore/hazelcast/HZTable.java
@@ -26,10 +26,11 @@
private static final Logger log = LoggerFactory.getLogger(HZTable.class);
// not sure how strict this should be managed
- private static final AtomicLong initialVersion = new AtomicLong(HZClient.VERSION_NONEXISTENT);
+ private static final AtomicLong initialVersion = new AtomicLong(HZClient.VERSION_NONEXISTENT);
/**
* generate a new initial version for an entry.
+ *
* @return initial value
*/
protected static long getInitialVersion() {
@@ -43,6 +44,7 @@
/**
* increment version, avoiding VERSION_NONEXISTENT.
+ *
* @param version
* @return
*/
@@ -185,7 +187,6 @@
}
-
private final String mapName;
private final IMap<byte[], VersionedValue> map;
diff --git a/src/main/java/net/onrc/onos/core/datastore/hazelcast/VersionedValueSerializableFactory.java b/src/main/java/net/onrc/onos/core/datastore/hazelcast/VersionedValueSerializableFactory.java
index 7e77be7..75bd568 100644
--- a/src/main/java/net/onrc/onos/core/datastore/hazelcast/VersionedValueSerializableFactory.java
+++ b/src/main/java/net/onrc/onos/core/datastore/hazelcast/VersionedValueSerializableFactory.java
@@ -13,11 +13,11 @@
@Override
public IdentifiedDataSerializable create(final int typeId) {
switch (typeId) {
- case VERSIONED_VALUE_ID:
- return new HZTable.VersionedValue();
+ case VERSIONED_VALUE_ID:
+ return new HZTable.VersionedValue();
- default:
- return null;
+ default:
+ return null;
}
}
diff --git a/src/main/java/net/onrc/onos/core/datastore/internal/IModifiableMultiEntryOperation.java b/src/main/java/net/onrc/onos/core/datastore/internal/IModifiableMultiEntryOperation.java
index a607add..631aaea 100644
--- a/src/main/java/net/onrc/onos/core/datastore/internal/IModifiableMultiEntryOperation.java
+++ b/src/main/java/net/onrc/onos/core/datastore/internal/IModifiableMultiEntryOperation.java
@@ -4,7 +4,7 @@
/**
* Interface for backend to realize IMultiEntryOperation.
- *
+ * <p/>
* Backend implementation must use these interfaces to update IMultiEntryOperation
* in order to support KVObject.
*/
@@ -12,8 +12,9 @@
/**
* Set value and version.
- *
+ * <p/>
* Expected to be called on multiRead implementations.
+ *
* @param value
* @param version
*/
@@ -21,23 +22,26 @@
/**
* Update version of the value.
- *
+ * <p/>
* Expected to be called on multiWrite, multiRead implementations.
+ *
* @param version
*/
public void setVersion(long version);
/**
* Update status.
- *
+ * <p/>
* Backend implementation is expected to update to SUCCESS or FAILED after
* datastore operation.
+ *
* @param status
*/
public void setStatus(STATUS status);
/**
* Return actual IModifiableMultiEntryOperation if is a wrapper, this otherwise.
+ *
* @return actual IModifiableMultiEntryOperation directly interact with data store
*/
public IModifiableMultiEntryOperation getActualOperation();
diff --git a/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCClient.java b/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCClient.java
index 7ff7e7f..41fda9e 100644
--- a/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCClient.java
+++ b/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCClient.java
@@ -61,16 +61,16 @@
/**
* @return JRamCloud instance intended to be used only within the
- * SameThread.
+ * SameThread.
* @note Do not store the returned instance in a member variable, etc. which
- * may be accessed later by another thread.
+ * may be accessed later by another thread.
*/
static JRamCloud getJRamCloudClient() {
return tlsRCClient.get();
}
// Currently RCClient is state-less
- private static final RCClient theInstance= new RCClient();
+ private static final RCClient theInstance = new RCClient();
public static RCClient getClient() {
return theInstance;
@@ -172,13 +172,13 @@
}
@Override
- public IMultiEntryOperation updateOp(IKVTableID tableId, byte[] key, byte[] value,long version) {
+ public IMultiEntryOperation updateOp(IKVTableID tableId, byte[] key, byte[] value, long version) {
return RCMultiEntryOperation.update(tableId, key, value, version);
}
@Override
public long update(IKVTableID tableId, byte[] key, byte[] value,
- long version) throws ObjectDoesntExistException,
+ long version) throws ObjectDoesntExistException,
WrongVersionException {
RCTableID rcTableId = (RCTableID) tableId;
@@ -222,7 +222,7 @@
}
@Override
- public IMultiEntryOperation deleteOp(IKVTableID tableId, byte[] key, byte[] value,long version) {
+ public IMultiEntryOperation deleteOp(IKVTableID tableId, byte[] key, byte[] value, long version) {
return RCMultiEntryOperation.delete(tableId, key, value, version);
}
@@ -323,9 +323,9 @@
@Override
public boolean multiRead(final Collection<IMultiEntryOperation> ops) {
- if ( ops.size() <= MAX_MULTI_READS && ops instanceof ArrayList) {
- @SuppressWarnings({ "unchecked", "rawtypes" })
- final ArrayList<RCMultiEntryOperation> arrays = (ArrayList)ops;
+ if (ops.size() <= MAX_MULTI_READS && ops instanceof ArrayList) {
+ @SuppressWarnings({"unchecked", "rawtypes"})
+ final ArrayList<RCMultiEntryOperation> arrays = (ArrayList) ops;
return multiReadInternal(arrays);
}
@@ -356,9 +356,9 @@
@Override
public boolean multiWrite(final List<IMultiEntryOperation> ops) {
- if ( ops.size() <= MAX_MULTI_WRITES && ops instanceof ArrayList) {
- @SuppressWarnings({ "unchecked", "rawtypes" })
- final ArrayList<RCMultiEntryOperation> arrays = (ArrayList)ops;
+ if (ops.size() <= MAX_MULTI_WRITES && ops instanceof ArrayList) {
+ @SuppressWarnings({"unchecked", "rawtypes"})
+ final ArrayList<RCMultiEntryOperation> arrays = (ArrayList) ops;
return multiWriteInternal(arrays);
}
@@ -395,45 +395,45 @@
JRamCloud rcClient = getJRamCloudClient();
for (IMultiEntryOperation iop : ops) {
- RCMultiEntryOperation op = (RCMultiEntryOperation)iop;
+ RCMultiEntryOperation op = (RCMultiEntryOperation) iop;
switch (op.getOperation()) {
- case DELETE:
- RejectRules rules = new RejectRules();
- rules.rejectIfDoesntExists();
- rules.rejectIfNeVersion(op.getVersion());
+ case DELETE:
+ RejectRules rules = new RejectRules();
+ rules.rejectIfDoesntExists();
+ rules.rejectIfNeVersion(op.getVersion());
- try {
- final long removedVersion = rcClient.remove(op.tableId.getTableID(), op.entry.getKey(), rules);
- op.entry.setVersion(removedVersion);
- op.status = STATUS.SUCCESS;
- } catch (JRamCloud.ObjectDoesntExistException|JRamCloud.WrongVersionException e) {
- log.error("Failed to remove key:" + ByteArrayUtil.toHexStringBuffer(op.entry.getKey(), "") + " from tableID:" + op.tableId, e );
+ try {
+ final long removedVersion = rcClient.remove(op.tableId.getTableID(), op.entry.getKey(), rules);
+ op.entry.setVersion(removedVersion);
+ op.status = STATUS.SUCCESS;
+ } catch (JRamCloud.ObjectDoesntExistException | JRamCloud.WrongVersionException e) {
+ log.error("Failed to remove key:" + ByteArrayUtil.toHexStringBuffer(op.entry.getKey(), "") + " from tableID:" + op.tableId, e);
+ failExists = true;
+ op.status = STATUS.FAILED;
+ } catch (JRamCloud.RejectRulesException e) {
+ log.error("Failed to remove key:" + ByteArrayUtil.toHexStringBuffer(op.entry.getKey(), "") + " from tableID:" + op.tableId, e);
+ failExists = true;
+ op.status = STATUS.FAILED;
+ }
+ break;
+
+ case FORCE_DELETE:
+ final long removedVersion = rcClient.remove(op.tableId.getTableID(), op.entry.getKey());
+ if (removedVersion != VERSION_NONEXISTENT) {
+ op.entry.setVersion(removedVersion);
+ op.status = STATUS.SUCCESS;
+ } else {
+ log.error("Failed to remove key:{} from tableID:{}", ByteArrayUtil.toHexStringBuffer(op.entry.getKey(), ""), op.tableId);
+ failExists = true;
+ op.status = STATUS.FAILED;
+ }
+ break;
+
+ default:
+ log.error("Invalid operation {} specified on multiDelete", op.getOperation());
failExists = true;
op.status = STATUS.FAILED;
- } catch (JRamCloud.RejectRulesException e) {
- log.error("Failed to remove key:" + ByteArrayUtil.toHexStringBuffer(op.entry.getKey(), "") + " from tableID:" + op.tableId, e );
- failExists = true;
- op.status = STATUS.FAILED;
- }
- break;
-
- case FORCE_DELETE:
- final long removedVersion = rcClient.remove(op.tableId.getTableID(), op.entry.getKey());
- if (removedVersion != VERSION_NONEXISTENT) {
- op.entry.setVersion(removedVersion);
- op.status = STATUS.SUCCESS;
- } else {
- log.error("Failed to remove key:{} from tableID:{}", ByteArrayUtil.toHexStringBuffer(op.entry.getKey(), ""), op.tableId );
- failExists = true;
- op.status = STATUS.FAILED;
- }
- break;
-
- default:
- log.error("Invalid operation {} specified on multiDelete", op.getOperation() );
- failExists = true;
- op.status = STATUS.FAILED;
- break;
+ break;
}
}
return failExists;
@@ -450,7 +450,7 @@
// setup multi-read operation objects
for (int i = 0; i < reqs; ++i) {
IMultiEntryOperation op = ops.get(i);
- multiReadObjects.setObject(i, ((RCTableID)op.getTableId()).getTableID(), op.getKey());
+ multiReadObjects.setObject(i, ((RCTableID) op.getTableId()).getTableID(), op.getKey());
}
// execute
@@ -496,24 +496,24 @@
RejectRules rules = new RejectRules();
switch (op.getOperation()) {
- case CREATE:
- rules.rejectIfExists();
- break;
- case FORCE_CREATE:
- // no reject rule
- break;
- case UPDATE:
- rules.rejectIfDoesntExists();
- rules.rejectIfNeVersion(op.getVersion());
- break;
+ case CREATE:
+ rules.rejectIfExists();
+ break;
+ case FORCE_CREATE:
+ // no reject rule
+ break;
+ case UPDATE:
+ rules.rejectIfDoesntExists();
+ rules.rejectIfNeVersion(op.getVersion());
+ break;
- default:
- log.error("Invalid operation {} specified on multiWriteInternal", op.getOperation() );
- failExists = true;
- op.setStatus(STATUS.FAILED);
- return failExists;
+ default:
+ log.error("Invalid operation {} specified on multiWriteInternal", op.getOperation());
+ failExists = true;
+ op.setStatus(STATUS.FAILED);
+ return failExists;
}
- multiWriteObjects.setObject(i, ((RCTableID)op.getTableId()).getTableID(), op.getKey(), op.getValue(), rules);
+ multiWriteObjects.setObject(i, ((RCTableID) op.getTableId()).getTableID(), op.getKey(), op.getValue(), rules);
}
MultiWriteRspObject[] results = rcClient.multiWrite(multiWriteObjects.tableId, multiWriteObjects.key, multiWriteObjects.keyLength, multiWriteObjects.value, multiWriteObjects.valueLength, ops.size(), multiWriteObjects.rules);
diff --git a/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCMultiEntryOperation.java b/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCMultiEntryOperation.java
index 9b8c8b6..9893838 100644
--- a/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCMultiEntryOperation.java
+++ b/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCMultiEntryOperation.java
@@ -73,33 +73,33 @@
}
public static IMultiEntryOperation create(final IKVTableID tableId, final byte[] key, final byte[] value) {
- return new RCMultiEntryOperation(tableId, new Entry(key,value, RCClient.VERSION_NONEXISTENT), OPERATION.CREATE);
+ return new RCMultiEntryOperation(tableId, new Entry(key, value, RCClient.VERSION_NONEXISTENT), OPERATION.CREATE);
}
public static IMultiEntryOperation forceCreate(final IKVTableID tableId, final byte[] key, final byte[] value) {
- return new RCMultiEntryOperation(tableId, new Entry(key,value, RCClient.VERSION_NONEXISTENT), OPERATION.FORCE_CREATE);
+ return new RCMultiEntryOperation(tableId, new Entry(key, value, RCClient.VERSION_NONEXISTENT), OPERATION.FORCE_CREATE);
}
/**
* Constructor for READ operation.
*
* @param tableId table to read from
- * @param key key of an Entry to read
+ * @param key key of an Entry to read
*/
public static IMultiEntryOperation read(final IKVTableID tableId, final byte[] key) {
return new RCMultiEntryOperation(tableId, new Entry(key), OPERATION.READ);
}
public static IMultiEntryOperation update(final IKVTableID tableId, final byte[] key, final byte[] value, final long version) {
- return new RCMultiEntryOperation(tableId, new Entry(key,value, version), OPERATION.UPDATE);
+ return new RCMultiEntryOperation(tableId, new Entry(key, value, version), OPERATION.UPDATE);
}
public static IMultiEntryOperation delete(final IKVTableID tableId, final byte[] key, final byte[] value, final long version) {
- return new RCMultiEntryOperation(tableId, new Entry(key,value, version), OPERATION.DELETE);
+ return new RCMultiEntryOperation(tableId, new Entry(key, value, version), OPERATION.DELETE);
}
public static IMultiEntryOperation forceDelete(final IKVTableID tableId, final byte[] key) {
- return new RCMultiEntryOperation(tableId, new Entry(key), OPERATION.FORCE_DELETE);
+ return new RCMultiEntryOperation(tableId, new Entry(key), OPERATION.FORCE_DELETE);
}
@Override
diff --git a/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCTable.java b/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCTable.java
index 098215e..e5a6675 100644
--- a/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCTable.java
+++ b/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCTable.java
@@ -58,8 +58,8 @@
private final RCTableID rcTableId;
/**
- *
* {@code rcTableName} must be unique cluster wide.
+ *
* @param rcTableName RAMCloud table name
*/
RCTable(final String rcTableName) {
diff --git a/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCTableID.java b/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCTableID.java
index f69addc..9882ce3 100644
--- a/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCTableID.java
+++ b/src/main/java/net/onrc/onos/core/datastore/ramcloud/RCTableID.java
@@ -21,7 +21,7 @@
// following is RAMCloud specific
public long getTableID() {
- if ( tableID != 0) {
+ if (tableID != 0) {
return tableID;
}
tableID = RCClient.getJRamCloudClient().createTable(tableName);
@@ -34,7 +34,7 @@
@Override
public String toString() {
- return "["+tableName + "]@" + getTableID();
+ return "[" + tableName + "]@" + getTableID();
}
@Override
diff --git a/src/main/java/net/onrc/onos/core/datastore/topology/KVDevice.java b/src/main/java/net/onrc/onos/core/datastore/topology/KVDevice.java
index 14268b5..8b1d8af 100644
--- a/src/main/java/net/onrc/onos/core/datastore/topology/KVDevice.java
+++ b/src/main/java/net/onrc/onos/core/datastore/topology/KVDevice.java
@@ -25,7 +25,7 @@
/**
* Device object.
- *
+ * <p/>
* TODO switch to ProtoBuf, etc.
*/
public class KVDevice extends KVObject {
@@ -55,7 +55,7 @@
private final byte[] mac;
private TreeSet<byte[]> portIds;
private transient boolean isPortIdsModified;
-
+
// Assume there is only one ip on a device now.
private int ip;
private long lastSeenTime;
@@ -86,9 +86,9 @@
/**
* Get an instance from Key.
*
- * @note You need to call `read()` to get the DB content.
* @param key
* @return
+ * @note You need to call `read()` to get the DB content.
*/
public static KVDevice createFromKey(final byte[] key) {
return new KVDevice(getMacFromKey(key));
@@ -150,7 +150,6 @@
}
/**
- *
* @return Unmodifiable Set view of all the PortIds;
*/
public Set<byte[]> getAllPortIds() {
@@ -203,20 +202,20 @@
return "[" + this.getClass().getSimpleName()
+ " " + ByteArrayUtil.toHexStringBuffer(mac, ":") + "]";
}
-
- public int getIp() {
- return ip;
- }
- public void setIp(int ip) {
- this.ip = ip;
- }
+ public int getIp() {
+ return ip;
+ }
- public long getLastSeenTime() {
- return lastSeenTime;
- }
+ public void setIp(int ip) {
+ this.ip = ip;
+ }
- public void setLastSeenTime(long lastSeenTime) {
- this.lastSeenTime = lastSeenTime;
- }
+ public long getLastSeenTime() {
+ return lastSeenTime;
+ }
+
+ public void setLastSeenTime(long lastSeenTime) {
+ this.lastSeenTime = lastSeenTime;
+ }
}
diff --git a/src/main/java/net/onrc/onos/core/datastore/topology/KVLink.java b/src/main/java/net/onrc/onos/core/datastore/topology/KVLink.java
index 23001ff..64eabc1 100644
--- a/src/main/java/net/onrc/onos/core/datastore/topology/KVLink.java
+++ b/src/main/java/net/onrc/onos/core/datastore/topology/KVLink.java
@@ -76,7 +76,7 @@
private STATUS status;
public static byte[] getLinkID(final Long src_dpid, final Long src_port_no,
- final Long dst_dpid, final Long dst_port_no) {
+ final Long dst_dpid, final Long dst_port_no) {
return LinkEvent.getLinkID(src_dpid, src_port_no, dst_dpid,
dst_port_no).array();
}
@@ -103,7 +103,7 @@
}
public KVLink(final Long src_dpid, final Long src_port_no,
- final Long dst_dpid, final Long dst_port_no) {
+ final Long dst_dpid, final Long dst_port_no) {
super(DataStoreClient.getClient().getTable(GLOBAL_LINK_TABLE_NAME), getLinkID(src_dpid,
src_port_no, dst_dpid, dst_port_no));
@@ -115,9 +115,9 @@
/**
* Get an instance from Key.
*
- * @note You need to call `read()` to get the DB content.
* @param key
* @return KVLink instance
+ * @note You need to call `read()` to get the DB content.
*/
public static KVLink createFromKey(final byte[] key) {
long[] linkTuple = getLinkTupleFromKey(key);
diff --git a/src/main/java/net/onrc/onos/core/datastore/topology/KVPort.java b/src/main/java/net/onrc/onos/core/datastore/topology/KVPort.java
index a5b41e6..db4e1ff 100644
--- a/src/main/java/net/onrc/onos/core/datastore/topology/KVPort.java
+++ b/src/main/java/net/onrc/onos/core/datastore/topology/KVPort.java
@@ -21,10 +21,10 @@
/**
* Port object in data store.
- *
+ * <p/>
* Note: This class will not maintain invariants.
- * e.g., It will NOT automatically remove Links or Devices on Port,
- * when deleting a Port.
+ * e.g., It will NOT automatically remove Links or Devices on Port,
+ * when deleting a Port.
*/
public class KVPort extends KVObject {
private static final Logger log = LoggerFactory.getLogger(KVPort.class);
@@ -105,9 +105,9 @@
/**
* Get an instance from Key.
*
- * @note You need to call `read()` to get the DB content.
* @param key
* @return KVPort instance
+ * @note You need to call `read()` to get the DB content.
*/
public static KVPort createFromKey(final byte[] key) {
long[] pair = getPortPairFromKey(key);
diff --git a/src/main/java/net/onrc/onos/core/datastore/topology/KVSwitch.java b/src/main/java/net/onrc/onos/core/datastore/topology/KVSwitch.java
index 474e99a..9f865e0 100644
--- a/src/main/java/net/onrc/onos/core/datastore/topology/KVSwitch.java
+++ b/src/main/java/net/onrc/onos/core/datastore/topology/KVSwitch.java
@@ -20,10 +20,10 @@
/**
* Switch object in data store.
- *
+ * <p/>
* Note: This class will not maintain invariants.
- * e.g., It will NOT automatically remove Ports on Switch,
- * when deleting a Switch.
+ * e.g., It will NOT automatically remove Ports on Switch,
+ * when deleting a Switch.
*/
public class KVSwitch extends KVObject {
private static final Logger log = LoggerFactory.getLogger(KVSwitch.class);
@@ -80,9 +80,9 @@
/**
* Get an instance from Key.
*
- * @note You need to call `read()` to get the DB content.
* @param key
* @return KVSwitch instance
+ * @note You need to call `read()` to get the DB content.
*/
public static KVSwitch createFromKey(final byte[] key) {
return new KVSwitch(getDpidFromKey(key));
diff --git a/src/main/java/net/onrc/onos/core/datastore/utils/ByteArrayComparator.java b/src/main/java/net/onrc/onos/core/datastore/utils/ByteArrayComparator.java
index f937e50..0c0cf18 100644
--- a/src/main/java/net/onrc/onos/core/datastore/utils/ByteArrayComparator.java
+++ b/src/main/java/net/onrc/onos/core/datastore/utils/ByteArrayComparator.java
@@ -5,7 +5,7 @@
/**
* Comparator which will compares the content of byte[].
- *
+ * <p/>
* Expected to be used with TreeMap, etc. when you want to use byte[] as a key.
*/
public final class ByteArrayComparator implements Comparator<byte[]> {
diff --git a/src/main/java/net/onrc/onos/core/datastore/utils/ByteArrayUtil.java b/src/main/java/net/onrc/onos/core/datastore/utils/ByteArrayUtil.java
index 14cd419..32abb59 100644
--- a/src/main/java/net/onrc/onos/core/datastore/utils/ByteArrayUtil.java
+++ b/src/main/java/net/onrc/onos/core/datastore/utils/ByteArrayUtil.java
@@ -5,7 +5,8 @@
public class ByteArrayUtil {
// Suppresses default constructor, ensuring non-instantiability.
- private ByteArrayUtil() {}
+ private ByteArrayUtil() {
+ }
/**
* Returns a StringBuffer with each byte in {@code bytes}
@@ -13,11 +14,11 @@
* separated by {@code sep}.
*
* @param bytes byte array to convert
- * @param sep separator between each bytes
+ * @param sep separator between each bytes
* @return {@code bytes} converted to a StringBuffer
*/
public static StringBuffer toHexStringBuffer(final byte[] bytes,
- final String sep) {
+ final String sep) {
return toHexStringBuffer(bytes, sep, new StringBuffer());
}
@@ -27,12 +28,12 @@
* separated by {@code sep}.
*
* @param bytes byte array to convert
- * @param sep separator between each bytes
- * @param buf StringBuffer to append to.
+ * @param sep separator between each bytes
+ * @param buf StringBuffer to append to.
* @return {@code buf}
*/
public static StringBuffer toHexStringBuffer(final byte[] bytes,
- final String sep, final StringBuffer buf) {
+ final String sep, final StringBuffer buf) {
if (bytes == null) {
return buf;
}
diff --git a/src/main/java/net/onrc/onos/core/datastore/utils/KVObject.java b/src/main/java/net/onrc/onos/core/datastore/utils/KVObject.java
index ce4f617..937129a 100644
--- a/src/main/java/net/onrc/onos/core/datastore/utils/KVObject.java
+++ b/src/main/java/net/onrc/onos/core/datastore/utils/KVObject.java
@@ -27,7 +27,6 @@
/**
* Class to represent an Object represented as a single K-V pair Value blob.
- *
*/
public class KVObject {
private static final Logger log = LoggerFactory.getLogger(KVObject.class);
@@ -55,7 +54,7 @@
private long version;
/**
- * Map to store user-defined properties
+ * Map to store user-defined properties
*/
private Map<Object, Object> propertyMap;
@@ -105,8 +104,8 @@
/**
* Return user-defined object properties.
*
- * @note Will not trigger deserialization
* @return Will return null, if never been set, or was not deserialized
+ * @note Will not trigger deserialization
*/
protected Map<Object, Object> getPropertyMap() {
return this.propertyMap;
@@ -120,7 +119,7 @@
/**
* Serialize object.
- *
+ * <p/>
* sub-classes should override this method to customize serialization.
*
* @return serialized byte array
@@ -130,7 +129,7 @@
}
protected byte[] serializePropertyMap(final Kryo kryo,
- final Map<Object, Object> propMap) {
+ final Map<Object, Object> propMap) {
// value
@@ -144,7 +143,7 @@
/**
* Deserialize using value and version stored in data store.
*
- * @param bytes serialized bytes
+ * @param bytes serialized bytes
* @param version version of this {@code bytes}
* @return true if success
*/
@@ -155,7 +154,7 @@
/**
* Deserialize object.
- *
+ * <p/>
* sub-classes should override this method to customize deserialization.
*
* @param bytes serialized byte array
@@ -168,7 +167,8 @@
/**
* Deserialize and set {@link propertyMap}.
- * @param kryo serializer to use
+ *
+ * @param kryo serializer to use
* @param bytes Kryo serialized Map object
* @return true if success
*/
@@ -183,7 +183,7 @@
}
protected <T extends Map<?, ?>> T deserializePropertyMap(final Kryo kryo,
- final byte[] bytes, final Class<T> type) {
+ final byte[] bytes, final Class<T> type) {
if (bytes == null || bytes.length == 0) {
return null;
@@ -198,7 +198,7 @@
/**
* Create an Object in DataStore.
- *
+ * <p/>
* Fails if the Object with same key already exists.
*
* @throws ObjectExistsException
@@ -225,11 +225,10 @@
/**
* Read an Object from DataStore.
- *
+ * <p/>
* Fails if the Object with the key does not exist.
*
* @throws ObjectDoesntExistException
- *
*/
public void read() throws ObjectDoesntExistException {
IKVEntry e = table.read(key);
@@ -238,14 +237,14 @@
/**
* Update an existing Object in DataStore checking versions.
- *
+ * <p/>
* Fails if the Object with key does not exists, or conditional failure.
*
* @throws WrongVersionException
* @throws ObjectDoesntExistException
*/
public void update() throws ObjectDoesntExistException,
- WrongVersionException {
+ WrongVersionException {
if (this.propertyMap == null) {
replacePropertyMap(new HashMap<Object, Object>());
}
@@ -255,14 +254,14 @@
/**
* Remove an existing Object in DataStore.
- *
+ * <p/>
* Fails if the Object with key does not exists.
*
* @throws ObjectDoesntExistException
* @throws WrongVersionException
*/
public void delete() throws ObjectDoesntExistException,
- WrongVersionException {
+ WrongVersionException {
this.version = table.delete(key, this.version);
}
@@ -297,11 +296,10 @@
/**
* Multi-read RCObjects.
- *
+ * <p/>
* If the blob value was read successfully, RCObject will deserialize them.
*
- * @param objects
- * RCObjects to read
+ * @param objects RCObjects to read
* @return true if there exist a failed read.
*/
public static boolean multiRead(final List<? extends KVObject> objects) {
@@ -318,8 +316,8 @@
for (int i = 0; i < readOps.size(); ++i) {
KVObject obj = objects.get(i);
IMultiEntryOperation entry = readOps.get(i);
- if ( entry.hasSucceeded() ) {
- if ( !obj.deserialize(entry.getValue(), entry.getVersion()) ) {
+ if (entry.hasSucceeded()) {
+ if (!obj.deserialize(entry.getValue(), entry.getVersion())) {
//deserialize return true on success
failExists = true;
log.error("MultiRead error, failed to deserialize {}, {}", obj.getTable(), obj);
@@ -346,14 +344,14 @@
this.base = (IModifiableMultiEntryOperation) base;
this.obj = obj;
- // switch (base.getOperation()) {
- // case CREATE:
- // case FORCE_CREATE:
- // case UPDATE:
- // break;
- // default:
- // throw new UnsupportedOperationException("Unexpected OPERATION:"+base.getOperation());
- // }
+ // switch (base.getOperation()) {
+ // case CREATE:
+ // case FORCE_CREATE:
+ // case UPDATE:
+ // break;
+ // default:
+ // throw new UnsupportedOperationException("Unexpected OPERATION:"+base.getOperation());
+ // }
}
@Override
@@ -436,7 +434,7 @@
}
public abstract static class AbstractObjectIterator<E extends KVObject> implements
- Iterator<E> {
+ Iterator<E> {
protected Iterator<IKVEntry> enumerator;
@@ -450,13 +448,13 @@
}
// Implement something similar to below to realize Iterator
- // @Override
- // public E next() {
- // IKVTable.IKVEntry o = enumerator.next();
- // E obj = E.createFromKey(o.getKey());
- // obj.deserialize(o.getValue(), o.getVersion());
- // return obj;
- // }
+ // @Override
+ // public E next() {
+ // IKVTable.IKVEntry o = enumerator.next();
+ // E obj = E.createFromKey(o.getKey());
+ // obj.deserialize(o.getValue(), o.getVersion());
+ // return obj;
+ // }
@Deprecated
@Override