using System; using System.Collections.Generic; using System.Text; using System.Threading; using libsecondlife; using OpenSim.Region.ScriptEngine.Common; using OpenSim.Region.Environment.Modules; using OpenSim.Region.Environment.Interfaces; namespace OpenSim.Grid.ScriptEngine.DotNetEngine { /// /// Handles LSL commands that takes long time and returns an event, for example timers, HTTP requests, etc. /// class LSLLongCmdHandler { private Thread cmdHandlerThread; private int cmdHandlerThreadCycleSleepms = 100; private ScriptEngine m_ScriptEngine; public LSLLongCmdHandler(ScriptEngine _ScriptEngine) { m_ScriptEngine = _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(); Thread.Sleep(25); // Check HttpRequests CheckHttpRequests(); Thread.Sleep(25); // Check XMLRPCRequests CheckXMLRPCRequests(); Thread.Sleep(25); // Check Listeners CheckListeners(); Thread.Sleep(25); // Sleep before next cycle //Thread.Sleep(cmdHandlerThreadCycleSleepms); } } /// /// Remove a specific script (and all its pending commands) /// /// /// public void RemoveScript(uint localID, LLUUID itemID) { // Remove a specific script // Remove from: Timers UnSetTimerEvents(localID, itemID); // Remove from: HttpRequest StopHttpRequest(localID, itemID); } #region TIMER // // TIMER // private class TimerClass { public uint localID; public LLUUID itemID; public double interval; public DateTime next; } private List Timers = new List(); private object TimerListLock = 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 (TimerListLock) { Timers.Add(ts); } } public void UnSetTimerEvents(uint m_localID, LLUUID m_itemID) { // Remove from timer lock (TimerListLock) { List NewTimers = new List(); 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; lock (TimerListLock) { // Go through all timers foreach (TimerClass ts in Timers) { // Time has passed? if (ts.next.ToUniversalTime() < DateTime.Now.ToUniversalTime()) { // Add it to queue m_ScriptEngine.m_EventQueueManager.AddToScriptQueue(ts.localID, ts.itemID, "timer", new object[] { }); // set next interval ts.next = DateTime.Now.ToUniversalTime().AddSeconds(ts.interval); } } } // lock } #endregion #region HTTP REQUEST // // HTTP REAQUEST // private class HttpClass { public uint localID; public LLUUID itemID; public string url; public List parameters; public string body; public DateTime next; public string response_request_id; public int response_status; public List response_metadata; public string response_body; public void SendRequest() { // TODO: SEND REQUEST!!! } public void Stop() { // TODO: Cancel any ongoing request } public bool CheckResponse() { // TODO: Check if we got a response yet, return true if so -- false if not return true; // TODO: If we got a response, set the following then return true //response_request_id //response_status //response_metadata //response_body } } private List HttpRequests = new List(); private object HttpListLock = new object(); public void StartHttpRequest(uint localID, LLUUID itemID, string url, List parameters, string body) { Console.WriteLine("StartHttpRequest"); HttpClass htc = new HttpClass(); htc.localID = localID; htc.itemID = itemID; htc.url = url; htc.parameters = parameters; htc.body = body; lock (HttpListLock) { //ADD REQUEST HttpRequests.Add(htc); } } public void StopHttpRequest(uint m_localID, LLUUID m_itemID) { // Remove from list lock (HttpListLock) { List NewHttpList = new List(); foreach (HttpClass ts in HttpRequests) { if (ts.localID != m_localID && ts.itemID != m_itemID) { // Keeping this one NewHttpList.Add(ts); } else { // Shutting this one down ts.Stop(); } } HttpRequests.Clear(); HttpRequests = NewHttpList; } } public void CheckHttpRequests() { // Nothing to do here? if (HttpRequests.Count == 0) return; lock (HttpListLock) { foreach (HttpClass ts in HttpRequests) { if (ts.CheckResponse() == true) { // Add it to event queue //key request_id, integer status, list metadata, string body object[] resobj = new object[] { ts.response_request_id, ts.response_status, ts.response_metadata, ts.response_body }; m_ScriptEngine.m_EventQueueManager.AddToScriptQueue(ts.localID, ts.itemID, "http_response", resobj); // Now stop it StopHttpRequest(ts.localID, ts.itemID); } } } // lock } #endregion public void CheckXMLRPCRequests() { IXMLRPC xmlrpc = m_ScriptEngine.World.RequestModuleInterface(); while (xmlrpc.hasRequests()) { RPCRequestInfo rInfo = xmlrpc.GetNextRequest(); System.Console.WriteLine("PICKED REQUEST"); //Deliver data to prim's remote_data handler object[] resobj = new object[] { 2, rInfo.GetChannelKey().ToString(), rInfo.GetMessageID().ToString(), "", rInfo.GetIntValue(), rInfo.GetStrVal() }; m_ScriptEngine.m_EventQueueManager.AddToScriptQueue( rInfo.GetLocalID(), rInfo.GetItemID(), "remote_data", resobj ); } } public void CheckListeners() { IWorldComm comms = m_ScriptEngine.World.RequestModuleInterface(); while (comms.HasMessages()) { ListenerInfo lInfo = comms.GetNextMessage(); System.Console.WriteLine("PICKED LISTENER"); //Deliver data to prim's listen handler object[] resobj = new object[] { lInfo.GetChannel(), lInfo.GetName(), lInfo.GetID().ToString(), lInfo.GetMessage() }; m_ScriptEngine.m_EventQueueManager.AddToScriptQueue( lInfo.GetLocalID(), lInfo.GetItemID(), "listen", resobj ); } } } }