From 206e36a5216ae5bb33385d9a24884dde825b4eb8 Mon Sep 17 00:00:00 2001 From: Kane York Date: Tue, 26 Sep 2017 13:04:54 -0700 Subject: [PATCH] Fix compile --- socketserver/server/subscriptions.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/socketserver/server/subscriptions.go b/socketserver/server/subscriptions.go index 007aea03..136fa603 100644 --- a/socketserver/server/subscriptions.go +++ b/socketserver/server/subscriptions.go @@ -156,8 +156,11 @@ func UnsubscribeSingleChat(client *ClientInfo, channelName string) { // - write lock to SubscriptionInfos // - write lock to ClientInfo func UnsubscribeAll(client *ClientInfo) { - if StopAcceptingConnections { - return // no need to remove from a high-contention list when the server is closing + select { + case <-StopAcceptingConnectionsCh: + // Skip high-contention client removal operations while server shutting down + return + default: } GlobalSubscriptionLock.Lock()