From 8b933e53c0c679df4b150849a8984ed6068655ad Mon Sep 17 00:00:00 2001 From: Dr Scofield Date: Tue, 15 Jul 2008 13:06:30 +0000 Subject: fixes handler scoring method. XmlRpc code path now fully working with HttpServer. :-) --- OpenSim/Framework/Servers/OSHttpRequestPump.cs | 61 +++++++++++++++++++++++--- OpenSim/Framework/Servers/OSHttpServer.cs | 7 ++- 2 files changed, 61 insertions(+), 7 deletions(-) (limited to 'OpenSim/Framework/Servers') diff --git a/OpenSim/Framework/Servers/OSHttpRequestPump.cs b/OpenSim/Framework/Servers/OSHttpRequestPump.cs index 9d0ffc1..be4c3ff 100644 --- a/OpenSim/Framework/Servers/OSHttpRequestPump.cs +++ b/OpenSim/Framework/Servers/OSHttpRequestPump.cs @@ -25,9 +25,12 @@ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. */ +// #define DEBUGGING + using System; using System.Collections.Generic; using System.Collections.Specialized; +using System.Diagnostics; using System.IO; using System.Net; using System.Reflection; @@ -36,6 +39,7 @@ using System.Threading; using log4net; using HttpServer; + namespace OpenSim.Framework.Servers { /// @@ -57,12 +61,16 @@ namespace OpenSim.Framework.Servers public string EngineID { - get { return String.Format("{0}-{1}", _server.EngineID, _id); } + get { return String.Format("{0} pump {1}", _server.EngineID, _id); } } - public OSHttpRequestPump() + public OSHttpRequestPump(OSHttpServer server, OSHttpRequestQueue queue, int id) { + _server = server; + _queue = queue; + _id = id; + _engine = new Thread(new ThreadStart(Engine)); _engine.Name = EngineID; _engine.IsBackground = true; @@ -77,9 +85,7 @@ namespace OpenSim.Framework.Servers OSHttpRequestPump[] pumps = new OSHttpRequestPump[poolSize]; for (int i = 0; i < pumps.Length; i++) { - pumps[i]._server = server; - pumps[i]._queue = queue; - pumps[i]._id = i; + pumps[i] = new OSHttpRequestPump(server, queue, i); } return pumps; @@ -166,12 +172,15 @@ namespace OpenSim.Framework.Servers { Dictionary scoredHandlers = new Dictionary(); + _log.DebugFormat("[{0}] MatchHandlers for {1}", EngineID, req); foreach (OSHttpHandler h in handlers) { Regex pathRegex = h.Path; Dictionary headerRegexs = h.Headers; Regex endPointsRegex = h.IPEndPointWhitelist; + // initial anchor + scoredHandlers[h] = 0; // first, check whether IPEndPointWhitelist applies // and, if it does, whether client is on that white @@ -218,6 +227,9 @@ namespace OpenSim.Framework.Servers { // no: remove the handler if it was added // earlier and on to the next one + _LogDumpOSHttpHandler(String.Format("[{0}] dropping handler for {1}: null {2} header field", + EngineID, req, tag), h); + scoredHandlers.Remove(h); break; } @@ -228,6 +240,8 @@ namespace OpenSim.Framework.Servers if (!hm.Success) { // no: remove the handler if it was added // earlier and on to the next one + _LogDumpOSHttpHandler(String.Format("[{0}] dropping handler for {1}: {2} header field content \"{3}\" does not match regex {4}", + EngineID, req, tag, headers[tag], headerRegexs[tag].ToString()), h); scoredHandlers.Remove(h); break; } @@ -238,11 +252,14 @@ namespace OpenSim.Framework.Servers if ((null != h.ContentTypeChecker) && !h.ContentTypeChecker(req)) { scoredHandlers.Remove(h); + _LogDumpOSHttpHandler(String.Format("[{0}] dropping handler for {1}: content checker returned false", + EngineID, req), h); break; } // ok: header matches headersMatch++; + _LogDumpOSHttpHandler(String.Format("[{0}] MatchHandlers: found handler for {1}", EngineID, req), h); continue; } // check whether h got kicked out @@ -251,15 +268,49 @@ namespace OpenSim.Framework.Servers scoredHandlers[h] += headersMatch; } } + + foreach (OSHttpHandler hh in scoredHandlers.Keys) + { + _LogDumpOSHttpHandler("scoredHandlers:", hh); + } List matchingHandlers = new List(scoredHandlers.Keys); + _LogDumpOSHttpHandlerList("before sort: ", matchingHandlers); matchingHandlers.Sort(delegate(OSHttpHandler x, OSHttpHandler y) { return scoredHandlers[x] - scoredHandlers[y]; }); + + _LogDumpOSHttpHandlerList("after sort: ", matchingHandlers); return matchingHandlers; } + + [ConditionalAttribute("DEBUGGING")] + private void _LogDumpOSHttpHandler(string msg, OSHttpHandler h) + { + _log.Debug(msg); + + StringWriter sw = new StringWriter(); + sw.WriteLine("{0}", h.ToString()); + sw.WriteLine(" path regex {0}", null == h.Path ? "null": h.Path.ToString()); + foreach (string tag in h.Headers.Keys) + { + sw.WriteLine(" header[{0}] {1}", tag, h.Headers[tag].ToString()); + } + sw.WriteLine(" IP whitelist {0}", null == h.IPEndPointWhitelist ? "null" : h.IPEndPointWhitelist.ToString()); + sw.WriteLine(); + sw.Close(); + + _log.Debug(sw.ToString()); + } + [ConditionalAttribute("DEBUGGING")] + private void _LogDumpOSHttpHandlerList(string msg, List l) + { + _log.DebugFormat("OSHttpHandlerList dump: {0}", msg); + foreach (OSHttpHandler h in l) + _LogDumpOSHttpHandler("OSHttpHandler", h); + } } } diff --git a/OpenSim/Framework/Servers/OSHttpServer.cs b/OpenSim/Framework/Servers/OSHttpServer.cs index 4940101..e0d26ff 100644 --- a/OpenSim/Framework/Servers/OSHttpServer.cs +++ b/OpenSim/Framework/Servers/OSHttpServer.cs @@ -106,8 +106,9 @@ namespace OpenSim.Framework.Servers /// public OSHttpServer(IPAddress address, int port, int poolSize) { - _engineId = String.Format("OSHttpServer [HTTP:{0}/ps:{1}]", port, poolSize); + _engineId = String.Format("OSHttpServer (HTTP:{0})", port); _isSecure = false; + _log.DebugFormat("[{0}] HTTP server instantiated", EngineID); _listener = new HttpListener(address, port); _queue = new OSHttpRequestQueue(); @@ -121,6 +122,7 @@ namespace OpenSim.Framework.Servers { _engineId = String.Format("OSHttpServer [HTTPS:{0}/ps:{1}]", port, poolSize); _isSecure = true; + _log.DebugFormat("[{0}] HTTPS server instantiated", EngineID); _listener = new HttpListener(address, port, certificate); _queue = new OSHttpRequestQueue(); @@ -176,8 +178,9 @@ namespace OpenSim.Framework.Servers lock (_syncObject) Monitor.Wait(_syncObject); } - catch (Exception) + catch (Exception ex) { + _log.DebugFormat("[{0}] HTTP server startup failed: {1}", EngineID, ex.ToString()); } _log.InfoFormat("[{0}] HTTP server terminated", EngineID); -- cgit v1.1