Fixed sending error messages before closing session.

2009-02-05 19:29:44 +00:00
parent 8f59de0c62
commit ac7d448d09
1 changed files with 6 additions and 1 deletions
@@ -212,7 +212,12 @@ SenderThread::Main()
 					if (pos != m_sendQueueMap.end())
 					{
 						// Remove session if no write is in progress, else wait.
-						if (!pos->second->writeInProgress)
+						bool shouldDelete;
+						{
+							boost::mutex::scoped_lock lock(pos->second->dataMutex);
+							shouldDelete = (!pos->second->writeInProgress && pos->second->list.empty());
+						}
+						if (shouldDelete)
 							m_sendQueueMap.erase(pos);
 						else
 							newRemovedSessions.push_back(*i);