opendaylight/md-sal/compatibility/sal-compatibility/src/main/java/org/opendaylight/controller/sal/compatibility/DataPacketAdapter.xtend

   1 package org.opendaylight.controller.sal.compatibility
   2
   3 import org.opendaylight.controller.sal.packet.IPluginOutDataPacketService
   4 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingListener
   5 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketReceived
   6 import org.opendaylight.controller.sal.packet.RawPacket
   7
   8 class DataPacketAdapter implements PacketProcessingListener {
   9
  10     @Property
  11     IPluginOutDataPacketService dataPacketPublisher;
  12
  13     override onPacketReceived(PacketReceived packet) {
  14         val RawPacket inPacket = packet.toRawPacket();
  15         dataPacketPublisher.receiveDataPacket(inPacket);
  16     }
  17
  18     public static def RawPacket toRawPacket(PacketReceived received) {
  19         val ret = new RawPacket(received.payload);
  20         ret.setIncomingNodeConnector(NodeMapping.toADNodeConnector(received.ingress))
  21         return ret;
  22     }
  23
  24 }