204 lines
7.9 KiB
C#
204 lines
7.9 KiB
C#
/*
|
|
* 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.Diagnostics;
|
|
using System.Reflection;
|
|
using System.Text;
|
|
using System.Threading;
|
|
using log4net;
|
|
using OpenMetaverse;
|
|
using OpenSim.Region.ScriptEngine.Shared;
|
|
using OpenSim.ScriptEngine.Shared;
|
|
using EventParams=OpenSim.ScriptEngine.Shared.EventParams;
|
|
|
|
namespace OpenSim.ScriptEngine.Components.DotNetEngine.Scheduler
|
|
{
|
|
public partial class ScriptManager: IScriptExecutor
|
|
{
|
|
private const int NoWorkSleepMs = 50;
|
|
private const int NoWorkSleepMsInc = 1; // How much time to increase wait with on every iteration
|
|
private const int NoWorkSleepMsIncMax = 300; // Max time to wait
|
|
|
|
internal static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
|
|
public string Name { get { return "SECS.DotNetEngine.ScriptManager"; } }
|
|
private static Thread ScriptLoadUnloadThread;
|
|
public Dictionary<uint, Dictionary<UUID, ScriptStructure>> Scripts = new Dictionary<uint, Dictionary<UUID, ScriptStructure>>();
|
|
|
|
private RegionInfoStructure CurrentRegion;
|
|
public void Initialize(RegionInfoStructure currentRegion)
|
|
{
|
|
CurrentRegion = currentRegion;
|
|
}
|
|
|
|
public ScriptManager()
|
|
{
|
|
ScriptLoadUnloadThread = new Thread(LoadUnloadLoop);
|
|
ScriptLoadUnloadThread.Name = "ScriptLoadUnloadThread";
|
|
ScriptLoadUnloadThread.IsBackground = true;
|
|
ScriptLoadUnloadThread.Start();
|
|
}
|
|
public void Close() { }
|
|
|
|
private void LoadUnloadLoop ()
|
|
{
|
|
int _NoWorkSleepMsInc = 0;
|
|
while (true)
|
|
{
|
|
if (DoScriptLoadUnload())
|
|
{
|
|
// We found work, reset counter
|
|
_NoWorkSleepMsInc = NoWorkSleepMs;
|
|
} else
|
|
{
|
|
// We didn't find work
|
|
// Sleep
|
|
Thread.Sleep(NoWorkSleepMs + NoWorkSleepMsInc);
|
|
// Increase sleep delay
|
|
_NoWorkSleepMsInc += NoWorkSleepMsInc;
|
|
// Make sure we don't exceed max
|
|
if (_NoWorkSleepMsInc > NoWorkSleepMsIncMax)
|
|
_NoWorkSleepMsInc = NoWorkSleepMsIncMax;
|
|
}
|
|
}
|
|
}
|
|
|
|
#region Add/Remove/Find script functions for our Script memory structure
|
|
private void MemAddScript(ScriptStructure script)
|
|
{
|
|
lock (scriptLock)
|
|
{
|
|
// Create object if it doesn't exist
|
|
if (!Scripts.ContainsKey(script.LocalID))
|
|
Scripts.Add(script.LocalID, new Dictionary<UUID, ScriptStructure>());
|
|
|
|
// Delete script if it exists
|
|
Dictionary<UUID, ScriptStructure> Obj;
|
|
if (Scripts.TryGetValue(script.LocalID, out Obj))
|
|
if (Obj.ContainsKey(script.ItemID) == true)
|
|
Obj.Remove(script.ItemID);
|
|
|
|
// Add to object
|
|
Obj.Add(script.ItemID, script);
|
|
}
|
|
}
|
|
private void MemRemoveScript(uint LocalID, UUID ItemID)
|
|
{
|
|
// TODO: Also clean up command queue and async commands for object
|
|
lock (scriptLock)
|
|
{
|
|
// Create object if it doesn't exist
|
|
if (!Scripts.ContainsKey(LocalID))
|
|
return;
|
|
|
|
// Delete script if it exists
|
|
Dictionary<UUID, ScriptStructure> Obj;
|
|
if (Scripts.TryGetValue(LocalID, out Obj))
|
|
if (Obj.ContainsKey(ItemID) == true)
|
|
Obj.Remove(ItemID);
|
|
|
|
// Empty?
|
|
if (Obj.Count == 0)
|
|
Scripts.Remove(LocalID);
|
|
|
|
}
|
|
}
|
|
public bool TryGetScript(uint localID, UUID itemID, ref ScriptStructure script)
|
|
{
|
|
lock (scriptLock)
|
|
{
|
|
|
|
if (Scripts.ContainsKey(localID) == false)
|
|
return false;
|
|
|
|
Dictionary<UUID, ScriptStructure> Obj;
|
|
if (Scripts.TryGetValue(localID, out Obj))
|
|
if (Obj.ContainsKey(itemID) == false)
|
|
return false;
|
|
|
|
// Get script
|
|
return Obj.TryGetValue(itemID, out script);
|
|
}
|
|
}
|
|
public ScriptStructure GetScript(uint localID, UUID itemID)
|
|
{
|
|
lock (scriptLock)
|
|
{
|
|
|
|
if (Scripts.ContainsKey(localID) == false)
|
|
throw new Exception("No script with LocalID " + localID + " was found.");
|
|
|
|
Dictionary<UUID, ScriptStructure> Obj;
|
|
if (Scripts.TryGetValue(localID, out Obj))
|
|
if (Obj.ContainsKey(itemID) == false)
|
|
throw new Exception("No script with ItemID " + itemID + " was found.");
|
|
|
|
// Get script
|
|
return Obj[itemID];
|
|
}
|
|
}
|
|
public bool TryGetScripts(uint localID, ref Dictionary<UUID, ScriptStructure> returnList)
|
|
{
|
|
Dictionary<UUID, ScriptStructure> getList = GetScripts(localID);
|
|
if (getList != null)
|
|
{
|
|
returnList = getList;
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
public Dictionary<UUID, ScriptStructure> GetScripts(uint localID)
|
|
{
|
|
lock (scriptLock)
|
|
{
|
|
|
|
if (Scripts.ContainsKey(localID) == false)
|
|
return null;
|
|
return Scripts[localID];
|
|
}
|
|
}
|
|
#endregion
|
|
|
|
public void ExecuteCommand(EventParams p)
|
|
{
|
|
ScriptStructure ss = new ScriptStructure();
|
|
if (TryGetScript(p.LocalID, p.ItemID, ref ss))
|
|
ExecuteCommand(ref ss, p);
|
|
}
|
|
|
|
public void ExecuteCommand(ref ScriptStructure scriptContainer, EventParams p)
|
|
{
|
|
m_log.DebugFormat("[{0}] ######################################################", Name);
|
|
m_log.DebugFormat("[{0}] Command execution ItemID {1}: \"{2}\".", Name, scriptContainer.ItemID, p.EventName);
|
|
scriptContainer.ExecuteEvent(p);
|
|
m_log.DebugFormat("[{0}] ######################################################", Name);
|
|
}
|
|
|
|
}
|
|
}
|