/* * 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.Generic; using System.Reflection; using log4net; using Nini.Config; using OpenSim.Framework; using OpenSim.Region.CoreModules.Framework.EventQueue; using OpenSim.Region.Framework.Interfaces; using OpenSim.Region.Framework.Scenes; using OpenSim.Region.ScriptEngine.Interfaces; using OpenMetaverse; using OpenMetaverse.StructuredData; using OpenSim.Region.ScriptEngine.Shared; using OpenSim.Region.ScriptEngine.Shared.ScriptBase; namespace OpenSim.Region.ScriptEngine.DotNetEngine { [Serializable] public class ScriptEngine : IRegionModule, IScriptEngine, IScriptModule { private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); public static List ScriptEngines = new List(); private Scene m_Scene; public Scene World { get { return m_Scene; } } // Handles and queues incoming events from OpenSim public EventManager m_EventManager; // Executes events, handles script threads public EventQueueManager m_EventQueueManager; // Load, unload and execute scripts public ScriptManager m_ScriptManager; // Handles loading/unloading of scripts into AppDomains public AppDomainManager m_AppDomainManager; // Thread that does different kinds of maintenance, // for example refreshing config and killing scripts // that has been running too long public static MaintenanceThread m_MaintenanceThread; public IConfigSource ConfigSource; public IConfig ScriptConfigSource; private bool m_enabled = false; public IConfig Config { get { return ScriptConfigSource; } } // How many seconds between re-reading config-file. // 0 = never. ScriptEngine will try to adjust to new config changes. public int RefreshConfigFileSeconds { get { return (int)(RefreshConfigFilens / 10000000); } set { RefreshConfigFilens = value * 10000000; } } public long RefreshConfigFilens; public string ScriptEngineName { get { return "ScriptEngine.DotNetEngine"; } } public event ScriptRemoved OnScriptRemoved; public event ObjectRemoved OnObjectRemoved; public ScriptEngine() { // For logging, just need any instance, doesn't matter Common.mySE = this; lock (ScriptEngines) { // Keep a list of ScriptEngines for shared threads // to process all instances ScriptEngines.Add(this); } } public void Initialise(Scene Sceneworld, IConfigSource config) { m_log.Info("[" + ScriptEngineName + "]: ScriptEngine initializing"); ConfigSource = config; m_Scene = Sceneworld; // Make sure we have config if (ConfigSource.Configs[ScriptEngineName] == null) ConfigSource.AddConfig(ScriptEngineName); ScriptConfigSource = ConfigSource.Configs[ScriptEngineName]; m_enabled = ScriptConfigSource.GetBoolean("Enabled", true); if (!m_enabled) return; // Create all objects we'll be using m_EventQueueManager = new EventQueueManager(this); m_EventManager = new EventManager(this, true); // We need to start it m_ScriptManager = new ScriptManager(this); m_ScriptManager.Setup(); m_AppDomainManager = new AppDomainManager(this); if (m_MaintenanceThread == null) m_MaintenanceThread = new MaintenanceThread(); m_log.Info("[" + ScriptEngineName + "]: Reading configuration "+ "from config section \"" + ScriptEngineName + "\""); ReadConfig(); m_Scene.StackModuleInterface(this); } public void PostInitialise() { if (!m_enabled) return; m_EventManager.HookUpEvents(); m_Scene.EventManager.OnScriptReset += OnScriptReset; m_Scene.EventManager.OnGetScriptRunning += OnGetScriptRunning; m_Scene.EventManager.OnStartScript += OnStartScript; m_Scene.EventManager.OnStopScript += OnStopScript; m_ScriptManager.Start(); } public void Shutdown() { // We are shutting down lock (ScriptEngines) { ScriptEngines.Remove(this); } } public void ReadConfig() { RefreshConfigFileSeconds = ScriptConfigSource.GetInt("RefreshConfig", 0); if (m_EventQueueManager != null) m_EventQueueManager.ReadConfig(); if (m_EventManager != null) m_EventManager.ReadConfig(); if (m_ScriptManager != null) m_ScriptManager.ReadConfig(); if (m_AppDomainManager != null) m_AppDomainManager.ReadConfig(); if (m_MaintenanceThread != null) m_MaintenanceThread.ReadConfig(); } #region IRegionModule public void Close() { } public string Name { get { return "Common." + ScriptEngineName; } } public bool IsSharedModule { get { return false; } } public bool PostObjectEvent(uint localID, EventParams p) { return m_EventQueueManager.AddToObjectQueue(localID, p.EventName, p.DetectParams, p.Params); } public bool PostScriptEvent(UUID itemID, EventParams p) { uint localID = m_ScriptManager.GetLocalID(itemID); return m_EventQueueManager.AddToScriptQueue(localID, itemID, p.EventName, p.DetectParams, p.Params); } public DetectParams GetDetectParams(UUID itemID, int number) { uint localID = m_ScriptManager.GetLocalID(itemID); if (localID == 0) return null; InstanceData id = m_ScriptManager.GetScript(localID, itemID); if (id == null) return null; DetectParams[] det = m_ScriptManager.GetDetectParams(id); if (number < 0 || number >= det.Length) return null; return det[number]; } public int GetStartParameter(UUID itemID) { return m_ScriptManager.GetStartParameter(itemID); } public void SetMinEventDelay(UUID itemID, double delay) { // TODO in DotNet, done in XEngine throw new NotImplementedException(); } #endregion public void SetState(UUID itemID, string state) { uint localID = m_ScriptManager.GetLocalID(itemID); if (localID == 0) return; InstanceData id = m_ScriptManager.GetScript(localID, itemID); if (id == null) return; string currentState = id.State; if (currentState != state) { try { m_EventManager.state_exit(localID); } catch (AppDomainUnloadedException) { m_log.Error("[SCRIPT]: state change called when "+ "script was unloaded. Nothing to worry about, "+ "but noting the occurance"); } id.State = state; try { int eventFlags = m_ScriptManager.GetStateEventFlags(localID, itemID); SceneObjectPart part = m_Scene.GetSceneObjectPart(localID); if (part != null) part.SetScriptEvents(itemID, eventFlags); m_EventManager.state_entry(localID); } catch (AppDomainUnloadedException) { m_log.Error("[SCRIPT]: state change called when "+ "script was unloaded. Nothing to worry about, but "+ "noting the occurance"); } } } public bool GetScriptState(UUID itemID) { uint localID = m_ScriptManager.GetLocalID(itemID); if (localID == 0) return false; InstanceData id = m_ScriptManager.GetScript(localID, itemID); if (id == null) return false; return id.Running; } public void SetScriptState(UUID itemID, bool state) { uint localID = m_ScriptManager.GetLocalID(itemID); if (localID == 0) return; InstanceData id = m_ScriptManager.GetScript(localID, itemID); if (id == null) return; if (!id.Disabled) id.Running = state; } public void ApiResetScript(UUID itemID) { uint localID = m_ScriptManager.GetLocalID(itemID); if (localID == 0) return; m_ScriptManager.ResetScript(localID, itemID); } public void ResetScript(UUID itemID) { uint localID = m_ScriptManager.GetLocalID(itemID); if (localID == 0) return; m_ScriptManager.ResetScript(localID, itemID); } public void OnScriptReset(uint localID, UUID itemID) { ResetScript(itemID); } public void OnStartScript(uint localID, UUID itemID) { InstanceData id = m_ScriptManager.GetScript(localID, itemID); if (id == null) return; if (!id.Disabled) id.Running = true; } public void OnStopScript(uint localID, UUID itemID) { InstanceData id = m_ScriptManager.GetScript(localID, itemID); if (id == null) return; id.Running = false; } public void OnGetScriptRunning(IClientAPI controllingClient, UUID objectID, UUID itemID) { uint localID = m_ScriptManager.GetLocalID(itemID); if (localID == 0) return; InstanceData id = m_ScriptManager.GetScript(localID, itemID); if (id == null) return; IEventQueue eq = World.RequestModuleInterface(); if (eq == null) { controllingClient.SendScriptRunningReply(objectID, itemID, id.Running); } else { eq.Enqueue(EventQueueHelper.ScriptRunningReplyEvent(objectID, itemID, id.Running, true), controllingClient.AgentId); } } public IScriptApi GetApi(UUID itemID, string name) { return m_ScriptManager.GetApi(itemID, name); } public IScriptWorkItem QueueEventHandler(Object o) { return null; } public string GetAssemblyName(UUID itemID) { return ""; } public string GetXMLState(UUID itemID) { return ""; } } }