Public Methods |
| ACE_WFMO_Reactor_Handler_Repository (ACE_WFMO_Reactor &wfmo_reactor) |
| Constructor.
|
virtual | ~ACE_WFMO_Reactor_Handler_Repository (void) |
| Destructor.
|
int | open (size_t size) |
| Initialize the repository of the approriate <size>.
|
int | close (void) |
| Close down the handler repository.
|
int | bind (ACE_HANDLE, ACE_Event_Handler *) |
| Bind the to the . This is for the simple event entry.
|
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) |
| Insert I/O <Event_Handler> entry into the system. This method assumes that the lock are head *before* this method is invoked.
|
int | unbind (ACE_HANDLE, ACE_Reactor_Mask mask) |
| Remove the binding of in accordance with the <mask>.
|
int | unbind_i (ACE_HANDLE, ACE_Reactor_Mask mask, int &changes_required) |
| Non-lock-grabbing version of <unbind>.
|
void | unbind_all (void) |
| Remove all bindings of tuples.
|
int | invalid_handle (ACE_HANDLE handle) const |
size_t | max_handlep1 (void) const |
| Maximum ACE_HANDLE value, plus 1.
|
ACE_HANDLE* | handles (void) const |
| Pointer to the beginning of the current array of *'s.
|
Current_Info* | current_info (void) const |
| Pointer to the beginning of the current array of *'s.
|
virtual int | changes_required (void) |
| Check if changes to the handle set are required.
|
virtual int | make_changes (void) |
| Make changes to the handle set.
|
int | scheduled_for_deletion (size_t slot) const |
| Check to see if <slot> has been scheduled for deletion.
|
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) |
ACE_Reactor_Mask | bit_ops (long &existing_masks, ACE_Reactor_Mask to_be_removed_masks, int operation) |
| This method is used to change the network mask left (if any) after a remove request to <WFMO_Reactor>.
|
int | suspend_handler_i (ACE_HANDLE handle, int &changes_required) |
| Temporarily suspend entry.
|
int | resume_handler_i (ACE_HANDLE handle, int &changes_required) |
| Resume suspended entry.
|
int | make_changes_in_current_infos (void) |
| Deletions and suspensions in current_info_.
|
int | make_changes_in_suspension_infos (void) |
| Deletions and resumptions in current_suspended_info_.
|
int | make_changes_in_to_be_added_infos (void) |
| Deletions in to_be_added_info_, or transfers to current_info_ or current_suspended_info_ from to_be_added_info_.
|
int | remove_handler_i (size_t slot, ACE_Reactor_Mask mask) |
| Removes the at <slot> from the table.
|
int | remove_suspended_handler_i (size_t slot, ACE_Reactor_Mask mask) |
| Removes the at <slot> from the table.
|
int | remove_to_be_added_handler_i (size_t slot, ACE_Reactor_Mask to_be_removed_masks) |
| Removes the at <slot> from the table.
|
int | handler (ACE_HANDLE handle, ACE_Reactor_Mask mask, ACE_Event_Handler **event_handler = 0) |
void | dump (void) const |
| Dump the state of an object.
|
Protected Attributes |
ACE_WFMO_Reactor& | wfmo_reactor_ |
| Reference to our <WFMO_Reactor>.
|
size_t | max_size_ |
| Maximum number of handles.
|
ACE_HANDLE* | current_handles_ |
Current_Info* | current_info_ |
| Array of current entries in the table.
|
size_t | max_handlep1_ |
| A count of the number of active handles.
|
To_Be_Added_Info* | to_be_added_info_ |
| Information for entries to be added.
|
size_t | handles_to_be_added_ |
| Number of records to be added.
|
Suspended_Info* | current_suspended_info_ |
| Currently suspended handles.
|
size_t | suspended_handles_ |
| Number of currently suspended handles.
|
size_t | handles_to_be_suspended_ |
| Number of records to be suspended.
|
size_t | handles_to_be_resumed_ |
| Number of records to be resumed.
|
size_t | handles_to_be_deleted_ |
| Number of records to be deleted.
|
Friends |
class | ACE_WFMO_Reactor |
class | ACE_WFMO_Reactor_Test |