/* * 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 OpenSimulator 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.Generic; using System.Net; using System.Reflection; using OpenMetaverse; using log4net; using OpenSim.Framework; using OpenSim.Region.Framework.Interfaces; namespace OpenSim.Region.Framework.Scenes { public delegate void RestartSim(RegionInfo thisregion); /// /// Manager for adding, closing and restarting scenes. /// public class SceneManager { private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); public event RestartSim OnRestartSim; /// /// Fired when either all regions are ready for use or at least one region has become unready for use where /// previously all regions were ready. /// public event Action OnRegionsReadyStatusChange; /// /// Are all regions ready for use? /// public bool AllRegionsReady { get { return m_allRegionsReady; } private set { if (m_allRegionsReady != value) { m_allRegionsReady = value; Action handler = OnRegionsReadyStatusChange; if (handler != null) { foreach (Action d in handler.GetInvocationList()) { try { d(this); } catch (Exception e) { m_log.ErrorFormat("[SCENE MANAGER]: Delegate for OnRegionsReadyStatusChange failed - continuing {0} - {1}", e.Message, e.StackTrace); } } } } } } private bool m_allRegionsReady; private static SceneManager m_instance = null; public static SceneManager Instance { get { if (m_instance == null) m_instance = new SceneManager(); return m_instance; } } private readonly DoubleDictionary m_localScenes = new DoubleDictionary(); private Scene m_currentScene = null; public List Scenes { get { return new List(m_localScenes.FindAll(delegate(Scene s) { return true; })); } } public Scene CurrentScene { get { return m_currentScene; } } public Scene CurrentOrFirstScene { get { if (m_currentScene == null) { List sceneList = Scenes; if (sceneList.Count == 0) return null; return sceneList[0]; } else { return m_currentScene; } } } public SceneManager() { m_instance = this; m_localScenes = new DoubleDictionary(); } public void Close() { List localScenes = null; lock (m_localScenes) { localScenes = Scenes; } for (int i = 0; i < localScenes.Count; i++) { localScenes[i].Close(); } } public void Close(Scene cscene) { if (!m_localScenes.ContainsKey(cscene.RegionInfo.RegionID)) return; cscene.Close(); } public void Add(Scene scene) { lock (m_localScenes) m_localScenes.Add(scene.RegionInfo.RegionID, scene.RegionInfo.RegionName, scene); scene.OnRestart += HandleRestart; scene.EventManager.OnRegionReadyStatusChange += HandleRegionReadyStatusChange; } public void HandleRestart(RegionInfo rdata) { m_log.Error("[SCENEMANAGER]: Got Restart message for region:" + rdata.RegionName + " Sending up to main"); int RegionSceneElement = -1; lock (m_localScenes) m_localScenes.Remove(rdata.RegionID); // Send signal to main that we're restarting this sim. OnRestartSim(rdata); } private void HandleRegionReadyStatusChange(IScene scene) { lock (m_localScenes) AllRegionsReady = m_localScenes.FindAll(s => !s.Ready).Count == 0; } public void SendSimOnlineNotification(ulong regionHandle) { RegionInfo Result = null; Scene s = m_localScenes.FindValue(delegate(Scene x) { if (x.RegionInfo.RegionHandle == regionHandle) return true; return false; }); if (s != null) { List sceneList = Scenes; for (int i = 0; i < sceneList.Count; i++) { if (sceneList[i]!= s) { // Inform other regions to tell their avatar about me //sceneList[i].OtherRegionUp(Result); } } } else { m_log.Error("[REGION]: Unable to notify Other regions of this Region coming up"); } } /// /// Save the prims in the current scene to an xml file in OpenSimulator's original 'xml' format /// /// public void SaveCurrentSceneToXml(string filename) { IRegionSerialiserModule serialiser = CurrentOrFirstScene.RequestModuleInterface(); if (serialiser != null) serialiser.SavePrimsToXml(CurrentOrFirstScene, filename); } /// /// Load an xml file of prims in OpenSimulator's original 'xml' file format to the current scene /// /// /// /// public void LoadCurrentSceneFromXml(string filename, bool generateNewIDs, Vector3 loadOffset) { IRegionSerialiserModule serialiser = CurrentOrFirstScene.RequestModuleInterface(); if (serialiser != null) serialiser.LoadPrimsFromXml(CurrentOrFirstScene, filename, generateNewIDs, loadOffset); } /// /// Save the prims in the current scene to an xml file in OpenSimulator's current 'xml2' format /// /// public void SaveCurrentSceneToXml2(string filename) { IRegionSerialiserModule serialiser = CurrentOrFirstScene.RequestModuleInterface(); if (serialiser != null) serialiser.SavePrimsToXml2(CurrentOrFirstScene, filename); } public void SaveNamedPrimsToXml2(string primName, string filename) { IRegionSerialiserModule serialiser = CurrentOrFirstScene.RequestModuleInterface(); if (serialiser != null) serialiser.SaveNamedPrimsToXml2(CurrentOrFirstScene, primName, filename); } /// /// Load an xml file of prims in OpenSimulator's current 'xml2' file format to the current scene /// public void LoadCurrentSceneFromXml2(string filename) { IRegionSerialiserModule serialiser = CurrentOrFirstScene.RequestModuleInterface(); if (serialiser != null) serialiser.LoadPrimsFromXml2(CurrentOrFirstScene, filename); } /// /// Save the current scene to an OpenSimulator archive. This archive will eventually include the prim's assets /// as well as the details of the prims themselves. /// /// public void SaveCurrentSceneToArchive(string[] cmdparams) { IRegionArchiverModule archiver = CurrentOrFirstScene.RequestModuleInterface(); if (archiver != null) archiver.HandleSaveOarConsoleCommand(string.Empty, cmdparams); } /// /// Load an OpenSim archive into the current scene. This will load both the shapes of the prims and upload /// their assets to the asset service. /// /// public void LoadArchiveToCurrentScene(string[] cmdparams) { IRegionArchiverModule archiver = CurrentOrFirstScene.RequestModuleInterface(); if (archiver != null) archiver.HandleLoadOarConsoleCommand(string.Empty, cmdparams); } public string SaveCurrentSceneMapToXmlString() { return CurrentOrFirstScene.Heightmap.SaveToXmlString(); } public void LoadCurrenSceneMapFromXmlString(string mapData) { CurrentOrFirstScene.Heightmap.LoadFromXmlString(mapData); } public void SendCommandToPluginModules(string[] cmdparams) { ForEachCurrentScene(delegate(Scene scene) { scene.SendCommandToPlugins(cmdparams); }); } public void SetBypassPermissionsOnCurrentScene(bool bypassPermissions) { ForEachCurrentScene(delegate(Scene scene) { scene.Permissions.SetBypassPermissions(bypassPermissions); }); } private void ForEachCurrentScene(Action func) { if (m_currentScene == null) { List sceneList = Scenes; sceneList.ForEach(func); } else { func(m_currentScene); } } public void RestartCurrentScene() { ForEachCurrentScene(delegate(Scene scene) { scene.RestartNow(); }); } public void BackupCurrentScene() { ForEachCurrentScene(delegate(Scene scene) { scene.Backup(true); }); } public bool TrySetCurrentScene(string regionName) { if ((String.Compare(regionName, "root") == 0) || (String.Compare(regionName, "..") == 0) || (String.Compare(regionName, "/") == 0)) { m_currentScene = null; return true; } else { Scene s; if (m_localScenes.TryGetValue(regionName, out s)) { m_currentScene = s; return true; } return false; } } public bool TrySetCurrentScene(UUID regionID) { // m_log.Debug("Searching for Region: '" + regionID + "'"); Scene s; if (m_localScenes.TryGetValue(regionID, out s)) { m_currentScene = s; return true; } return false; } public bool TryGetScene(string regionName, out Scene scene) { return m_localScenes.TryGetValue(regionName, out scene); } public bool TryGetScene(UUID regionID, out Scene scene) { return m_localScenes.TryGetValue(regionID, out scene); } public bool TryGetScene(uint locX, uint locY, out Scene scene) { List sceneList = Scenes; foreach (Scene mscene in sceneList) { if (mscene.RegionInfo.RegionLocX == locX && mscene.RegionInfo.RegionLocY == locY) { scene = mscene; return true; } } scene = null; return false; } public bool TryGetScene(IPEndPoint ipEndPoint, out Scene scene) { List sceneList = Scenes; foreach (Scene mscene in sceneList) { if ((mscene.RegionInfo.InternalEndPoint.Equals(ipEndPoint.Address)) && (mscene.RegionInfo.InternalEndPoint.Port == ipEndPoint.Port)) { scene = mscene; return true; } } scene = null; return false; } /// /// Set the debug packet level on each current scene. This level governs which packets are printed out to the /// console. /// /// /// Name of avatar to debug public void SetDebugPacketLevelOnCurrentScene(int newDebug, string name) { ForEachCurrentScene(scene => scene.ForEachScenePresence(sp => { if (name == null || sp.Name == name) { m_log.DebugFormat( "Packet debug for {0} ({1}) set to {2}", sp.Name, sp.IsChildAgent ? "child" : "root", newDebug); sp.ControllingClient.DebugPacketLevel = newDebug; } }) ); } public List GetCurrentSceneAvatars() { List avatars = new List(); ForEachCurrentScene( delegate(Scene scene) { scene.ForEachRootScenePresence(delegate(ScenePresence scenePresence) { avatars.Add(scenePresence); }); } ); return avatars; } public List GetCurrentScenePresences() { List presences = new List(); ForEachCurrentScene(delegate(Scene scene) { scene.ForEachScenePresence(delegate(ScenePresence sp) { presences.Add(sp); }); }); return presences; } public RegionInfo GetRegionInfo(UUID regionID) { Scene s; if (m_localScenes.TryGetValue(regionID, out s)) { return s.RegionInfo; } return null; } public void ForceCurrentSceneClientUpdate() { ForEachCurrentScene(delegate(Scene scene) { scene.ForceClientUpdate(); }); } public void HandleEditCommandOnCurrentScene(string[] cmdparams) { ForEachCurrentScene(delegate(Scene scene) { scene.HandleEditCommand(cmdparams); }); } public bool TryGetScenePresence(UUID avatarId, out ScenePresence avatar) { List sceneList = Scenes; foreach (Scene scene in sceneList) { if (scene.TryGetScenePresence(avatarId, out avatar)) { return true; } } avatar = null; return false; } public bool TryGetRootScenePresence(UUID avatarId, out ScenePresence avatar) { List sceneList = Scenes; foreach (Scene scene in sceneList) { avatar = scene.GetScenePresence(avatarId); if (avatar != null && !avatar.IsChildAgent) return true; } avatar = null; return false; } public void CloseScene(Scene scene) { lock (m_localScenes) m_localScenes.Remove(scene.RegionInfo.RegionID); scene.Close(); } public bool TryGetAvatarByName(string avatarName, out ScenePresence avatar) { List sceneList = Scenes; foreach (Scene scene in sceneList) { if (scene.TryGetAvatarByName(avatarName, out avatar)) { return true; } } avatar = null; return false; } public bool TryGetRootScenePresenceByName(string firstName, string lastName, out ScenePresence sp) { List sceneList = Scenes; foreach (Scene scene in sceneList) { sp = scene.GetScenePresence(firstName, lastName); if (sp != null && !sp.IsChildAgent) return true; } sp = null; return false; } public void ForEachScene(Action action) { List sceneList = Scenes; sceneList.ForEach(action); } } }