git.opendaylight Code Review - controller.git/blob

   1 /*
   2  * Copyright (c) 2011,2012 Big Switch Networks, Inc.
   3  *
   4  * Licensed under the Eclipse Public License, Version 1.0 (the
   5  * "License"); you may not use this file except in compliance with the
   6  * License. You may obtain a copy of the License at
   7  *
   8  *      http://www.eclipse.org/legal/epl-v10.html
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
  13  * implied. See the License for the specific language governing
  14  * permissions and limitations under the License.
  15  *
  16  * This file incorporates work covered by the following copyright and
  17  * permission notice:
  18  *
  19  *    Originally created by David Erickson, Stanford University
  20  *
  21  *    Licensed under the Apache License, Version 2.0 (the "License");
  22  *    you may not use this file except in compliance with the
  23  *    License. You may obtain a copy of the License at
  24  *
  25  *         http://www.apache.org/licenses/LICENSE-2.0
  26  *
  27  *    Unless required by applicable law or agreed to in writing,
  28  *    software distributed under the License is distributed on an "AS
  29  *    IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
  30  *    express or implied. See the License for the specific language
  31  *    governing permissions and limitations under the License.
  32  */
  33
  34 package org.opendaylight.controller.hosttracker;
  35
  36 import java.net.InetAddress;
  37 import java.util.Date;
  38
  39 import org.opendaylight.controller.hosttracker.hostAware.HostNodeConnector;
  40 import org.opendaylight.controller.sal.core.NodeConnector;
  41 import org.opendaylight.controller.sal.utils.NetUtils;
  42
  43 /**
  44  * An entity on the network is a visible trace of a device that corresponds to a
  45  * packet received from a particular interface on the edge of a network, with a
  46  * particular VLAN tag, and a particular MAC address, along with any other
  47  * packet characteristics we might want to consider as helpful for
  48  * disambiguating devices.
  49  *
  50  * Entities are the most basic element of devices; devices consist of one or
  51  * more entities. Entities are immutable once created, except for the last seen
  52  * timestamp.
  53  *
  54  * @author readams
  55  *
  56  */
  57 public class Entity implements Comparable<Entity> {
  58     /**
  59      * Timeout for computing {@link Entity#activeSince}.
  60      *
  61      * @see {@link Entity#activeSince}
  62      */
  63     protected static int ACTIVITY_TIMEOUT = 30000;
  64
  65     /**
  66      * The MAC address associated with this entity
  67      */
  68     protected long macAddress;
  69
  70     /**
  71      * The IP address associated with this entity, or null if no IP learned from
  72      * the network observation associated with this entity
  73      */
  74     protected Integer ipv4Address;
  75
  76     /**
  77      * The VLAN tag on this entity, or null if untagged
  78      */
  79     protected Short vlan;
  80
  81     /**
  82      * The attachment point for this entity
  83      */
  84     NodeConnector port;
  85
  86     /**
  87      * The last time we observed this entity on the network
  88      */
  89     protected Date lastSeenTimestamp;
  90
  91     /**
  92      * The time between {@link Entity#activeSince} and
  93      * {@link Entity#lastSeenTimestamp} is a period of activity for this entity
  94      * where it was observed repeatedly. If, when the entity is observed, the is
  95      * longer ago than the activity timeout, {@link Entity#lastSeenTimestamp}
  96      * and {@link Entity#activeSince} will be set to the current time.
  97      */
  98     protected Date activeSince;
  99
 100     private int hashCode = 0;
 101
 102     // ************
 103     // Constructors
 104     // ************
 105
 106     /**
 107      * Create a new entity
 108      *
 109      * @param macAddress
 110      * @param vlan
 111      * @param ipv4Address
 112      * @param switchDPID
 113      * @param switchPort
 114      * @param lastSeenTimestamp
 115      */
 116     public Entity(long macAddress, Short vlan, Integer ipv4Address,
 117             NodeConnector port, Date lastSeenTimestamp) {
 118         this.macAddress = macAddress;
 119         this.ipv4Address = ipv4Address;
 120         this.vlan = vlan;
 121         this.port = port;
 122         this.lastSeenTimestamp = lastSeenTimestamp;
 123         this.activeSince = lastSeenTimestamp;
 124     }
 125
 126     // ***************
 127     // Getters/Setters
 128     // ***************
 129
 130     // @JsonSerialize(using=MACSerializer.class)
 131     public long getMacAddress() {
 132         return macAddress;
 133     }
 134
 135     // @JsonSerialize(using=IPv4Serializer.class)
 136     public Integer getIpv4Address() {
 137         return ipv4Address;
 138     }
 139
 140     public Short getVlan() {
 141         return vlan;
 142     }
 143
 144     public NodeConnector getPort() {
 145         return port;
 146     }
 147
 148     // @JsonIgnore
 149     public boolean hasSwitchPort() {
 150         return port != null;
 151     }
 152
 153     public Date getLastSeenTimestamp() {
 154         return lastSeenTimestamp;
 155     }
 156
 157     /**
 158      * Set the last seen timestamp and also update {@link Entity#activeSince} if
 159      * appropriate
 160      *
 161      * @param lastSeenTimestamp
 162      *            the new last seen timestamp
 163      * @see {@link Entity#activeSince}
 164      */
 165     public void setLastSeenTimestamp(Date lastSeenTimestamp) {
 166         if (activeSince == null
 167                 || (activeSince.getTime() + ACTIVITY_TIMEOUT) < lastSeenTimestamp
 168                         .getTime()) {
 169             this.activeSince = lastSeenTimestamp;
 170         }
 171         this.lastSeenTimestamp = lastSeenTimestamp;
 172     }
 173
 174     public Date getActiveSince() {
 175         return activeSince;
 176     }
 177
 178     public void setActiveSince(Date activeSince) {
 179         this.activeSince = activeSince;
 180     }
 181
 182     @Override
 183     public int hashCode() {
 184         if (hashCode != 0) {
 185             return hashCode;
 186         }
 187         final int prime = 31;
 188         hashCode = 1;
 189         hashCode = prime * hashCode
 190                 + ((ipv4Address == null) ? 0 : ipv4Address.hashCode());
 191         hashCode = prime * hashCode + (int) (macAddress ^ (macAddress >>> 32));
 192         hashCode = prime * hashCode + ((port == null) ? 0 : port.hashCode());
 193         hashCode = prime * hashCode + ((vlan == null) ? 0 : vlan.hashCode());
 194         return hashCode;
 195     }
 196
 197     @Override
 198     public boolean equals(Object obj) {
 199         if (this == obj) {
 200             return true;
 201         }
 202         if (obj == null) {
 203             return false;
 204         }
 205         if (getClass() != obj.getClass()) {
 206             return false;
 207         }
 208         Entity other = (Entity) obj;
 209         if (ipv4Address == null) {
 210             if (other.ipv4Address != null) {
 211                 return false;
 212             }
 213         } else if (!ipv4Address.equals(other.ipv4Address)) {
 214             return false;
 215         }
 216         if (macAddress != other.macAddress) {
 217             return false;
 218         }
 219         if (port == null) {
 220             if (other.port != null) {
 221                 return false;
 222             }
 223         } else if (!port.equals(other.port)) {
 224             return false;
 225         }
 226         if (vlan == null) {
 227             if (other.vlan != null) {
 228                 return false;
 229             }
 230         } else if (!vlan.equals(other.vlan)) {
 231             return false;
 232         }
 233         return true;
 234     }
 235
 236     public HostNodeConnector toHostNodeConnector() {
 237         try {
 238             NodeConnector n = this.getPort();
 239             InetAddress ip = InetAddress.getByAddress(NetUtils.intToByteArray4(this.getIpv4Address()));
 240             byte[] macAddr = NetUtils.longToByteArray6(this.getMacAddress());
 241             HostNodeConnector nc = new HostNodeConnector(macAddr, ip, n,
 242                     (short) 0);
 243             return nc;
 244         } catch (Exception e) {
 245             return null;
 246         }
 247     }
 248
 249     @Override
 250     public String toString() {
 251         return "Entity [macAddress=" + macAddress + ", ipv4Address="
 252                 + ipv4Address + ", vlan=" + vlan + ", port=" + port + "]";
 253     }
 254
 255     @SuppressWarnings({ "rawtypes", "unchecked" })
 256     @Override
 257     public int compareTo(Entity o) {
 258         int r;
 259         if (port == null) {
 260             r = o.port == null ? 0 : -1;
 261         }
 262         else if (o.port == null) {
 263             r = 1;
 264         }
 265         else {
 266             // XXX - the node id is only defined as an object rather
 267             // than something useful. We're just going to have to
 268             // blindly cast to Comparable and hope it works.
 269             Comparable switchId = (Comparable) port.getNode().getID();
 270             Comparable oswitchId = (Comparable) o.port.getNode().getID();
 271             r = switchId.compareTo(oswitchId);
 272             if (r != 0) {
 273                 return r;
 274             }
 275
 276             Comparable portId = (Comparable) port.getID();
 277             Comparable oportId = (Comparable) o.port.getID();
 278             r = portId.compareTo(oportId);
 279         }
 280         return r;
 281     }
 282
 283 }