From bd5bf32aba45f3a4dff4f883505ddf9fb528e53a Mon Sep 17 00:00:00 2001 From: Luke Pulverenti Date: Sun, 6 Oct 2013 14:48:04 -0400 Subject: fix web socket message name for library change --- .../WebSocket/AlchemyServer.cs | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) (limited to 'MediaBrowser.Server.Implementations/WebSocket') diff --git a/MediaBrowser.Server.Implementations/WebSocket/AlchemyServer.cs b/MediaBrowser.Server.Implementations/WebSocket/AlchemyServer.cs index 14d468a8e..251083dc2 100644 --- a/MediaBrowser.Server.Implementations/WebSocket/AlchemyServer.cs +++ b/MediaBrowser.Server.Implementations/WebSocket/AlchemyServer.cs @@ -4,7 +4,6 @@ using MediaBrowser.Common.Net; using MediaBrowser.Model.Logging; using System; using System.Net; -using System.Net.Sockets; namespace MediaBrowser.Server.Implementations.WebSocket { @@ -29,6 +28,8 @@ namespace MediaBrowser.Server.Implementations.WebSocket /// private readonly ILogger _logger; + private bool _hasStopped; + /// /// Initializes a new instance of the class. /// @@ -57,6 +58,8 @@ namespace MediaBrowser.Server.Implementations.WebSocket /// The port number. public void Start(int portNumber) { + _logger.Info("Starting Alchemy web socket server on port {0}", portNumber); + try { WebSocketServer = new WebSocketServer(portNumber, IPAddress.Any) @@ -87,6 +90,11 @@ namespace MediaBrowser.Server.Implementations.WebSocket /// The context. private void OnAlchemyWebSocketClientConnected(UserContext context) { + if (_hasStopped) + { + return; + } + if (WebSocketConnected != null) { var socket = new AlchemyWebSocket(context, _logger); @@ -127,6 +135,8 @@ namespace MediaBrowser.Server.Implementations.WebSocket /// true to release both managed and unmanaged resources; false to release only unmanaged resources. protected virtual void Dispose(bool dispose) { + _hasStopped = true; + lock (_syncLock) { if (WebSocketServer != null) -- cgit v1.2.3