aboutsummaryrefslogtreecommitdiffstats
path: root/framework/src/onos/apps/routing/src/test/java/org/onosproject/routing/impl/RouterTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'framework/src/onos/apps/routing/src/test/java/org/onosproject/routing/impl/RouterTest.java')
-rw-r--r--framework/src/onos/apps/routing/src/test/java/org/onosproject/routing/impl/RouterTest.java455
1 files changed, 0 insertions, 455 deletions
diff --git a/framework/src/onos/apps/routing/src/test/java/org/onosproject/routing/impl/RouterTest.java b/framework/src/onos/apps/routing/src/test/java/org/onosproject/routing/impl/RouterTest.java
deleted file mode 100644
index c73e18cb..00000000
--- a/framework/src/onos/apps/routing/src/test/java/org/onosproject/routing/impl/RouterTest.java
+++ /dev/null
@@ -1,455 +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.routing.impl;
-
-import com.google.common.collect.Sets;
-
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-import org.onlab.packet.Ip4Address;
-import org.onlab.packet.Ip4Prefix;
-import org.onlab.packet.Ip6Address;
-import org.onlab.packet.Ip6Prefix;
-import org.onlab.packet.IpAddress;
-import org.onlab.packet.IpPrefix;
-import org.onlab.packet.MacAddress;
-import org.onlab.packet.VlanId;
-import org.onosproject.core.CoreService;
-import org.onosproject.net.ConnectPoint;
-import org.onosproject.net.DefaultHost;
-import org.onosproject.net.DeviceId;
-import org.onosproject.net.Host;
-import org.onosproject.net.HostId;
-import org.onosproject.net.HostLocation;
-import org.onosproject.net.PortNumber;
-import org.onosproject.net.host.HostListener;
-import org.onosproject.net.host.HostService;
-import org.onosproject.net.provider.ProviderId;
-import org.onosproject.routing.BgpService;
-import org.onosproject.routing.FibEntry;
-import org.onosproject.routing.FibListener;
-import org.onosproject.routing.FibUpdate;
-import org.onosproject.routing.RouteEntry;
-import org.onosproject.routing.RouteListener;
-import org.onosproject.routing.RouteUpdate;
-import org.onosproject.routing.config.RoutingConfigurationService;
-
-import java.util.Collections;
-
-import static org.easymock.EasyMock.*;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertTrue;
-
-/**
- * This class tests adding a route, updating a route, deleting a route,
- * and adding a route whose next hop is the local BGP speaker.
- * <p/>
- * The HostService answers requests synchronously.
- */
-public class RouterTest {
-
- private HostService hostService;
- private RoutingConfigurationService routingConfigurationService;
-
- private FibListener fibListener;
-
- private static final ConnectPoint SW1_ETH1 = new ConnectPoint(
- DeviceId.deviceId("of:0000000000000001"),
- PortNumber.portNumber(1));
-
- private static final ConnectPoint SW2_ETH1 = new ConnectPoint(
- DeviceId.deviceId("of:0000000000000002"),
- PortNumber.portNumber(1));
-
- private static final ConnectPoint SW3_ETH1 = new ConnectPoint(
- DeviceId.deviceId("of:0000000000000003"),
- PortNumber.portNumber(1));
-
- private static final ConnectPoint SW4_ETH1 = new ConnectPoint(
- DeviceId.deviceId("of:0000000000000004"),
- PortNumber.portNumber(1));
-
- private static final ConnectPoint SW5_ETH1 = new ConnectPoint(
- DeviceId.deviceId("of:0000000000000005"),
- PortNumber.portNumber(1));
-
- private static final ConnectPoint SW6_ETH1 = new ConnectPoint(
- DeviceId.deviceId("of:0000000000000006"),
- PortNumber.portNumber(1));
- private Router router;
-
- @Before
- public void setUp() throws Exception {
- setUpHostService();
- routingConfigurationService =
- createMock(RoutingConfigurationService.class);
-
- BgpService bgpService = createMock(BgpService.class);
- bgpService.start(anyObject(RouteListener.class));
- bgpService.stop();
- replay(bgpService);
-
- fibListener = createMock(FibListener.class);
-
- router = new Router();
- router.coreService = createNiceMock(CoreService.class);
- router.hostService = hostService;
- router.routingConfigurationService = routingConfigurationService;
- router.bgpService = bgpService;
- router.activate();
-
- router.addFibListener(fibListener);
- router.start();
- }
-
- @After
- public void tearDown() {
- router.stop();
- }
-
- /**
- * Sets up the host service with details of some hosts.
- */
- private void setUpHostService() {
- hostService = createMock(HostService.class);
-
- hostService.addListener(anyObject(HostListener.class));
- expectLastCall().anyTimes();
-
- IpAddress host1Address = IpAddress.valueOf("192.168.10.1");
- Host host1 = new DefaultHost(ProviderId.NONE, HostId.NONE,
- MacAddress.valueOf("00:00:00:00:00:01"), VlanId.NONE,
- new HostLocation(SW1_ETH1, 1),
- Sets.newHashSet(host1Address));
-
- expect(hostService.getHostsByIp(host1Address))
- .andReturn(Sets.newHashSet(host1)).anyTimes();
- hostService.startMonitoringIp(host1Address);
- expectLastCall().anyTimes();
-
- IpAddress host2Address = IpAddress.valueOf("192.168.20.1");
- Host host2 = new DefaultHost(ProviderId.NONE, HostId.NONE,
- MacAddress.valueOf("00:00:00:00:00:02"), VlanId.NONE,
- new HostLocation(SW2_ETH1, 1),
- Sets.newHashSet(host2Address));
-
- expect(hostService.getHostsByIp(host2Address))
- .andReturn(Sets.newHashSet(host2)).anyTimes();
- hostService.startMonitoringIp(host2Address);
- expectLastCall().anyTimes();
-
- // Next hop on a VLAN
- IpAddress host3Address = IpAddress.valueOf("192.168.40.1");
- Host host3 = new DefaultHost(ProviderId.NONE, HostId.NONE,
- MacAddress.valueOf("00:00:00:00:00:03"), VlanId.vlanId((short) 1),
- new HostLocation(SW3_ETH1, 1),
- Sets.newHashSet(host3Address));
-
- expect(hostService.getHostsByIp(host3Address))
- .andReturn(Sets.newHashSet(host3)).anyTimes();
- hostService.startMonitoringIp(host3Address);
- expectLastCall().anyTimes();
-
- IpAddress host4Address = IpAddress.valueOf("1000::1");
- Host host4 = new DefaultHost(ProviderId.NONE, HostId.NONE,
- MacAddress.valueOf("00:00:00:00:00:04"), VlanId.NONE,
- new HostLocation(SW4_ETH1, 1),
- Sets.newHashSet(host4Address));
-
- expect(hostService.getHostsByIp(host4Address))
- .andReturn(Sets.newHashSet(host4)).anyTimes();
- hostService.startMonitoringIp(host4Address);
- expectLastCall().anyTimes();
-
- IpAddress host5Address = IpAddress.valueOf("2000::1");
- Host host5 = new DefaultHost(ProviderId.NONE, HostId.NONE,
- MacAddress.valueOf("00:00:00:00:00:05"), VlanId.NONE,
- new HostLocation(SW5_ETH1, 1),
- Sets.newHashSet(host5Address));
-
- expect(hostService.getHostsByIp(host5Address))
- .andReturn(Sets.newHashSet(host5)).anyTimes();
- hostService.startMonitoringIp(host5Address);
- expectLastCall().anyTimes();
-
- // Next hop on a VLAN
- IpAddress host6Address = IpAddress.valueOf("3000::1");
- Host host6 = new DefaultHost(ProviderId.NONE, HostId.NONE,
- MacAddress.valueOf("00:00:00:00:00:06"), VlanId.vlanId((short) 1),
- new HostLocation(SW6_ETH1, 1),
- Sets.newHashSet(host6Address));
-
- expect(hostService.getHostsByIp(host6Address))
- .andReturn(Sets.newHashSet(host6)).anyTimes();
- hostService.startMonitoringIp(host6Address);
- expectLastCall().anyTimes();
-
-
- // Called during shutdown
- hostService.removeListener(anyObject(HostListener.class));
-
- replay(hostService);
- }
-
- /**
- * Tests adding a IPv4 route entry.
- */
- @Test
- public void testIpv4RouteAdd() {
- // Construct a route entry
- IpPrefix prefix = Ip4Prefix.valueOf("1.1.1.0/24");
- IpAddress nextHopIp = Ip4Address.valueOf("192.168.10.1");
-
- RouteEntry routeEntry = new RouteEntry(prefix, nextHopIp);
-
- // Expected FIB entry
- FibEntry fibEntry = new FibEntry(prefix, nextHopIp,
- MacAddress.valueOf("00:00:00:00:00:01"));
-
- fibListener.update(Collections.singletonList(new FibUpdate(
- FibUpdate.Type.UPDATE, fibEntry)), Collections.emptyList());
-
- replay(fibListener);
-
- router.processRouteUpdates(Collections.singletonList(
- new RouteUpdate(RouteUpdate.Type.UPDATE, routeEntry)));
-
- verify(fibListener);
- }
-
-
- /**
- * Tests adding a IPv6 route entry.
- */
- @Test
- public void testIpv6RouteAdd() {
- // Construct a route entry
- IpPrefix prefix = Ip6Prefix.valueOf("4000::/64");
- IpAddress nextHopIp = Ip6Address.valueOf("1000::1");
-
- RouteEntry routeEntry = new RouteEntry(prefix, nextHopIp);
-
- // Expected FIB entry
- FibEntry fibEntry = new FibEntry(prefix, nextHopIp,
- MacAddress.valueOf("00:00:00:00:00:04"));
-
- fibListener.update(Collections.singletonList(new FibUpdate(
- FibUpdate.Type.UPDATE, fibEntry)), Collections.emptyList());
-
- replay(fibListener);
-
- router.processRouteUpdates(Collections.singletonList(
- new RouteUpdate(RouteUpdate.Type.UPDATE, routeEntry)));
-
- verify(fibListener);
- }
-
-
- /**
- * Tests updating a IPv4 route entry.
- */
- @Test
- public void testRouteUpdate() {
- // Firstly add a route
- testIpv4RouteAdd();
-
- // Route entry with updated next hop for the original prefix
- RouteEntry routeEntryUpdate = new RouteEntry(
- Ip4Prefix.valueOf("1.1.1.0/24"),
- Ip4Address.valueOf("192.168.20.1"));
-
- // The old FIB entry will be withdrawn
- FibEntry withdrawFibEntry = new FibEntry(
- Ip4Prefix.valueOf("1.1.1.0/24"), null, null);
-
- // A new FIB entry will be added
- FibEntry updateFibEntry = new FibEntry(
- Ip4Prefix.valueOf("1.1.1.0/24"),
- Ip4Address.valueOf("192.168.20.1"),
- MacAddress.valueOf("00:00:00:00:00:02"));
-
- reset(fibListener);
- fibListener.update(Collections.singletonList(new FibUpdate(
- FibUpdate.Type.UPDATE, updateFibEntry)),
- Collections.singletonList(new FibUpdate(
- FibUpdate.Type.DELETE, withdrawFibEntry)));
- replay(fibListener);
-
- reset(routingConfigurationService);
- expect(routingConfigurationService.isIpPrefixLocal(
- anyObject(IpPrefix.class))).andReturn(false);
- replay(routingConfigurationService);
-
- router.processRouteUpdates(Collections.singletonList(new RouteUpdate(
- RouteUpdate.Type.UPDATE, routeEntryUpdate)));
-
- verify(fibListener);
- }
-
- /**
- * Tests updating a IPv6 route entry.
- */
- @Test
- public void testIpv6RouteUpdate() {
- // Firstly add a route
- testIpv6RouteAdd();
-
- // Route entry with updated next hop for the original prefix
- RouteEntry routeEntryUpdate = new RouteEntry(
- Ip6Prefix.valueOf("4000::/64"),
- Ip6Address.valueOf("2000::1"));
-
- // The old FIB entry will be withdrawn
- FibEntry withdrawFibEntry = new FibEntry(
- Ip6Prefix.valueOf("4000::/64"), null, null);
-
- // A new FIB entry will be added
- FibEntry updateFibEntry = new FibEntry(
- Ip6Prefix.valueOf("4000::/64"),
- Ip6Address.valueOf("2000::1"),
- MacAddress.valueOf("00:00:00:00:00:05"));
-
- reset(fibListener);
- fibListener.update(Collections.singletonList(new FibUpdate(
- FibUpdate.Type.UPDATE, updateFibEntry)),
- Collections.singletonList(new FibUpdate(
- FibUpdate.Type.DELETE, withdrawFibEntry)));
- replay(fibListener);
-
- reset(routingConfigurationService);
- expect(routingConfigurationService.isIpPrefixLocal(
- anyObject(IpPrefix.class))).andReturn(false);
- replay(routingConfigurationService);
-
- router.processRouteUpdates(Collections.singletonList(new RouteUpdate(
- RouteUpdate.Type.UPDATE, routeEntryUpdate)));
-
- verify(fibListener);
- }
-
- /**
- * Tests deleting a IPv4 route entry.
- */
- @Test
- public void testIpv4RouteDelete() {
- // Firstly add a route
- testIpv4RouteAdd();
-
- RouteEntry deleteRouteEntry = new RouteEntry(
- Ip4Prefix.valueOf("1.1.1.0/24"),
- Ip4Address.valueOf("192.168.10.1"));
-
- FibEntry deleteFibEntry = new FibEntry(
- Ip4Prefix.valueOf("1.1.1.0/24"), null, null);
-
- reset(fibListener);
- fibListener.update(Collections.emptyList(), Collections.singletonList(
- new FibUpdate(FibUpdate.Type.DELETE, deleteFibEntry)));
-
- replay(fibListener);
-
- router.processRouteUpdates(Collections.singletonList(
- new RouteUpdate(RouteUpdate.Type.DELETE, deleteRouteEntry)));
-
- verify(fibListener);
- }
-
- /**
- * Tests deleting a IPv6 route entry.
- */
- @Test
- public void testIpv6RouteDelete() {
- // Firstly add a route
- testIpv6RouteAdd();
-
- RouteEntry deleteRouteEntry = new RouteEntry(
- Ip6Prefix.valueOf("4000::/64"),
- Ip6Address.valueOf("1000::1"));
-
- FibEntry deleteFibEntry = new FibEntry(
- Ip6Prefix.valueOf("4000::/64"), null, null);
-
- reset(fibListener);
- fibListener.update(Collections.emptyList(), Collections.singletonList(
- new FibUpdate(FibUpdate.Type.DELETE, deleteFibEntry)));
-
- replay(fibListener);
-
- router.processRouteUpdates(Collections.singletonList(
- new RouteUpdate(RouteUpdate.Type.DELETE, deleteRouteEntry)));
-
- verify(fibListener);
- }
-
- /**
- * Tests adding a IPv4 route whose next hop is the local BGP speaker.
- */
- @Test
- public void testIpv4LocalRouteAdd() {
- // Construct a route entry, the next hop is the local BGP speaker
- RouteEntry routeEntry = new RouteEntry(
- Ip4Prefix.valueOf("1.1.1.0/24"),
- Ip4Address.valueOf("0.0.0.0"));
-
- // No methods on the FIB listener should be called
- replay(fibListener);
-
- reset(routingConfigurationService);
- expect(routingConfigurationService.isIpPrefixLocal(
- anyObject(IpPrefix.class))).andReturn(true);
- replay(routingConfigurationService);
-
- // Call the processRouteUpdates() method in Router class
- RouteUpdate routeUpdate = new RouteUpdate(RouteUpdate.Type.UPDATE,
- routeEntry);
- router.processRouteUpdates(Collections.singletonList(routeUpdate));
-
- // Verify
- assertEquals(1, router.getRoutes4().size());
- assertTrue(router.getRoutes4().contains(routeEntry));
- verify(fibListener);
- }
-
- /**
- * Tests adding a IPv6 route whose next hop is the local BGP speaker.
- */
- @Test
- public void testIpv6LocalRouteAdd() {
- // Construct a route entry, the next hop is the local BGP speaker
- RouteEntry routeEntry = new RouteEntry(
- Ip6Prefix.valueOf("4000::/64"),
- Ip6Address.valueOf("::"));
-
- // No methods on the FIB listener should be called
- replay(fibListener);
-
- reset(routingConfigurationService);
- expect(routingConfigurationService.isIpPrefixLocal(
- anyObject(IpPrefix.class))).andReturn(true);
- replay(routingConfigurationService);
-
- // Call the processRouteUpdates() method in Router class
- RouteUpdate routeUpdate = new RouteUpdate(RouteUpdate.Type.UPDATE,
- routeEntry);
- router.processRouteUpdates(Collections.singletonList(routeUpdate));
-
- // Verify
- assertEquals(1, router.getRoutes6().size());
- assertTrue(router.getRoutes6().contains(routeEntry));
- verify(fibListener);
- }
-}