Yuta HIGUCHI

Revert "Renamed *MastershipStore* to *DeviceMastershipStore*"

This reverts commit da147db7.
...@@ -32,7 +32,7 @@ import com.hazelcast.core.MultiMap; ...@@ -32,7 +32,7 @@ import com.hazelcast.core.MultiMap;
32 */ 32 */
33 @Component(immediate = true) 33 @Component(immediate = true)
34 @Service 34 @Service
35 -public class DistributedDeviceMastershipStore 35 +public class DistributedMastershipStore
36 extends AbstractHazelcastStore<DeviceMastershipEvent, DeviceMastershipStoreDelegate> 36 extends AbstractHazelcastStore<DeviceMastershipEvent, DeviceMastershipStoreDelegate>
37 implements DeviceMastershipStore { 37 implements DeviceMastershipStore {
38 38
......
...@@ -40,7 +40,7 @@ import com.hazelcast.core.Hazelcast; ...@@ -40,7 +40,7 @@ import com.hazelcast.core.Hazelcast;
40 /** 40 /**
41 * Test of the Hazelcast-based distributed MastershipStore implementation. 41 * Test of the Hazelcast-based distributed MastershipStore implementation.
42 */ 42 */
43 -public class DistributedDeviceMastershipStoreTest { 43 +public class DistributedMastershipStoreTest {
44 44
45 private static final DeviceId DID1 = DeviceId.deviceId("of:01"); 45 private static final DeviceId DID1 = DeviceId.deviceId("of:01");
46 private static final DeviceId DID2 = DeviceId.deviceId("of:02"); 46 private static final DeviceId DID2 = DeviceId.deviceId("of:02");
...@@ -54,8 +54,8 @@ public class DistributedDeviceMastershipStoreTest { ...@@ -54,8 +54,8 @@ public class DistributedDeviceMastershipStoreTest {
54 private static final ControllerNode CN1 = new DefaultControllerNode(N1, IP); 54 private static final ControllerNode CN1 = new DefaultControllerNode(N1, IP);
55 private static final ControllerNode CN2 = new DefaultControllerNode(N2, IP); 55 private static final ControllerNode CN2 = new DefaultControllerNode(N2, IP);
56 56
57 - private DistributedDeviceMastershipStore dms; 57 + private DistributedMastershipStore dms;
58 - private TestDistributedDeviceMastershipStore testStore; 58 + private TestDistributedMastershipStore testStore;
59 private KryoSerializer serializationMgr; 59 private KryoSerializer serializationMgr;
60 private StoreManager storeMgr; 60 private StoreManager storeMgr;
61 61
...@@ -77,11 +77,11 @@ public class DistributedDeviceMastershipStoreTest { ...@@ -77,11 +77,11 @@ public class DistributedDeviceMastershipStoreTest {
77 77
78 serializationMgr = new KryoSerializer(); 78 serializationMgr = new KryoSerializer();
79 79
80 - dms = new TestDistributedDeviceMastershipStore(storeMgr, serializationMgr); 80 + dms = new TestDistributedMastershipStore(storeMgr, serializationMgr);
81 dms.clusterService = new TestClusterService(); 81 dms.clusterService = new TestClusterService();
82 dms.activate(); 82 dms.activate();
83 83
84 - testStore = (TestDistributedDeviceMastershipStore) dms; 84 + testStore = (TestDistributedMastershipStore) dms;
85 } 85 }
86 86
87 @After 87 @After
...@@ -227,9 +227,9 @@ public class DistributedDeviceMastershipStoreTest { ...@@ -227,9 +227,9 @@ public class DistributedDeviceMastershipStoreTest {
227 assertTrue("Add event fired", addLatch.await(1, TimeUnit.SECONDS)); 227 assertTrue("Add event fired", addLatch.await(1, TimeUnit.SECONDS));
228 } 228 }
229 229
230 - private class TestDistributedDeviceMastershipStore extends 230 + private class TestDistributedMastershipStore extends
231 - DistributedDeviceMastershipStore { 231 + DistributedMastershipStore {
232 - public TestDistributedDeviceMastershipStore(StoreService storeService, 232 + public TestDistributedMastershipStore(StoreService storeService,
233 KryoSerializer kryoSerialization) { 233 KryoSerializer kryoSerialization) {
234 this.storeService = storeService; 234 this.storeService = storeService;
235 this.serializer = kryoSerialization; 235 this.serializer = kryoSerialization;
......