1 package org.opendaylight.openflowplugin.openflow.md.core.translator;
3 import java.math.BigInteger;
5 import java.util.concurrent.CopyOnWriteArrayList;
7 import org.opendaylight.openflowplugin.openflow.md.core.IMDMessageTranslator;
8 import org.opendaylight.openflowplugin.openflow.md.core.SwitchConnectionDistinguisher;
9 import org.opendaylight.openflowplugin.openflow.md.core.session.SessionContext;
10 import org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil;
11 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PortNumberMatchEntry;
12 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.oxm.fields.MatchEntries;
13 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetFeaturesOutput;
14 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketInMessage;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.Cookie;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketReceived;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketReceivedBuilder;
19 import org.opendaylight.yangtools.yang.binding.DataObject;
20 import org.slf4j.Logger;
21 import org.slf4j.LoggerFactory;
23 public class PacketInTranslator implements IMDMessageTranslator<OfHeader, List<DataObject>> {
25 protected static final Logger LOG = LoggerFactory
26 .getLogger(PacketInTranslator.class);
28 public List<DataObject> translate(SwitchConnectionDistinguisher cookie,
29 SessionContext sc, OfHeader msg) {
30 if(msg instanceof PacketInMessage) {
31 PacketInMessage message = (PacketInMessage)msg;
32 List<DataObject> list = new CopyOnWriteArrayList<DataObject>();
33 LOG.info("PacketIn: InPort: {} Cookie: {} Match.type: {}",
34 message.getInPort(), message.getCookie(),
35 message.getMatch() != null ? message.getMatch().getType()
36 : message.getMatch());
38 // create a packet received event builder
39 PacketReceivedBuilder pktInBuilder = new PacketReceivedBuilder();
40 pktInBuilder.setPayload(message.getData());
43 GetFeaturesOutput features = sc.getFeatures();
44 BigInteger dpid = features.getDatapathId();
46 // get the Cookie if it exists
47 if(message.getCookie() != null) {
48 pktInBuilder.setCookie(new Cookie(message.getCookie().longValue()));
51 // extract the port number
54 if (message.getInPort() != null) {
55 // this doesn't work--at least for OF1.3
56 port = message.getInPort().longValue();
59 // this should work for OF1.3
60 if (message.getMatch() != null && message.getMatch().getMatchEntries() != null) {
61 List<MatchEntries> entries = message.getMatch().getMatchEntries();
62 for (MatchEntries entry : entries) {
63 PortNumberMatchEntry tmp = entry.getAugmentation(PortNumberMatchEntry.class);
66 port = tmp.getPortNumber().getValue();
68 LOG.warn("Multiple input ports (at least {} and {})",
69 port, tmp.getPortNumber().getValue());
76 // no incoming port, so drop the event
77 LOG.warn("Received packet_in, but couldn't find an input port");
80 LOG.info("Receive packet_in from {} on port {}", dpid, port);
82 pktInBuilder.setIngress(InventoryDataServiceUtil.nodeConnectorRefFromDatapathIdPortno(dpid,port));
83 PacketReceived pktInEvent = pktInBuilder.build();