plumbing for multiple inventory servers. Mostly done on the region server side.

TODO next is to make the login server read/write a users inventory from the correct server (the inventory url set in a userprofile)
On the region side, although not tested with multiple servers it should work if that inventory url was set, and the inventory servers urls have been added to the CommunicationsManager, using CommunicationsManager.AddInventoryService(string hostUrl)

1 files changed, 65 insertions, 7 deletions

diff --git a/OpenSim/Framework/Communications/CommunicationsManager.cs b/OpenSim/Framework/Communications/CommunicationsManager.cs
index 5de0c71..0410f0e 100644
--- a/OpenSim/Framework/Communications/CommunicationsManager.cs
+++ b/OpenSim/Framework/Communications/CommunicationsManager.cs
@@ -55,12 +55,6 @@ namespace OpenSim.Framework.Communications
             get { return m_gridService; }
         }
 
-        protected IInventoryServices m_inventoryService;
-
-        public IInventoryServices InventoryService
-        {
-            get { return m_inventoryService; }
-        }
 
         protected IInterRegionCommunications m_interRegion;
 
@@ -106,6 +100,70 @@ namespace OpenSim.Framework.Communications
          //   m_transactionsManager = new AgentAssetTransactionsManager(this, dumpAssetsToFile);
         }
 
+        #region Inventory
+        protected string m_defaultInventoryHost = "default";
+
+        protected List<IInventoryServices> m_inventoryServices = new List<IInventoryServices>();
+        // protected IInventoryServices m_inventoryService;
+
+        public IInventoryServices InventoryService
+        {
+            get
+            {
+                if (m_inventoryServices.Count > 0)
+                {
+                    // return m_inventoryServices[0];
+                    IInventoryServices invService;
+                    if (TryGetInventoryService(m_defaultInventoryHost, out invService))
+                    {
+                        return invService;
+                    }
+
+                }
+
+                return null;
+            }
+        }
+
+        public bool TryGetInventoryService(string host, out IInventoryServices inventoryService)
+        {
+            if ((host == string.Empty) | (host == "default"))
+            {
+                host = m_defaultInventoryHost;
+            }
+
+
+            lock (m_inventoryServices)
+            {
+                foreach (IInventoryServices service in m_inventoryServices)
+                {
+                    if (service.Host == host)
+                    {
+                        inventoryService = service;
+                        return true;
+                    }
+                }
+            }
+
+            inventoryService = null;
+            return false;
+        }
+
+        public virtual void AddInventoryService(string hostUrl)
+        {
+
+        }
+
+        public virtual void AddInventoryService(IInventoryServices service)
+        {
+            lock (m_inventoryServices)
+            {
+                m_inventoryServices.Add(service);
+            }
+        }
+
+        #endregion
+
         public void doCreate(string[] cmmdParams)
         {
             switch (cmmdParams[0])
@@ -167,7 +225,7 @@ namespace OpenSim.Framework.Communications
             }
             else
             {
-                m_inventoryService.CreateNewUserInventory(userProf.ID);
+                InventoryService.CreateNewUserInventory(userProf.ID);
                 m_log.Info("[USERS]: Created new inventory set for " + firstName + " " + lastName);
                 return userProf.ID;
             }