From 4c8301cd9cf35bea953e4d26a3bfa2725ac23d3c Mon Sep 17 00:00:00 2001 From: sta Date: Sat, 26 Aug 2017 21:30:57 +0900 Subject: [PATCH] [Modify] Polish it --- websocket-sharp/Server/WebSocketSessionManager.cs | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/websocket-sharp/Server/WebSocketSessionManager.cs b/websocket-sharp/Server/WebSocketSessionManager.cs index 29a12611..f453d30d 100644 --- a/websocket-sharp/Server/WebSocketSessionManager.cs +++ b/websocket-sharp/Server/WebSocketSessionManager.cs @@ -276,13 +276,23 @@ namespace WebSocketSharp.Server private void broadcast (Opcode opcode, Stream stream, Action completed) { var cache = new Dictionary (); + try { - Broadcast (opcode, stream, cache); + foreach (var session in Sessions) { + if (_state != ServerState.Start) { + _log.Error ("The service is shutting down."); + break; + } + + session.Context.WebSocket.Send (opcode, stream, cache); + } + if (completed != null) completed (); } catch (Exception ex) { - _log.Fatal (ex.ToString ()); + _log.Error (ex.Message); + _log.Debug (ex.ToString ()); } finally { foreach (var cached in cache.Values)