mirrors/onos
1
0
Fork 0
mirror of https://github.com/opennetworkinglab/onos.git synced 2025-10-16 09:51:38 +02:00
Code Issues Projects Releases Wiki Activity

Juniper driver for netconf

Browse Source 
Tested with MX240 junos 14.2

Change-Id: Iba53959f9ebc98c1c3394cb387eba2784fb32210
This commit is contained in:
Michele Santuari 2016-11-14 13:31:33 +01:00 committed by Gerrit Code Review
parent 652f27f0fe
commit 21c14018a6
11 changed files with 750 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
drivers/juniper/BUCK Normal file
View File

@ -0,0 +1,26 @@
COMPILE_DEPS = [
'//lib:CORE_DEPS',
'//drivers/utilities:onos-drivers-utilities',
'//protocols/netconf/api:onos-protocols-netconf-api',
]
BUNDLES = [
':onos-drivers-juniper',
'//drivers/utilities:onos-drivers-utilities',
]
osgi_jar_with_tests (
deps = COMPILE_DEPS,
resources_root = 'src/main/resources',
resources = glob(['src/main/resources/**']),
)
onos_app (
app_name = 'org.onosproject.drivers.juniper',
title = 'Juniper Device Drivers',
category = 'Drivers',
url = 'http://onosproject.org',
description = 'ONOS Juniper Device Drivers application.',
included_bundles = BUNDLES,
required_apps = [ 'org.onosproject.netconf' ],
)

35
drivers/juniper/features.xml Normal file
View File

@ -0,0 +1,35 @@
<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<!--
~ Copyright 2016 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.
-->
<features xmlns="http://karaf.apache.org/xmlns/features/v1.2.0"
name="${project.artifactId}-${project.version}">
<feature name="${project.artifactId}" version="${project.version}"
description="${project.description}">
<feature>onos-api</feature>
<bundle>
mvn:${project.groupId}/${project.artifactId}/${project.version}
</bundle>
<bundle>
mvn:${project.groupId}/onos-drivers-utilities/${project.version}
</bundle>
<bundle>mvn:${project.groupId}/onos-netconf-api/${project.version}
</bundle>
</feature>
</features>

49
drivers/juniper/pom.xml Normal file
View File

@ -0,0 +1,49 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
~ Copyright 2016 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/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>onos-drivers-general</artifactId>
<groupId>org.onosproject</groupId>
<version>1.8.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<description>Juniper device drivers</description>
<dependencies>
<dependency>
<groupId>org.onosproject</groupId>
<artifactId>onos-netconf-api</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.onosproject</groupId>
<artifactId>onos-drivers-utilities</artifactId>
<version>${project.version}</version>
</dependency>
</dependencies>
<artifactId>onos-drivers-juniper</artifactId>
<packaging>bundle</packaging>
<properties>
<onos.app.name>org.onosproject.drivers.juniper</onos.app.name>
</properties>
</project>

89
drivers/juniper/src/main/java/org/onosproject/drivers/juniper/DeviceDiscoveryJuniperImpl.java Normal file
View File

@ -0,0 +1,89 @@
/*
* Copyright 2016 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.drivers.juniper;
import com.google.common.annotations.Beta;
import org.onosproject.drivers.utilities.XmlConfigParser;
import org.onosproject.net.DeviceId;
import org.onosproject.net.device.DeviceDescription;
import org.onosproject.net.device.DeviceDescriptionDiscovery;
import org.onosproject.net.device.PortDescription;
import org.onosproject.net.driver.AbstractHandlerBehaviour;
import org.onosproject.netconf.NetconfController;
import org.onosproject.netconf.NetconfException;
import org.onosproject.netconf.NetconfSession;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.util.List;
import static com.google.common.base.Preconditions.checkNotNull;
import static org.onosproject.drivers.juniper.JuniperUtils.FAILED_CFG;
import static org.onosproject.drivers.juniper.JuniperUtils.REQ_IF_INFO;
import static org.onosproject.drivers.juniper.JuniperUtils.REQ_MAC_ADD_INFO;
import static org.onosproject.drivers.juniper.JuniperUtils.REQ_SYS_INFO;
import static org.onosproject.drivers.juniper.JuniperUtils.requestBuilder;
import static org.slf4j.LoggerFactory.getLogger;
/**
* Retrieve the Device information and ports via NETCONF for Juniper Router.
* Tested with MX240 junos 14.2
*/
@Beta
public class DeviceDiscoveryJuniperImpl extends AbstractHandlerBehaviour
implements DeviceDescriptionDiscovery {
public final org.slf4j.Logger log = getLogger(getClass());
@Override
public DeviceDescription discoverDeviceDetails() {
DeviceId deviceId = handler().data().deviceId();
NetconfController controller = checkNotNull(handler().get(NetconfController.class));
NetconfSession session = controller.getDevicesMap().get(deviceId).getSession();
String sysInfo;
String chassis;
try {
sysInfo = session.get(requestBuilder(REQ_SYS_INFO));
chassis = session.get(requestBuilder(REQ_MAC_ADD_INFO));
} catch (IOException e) {
throw new RuntimeException(new NetconfException(FAILED_CFG, e));
}
DeviceDescription description =
JuniperUtils.parseJuniperDescription(deviceId, XmlConfigParser.
loadXml(new ByteArrayInputStream(sysInfo.getBytes())), chassis);
log.debug("Device description {}", description);
return description;
}
@Override
public List<PortDescription> discoverPortDetails() {
NetconfController controller = checkNotNull(handler().get(NetconfController.class));
NetconfSession session = controller.getDevicesMap().get(handler().data().deviceId()).getSession();
String reply;
try {
reply = session.get(requestBuilder(REQ_IF_INFO));
} catch (IOException e) {
throw new RuntimeException(new NetconfException(FAILED_CFG, e));
}
List<PortDescription> descriptions =
JuniperUtils.parseJuniperPorts(XmlConfigParser.
loadXml(new ByteArrayInputStream(reply.getBytes())));
log.debug("Discovered ports {}", descriptions);
return descriptions;
}
}

27
drivers/juniper/src/main/java/org/onosproject/drivers/juniper/JuniperDriversLoader.java Normal file
View File

@ -0,0 +1,27 @@
/*
* Copyright 2016 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.drivers.juniper;
import org.apache.felix.scr.annotations.Component;
import org.onosproject.net.driver.AbstractDriverLoader;
@Component(immediate = true)
public class JuniperDriversLoader extends AbstractDriverLoader {
public JuniperDriversLoader() {
super("/juniper-drivers.xml");
}
}

339
drivers/juniper/src/main/java/org/onosproject/drivers/juniper/JuniperUtils.java Normal file
View File

@ -0,0 +1,339 @@
/*
* Copyright 2016-present 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.drivers.juniper;
import com.google.common.collect.Lists;
import org.apache.commons.configuration.HierarchicalConfiguration;
import org.onlab.packet.ChassisId;
import org.onlab.packet.MacAddress;
import org.onosproject.net.AnnotationKeys;
import org.onosproject.net.ConnectPoint;
import org.onosproject.net.DefaultAnnotations;
import org.onosproject.net.DeviceId;
import org.onosproject.net.Link;
import org.onosproject.net.Port;
import org.onosproject.net.PortNumber;
import org.onosproject.net.device.DefaultDeviceDescription;
import org.onosproject.net.device.DefaultPortDescription;
import org.onosproject.net.device.DeviceDescription;
import org.onosproject.net.device.PortDescription;
import org.onosproject.net.link.DefaultLinkDescription;
import org.onosproject.net.link.LinkDescription;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import static java.lang.Integer.parseInt;
import static org.onosproject.net.DefaultAnnotations.Builder;
import static org.onosproject.net.Device.Type.ROUTER;
import static org.onosproject.net.Port.Type.COPPER;
import static org.onosproject.net.PortNumber.portNumber;
/**
* Utility class for Netconf XML for Juniper.
* Tested with MX240 junos 14.2
*/
public final class JuniperUtils {
public static final String FAILED_CFG = "Failed to retrieve configuration.";
private static final String RPC_TAG_NETCONF_BASE = "<rpc xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\">";
private static final String RPC_CLOSE_TAG = "</rpc>";
//requests
public static final String REQ_LLDP_NBR_INFO = "<get-lldp-neighbors-information/>";
public static final String REQ_SYS_INFO = "<get-system-information/>";
public static final String REQ_MAC_ADD_INFO = "<get-chassis-mac-addresses/>";
public static final String REQ_IF_INFO = "<get-interface-information/>";
//helper strings for parsing
private static final String LLDP_NBR_INFO = "lldp-neighbors-information";
private static final String SYS_INFO = "system-information";
private static final String HW_MODEL = "hardware-model";
private static final String OS_NAME = "os-name";
private static final String OS_VER = "os-version";
private static final String SER_NUM = "serial-number";
private static final String IF_INFO = "interface-information";
private static final String IF_PHY = "physical-interface";
private static final String IF_TYPE = "if-type";
private static final String SPEED = "speed";
private static final String ETH = "Ethernet";
private static final String MBPS = "mbps";
private static final String NAME = "name";
private static final String IF_LO_ENCAP = "logical-interface.encapsulation";
private static final String IF_LO_NAME = "logical-interface.name";
private static final String IF_LO_ADD =
"logical-interface.address-family.interface-address.ifa-local";
private static final String LO_INDEX = "local-index";
private static final String STATUS = "admin-status";
private static final String SNMP_INDEX = "snmp-index";
private static final String IF_LO_INDEX = "logical-interface.local-index";
private static final String IF_LO_STATUS =
"logical-interface.if-config-flags.iff-up";
private static final String LLDP_LO_PORT = "lldp-local-port-id";
private static final String LLDP_REM_CHASS = "lldp-remote-chassis-id";
private static final String LLDP_REM_PORT = "lldp-remote-port-id";
private static final String REGEX_ADD =
".*Private base address\\s*([:,0-9,a-f,A-F]*).*";
private static final Pattern ADD_PATTERN =
Pattern.compile(REGEX_ADD, Pattern.DOTALL);
private static final String JUNIPER = "JUNIPER";
private static final String UNKNOWN = "UNKNOWN";
private static final long DEFAULT_PORT_SPEED = 1000;
private JuniperUtils() {
//not called, preventing any allocation
}
/**
* Helper method to build a XML schema given a request.
*
* @param request a tag element of the XML schema
* @return string containing the XML schema
*/
public static String requestBuilder(String request) {
return RPC_TAG_NETCONF_BASE +
request + RPC_CLOSE_TAG;
}
/**
* Parses device configuration and returns the device description.
*
* @param deviceId the id of the device
* @param sysInfoCfg system configuration
* @param chassisText chassis string
* @return device description
*/
public static DeviceDescription parseJuniperDescription(DeviceId deviceId,
HierarchicalConfiguration sysInfoCfg,
String chassisText) {
HierarchicalConfiguration info = sysInfoCfg.configurationAt(SYS_INFO);
String hw = info.getString(HW_MODEL) == null ? UNKNOWN : info.getString(HW_MODEL);
String sw = UNKNOWN;
if (info.getString(OS_NAME) != null || info.getString(OS_VER) != null) {
sw = info.getString(OS_NAME) + " " + info.getString(OS_VER);
}
String serial = info.getString(SER_NUM) == null ? UNKNOWN : info.getString(SER_NUM);
Matcher matcher = ADD_PATTERN.matcher(chassisText);
if (matcher.lookingAt()) {
String chassis = matcher.group(1);
MacAddress chassisMac = MacAddress.valueOf(chassis);
return new DefaultDeviceDescription(deviceId.uri(), ROUTER,
JUNIPER, hw, sw, serial,
new ChassisId(chassisMac.toLong()),
DefaultAnnotations.EMPTY);
}
return new DefaultDeviceDescription(deviceId.uri(), ROUTER,
JUNIPER, hw, sw, serial,
null, DefaultAnnotations.EMPTY);
}
/**
* Parses device ports configuration and returns a list of
* port description.
*
* @param cfg interface configuration
* @return list of interface descriptions of the device
*/
public static List<PortDescription> parseJuniperPorts(HierarchicalConfiguration cfg) {
//This methods ignores some internal ports
List<PortDescription> portDescriptions = Lists.newArrayList();
List<HierarchicalConfiguration> subtrees =
cfg.configurationsAt(IF_INFO);
for (HierarchicalConfiguration interfInfo : subtrees) {
List<HierarchicalConfiguration> interfaceTree =
interfInfo.configurationsAt(IF_PHY);
for (HierarchicalConfiguration interf : interfaceTree) {
if (interf != null) {
if (interf.getString(IF_TYPE) != null &&
interf.getString(SPEED) != null) {
if (interf.getString(IF_TYPE).contains(ETH) &&
interf.getString(SPEED).contains(MBPS)) {
portDescriptions.add(parseDefaultPort(interf));
}
} else if (interf.getString(IF_LO_ENCAP) != null &&
!interf.getString(NAME).contains("pfe") &&
interf.getString(IF_LO_ENCAP).contains("ENET2")) {
portDescriptions.add(parseLogicalPort(interf));
} else if (interf.getString(NAME).contains("lo")) {
portDescriptions.add(parseLoopback(interf));
}
}
}
}
return portDescriptions;
}
private static PortDescription parseLoopback(HierarchicalConfiguration cfg) {
String name = cfg.getString(IF_LO_NAME).trim();
PortNumber portNumber = portNumber(name.replace("lo0.", ""));
Builder annotationsBuilder = DefaultAnnotations.builder()
.set(AnnotationKeys.PORT_NAME, name);
String ip = cfg.getString(IF_LO_ADD);
if (ip != null) {
annotationsBuilder.set("ip", ip);
}
return new DefaultPortDescription(portNumber,
true,
COPPER,
DEFAULT_PORT_SPEED,
annotationsBuilder.build());
}
private static DefaultPortDescription parseDefaultPort(HierarchicalConfiguration cfg) {
PortNumber portNumber = portNumber(cfg.getString(LO_INDEX));
boolean enabled = cfg.getString(STATUS).equals("up");
int speed = parseInt(cfg.getString(SPEED).replaceAll(MBPS, ""));
Builder annotationsBuilder = DefaultAnnotations.builder()
.set(AnnotationKeys.PORT_NAME, cfg.getString(NAME).trim());
setIpIfPresent(cfg, annotationsBuilder);
return new DefaultPortDescription(portNumber,
enabled,
COPPER,
speed,
annotationsBuilder.build());
}
private static DefaultPortDescription parseLogicalPort(HierarchicalConfiguration cfg) {
String name = cfg.getString(NAME).trim();
String index = cfg.getString(SNMP_INDEX).trim();
Builder annotationsBuilder = DefaultAnnotations.builder()
.set(AnnotationKeys.PORT_NAME, name)
.set("index", index);
setIpIfPresent(cfg, annotationsBuilder);
PortNumber portNumber = portNumberFromName(cfg.getString(IF_LO_INDEX), name);
boolean enabled = false;
if (cfg.getString(IF_LO_STATUS) != null) {
enabled = true;
}
//FIXME: port speed should be exposed
return new DefaultPortDescription(
portNumber,
enabled,
COPPER,
DEFAULT_PORT_SPEED,
annotationsBuilder.build());
}
private static PortNumber portNumberFromName(String ifIndex, String name) {
PortNumber portNumber = portNumber(ifIndex);
if (name.contains("-")) {
String[] splitted = name.split("-");
String typeInt = "[" + splitted[0] + "]";
String number = splitted[1].replace("/", "");
number = "(" + number + ")";
portNumber = PortNumber.fromString(typeInt + number);
}
return portNumber;
}
private static void setIpIfPresent(HierarchicalConfiguration cfg,
Builder annotationsBuilder) {
String ip = cfg.getString(IF_LO_ADD);
if (ip != null) {
annotationsBuilder.set("ip", ip);
}
}
/**
* Create two LinkDescriptions corresponding to the bidirectional links.
*
* @param localDevId the identity of the local device
* @param localPort the port of the local device
* @param remoteDevId the identity of the remote device
* @param remotePort the port of the remote device
* @param descs the collection to which the link descriptions
* should be added
*/
public static void createBiDirLinkDescription(DeviceId localDevId,
Port localPort,
DeviceId remoteDevId,
Port remotePort,
Set<LinkDescription> descs) {
ConnectPoint local = new ConnectPoint(localDevId, localPort.number());
ConnectPoint remote = new ConnectPoint(remoteDevId, remotePort.number());
DefaultAnnotations annotations = DefaultAnnotations.builder()
.set("layer", "IP")
.build();
descs.add(new DefaultLinkDescription(
local, remote, Link.Type.INDIRECT, false, annotations));
descs.add(new DefaultLinkDescription(
remote, local, Link.Type.INDIRECT, false, annotations));
}
/**
* Parses neighbours discovery information and returns a list of
* link abstractions.
*
* @param info interface configuration
* @return set of link abstractions
*/
public static Set<LinkAbstraction> parseJuniperLldp(HierarchicalConfiguration info) {
Set<LinkAbstraction> neighbour = new HashSet<>();
List<HierarchicalConfiguration> subtrees =
info.configurationsAt(LLDP_NBR_INFO);
for (HierarchicalConfiguration neighborsInfo : subtrees) {
List<HierarchicalConfiguration> neighbors =
neighborsInfo.configurationsAt(LLDP_NBR_INFO);
for (HierarchicalConfiguration neighbor : neighbors) {
String localPortName = neighbor.getString(LLDP_LO_PORT);
MacAddress mac = MacAddress.valueOf(
neighbor.getString(LLDP_REM_CHASS));
int remotePortIndex =
neighbor.getInt(LLDP_REM_PORT);
LinkAbstraction link = new LinkAbstraction(
localPortName,
mac.toLong(),
remotePortIndex);
neighbour.add(link);
}
}
return neighbour;
}
/**
* Device representation of the adjacency at the IP Layer.
*/
protected static final class LinkAbstraction {
protected String localPortName;
protected ChassisId remoteChassisId;
protected int remotePortIndex;
protected LinkAbstraction(String pName, long chassisId, int pIndex) {
this.localPortName = pName;
this.remoteChassisId = new ChassisId(chassisId);
this.remotePortIndex = pIndex;
}
}
}

138
drivers/juniper/src/main/java/org/onosproject/drivers/juniper/LinkDiscoveryJuniperImpl.java Normal file
View File

@ -0,0 +1,138 @@
/*
* Copyright 2016-present 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.drivers.juniper;
//import com.google.common.base.Optional;
import com.google.common.annotations.Beta;
import com.google.common.collect.Iterables;
import org.onosproject.drivers.utilities.XmlConfigParser;
import org.onosproject.net.Device;
import org.onosproject.net.DeviceId;
import org.onosproject.net.Port;
import org.onosproject.net.behaviour.LinkDiscovery;
import org.onosproject.net.device.DeviceService;
import org.onosproject.net.driver.AbstractHandlerBehaviour;
import org.onosproject.net.link.LinkDescription;
import org.onosproject.netconf.NetconfController;
import org.onosproject.netconf.NetconfException;
import org.onosproject.netconf.NetconfSession;
import org.slf4j.Logger;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.util.HashSet;
import java.util.Optional;
import java.util.Set;
import static com.google.common.base.Preconditions.checkNotNull;
import static org.onosproject.drivers.juniper.JuniperUtils.LinkAbstraction;
import static org.onosproject.drivers.juniper.JuniperUtils.parseJuniperLldp;
import static org.onosproject.drivers.juniper.JuniperUtils.requestBuilder;
import static org.onosproject.net.AnnotationKeys.PORT_NAME;
import static org.onosproject.drivers.juniper.JuniperUtils.REQ_LLDP_NBR_INFO;
import static org.onosproject.drivers.juniper.JuniperUtils.FAILED_CFG;
import static org.slf4j.LoggerFactory.getLogger;
/**
* Retrieve Links discovered by the device LLDP.
* Tested with MX240 junos 14.2
*/
@Beta
public class LinkDiscoveryJuniperImpl extends AbstractHandlerBehaviour
implements LinkDiscovery {
private final Logger log = getLogger(getClass());
@Override
public Set<LinkDescription> getLinks() {
DeviceId localDeviceId = this.handler().data().deviceId();
NetconfController controller =
checkNotNull(handler().get(NetconfController.class));
NetconfSession session =
controller.getDevicesMap().get(localDeviceId).getSession();
String reply;
try {
reply = session.get(requestBuilder(REQ_LLDP_NBR_INFO));
} catch (IOException e) {
throw new RuntimeException(new NetconfException(FAILED_CFG, e));
}
log.debug("Reply from device {} : {}", localDeviceId, reply);
Set<LinkAbstraction> linkAbstractions = parseJuniperLldp(
XmlConfigParser.loadXml(new ByteArrayInputStream(reply.getBytes())));
log.debug("Set of LinkAbstraction discovered {}", linkAbstractions);
DeviceService deviceService = this.handler().get(DeviceService.class);
Set<LinkDescription> descriptions = new HashSet<>();
//for each lldp neighbor create two LinkDescription
for (LinkAbstraction linkAbs : linkAbstractions) {
//find source port by local port name
Optional<Port> localPort = deviceService.getPorts(localDeviceId).stream()
.filter(port -> {
if (linkAbs.localPortName.equals(
port.annotations().value(PORT_NAME))) {
return true;
}
return false;
}).findAny();
if (!localPort.isPresent()) {
log.warn("Port name {} does not exist in device {}",
linkAbs.localPortName, localDeviceId);
continue;
}
//find destination device by remote chassis id
com.google.common.base.Optional<Device> dev = Iterables.tryFind(
deviceService.getAvailableDevices(),
input -> input.chassisId().equals(linkAbs.remoteChassisId));
if (!dev.isPresent()) {
log.warn("Device with chassis ID {} does not exist",
linkAbs.remoteChassisId);
continue;
}
Device remoteDevice = dev.get();
//find destination port by interface index
Optional<Port> remotePort = deviceService.getPorts(remoteDevice.id())
.stream().filter(port -> {
if (port.annotations().value("index") != null &&
Integer.parseInt(port.annotations().value("index"))
== linkAbs.remotePortIndex) {
return true;
}
return false;
}).findAny();
if (!remotePort.isPresent()) {
log.warn("Port with index {} does not exist in device {}",
linkAbs.remotePortIndex, remoteDevice.id());
continue;
}
JuniperUtils.createBiDirLinkDescription(localDeviceId,
localPort.get(),
remoteDevice.id(),
remotePort.get(),
descriptions);
}
return descriptions;
}
}

20
drivers/juniper/src/main/java/org/onosproject/drivers/juniper/package-info.java Normal file
View File

@ -0,0 +1,20 @@
/*
* Copyright 2016 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 for juniper device drivers.
*/
package org.onosproject.drivers.juniper;

25
drivers/juniper/src/main/resources/juniper-drivers.xml Normal file
View File

@ -0,0 +1,25 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
~ Copyright 2016 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.
-->
<drivers>
<driver name="juniper-netconf" manufacturer="Juniper"
hwVersion="" swVersion="JunOS">
<behaviour api="org.onosproject.net.device.DeviceDescriptionDiscovery"
impl="org.onosproject.drivers.juniper.DeviceDiscoveryJuniperImpl"/>
<behaviour api="org.onosproject.net.behaviour.LinkDiscovery"
impl="org.onosproject.drivers.juniper.LinkDiscoveryJuniperImpl"/>
</driver>
</drivers>

1
drivers/pom.xml
View File

@ -45,6 +45,7 @@
<module>corsa</module> <module>corsa</module>
<module>optical</module> <module>optical</module>
<module>arista</module> <module>arista</module>
<module>juniper</module>
</modules> </modules>
<!--<properties> <!--<properties>

1
modules.defs
View File

@ -87,6 +87,7 @@ ONOS_DRIVERS = [
'//drivers/netconf:onos-drivers-netconf-oar', '//drivers/netconf:onos-drivers-netconf-oar',
'//drivers/optical:onos-drivers-optical-oar', '//drivers/optical:onos-drivers-optical-oar',
'//drivers/ovsdb:onos-drivers-ovsdb-oar', '//drivers/ovsdb:onos-drivers-ovsdb-oar',
'//drivers/juniper:onos-drivers-juniper-oar',
] ]
ONOS_PROVIDERS = [ ONOS_PROVIDERS = [