Skip to content
GitLab
Explore
Sign in
Primary navigation
Search or go to…
Project
ARSnova Backend
Manage
Activity
Members
Labels
Plan
Issues
27
Issue boards
Milestones
Code
Merge requests
1
Repository
Branches
Commits
Tags
Repository graph
Compare revisions
Build
Pipelines
Jobs
Pipeline schedules
Artifacts
Deploy
Releases
Operate
Environments
Monitor
Incidents
Analyze
Value stream analytics
Contributor analytics
CI/CD analytics
Repository analytics
Help
Help
Support
GitLab documentation
Community forum
Contribute to GitLab
Provide feedback
Keyboard shortcuts
?
Privacy
Imprint
Contact
Snippets
Groups
Projects
Show more breadcrumbs
ARSnova
ARSnova Backend
Commits
1feda1d3
Commit
1feda1d3
authored
11 years ago
by
Paul-Christian Volkmer
Browse files
Options
Downloads
Patches
Plain Diff
Count pending websocket connections
parent
2dfbbfa1
No related merge requests found
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java
+9
-0
9 additions, 0 deletions
...ain/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java
with
9 additions
and
0 deletions
src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java
+
9
−
0
View file @
1feda1d3
...
...
@@ -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
();
}
...
...
This diff is collapsed.
Click to expand it.
Preview
0%
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Save comment
Cancel
Please
register
or
sign in
to comment