l2switch-main/implementation/src/main/java/org/opendaylight/l2switch/flow/ReactiveFlowWriter.java

   1 /*
   2  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   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
   7  */
   8 package org.opendaylight.l2switch.flow;
   9
  10 import org.opendaylight.l2switch.inventory.InventoryReader;
  11 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.MacAddress;
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRef;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.arp.rev140528.ArpPacketListener;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.arp.rev140528.ArpPacketReceived;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.arp.rev140528.arp.packet.received.packet.chain.packet.ArpPacket;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.basepacket.rev140528.packet.chain.grp.PacketChain;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.basepacket.rev140528.packet.chain.grp.packet.chain.packet.RawPacket;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.ethernet.rev140528.ethernet.packet.received.packet.chain.packet.EthernetPacket;
  20
  21 /**
  22  * This class listens to certain type of packets and writes
  23  * a mac to mac flows.
  24  */
  25 public class ReactiveFlowWriter implements ArpPacketListener {
  26   private InventoryReader inventoryReader;
  27   private FlowWriterService flowWriterService;
  28   private final MacAddress MAC_TO_IGNORE = new MacAddress("ff:ff:ff:ff:ff:ff");
  29
  30   public ReactiveFlowWriter(InventoryReader inventoryReader, FlowWriterService flowWriterService) {
  31     this.inventoryReader = inventoryReader;
  32     this.flowWriterService = flowWriterService;
  33   }
  34
  35   @Override
  36   public void onArpPacketReceived(ArpPacketReceived packetReceived) {
  37     if(packetReceived == null || packetReceived.getPacketChain() == null) {
  38       return;
  39     }
  40
  41     RawPacket rawPacket = null;
  42     EthernetPacket ethernetPacket = null;
  43     ArpPacket arpPacket = null;
  44     for(PacketChain packetChain : packetReceived.getPacketChain()) {
  45       if(packetChain.getPacket() instanceof RawPacket) {
  46         rawPacket = (RawPacket) packetChain.getPacket();
  47       } else if(packetChain.getPacket() instanceof EthernetPacket) {
  48         ethernetPacket = (EthernetPacket) packetChain.getPacket();
  49       } else if(packetChain.getPacket() instanceof ArpPacket) {
  50         arpPacket = (ArpPacket) packetChain.getPacket();
  51       }
  52     }
  53     if(rawPacket == null || ethernetPacket == null || arpPacket == null) {
  54       return;
  55     }
  56     MacAddress destMac = ethernetPacket.getDestinationMac();
  57     if(!MAC_TO_IGNORE.equals(destMac)) {
  58       writeFlows(rawPacket.getIngress(),
  59           ethernetPacket.getSourceMac(),
  60           ethernetPacket.getDestinationMac());
  61     }
  62   }
  63
  64   /**
  65    * Invokes flow writer service to write  bidirectional mac-mac flows on a switch.
  66    *
  67    * @param ingress The NodeConnector where the payload came from.
  68    * @param srcMac  The source MacAddress of the packet.
  69    * @param destMac The destination MacAddress of the packet.
  70    */
  71   public void writeFlows(NodeConnectorRef ingress, MacAddress srcMac, MacAddress destMac) {
  72     NodeConnectorRef destNodeConnector = inventoryReader.getNodeConnector(ingress.getValue().firstIdentifierOf(Node.class), destMac);
  73     if(destNodeConnector != null) {
  74       flowWriterService.addBidirectionalMacToMacFlows(srcMac, ingress, destMac, destNodeConnector);
  75     }
  76   }
  77 }