|
version 1.107, 2005/05/27 02:34:02
|
version 1.108, 2005/05/27 13:18:13
|
|
|
|
| | |
| msg->op->_op_dest = this; | msg->op->_op_dest = this; |
| msg->op->_request.insert_first(msg); | msg->op->_request.insert_first(msg); |
| |
try { |
| _incoming.insert_last_wait(msg->op); | _incoming.insert_last_wait(msg->op); |
| _polling_sem.signal(); | _polling_sem.signal(); |
| |
} catch (const ListClosed &) |
| |
{ |
| |
// This means the queue has already been shut-down (happens when there |
| |
// are two AsyncIoctrl::IO_CLOSE messages generated and one got first |
| |
// processed. |
| |
delete msg; |
| |
} |
| } | } |
| | |
| | |
Return to
MessageQueueService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common