Merge branch 'master' of ssh://gerrit.onlab.us:29418/onos-next
Conflicts:
core/net/src/main/java/org/onlab/onos/net/device/impl/DeviceManager.java
core/store/hz/cluster/src/main/java/org/onlab/onos/store/cluster/impl/DistributedMastershipStore.java
Change-Id: Ia1274657b27e01366a4a87196a13068d7104ee80
diff --git a/core/store/hz/cluster/src/test/java/org/onlab/onos/store/cluster/impl/DistributedMastershipStoreTest.java b/core/store/hz/cluster/src/test/java/org/onlab/onos/store/cluster/impl/DistributedMastershipStoreTest.java
index 9178e90..bf1bb38 100644
--- a/core/store/hz/cluster/src/test/java/org/onlab/onos/store/cluster/impl/DistributedMastershipStoreTest.java
+++ b/core/store/hz/cluster/src/test/java/org/onlab/onos/store/cluster/impl/DistributedMastershipStoreTest.java
@@ -30,8 +30,7 @@
import org.onlab.onos.store.common.StoreManager;
import org.onlab.onos.store.common.StoreService;
import org.onlab.onos.store.common.TestStoreManager;
-import org.onlab.onos.store.serializers.KryoSerializationManager;
-import org.onlab.onos.store.serializers.KryoSerializationService;
+import org.onlab.onos.store.serializers.KryoSerializer;
import org.onlab.packet.IpPrefix;
import com.google.common.collect.Sets;
@@ -57,7 +56,7 @@
private DistributedMastershipStore dms;
private TestDistributedMastershipStore testStore;
- private KryoSerializationManager serializationMgr;
+ private KryoSerializer serializationMgr;
private StoreManager storeMgr;
@BeforeClass
@@ -76,8 +75,7 @@
storeMgr = new TestStoreManager(Hazelcast.newHazelcastInstance(config));
storeMgr.activate();
- serializationMgr = new KryoSerializationManager();
- serializationMgr.activate();
+ serializationMgr = new KryoSerializer();
dms = new TestDistributedMastershipStore(storeMgr, serializationMgr);
dms.clusterService = new TestClusterService();
@@ -90,8 +88,6 @@
public void tearDown() throws Exception {
dms.deactivate();
- serializationMgr.deactivate();
-
storeMgr.deactivate();
}
@@ -234,9 +230,9 @@
private class TestDistributedMastershipStore extends
DistributedMastershipStore {
public TestDistributedMastershipStore(StoreService storeService,
- KryoSerializationService kryoSerializationService) {
+ KryoSerializer kryoSerialization) {
this.storeService = storeService;
- this.kryoSerializationService = kryoSerializationService;
+ this.serializer = kryoSerialization;
}
//helper to populate master/backup structures
@@ -260,6 +256,7 @@
}
}
+ //a dumb utility function.
public void dump() {
System.out.println("standbys");
for (Map.Entry<byte [], byte []> e : standbys.entrySet()) {