Thomas Vachuska
Committed by Gerrit Code Review

Increasing tolerance for evicting latent listeners.

Change-Id: I3ab62084479185160ef7cc8ba5035a34cb96ad15
......@@ -49,7 +49,7 @@ public class CoreEventDispatcher extends DefaultEventSinkRegistry
private final Logger log = getLogger(getClass());
// Default number of millis a sink can take to process an event.
private static final long DEFAULT_EXECUTE_MS = 2_000; // ms
private static final long DEFAULT_EXECUTE_MS = 5_000; // ms
private static final long WATCHDOG_MS = 250; // ms
private final BlockingQueue<Event> events = new LinkedBlockingQueue<>();
......@@ -122,6 +122,8 @@ public class CoreEventDispatcher extends DefaultEventSinkRegistry
break;
}
process(event);
} catch (InterruptedException e) {
log.warn("Dispatch loop interrupted");
} catch (Exception e) {
log.warn("Error encountered while dispatching event:", e);
}
......
......@@ -34,13 +34,14 @@
<step name="Check-Summary" requires="Wait-For-Mininet"
exec="onos-check-summary ${OC1} [0-9]* 25 140 0"/>
<step name="Check-Flows" requires="Wait-For-Mininet"
exec="onos-check-flows ${OC1}"/>
<step name="Balance-Masters" requires="Check-Summary"
exec="onos ${OC1} balance-masters"/>
<step name="Pause-For-Masters" requires="Balance-Masters"
exec="sleep 10"/>
<step name="Check-Flows" requires="~Pause-For-Masters"
exec="onos-check-flows ${OC1}"/>
</group>
</scenario>
\ No newline at end of file
......