ogb912/opensim
1
0
Fork 0
mirror of https://github.com/opensim/opensim.git synced 2026-08-05 08:55:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

further work on the HttpServer stuff. not functional yet. just sharing

Browse Source 
what crimes i'm committing.
This commit is contained in:
Dr Scofield
2008-06-25 13:10:12 +00:00
parent b713f4a540
commit daca971bf6
4 changed files with 126 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
OpenSim/Framework/Servers/OSHttpServer.cs
View File

@@ -50,8 +50,12 @@ namespace OpenSim.Framework.Servers
// underlying HttpServer.HttpListener
protected HttpListener _listener;
// underlying core/engine thread
protected Thread _engine;
// Queue containing (OS)HttpRequests
protected OSHttpRequestQueue _queue;
// OSHttpRequestPumps "pumping" incoming OSHttpRequests
// upwards
protected OSHttpRequestPump[] _pumps;
@@ -72,6 +76,11 @@ namespace OpenSim.Framework.Servers
get { return _isSecure; }
}
public int QueueSize
{
get { return _pumps.Length; }
}
/// <summary>
/// Instantiate an HTTP server.
/// </summary>
@@ -80,17 +89,37 @@ namespace OpenSim.Framework.Servers
_engineId = String.Format("OSHttpServer [HTTP:{0}/ps:{1}]", port, poolSize);
_isSecure = false;
_pumps = OSHttpRequestPump.Pumps(this, poolSize);
_listener = new HttpListener(address, port);
_queue = new OSHttpRequestQueue();
_pumps = OSHttpRequestPump.Pumps(this, _queue, poolSize);
}
/// <summary>
/// Instantiate an HTTPS server.
/// </summary>
public OSHttpServer(IPAddress address, int port, X509Certificate certificate, int poolSize) :
this(address, port, poolSize)
public OSHttpServer(IPAddress address, int port, X509Certificate certificate, int poolSize)
{
_engineId = String.Format("OSHttpServer [HTTPS:{0}/ps:{1}]", port, poolSize);
_isSecure = true;
_listener = new HttpListener(address, port, certificate);
_queue = new OSHttpRequestQueue();
_pumps = OSHttpRequestPump.Pumps(this, _queue, poolSize);
}
/// <summary>
/// Turn an HttpRequest into an OSHttpRequestItem and place it
/// in the queue. The OSHttpRequestQueue object will pulse the
/// next available idle pump.
/// </summary>
protected void OnHttpRequest(HttpClientContext client, HttpRequest request)
{
// turn request into OSHttpRequest
OSHttpRequest req = new OSHttpRequest(client, request);
// place OSHttpRequest into _httpRequestQueue, will
// trigger Pulse to idle waiting pumps
_queue.Enqueue(req);
}
/// <summary>
@@ -102,6 +131,7 @@ namespace OpenSim.Framework.Servers
_engine.Name = _engineId;
_engine.IsBackground = true;
_engine.Start();
ThreadTracker.Add(_engine);
}
@@ -111,9 +141,12 @@ namespace OpenSim.Framework.Servers
{
while (true)
{
// do stuff
_listener.RequestHandler += OnHttpRequest;
_listener.Start(QueueSize);
}
}
}
}