|
version 1.42, 2002/04/25 16:37:09
|
version 1.43, 2002/04/25 17:46:03
|
|
|
|
| return(0); | return(0); |
| } | } |
| | |
| |
Uint32 MessageQueueService::get_pending_callback_count(void) |
| |
{ |
| |
return _callback.count(); |
| |
} |
| |
|
| |
|
| |
|
| void MessageQueueService::_sendwait_callback(AsyncOpNode *op, | void MessageQueueService::_sendwait_callback(AsyncOpNode *op, |
| MessageQueue *q, | MessageQueue *q, |
| void *parm) | void *parm) |
|
|
|
| if(callback == NULL) | if(callback == NULL) |
| return SendForget(msg); | return SendForget(msg); |
| AsyncOpNode *op = get_op(); | AsyncOpNode *op = get_op(); |
| |
msg->dest = destination; |
| if( NULL == (op->_op_dest = MessageQueue::lookup(msg->dest))) | if( NULL == (op->_op_dest = MessageQueue::lookup(msg->dest))) |
| { | { |
| op->release(); | op->release(); |
|
|
|
| destination, | destination, |
| msg, | msg, |
| destination); | destination); |
| msg = static_cast<Message *>(wrapper); |
|
| } | } |
| else | else |
| { | { |
|
|
|
| (static_cast<AsyncMessage *>(msg))->op = op; | (static_cast<AsyncMessage *>(msg))->op = op; |
| } | } |
| | |
| op->_callback_notify = _incoming.get_node_cond(); |
|
| _callback.insert_last(op); | _callback.insert_last(op); |
| return _meta_dispatcher->route_async(op); | return _meta_dispatcher->route_async(op); |
| } | } |
Return to
MessageQueueService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common