From b75c1b2191640f4a140dc4cd0e8ce35ab64863d9 Mon Sep 17 00:00:00 2001
From: Tedd Hansen
Date: Sat, 25 Aug 2007 19:08:15 +0000
Subject: Added class for "long commands" (command that returns as event) with
 dedicated thread for processing. Added support for llSetTimerEvent().
 Deleting old compiled scripts before new compile is attempted (avoids loading
 wrong script on compile error).

---
 .../ScriptEngine/DotNetEngine/LSLLongCmdHandler.cs | 145 +++++++++++++++++++++
 1 file changed, 145 insertions(+)
 create mode 100644 OpenSim/Region/ScriptEngine/DotNetEngine/LSLLongCmdHandler.cs

(limited to 'OpenSim/Region/ScriptEngine/DotNetEngine/LSLLongCmdHandler.cs')

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);
+                }
+            }
+        }
+
+    }
+}
-- 
cgit v1.1