From 88b2fc61ff5e9a190d306a784839ad1ed1b30a8f Mon Sep 17 00:00:00 2001
From: "Justin Clark-Casey (justincc)" <jjustincc@googlemail.com>
Date: Tue, 19 Aug 2014 00:42:19 +0100
Subject: [PATCH] Add clientstack.<scene>.OQRERequestsWaiting stat

Only present if OQRE is enabled
---
 .../Linden/UDP/OutgoingQueueRefillEngine.cs   | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

diff --git a/OpenSim/Region/ClientStack/Linden/UDP/OutgoingQueueRefillEngine.cs b/OpenSim/Region/ClientStack/Linden/UDP/OutgoingQueueRefillEngine.cs
index 8777402fc4..0659d8e47e 100644
--- a/OpenSim/Region/ClientStack/Linden/UDP/OutgoingQueueRefillEngine.cs
+++ b/OpenSim/Region/ClientStack/Linden/UDP/OutgoingQueueRefillEngine.cs
@@ -74,6 +74,8 @@ namespace OpenSim.Region.ClientStack.LindenUDP
 
         private LLUDPServer m_udpServer;
 
+        private Stat m_oqreRequestsWaitingStat;
+
         /// <summary>
         /// Used to signal that we are ready to complete stop.
         /// </summary>
@@ -107,6 +109,21 @@ namespace OpenSim.Region.ClientStack.LindenUDP
 
                 m_requestQueue = new BlockingCollection<RefillRequest>(new ConcurrentQueue<RefillRequest>(), 5000);
 
+                m_oqreRequestsWaitingStat = 
+                    new Stat(
+                        "OQRERequestsWaiting",
+                        "Number of outgong queue refill requests waiting for processing.",
+                        "",
+                        "",
+                        "clientstack",
+                        m_udpServer.Scene.Name,
+                        StatType.Pull,
+                        MeasuresOfInterest.None,
+                        stat => stat.Value = m_requestQueue.Count,
+                        StatVerbosity.Debug);
+
+                StatsManager.RegisterStat(m_oqreRequestsWaitingStat);
+
                 Watchdog.StartThread(
                     ProcessRequests,
                     String.Format("OutgoingQueueRefillEngineThread ({0})", m_udpServer.Scene.Name),
@@ -161,6 +178,8 @@ namespace OpenSim.Region.ClientStack.LindenUDP
                 finally
                 {
                     m_cancelSource.Dispose();
+                    StatsManager.DeregisterStat(m_oqreRequestsWaitingStat);
+                    m_oqreRequestsWaitingStat = null;
                     m_requestQueue = null;
                 }
             }