TAO_RTEvent
2.4.0
|
Simple Event Handler for mcast messages. Listens for messages on a single mcast group. Useful in environments where event traffic is not separated into different groups. Calls handle_input (ACE_SOCK_Dgram_Mcast dgram) on a specified TAO_ECG_Dgram_Handler to inform it about message arrival. More...
#include <ECG_Simple_Mcast_EH.h>
Public Member Functions | |
virtual int | handle_input (ACE_HANDLE fd) |
TAO_ECG_Simple_Mcast_EH (TAO_ECG_Dgram_Handler *recv) | |
Initialization and termination methods. More... | |
virtual | ~TAO_ECG_Simple_Mcast_EH (void) |
Destructor. More... | |
int | open (const char *mcast_addr, const ACE_TCHAR *net_if=0) |
virtual int | shutdown (void) |
Public Member Functions inherited from ACE_Event_Handler | |
virtual | ~ACE_Event_Handler (void) |
virtual ACE_HANDLE | get_handle (void) const |
virtual void | set_handle (ACE_HANDLE) |
virtual int | priority (void) const |
virtual void | priority (int priority) |
virtual int | handle_output (ACE_HANDLE fd=ACE_INVALID_HANDLE) |
virtual int | handle_exception (ACE_HANDLE fd=ACE_INVALID_HANDLE) |
virtual int | handle_timeout (const ACE_Time_Value ¤t_time, const void *act=0) |
virtual int | handle_exit (ACE_Process *) |
virtual int | handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask) |
virtual int | handle_signal (int signum, siginfo_t *=0, ucontext_t *=0) |
virtual int | resume_handler (void) |
virtual int | handle_qos (ACE_HANDLE=ACE_INVALID_HANDLE) |
virtual int | handle_group_qos (ACE_HANDLE=ACE_INVALID_HANDLE) |
virtual void | reactor (ACE_Reactor *reactor) |
virtual ACE_Reactor * | reactor (void) const |
virtual ACE_Reactor_Timer_Interface * | reactor_timer_interface (void) const |
virtual Reference_Count | add_reference (void) |
virtual Reference_Count | remove_reference (void) |
Reference_Counting_Policy & | reference_counting_policy (void) |
Public Member Functions inherited from TAO_ECG_Handler_Shutdown | |
virtual | ~TAO_ECG_Handler_Shutdown (void) |
Private Attributes | |
ACE_SOCK_Dgram_Mcast | dgram_ |
TAO_ECG_Dgram_Handler * | receiver_ |
We callback to this object when a message arrives. More... | |
Simple Event Handler for mcast messages. Listens for messages on a single mcast group. Useful in environments where event traffic is not separated into different groups. Calls handle_input (ACE_SOCK_Dgram_Mcast dgram) on a specified TAO_ECG_Dgram_Handler to inform it about message arrival.
NOT THREAD-SAFE.
TAO_ECG_Simple_Mcast_EH::TAO_ECG_Simple_Mcast_EH | ( | TAO_ECG_Dgram_Handler * | recv | ) |
Initialization and termination methods.
Constructor. Messages received by this EH will be forwarded to the <recv>.
|
virtual |
Destructor.
|
virtual |
Main method - reactor callback. Notify <receiver_> that <dgram_> is ready for reading.
Reimplemented from ACE_Event_Handler.
int TAO_ECG_Simple_Mcast_EH::open | ( | const char * | mcast_addr, |
const ACE_TCHAR * | net_if = 0 |
||
) |
Join the specified multicast group and register itself with the reactor. To insure proper resource clean up, if open () is successful, the user MUST call shutdown () when handler is no longer needed (and its reactor still exists).
|
virtual |
TAO_ECG_Handler_Shutdown method. Unsubscribe from the reactor and close the datagram.
Implements TAO_ECG_Handler_Shutdown.
|
private |
|
private |
We callback to this object when a message arrives.