From 1feda1d3b102bcc053c6a1919499e235b7f8e9c5 Mon Sep 17 00:00:00 2001
From: Paul-Christian Volkmer <paul-christian.volkmer@mni.thm.de>
Date: Tue, 18 Jun 2013 14:31:03 +0200
Subject: [PATCH] Count pending websocket connections
---
.../de/thm/arsnova/socket/ARSnovaSocketIOServer.java | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java b/src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java
index 3dfe7e15e..f9d41fcd9 100644
--- a/src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java
+++ b/src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java
@@ -23,6 +23,8 @@ import com.corundumstudio.socketio.SocketIOServer;
import com.corundumstudio.socketio.listener.ConnectListener;
import com.corundumstudio.socketio.listener.DataListener;
import com.corundumstudio.socketio.listener.DisconnectListener;
+import com.corundumstudio.socketio.parser.Packet;
+import com.corundumstudio.socketio.parser.PacketType;
import de.thm.arsnova.entities.User;
import de.thm.arsnova.events.ARSnovaEvent;
@@ -70,6 +72,13 @@ public class ARSnovaSocketIOServer {
for (SocketIOClient c : server.getAllClients()) {
c.disconnect();
}
+
+ int clientCount = 0;
+ for (SocketIOClient c : server.getAllClients()) {
+ c.send(new Packet(PacketType.DISCONNECT));
+ clientCount++;
+ }
+ LOGGER.info("Pending websockets at @PreDestroy: {}", clientCount);
server.stop();
}
--
GitLab