1 files changed, 17 insertions, 3 deletions

diff --git a/OpenSim/Framework/BlockingQueue.cs b/OpenSim/Framework/BlockingQueue.cs
index 345b361..5b7e911 100644
--- a/OpenSim/Framework/BlockingQueue.cs
+++ b/OpenSim/Framework/BlockingQueue.cs
@@ -32,9 +32,19 @@ namespace OpenSim.Framework
 {
     public class BlockingQueue<T>
     {
+        private readonly Queue<T> m_pqueue = new Queue<T>();
         private readonly Queue<T> m_queue = new Queue<T>();
         private readonly object m_queueSync = new object();
 
+        public void PriorityEnqueue(T value)
+        {
+            lock (m_queueSync)
+            {
+                m_pqueue.Enqueue(value);
+                Monitor.Pulse(m_queueSync);
+            }
+        }
+
         public void Enqueue(T value)
         {
             lock (m_queueSync)
@@ -48,11 +58,13 @@ namespace OpenSim.Framework
         {
             lock (m_queueSync)
             {
-                if (m_queue.Count < 1)
+                if (m_queue.Count < 1 && m_pqueue.Count < 1)
                 {
                     Monitor.Wait(m_queueSync);
                 }
 
+                if(m_pqueue.Count > 0)
+                    return m_pqueue.Dequeue();
                 return m_queue.Dequeue();
             }
         }
@@ -61,6 +73,8 @@ namespace OpenSim.Framework
         {
             lock (m_queueSync)
             {
+                if(m_pqueue.Contains(item))
+                    return true;
                 return m_queue.Contains(item);
             }
         }
@@ -69,7 +83,7 @@ namespace OpenSim.Framework
         {
             lock (m_queueSync)
             {
-                return m_queue.Count;
+                return m_queue.Count+m_pqueue.Count;
             }
         }
 
@@ -81,4 +95,4 @@ namespace OpenSim.Framework
             }
         }
     }
-}
\ No newline at end of file
+}