diff options
author | sapier <Sapier at GMX dot net> | 2014-01-06 12:45:42 +0100 |
---|---|---|
committer | sapier <Sapier at GMX dot net> | 2014-01-10 10:10:45 +0100 |
commit | 8b0b857eaaa50c6ec217a46c0577395c78ec04c7 (patch) | |
tree | b9fd5e1edb099aee1498b29a43702568a283aa34 /src/connection.cpp | |
parent | 10fdbf737513e48bfcfb9e90fe243dcd989c0476 (diff) | |
download | hax-minetest-server-8b0b857eaaa50c6ec217a46c0577395c78ec04c7.tar.gz hax-minetest-server-8b0b857eaaa50c6ec217a46c0577395c78ec04c7.zip |
Make MutexQueue use jsemaphore for signaling
Diffstat (limited to 'src/connection.cpp')
-rw-r--r-- | src/connection.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/connection.cpp b/src/connection.cpp index 8f83f6219..bc9279649 100644 --- a/src/connection.cpp +++ b/src/connection.cpp @@ -592,8 +592,9 @@ void * Connection::Thread() runTimeouts(dtime); + //NOTE this is only thread safe for ONE consumer thread! while(!m_command_queue.empty()){ - ConnectionCommand c = m_command_queue.pop_front(); + ConnectionCommand c = m_command_queue.pop_frontNoEx(); processCommand(c); } @@ -1556,7 +1557,7 @@ ConnectionEvent Connection::getEvent() e.type = CONNEVENT_NONE; return e; } - return m_event_queue.pop_front(); + return m_event_queue.pop_frontNoEx(); } ConnectionEvent Connection::waitEvent(u32 timeout_ms) |