NAME

ACE_WFMO_Reactor_Notify - Unblock the ACE_WFMO_Reactor from its event loop, passing it an optional ACE_Event_Handler to dispatch.

SYNOPSIS

#include <ace/WFMO_Reactor.h>

class ACE_WFMO_Reactor_Notify : public ACE_Reactor_Notify { public: ACE_WFMO_Reactor_Notify (void); virtual int open ( ACE_Reactor_Impl *wfmo_reactor, ACE_Timer_Queue *timer_queue, int disable_notify = 0 ); virtual int close (void); ssize_t notify ( ACE_Event_Handler *event_handler = 0, ACE_Reactor_Mask mask = ACE_Event_Handler::EXCEPT_MASK, ACE_Time_Value *timeout = 0 ); virtual int dispatch_notifications ( int &number_of_active_handles, ACE_Handle_Set &rd_mask ); virtual ACE_HANDLE get_handle (void) const; void max_notify_iterations (int); int max_notify_iterations (void); virtual void dump (void) const; private: ACE_Timer_Queue *timer_queue_; virtual int handle_signal ( int signum, siginfo_t * = 0, ucontext_t * = 0 ); ACE_Auto_Event wakeup_one_thread_; ACE_Message_Queue<ACE_MT_SYNCH> message_queue_; int max_notify_iterations_; };

DESCRIPTION

This implementation is necessary for cases where the ACE_WFMO_Reactor is run in a multi-threaded program. In this case, we need to be able to unblock WaitForMultipleObjects when updates occur other than in the main ACE_WFMO_Reactor thread. To do this, we signal an auto-reset event the ACE_WFMO_Reactor is listening on. If an ACE_Event_Handler and ACE_Reactor_Mask is passed to notify, the appropriate handle_* method is dispatched.

PUBLIC MEMBERS

ACE_WFMO_Reactor_Notify (void);

virtual int open (
    ACE_Reactor_Impl *wfmo_reactor,
    ACE_Timer_Queue *timer_queue,
    int disable_notify = 0
    );

virtual int close (void);

ssize_t notify (
    ACE_Event_Handler *event_handler = 0,
    ACE_Reactor_Mask mask = ACE_Event_Handler::EXCEPT_MASK,
    ACE_Time_Value *timeout = 0
    );

virtual int dispatch_notifications (
    int &number_of_active_handles,
    ACE_Handle_Set &rd_mask
    );

virtual ACE_HANDLE get_handle (void) const;

void max_notify_iterations (int);

int max_notify_iterations (void);

virtual void dump (void) const;

PRIVATE MEMBERS

ACE_Timer_Queue *timer_queue_;

virtual int handle_signal (
    int signum,
    siginfo_t * = 0,
    ucontext_t * = 0
    );

ACE_Auto_Event wakeup_one_thread_;

ACE_Message_Queue<ACE_MT_SYNCH> message_queue_;

int max_notify_iterations_;

AUTHOR

Irfan Pyarali, Tim Harrison, and Doug Schmidt

LIBRARY

ace