This is a beefy commit containing the communication modules that implement SendChildAgentUpdate. This commit has only the modules, but not their usage. It should be harmless.

1 files changed, 140 insertions, 0 deletions

diff --git a/OpenSim/Region/Environment/Modules/Communications/Local/LocalInterregionComms.cs b/OpenSim/Region/Environment/Modules/Communications/Local/LocalInterregionComms.cs
new file mode 100644
index 0000000..9661387
--- /dev/null
+++ b/OpenSim/Region/Environment/Modules/Communications/Local/LocalInterregionComms.cs
@@ -0,0 +1,140 @@
+/*

+ * Copyright (c) Contributors, http://opensimulator.org/

+ * See CONTRIBUTORS.TXT for a full list of copyright holders.

+ *

+ * Redistribution and use in source and binary forms, with or without

+ * modification, are permitted provided that the following conditions are met:

+ *     * Redistributions of source code must retain the above copyright

+ *       notice, this list of conditions and the following disclaimer.

+ *     * Redistributions in binary form must reproduce the above copyright

+ *       notice, this list of conditions and the following disclaimer in the

+ *       documentation and/or other materials provided with the distribution.

+ *     * Neither the name of the OpenSim Project nor the

+ *       names of its contributors may be used to endorse or promote products

+ *       derived from this software without specific prior written permission.

+ *

+ * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY

+ * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE

+ * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY

+ * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES

+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;

+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND

+ * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS

+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

+ */

+using System;

+using System.Collections;

+using System.Collections.Generic;

+using System.Net;

+using System.Net.Sockets;

+using System.Reflection;

+using System.Threading;

+using System.Xml;

+using OpenMetaverse;

+using log4net;

+using Nini.Config;

+using Nwc.XmlRpc;

+using OpenSim.Framework;

+using OpenSim.Framework.Communications.Cache;

+using OpenSim.Region.Environment.Interfaces;

+using OpenSim.Region.Interfaces;

+using OpenSim.Region.Environment.Scenes;

+

+namespace OpenSim.Region.Environment.Modules.Communications.Local

+{

+    public class LocalInterregionComms : IRegionModule, IInterregionCommsOut, IInterregionCommsIn

+    {

+        private bool m_enabled = false;

+

+        private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);

+        private List<Scene> m_sceneList = new List<Scene>();

+

+        #region Events

+        public event ChildAgentUpdateReceived OnChildAgentUpdate;

+

+        #endregion /* Events */

+

+        #region IRegionModule

+

+        public void Initialise(Scene scene, IConfigSource config)

+        {

+            if (m_sceneList.Count == 0)

+            {

+                IConfig startupConfig = config.Configs["Communications"];

+

+                if ((startupConfig == null) ||

+                    (startupConfig != null) && (startupConfig.GetString("InterregionComms", "LocalComms") == "LocalComms"))

+                    m_enabled = true;

+            }

+

+            if (!m_enabled)

+                return;

+

+            Init(scene);

+

+        }

+

+        public void PostInitialise()

+        {

+        }

+

+        public void Close()

+        {

+        }

+

+        public string Name

+        {

+            get { return "LocalInterregionCommsModule"; }

+        }

+

+        public bool IsSharedModule

+        {

+            get { return true; }

+        }

+        /// <summary>

+        /// Can be called from other modules.

+        /// </summary>

+        /// <param name="scene"></param>

+        public void Init(Scene scene)

+        {

+            if (!m_sceneList.Contains(scene))

+            {

+                lock (m_sceneList)

+                {

+                    m_sceneList.Add(scene);

+                    if (m_enabled)

+                        scene.RegisterModuleInterface<IInterregionCommsOut>(this);

+                    scene.RegisterModuleInterface<IInterregionCommsIn>(this);

+                }

+

+            }

+        }

+

+        #endregion /* IRegionModule */

+

+        #region IInterregionComms

+

+        public bool SendChildAgentUpdate(ulong regionHandle, AgentData cAgentData)

+        {

+            lock (m_sceneList)

+            {

+                foreach (Scene s in m_sceneList)

+                {

+                    if (s.RegionInfo.RegionHandle == regionHandle)

+                    {

+                        //m_log.Debug("[LOCAL COMMS]: Found region to send ChildAgentUpdate");

+                        return s.IncomingChildAgentDataUpdate(cAgentData);

+                        //if (OnChildAgentUpdate != null)

+                        //    return OnChildAgentUpdate(cAgentData);

+                    }

+                }

+            }

+            m_log.Debug("[LOCAL COMMS]: region not found for ChildAgentUpdate");

+            return false;

+        }

+

+        #endregion /* IInterregionComms */

+    }

+}