diff --git a/core/api/src/main/java/org/onosproject/store/service/Serializer.java b/core/api/src/main/java/org/onosproject/store/service/Serializer.java index 5ad35a380e..5608333b1b 100644 --- a/core/api/src/main/java/org/onosproject/store/service/Serializer.java +++ b/core/api/src/main/java/org/onosproject/store/service/Serializer.java @@ -86,7 +86,6 @@ public interface Serializer { KryoNamespace.Builder builder = new KryoNamespace.Builder(); namespaces.forEach(builder::register); Lists.newArrayList(classes).forEach(builder::register); - builder.register(MapEvent.class, MapEvent.Type.class, Versioned.class); KryoNamespace namespace = builder.build(); return new Serializer() { @Override diff --git a/core/store/dist/src/main/java/org/onosproject/store/device/impl/GossipDeviceStore.java b/core/store/dist/src/main/java/org/onosproject/store/device/impl/GossipDeviceStore.java index 4f367f895a..d2d450ed69 100644 --- a/core/store/dist/src/main/java/org/onosproject/store/device/impl/GossipDeviceStore.java +++ b/core/store/dist/src/main/java/org/onosproject/store/device/impl/GossipDeviceStore.java @@ -231,8 +231,8 @@ public class GossipDeviceStore // Create a distributed map for port stats. KryoNamespace.Builder deviceDataSerializer = KryoNamespace.newBuilder() .register(KryoNamespaces.API) - .register(MultiValuedTimestamp.class) - .register(WallClockTimestamp.class); + .nextId(KryoNamespaces.BEGIN_USER_CUSTOM_ID) + .register(MultiValuedTimestamp.class); devicePortStats = storageService.>eventuallyConsistentMapBuilder() .withName("port-stats") diff --git a/core/store/dist/src/main/java/org/onosproject/store/intent/impl/GossipIntentStore.java b/core/store/dist/src/main/java/org/onosproject/store/intent/impl/GossipIntentStore.java index 99e19768fe..98aa3cfd11 100644 --- a/core/store/dist/src/main/java/org/onosproject/store/intent/impl/GossipIntentStore.java +++ b/core/store/dist/src/main/java/org/onosproject/store/intent/impl/GossipIntentStore.java @@ -91,9 +91,9 @@ public class GossipIntentStore public void activate() { KryoNamespace.Builder intentSerializer = KryoNamespace.newBuilder() .register(KryoNamespaces.API) + .nextId(KryoNamespaces.BEGIN_USER_CUSTOM_ID) .register(IntentData.class) - .register(MultiValuedTimestamp.class) - .register(WallClockTimestamp.class); + .register(MultiValuedTimestamp.class); currentMap = storageService.eventuallyConsistentMapBuilder() .withName("intent-current") diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StorageManager.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StorageManager.java index b4074ba4d6..4def1e9edb 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StorageManager.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StorageManager.java @@ -35,7 +35,6 @@ import org.onosproject.cluster.PartitionId; import org.onosproject.persistence.PersistenceService; import org.onosproject.store.cluster.messaging.ClusterCommunicationService; import org.onosproject.store.primitives.DistributedPrimitiveCreator; -import org.onosproject.store.primitives.MapUpdate; import org.onosproject.store.primitives.PartitionAdminService; import org.onosproject.store.primitives.PartitionService; import org.onosproject.store.primitives.TransactionId; @@ -103,8 +102,6 @@ public class StorageManager implements StorageService, StorageAdminService { transactions = this.consistentMapBuilder() .withName("onos-transactions") .withSerializer(Serializer.using(KryoNamespaces.API, - MapUpdate.class, - MapUpdate.Type.class, Transaction.class, Transaction.State.class)) .buildAsyncMap(); diff --git a/incubator/store/src/main/java/org/onosproject/incubator/store/meter/impl/DistributedMeterStore.java b/incubator/store/src/main/java/org/onosproject/incubator/store/meter/impl/DistributedMeterStore.java index ecef57ff4a..be7de21317 100644 --- a/incubator/store/src/main/java/org/onosproject/incubator/store/meter/impl/DistributedMeterStore.java +++ b/incubator/store/src/main/java/org/onosproject/incubator/store/meter/impl/DistributedMeterStore.java @@ -32,7 +32,6 @@ import org.onosproject.net.meter.DefaultMeter; import org.onosproject.net.meter.Meter; import org.onosproject.net.meter.MeterEvent; import org.onosproject.net.meter.MeterFailReason; -import org.onosproject.net.meter.MeterId; import org.onosproject.net.meter.MeterKey; import org.onosproject.net.meter.MeterOperation; import org.onosproject.net.meter.MeterState; @@ -103,8 +102,7 @@ public class DistributedMeterStore extends AbstractStore