|
version 1.138, 2008/06/19 17:57:01
|
version 1.141, 2008/08/21 17:51:31
|
|
|
|
| "Common.MessageQueueService.UNABLE_TO_REGISTER", | "Common.MessageQueueService.UNABLE_TO_REGISTER", |
| "CIM base message queue service is unable to register with the " | "CIM base message queue service is unable to register with the " |
| "CIMOM dispatcher."); | "CIMOM dispatcher."); |
| throw BindFailedException(parms); |
throw Exception(parms); |
| } | } |
| | |
| _get_polling_list()->insert_back(this); | _get_polling_list()->insert_back(this); |
|
|
|
| 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&) |
|
|
|
| // processed. | // processed. |
| delete msg; | delete msg; |
| } | } |
| catch (const Permission&) |
|
| { |
|
| delete msg; |
|
| } | } |
| } |
|
| |
|
| | |
| | |
| void MessageQueueService::enqueue(Message* msg) | void MessageQueueService::enqueue(Message* msg) |
|
|
|
| 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