2 * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.openflowplugin.openflow.md.core.translator;
10 import java.math.BigInteger;
11 import java.util.Collections;
12 import java.util.List;
14 import org.opendaylight.openflowplugin.openflow.md.core.IMDMessageTranslator;
15 import org.opendaylight.openflowplugin.openflow.md.core.SwitchConnectionDistinguisher;
16 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.match.MatchConvertorImpl;
17 import org.opendaylight.openflowplugin.openflow.md.core.session.SessionContext;
18 import org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil;
19 import org.opendaylight.openflowplugin.openflow.md.util.PacketInUtil;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.FlowCookie;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.Match;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.PortNumberMatchEntry;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.oxm.fields.grouping.MatchEntries;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetFeaturesOutput;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketInMessage;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketReceived;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketReceivedBuilder;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.packet.received.MatchBuilder;
30 import org.opendaylight.yangtools.yang.binding.DataObject;
31 import org.slf4j.Logger;
32 import org.slf4j.LoggerFactory;
35 * translates packetIn from OF-API model to MD-SAL model, supports OF-1.3
37 public class PacketInTranslator implements IMDMessageTranslator<OfHeader, List<DataObject>> {
39 protected static final Logger LOG = LoggerFactory
40 .getLogger(PacketInTranslator.class);
42 public List<DataObject> translate(final SwitchConnectionDistinguisher cookie,
43 final SessionContext sc, final OfHeader msg) {
45 List<DataObject> salPacketIn = Collections.emptyList();
47 if (sc != null && msg instanceof PacketInMessage) {
48 PacketInMessage message = (PacketInMessage)msg;
49 LOG.trace("PacketIn[v{}]: Cookie: {} Match.type: {}",
50 message.getVersion(), message.getCookie(),
51 message.getMatch() != null ? message.getMatch().getType() : message.getMatch());
53 // create a packet received event builder
54 PacketReceivedBuilder pktInBuilder = new PacketReceivedBuilder();
55 pktInBuilder.setPayload(message.getData());
56 //TODO: add connection cookie
57 //pktInBuilder.setConnectionCookie(new ConnectionCookie(cookie.getId()));
60 GetFeaturesOutput features = sc.getFeatures();
61 // Make sure we actually have features, some naughty switches start sending packetIn before they send us the FeatureReply
62 if ( features == null) {
63 LOG.warn("Received packet_in, but there is no device datapathId received yet");
65 BigInteger dpid = features.getDatapathId();
67 // get the Cookie if it exists
68 if(message.getCookie() != null) {
69 pktInBuilder.setFlowCookie(new FlowCookie(message.getCookie()));
71 //TODO: use either canonical mapping or suitable hash -> 32b
72 //pktInBuilder.setConnectionCookie(cookie);
74 // extract the port number
76 if (message.getMatch() != null && message.getMatch().getMatchEntries() != null) {
77 List<MatchEntries> entries = message.getMatch().getMatchEntries();
78 for (MatchEntries entry : entries) {
79 PortNumberMatchEntry tmp = entry.getAugmentation(PortNumberMatchEntry.class);
82 port = tmp.getPortNumber().getValue();
84 LOG.warn("Multiple input ports discovered when walking through match entries (at least {} and {})",
85 port, tmp.getPortNumber().getValue());
92 // no incoming port, so drop the event
93 LOG.warn("Received packet_in, but couldn't find an input port");
95 LOG.trace("Received packet_in from {} on port {}", dpid, port);
97 Match match = MatchConvertorImpl.fromOFMatchToSALMatch(message.getMatch(),dpid);
98 MatchBuilder matchBuilder = new MatchBuilder(match);
99 pktInBuilder.setMatch(matchBuilder.build());
101 pktInBuilder.setPacketInReason(PacketInUtil.getMdSalPacketInReason(message.getReason()));
102 pktInBuilder.setTableId(new org.opendaylight.yang.gen.v1.urn.opendaylight.table.types.rev131026.TableId(message.getTableId().getValue().shortValue()));
103 pktInBuilder.setIngress(InventoryDataServiceUtil.nodeConnectorRefFromDatapathIdPortno(dpid,port));
104 PacketReceived pktInEvent = pktInBuilder.build();
105 salPacketIn = Collections.<DataObject>singletonList(pktInEvent);