commit 8d978f4fb021653e09246ef4f2f5dfd8c67aaf05
author Thomas Vachuska <tom@onlab.us> Wed Jun 08 13:49:13 2016 -0700
committer Brian O'Connor <bocon@onlab.us> Wed Jun 08 22:09:41 2016 +0000
tree 5562f4fdc1b19075ff1ebd660abf0af15430dc54
parent 9a6acff5f16f559a86f14e0bcc43dac9a759b91b

ONOS-4590 Added back-off mechanism for intent clean-up.

Change-Id: If997943aef8e46caafd21629296b939d6669e374

core/net/src/main/java/org/onosproject/net/intent/impl/IntentCleanup.java

diff --git a/core/net/src/main/java/org/onosproject/net/intent/impl/IntentCleanup.java b/core/net/src/main/java/org/onosproject/net/intent/impl/IntentCleanup.java
index d51fe3a..68aed97 100644
--- a/core/net/src/main/java/org/onosproject/net/intent/impl/IntentCleanup.java
+++ b/core/net/src/main/java/org/onosproject/net/intent/impl/IntentCleanup.java
@@ -86,6 +86,7 @@
     private ExecutorService executor;
     private Timer timer;
     private TimerTask timerTask;
+    private int cleanupIteration = 0;
 
     @Activate
     public void activate() {
@@ -188,6 +189,11 @@
     }
 
     private void resubmitPendingRequest(IntentData intentData) {
+        if (cleanupIteration % (intentData.errorCount() + 1) != 0) {
+            // backoff
+            return;
+        }
+
         switch (intentData.request()) {
             case INSTALL_REQ:
                 service.submit(intentData.intent());
@@ -210,6 +216,8 @@
      * re-submit/withdraw appropriately.
      */
     private void cleanup() {
+        cleanupIteration++;
+
         int corruptCount = 0, failedCount = 0, stuckCount = 0, pendingCount = 0;
 
         for (IntentData intentData : store.getIntentData(true, periodMs)) {