diff options
Diffstat (limited to 'framework/src/onos/core/net/src/test/java/org/onosproject/cluster/impl/MastershipManagerTest.java')
| -rw-r--r-- | framework/src/onos/core/net/src/test/java/org/onosproject/cluster/impl/MastershipManagerTest.java | 180 |
1 files changed, 0 insertions, 180 deletions
diff --git a/framework/src/onos/core/net/src/test/java/org/onosproject/cluster/impl/MastershipManagerTest.java b/framework/src/onos/core/net/src/test/java/org/onosproject/cluster/impl/MastershipManagerTest.java deleted file mode 100644 index bf1a1ff3..00000000 --- a/framework/src/onos/core/net/src/test/java/org/onosproject/cluster/impl/MastershipManagerTest.java +++ /dev/null @@ -1,180 +0,0 @@ -/* - * Copyright 2014-2015 Open Networking Laboratory - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.onosproject.cluster.impl; - -import java.util.Set; - -import org.junit.After; -import org.junit.Before; -import org.junit.Test; -import org.onlab.packet.IpAddress; -import org.onosproject.cluster.ClusterService; -import org.onosproject.cluster.ClusterServiceAdapter; -import org.onosproject.cluster.ControllerNode; -import org.onosproject.cluster.DefaultControllerNode; -import org.onosproject.cluster.NodeId; -import org.onosproject.common.event.impl.TestEventDispatcher; -import org.onosproject.mastership.MastershipService; -import org.onosproject.mastership.MastershipStore; -import org.onosproject.mastership.MastershipTermService; -import org.onosproject.net.DeviceId; -import org.onosproject.store.trivial.SimpleMastershipStore; - -import com.google.common.collect.Sets; -import com.google.common.util.concurrent.Futures; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertNull; -import static org.onosproject.net.MastershipRole.MASTER; -import static org.onosproject.net.MastershipRole.NONE; -import static org.onosproject.net.MastershipRole.STANDBY; -import static org.onosproject.net.NetTestTools.injectEventDispatcher; - -/** - * Test codifying the mastership service contracts. - */ -public class MastershipManagerTest { - - private static final NodeId NID_LOCAL = new NodeId("local"); - private static final NodeId NID_OTHER = new NodeId("foo"); - private static final IpAddress LOCALHOST = IpAddress.valueOf("127.0.0.1"); - private static final DeviceId DEV_MASTER = DeviceId.deviceId("of:1"); - private static final DeviceId DEV_OTHER = DeviceId.deviceId("of:2"); - - private MastershipManager mgr; - protected MastershipService service; - - @Before - public void setUp() { - mgr = new MastershipManager(); - service = mgr; - injectEventDispatcher(mgr, new TestEventDispatcher()); - mgr.clusterService = new TestClusterService(); - mgr.store = new TestSimpleMastershipStore(mgr.clusterService); - mgr.activate(); - } - - @After - public void tearDown() { - mgr.deactivate(); - mgr.clusterService = null; - injectEventDispatcher(mgr, null); - mgr.store = null; - } - - @Test - public void setRole() { - mgr.setRole(NID_OTHER, DEV_MASTER, MASTER); - assertEquals("wrong local role:", NONE, mgr.getLocalRole(DEV_MASTER)); - assertEquals("wrong obtained role:", STANDBY, Futures.getUnchecked(mgr.requestRoleFor(DEV_MASTER))); - - //set to master - mgr.setRole(NID_LOCAL, DEV_MASTER, MASTER); - assertEquals("wrong local role:", MASTER, mgr.getLocalRole(DEV_MASTER)); - } - - @Test - public void relinquishMastership() { - //no backups - should just turn to NONE for device. - mgr.setRole(NID_LOCAL, DEV_MASTER, MASTER); - assertEquals("wrong role:", MASTER, mgr.getLocalRole(DEV_MASTER)); - mgr.relinquishMastership(DEV_MASTER); - assertNull("wrong master:", mgr.getMasterFor(DEV_OTHER)); - assertEquals("wrong role:", NONE, mgr.getLocalRole(DEV_MASTER)); - - //not master, nothing should happen - mgr.setRole(NID_LOCAL, DEV_OTHER, NONE); - mgr.relinquishMastership(DEV_OTHER); - assertNull("wrong role:", mgr.getMasterFor(DEV_OTHER)); - - //provide NID_OTHER as backup and relinquish - mgr.setRole(NID_LOCAL, DEV_MASTER, MASTER); - assertEquals("wrong master:", NID_LOCAL, mgr.getMasterFor(DEV_MASTER)); - mgr.setRole(NID_OTHER, DEV_MASTER, STANDBY); - mgr.relinquishMastership(DEV_MASTER); - assertEquals("wrong master:", NID_OTHER, mgr.getMasterFor(DEV_MASTER)); - } - - @Test - public void requestRoleFor() { - mgr.setRole(NID_LOCAL, DEV_MASTER, MASTER); - mgr.setRole(NID_OTHER, DEV_OTHER, MASTER); - - //local should be master for one but standby for other - assertEquals("wrong role:", MASTER, Futures.getUnchecked(mgr.requestRoleFor(DEV_MASTER))); - assertEquals("wrong role:", STANDBY, Futures.getUnchecked(mgr.requestRoleFor(DEV_OTHER))); - } - - @Test - public void getMasterFor() { - mgr.setRole(NID_LOCAL, DEV_MASTER, MASTER); - mgr.setRole(NID_OTHER, DEV_OTHER, MASTER); - assertEquals("wrong master:", NID_LOCAL, mgr.getMasterFor(DEV_MASTER)); - assertEquals("wrong master:", NID_OTHER, mgr.getMasterFor(DEV_OTHER)); - - //have NID_OTHER hand over DEV_OTHER to NID_LOCAL - mgr.setRole(NID_LOCAL, DEV_OTHER, MASTER); - assertEquals("wrong master:", NID_LOCAL, mgr.getMasterFor(DEV_OTHER)); - } - - @Test - public void getDevicesOf() { - mgr.setRole(NID_LOCAL, DEV_MASTER, MASTER); - mgr.setRole(NID_LOCAL, DEV_OTHER, STANDBY); - assertEquals("should be one device:", 1, mgr.getDevicesOf(NID_LOCAL).size()); - //hand both devices to NID_LOCAL - mgr.setRole(NID_LOCAL, DEV_OTHER, MASTER); - assertEquals("should be two devices:", 2, mgr.getDevicesOf(NID_LOCAL).size()); - } - - @Test - public void termService() { - MastershipTermService ts = mgr; - - //term = 1 for both - mgr.setRole(NID_LOCAL, DEV_MASTER, MASTER); - assertEquals("inconsistent term: ", 1, ts.getMastershipTerm(DEV_MASTER).termNumber()); - - //hand devices to NID_LOCAL and back: term = 1 + 2 - mgr.setRole(NID_OTHER, DEV_MASTER, MASTER); - mgr.setRole(NID_LOCAL, DEV_MASTER, MASTER); - assertEquals("inconsistent terms: ", 3, ts.getMastershipTerm(DEV_MASTER).termNumber()); - } - - private final class TestClusterService extends ClusterServiceAdapter { - - ControllerNode local = new DefaultControllerNode(NID_LOCAL, LOCALHOST); - - @Override - public ControllerNode getLocalNode() { - return local; - } - - @Override - public Set<ControllerNode> getNodes() { - return Sets.newHashSet(); - } - - } - - private final class TestSimpleMastershipStore extends SimpleMastershipStore - implements MastershipStore { - - public TestSimpleMastershipStore(ClusterService clusterService) { - super.clusterService = clusterService; - } - } -} |