diff options
Diffstat (limited to 'framework/src/onos/drivers/src/main/java/org/onosproject/driver/handshaker/OFOpticalSwitch13.java')
-rw-r--r-- | framework/src/onos/drivers/src/main/java/org/onosproject/driver/handshaker/OFOpticalSwitch13.java | 179 |
1 files changed, 0 insertions, 179 deletions
diff --git a/framework/src/onos/drivers/src/main/java/org/onosproject/driver/handshaker/OFOpticalSwitch13.java b/framework/src/onos/drivers/src/main/java/org/onosproject/driver/handshaker/OFOpticalSwitch13.java deleted file mode 100644 index 5c6ce360..00000000 --- a/framework/src/onos/drivers/src/main/java/org/onosproject/driver/handshaker/OFOpticalSwitch13.java +++ /dev/null @@ -1,179 +0,0 @@ -/* - * Copyright 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.driver.handshaker; - -import org.projectfloodlight.openflow.protocol.OFExpPort; -import org.projectfloodlight.openflow.protocol.OFExpPortDescReply; -import org.projectfloodlight.openflow.protocol.OFExpPortDescRequest; -import org.projectfloodlight.openflow.protocol.OFMessage; -import org.projectfloodlight.openflow.protocol.OFPortDesc; -import org.projectfloodlight.openflow.protocol.OFStatsReply; -import org.projectfloodlight.openflow.protocol.OFStatsReplyFlags; -import org.projectfloodlight.openflow.protocol.OFStatsType; - -import java.io.IOException; -import java.util.ArrayList; -import java.util.List; -import java.util.Set; -import java.util.concurrent.atomic.AtomicBoolean; -import java.util.stream.Collectors; - -import org.onosproject.net.Device; -import org.onosproject.openflow.controller.OpenFlowOpticalSwitch; -import org.onosproject.openflow.controller.PortDescPropertyType; -import org.onosproject.openflow.controller.driver.AbstractOpenFlowSwitch; -import org.onosproject.openflow.controller.driver.SwitchDriverSubHandshakeAlreadyStarted; -import org.onosproject.openflow.controller.driver.SwitchDriverSubHandshakeCompleted; -import org.onosproject.openflow.controller.driver.SwitchDriverSubHandshakeNotStarted; -import org.projectfloodlight.openflow.protocol.OFObject; - -import com.google.common.collect.ImmutableList; -import com.google.common.collect.ImmutableSet; - - -/** - * Open Flow Optical Switch handshaker - for Open Flow 13. - */ -public class OFOpticalSwitch13 extends AbstractOpenFlowSwitch implements OpenFlowOpticalSwitch { - - private final AtomicBoolean driverHandshakeComplete = new AtomicBoolean(false); - private List<OFExpPort> expPortDes = new ArrayList<>(); - - @Override - public Boolean supportNxRole() { - return false; - } - - @Override - public void startDriverHandshake() { - log.info("Starting driver handshake for sw {}", getStringId()); - if (startDriverHandshakeCalled) { - throw new SwitchDriverSubHandshakeAlreadyStarted(); - } - startDriverHandshakeCalled = true; - - log.debug("sendHandshakeOFExperimenterPortDescRequest for sw {}", getStringId()); - - try { - sendHandshakeOFExperimenterPortDescRequest(); - } catch (IOException e) { - log.error("Failed to send handshaker message OFExperimenterPortDescRequestfor sw {}, {}", - getStringId(), e.getMessage()); - e.printStackTrace(); - } - } - - @Override - public void processDriverHandshakeMessage(OFMessage m) { - if (!startDriverHandshakeCalled) { - throw new SwitchDriverSubHandshakeNotStarted(); - } - if (driverHandshakeComplete.get()) { - throw new SwitchDriverSubHandshakeCompleted(m); - } - - log.debug("processDriverHandshakeMessage for sw {}", getStringId()); - - switch (m.getType()) { - case STATS_REPLY: // multipart message is reported as STAT - processOFMultipartReply((OFStatsReply) m); - break; - default: - log.warn("Received message {} during switch-driver " + - "subhandshake " + "from switch {} ... " + - "Ignoring message", m, - getStringId()); - } - } - - private void processOFMultipartReply(OFStatsReply stats) { - log.debug("Received message {} during switch-driver " + - "subhandshake " + "from switch {} ... " + - stats, - getStringId()); - - if (stats.getStatsType() == OFStatsType.EXPERIMENTER) { - try { - OFExpPortDescReply expPortDescReply = (OFExpPortDescReply) stats; - expPortDes.addAll(expPortDescReply.getEntries()); - if (!expPortDescReply.getFlags().contains(OFStatsReplyFlags.REPLY_MORE)) { - driverHandshakeComplete.set(true); - return; - } - } catch (ClassCastException e) { - log.error("Unexspected Experimenter Multipart message type {} " - , stats.getClass().getName()); - } - } - } - - - @Override - public boolean isDriverHandshakeComplete() { - return driverHandshakeComplete.get(); - } - - private void sendHandshakeOFExperimenterPortDescRequest() throws - IOException { - - OFExpPortDescRequest preq = factory() - .buildExpPortDescRequest() - .setXid(getNextTransactionId()) - .build(); - - log.debug("Sending experimented port description " + - "message " + - "{}", - preq.toString()); - - this.sendHandshakeMessage(preq); - } - - @Override - public Device.Type deviceType() { - String hwDesc = hardwareDescription(); - switch (hwDesc) { - case "Optical-ROADM": - return Device.Type.ROADM; - case "Optical-OTN": - return Device.Type.OTN; - default: - log.error("Unsupported hardwareDescription {}", hwDesc); - return Device.Type.OTHER; - } - } - - /* - * OduClt ports are reported as regular ETH ports. - */ - @Override - public List<OFPortDesc> getPorts() { - return ImmutableList.copyOf( - ports.stream().flatMap(p -> p.getEntries().stream()) - .collect(Collectors.toList())); - } - - @Override - public List<? extends OFObject> getPortsOf(PortDescPropertyType type) { - return ImmutableList.copyOf(expPortDes); - } - - @Override - public Set<PortDescPropertyType> getPortTypes() { - return ImmutableSet.of(PortDescPropertyType.OPTICAL_TRANSPORT); - } - -} |