From 1b7b664c8696531fec26378d1386362d8a3da55e Mon Sep 17 00:00:00 2001
From: Justin Clark-Casey (justincc)
Date: Mon, 15 Jul 2013 23:22:39 +0100
Subject: Add request received/handling stats for caps which are served by http
poll handlers.
This adds explicit cap poll handler supporting to the Caps classes rather than relying on callers to do the complicated coding.
Other refactoring was required to get logic into the right places to support this.
---
.../Framework/Servers/HttpServer/BaseHttpServer.cs | 2 +
.../Servers/HttpServer/PollServiceEventArgs.cs | 14 ++++++
.../Servers/HttpServer/PollServiceHttpRequest.cs | 45 +++++++++++++++++
.../HttpServer/PollServiceRequestManager.cs | 58 +++-------------------
4 files changed, 69 insertions(+), 50 deletions(-)
(limited to 'OpenSim/Framework/Servers/HttpServer')
diff --git a/OpenSim/Framework/Servers/HttpServer/BaseHttpServer.cs b/OpenSim/Framework/Servers/HttpServer/BaseHttpServer.cs
index 6863e0e..c4e569d 100644
--- a/OpenSim/Framework/Servers/HttpServer/BaseHttpServer.cs
+++ b/OpenSim/Framework/Servers/HttpServer/BaseHttpServer.cs
@@ -387,6 +387,8 @@ namespace OpenSim.Framework.Servers.HttpServer
if (TryGetPollServiceHTTPHandler(request.UriPath.ToString(), out psEvArgs))
{
+ psEvArgs.RequestsReceived++;
+
PollServiceHttpRequest psreq = new PollServiceHttpRequest(psEvArgs, context, request);
if (psEvArgs.Request != null)
diff --git a/OpenSim/Framework/Servers/HttpServer/PollServiceEventArgs.cs b/OpenSim/Framework/Servers/HttpServer/PollServiceEventArgs.cs
index 3079a7e..020bfd5 100644
--- a/OpenSim/Framework/Servers/HttpServer/PollServiceEventArgs.cs
+++ b/OpenSim/Framework/Servers/HttpServer/PollServiceEventArgs.cs
@@ -55,12 +55,26 @@ namespace OpenSim.Framework.Servers.HttpServer
Inventory = 2
}
+ public string Url { get; set; }
+
+ ///
+ /// Number of requests received for this poll service.
+ ///
+ public int RequestsReceived { get; set; }
+
+ ///
+ /// Number of requests handled by this poll service.
+ ///
+ public int RequestsHandled { get; set; }
+
public PollServiceEventArgs(
RequestMethod pRequest,
+ string pUrl,
HasEventsMethod pHasEvents, GetEventsMethod pGetEvents, NoEventsMethod pNoEvents,
UUID pId, int pTimeOutms)
{
Request = pRequest;
+ Url = pUrl;
HasEvents = pHasEvents;
GetEvents = pGetEvents;
NoEvents = pNoEvents;
diff --git a/OpenSim/Framework/Servers/HttpServer/PollServiceHttpRequest.cs b/OpenSim/Framework/Servers/HttpServer/PollServiceHttpRequest.cs
index 723530a..6aa9479 100644
--- a/OpenSim/Framework/Servers/HttpServer/PollServiceHttpRequest.cs
+++ b/OpenSim/Framework/Servers/HttpServer/PollServiceHttpRequest.cs
@@ -26,13 +26,19 @@
*/
using System;
+using System.Collections;
+using System.Reflection;
+using System.Text;
using HttpServer;
+using log4net;
using OpenMetaverse;
namespace OpenSim.Framework.Servers.HttpServer
{
public class PollServiceHttpRequest
{
+ private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
+
public readonly PollServiceEventArgs PollServiceArgs;
public readonly IHttpClientContext HttpContext;
public readonly IHttpRequest Request;
@@ -48,5 +54,44 @@ namespace OpenSim.Framework.Servers.HttpServer
RequestTime = System.Environment.TickCount;
RequestID = UUID.Random();
}
+
+ internal void DoHTTPGruntWork(BaseHttpServer server, Hashtable responsedata)
+ {
+ OSHttpResponse response
+ = new OSHttpResponse(new HttpResponse(HttpContext, Request), HttpContext);
+
+ byte[] buffer = server.DoHTTPGruntWork(responsedata, response);
+
+ response.SendChunked = false;
+ response.ContentLength64 = buffer.Length;
+ response.ContentEncoding = Encoding.UTF8;
+
+ try
+ {
+ response.OutputStream.Write(buffer, 0, buffer.Length);
+ }
+ catch (Exception ex)
+ {
+ m_log.Warn(string.Format("[POLL SERVICE WORKER THREAD]: Error ", ex));
+ }
+ finally
+ {
+ //response.OutputStream.Close();
+ try
+ {
+ response.OutputStream.Flush();
+ response.Send();
+
+ //if (!response.KeepAlive && response.ReuseContext)
+ // response.FreeContext();
+ }
+ catch (Exception e)
+ {
+ m_log.Warn(String.Format("[POLL SERVICE WORKER THREAD]: Error ", e));
+ }
+
+ PollServiceArgs.RequestsHandled++;
+ }
+ }
}
}
\ No newline at end of file
diff --git a/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs b/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs
index aee3e3c..1b9010a 100644
--- a/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs
+++ b/OpenSim/Framework/Servers/HttpServer/PollServiceRequestManager.cs
@@ -157,8 +157,7 @@ namespace OpenSim.Framework.Servers.HttpServer
{
foreach (PollServiceHttpRequest req in m_retryRequests)
{
- DoHTTPGruntWork(m_server,req,
- req.PollServiceArgs.NoEvents(req.RequestID, req.PollServiceArgs.Id));
+ req.DoHTTPGruntWork(m_server, req.PollServiceArgs.NoEvents(req.RequestID, req.PollServiceArgs.Id));
}
}
catch
@@ -179,8 +178,8 @@ namespace OpenSim.Framework.Servers.HttpServer
try
{
wreq = m_requests.Dequeue(0);
- DoHTTPGruntWork(m_server,wreq,
- wreq.PollServiceArgs.NoEvents(wreq.RequestID, wreq.PollServiceArgs.Id));
+ wreq.DoHTTPGruntWork(
+ m_server, wreq.PollServiceArgs.NoEvents(wreq.RequestID, wreq.PollServiceArgs.Id));
}
catch
{
@@ -214,7 +213,7 @@ namespace OpenSim.Framework.Servers.HttpServer
{
try
{
- DoHTTPGruntWork(m_server, req, responsedata);
+ req.DoHTTPGruntWork(m_server, responsedata);
}
catch (ObjectDisposedException) // Browser aborted before we could read body, server closed the stream
{
@@ -227,7 +226,7 @@ namespace OpenSim.Framework.Servers.HttpServer
{
try
{
- DoHTTPGruntWork(m_server, req, responsedata);
+ req.DoHTTPGruntWork(m_server, responsedata);
}
catch (ObjectDisposedException) // Browser aborted before we could read body, server closed the stream
{
@@ -242,8 +241,8 @@ namespace OpenSim.Framework.Servers.HttpServer
{
if ((Environment.TickCount - req.RequestTime) > req.PollServiceArgs.TimeOutms)
{
- DoHTTPGruntWork(m_server, req,
- req.PollServiceArgs.NoEvents(req.RequestID, req.PollServiceArgs.Id));
+ req.DoHTTPGruntWork(
+ m_server, req.PollServiceArgs.NoEvents(req.RequestID, req.PollServiceArgs.Id));
}
else
{
@@ -258,46 +257,5 @@ namespace OpenSim.Framework.Servers.HttpServer
}
}
}
-
- // DoHTTPGruntWork changed, not sending response
- // do the same work around as core
-
- internal static void DoHTTPGruntWork(BaseHttpServer server, PollServiceHttpRequest req, Hashtable responsedata)
- {
- OSHttpResponse response
- = new OSHttpResponse(new HttpResponse(req.HttpContext, req.Request), req.HttpContext);
-
- byte[] buffer = server.DoHTTPGruntWork(responsedata, response);
-
- response.SendChunked = false;
- response.ContentLength64 = buffer.Length;
- response.ContentEncoding = Encoding.UTF8;
-
- try
- {
- response.OutputStream.Write(buffer, 0, buffer.Length);
- }
- catch (Exception ex)
- {
- m_log.Warn(string.Format("[POLL SERVICE WORKER THREAD]: Error ", ex));
- }
- finally
- {
- //response.OutputStream.Close();
- try
- {
- response.OutputStream.Flush();
- response.Send();
-
- //if (!response.KeepAlive && response.ReuseContext)
- // response.FreeContext();
- }
- catch (Exception e)
- {
- m_log.Warn(String.Format("[POLL SERVICE WORKER THREAD]: Error ", e));
- }
- }
- }
}
-}
-
+}
\ No newline at end of file
--
cgit v1.1