Updates to ConsistentMap and LeaderElector state machines
Change-Id: I7734b253a56fef7300a8a094a3cfc8c1b45c2453
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapCommands.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapCommands.java
index 458e5fb..913c3bc 100644
--- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapCommands.java
+++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapCommands.java
@@ -18,7 +18,9 @@
import io.atomix.catalyst.buffer.BufferInput;
import io.atomix.catalyst.buffer.BufferOutput;
import io.atomix.catalyst.serializer.CatalystSerializable;
+import io.atomix.catalyst.serializer.SerializableTypeResolver;
import io.atomix.catalyst.serializer.Serializer;
+import io.atomix.catalyst.serializer.SerializerRegistry;
import io.atomix.catalyst.util.Assert;
import io.atomix.copycat.client.Command;
import io.atomix.copycat.client.Query;
@@ -514,4 +516,28 @@
.toString();
}
}
+
+ /**
+ * Map command type resolver.
+ */
+ public static class TypeResolver implements SerializableTypeResolver {
+ @Override
+ public void resolve(SerializerRegistry registry) {
+ registry.register(ContainsKey.class, -761);
+ registry.register(ContainsValue.class, -762);
+ registry.register(Get.class, -763);
+ registry.register(EntrySet.class, -764);
+ registry.register(Values.class, -765);
+ registry.register(KeySet.class, -766);
+ registry.register(Clear.class, -767);
+ registry.register(IsEmpty.class, -768);
+ registry.register(Size.class, -769);
+ registry.register(Listen.class, -770);
+ registry.register(Unlisten.class, -771);
+ registry.register(TransactionPrepare.class, -772);
+ registry.register(TransactionCommit.class, -773);
+ registry.register(TransactionRollback.class, -774);
+ registry.register(UpdateAndGet.class, -775);
+ }
+ }
}