GUI -- Moved of potentially expensive processing off listener dispatch thread.

Change-Id: Iba30f01b99f464b06c7d33fddf2b143ce6aa1fdd

@@ -67,8 +67,11 @@ import java.util.List;
 import java.util.Set;
 import java.util.Set;
 import java.util.Timer;
 import java.util.Timer;
 import java.util.TimerTask;
 import java.util.TimerTask;
+import java.util.concurrent.ExecutorService;
 
 
 import static com.google.common.base.Strings.isNullOrEmpty;
 import static com.google.common.base.Strings.isNullOrEmpty;
+import static java.util.concurrent.Executors.newSingleThreadExecutor;
+import static org.onlab.util.Tools.groupedThreads;
 import static org.onosproject.cluster.ClusterEvent.Type.INSTANCE_ADDED;
 import static org.onosproject.cluster.ClusterEvent.Type.INSTANCE_ADDED;
 import static org.onosproject.net.DeviceId.deviceId;
 import static org.onosproject.net.DeviceId.deviceId;
 import static org.onosproject.net.HostId.hostId;
 import static org.onosproject.net.HostId.hostId;
@@ -111,7 +114,7 @@ public class TopologyViewMessageHandler extends TopologyViewMessageHandlerBase {
             (o1, o2) -> o1.id().toString().compareTo(o2.id().toString());
             (o1, o2) -> o1.id().toString().compareTo(o2.id().toString());
 
 
 
 
-    private final Timer timer = new Timer("topology-view");
+    private final Timer timer = new Timer("onos-topology-view");
 
 
     private static final int MAX_EVENTS = 1000;
     private static final int MAX_EVENTS = 1000;
     private static final int MAX_BATCH_MS = 5000;
     private static final int MAX_BATCH_MS = 5000;
@@ -128,6 +131,8 @@ public class TopologyViewMessageHandler extends TopologyViewMessageHandlerBase {
     private final FlowRuleListener flowListener = new InternalFlowListener();
     private final FlowRuleListener flowListener = new InternalFlowListener();
 
 
     private final Accumulator<Event> eventAccummulator = new InternalEventAccummulator();
     private final Accumulator<Event> eventAccummulator = new InternalEventAccummulator();
+    private final ExecutorService msgSender =
+            newSingleThreadExecutor(groupedThreads("onos/gui", "msg-sender"));
 
 
     private TimerTask trafficTask = null;
     private TimerTask trafficTask = null;
     private TrafficEvent trafficEvent = null;
     private TrafficEvent trafficEvent = null;
@@ -507,6 +512,7 @@ public class TopologyViewMessageHandler extends TopologyViewMessageHandlerBase {
 
 
     // Subscribes for summary messages.
     // Subscribes for summary messages.
     private synchronized void requestSummary(long sid) {
     private synchronized void requestSummary(long sid) {
+
         sendMessage(summmaryMessage(sid));
         sendMessage(summmaryMessage(sid));
     }
     }
 
 
@@ -748,7 +754,9 @@ public class TopologyViewMessageHandler extends TopologyViewMessageHandlerBase {
     private class InternalClusterListener implements ClusterEventListener {
     private class InternalClusterListener implements ClusterEventListener {
         @Override
         @Override
         public void event(ClusterEvent event) {
         public void event(ClusterEvent event) {
+            msgSender.execute(() -> {
                 sendMessage(instanceMessage(event, null));
                 sendMessage(instanceMessage(event, null));
+            });
         }
         }
     }
     }
 
 
@@ -756,11 +764,13 @@ public class TopologyViewMessageHandler extends TopologyViewMessageHandlerBase {
     private class InternalMastershipListener implements MastershipListener {
     private class InternalMastershipListener implements MastershipListener {
         @Override
         @Override
         public void event(MastershipEvent event) {
         public void event(MastershipEvent event) {
+            msgSender.execute(() -> {
                 sendAllInstances("updateInstance");
                 sendAllInstances("updateInstance");
                 Device device = deviceService.getDevice(event.subject());
                 Device device = deviceService.getDevice(event.subject());
                 if (device != null) {
                 if (device != null) {
                     sendMessage(deviceMessage(new DeviceEvent(DEVICE_UPDATED, device)));
                     sendMessage(deviceMessage(new DeviceEvent(DEVICE_UPDATED, device)));
                 }
                 }
+            });
         }
         }
     }
     }
 
 
@@ -769,7 +779,9 @@ public class TopologyViewMessageHandler extends TopologyViewMessageHandlerBase {
         @Override
         @Override
         public void event(DeviceEvent event) {
         public void event(DeviceEvent event) {
             if (event.type() != PORT_STATS_UPDATED) {
             if (event.type() != PORT_STATS_UPDATED) {
+                msgSender.execute(() -> {
                     sendMessage(deviceMessage(event));
                     sendMessage(deviceMessage(event));
+                });
                 eventAccummulator.add(event);
                 eventAccummulator.add(event);
             }
             }
         }
         }
@@ -779,7 +791,9 @@ public class TopologyViewMessageHandler extends TopologyViewMessageHandlerBase {
     private class InternalLinkListener implements LinkListener {
     private class InternalLinkListener implements LinkListener {
         @Override
         @Override
         public void event(LinkEvent event) {
         public void event(LinkEvent event) {
+            msgSender.execute(() -> {
                 sendMessage(linkMessage(event));
                 sendMessage(linkMessage(event));
+            });
             eventAccummulator.add(event);
             eventAccummulator.add(event);
         }
         }
     }
     }
@@ -788,7 +802,9 @@ public class TopologyViewMessageHandler extends TopologyViewMessageHandlerBase {
     private class InternalHostListener implements HostListener {
     private class InternalHostListener implements HostListener {
         @Override
         @Override
         public void event(HostEvent event) {
         public void event(HostEvent event) {
+            msgSender.execute(() -> {
                 sendMessage(hostMessage(event));
                 sendMessage(hostMessage(event));
+            });
             eventAccummulator.add(event);
             eventAccummulator.add(event);
         }
         }
     }
     }
@@ -798,7 +814,7 @@ public class TopologyViewMessageHandler extends TopologyViewMessageHandlerBase {
         @Override
         @Override
         public void event(IntentEvent event) {
         public void event(IntentEvent event) {
             if (trafficTask != null) {
             if (trafficTask != null) {
-                requestSelectedIntentTraffic();
+                msgSender.execute(TopologyViewMessageHandler.this::requestSelectedIntentTraffic);
             }
             }
             eventAccummulator.add(event);
             eventAccummulator.add(event);
         }
         }

@@ -22,7 +22,7 @@
 
 
     // configuration
     // configuration
     var defaultSettings = {
     var defaultSettings = {
-        zoomMin: 0.25,
+        zoomMin: 0.05,
         zoomMax: 10,
         zoomMax: 10,
         zoomEnabled: function (ev) { return true; },
         zoomEnabled: function (ev) { return true; },
         zoomCallback: function () {}
         zoomCallback: function () {}