Added detection of traffic flowing using StatisticService.
Change-Id: I2044ec16fd722d953d0e2b2c955e4da2b1dab663
diff --git a/web/gui/src/main/java/org/onlab/onos/gui/GuiWebSocketServlet.java b/web/gui/src/main/java/org/onlab/onos/gui/GuiWebSocketServlet.java
index aa00a863..37120d9 100644
--- a/web/gui/src/main/java/org/onlab/onos/gui/GuiWebSocketServlet.java
+++ b/web/gui/src/main/java/org/onlab/onos/gui/GuiWebSocketServlet.java
@@ -37,7 +37,7 @@
private ServiceDirectory directory = new DefaultServiceDirectory();
- private final Set<TopologyWebSocket> sockets = new HashSet<>();
+ private final Set<TopologyViewWebSocket> sockets = new HashSet<>();
private final Timer timer = new Timer();
private final TimerTask pruner = new Pruner();
@@ -49,7 +49,7 @@
@Override
public WebSocket doWebSocketConnect(HttpServletRequest request, String protocol) {
- TopologyWebSocket socket = new TopologyWebSocket(directory);
+ TopologyViewWebSocket socket = new TopologyViewWebSocket(directory);
synchronized (sockets) {
sockets.add(socket);
}
@@ -61,9 +61,9 @@
@Override
public void run() {
synchronized (sockets) {
- Iterator<TopologyWebSocket> it = sockets.iterator();
+ Iterator<TopologyViewWebSocket> it = sockets.iterator();
while (it.hasNext()) {
- TopologyWebSocket socket = it.next();
+ TopologyViewWebSocket socket = it.next();
if (socket.isIdle()) {
it.remove();
socket.close();