#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-2016 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 readonly Dictionary _endpoints; #endregion #region Static Constructor static EndPointManager () { _endpoints = 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); var addr = convertToIPAddress (pref.Host); if (addr == null) throw new HttpListenerException (87, "Includes an invalid host."); if (!addr.IsLocal ()) throw new HttpListenerException (87, "Includes an invalid host."); int port; if (!Int32.TryParse (pref.Port, out port)) throw new HttpListenerException (87, "Includes an invalid port."); if (!port.IsPortNumber ()) throw new HttpListenerException (87, "Includes an invalid port."); var path = pref.Path; if (path.IndexOf ('%') != -1) throw new HttpListenerException (87, "Includes an invalid path."); if (path.IndexOf ("//", StringComparison.Ordinal) != -1) throw new HttpListenerException (87, "Includes an invalid path."); var endpoint = new IPEndPoint (addr, port); EndPointListener lsnr; if (_endpoints.TryGetValue (endpoint, out lsnr)) { if (lsnr.IsSecure ^ pref.IsSecure) throw new HttpListenerException (87, "Includes an invalid scheme."); } else { lsnr = new EndPointListener ( endpoint, pref.IsSecure, listener.CertificateFolderPath, listener.SslConfiguration, listener.ReuseAddress ); _endpoints.Add (endpoint, lsnr); } lsnr.AddPrefix (pref, listener); } private static IPAddress convertToIPAddress (string hostname) { if (hostname == "*") return IPAddress.Any; if (hostname == "+") return IPAddress.Any; return hostname.ToIPAddress (); } private static void removePrefix (string uriPrefix, HttpListener listener) { var pref = new HttpListenerPrefix (uriPrefix); var addr = convertToIPAddress (pref.Host); if (addr == null) return; if (!addr.IsLocal ()) return; int port; if (!Int32.TryParse (pref.Port, out port)) return; if (!port.IsPortNumber ()) return; var path = pref.Path; if (path.IndexOf ('%') != -1) return; if (path.IndexOf ("//", StringComparison.Ordinal) != -1) return; var endpoint = new IPEndPoint (addr, port); EndPointListener lsnr; if (!_endpoints.TryGetValue (endpoint, out lsnr)) return; if (lsnr.IsSecure ^ pref.IsSecure) return; lsnr.RemovePrefix (pref, listener); } #endregion #region Internal Methods internal static bool RemoveEndPoint (IPEndPoint endpoint) { lock (((ICollection) _endpoints).SyncRoot) { EndPointListener lsnr; if (!_endpoints.TryGetValue (endpoint, out lsnr)) return false; _endpoints.Remove (endpoint); lsnr.Close (); return true; } } #endregion #region Public Methods public static void AddListener (HttpListener listener) { var added = new List (); lock (((ICollection) _endpoints).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) _endpoints).SyncRoot) addPrefix (uriPrefix, listener); } public static void RemoveListener (HttpListener listener) { lock (((ICollection) _endpoints).SyncRoot) { foreach (var pref in listener.Prefixes) removePrefix (pref, listener); } } public static void RemovePrefix (string uriPrefix, HttpListener listener) { lock (((ICollection) _endpoints).SyncRoot) removePrefix (uriPrefix, listener); } #endregion } }