From bc657237aa4c541fe0079fcbb7616dbe87bbf0a7 Mon Sep 17 00:00:00 2001 From: Luke Pulverenti Date: Fri, 18 Jul 2014 21:28:40 -0400 Subject: consolidate web socket onto one port --- .../HttpServer/NetListener/HttpListenerServer.cs | 27 ++++++++++++++++++---- 1 file changed, 23 insertions(+), 4 deletions(-) (limited to 'MediaBrowser.Server.Implementations/HttpServer/NetListener/HttpListenerServer.cs') diff --git a/MediaBrowser.Server.Implementations/HttpServer/NetListener/HttpListenerServer.cs b/MediaBrowser.Server.Implementations/HttpServer/NetListener/HttpListenerServer.cs index 51f0554d7..7f766129e 100644 --- a/MediaBrowser.Server.Implementations/HttpServer/NetListener/HttpListenerServer.cs +++ b/MediaBrowser.Server.Implementations/HttpServer/NetListener/HttpListenerServer.cs @@ -1,4 +1,5 @@ -using Amib.Threading; +using System.Text; +using Amib.Threading; using MediaBrowser.Common.Net; using MediaBrowser.Model.Logging; using ServiceStack; @@ -132,7 +133,7 @@ namespace MediaBrowser.Server.Implementations.HttpServer.NetListener _threadPoolManager.QueueWorkItem(() => InitTask(context)); } - public virtual void InitTask(HttpListenerContext context) + private void InitTask(HttpListenerContext context) { try { @@ -150,7 +151,7 @@ namespace MediaBrowser.Server.Implementations.HttpServer.NetListener } } - protected Task ProcessRequestAsync(HttpListenerContext context) + private Task ProcessRequestAsync(HttpListenerContext context) { var request = context.Request; @@ -235,7 +236,25 @@ namespace MediaBrowser.Server.Implementations.HttpServer.NetListener _localEndPoints.GetOrAdd(address, address); } - LoggerUtils.LogRequest(_logger, request); + LogRequest(_logger, request); + } + + /// + /// Logs the request. + /// + /// The logger. + /// The request. + private static void LogRequest(ILogger logger, HttpListenerRequest request) + { + var log = new StringBuilder(); + + //var headers = string.Join(",", request.Headers.AllKeys.Where(i => !string.Equals(i, "cookie", StringComparison.OrdinalIgnoreCase) && !string.Equals(i, "Referer", StringComparison.OrdinalIgnoreCase)).Select(k => k + "=" + request.Headers[k])); + + //log.AppendLine("Ip: " + request.RemoteEndPoint + ". Headers: " + headers); + + var type = request.IsWebSocketRequest ? "Web Socket" : "HTTP " + request.HttpMethod; + + logger.LogMultiline(type + " " + request.Url, LogSeverity.Debug, log); } public void Stop() -- cgit v1.2.3