|
version 1.65, 2002/11/06 21:43:55
|
version 1.66, 2003/01/19 16:14:00
|
|
|
|
| DQueue<MessageQueueService> *list = reinterpret_cast<DQueue<MessageQueueService> *>(myself->get_parm()); | DQueue<MessageQueueService> *list = reinterpret_cast<DQueue<MessageQueueService> *>(myself->get_parm()); |
| while ( _stop_polling.value() == 0 ) | while ( _stop_polling.value() == 0 ) |
| { | { |
| |
try |
| |
{ |
| _polling_sem.wait(); | _polling_sem.wait(); |
| |
} |
| |
catch (WaitFailed) |
| |
{ |
| |
myself->exit_self( (PEGASUS_THREAD_RETURN) 1 ); |
| |
} |
| |
|
| if(_stop_polling.value() != 0 ) | if(_stop_polling.value() != 0 ) |
| { | { |
| break; | break; |
Return to
MessageQueueService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common