/* -*- C++ -*- */ //============================================================================= /** * @file WFMO_Reactor.h * * $Id$ * * @author Irfan Pyarali * @author Tim Harrison * @author and Doug Schmidt */ //============================================================================= #ifndef ACE_WFMO_REACTOR_H #define ACE_WFMO_REACTOR_H #include "ace/pre.h" #include "ace/config-all.h" #if !defined (ACE_LACKS_PRAGMA_ONCE) # pragma once #endif /* ACE_LACKS_PRAGMA_ONCE */ #if defined (ACE_WIN32) #include "ace/Signal.h" #include "ace/Timer_Queue.h" #include "ace/Event_Handler.h" #include "ace/Synch.h" #include "ace/Reactor_Impl.h" #include "ace/Message_Queue.h" #include "ace/Process_Mutex.h" // If we don't have WinSOCK2, we need these defined #if !defined (ACE_HAS_WINSOCK2) || (ACE_HAS_WINSOCK2 == 0) /* * WinSock 2 extension -- bit values and indices for FD_XXX network events */ #define FD_READ_BIT 0 #define FD_WRITE_BIT 1 #define FD_OOB_BIT 2 #define FD_ACCEPT_BIT 3 #define FD_CONNECT_BIT 4 #define FD_CLOSE_BIT 5 #define FD_QOS_BIT 6 #define FD_GROUP_QOS_BIT 7 #define FD_QOS (1 << FD_QOS_BIT) #define FD_GROUP_QOS (1 << FD_GROUP_QOS_BIT) #define FD_MAX_EVENTS 8 #define FD_ALL_EVENTS ((1 << FD_MAX_EVENTS) - 1) #define WSAEVENT HANDLE typedef struct _WSANETWORKEVENTS { long lNetworkEvents; int iErrorCode[FD_MAX_EVENTS]; } WSANETWORKEVENTS, FAR * LPWSANETWORKEVENTS; int WSAEventSelect (SOCKET s, WSAEVENT hEventObject, long lNetworkEvents); int WSAEnumNetworkEvents (SOCKET s, WSAEVENT hEventObject, LPWSANETWORKEVENTS lpNetworkEvents); #endif /* !defined ACE_HAS_WINSOCK2 */ // Forward decl. class ACE_WFMO_Reactor; class ACE_Handle_Set; /** * @class ACE_Wakeup_All_Threads_Handler * * @brief This is a helper class whose sole purpose is to handle events * on wakeup_all_threads_> */ class ACE_Export ACE_Wakeup_All_Threads_Handler : public ACE_Event_Handler { public: /// Called when the wakeup_all_threads_> virtual int handle_signal (int signum, siginfo_t * = 0, ucontext_t * = 0); }; /** * @class ACE_WFMO_Reactor_Handler_Repository * * @brief Used to map s onto the appropriate * * and other information. */ class ACE_Export ACE_WFMO_Reactor_Handler_Repository { public: friend class ACE_WFMO_Reactor; friend class ACE_WFMO_Reactor_Test; /** * @class Common_Info * * @brief This struct contains the necessary information for every * entry. The reason the event is not in this * structure is because we need to pass an event array into * WaitForMultipleObjects and therefore keeping the events * seperate makes sense. */ class Common_Info { public: /// This indicates whether this entry is for I/O or for a regular /// event int io_entry_; /// The assosiated ACE_Event_Handler *event_handler_; /// The I/O handle related to the . This entry is /// only valid if the flag is true. ACE_HANDLE io_handle_; /** * This is the set of events that the is * interested in. This entry is only valid if the flag * is true. */ long network_events_; /** * This flag indicates that created the event on * behalf of the user. Therefore we need to clean this up when the * removes itself from . This entry * is only valid if the flag is true. */ int delete_event_; /// This is set when the entry needed to be deleted. int delete_entry_; /** * These are the masks related to for the * . This is only valid when is * set. */ ACE_Reactor_Mask close_masks_; /// Constructor used for initializing the structure Common_Info (void); /// Reset the state of the structure void reset (void); /// Set the structure to these new values void set (int io_entry, ACE_Event_Handler *event_handler, ACE_HANDLE io_handle, long network_events, int delete_event, int delete_entry, ACE_Reactor_Mask close_masks); /// Set the structure to these new values void set (Common_Info &common_info); /// Dump the state of an object. void dump (void) const; }; /** * @class Current_Info * * @brief This structure inherits from the common structure to add * information for current entries. */ class Current_Info : public Common_Info { public: /// This is set when the entry needed to be suspended. int suspend_entry_; /// Default constructor Current_Info (void); /// Reset the state of the structure void reset (void); /// Set the structure to these new values void set (int io_entry, ACE_Event_Handler *event_handler, ACE_HANDLE io_handle, long network_events, int delete_event, int delete_entry = 0, ACE_Reactor_Mask close_masks = ACE_Event_Handler::NULL_MASK, int suspend_entry = 0); /// Set the structure to these new values void set (Common_Info &common_info, int suspend_entry = 0); /// Dump the state of an object. void dump (ACE_HANDLE event_handle) const; }; /** * @class To_Be_Added_Info * * @brief This structure inherits from the common structure to add * information for entries. */ class To_Be_Added_Info : public Common_Info { public: /// Handle for the event ACE_HANDLE event_handle_; /// This is set when the entry needed to be suspended. int suspend_entry_; /// Default constructor To_Be_Added_Info (void); /// Reset the state of the structure void reset (void); /// Set the structure to these new values void set (ACE_HANDLE event_handle, int io_entry, ACE_Event_Handler *event_handler, ACE_HANDLE io_handle, long network_events, int delete_event, int delete_entry = 0, ACE_Reactor_Mask close_masks = ACE_Event_Handler::NULL_MASK, int suspend_entry = 0); /// Set the structure to these new values void set (ACE_HANDLE event_handle, Common_Info &common_info, int suspend_entry = 0); /// Dump the state of an object. void dump (void) const; }; /** * @class Suspended_Info * * @brief This structure inherits from the common structure to add * information for suspended entries. */ class Suspended_Info : public Common_Info { public: /// Handle for the event ACE_HANDLE event_handle_; /// This is set when the entry needed to be resumed. int resume_entry_; /// Constructor used for initializing the structure Suspended_Info (void); /// Reset the state of the structure void reset (void); /// Set the structure to these new values void set (ACE_HANDLE event_handle, int io_entry, ACE_Event_Handler *event_handler, ACE_HANDLE io_handle, long network_events, int delete_event, int delete_entry = 0, ACE_Reactor_Mask close_masks = 0, int resume_entry = 0); /// Set the structure to these new values void set (ACE_HANDLE event_handle, Common_Info &common_info, int resume_entry = 0); /// Dump the state of an object. void dump (void) const; }; /// Constructor. ACE_WFMO_Reactor_Handler_Repository (ACE_WFMO_Reactor &wfmo_reactor); /// Destructor. virtual ~ACE_WFMO_Reactor_Handler_Repository (void); /// Initialize the repository of the approriate . int open (size_t size); /// Close down the handler repository. int close (void); // = Search structure operations. /// Bind the to the . This is for /// the simple event entry. int bind (ACE_HANDLE, ACE_Event_Handler *); /// Insert I/O entry into the system. This method /// assumes that the lock are head *before* this method is invoked. int bind_i (int io_entry, ACE_Event_Handler *event_handler, long network_events, ACE_HANDLE io_handle, ACE_HANDLE event_handle, int delete_event); /// Remove the binding of in accordance with the . int unbind (ACE_HANDLE, ACE_Reactor_Mask mask); /// Non-lock-grabbing version of int unbind_i (ACE_HANDLE, ACE_Reactor_Mask mask, int &changes_required); /// Remove all bindings of tuples. void unbind_all (void); // = Sanity checking. // Check the to make sure it's a valid ACE_HANDLE int invalid_handle (ACE_HANDLE handle) const; // = Accessors. /// Maximum ACE_HANDLE value, plus 1. DWORD max_handlep1 (void) const; /// Pointer to the beginning of the current array of /// *'s. ACE_HANDLE *handles (void) const; /// Pointer to the beginning of the current array of /// *'s. Current_Info *current_info (void) const; /// Check if changes to the handle set are required. virtual int changes_required (void); /// Make changes to the handle set virtual int make_changes (void); /// Check to see if has been scheduled for deletion int scheduled_for_deletion (size_t slot) const; /** * This method is used to calculate the network mask after a mask_op * request to . Note that because the * may already be in the handler repository, we may have to find the * old event and the old network events */ int modify_network_events_i (ACE_HANDLE io_handle, ACE_Reactor_Mask new_masks, ACE_Reactor_Mask &old_masks, long &new_network_events, ACE_HANDLE &event_handle, int &delete_event, int operation); /// This method is used to change the network mask left (if any) /// after a remove request to ACE_Reactor_Mask bit_ops (long &existing_masks, ACE_Reactor_Mask to_be_removed_masks, int operation); /// Temporarily suspend entry int suspend_handler_i (ACE_HANDLE handle, int &changes_required); /// Resume suspended entry int resume_handler_i (ACE_HANDLE handle, int &changes_required); /// Deletions and suspensions in current_info_ int make_changes_in_current_infos (void); /// Deletions and resumptions in current_suspended_info_ int make_changes_in_suspension_infos (void); /// Deletions in to_be_added_info_, or transfers to current_info_ or /// current_suspended_info_ from to_be_added_info_ int make_changes_in_to_be_added_infos (void); /// Removes the at from the table. int remove_handler_i (size_t slot, ACE_Reactor_Mask mask); /// Removes the at from the table. int remove_suspended_handler_i (size_t slot, ACE_Reactor_Mask mask); /// Removes the at from the table. int remove_to_be_added_handler_i (size_t slot, ACE_Reactor_Mask to_be_removed_masks); /** * Check to see if is associated with a valid Event_Handler * bound to . Return the associated with this * if != 0. */ int handler (ACE_HANDLE handle, ACE_Reactor_Mask mask, ACE_Event_Handler **event_handler = 0); /// Dump the state of an object. void dump (void) const; protected: /// Reference to our . ACE_WFMO_Reactor &wfmo_reactor_; /// Maximum number of handles. size_t max_size_; /** * Array of passed to . This * is not part of the structure as the handle array needs to be * passed directly to . */ ACE_HANDLE *current_handles_; /// Array of current entries in the table Current_Info *current_info_; /// A count of the number of active handles. DWORD max_handlep1_; /// Information for entries to be added To_Be_Added_Info *to_be_added_info_; /// Number of records to be added size_t handles_to_be_added_; /// Currently suspended handles Suspended_Info *current_suspended_info_; /// Number of currently suspended handles size_t suspended_handles_; /// Number of records to be suspended size_t handles_to_be_suspended_; /// Number of records to be resumed size_t handles_to_be_resumed_; /// Number of records to be deleted size_t handles_to_be_deleted_; }; /** * @class ACE_WFMO_Reactor_Notify * * @brief Unblock the from its event loop, passing * it an optional to dispatch. * * This implementation is necessary for cases where the * is run in a multi-threaded program. In * this case, we need to be able to unblock * when updates occur other than in the * main thread. To do this, we signal an * auto-reset event the is listening on. If * an and is passed to * , the appropriate method is dispatched. */ class ACE_Export ACE_WFMO_Reactor_Notify : public ACE_Reactor_Notify { public: /// Constructor ACE_WFMO_Reactor_Notify (size_t max_notifies = 1024); /// Initialization. is stored to call . virtual int open (ACE_Reactor_Impl *wfmo_reactor, ACE_Timer_Queue *timer_queue, int disable_notify = 0); /// No-op. virtual int close (void); /** * Special trick to unblock when updates * occur. All we do is enqueue and onto the * and wakeup the by signaling * its handle. The indicates how long * to blocking trying to notify the . If == * 0, the caller will block until action is possible, else will wait * until the relative time specified in elapses). */ virtual int notify (ACE_Event_Handler *event_handler = 0, ACE_Reactor_Mask mask = ACE_Event_Handler::EXCEPT_MASK, ACE_Time_Value *timeout = 0); /// No-op. virtual int dispatch_notifications (int &number_of_active_handles, ACE_Handle_Set &rd_mask); /// Returns a handle to the . virtual ACE_HANDLE get_handle (void) const; /// Returns the ACE_HANDLE of the notify pipe on which the reactor /// is listening for notifications so that other threads can unblock /// the virtual ACE_HANDLE notify_handle (void); /// Handle one of the notify call on the . This could be /// because of a thread trying to unblock the virtual int dispatch_notify (ACE_Notification_Buffer &buffer); /// Verify whether the buffer has dispatchable info or not. virtual int is_dispatchable (ACE_Notification_Buffer &buffer); /// Read one of the notify call on the into the /// . This could be because of a thread trying to unblock /// the virtual int read_notify_pipe (ACE_HANDLE handle, ACE_Notification_Buffer &buffer); /** * Set the maximum number of times that the * method will iterate and * dispatch the that are passed in via the * notify queue before breaking out of its * loop. By default, this is set to * -1, which means "iterate until the queue is empty." Setting this * to a value like "1 or 2" will increase "fairness" (and thus * prevent starvation) at the expense of slightly higher dispatching * overhead. */ void max_notify_iterations (int); /** * Get the maximum number of times that the * method will iterate and * dispatch the that are passed in via the * notify queue before breaking out of its * loop. */ int max_notify_iterations (void); /** * Purge any notifications pending in this reactor for the specified * object. If == 0, all notifications for all * handlers are removed (but not any notifications posted just to wake up * the reactor itself). Returns the number of notifications purged. * Returns -1 on error. */ virtual int purge_pending_notifications (ACE_Event_Handler *, ACE_Reactor_Mask = ACE_Event_Handler::ALL_EVENTS_MASK); /// Dump the state of an object. virtual void dump (void) const; private: /// Pointer to the wfmo_reactor's timer queue. ACE_Timer_Queue *timer_queue_; /** * Called when the notification event waited on by * is signaled. This dequeues all pending * and dispatches them. */ virtual int handle_signal (int signum, siginfo_t * = 0, ucontext_t * = 0); /// An auto event is used so that we can it to wakeup one /// thread up (e.g., when the method is called). ACE_Auto_Event wakeup_one_thread_; /// Message queue that keeps track of pending . /// This queue must be thread-safe because it can be called by /// multiple threads of control. ACE_Message_Queue message_queue_; /** * Keeps track of the maximum number of times that the * method will iterate and * dispatch the that are passed in via the * notify queue before breaking out of its * loop. By default, this is set to * -1, which means "iterate until the queue is empty." */ int max_notify_iterations_; }; /** * @class ACE_WFMO_Reactor * * @brief An object oriented event demultiplexor and event handler. * ACE_WFMO_Reactor is a Windows-only implementation of the ACE_Reactor * interface that uses the WaitForMultipleObjects() event demultiplexer. * * Like the other ACE Reactors, ACE_WFMO_Reactor can schedule timers. * It also reacts to signalable handles, such as events (see the documentation * for WaitForMultipleObjects() for a complete list of signalable handle * types). Therefore, I/O handles are not directly usable for registering * for input, output, and exception notification. The exception to this * is ACE_SOCK-based handles, which can be registered for input, output, and * exception notification just as with other platforms. See Chapter 4 in * C++NPv2 for complete details. * * Note that changes to the state of ACE_WFMO_Reactor are not * instantaneous. Most changes (registration, removal, * suspension, and resumption of handles, and changes in * ownership) are made when the ACE_WFMO_Reactor reaches a stable * state. Users should be careful, especially when removing * handlers. This is because the ACE_WFMO_Reactor will call * handle_close() on the handler when it is finally removed and * not when remove_handler() is called. If the registered handler's pointer * is not valid when ACE_WFMO_Reactor calls ACE_Event_Handler::handle_close(), * use the DONT_CALL flag with remove_handler(). Preferably, use dynamically * allocated event handlers and call "delete this" inside the handle_close() * hook method. */ class ACE_Export ACE_WFMO_Reactor : public ACE_Reactor_Impl { public: friend class ACE_WFMO_Reactor_Handler_Repository; friend class ACE_WFMO_Reactor_Test; enum { /// Default size of the WFMO_Reactor's handle table. /** * Two slots will be added to the @a size parameter in the * constructor and open methods which will store handles used for * internal management purposes. */ DEFAULT_SIZE = MAXIMUM_WAIT_OBJECTS - 2 }; // = Initialization and termination methods. /// Initialize ACE_WFMO_Reactor with the default size. ACE_WFMO_Reactor (ACE_Sig_Handler * = 0, ACE_Timer_Queue * = 0, ACE_Reactor_Notify * = 0); /** * Initialize ACE_WFMO_Reactor with the specified size. * * @param size The maximum number of handles the reactor can * register. The value should not exceed * ACE_WFMO_Reactor::DEFAULT_SIZE. Two slots will be * added to the @a size parameter which will store handles * used for internal management purposes. */ ACE_WFMO_Reactor (size_t size, int unused = 0, ACE_Sig_Handler * = 0, ACE_Timer_Queue * = 0, ACE_Reactor_Notify * = 0); /** * Initialize ACE_WFMO_Reactor with the specified size. * * @param size The maximum number of handles the reactor can * register. The value should not exceed * ACE_WFMO_Reactor::DEFAULT_SIZE. Two slots will be * added to the @a size parameter which will store handles * used for internal management purposes. */ virtual int open (size_t size = ACE_WFMO_Reactor::DEFAULT_SIZE, int restart = 0, ACE_Sig_Handler * = 0, ACE_Timer_Queue * = 0, int disable_notify_pipe = 0, ACE_Reactor_Notify * = 0); /// Returns -1 (not used in this implementation); virtual int current_info (ACE_HANDLE, size_t & /* size */); /// Use a user specified signal handler instead. virtual int set_sig_handler (ACE_Sig_Handler *signal_handler); /// @deprecated The following method is deprecated. /// Instead, either specify a timer queue when creating/opening the /// object or use the timer_queue() method. virtual int set_timer_queue (ACE_Timer_Queue *tq); /// Set a user-specified timer queue. virtual int timer_queue (ACE_Timer_Queue *tq); /// Return the current ACE_Timer_Queue. virtual ACE_Timer_Queue *timer_queue (void) const; /// Close down the ACE_WFMO_Reactor and release all of its resources. virtual int close (void); /// Close down the ACE_WFMO_Reactor and release all of its resources. virtual ~ACE_WFMO_Reactor (void); // = Event loop drivers. /** * This method is not currently implemented. We recommend that you * use handle_events (ACE_Time_Value::zero) to get basically the * same effect, i.e., it won't block the caller if there are no events. */ virtual int work_pending (const ACE_Time_Value &max_wait_time = ACE_Time_Value::zero); /** * This event loop driver blocks for up to before * returning. It will return earlier if timer events, I/O events, * or signal events occur. Note that can be 0, in * which case this method blocks indefinitely until events occur. * * is decremented to reflect how much time this call * took. For instance, if a time value of 3 seconds is passed to * handle_events and an event occurs after 2 seconds, * will equal 1 second. This can be used if an * application wishes to handle events for some fixed amount of * time. * * is used as the demultiplexing call * * Returns the total number of I/O and timer s * that were dispatched, 0 if the elapsed without * dispatching any handlers, or -1 if an error occurs. * * The only difference between and * is that in the alertable case, TRUE is passed to * for the option. */ virtual int handle_events (ACE_Time_Value *max_wait_time = 0); virtual int alertable_handle_events (ACE_Time_Value *max_wait_time = 0); /** * This method is just like the one above, except the * value is a reference and can therefore never be * NULL. * * The only difference between and * is that in the alertable case, TRUE is passed to * for the option. */ virtual int handle_events (ACE_Time_Value &max_wait_time); virtual int alertable_handle_events (ACE_Time_Value &max_wait_time); // = Event handling control. /** * Return the status of Reactor. If this function returns 0, the reactor is * actively handling events. If it returns non-zero, and * return -1 immediately. */ virtual int deactivated (void); /** * Control whether the Reactor will handle any more incoming events or not. * If == 1, the Reactor will be disabled. By default, a reactor * is in active state and can be deactivated/reactived as wish. */ virtual void deactivate (int do_stop); // = Register and remove Handlers. /** * Register an . Since no Event * Mask is passed through this interface, it is assumed that the * being passed in is an event handle and when the event * becomes signaled, will call handle_signal on * . If == the * will call the method of * to extract the underlying event handle. */ virtual int register_handler (ACE_Event_Handler *event_handler, ACE_HANDLE event_handle = ACE_INVALID_HANDLE); /** * Register an . specifies * the network events that the is interested in. If * == the will * call the method of to extract the * underlying I/O handle. If the == * , WFMO_Reactor will create an event for * associating it with the I/O handle. When the is * signalled, the appropriate callback will be invoked on * the */ virtual int register_handler (ACE_HANDLE event_handle, ACE_HANDLE io_handle, ACE_Event_Handler *event_handler, ACE_Reactor_Mask mask); /** * This is a simple version of the above method * where the I/O handle is passed in and the event handle will * always be created by */ virtual int register_handler (ACE_HANDLE io_handle, ACE_Event_Handler *event_handler, ACE_Reactor_Mask mask); /** * This is a simple version of the above method * where the I/O handle will always come from on the * and the event handle will always be created by * */ virtual int register_handler (ACE_Event_Handler *event_handler, ACE_Reactor_Mask mask); /// Register with all the in the /// . virtual int register_handler (const ACE_Handle_Set &handles, ACE_Event_Handler *event_handler, ACE_Reactor_Mask mask); /** * Register to handle the signal using the * . Returns the that was previously registered * (if any), along with the of the signal handler. */ virtual int register_handler (int signum, ACE_Event_Handler *new_sh, ACE_Sig_Action *new_disp = 0, ACE_Event_Handler **old_sh = 0, ACE_Sig_Action *old_disp = 0); /// Registers to handle a set of signals using the /// . virtual int register_handler (const ACE_Sig_Set &sigset, ACE_Event_Handler *new_sh, ACE_Sig_Action *new_disp = 0); /** * Removes from the . Note that * the will call the method of * to extract the underlying handle. If == * then the method of * the is not invoked. Note that the can * either be the or the */ virtual int remove_handler (ACE_Event_Handler *event_handler, ACE_Reactor_Mask mask); /** * Removes from the . If == * then the method of * the is not invoked. Note that the can * either be the or the * * For the case of I/O entries, this removes the binding of * whose handle is from . If * there are no more bindings for this then it is * removed from the WFMO_Reactor. For simple event entries, mask is * mostly ignored and the is always removed from * */ virtual int remove_handler (ACE_HANDLE handle, ACE_Reactor_Mask mask); /** * Removes all the bindings for handles in the * bind of . If there are no more bindings for any * of these handles then they are removed from WFMO_Reactor. */ virtual int remove_handler (const ACE_Handle_Set &handle_set, ACE_Reactor_Mask); /** * Remove the ACE_Event_Handler currently associated with . * is ignored in this implementation since there is only * one instance of a signal handler. Install the new disposition * (if given) and return the previous disposition (if desired by the * caller). Returns 0 on success and -1 if is invalid. */ virtual int remove_handler (int signum, ACE_Sig_Action *new_disp, ACE_Sig_Action *old_disp = 0, int sigkey = -1); /// Calls for every signal in . virtual int remove_handler (const ACE_Sig_Set &sigset); // = Suspend and resume Handlers. /// Suspend temporarily. Use /// to get the handle. virtual int suspend_handler (ACE_Event_Handler *event_handler); /// Suspend temporarily. virtual int suspend_handler (ACE_HANDLE handle); /// Suspend all in handle set temporarily. virtual int suspend_handler (const ACE_Handle_Set &handles); /// Suspend all temporarily. virtual int suspend_handlers (void); /// Resume . Use to /// get the handle. virtual int resume_handler (ACE_Event_Handler *event_handler); /// Resume . virtual int resume_handler (ACE_HANDLE handle); /// Resume all in handle set. virtual int resume_handler (const ACE_Handle_Set &handles); /// Resume all . virtual int resume_handlers (void); /// Does the reactor allow the application to resume the handle on /// its own ie. can it pass on the control of handle resumption to /// the application. A positive value indicates that the handlers /// are application resumable. A value of 0 indicates otherwise. virtual int resumable_handler (void); /** * Return 1 if we any event associations were made by the reactor * for the handles that it waits on, 0 otherwise. Since the * WFMO_Reactor does use event associations, this function always * return 1. */ virtual int uses_event_associations (void); // Timer management. /** * Schedule an ACE_Event_Handler that will expire after an amount * of time. The return value of this method, a timer_id value, * uniquely identifies the event_handler in the ACE_Reactor's * internal list of timers. * This timer_id value can be used to cancel the timer * with the cancel_timer() call. * * @see cancel_timer() * @see reset_timer_interval() * * @param event_handler event handler to schedule on reactor * @param arg argument passed to the handle_timeout() method of event_handler * @param delay time interval after which the timer will expire * @param interval time interval after which the timer will be automatically rescheduled * @return -1 on failure, a timer_id value on success */ virtual long schedule_timer (ACE_Event_Handler *event_handler, const void *arg, const ACE_Time_Value &delay, const ACE_Time_Value &interval = ACE_Time_Value::zero); /** * Resets the interval of the timer represented by to * , which is specified in relative time to the current * . If is equal to * , the timer will become a non-rescheduling * timer. Returns 0 if successful, -1 if not. */ virtual int reset_timer_interval (long timer_id, const ACE_Time_Value &interval); /// Cancel all Event_Handlers that match the address of /// . Returns number of handler's cancelled. virtual int cancel_timer (ACE_Event_Handler *event_handler, int dont_call_handle_close = 1); /** * Cancel the single Event_Handler that matches the value * (which was returned from the schedule method). If arg is * non-NULL then it will be set to point to the ``magic cookie'' * argument passed in when the Event_Handler was registered. This * makes it possible to free up the memory and avoid memory leaks. * Returns 1 if cancellation succeeded and 0 if the * wasn't found. */ virtual int cancel_timer (long timer_id, const void **arg = 0, int dont_call_handle_close = 1); // = High-level Event_Handler scheduling operations /** * Add to the 's entry in * WFMO_Reactor. must already have been registered * with WFMO_Reactor. */ virtual int schedule_wakeup (ACE_Event_Handler *event_handler, ACE_Reactor_Mask masks_to_be_added); /** * Add to the 's entry in WFMO_Reactor. * The Event_Handler associated with must already have been * registered with WFMO_Reactor. */ virtual int schedule_wakeup (ACE_HANDLE handle, ACE_Reactor_Mask masks_to_be_added); /** * Remove to the 's entry in * WFMO_Reactor. The Event_Handler associated with must * already have been registered with WFMO_Reactor. */ virtual int cancel_wakeup (ACE_Event_Handler *event_handler, ACE_Reactor_Mask masks_to_be_deleted); /** * Remove to the 's entry in * WFMO_Reactor. The Event_Handler associated with must * already have been registered with WFMO_Reactor. */ virtual int cancel_wakeup (ACE_HANDLE handle, ACE_Reactor_Mask masks_to_be_deleted); // = Notification methods. /** * Wakeup one thread if it is currently blocked * in . The indicates how * long to blocking trying to notify the . If * == 0, the caller will block until action is possible, * else will wait until the relative time specified in * elapses). */ virtual int notify (ACE_Event_Handler * = 0, ACE_Reactor_Mask = ACE_Event_Handler::EXCEPT_MASK, ACE_Time_Value * = 0); /** * Set the maximum number of times that the * method will iterate and * dispatch the that are passed in via the * notify queue before breaking out of its * loop. By default, this is set to * -1, which means "iterate until the queue is empty." Setting this * to a value like "1 or 2" will increase "fairness" (and thus * prevent starvation) at the expense of slightly higher dispatching * overhead. */ virtual void max_notify_iterations (int); /** * Get the maximum number of times that the * method will iterate and * dispatch the that are passed in via the * notify queue before breaking out of its * loop. */ virtual int max_notify_iterations (void); /** * Purge any notifications pending in this reactor for the specified * object. Returns the number of notifications * purged. Returns -1 on error. */ virtual int purge_pending_notifications (ACE_Event_Handler * = 0, ACE_Reactor_Mask = ACE_Event_Handler::ALL_EVENTS_MASK); // = Assorted helper methods. /** * Check to see if is associated with a valid Event_Handler * bound to . Return the associated with this * if != 0. */ virtual int handler (ACE_HANDLE handle, ACE_Reactor_Mask mask, ACE_Event_Handler **event_handler = 0); /** * Check to see if is associated with a valid Event_Handler * bound to a signal. Return the associated with * this if != 0. */ virtual int handler (int signum, ACE_Event_Handler ** = 0); /// Returns true if WFMO_Reactor has been successfully initialized, else /// false. virtual int initialized (void); /// Returns the current size of the WFMO_Reactor's internal /// descriptor table. virtual size_t size (void) const; /// Returns a reference to the WFMO_Reactor's internal lock. virtual ACE_Lock &lock (void); /// Wake up all threads in WaitForMultipleObjects so that they can /// reconsult the handle set virtual void wakeup_all_threads (void); /** * Transfers ownership of the WFMO_Reactor to the . The * transfer will not complete until all threads are ready (just like * the handle set). */ virtual int owner (ACE_thread_t new_owner, ACE_thread_t *old_owner = 0); /// Return the ID of the "owner" thread. virtual int owner (ACE_thread_t *owner); /// Get the existing restart value. virtual int restart (void); /// Set a new value for restart and return the original value. virtual int restart (int r); /// Not implemented virtual void requeue_position (int); /// Not implemented virtual int requeue_position (void); // = Low-level wait_set mask manipulation methods. /** * Modify of the 's entry in WFMO_Reactor * depending upon . must already have * been registered with WFMO_Reactor. */ virtual int mask_ops (ACE_Event_Handler *event_handler, ACE_Reactor_Mask masks, int operation); /** * Modify of the 's entry in WFMO_Reactor depending * upon . must already have been registered * with WFMO_Reactor. */ virtual int mask_ops (ACE_HANDLE handle, ACE_Reactor_Mask masks, int ops); // = Low-level ready_set mask manipulation methods. /// Not implemented virtual int ready_ops (ACE_Event_Handler *event_handler, ACE_Reactor_Mask mask, int ops); /// Not implemented virtual int ready_ops (ACE_HANDLE handle, ACE_Reactor_Mask, int ops); /// Declare the dynamic allocation hooks. ACE_ALLOC_HOOK_DECLARE; /// Dump the state of an object. virtual void dump (void) const; protected: /// Registration workhorse virtual int register_handler_i (ACE_HANDLE event_handle, ACE_HANDLE io_handle, ACE_Event_Handler *event_handler, ACE_Reactor_Mask mask); /// Event handling workhorse virtual int event_handling (ACE_Time_Value *max_wait_time = 0, int alertable = 0); /// Bit masking workhorse virtual int mask_ops_i (ACE_HANDLE io_handle, ACE_Reactor_Mask masks, int operation); /// Return the ID of the "owner" thread. Does not do any locking. virtual ACE_thread_t owner_i (void); /// Check to see if it is ok to enter <::WaitForMultipleObjects>. virtual int ok_to_wait (ACE_Time_Value *max_wait_time, int alertable); /// Wait for timer and I/O events to occur. virtual DWORD wait_for_multiple_events (int timeout, int alertable); /// Check for activity on remaining handles. virtual DWORD poll_remaining_handles (DWORD slot); /// Expire timers. Only the owner thread does useful stuff in this /// function. virtual int expire_timers (void); /// Dispatches the timers and I/O handlers. virtual int dispatch (DWORD wait_status); /// Protect against structured exceptions caused by user code when /// dispatching handles virtual int safe_dispatch (DWORD wait_status); /** * Dispatches any active handles from handles_[] to * handles_[active_handles_] using to poll * through our handle set looking for active handles. */ virtual int dispatch_handles (DWORD slot); /// Dispatches a single handler. Returns 0 on success, -1 if the /// handler was removed. virtual int dispatch_handler (DWORD slot, DWORD max_handlep1); /// Dispatches a single handler. Returns 0 on success, -1 if the /// handler was removed. virtual int simple_dispatch_handler (DWORD slot, ACE_HANDLE event_handle); /// Dispatches a single handler. Returns 0 on success, -1 if the /// handler was removed. virtual int complex_dispatch_handler (DWORD slot, ACE_HANDLE event_handle); /// Dispatches window messages. Noop for WFMO_Reactor. virtual int dispatch_window_messages (void); virtual ACE_Reactor_Mask upcall (ACE_Event_Handler *event_handler, ACE_HANDLE io_handle, WSANETWORKEVENTS &events); /// Used to caluculate the next timeout virtual int calculate_timeout (ACE_Time_Value *time); /// Update the state of the handler repository virtual int update_state (void); /// Check to see if we have a new owner virtual int new_owner (void); /// Set owner to new owner virtual int change_owner (void); /// Handle signals without requiring global/static variables. ACE_Sig_Handler *signal_handler_; /// Keeps track of whether we should delete the signal handler (if we /// didn't create it, then we don't delete it). int delete_signal_handler_; /// Defined as a pointer to allow overriding by derived classes... ACE_Timer_Queue *timer_queue_; /// Keeps track of whether we should delete the timer queue (if we /// didn't create it, then we don't delete it). int delete_timer_queue_; /// Keeps track of whether we should delete the handler repository int delete_handler_rep_; /// Used when is called. ACE_Reactor_Notify *notify_handler_; /// Keeps track of whether we should delete the notify handler. int delete_notify_handler_; /** * Synchronization for the ACE_WFMO_Reactor. * * A Process Mutex is used here because of two reasons: * (a) The implementation of ACE_Thread_Mutex uses CriticalSections * CriticalSections are not waitable using ::WaitForMultipleObjects * (b) This is really not a process mutex because it is not * named. No other process can use this mutex. */ ACE_Process_Mutex lock_; /// Adapter used to return internal lock to outside world. ACE_Lock_Adapter lock_adapter_; /// Table that maps to 's. ACE_WFMO_Reactor_Handler_Repository handler_rep_; /// A manual event used to block threads from proceeding into /// WaitForMultipleObjects ACE_Manual_Event ok_to_wait_; /** * A manual event is used so that we can wake everyone up (e.g., * when are bounded and unbound from the * handler repository). */ ACE_Manual_Event wakeup_all_threads_; /// Used when is signaled ACE_Wakeup_All_Threads_Handler wakeup_all_threads_handler_; /// The changing thread waits on this event, till all threads are not /// active anymore ACE_Auto_Event waiting_to_change_state_; /// Count of currently active threads size_t active_threads_; /** * The thread which is "owner" of the WFMO_Reactor. The owner * concept is used because we don't want multiple threads to try to * expire timers. Therefore the "owner" thread is the only one * allowed to expire timers. Also, the owner thread is the only * thread which waits on the notify handle. Note that the ownership * can be transferred. */ ACE_thread_t owner_; /// The owner to be of the WFMO_Reactor ACE_thread_t new_owner_; /// This is the thread which is responsible for the changing the /// state of the handle set ACE_thread_t change_state_thread_; /// This is an array of ACE_HANDLEs which keep track of the /// and handles ACE_HANDLE atomic_wait_array_ [2]; /// This flag is used to keep track of whether we are already closed. int open_for_business_; /// This flag is used to keep track of whether we are actively handling /// events or not. sig_atomic_t deactivated_; private: /// Deny access since member-wise won't work... ACE_WFMO_Reactor (const ACE_WFMO_Reactor &); ACE_WFMO_Reactor &operator = (const ACE_WFMO_Reactor &); }; #if defined (__ACE_INLINE__) #include "ace/WFMO_Reactor.i" #endif /* __ACE_INLINE__ */ #endif /* ACE_WIN32 */ #include "ace/post.h" #endif /* ACE_WFMO_REACTOR_H */