addresstracker/implementation/src/main/java/org/opendaylight/l2switch/addresstracker/addressobserver/AddressObserverUsingArp.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.addresstracker.addressobserver;
   9
  10 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.arp.rev140528.ArpPacketListener;
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.arp.rev140528.ArpPacketReceived;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.arp.rev140528.arp.packet.received.packet.chain.packet.ArpPacket;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.basepacket.rev140528.packet.chain.grp.PacketChain;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.basepacket.rev140528.packet.chain.grp.packet.chain.packet.RawPacket;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.ethernet.rev140528.ethernet.packet.received.packet.chain.packet.EthernetPacket;
  17 import org.slf4j.Logger;
  18 import org.slf4j.LoggerFactory;
  19
  20 /**
  21  * AddressObserver listens to ARP packets to find addresses (mac, ip) and store
  22  * these address observations for each node-connector. These packets are
  23  * returned to the network after the addresses are learned.
  24  */
  25 public class AddressObserverUsingArp implements ArpPacketListener {
  26
  27     private final static Logger LOG = LoggerFactory.getLogger(AddressObserverUsingArp.class);
  28     private org.opendaylight.l2switch.addresstracker.addressobserver.AddressObservationWriter addressObservationWriter;
  29
  30     public AddressObserverUsingArp(
  31             org.opendaylight.l2switch.addresstracker.addressobserver.AddressObservationWriter addressObservationWriter) {
  32         this.addressObservationWriter = addressObservationWriter;
  33     }
  34
  35     /**
  36      * The handler function for ARP packets.
  37      *
  38      * @param packetReceived
  39      *            The incoming packet.
  40      */
  41     @Override
  42     public void onArpPacketReceived(ArpPacketReceived packetReceived) {
  43         if (packetReceived == null || packetReceived.getPacketChain() == null) {
  44             return;
  45         }
  46
  47         RawPacket rawPacket = null;
  48         EthernetPacket ethernetPacket = null;
  49         ArpPacket arpPacket = null;
  50         for (PacketChain packetChain : packetReceived.getPacketChain()) {
  51             if (packetChain.getPacket() instanceof RawPacket) {
  52                 rawPacket = (RawPacket) packetChain.getPacket();
  53             } else if (packetChain.getPacket() instanceof EthernetPacket) {
  54                 ethernetPacket = (EthernetPacket) packetChain.getPacket();
  55             } else if (packetChain.getPacket() instanceof ArpPacket) {
  56                 arpPacket = (ArpPacket) packetChain.getPacket();
  57             }
  58         }
  59         if (rawPacket == null || ethernetPacket == null || arpPacket == null) {
  60             return;
  61         }
  62
  63         addressObservationWriter.addAddress(ethernetPacket.getSourceMac(),
  64                 new IpAddress(arpPacket.getSourceProtocolAddress().toCharArray()), rawPacket.getIngress());
  65     }
  66 }