1 files changed, 47 insertions, 40 deletions
diff --git a/OpenSim/Region/ScriptEngine/DotNetEngine/EventQueueManager.cs b/OpenSim/Region/ScriptEngine/DotNetEngine/EventQueueManager.cs
index 99971a5..9037c2a 100644
--- a/OpenSim/Region/ScriptEngine/DotNetEngine/EventQueueManager.cs
+++ b/OpenSim/Region/ScriptEngine/DotNetEngine/EventQueueManager.cs
@@ -131,57 +131,64 @@ namespace OpenSim.Region.ScriptEngine.DotNetEngine
                QueueItemStruct BlankQIS = new QueueItemStruct();
                while (true)
                {
-                    QueueItemStruct QIS = BlankQIS;
+                    try
-                    bool GotItem = false;
-                    if (EventQueue.Count == 0)
-                    {
-                        // Nothing to do? Sleep a bit waiting for something to do
-                        Thread.Sleep(NothingToDoSleepms);
-                    }
-                    else
                    {
-                        // Something in queue, process
+                        QueueItemStruct QIS = BlankQIS;
-                        //myScriptEngine.m_logger.Verbose("ScriptEngine", "Processing event for localID: " + QIS.localID + ", itemID: " + QIS.itemID + ", FunctionName: " + QIS.FunctionName);
+                        bool GotItem = false;
-                        // OBJECT BASED LOCK - TWO THREADS WORKING ON SAME OBJECT IS NOT GOOD
+                        if (EventQueue.Count == 0)
-                        lock (QueueLock)
                        {
-                            GotItem = false;
+                            // Nothing to do? Sleep a bit waiting for something to do
-                            for (int qc = 0; qc < EventQueue.Count; qc++)
+                            Thread.Sleep(NothingToDoSleepms);
+                        }
+                        else
+                        {
+                            // Something in queue, process
+                            //myScriptEngine.m_logger.Verbose("ScriptEngine", "Processing event for localID: " + QIS.localID + ", itemID: " + QIS.itemID + ", FunctionName: " + QIS.FunctionName);
+                            // OBJECT BASED LOCK - TWO THREADS WORKING ON SAME OBJECT IS NOT GOOD
+                            lock (QueueLock)
                            {
-                                // Get queue item
+                                GotItem = false;
-                                QIS = EventQueue.Dequeue();
+                                for (int qc = 0; qc < EventQueue.Count; qc++)
+                                {
+                                    // Get queue item
+                                    QIS = EventQueue.Dequeue();
+                                    // Check if object is being processed by someone else
+                                    if (TryLock(QIS.localID) == false)
+                                    {
+                                        // Object is already being processed, requeue it
+                                        EventQueue.Enqueue(QIS);
+                                    }
+                                    else
+                                    {
+                                        // We have lock on an object and can process it
+                                        GotItem = true;
+                                        break;
+                                    }
+                                } // go through queue
+                            } // lock
-                                // Check if object is being processed by someone else
+                            if (GotItem == true)
-                                if (TryLock(QIS.localID) == false)
+                            {
+                                // Execute function
+                                try
                                {
-                                    // Object is already being processed, requeue it
+                                    myScriptEngine.myScriptManager.ExecuteEvent(QIS.localID, QIS.itemID, QIS.FunctionName, QIS.param);
-                                    EventQueue.Enqueue(QIS);
                                }
-                                else
+                                finally
                                {
-                                    // We have lock on an object and can process it
+                                    ReleaseLock(QIS.localID);
-                                    GotItem = true;
-                                    break;
                                }
-                            } // go through queue
-                        } // lock
-                        if (GotItem == true)
-                        {
-                            // Execute function
-                            try
-                            {
-                                myScriptEngine.myScriptManager.ExecuteEvent(QIS.localID, QIS.itemID, QIS.FunctionName, QIS.param);
                            }
-                            finally
-                            {
-                                ReleaseLock(QIS.localID);
-                            }
-                        }
-                    } // Something in queue
+                        } // Something in queue
+                    } catch {ThreadAbortException tae) {
+                        throw tae;
+                    } catch (Exception e) {
+                        Console.WriteLine("Exception in EventQueueThreadLoop: " + e.ToString());
+                    }
                } // while
            } // try
            catch (ThreadAbortException tae)