generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-10-27 11:06:50 +01:00
Code Issues Projects Releases Wiki Activity

trunk/branch integration: AsyncChannel locking fix

Browse Source
This commit is contained in:
Marian Krivos
2011-08-22 16:36:33 +00:00
parent ec76633667
commit be689588e4
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
Foundation/src/AsyncChannel.cpp
View File

@@ -86,7 +86,7 @@ AsyncChannel::~AsyncChannel()
void AsyncChannel::setChannel(Channel* pChannel) void AsyncChannel::setChannel(Channel* pChannel)
{ {
FastMutex::ScopedLock lock(_mutex); FastMutex::ScopedLock lock(_channelMutex);
if (_pChannel) _pChannel->release(); if (_pChannel) _pChannel->release();
_pChannel = pChannel; _pChannel = pChannel;
@@ -102,7 +102,7 @@ Channel* AsyncChannel::getChannel() const
void AsyncChannel::open() void AsyncChannel::open()
{ {
FastMutex::ScopedLock lock(_mutex); FastMutex::ScopedLock lock(_threadMutex);
if (!_thread.isRunning()) if (!_thread.isRunning())
_thread.start(*this); _thread.start(*this);
@@ -150,7 +150,7 @@ void AsyncChannel::run()
{ {
MessageNotification* pNf = dynamic_cast<MessageNotification*>(nf.get()); MessageNotification* pNf = dynamic_cast<MessageNotification*>(nf.get());
{ {
FastMutex::ScopedLock lock(_mutex); FastMutex::ScopedLock lock(_channelMutex);
if (pNf && _pChannel) _pChannel->log(pNf->message()); if (pNf && _pChannel) _pChannel->log(pNf->message());
} }