commit | d331afdc3dfa131534a9f11bf963b297e43624b6 | [log] [tgz] |
---|---|---|
author | Hyunsun Moon <hyunsun.moon@gmail.com> | Wed Jul 20 02:19:20 2016 -0700 |
committer | Gerrit Code Review <gerrit@onlab.us> | Thu Jul 21 01:15:17 2016 +0000 |
tree | 8348b6cfcdd0e412dbeca9536699695d74b77404 | |
parent | ac32718820059daa0ace4af51bcb71621645935e [diff] [blame] |
Fix to update gateway group only if new gateway is added Also implemented equals, hashCode, and toString for GatewayNode. Change-Id: I4c487cafa263833701c5790b2057c1d9c23e33bf
diff --git a/apps/scalablegateway/src/main/java/org/onosproject/scalablegateway/impl/ScalableGatewayManager.java b/apps/scalablegateway/src/main/java/org/onosproject/scalablegateway/impl/ScalableGatewayManager.java index adf354e..37e601c 100644 --- a/apps/scalablegateway/src/main/java/org/onosproject/scalablegateway/impl/ScalableGatewayManager.java +++ b/apps/scalablegateway/src/main/java/org/onosproject/scalablegateway/impl/ScalableGatewayManager.java
@@ -203,9 +203,15 @@ @Override public boolean addGatewayNode(GatewayNode gatewayNode) { - gatewayNodeMap.putIfAbsent(gatewayNode.getGatewayDeviceId(), gatewayNode); - updateGatewayLoadBalance(gatewayNode, true); - return true; + Versioned<GatewayNode> existingNode = gatewayNodeMap.putIfAbsent( + gatewayNode.getGatewayDeviceId(), gatewayNode); + if (existingNode == null) { + updateGatewayLoadBalance(gatewayNode, true); + log.info("Added {} to gateway pool", gatewayNode); + return true; + } else { + return false; + } } @Override