GUI -- Moved more potentially expensive processing off listener dispatch thread.
Change-Id: Id5ff77ad1a4038e6840993da5cbc03a3fac944fb
diff --git a/web/gui/src/main/java/org/onosproject/ui/impl/TopologyViewMessageHandler.java b/web/gui/src/main/java/org/onosproject/ui/impl/TopologyViewMessageHandler.java
index 08a9e13..ba34f8e 100644
--- a/web/gui/src/main/java/org/onosproject/ui/impl/TopologyViewMessageHandler.java
+++ b/web/gui/src/main/java/org/onosproject/ui/impl/TopologyViewMessageHandler.java
@@ -512,7 +512,6 @@
// Subscribes for summary messages.
private synchronized void requestSummary(long sid) {
-
sendMessage(summmaryMessage(sid));
}
@@ -754,9 +753,7 @@
private class InternalClusterListener implements ClusterEventListener {
@Override
public void event(ClusterEvent event) {
- msgSender.execute(() -> {
- sendMessage(instanceMessage(event, null));
- });
+ msgSender.execute(() -> sendMessage(instanceMessage(event, null)));
}
}
@@ -779,9 +776,7 @@
@Override
public void event(DeviceEvent event) {
if (event.type() != PORT_STATS_UPDATED) {
- msgSender.execute(() -> {
- sendMessage(deviceMessage(event));
- });
+ msgSender.execute(() -> sendMessage(deviceMessage(event)));
eventAccummulator.add(event);
}
}
@@ -791,9 +786,7 @@
private class InternalLinkListener implements LinkListener {
@Override
public void event(LinkEvent event) {
- msgSender.execute(() -> {
- sendMessage(linkMessage(event));
- });
+ msgSender.execute(() -> sendMessage(linkMessage(event)));
eventAccummulator.add(event);
}
}
@@ -802,9 +795,7 @@
private class InternalHostListener implements HostListener {
@Override
public void event(HostEvent event) {
- msgSender.execute(() -> {
- sendMessage(hostMessage(event));
- });
+ msgSender.execute(() -> sendMessage(hostMessage(event)));
eventAccummulator.add(event);
}
}
@@ -830,7 +821,9 @@
// encapsulate
private static class TrafficEvent {
- enum Type { ALL_TRAFFIC, DEV_LINK_FLOWS, SEL_INTENT }
+ enum Type {
+ ALL_TRAFFIC, DEV_LINK_FLOWS, SEL_INTENT
+ }
private final Type type;
private final ObjectNode payload;
@@ -875,7 +868,7 @@
public void run() {
try {
if (summaryRunning) {
- requestSummary(0);
+ msgSender.execute(() -> requestSummary(0));
}
} catch (Exception e) {
log.warn("Unable to handle summary request due to {}", e.getMessage());
@@ -894,7 +887,7 @@
public void processItems(List<Event> items) {
try {
if (summaryRunning) {
- requestSummary(0);
+ msgSender.execute(() -> requestSummary(0));
}
} catch (Exception e) {
log.warn("Unable to handle summary request due to {}", e.getMessage());