From 6130cb2403662596bba0474494372446d9caa3c3 Mon Sep 17 00:00:00 2001 From: Luke Pulverenti Date: Tue, 16 Sep 2014 23:04:10 -0400 Subject: adjust discovery of local ip addresses --- .../HttpServer/HttpListenerHost.cs | 28 ++++++++++++++++++---- 1 file changed, 23 insertions(+), 5 deletions(-) (limited to 'MediaBrowser.Server.Implementations/HttpServer') diff --git a/MediaBrowser.Server.Implementations/HttpServer/HttpListenerHost.cs b/MediaBrowser.Server.Implementations/HttpServer/HttpListenerHost.cs index 15d1eea6d..d88a04063 100644 --- a/MediaBrowser.Server.Implementations/HttpServer/HttpListenerHost.cs +++ b/MediaBrowser.Server.Implementations/HttpServer/HttpListenerHost.cs @@ -14,7 +14,6 @@ using ServiceStack.Host.HttpListener; using ServiceStack.Logging; using ServiceStack.Web; using System; -using System.Collections.Concurrent; using System.Collections.Generic; using System.IO; using System.Linq; @@ -40,15 +39,26 @@ namespace MediaBrowser.Server.Implementations.HttpServer public event EventHandler WebSocketConnected; - private readonly ConcurrentDictionary _localEndPoints = new ConcurrentDictionary(StringComparer.OrdinalIgnoreCase); - + private readonly List _localEndpoints = new List(); + + private readonly ReaderWriterLockSlim _localEndpointLock = new ReaderWriterLockSlim(); + /// /// Gets the local end points. /// /// The local end points. public IEnumerable LocalEndPoints { - get { return _listener == null ? new List() : _localEndPoints.Keys.ToList(); } + get + { + _localEndpointLock.EnterReadLock(); + + var list = _localEndpoints.ToList(); + + _localEndpointLock.ExitReadLock(); + + return list; + } } public HttpListenerHost(IApplicationHost applicationHost, ILogManager logManager, string serviceName, string handlerPath, string defaultRedirectPath, params Assembly[] assembliesWithServices) @@ -156,7 +166,15 @@ namespace MediaBrowser.Server.Implementations.HttpServer private void OnRequestReceived(string localEndPoint) { - _localEndPoints.GetOrAdd(localEndPoint, localEndPoint); + if (_localEndpointLock.TryEnterWriteLock(100)) + { + var list = _localEndpoints.ToList(); + + list.Remove(localEndPoint); + list.Insert(0, localEndPoint); + + _localEndpointLock.ExitWriteLock(); + } } /// -- cgit v1.2.3