From 2e71972b8b38dce54729a474c677d0af0d8a343b Mon Sep 17 00:00:00 2001
From: Adam Frisby <adam@gwala.net>
Date: Sun, 24 Jun 2007 18:17:48 +0000
Subject: [PATCH] * Updated to use multi-listeners

---
 .../OGS1GridServices.cs                       | 54 ++++++++++---------
 1 file changed, 30 insertions(+), 24 deletions(-)

diff --git a/Common/OpenGrid.Framework.Communications.OGS1/OGS1GridServices.cs b/Common/OpenGrid.Framework.Communications.OGS1/OGS1GridServices.cs
index 2293dbf838..f7634462a8 100644
--- a/Common/OpenGrid.Framework.Communications.OGS1/OGS1GridServices.cs
+++ b/Common/OpenGrid.Framework.Communications.OGS1/OGS1GridServices.cs
@@ -16,7 +16,7 @@ namespace OpenGrid.Framework.Communications.OGS1
 {
     public class OGS1GridServices : IGridServices
     {
-        public RegionCommsListener listener;
+        public Dictionary<ulong, RegionCommsListener> listeners = new Dictionary<ulong, RegionCommsListener>();
         public GridInfo grid;
         public BaseHttpServer httpListener;
         private bool initialised = false;
@@ -52,7 +52,7 @@ namespace OpenGrid.Framework.Communications.OGS1
             }
             
             // Initialise the background listeners
-            listener = new RegionCommsListener();
+            listeners[regionInfo.RegionHandle] = new RegionCommsListener();
 
             if (!initialised)
             {
@@ -62,21 +62,12 @@ namespace OpenGrid.Framework.Communications.OGS1
                 httpListener.Start();
             }
 
-            return listener;
+            return listeners[regionInfo.RegionHandle];
         }
 
         public List<RegionInfo> RequestNeighbours(RegionInfo regionInfo)
         {
-            Hashtable param = new Hashtable();
-            param["xmin"] = regionInfo.RegionLocX - 1;
-            param["ymin"] = regionInfo.RegionLocY - 1;
-            param["xmax"] = regionInfo.RegionLocX + 1;
-            param["ymax"] = regionInfo.RegionLocY + 1;
-            IList parameters = new ArrayList();
-            parameters.Add(param);
-            XmlRpcRequest req = new XmlRpcRequest("map_block", parameters);
-            XmlRpcResponse resp = req.Send(grid.GridServerURI, 3000);
-            Hashtable respData = (Hashtable)resp.Value;
+            Hashtable respData = MapBlockQuery((int)regionInfo.RegionLocX - 1, (int)regionInfo.RegionLocY - 1, (int)regionInfo.RegionLocX + 1, (int)regionInfo.RegionLocY + 1);
 
             List<RegionInfo> neighbours = new List<RegionInfo>();
 
@@ -101,23 +92,16 @@ namespace OpenGrid.Framework.Communications.OGS1
 
             return neighbours;
         }
+
         public RegionInfo RequestNeighbourInfo(ulong regionHandle)
         {
             OpenSim.Framework.Console.MainLog.Instance.Warn("Unimplemented - RequestNeighbourInfo()");
             return null;
         }
+
         public List<MapBlockData> RequestNeighbourMapBlocks(int minX, int minY, int maxX, int maxY)
         {
-            Hashtable param = new Hashtable();
-            param["xmin"] = minX;
-            param["ymin"] = minY;
-            param["xmax"] = maxX;
-            param["ymax"] = maxY;
-            IList parameters = new ArrayList();
-            parameters.Add(param);
-            XmlRpcRequest req = new XmlRpcRequest("map_block", parameters);
-            XmlRpcResponse resp = req.Send(grid.GridServerURI, 3000);
-            Hashtable respData = (Hashtable)resp.Value;
+            Hashtable respData = MapBlockQuery(minX, minY, maxX, maxY);
 
             List<MapBlockData> neighbours = new List<MapBlockData>();
 
@@ -140,6 +124,21 @@ namespace OpenGrid.Framework.Communications.OGS1
             return neighbours;
         }
 
+        private Hashtable MapBlockQuery(int minX, int minY, int maxX, int maxY)
+        {
+            Hashtable param = new Hashtable();
+            param["xmin"] = minX;
+            param["ymin"] = minY;
+            param["xmax"] = maxX;
+            param["ymax"] = maxY;
+            IList parameters = new ArrayList();
+            parameters.Add(param);
+            XmlRpcRequest req = new XmlRpcRequest("map_block", parameters);
+            XmlRpcResponse resp = req.Send(grid.GridServerURI, 3000);
+            Hashtable respData = (Hashtable)resp.Value;
+            return respData;
+        }
+
         // Grid Request Processing
         public XmlRpcResponse ExpectUser(XmlRpcRequest request)
         {
@@ -162,7 +161,14 @@ namespace OpenGrid.Framework.Communications.OGS1
 
             }
 
-            this.listener.TriggerExpectUser((ulong)requestData["regionhandle"], agentData);
+            if (listeners.ContainsKey((ulong)requestData["regionhandle"]))
+            {
+                this.listeners[(ulong)requestData["regionhandle"]].TriggerExpectUser((ulong)requestData["regionhandle"], agentData);
+            }
+            else
+            {
+                OpenSim.Framework.Console.MainLog.Instance.Error("ExpectUser() - Unknown region " + ((ulong)requestData["regionhandle"]).ToString());
+            }
 
             return new XmlRpcResponse();
         }