"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "system/ThreadPool.cpp" between
muscle8.20.zip and muscle8.30.zip

About: MUSCLE (Multi User Server Client Linking Environment) is a messaging server and networking API. The included server program ("muscled") lets its clients message each other, and/or store information in its serverside hierarchical database.

ThreadPool.cpp  (muscle8.20):ThreadPool.cpp  (muscle8.30)
skipping to change at line 110 skipping to change at line 110
(void) _deferredMessages.Remove(client); (void) _deferredMessages.Remove(client);
} }
status_t ThreadPool :: ThreadPoolThread :: SendMessagesToInternalThread(IThreadP oolClient * client, Queue<MessageRef> & mq) status_t ThreadPool :: ThreadPoolThread :: SendMessagesToInternalThread(IThreadP oolClient * client, Queue<MessageRef> & mq)
{ {
MASSERT((_currentClient == NULL), "ThreadPoolThread::SendMessagesToInternal Thread: _currentClient isn't NULL!"); MASSERT((_currentClient == NULL), "ThreadPoolThread::SendMessagesToInternal Thread: _currentClient isn't NULL!");
MASSERT((_internalQueue.IsEmpty()), "ThreadPoolThread::SendMessagesToInternal Thread: _internalQueue isn't empty!"); MASSERT((_internalQueue.IsEmpty()), "ThreadPoolThread::SendMessagesToInternal Thread: _internalQueue isn't empty!");
_currentClient = client; _currentClient = client;
_internalQueue.SwapContents(mq); _internalQueue.SwapContents(mq);
if (SendMessageToInternalThread(MessageRef(&_dummyMsg, false)).IsOK()) return B_NO_ERROR; // Send an empty Message, just to signal the internal thread if (SendMessageToInternalThread(DummyMessageRef(_dummyMsg)).IsOK()) return B_ NO_ERROR; // Send an empty Message, just to signal the internal thread
else else
{ {
// roll back! // roll back!
_currentClient = NULL; _currentClient = NULL;
_internalQueue.SwapContents(mq); _internalQueue.SwapContents(mq);
return B_NO_ERROR; return B_NO_ERROR;
} }
} }
status_t ThreadPool :: ThreadPoolThread :: MessageReceivedFromOwner(const Messag eRef & msgRef, uint32 /*numLeft*/) status_t ThreadPool :: ThreadPoolThread :: MessageReceivedFromOwner(const Messag eRef & msgRef, uint32 /*numLeft*/)
 End of changes. 1 change blocks. 
1 lines changed or deleted 1 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)