CORD-1180 Collection of fixes for hash-group buckets. Required the following changes:
Next-objectives that edited groups are now queued in the FlowObjectiveManager instead of the driver.
During linkup immediately checking for previous portups that should be added to a hash group.
A final retry 30 secs later to catch all ports that should be part of the same hash group.
Change-Id: I7ef450149d685890ca47932b8e559a0c11dc5ab4
diff --git a/drivers/default/src/main/java/org/onosproject/driver/pipeline/ofdpa/Ofdpa2Pipeline.java b/drivers/default/src/main/java/org/onosproject/driver/pipeline/ofdpa/Ofdpa2Pipeline.java
index 1abe86c..9800260 100644
--- a/drivers/default/src/main/java/org/onosproject/driver/pipeline/ofdpa/Ofdpa2Pipeline.java
+++ b/drivers/default/src/main/java/org/onosproject/driver/pipeline/ofdpa/Ofdpa2Pipeline.java
@@ -283,13 +283,13 @@
nextObjective.id(), deviceId);
return;
}
- log.debug("Processing NextObjective id{} in dev{} - add group",
+ log.debug("Processing NextObjective id {} in dev {} - add group",
nextObjective.id(), deviceId);
groupHandler.addGroup(nextObjective);
break;
case ADD_TO_EXISTING:
if (nextGroup != null) {
- log.debug("Processing NextObjective id{} in dev{} - add bucket",
+ log.debug("Processing NextObjective id {} in dev {} - add bucket",
nextObjective.id(), deviceId);
groupHandler.addBucketToGroup(nextObjective, nextGroup);
} else {
@@ -313,7 +313,7 @@
nextObjective.id(), deviceId);
return;
}
- log.debug("Processing NextObjective id{} in dev{} - remove group",
+ log.debug("Processing NextObjective id {} in dev {} - remove group",
nextObjective.id(), deviceId);
groupHandler.removeGroup(nextObjective, nextGroup);
break;
@@ -323,7 +323,7 @@
nextObjective.id(), deviceId);
return;
}
- log.debug("Processing NextObjective id{} in dev{} - remove bucket",
+ log.debug("Processing NextObjective id {} in dev {} - remove bucket",
nextObjective.id(), deviceId);
groupHandler.removeBucketFromGroup(nextObjective, nextGroup);
break;