1 files changed, 145 insertions, 0 deletions
diff --git a/OpenSim/Region/ScriptEngine/DotNetEngine/LSLLongCmdHandler.cs b/OpenSim/Region/ScriptEngine/DotNetEngine/LSLLongCmdHandler.cs
new file mode 100644
index 0000000..e2c039c
--- /dev/null
+++ b/OpenSim/Region/ScriptEngine/DotNetEngine/LSLLongCmdHandler.cs
@@ -0,0 +1,145 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Threading;
+using libsecondlife;
+namespace OpenSim.Region.ScriptEngine.DotNetEngine
+{
+    /// <summary>
+    /// Handles LSL commands that takes long time and returns an event, for example timers, HTTP requests, etc.
+    /// </summary>
+    class LSLLongCmdHandler
+    {
+        private Thread CmdHandlerThread;
+        private int CmdHandlerThreadCycleSleepms = 100;
+        private ScriptEngine myScriptEngine;
+        public LSLLongCmdHandler(ScriptEngine _ScriptEngine)
+        {
+            myScriptEngine = _ScriptEngine;
+            // Start the thread that will be doing the work
+            CmdHandlerThread = new Thread(CmdHandlerThreadLoop);
+            CmdHandlerThread.Name = "CmdHandlerThread";
+            CmdHandlerThread.Priority = ThreadPriority.BelowNormal;
+            CmdHandlerThread.IsBackground = true;
+            CmdHandlerThread.Start();
+        }
+        ~LSLLongCmdHandler()
+        {
+            // Shut down thread
+            try
+            {
+                if (CmdHandlerThread != null)
+                {
+                    if (CmdHandlerThread.IsAlive == true)
+                    {
+                        CmdHandlerThread.Abort();
+                        CmdHandlerThread.Join();
+                    }
+                }
+            }
+            catch { }
+        }
+        private void CmdHandlerThreadLoop()
+        {
+            while (true)
+            {
+                // Check timers
+                CheckTimerEvents();                    
+                // Sleep before next cycle
+                Thread.Sleep(CmdHandlerThreadCycleSleepms);
+            }
+        }
+        /// <summary>
+        /// Remove a specific script (and all its pending commands)
+        /// </summary>
+        /// <param name="m_localID"></param>
+        /// <param name="m_itemID"></param>
+        public void RemoveScript(uint m_localID, LLUUID m_itemID)
+        {
+            // Remove a specific script
+            // Remove from: Timers
+            UnSetTimerEvents(m_localID, m_itemID);
+        }
+        //
+        // TIMER
+        //
+        private class TimerClass
+        {
+            public uint localID;
+            public LLUUID itemID;
+            public double interval;
+            public DateTime next;
+        }
+        private List<TimerClass> Timers = new List<TimerClass>();
+        private object ListLock = new object();
+        public void SetTimerEvent(uint m_localID, LLUUID m_itemID, double sec)
+        {
+            Console.WriteLine("SetTimerEvent");
+            // Always remove first, in case this is a re-set
+            UnSetTimerEvents(m_localID, m_itemID);
+            if (sec == 0) // Disabling timer
+                return;
+            // Add to timer
+            TimerClass ts = new TimerClass();
+            ts.localID = m_localID;
+            ts.itemID = m_itemID;
+            ts.interval = sec;
+            ts.next = DateTime.Now.ToUniversalTime().AddSeconds(ts.interval);
+            lock (ListLock)
+            {
+                Timers.Add(ts);
+            }
+        }
+        public void UnSetTimerEvents(uint m_localID, LLUUID m_itemID)
+        {
+            // Remove from timer
+            lock (ListLock)
+            {
+                List<TimerClass> NewTimers = new List<TimerClass>();
+                foreach (TimerClass ts in Timers)
+                {
+                    if (ts.localID != m_localID && ts.itemID != m_itemID)
+                    {
+                        NewTimers.Add(ts);
+                    }
+                }
+                Timers.Clear();
+                Timers = NewTimers;
+            }
+        }
+        public void CheckTimerEvents()
+        {
+            // Nothing to do here?
+            if (Timers.Count == 0)
+                return;
+            // Go through all timers
+            foreach (TimerClass ts in Timers)
+            {
+                // Time has passed?
+                if (ts.next.ToUniversalTime() < DateTime.Now.ToUniversalTime())
+                {
+                    // Add it to queue
+                    //Console.WriteLine("Enqueue timer event: " + ts.next.ToUniversalTime().ToString("HH:mm:ss") + " > " + DateTime.Now.ToUniversalTime().ToString("HH:mm:ss"));
+                    myScriptEngine.myEventQueueManager.AddToScriptQueue(ts.localID, ts.itemID, "timer", new object[] { });
+                    // set next interval
+                    
+                    
+                    ts.next = DateTime.Now.ToUniversalTime().AddSeconds(ts.interval);
+                }
+            }
+        }
+    }
+}

diff --git a/OpenSim/Region/ScriptEngine/DotNetEngine/LSLLongCmdHandler.cs b/OpenSim/Region/ScriptEngine/DotNetEngine/LSLLongCmdHandler.cs new file mode 100644 index 0000000..e2c039c --- /dev/null +++ b/OpenSim/Region/ScriptEngine/DotNetEngine/LSLLongCmdHandler.cs
@@ -0,0 +1,145 @@
	1	using System;
	2	using System.Collections.Generic;
	3	using System.Text;
	4	using System.Threading;
	5	using libsecondlife;
	6
	7	namespace OpenSim.Region.ScriptEngine.DotNetEngine
	8	{
	9	/// <summary>
	10	/// Handles LSL commands that takes long time and returns an event, for example timers, HTTP requests, etc.
	11	/// </summary>
	12	class LSLLongCmdHandler
	13	{
	14	private Thread CmdHandlerThread;
	15	private int CmdHandlerThreadCycleSleepms = 100;
	16
	17	private ScriptEngine myScriptEngine;
	18	public LSLLongCmdHandler(ScriptEngine _ScriptEngine)
	19	{
	20	myScriptEngine = _ScriptEngine;
	21
	22	// Start the thread that will be doing the work
	23	CmdHandlerThread = new Thread(CmdHandlerThreadLoop);
	24	CmdHandlerThread.Name = "CmdHandlerThread";
	25	CmdHandlerThread.Priority = ThreadPriority.BelowNormal;
	26	CmdHandlerThread.IsBackground = true;
	27	CmdHandlerThread.Start();
	28	}
	29	~LSLLongCmdHandler()
	30	{
	31	// Shut down thread
	32	try
	33	{
	34	if (CmdHandlerThread != null)
	35	{
	36	if (CmdHandlerThread.IsAlive == true)
	37	{
	38	CmdHandlerThread.Abort();
	39	CmdHandlerThread.Join();
	40	}
	41	}
	42	}
	43	catch { }
	44	}
	45
	46	private void CmdHandlerThreadLoop()
	47	{
	48	while (true)
	49	{
	50	// Check timers
	51	CheckTimerEvents();
	52
	53	// Sleep before next cycle
	54	Thread.Sleep(CmdHandlerThreadCycleSleepms);
	55	}
	56	}
	57
	58	/// <summary>
	59	/// Remove a specific script (and all its pending commands)
	60	/// </summary>
	61	/// <param name="m_localID"></param>
	62	/// <param name="m_itemID"></param>
	63	public void RemoveScript(uint m_localID, LLUUID m_itemID)
	64	{
	65	// Remove a specific script
	66
	67	// Remove from: Timers
	68	UnSetTimerEvents(m_localID, m_itemID);
	69	}
	70
	71
	72	//
	73	// TIMER
	74	//
	75	private class TimerClass
	76	{
	77	public uint localID;
	78	public LLUUID itemID;
	79	public double interval;
	80	public DateTime next;
	81	}
	82	private List<TimerClass> Timers = new List<TimerClass>();
	83	private object ListLock = new object();
	84	public void SetTimerEvent(uint m_localID, LLUUID m_itemID, double sec)
	85	{
	86	Console.WriteLine("SetTimerEvent");
	87
	88	// Always remove first, in case this is a re-set
	89	UnSetTimerEvents(m_localID, m_itemID);
	90	if (sec == 0) // Disabling timer
	91	return;
	92
	93	// Add to timer
	94	TimerClass ts = new TimerClass();
	95	ts.localID = m_localID;
	96	ts.itemID = m_itemID;
	97	ts.interval = sec;
	98	ts.next = DateTime.Now.ToUniversalTime().AddSeconds(ts.interval);
	99	lock (ListLock)
	100	{
	101	Timers.Add(ts);
	102	}
	103	}
	104	public void UnSetTimerEvents(uint m_localID, LLUUID m_itemID)
	105	{
	106	// Remove from timer
	107	lock (ListLock)
	108	{
	109	List<TimerClass> NewTimers = new List<TimerClass>();
	110	foreach (TimerClass ts in Timers)
	111	{
	112	if (ts.localID != m_localID && ts.itemID != m_itemID)
	113	{
	114	NewTimers.Add(ts);
	115	}
	116	}
	117	Timers.Clear();
	118	Timers = NewTimers;
	119	}
	120	}
	121	public void CheckTimerEvents()
	122	{
	123	// Nothing to do here?
	124	if (Timers.Count == 0)
	125	return;
	126
	127	// Go through all timers
	128	foreach (TimerClass ts in Timers)
	129	{
	130	// Time has passed?
	131	if (ts.next.ToUniversalTime() < DateTime.Now.ToUniversalTime())
	132	{
	133	// Add it to queue
	134	//Console.WriteLine("Enqueue timer event: " + ts.next.ToUniversalTime().ToString("HH:mm:ss") + " > " + DateTime.Now.ToUniversalTime().ToString("HH:mm:ss"));
	135	myScriptEngine.myEventQueueManager.AddToScriptQueue(ts.localID, ts.itemID, "timer", new object[] { });
	136	// set next interval
	137
	138
	139	ts.next = DateTime.Now.ToUniversalTime().AddSeconds(ts.interval);
	140	}
	141	}
	142	}
	143
	144	}
	145	}