#include <ECG_Mcast_EH.h>
Inheritance diagram for TAO_ECG_Mcast_EH:
This object acts as an Observer to Event Channel. It subscribes to multicast groups that carry events matching the EC's subscriptions. This object then receives callbacks from the Reactor when data is available on the mcast sockets and alerts TAO_ECG_Dgram_Handler, which reads the data, transforms it into event and pushes to the Event Channel.
|
|
|
|
|
Constructor. Messages received by this EH will be forwarded to the recv. net_if can be used to specify NIC where multicast messages are expected. \buf_sz would be used to alter the default buffer size. See comments for receiver_ data member on why raw pointer is used for the recv argument. |
|
Destructor.
|
|
|
|
|
|
|
|
Reactor callback. Notify receiver_ that a dgram corresponding to fd is ready for reading. Reimplemented from ACE_Event_Handler. |
|
Register for changes in the EC subscription list. When the subscription list becomes non-empty we join the proper multicast groups (using Dgram_Handler to translate between event types and mcast groups) and the class registers 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). |
|
TAO_ECG_Handler_Shutdown method. Remove ourselves from the event channel, unsubscribe from the multicast groups, close the sockets and deregister from the reactor. Implements TAO_ECG_Handler_Shutdown. |
|
The Observer method. Subscribe/unsubscribe to multicast groups according to changes in consumer subscriptions. |
|
Make update_consumer () accessible to Observer.
|
|
Manages connection of our observer to the Event Channel. ORDER DEPENDENCY: this member should be declared AFTER <observer_>. |
|
The NIC used to subscribe for multicast traffic.
|
|
Event Channel Observer. Detects changes in EC consumer subscriptions. ORDER DEPENDENCY: this member should be declared before <auto_observer_disconnect_>. |
|
We callback to this object when a message arrives.
|
|
SOCKbuf size.
|
|
List of multicast addresses we subscribe to and dgrams we use.
|