#region License /* * EndPointManager.cs * * This code is derived from EndPointManager.cs (System.Net) of Mono * (http://www.mono-project.com). * * The MIT License * * Copyright (c) 2005 Novell, Inc. (http://www.novell.com) * Copyright (c) 2012-2015 sta.blockhead * * Permission is hereby granted, free of charge, to any person obtaining a copy * of this software and associated documentation files (the "Software"), to deal * in the Software without restriction, including without limitation the rights * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell * copies of the Software, and to permit persons to whom the Software is * furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included in * all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN * THE SOFTWARE. */ #endregion #region Authors /* * Authors: * - Gonzalo Paniagua Javier */ #endregion #region Contributors /* * Contributors: * - Liryna */ #endregion using System; using System.Collections; using System.Collections.Generic; using System.Net; namespace WebSocketSharp.Net { internal sealed class EndPointManager { #region Private Fields private static Dictionary> _addressToEndpoints; #endregion #region Static Constructor static EndPointManager () { _addressToEndpoints = new Dictionary> (); } #endregion #region Private Constructors private EndPointManager () { } #endregion #region Private Methods private static void addPrefix (string uriPrefix, HttpListener listener) { var pref = new HttpListenerPrefix (uriPrefix); if (pref.Path.IndexOf ('%') != -1) throw new HttpListenerException (400, "Invalid path."); // TODO: Code? if (pref.Path.IndexOf ("//", StringComparison.Ordinal) != -1) throw new HttpListenerException (400, "Invalid path."); // TODO: Code? // Listens on all the interfaces if host name cannot be parsed by IPAddress. var lsnr = getEndPointListener (pref.Host, pref.Port, listener, pref.IsSecure); lsnr.AddPrefix (pref, listener); } private static IPAddress convertToAddress (string hostname) { if (hostname == "*" || hostname == "+") return IPAddress.Any; IPAddress addr; if (IPAddress.TryParse (hostname, out addr)) return addr; try { var host = Dns.GetHostEntry (hostname); return host != null ? host.AddressList[0] : IPAddress.Any; } catch { return IPAddress.Any; } } private static EndPointListener getEndPointListener ( string host, int port, HttpListener listener, bool secure) { var addr = convertToAddress (host); Dictionary eps = null; if (_addressToEndpoints.ContainsKey (addr)) { eps = _addressToEndpoints[addr]; } else { eps = new Dictionary (); _addressToEndpoints[addr] = eps; } EndPointListener lsnr = null; if (eps.ContainsKey (port)) { lsnr = eps[port]; } else { lsnr = new EndPointListener ( addr, port, secure, listener.CertificateFolderPath, listener.SslConfiguration, listener.ReuseAddress); eps[port] = lsnr; } return lsnr; } private static void removePrefix (string uriPrefix, HttpListener listener) { var pref = new HttpListenerPrefix (uriPrefix); if (pref.Path.IndexOf ('%') != -1) return; if (pref.Path.IndexOf ("//", StringComparison.Ordinal) != -1) return; var lsnr = getEndPointListener (pref.Host, pref.Port, listener, pref.IsSecure); lsnr.RemovePrefix (pref, listener); } #endregion #region Internal Methods internal static void RemoveEndPoint (EndPointListener listener) { lock (((ICollection) _addressToEndpoints).SyncRoot) { var addr = listener.Address; var eps = _addressToEndpoints[addr]; eps.Remove (listener.Port); if (eps.Count == 0) _addressToEndpoints.Remove (addr); listener.Close (); } } #endregion #region Public Methods public static void AddListener (HttpListener listener) { var added = new List (); lock (((ICollection) _addressToEndpoints).SyncRoot) { try { foreach (var pref in listener.Prefixes) { addPrefix (pref, listener); added.Add (pref); } } catch { foreach (var pref in added) removePrefix (pref, listener); throw; } } } public static void AddPrefix (string uriPrefix, HttpListener listener) { lock (((ICollection) _addressToEndpoints).SyncRoot) addPrefix (uriPrefix, listener); } public static void RemoveListener (HttpListener listener) { lock (((ICollection) _addressToEndpoints).SyncRoot) foreach (var pref in listener.Prefixes) removePrefix (pref, listener); } public static void RemovePrefix (string uriPrefix, HttpListener listener) { lock (((ICollection) _addressToEndpoints).SyncRoot) removePrefix (uriPrefix, listener); } #endregion } }