From daca971bf6de2020be00c6f0641494bd481bd091 Mon Sep 17 00:00:00 2001 From: Dr Scofield Date: Wed, 25 Jun 2008 13:10:12 +0000 Subject: further work on the HttpServer stuff. not functional yet. just sharing what crimes i'm committing. --- OpenSim/Framework/Servers/OSHttpRequestPump.cs | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) (limited to 'OpenSim/Framework/Servers/OSHttpRequestPump.cs') diff --git a/OpenSim/Framework/Servers/OSHttpRequestPump.cs b/OpenSim/Framework/Servers/OSHttpRequestPump.cs index 8a3e73f..06e41e4 100644 --- a/OpenSim/Framework/Servers/OSHttpRequestPump.cs +++ b/OpenSim/Framework/Servers/OSHttpRequestPump.cs @@ -31,25 +31,28 @@ using HttpServer; namespace OpenSim.Framework.Servers { /// - /// OSHttpServer provides an HTTP server bound to a specific - /// port. When instantiated with just address and port it uses - /// normal HTTP, when instantiated with address, port, and X509 - /// certificate, it uses HTTPS. + /// An OSHttpRequestPump fetches incoming OSHttpRequest objects + /// from the OSHttpRequestQueue and feeds them to all subscribed + /// parties. Each OSHttpRequestPump encapsulates one thread to do + /// the work and there is a fixed number of pumps for each + /// OSHttpServer object. /// public class OSHttpRequestPump { - protected OSHttpServer _httpServer; + protected OSHttpServer _server; + protected OSHttpRequestQueue _queue; public OSHttpRequestPump() { } - public static OSHttpRequestPump[] Pumps(OSHttpServer server, int poolSize) + public static OSHttpRequestPump[] Pumps(OSHttpServer server, OSHttpRequestQueue queue, int poolSize) { OSHttpRequestPump[] pumps = new OSHttpRequestPump[poolSize]; for (int i = 0; i < pumps.Length; i++) { - pumps[i]._httpServer = server; + pumps[i]._server = server; + pumps[i]._queue = queue; } return pumps; -- cgit v1.1