1 package org.opendaylight.openflowplugin.openflow.md.core.translator;
3 import java.math.BigInteger;
4 import java.util.Collections;
6 import java.util.concurrent.CopyOnWriteArrayList;
8 import org.opendaylight.openflowplugin.openflow.md.OFConstants;
9 import org.opendaylight.openflowplugin.openflow.md.core.IMDMessageTranslator;
10 import org.opendaylight.openflowplugin.openflow.md.core.SwitchConnectionDistinguisher;
11 import org.opendaylight.openflowplugin.openflow.md.core.session.SessionContext;
12 import org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil;
13 import org.opendaylight.openflowplugin.openflow.md.util.PortTranslatorUtil;
14 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorUpdated;
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorUpdatedBuilder;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorUpdatedBuilder;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfig;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessage;
20 import org.opendaylight.yangtools.yang.binding.DataObject;
21 import org.slf4j.Logger;
22 import org.slf4j.LoggerFactory;
24 public class PortStatusMessageToNodeConnectorUpdatedTranslator implements IMDMessageTranslator<OfHeader, List<DataObject>> {
25 protected static final Logger LOG = LoggerFactory
26 .getLogger(PortStatusMessageToNodeConnectorUpdatedTranslator.class);
29 public List<DataObject> translate(SwitchConnectionDistinguisher cookie,
30 SessionContext sc, OfHeader msg) {
31 if(msg instanceof PortStatusMessage) {
32 PortStatusMessage port = (PortStatusMessage)msg;
33 List<DataObject> list = new CopyOnWriteArrayList<DataObject>();
34 BigInteger datapathId = sc.getFeatures().getDatapathId();
35 Long portNo = port.getPortNo();
36 Short version = port.getVersion();
37 LOG.error("PortStatusMessage: version {} dataPathId {} portNo {}",version, datapathId,portNo);
38 list.add(PortTranslatorUtil.translatePort(version, datapathId, portNo, port));
41 // TODO - Do something smarter than returning null if translation fails... what Exception should we throw here?
42 return Collections.emptyList();