|
version 1.139, 2008/06/26 17:46:58
|
version 1.140, 2008/08/19 17:20:21
|
|
|
|
| msg->op->_request.reset(msg); | msg->op->_request.reset(msg); |
| try | try |
| { | { |
| _incoming.enqueue_wait(msg->op); |
_incoming.enqueue(msg->op); |
| _polling_sem.signal(); | _polling_sem.signal(); |
| } | } |
| catch (const ListClosed&) | catch (const ListClosed&) |
|
|
|
| if ((rq != 0 && (true == messageOK(rq))) || | if ((rq != 0 && (true == messageOK(rq))) || |
| (rp != 0 && (true == messageOK(rp))) && _die.get() == 0) | (rp != 0 && (true == messageOK(rp))) && _die.get() == 0) |
| { | { |
| _incoming.enqueue_wait(op); |
_incoming.enqueue(op); |
| _polling_sem.signal(); | _polling_sem.signal(); |
| return true; | return true; |
| } | } |
Return to
MessageQueueService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common