commit 99c92fde0fbb544e3c8a91aefd3f0380a1382bc5
author Thomas Vachuska <tom@onlab.us> Mon Jun 01 11:44:53 2015 -0700
committer Gerrit Code Review <gerrit@onlab.us> Mon Jun 01 21:09:20 2015 +0000
tree d1585a024b4ac963d27c22ef25aebe655de413bf
parent c06966eee9d4a3e28a847237c7a25447f6995b7b

Reseting lastStart timestamp on listener ejection and sink notification.

Change-Id: Id13c8517fb4eca84a34ead168055328c236d090b

core/api/src/main/java/org/onosproject/event/ListenerRegistry.java

diff --git a/core/api/src/main/java/org/onosproject/event/ListenerRegistry.java b/core/api/src/main/java/org/onosproject/event/ListenerRegistry.java
index 6a570c5..ff8fcde 100644
--- a/core/api/src/main/java/org/onosproject/event/ListenerRegistry.java
+++ b/core/api/src/main/java/org/onosproject/event/ListenerRegistry.java
@@ -84,6 +84,7 @@
                       lastListener.getClass().getName(),
                       System.currentTimeMillis() - lastStart);
             removeListener(lastListener);
+            lastStart = 0;
         }
     }
 

core/net/src/main/java/org/onosproject/event/impl/CoreEventDispatcher.java

diff --git a/core/net/src/main/java/org/onosproject/event/impl/CoreEventDispatcher.java b/core/net/src/main/java/org/onosproject/event/impl/CoreEventDispatcher.java
index 6d97460..2c9d9aa 100644
--- a/core/net/src/main/java/org/onosproject/event/impl/CoreEventDispatcher.java
+++ b/core/net/src/main/java/org/onosproject/event/impl/CoreEventDispatcher.java
@@ -155,6 +155,7 @@
         public void run() {
             long delta = System.currentTimeMillis() - lastStart;
             if (lastStart > 0 && delta > maxProcessMillis) {
+                lastStart = 0;
                 log.error("Event sink {} exceeded execution time limit: {} ms",
                           lastSink.getClass().getName(), delta);