diff options
Diffstat (limited to 'framework/src/onos/providers/host')
4 files changed, 0 insertions, 1566 deletions
diff --git a/framework/src/onos/providers/host/pom.xml b/framework/src/onos/providers/host/pom.xml deleted file mode 100644 index ac1e4273..00000000 --- a/framework/src/onos/providers/host/pom.xml +++ /dev/null @@ -1,66 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- - ~ Copyright 2014 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. - --> -<project xmlns="http://maven.apache.org/POM/4.0.0" - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> - <modelVersion>4.0.0</modelVersion> - - <parent> - <groupId>org.onosproject</groupId> - <artifactId>onos-providers</artifactId> - <version>1.4.0-rc1</version> - <relativePath>../pom.xml</relativePath> - </parent> - - <artifactId>onos-host-provider</artifactId> - <packaging>bundle</packaging> - - <properties> - <onos.app.name>org.onosproject.hostprovider</onos.app.name> - </properties> - - <description>ONOS host location provider</description> - <dependencies> - <dependency> - <groupId>org.onosproject</groupId> - <artifactId>onos-api</artifactId> - <classifier>tests</classifier> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.osgi</groupId> - <artifactId>org.osgi.core</artifactId> - </dependency> - <dependency> - <groupId>org.osgi</groupId> - <artifactId>org.osgi.compendium</artifactId> - </dependency> - <dependency> - <groupId>org.onosproject</groupId> - <artifactId>onlab-osgi</artifactId> - <version>${project.version}</version> - <classifier>tests</classifier> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.easymock</groupId> - <artifactId>easymock</artifactId> - <scope>test</scope> - </dependency> - </dependencies> - -</project> diff --git a/framework/src/onos/providers/host/src/main/java/org/onosproject/provider/host/impl/HostLocationProvider.java b/framework/src/onos/providers/host/src/main/java/org/onosproject/provider/host/impl/HostLocationProvider.java deleted file mode 100644 index 93f6bf8c..00000000 --- a/framework/src/onos/providers/host/src/main/java/org/onosproject/provider/host/impl/HostLocationProvider.java +++ /dev/null @@ -1,439 +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.provider.host.impl; - -import org.apache.felix.scr.annotations.Activate; -import org.apache.felix.scr.annotations.Component; -import org.apache.felix.scr.annotations.Deactivate; -import org.apache.felix.scr.annotations.Modified; -import org.apache.felix.scr.annotations.Property; -import org.apache.felix.scr.annotations.Reference; -import org.apache.felix.scr.annotations.ReferenceCardinality; -import org.onlab.packet.ARP; -import org.onlab.packet.Ethernet; -import org.onlab.packet.ICMP6; -import org.onlab.packet.IPacket; -import org.onlab.packet.IPv6; -import org.onlab.packet.IpAddress; -import org.onlab.packet.MacAddress; -import org.onlab.packet.VlanId; -import org.onlab.packet.ipv6.IExtensionHeader; -import org.onlab.packet.ndp.NeighborAdvertisement; -import org.onlab.packet.ndp.NeighborSolicitation; -import org.onlab.packet.ndp.RouterAdvertisement; -import org.onlab.packet.ndp.RouterSolicitation; -import org.onosproject.cfg.ComponentConfigService; -import org.onosproject.core.ApplicationId; -import org.onosproject.core.CoreService; -import org.onosproject.net.ConnectPoint; -import org.onosproject.net.Device; -import org.onosproject.net.Host; -import org.onosproject.net.HostId; -import org.onosproject.net.HostLocation; -import org.onosproject.net.device.DeviceEvent; -import org.onosproject.net.device.DeviceListener; -import org.onosproject.net.device.DeviceService; -import org.onosproject.net.flow.DefaultTrafficSelector; -import org.onosproject.net.flow.TrafficSelector; -import org.onosproject.net.host.DefaultHostDescription; -import org.onosproject.net.host.HostDescription; -import org.onosproject.net.host.HostProvider; -import org.onosproject.net.host.HostProviderRegistry; -import org.onosproject.net.host.HostProviderService; -import org.onosproject.net.host.HostService; -import org.onosproject.net.packet.PacketContext; -import org.onosproject.net.packet.PacketPriority; -import org.onosproject.net.packet.PacketProcessor; -import org.onosproject.net.packet.PacketService; -import org.onosproject.net.provider.AbstractProvider; -import org.onosproject.net.provider.ProviderId; -import org.onosproject.net.topology.Topology; -import org.onosproject.net.topology.TopologyService; -import org.osgi.service.component.ComponentContext; -import org.slf4j.Logger; - -import java.util.Dictionary; -import java.util.Set; - -import static com.google.common.base.Strings.isNullOrEmpty; -import static org.slf4j.LoggerFactory.getLogger; - -/** - * Provider which uses an OpenFlow controller to detect network end-station - * hosts. - */ -@Component(immediate = true) -public class HostLocationProvider extends AbstractProvider implements HostProvider { - - private final Logger log = getLogger(getClass()); - - @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY) - protected CoreService coreService; - - @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY) - protected HostProviderRegistry providerRegistry; - - @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY) - protected PacketService packetService; - - @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY) - protected TopologyService topologyService; - - @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY) - protected HostService hostService; - - @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY) - protected DeviceService deviceService; - - @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY) - protected ComponentConfigService cfgService; - - private HostProviderService providerService; - - private final InternalHostProvider processor = new InternalHostProvider(); - private final DeviceListener deviceListener = new InternalDeviceListener(); - - private ApplicationId appId; - - @Property(name = "hostRemovalEnabled", boolValue = true, - label = "Enable host removal on port/device down events") - private boolean hostRemovalEnabled = true; - - @Property(name = "ipv6NeighborDiscovery", boolValue = false, - label = "Enable using IPv6 Neighbor Discovery by the " + - "Host Location Provider; default is false") - private boolean ipv6NeighborDiscovery = false; - - /** - * Creates an OpenFlow host provider. - */ - public HostLocationProvider() { - super(new ProviderId("of", "org.onosproject.provider.host")); - } - - @Activate - public void activate(ComponentContext context) { - cfgService.registerProperties(getClass()); - appId = coreService.registerApplication("org.onosproject.provider.host"); - - providerService = providerRegistry.register(this); - packetService.addProcessor(processor, PacketProcessor.advisor(1)); - deviceService.addListener(deviceListener); - readComponentConfiguration(context); - requestIntercepts(); - - log.info("Started with Application ID {}", appId.id()); - } - - @Deactivate - public void deactivate() { - cfgService.unregisterProperties(getClass(), false); - - withdrawIntercepts(); - - providerRegistry.unregister(this); - packetService.removeProcessor(processor); - deviceService.removeListener(deviceListener); - providerService = null; - log.info("Stopped"); - } - - @Modified - public void modified(ComponentContext context) { - readComponentConfiguration(context); - requestIntercepts(); - } - - /** - * Request packet intercepts. - */ - private void requestIntercepts() { - TrafficSelector.Builder selector = DefaultTrafficSelector.builder(); - selector.matchEthType(Ethernet.TYPE_ARP); - packetService.requestPackets(selector.build(), PacketPriority.CONTROL, appId); - - // IPv6 Neighbor Solicitation packet. - selector.matchEthType(Ethernet.TYPE_IPV6); - selector.matchIPProtocol(IPv6.PROTOCOL_ICMP6); - selector.matchIcmpv6Type(ICMP6.NEIGHBOR_SOLICITATION); - if (ipv6NeighborDiscovery) { - packetService.requestPackets(selector.build(), PacketPriority.CONTROL, appId); - } else { - packetService.cancelPackets(selector.build(), PacketPriority.CONTROL, appId); - } - - // IPv6 Neighbor Advertisement packet. - selector.matchIcmpv6Type(ICMP6.NEIGHBOR_ADVERTISEMENT); - if (ipv6NeighborDiscovery) { - packetService.requestPackets(selector.build(), PacketPriority.CONTROL, appId); - } else { - packetService.cancelPackets(selector.build(), PacketPriority.CONTROL, appId); - } - } - - /** - * Withdraw packet intercepts. - */ - private void withdrawIntercepts() { - TrafficSelector.Builder selector = DefaultTrafficSelector.builder(); - selector.matchEthType(Ethernet.TYPE_ARP); - packetService.cancelPackets(selector.build(), PacketPriority.CONTROL, appId); - - // IPv6 Neighbor Solicitation packet. - selector.matchEthType(Ethernet.TYPE_IPV6); - selector.matchIPProtocol(IPv6.PROTOCOL_ICMP6); - selector.matchIcmpv6Type(ICMP6.NEIGHBOR_SOLICITATION); - packetService.cancelPackets(selector.build(), PacketPriority.CONTROL, appId); - - // IPv6 Neighbor Advertisement packet. - selector.matchIcmpv6Type(ICMP6.NEIGHBOR_ADVERTISEMENT); - packetService.cancelPackets(selector.build(), PacketPriority.CONTROL, appId); - } - - /** - * Extracts properties from the component configuration context. - * - * @param context the component context - */ - private void readComponentConfiguration(ComponentContext context) { - Dictionary<?, ?> properties = context.getProperties(); - Boolean flag; - - flag = isPropertyEnabled(properties, "hostRemovalEnabled"); - if (flag == null) { - log.info("Host removal on port/device down events is not configured, " + - "using current value of {}", hostRemovalEnabled); - } else { - hostRemovalEnabled = flag; - log.info("Configured. Host removal on port/device down events is {}", - hostRemovalEnabled ? "enabled" : "disabled"); - } - - flag = isPropertyEnabled(properties, "ipv6NeighborDiscovery"); - if (flag == null) { - log.info("Using IPv6 Neighbor Discovery is not configured, " + - "using current value of {}", ipv6NeighborDiscovery); - } else { - ipv6NeighborDiscovery = flag; - log.info("Configured. Using IPv6 Neighbor Discovery is {}", - ipv6NeighborDiscovery ? "enabled" : "disabled"); - } - } - - /** - * Check property name is defined and set to true. - * - * @param properties properties to be looked up - * @param propertyName the name of the property to look up - * @return value when the propertyName is defined or return null - */ - private static Boolean isPropertyEnabled(Dictionary<?, ?> properties, - String propertyName) { - Boolean value = null; - try { - String s = (String) properties.get(propertyName); - value = isNullOrEmpty(s) ? null : s.trim().equals("true"); - } catch (ClassCastException e) { - // No propertyName defined. - value = null; - } - return value; - } - - @Override - public void triggerProbe(Host host) { - log.info("Triggering probe on device {}", host); - } - - private class InternalHostProvider implements PacketProcessor { - /** - * Update host location only. - * - * @param hid host ID - * @param mac source Mac address - * @param vlan VLAN ID - * @param hloc host location - */ - private void updateLocation(HostId hid, MacAddress mac, - VlanId vlan, HostLocation hloc) { - HostDescription desc = new DefaultHostDescription(mac, vlan, hloc); - try { - providerService.hostDetected(hid, desc); - } catch (IllegalStateException e) { - log.debug("Host {} suppressed", hid); - } - } - - /** - * Update host location and IP address. - * - * @param hid host ID - * @param mac source Mac address - * @param vlan VLAN ID - * @param hloc host location - * @param ip source IP address - */ - private void updateLocationIP(HostId hid, MacAddress mac, - VlanId vlan, HostLocation hloc, - IpAddress ip) { - HostDescription desc = ip.isZero() || ip.isSelfAssigned() ? - new DefaultHostDescription(mac, vlan, hloc) : - new DefaultHostDescription(mac, vlan, hloc, ip); - try { - providerService.hostDetected(hid, desc); - } catch (IllegalStateException e) { - log.debug("Host {} suppressed", hid); - } - } - - @Override - public void process(PacketContext context) { - if (context == null) { - return; - } - - Ethernet eth = context.inPacket().parsed(); - if (eth == null) { - return; - } - MacAddress srcMac = eth.getSourceMAC(); - - VlanId vlan = VlanId.vlanId(eth.getVlanID()); - ConnectPoint heardOn = context.inPacket().receivedFrom(); - - // If this arrived on control port, bail out. - if (heardOn.port().isLogical()) { - return; - } - - // If this is not an edge port, bail out. - Topology topology = topologyService.currentTopology(); - if (topologyService.isInfrastructure(topology, heardOn)) { - return; - } - - HostLocation hloc = new HostLocation(heardOn, System.currentTimeMillis()); - HostId hid = HostId.hostId(eth.getSourceMAC(), vlan); - - // ARP: possible new hosts, update both location and IP - if (eth.getEtherType() == Ethernet.TYPE_ARP) { - ARP arp = (ARP) eth.getPayload(); - IpAddress ip = IpAddress.valueOf(IpAddress.Version.INET, - arp.getSenderProtocolAddress()); - updateLocationIP(hid, srcMac, vlan, hloc, ip); - - // IPv4: update location only - } else if (eth.getEtherType() == Ethernet.TYPE_IPV4) { - updateLocation(hid, srcMac, vlan, hloc); - - // - // NeighborAdvertisement and NeighborSolicitation: possible - // new hosts, update both location and IP. - // - // IPv6: update location only - } else if (eth.getEtherType() == Ethernet.TYPE_IPV6) { - IPv6 ipv6 = (IPv6) eth.getPayload(); - IpAddress ip = IpAddress.valueOf(IpAddress.Version.INET6, - ipv6.getSourceAddress()); - - // skip extension headers - IPacket pkt = ipv6; - while (pkt.getPayload() != null && - pkt.getPayload() instanceof IExtensionHeader) { - pkt = pkt.getPayload(); - } - - // Neighbor Discovery Protocol - pkt = pkt.getPayload(); - if (pkt != null && pkt instanceof ICMP6) { - pkt = pkt.getPayload(); - // RouterSolicitation, RouterAdvertisement - if (pkt != null && (pkt instanceof RouterAdvertisement || - pkt instanceof RouterSolicitation)) { - return; - } - if (pkt != null && (pkt instanceof NeighborSolicitation || - pkt instanceof NeighborAdvertisement)) { - // Duplicate Address Detection - if (ip.isZero()) { - return; - } - // NeighborSolicitation, NeighborAdvertisement - updateLocationIP(hid, srcMac, vlan, hloc, ip); - return; - } - } - - // multicast - if (eth.isMulticast()) { - return; - } - - // normal IPv6 packets - updateLocation(hid, srcMac, vlan, hloc); - } - } - } - - // Auxiliary listener to device events. - private class InternalDeviceListener implements DeviceListener { - @Override - public void event(DeviceEvent event) { - Device device = event.subject(); - switch (event.type()) { - case DEVICE_ADDED: - break; - case DEVICE_AVAILABILITY_CHANGED: - if (hostRemovalEnabled && - !deviceService.isAvailable(device.id())) { - removeHosts(hostService.getConnectedHosts(device.id())); - } - break; - case DEVICE_SUSPENDED: - case DEVICE_UPDATED: - // Nothing to do? - break; - case DEVICE_REMOVED: - if (hostRemovalEnabled) { - removeHosts(hostService.getConnectedHosts(device.id())); - } - break; - case PORT_ADDED: - break; - case PORT_UPDATED: - if (hostRemovalEnabled) { - ConnectPoint point = - new ConnectPoint(device.id(), event.port().number()); - removeHosts(hostService.getConnectedHosts(point)); - } - break; - case PORT_REMOVED: - // Nothing to do? - break; - default: - break; - } - } - } - - // Signals host vanish for all specified hosts. - private void removeHosts(Set<Host> hosts) { - for (Host host : hosts) { - providerService.hostVanished(host.id()); - } - } - -} diff --git a/framework/src/onos/providers/host/src/main/java/org/onosproject/provider/host/impl/package-info.java b/framework/src/onos/providers/host/src/main/java/org/onosproject/provider/host/impl/package-info.java deleted file mode 100644 index 57c5c3f6..00000000 --- a/framework/src/onos/providers/host/src/main/java/org/onosproject/provider/host/impl/package-info.java +++ /dev/null @@ -1,20 +0,0 @@ -/* - * Copyright 2014 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. - */ - -/** - * Provider that uses packet service as a means of host discovery and tracking. - */ -package org.onosproject.provider.host.impl; diff --git a/framework/src/onos/providers/host/src/test/java/org/onosproject/provider/host/impl/HostLocationProviderTest.java b/framework/src/onos/providers/host/src/test/java/org/onosproject/provider/host/impl/HostLocationProviderTest.java deleted file mode 100644 index 566eb0c4..00000000 --- a/framework/src/onos/providers/host/src/test/java/org/onosproject/provider/host/impl/HostLocationProviderTest.java +++ /dev/null @@ -1,1041 +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.provider.host.impl; - -import com.google.common.collect.ImmutableSet; -import org.junit.After; -import org.junit.Before; -import org.junit.Test; -import org.onlab.osgi.ComponentContextAdapter; -import org.onlab.packet.ARP; -import org.onlab.packet.ChassisId; -import org.onlab.packet.Ethernet; -import org.onlab.packet.ICMP6; -import org.onlab.packet.IPv4; -import org.onlab.packet.IPv6; -import org.onlab.packet.Ip6Address; -import org.onlab.packet.IpAddress; -import org.onlab.packet.MacAddress; -import org.onlab.packet.VlanId; -import org.onlab.packet.ndp.NeighborAdvertisement; -import org.onlab.packet.ndp.NeighborSolicitation; -import org.onlab.packet.ndp.RouterAdvertisement; -import org.onlab.packet.ndp.RouterSolicitation; -import org.onosproject.cfg.ComponentConfigAdapter; -import org.onosproject.core.ApplicationId; -import org.onosproject.core.CoreService; -import org.onosproject.core.DefaultApplicationId; -import org.onosproject.net.ConnectPoint; -import org.onosproject.net.DefaultDevice; -import org.onosproject.net.DefaultHost; -import org.onosproject.net.DefaultPort; -import org.onosproject.net.Device; -import org.onosproject.net.DeviceId; -import org.onosproject.net.Host; -import org.onosproject.net.HostId; -import org.onosproject.net.HostLocation; -import org.onosproject.net.device.DeviceEvent; -import org.onosproject.net.device.DeviceListener; -import org.onosproject.net.device.DeviceServiceAdapter; -import org.onosproject.net.flow.TrafficTreatment; -import org.onosproject.net.host.HostDescription; -import org.onosproject.net.host.HostProvider; -import org.onosproject.net.host.HostProviderRegistry; -import org.onosproject.net.host.HostProviderService; -import org.onosproject.net.host.HostServiceAdapter; -import org.onosproject.net.packet.DefaultInboundPacket; -import org.onosproject.net.packet.InboundPacket; -import org.onosproject.net.packet.OutboundPacket; -import org.onosproject.net.packet.PacketContext; -import org.onosproject.net.packet.PacketProcessor; -import org.onosproject.net.packet.PacketServiceAdapter; -import org.onosproject.net.provider.AbstractProviderService; -import org.onosproject.net.provider.ProviderId; -import org.onosproject.net.topology.Topology; -import org.onosproject.net.topology.TopologyServiceAdapter; - -import java.nio.ByteBuffer; -import java.util.Collections; -import java.util.Dictionary; -import java.util.Hashtable; -import java.util.Set; - -import static org.easymock.EasyMock.*; -import static org.hamcrest.Matchers.is; -import static org.junit.Assert.*; -import static org.onlab.packet.VlanId.vlanId; -import static org.onosproject.net.Device.Type.SWITCH; -import static org.onosproject.net.DeviceId.deviceId; -import static org.onosproject.net.HostId.hostId; -import static org.onosproject.net.PortNumber.portNumber; -import static org.onosproject.net.device.DeviceEvent.Type.*; - -public class HostLocationProviderTest { - private static final Integer INPORT = 10; - private static final String DEV1 = "of:1"; - private static final String DEV2 = "of:2"; - private static final String DEV3 = "of:3"; - private static final String DEV4 = "of:4"; - private static final String DEV5 = "of:5"; - private static final String DEV6 = "of:6"; - - private static final VlanId VLAN = vlanId(); - - // IPv4 Host - private static final MacAddress MAC = MacAddress.valueOf("00:00:11:00:00:01"); - private static final MacAddress BCMAC = MacAddress.valueOf("ff:ff:ff:ff:ff:ff"); - private static final byte[] IP = new byte[]{10, 0, 0, 1}; - private static final IpAddress IP_ADDRESS = - IpAddress.valueOf(IpAddress.Version.INET, IP); - private static final HostLocation LOCATION = - new HostLocation(deviceId(DEV1), portNumber(INPORT), 0L); - private static final DefaultHost HOST = - new DefaultHost(ProviderId.NONE, hostId(MAC), MAC, - vlanId(VlanId.UNTAGGED), LOCATION, - ImmutableSet.of(IP_ADDRESS)); - - // IPv6 Host - private static final MacAddress MAC2 = MacAddress.valueOf("00:00:22:00:00:02"); - private static final MacAddress BCMAC2 = MacAddress.valueOf("33:33:00:00:00:01"); - private static final byte[] IP2 = Ip6Address.valueOf("1000::1").toOctets(); - private static final IpAddress IP_ADDRESS2 = - IpAddress.valueOf(IpAddress.Version.INET6, IP2); - private static final HostLocation LOCATION2 = - new HostLocation(deviceId(DEV4), portNumber(INPORT), 0L); - private static final DefaultHost HOST2 = - new DefaultHost(ProviderId.NONE, hostId(MAC2), MAC2, - vlanId(VlanId.UNTAGGED), LOCATION2, - ImmutableSet.of(IP_ADDRESS2)); - - private static final ComponentContextAdapter CTX_FOR_REMOVE = - new ComponentContextAdapter() { - @Override - public Dictionary getProperties() { - Hashtable<String, String> props = new Hashtable<>(); - props.put("hostRemovalEnabled", "true"); - return props; - } - }; - - public static final ComponentContextAdapter CTX_FOR_NO_REMOVE = - new ComponentContextAdapter() { - @Override - public Dictionary getProperties() { - return new Hashtable(); - } - }; - - private final HostLocationProvider provider = new HostLocationProvider(); - private final TestHostRegistry hostRegistry = new TestHostRegistry(); - private final TestTopologyService topoService = new TestTopologyService(); - private final TestDeviceService deviceService = new TestDeviceService(); - private final TestHostService hostService = new TestHostService(); - private final TestPacketService packetService = new TestPacketService(); - - private PacketProcessor testProcessor; - private CoreService coreService; - private TestHostProviderService providerService; - - private ApplicationId appId = - new DefaultApplicationId(100, "org.onosproject.provider.host"); - - @Before - public void setUp() { - - coreService = createMock(CoreService.class); - expect(coreService.registerApplication(appId.name())) - .andReturn(appId).anyTimes(); - replay(coreService); - - provider.cfgService = new ComponentConfigAdapter(); - provider.coreService = coreService; - - provider.providerRegistry = hostRegistry; - provider.topologyService = topoService; - provider.packetService = packetService; - provider.deviceService = deviceService; - provider.hostService = hostService; - - provider.activate(CTX_FOR_NO_REMOVE); - } - - @Test - public void basics() { - assertNotNull("registration expected", providerService); - assertEquals("incorrect provider", provider, providerService.provider()); - } - - @Test - public void events() { - // new host - testProcessor.process(new TestArpPacketContext(DEV1)); - assertNotNull("new host expected", providerService.added); - assertNull("host motion unexpected", providerService.moved); - - // the host moved to new switch - testProcessor.process(new TestArpPacketContext(DEV2)); - assertNotNull("host motion expected", providerService.moved); - - // the host was misheard on a spine - testProcessor.process(new TestArpPacketContext(DEV3)); - assertNull("host misheard on spine switch", providerService.spine); - - providerService.clear(); - - // new host - testProcessor.process(new TestNaPacketContext(DEV4)); - assertNotNull("new host expected", providerService.added); - assertNull("host motion unexpected", providerService.moved); - - // the host moved to new switch - testProcessor.process(new TestNaPacketContext(DEV5)); - assertNotNull("host motion expected", providerService.moved); - - // the host was misheard on a spine - testProcessor.process(new TestNaPacketContext(DEV6)); - assertNull("host misheard on spine switch", providerService.spine); - } - - @Test - public void removeHostByDeviceRemove() { - provider.modified(CTX_FOR_REMOVE); - testProcessor.process(new TestArpPacketContext(DEV1)); - testProcessor.process(new TestNaPacketContext(DEV4)); - - Device device = new DefaultDevice(ProviderId.NONE, deviceId(DEV1), SWITCH, - "m", "h", "s", "n", new ChassisId(0L)); - deviceService.listener.event(new DeviceEvent(DEVICE_REMOVED, device)); - assertEquals("incorrect remove count", 1, providerService.removeCount); - - device = new DefaultDevice(ProviderId.NONE, deviceId(DEV4), SWITCH, - "m", "h", "s", "n", new ChassisId(0L)); - deviceService.listener.event(new DeviceEvent(DEVICE_REMOVED, device)); - assertEquals("incorrect remove count", 2, providerService.removeCount); - } - - @Test - public void removeHostByDeviceOffline() { - provider.modified(CTX_FOR_REMOVE); - testProcessor.process(new TestArpPacketContext(DEV1)); - testProcessor.process(new TestArpPacketContext(DEV4)); - - Device device = new DefaultDevice(ProviderId.NONE, deviceId(DEV1), SWITCH, - "m", "h", "s", "n", new ChassisId(0L)); - deviceService.listener.event(new DeviceEvent(DEVICE_AVAILABILITY_CHANGED, device)); - assertEquals("incorrect remove count", 1, providerService.removeCount); - - device = new DefaultDevice(ProviderId.NONE, deviceId(DEV4), SWITCH, - "m", "h", "s", "n", new ChassisId(0L)); - deviceService.listener.event(new DeviceEvent(DEVICE_AVAILABILITY_CHANGED, device)); - assertEquals("incorrect remove count", 2, providerService.removeCount); - } - - @Test - public void removeHostByDevicePortDown() { - provider.modified(CTX_FOR_REMOVE); - testProcessor.process(new TestArpPacketContext(DEV1)); - testProcessor.process(new TestArpPacketContext(DEV4)); - - Device device = new DefaultDevice(ProviderId.NONE, deviceId(DEV1), SWITCH, - "m", "h", "s", "n", new ChassisId(0L)); - deviceService.listener.event(new DeviceEvent(PORT_UPDATED, device, - new DefaultPort(device, portNumber(INPORT), false))); - assertEquals("incorrect remove count", 1, providerService.removeCount); - - device = new DefaultDevice(ProviderId.NONE, deviceId(DEV4), SWITCH, - "m", "h", "s", "n", new ChassisId(0L)); - deviceService.listener.event(new DeviceEvent(PORT_UPDATED, device, - new DefaultPort(device, portNumber(INPORT), false))); - assertEquals("incorrect remove count", 2, providerService.removeCount); - } - - /** - * When receiving ARP, updates location and IP. - */ - @Test - public void testReceiveArp() { - testProcessor.process(new TestArpPacketContext(DEV1)); - HostDescription descr = providerService.added; - assertThat(descr.location(), is(LOCATION)); - assertThat(descr.hwAddress(), is(MAC)); - assertThat(descr.ipAddress().toArray()[0], is(IP_ADDRESS)); - assertThat(descr.vlan(), is(VLAN)); - } - - /** - * When receiving IPv4, updates location only. - */ - @Test - public void testReceiveIpv4() { - testProcessor.process(new TestIpv4PacketContext(DEV1)); - HostDescription descr = providerService.added; - assertThat(descr.location(), is(LOCATION)); - assertThat(descr.hwAddress(), is(MAC)); - assertThat(descr.ipAddress().size(), is(0)); - assertThat(descr.vlan(), is(VLAN)); - } - - /** - * When receiving NeighborAdvertisement, updates location and IP. - */ - @Test - public void testReceiveNa() { - testProcessor.process(new TestNaPacketContext(DEV4)); - assertNotNull(providerService.added); - HostDescription descr = providerService.added; - assertThat(descr.location(), is(LOCATION2)); - assertThat(descr.hwAddress(), is(MAC2)); - assertThat(descr.ipAddress().toArray()[0], is(IP_ADDRESS2)); - assertThat(descr.vlan(), is(VLAN)); - } - - /** - * When receiving NeighborSolicitation, updates location and IP. - */ - @Test - public void testReceiveNs() { - testProcessor.process(new TestNsPacketContext(DEV4)); - HostDescription descr = providerService.added; - assertThat(descr.location(), is(LOCATION2)); - assertThat(descr.hwAddress(), is(MAC2)); - assertThat(descr.ipAddress().toArray()[0], is(IP_ADDRESS2)); - assertThat(descr.vlan(), is(VLAN)); - } - - /** - * When receiving RouterAdvertisement, ignores it. - */ - @Test - public void testReceivesRa() { - testProcessor.process(new TestRAPacketContext(DEV4)); - assertNull(providerService.added); - } - - /** - * When receiving RouterSolicitation, ignores it. - */ - @Test - public void testReceiveRs() { - testProcessor.process(new TestRSPacketContext(DEV4)); - assertNull(providerService.added); - } - - /** - * When receiving Duplicate Address Detection (DAD), ignores it. - */ - @Test - public void testReceiveDad() { - testProcessor.process(new TestDadPacketContext(DEV4)); - assertNull(providerService.added); - } - - /** - * When receiving IPv6 multicast packet, ignores it. - */ - @Test - public void testReceiveIpv6Multicast() { - testProcessor.process(new TestIpv6McastPacketContext(DEV4)); - assertNull(providerService.added); - } - - /** - * When receiving IPv6 unicast packet, updates location only. - */ - @Test - public void testReceiveIpv6Unicast() { - testProcessor.process(new TestIpv6PacketContext(DEV4)); - assertNotNull(providerService.added); - HostDescription descr = providerService.added; - assertThat(descr.location(), is(LOCATION2)); - assertThat(descr.hwAddress(), is(MAC2)); - assertThat(descr.ipAddress().size(), is(0)); - assertThat(descr.vlan(), is(VLAN)); - } - - @After - public void tearDown() { - provider.deactivate(); - provider.coreService = null; - provider.providerRegistry = null; - } - - private class TestHostRegistry implements HostProviderRegistry { - - @Override - public HostProviderService register(HostProvider provider) { - providerService = new TestHostProviderService(provider); - return providerService; - } - - @Override - public void unregister(HostProvider provider) { - } - - @Override - public Set<ProviderId> getProviders() { - return null; - } - - } - - private class TestHostProviderService - extends AbstractProviderService<HostProvider> - implements HostProviderService { - - HostDescription added = null; - HostDescription moved = null; - HostDescription spine = null; - public int removeCount; - - public void clear() { - added = null; - moved = null; - spine = null; - removeCount = 0; - } - - protected TestHostProviderService(HostProvider provider) { - super(provider); - } - - @Override - public void hostDetected(HostId hostId, HostDescription hostDescription, boolean replaceIps) { - if (added == null) { - added = hostDescription; - } else if ((moved == null) && hostDescription != added) { - moved = hostDescription; - } else { - spine = hostDescription; - } - } - - @Override - public void hostVanished(HostId hostId) { - removeCount++; - } - - @Override - public void removeIpFromHost(HostId hostId, IpAddress ipAddress) { - } - - } - - private class TestPacketService extends PacketServiceAdapter { - @Override - public void addProcessor(PacketProcessor processor, int priority) { - testProcessor = processor; - } - } - - private class TestTopologyService extends TopologyServiceAdapter { - @Override - public boolean isInfrastructure(Topology topology, - ConnectPoint connectPoint) { - //simulate DPID3 as an infrastructure switch - if ((connectPoint.deviceId()).equals(deviceId(DEV3)) || - connectPoint.deviceId().equals(deviceId(DEV6))) { - return true; - } - return false; - } - } - - /** - * Generates ARP packet. - */ - private class TestArpPacketContext implements PacketContext { - private final String deviceId; - - public TestArpPacketContext(String deviceId) { - this.deviceId = deviceId; - } - - @Override - public long time() { - return 0; - } - - @Override - public InboundPacket inPacket() { - ARP arp = new ARP(); - arp.setSenderProtocolAddress(IP) - .setSenderHardwareAddress(MAC.toBytes()) - .setTargetHardwareAddress(BCMAC.toBytes()) - .setTargetProtocolAddress(IP); - - Ethernet eth = new Ethernet(); - eth.setEtherType(Ethernet.TYPE_ARP) - .setVlanID(VLAN.toShort()) - .setSourceMACAddress(MAC.toBytes()) - .setDestinationMACAddress(BCMAC) - .setPayload(arp); - ConnectPoint receivedFrom = new ConnectPoint(deviceId(deviceId), - portNumber(INPORT)); - return new DefaultInboundPacket(receivedFrom, eth, - ByteBuffer.wrap(eth.serialize())); - } - - @Override - public OutboundPacket outPacket() { - return null; - } - - @Override - public TrafficTreatment.Builder treatmentBuilder() { - return null; - } - - @Override - public void send() { - - } - - @Override - public boolean block() { - return false; - } - - @Override - public boolean isHandled() { - return false; - } - } - - /** - * Generates IPv6 Unicast packet. - */ - private class TestIpv4PacketContext implements PacketContext { - private final String deviceId; - - public TestIpv4PacketContext(String deviceId) { - this.deviceId = deviceId; - } - - @Override - public long time() { - return 0; - } - - @Override - public InboundPacket inPacket() { - IPv4 ipv4 = new IPv4(); - ipv4.setDestinationAddress("10.0.0.1"); - ipv4.setSourceAddress(IP_ADDRESS.toString()); - Ethernet eth = new Ethernet(); - eth.setEtherType(Ethernet.TYPE_IPV4) - .setVlanID(VLAN.toShort()) - .setSourceMACAddress(MAC) - .setDestinationMACAddress(MacAddress.valueOf("00:00:00:00:00:01")) - .setPayload(ipv4); - ConnectPoint receivedFrom = new ConnectPoint(deviceId(deviceId), - portNumber(INPORT)); - return new DefaultInboundPacket(receivedFrom, eth, - ByteBuffer.wrap(eth.serialize())); - } - - @Override - public OutboundPacket outPacket() { - return null; - } - - @Override - public TrafficTreatment.Builder treatmentBuilder() { - return null; - } - - @Override - public void send() { - - } - - @Override - public boolean block() { - return false; - } - - @Override - public boolean isHandled() { - return false; - } - } - - /** - * Generates NeighborAdvertisement packet. - */ - private class TestNaPacketContext implements PacketContext { - private final String deviceId; - - public TestNaPacketContext(String deviceId) { - this.deviceId = deviceId; - } - - @Override - public long time() { - return 0; - } - - @Override - public InboundPacket inPacket() { - NeighborAdvertisement na = new NeighborAdvertisement(); - ICMP6 icmp6 = new ICMP6(); - icmp6.setPayload(na); - IPv6 ipv6 = new IPv6(); - ipv6.setPayload(icmp6); - ipv6.setDestinationAddress(Ip6Address.valueOf("ff02::1").toOctets()); - ipv6.setSourceAddress(IP2); - Ethernet eth = new Ethernet(); - eth.setEtherType(Ethernet.TYPE_IPV6) - .setVlanID(VLAN.toShort()) - .setSourceMACAddress(MAC2.toBytes()) - .setDestinationMACAddress(BCMAC2) - .setPayload(ipv6); - ConnectPoint receivedFrom = new ConnectPoint(deviceId(deviceId), - portNumber(INPORT)); - return new DefaultInboundPacket(receivedFrom, eth, - ByteBuffer.wrap(eth.serialize())); - } - - @Override - public OutboundPacket outPacket() { - return null; - } - - @Override - public TrafficTreatment.Builder treatmentBuilder() { - return null; - } - - @Override - public void send() { - - } - - @Override - public boolean block() { - return false; - } - - @Override - public boolean isHandled() { - return false; - } - } - - /** - * Generates NeighborSolicitation packet. - */ - private class TestNsPacketContext implements PacketContext { - private final String deviceId; - - public TestNsPacketContext(String deviceId) { - this.deviceId = deviceId; - } - - @Override - public long time() { - return 0; - } - - @Override - public InboundPacket inPacket() { - NeighborSolicitation ns = new NeighborSolicitation(); - ICMP6 icmp6 = new ICMP6(); - icmp6.setPayload(ns); - IPv6 ipv6 = new IPv6(); - ipv6.setPayload(icmp6); - ipv6.setDestinationAddress(Ip6Address.valueOf("ff02::1:ff00:0000").toOctets()); - ipv6.setSourceAddress(IP2); - Ethernet eth = new Ethernet(); - eth.setEtherType(Ethernet.TYPE_IPV6) - .setVlanID(VLAN.toShort()) - .setSourceMACAddress(MAC2.toBytes()) - .setDestinationMACAddress(BCMAC2) - .setPayload(ipv6); - ConnectPoint receivedFrom = new ConnectPoint(deviceId(deviceId), - portNumber(INPORT)); - return new DefaultInboundPacket(receivedFrom, eth, - ByteBuffer.wrap(eth.serialize())); - } - - @Override - public OutboundPacket outPacket() { - return null; - } - - @Override - public TrafficTreatment.Builder treatmentBuilder() { - return null; - } - - @Override - public void send() { - - } - - @Override - public boolean block() { - return false; - } - - @Override - public boolean isHandled() { - return false; - } - } - - /** - * Generates Duplicate Address Detection packet. - */ - private class TestDadPacketContext implements PacketContext { - private final String deviceId; - - public TestDadPacketContext(String deviceId) { - this.deviceId = deviceId; - } - - @Override - public long time() { - return 0; - } - - @Override - public InboundPacket inPacket() { - NeighborSolicitation ns = new NeighborSolicitation(); - ICMP6 icmp6 = new ICMP6(); - icmp6.setPayload(ns); - IPv6 ipv6 = new IPv6(); - ipv6.setPayload(icmp6); - ipv6.setDestinationAddress(Ip6Address.valueOf("ff02::1").toOctets()); - ipv6.setSourceAddress(Ip6Address.valueOf("::").toOctets()); - Ethernet eth = new Ethernet(); - eth.setEtherType(Ethernet.TYPE_IPV6) - .setVlanID(VLAN.toShort()) - .setSourceMACAddress(MAC2.toBytes()) - .setDestinationMACAddress(BCMAC2) - .setPayload(ipv6); - ConnectPoint receivedFrom = new ConnectPoint(deviceId(deviceId), - portNumber(INPORT)); - return new DefaultInboundPacket(receivedFrom, eth, - ByteBuffer.wrap(eth.serialize())); - } - - @Override - public OutboundPacket outPacket() { - return null; - } - - @Override - public TrafficTreatment.Builder treatmentBuilder() { - return null; - } - - @Override - public void send() { - - } - - @Override - public boolean block() { - return false; - } - - @Override - public boolean isHandled() { - return false; - } - } - - /** - * Generates Router Solicitation packet. - */ - private class TestRSPacketContext implements PacketContext { - private final String deviceId; - - public TestRSPacketContext(String deviceId) { - this.deviceId = deviceId; - } - - @Override - public long time() { - return 0; - } - - @Override - public InboundPacket inPacket() { - RouterSolicitation ns = new RouterSolicitation(); - ICMP6 icmp6 = new ICMP6(); - icmp6.setPayload(ns); - IPv6 ipv6 = new IPv6(); - ipv6.setPayload(icmp6); - ipv6.setDestinationAddress(Ip6Address.valueOf("ff02::2").toOctets()); - ipv6.setSourceAddress(Ip6Address.valueOf("::").toOctets()); - Ethernet eth = new Ethernet(); - eth.setEtherType(Ethernet.TYPE_IPV6) - .setVlanID(VLAN.toShort()) - .setSourceMACAddress(MAC2.toBytes()) - .setDestinationMACAddress(MacAddress.valueOf("33:33:00:00:00:02")) - .setPayload(ipv6); - ConnectPoint receivedFrom = new ConnectPoint(deviceId(deviceId), - portNumber(INPORT)); - return new DefaultInboundPacket(receivedFrom, eth, - ByteBuffer.wrap(eth.serialize())); - } - - @Override - public OutboundPacket outPacket() { - return null; - } - - @Override - public TrafficTreatment.Builder treatmentBuilder() { - return null; - } - - @Override - public void send() { - - } - - @Override - public boolean block() { - return false; - } - - @Override - public boolean isHandled() { - return false; - } - } - - /** - * Generates Router Advertisement packet. - */ - private class TestRAPacketContext implements PacketContext { - private final String deviceId; - - public TestRAPacketContext(String deviceId) { - this.deviceId = deviceId; - } - - @Override - public long time() { - return 0; - } - - @Override - public InboundPacket inPacket() { - RouterAdvertisement ns = new RouterAdvertisement(); - ICMP6 icmp6 = new ICMP6(); - icmp6.setPayload(ns); - IPv6 ipv6 = new IPv6(); - ipv6.setPayload(icmp6); - ipv6.setDestinationAddress(Ip6Address.valueOf("ff02::1").toOctets()); - ipv6.setSourceAddress(IP2); - Ethernet eth = new Ethernet(); - eth.setEtherType(Ethernet.TYPE_IPV6) - .setVlanID(VLAN.toShort()) - .setSourceMACAddress(MAC2.toBytes()) - .setDestinationMACAddress(MacAddress.valueOf("33:33:00:00:00:01")) - .setPayload(ipv6); - ConnectPoint receivedFrom = new ConnectPoint(deviceId(deviceId), - portNumber(INPORT)); - return new DefaultInboundPacket(receivedFrom, eth, - ByteBuffer.wrap(eth.serialize())); - } - - @Override - public OutboundPacket outPacket() { - return null; - } - - @Override - public TrafficTreatment.Builder treatmentBuilder() { - return null; - } - - @Override - public void send() { - - } - - @Override - public boolean block() { - return false; - } - - @Override - public boolean isHandled() { - return false; - } - } - - /** - * Generates IPv6 Multicast packet. - */ - private class TestIpv6McastPacketContext implements PacketContext { - private final String deviceId; - - public TestIpv6McastPacketContext(String deviceId) { - this.deviceId = deviceId; - } - - @Override - public long time() { - return 0; - } - - @Override - public InboundPacket inPacket() { - IPv6 ipv6 = new IPv6(); - ipv6.setDestinationAddress(Ip6Address.valueOf("ff02::1").toOctets()); - ipv6.setSourceAddress(IP2); - Ethernet eth = new Ethernet(); - eth.setEtherType(Ethernet.TYPE_IPV6) - .setVlanID(VLAN.toShort()) - .setSourceMACAddress(MAC2.toBytes()) - .setDestinationMACAddress(MacAddress.valueOf("33:33:00:00:00:01")) - .setPayload(ipv6); - ConnectPoint receivedFrom = new ConnectPoint(deviceId(deviceId), - portNumber(INPORT)); - return new DefaultInboundPacket(receivedFrom, eth, - ByteBuffer.wrap(eth.serialize())); - } - - @Override - public OutboundPacket outPacket() { - return null; - } - - @Override - public TrafficTreatment.Builder treatmentBuilder() { - return null; - } - - @Override - public void send() { - - } - - @Override - public boolean block() { - return false; - } - - @Override - public boolean isHandled() { - return false; - } - } - - /** - * Generates IPv6 Unicast packet. - */ - private class TestIpv6PacketContext implements PacketContext { - private final String deviceId; - - public TestIpv6PacketContext(String deviceId) { - this.deviceId = deviceId; - } - - @Override - public long time() { - return 0; - } - - @Override - public InboundPacket inPacket() { - IPv6 ipv6 = new IPv6(); - ipv6.setDestinationAddress(Ip6Address.valueOf("1000::1").toOctets()); - ipv6.setSourceAddress(IP2); - Ethernet eth = new Ethernet(); - eth.setEtherType(Ethernet.TYPE_IPV6) - .setVlanID(VLAN.toShort()) - .setSourceMACAddress(MAC2) - .setDestinationMACAddress(MacAddress.valueOf("00:00:00:00:00:01")) - .setPayload(ipv6); - ConnectPoint receivedFrom = new ConnectPoint(deviceId(deviceId), - portNumber(INPORT)); - return new DefaultInboundPacket(receivedFrom, eth, - ByteBuffer.wrap(eth.serialize())); - } - - @Override - public OutboundPacket outPacket() { - return null; - } - - @Override - public TrafficTreatment.Builder treatmentBuilder() { - return null; - } - - @Override - public void send() { - - } - - @Override - public boolean block() { - return false; - } - - @Override - public boolean isHandled() { - return false; - } - } - - private class TestDeviceService extends DeviceServiceAdapter { - private DeviceListener listener; - - @Override - public void addListener(DeviceListener listener) { - this.listener = listener; - } - - @Override - public Iterable<Device> getDevices() { - return Collections.emptyList(); - } - } - - private class TestHostService extends HostServiceAdapter { - @Override - public Set<Host> getConnectedHosts(ConnectPoint connectPoint) { - ConnectPoint cp1 = new ConnectPoint(deviceId(DEV1), portNumber(INPORT)); - ConnectPoint cp2 = new ConnectPoint(deviceId(DEV4), portNumber(INPORT)); - if (connectPoint.equals(cp1)) { - return ImmutableSet.of(HOST); - } else if (connectPoint.equals(cp2)) { - return ImmutableSet.of(HOST2); - } else { - return ImmutableSet.of(); - } - } - - @Override - public Set<Host> getConnectedHosts(DeviceId deviceId) { - if (deviceId.equals(deviceId(DEV1))) { - return ImmutableSet.of(HOST); - } else if (deviceId.equals(deviceId(DEV4))) { - return ImmutableSet.of(HOST2); - } else { - return ImmutableSet.of(); - } - } - - } -} |