|
version 1.2, 2005/04/11 16:30:26
|
version 1.3, 2005/07/25 02:11:01
|
|
|
|
| | |
| Boolean isLoaded(void) const; | Boolean isLoaded(void) const; |
| | |
| |
void waitForEventThread(void); |
| |
|
| Boolean isIdle(void); | Boolean isIdle(void); |
| | |
| virtual void getIdleTimer(struct timeval *); | virtual void getIdleTimer(struct timeval *); |
|
|
|
| // This allows for a simulated "WaitForMultipleObjects" | // This allows for a simulated "WaitForMultipleObjects" |
| Semaphore* _check_queue; | Semaphore* _check_queue; |
| | |
| |
//Signals that the event thread is listening and can now be signalled. |
| |
//This eliminates any synchronization issues that may occur when the first event comes in or if shutdown is called |
| |
//right as the consumer thread is being started |
| |
Semaphore* _listeningSemaphore; |
| | |
| //ATTN: For now, we must store the shutdown semaphore on the consumer, in order to be able to gracefully | //ATTN: For now, we must store the shutdown semaphore on the consumer, in order to be able to gracefully |
| //unload it during a normal shutdown OR an idle shutdown. Pegasus's ThreadPool does not provide | //unload it during a normal shutdown OR an idle shutdown. Pegasus's ThreadPool does not provide |
Return to
DynamicConsumer.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / DynListener