4 files changed, 123 insertions, 93 deletions

diff --git a/OpenSim/Region/Application/Application.cs b/OpenSim/Region/Application/Application.cs
index ebfebc4..78636c4 100644
--- a/OpenSim/Region/Application/Application.cs
+++ b/OpenSim/Region/Application/Application.cs
@@ -27,6 +27,7 @@
 
 using System;
 using System.IO;
+using System.Net;
 using System.Reflection;
 using log4net;
 using log4net.Config;
@@ -73,6 +74,7 @@ namespace OpenSim
             AppDomain.CurrentDomain.UnhandledException +=
                 new UnhandledExceptionEventHandler(CurrentDomain_UnhandledException);
 
+            ServicePointManager.DefaultConnectionLimit = 6;
 
             // Add the arguments supplied when running the application to the configuration
             ArgvConfigSource configSource = new ArgvConfigSource(args);
diff --git a/OpenSim/Region/ClientStack/Linden/Caps/WebFetchInvDescModule.cs b/OpenSim/Region/ClientStack/Linden/Caps/WebFetchInvDescModule.cs
index 2475b1f..4908c2c 100644
--- a/OpenSim/Region/ClientStack/Linden/Caps/WebFetchInvDescModule.cs
+++ b/OpenSim/Region/ClientStack/Linden/Caps/WebFetchInvDescModule.cs
@@ -42,6 +42,7 @@ using OpenSim.Region.Framework.Scenes;
 using OpenSim.Services.Interfaces;
 using Caps = OpenSim.Framework.Capabilities.Caps;
 using OpenSim.Capabilities.Handlers;
+using OpenSim.Framework.Monitoring;
 
 namespace OpenSim.Region.ClientStack.Linden
 {
@@ -58,14 +59,13 @@ namespace OpenSim.Region.ClientStack.Linden
         private IInventoryService m_InventoryService;
         private ILibraryService m_LibraryService;
 
-        private WebFetchInvDescHandler m_webFetchHandler;
-
-//        private ManualResetEvent m_ev = new ManualResetEvent(true);
-        private object m_lock = new object();
+        private static WebFetchInvDescHandler m_webFetchHandler;
 
         private Dictionary<UUID, string> m_capsDict = new Dictionary<UUID, string>();
-        private Dictionary<UUID, Hashtable> m_requests = new Dictionary<UUID, Hashtable>();
-        bool m_busy = false;
+        private static Thread[] m_workerThreads = null;
+
+        private static OpenMetaverse.BlockingQueue<PollServiceInventoryEventArgs> m_queue =
+                new OpenMetaverse.BlockingQueue<PollServiceInventoryEventArgs>();
 
         #region ISharedRegionModule Members
 
@@ -95,6 +95,22 @@ namespace OpenSim.Region.ClientStack.Linden
 
             m_scene.EventManager.OnRegisterCaps += RegisterCaps;
             m_scene.EventManager.OnDeregisterCaps += DeregisterCaps;
+
+            if (m_workerThreads == null)
+            {
+                m_workerThreads = new Thread[2];
+
+                for (uint i = 0; i < 2; i++)
+                {
+                    m_workerThreads[i] = Watchdog.StartThread(DoInventoryRequests,
+                            String.Format("InventoryWorkerThread{0}", i),
+                            ThreadPriority.Normal,
+                            false,
+                            true,
+                            null,
+                            int.MaxValue);
+                }
+            }
         }
 
         public void PostInitialise()
@@ -112,13 +128,103 @@ namespace OpenSim.Region.ClientStack.Linden
 
         #endregion
 
+        ~WebFetchInvDescModule()
+        {
+            foreach (Thread t in m_workerThreads)
+                t.Abort();
+        }
+
+        private class PollServiceInventoryEventArgs : PollServiceEventArgs
+        {
+            private List<Hashtable> requests =
+                    new List<Hashtable>();
+            private Dictionary<UUID, Hashtable> responses =
+                    new Dictionary<UUID, Hashtable>();
+
+            public PollServiceInventoryEventArgs(UUID pId) :
+                    base(null, null, null, null, pId, 30000)
+            {
+                HasEvents = (x, y) => { return this.responses.ContainsKey(x); };
+                GetEvents = (x, y, s) =>
+                {
+                    try
+                    {
+                        return this.responses[x];
+                    }
+                    finally
+                    {
+                        responses.Remove(x);
+                    }
+                };
+
+                Request = (x, y) =>
+                {
+                    y["RequestID"] = x.ToString();
+                    lock (this.requests)
+                        this.requests.Add(y);
+
+                    m_queue.Enqueue(this);
+                };
+
+                NoEvents = (x, y) =>
+                {
+                    lock (this.requests)
+                    {
+                        Hashtable request = requests.Find(id => id["RequestID"].ToString() == x.ToString());
+                        requests.Remove(request);
+                    }
+
+                    Hashtable response = new Hashtable();
+
+                    response["int_response_code"] = 500;
+                    response["str_response_string"] = "Script timeout";
+                    response["content_type"] = "text/plain";
+                    response["keepalive"] = false;
+                    response["reusecontext"] = false;
+
+                    return response;
+                };
+            }
+
+            public void Process()
+            {
+                Hashtable request = null;
+
+                try
+                {
+                    lock (this.requests)
+                    {
+                        request = requests[0];
+                        requests.RemoveAt(0);
+                    }
+                }
+                catch
+                {
+                    return;
+                }
+
+                UUID requestID = new UUID(request["RequestID"].ToString());
+
+                Hashtable response = new Hashtable();
+
+                response["int_response_code"] = 200;
+                response["content_type"] = "text/plain";
+                response["keepalive"] = false;
+                response["reusecontext"] = false;
+
+                response["str_response_string"] = m_webFetchHandler.FetchInventoryDescendentsRequest(request["body"].ToString(), String.Empty, String.Empty, null, null);
+
+                responses[requestID] = response; 
+            }
+        }
+
         private void RegisterCaps(UUID agentID, Caps caps)
         {
             string capUrl = "/CAPS/" + UUID.Random() + "/";
 
             // Register this as a poll service
             // absurd large timeout to tune later to make a bit less than viewer
-            PollServiceEventArgs args = new PollServiceEventArgs(HttpRequestHandler, HasEvents, GetEvents, NoEvents, agentID, 300000);
+            PollServiceInventoryEventArgs args = new PollServiceInventoryEventArgs(agentID);
             
             args.Type = PollServiceEventArgs.EventType.Inventory;
             MainServer.Instance.AddPollServiceHTTPHandler(capUrl, args);
@@ -136,8 +242,6 @@ namespace OpenSim.Region.ClientStack.Linden
             caps.RegisterHandler("FetchInventoryDescendents2", String.Format("{0}://{1}:{2}{3}", protocol, hostName, port, capUrl));
 
             m_capsDict[agentID] = capUrl;
-
-            m_busy = false;
         }
 
         private void DeregisterCaps(UUID agentID, Caps caps)
@@ -151,93 +255,14 @@ namespace OpenSim.Region.ClientStack.Linden
             }
         }
 
-        public void HttpRequestHandler(UUID requestID, Hashtable request)
-        {
-//            m_log.DebugFormat("[FETCH2]: Received request {0}", requestID);
-            lock(m_lock)
-                m_requests[requestID] = request;
-        }
-
-        private bool HasEvents(UUID requestID, UUID sessionID)
+        private void DoInventoryRequests()
         {
-            lock (m_lock)
+            while (true)
             {
-/*
-                if (m_ev.WaitOne(0))
-                {
-                    m_ev.Reset();
-                    return true;
-                }
-                return false;
- */
-                return !m_busy;
-            }
-        }
-
-        private Hashtable NoEvents(UUID requestID, UUID sessionID)
-        {
-            lock(m_lock)
-                m_requests.Remove(requestID);
-
-            Hashtable response = new Hashtable();
-
-            response["int_response_code"] = 500;
-            response["str_response_string"] = "Script timeout";
-            response["content_type"] = "text/plain";
-            response["keepalive"] = false;
-            response["reusecontext"] = false;
+                PollServiceInventoryEventArgs args = m_queue.Dequeue();
 
-            lock (m_lock)
-                m_busy = false;
-
-            return response;
-        }
-
-        private Hashtable GetEvents(UUID requestID, UUID sessionID, string request)
-        {
-            lock (m_lock)
-                m_busy = true;
-
-            Hashtable response = new Hashtable();
-
-            response["int_response_code"] = 500;
-            response["str_response_string"] = "Internal error";
-            response["content_type"] = "text/plain";
-            response["keepalive"] = false;
-            response["reusecontext"] = false;
-
-            try
-            {
-
-                Hashtable requestHash;
-                lock (m_lock)
-                {
-                    if (!m_requests.TryGetValue(requestID, out requestHash))
-                    {
-                        m_busy = false;
-                        //                        m_ev.Set();
-                        response["str_response_string"] = "Invalid request";
-                        return response;
-                    }
-                    m_requests.Remove(requestID);
-                }
-
-//                m_log.DebugFormat("[FETCH2]: Processed request {0}", requestID);
-
-                string reply = m_webFetchHandler.FetchInventoryDescendentsRequest(requestHash["body"].ToString(), String.Empty, String.Empty, null, null);
-               
-
-                response["int_response_code"] = 200;
-                response["str_response_string"] = reply;
+                args.Process();
             }
-            finally
-            {
-                lock (m_lock)
-//                    m_ev.Set();
-                    m_busy = false;
-            }
-
-            return response;
         }
     }
 }
diff --git a/OpenSim/Region/CoreModules/Avatar/InstantMessage/MessageTransferModule.cs b/OpenSim/Region/CoreModules/Avatar/InstantMessage/MessageTransferModule.cs
index 1406aae..0c067d7 100644
--- a/OpenSim/Region/CoreModules/Avatar/InstantMessage/MessageTransferModule.cs
+++ b/OpenSim/Region/CoreModules/Avatar/InstantMessage/MessageTransferModule.cs
@@ -137,6 +137,9 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage
         {
             UUID toAgentID = new UUID(im.toAgentID);
 
+            if (toAgentID == UUID.Zero)
+                return;
+
             // Try root avatar only first
             foreach (Scene scene in m_Scenes)
             {
diff --git a/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs b/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
index d5e611c..f9b4bfd 100644
--- a/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
+++ b/OpenSim/Region/ScriptEngine/Shared/Api/Implementation/LSL_Api.cs
@@ -3420,7 +3420,7 @@ namespace OpenSim.Region.ScriptEngine.Shared.Api
         public void llInstantMessage(string user, string message)
         {
             UUID result;
-            if (!UUID.TryParse(user, out result))
+            if (!UUID.TryParse(user, out result) || result == UUID.Zero)
             {
                 ShoutError("An invalid key  was passed to llInstantMessage");
                 ScriptSleep(2000);