commit 1cca5e885dee84bc91d0e062659eb2ae8a155bf9
author Boyoung Jeong <andrew@telcoware.com> Wed Aug 01 21:00:08 2018 +0900
committer Jian Li <pyguni@gmail.com> Tue Aug 07 01:28:23 2018 +0000
tree 81832e01cef84760a2397184b101b792ed338f9b
parent 8141264e25283d26a7cb832674a2bb7f5feb4c41

Add a message handler for Openstack Telemetry view

Change-Id: I2803ac6e8f3c90e005bc73c43a5b867934daa80f

apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultFlowInfo.java

diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultFlowInfo.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultFlowInfo.java
index 6033483..2f67050 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultFlowInfo.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultFlowInfo.java
@@ -32,6 +32,8 @@
  * Implementation class of FlowInfo.
  */
 public final class DefaultFlowInfo implements FlowInfo {
+    private static final String INGRESS_STATS = "Ingress Port :";
+    private static final String EGRESS_STATS = "Egress Port :";
 
     private final byte flowType;
     private final DeviceId deviceId;
@@ -185,6 +187,20 @@
     }
 
     @Override
+    public String uniqueFlowInfoKey() {
+        if (srcIp.address().isZero() || dstIp.address().isZero()) {
+            if (!srcIp.address().isZero()) {
+                return INGRESS_STATS + srcIp.toString();
+            }
+            if (!dstIp.address().isZero()) {
+                return EGRESS_STATS + dstIp.toString();
+            }
+        }
+        return srcIp.toString() + ":" + srcPort.toString() + " -> " +
+                dstIp.toString() + ":" + dstPort.toString();
+    }
+
+    @Override
     public String toString() {
         return toStringHelper(this)
                 .add("flowType", flowType)