diff options
Diffstat (limited to 'OpenSim/Framework/BlockingQueue.cs')
-rw-r--r-- | OpenSim/Framework/BlockingQueue.cs | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/OpenSim/Framework/BlockingQueue.cs b/OpenSim/Framework/BlockingQueue.cs index e03229b..857930a 100644 --- a/OpenSim/Framework/BlockingQueue.cs +++ b/OpenSim/Framework/BlockingQueue.cs | |||
@@ -66,7 +66,9 @@ namespace OpenSim.Framework | |||
66 | if (m_pqueue.Count > 0) | 66 | if (m_pqueue.Count > 0) |
67 | return m_pqueue.Dequeue(); | 67 | return m_pqueue.Dequeue(); |
68 | 68 | ||
69 | return m_queue.Dequeue(); | 69 | if (m_queue.Count > 0) |
70 | return m_queue.Dequeue(); | ||
71 | return default(T); | ||
70 | } | 72 | } |
71 | } | 73 | } |
72 | 74 | ||
@@ -119,6 +121,7 @@ namespace OpenSim.Framework | |||
119 | { | 121 | { |
120 | m_pqueue.Clear(); | 122 | m_pqueue.Clear(); |
121 | m_queue.Clear(); | 123 | m_queue.Clear(); |
124 | Monitor.Pulse(m_queueSync); | ||
122 | } | 125 | } |
123 | } | 126 | } |
124 | } | 127 | } |