Inheritance diagram for TAO_ECG_Mcast_EH:
Public Member Functions
|virtual int||handle_input (ACE_HANDLE fd)|
|TAO_ECG_Mcast_EH (TAO_ECG_Dgram_Handler *recv, const ACE_TCHAR *net_if=0, CORBA::ULong buf_sz=0)|
|Initialization and termination methods. |
|void||open (RtecEventChannelAdmin::EventChannel_ptr ec)|
|virtual int||shutdown (void)|
|TAO_ECG_Handler_Shutdown method. |
|typedef ACE_Array_Base< Subscription >||Subscriptions|
Private Member Functions
|void||update_consumer (const RtecEventChannelAdmin::ConsumerQOS &sub) throw (CORBA::SystemException)|
|void||compute_required_subscriptions (const RtecEventChannelAdmin::ConsumerQOS &sub, Address_Set &multicast_addresses) throw (CORBA::SystemException)|
|int||delete_unwanted_subscriptions (Address_Set &multicast_addresses)|
|void||add_new_subscriptions (Address_Set &multicast_addresses)|
|The NIC used to subscribe for multicast traffic. |
|List of multicast addresses we subscribe to and dgrams we use. |
|We callback to this object when a message arrives. |
|SOCKbuf size. |
|TAO_EC_Servant_Var< Observer >||observer_|
|TAO_EC_Auto_Command< Observer_Disconnect_Command >||auto_observer_disconnect_|
|Make update_consumer () accessible to Observer. |
|Observes changes in the EC consumer subscriptions and notifies TAO_ECG_Mcast_EH when there are changes. More...|
|Disconnects Observer from the Event Channel. More...|
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.
|TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_ECG_Mcast_EH::TAO_ECG_Mcast_EH||(||TAO_ECG_Dgram_Handler *||recv,|
|const ACE_TCHAR *|| net_if =
|CORBA::ULong|| buf_sz = |
Initialization and termination methods.
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. 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.
|void TAO_ECG_Mcast_EH::add_new_subscriptions||(||Address_Set &||multicast_addresses||)||
|multicast_addresses||List of multicast addresses to which we need to subscribe to in order to be receiving all event types in the current consumer subscriptions.|
|void TAO_ECG_Mcast_EH::compute_required_subscriptions||(||const RtecEventChannelAdmin::ConsumerQOS &||sub,|
|)|| throw (CORBA::SystemException)
|sub||The list of event types that our event channel consumers are interested in.|
|multicast_addresses||This method populates this list with multicast addresses that we need to be subscribed to in order to receive event types specified in /a sub.|
|int TAO_ECG_Mcast_EH::delete_unwanted_subscriptions||(||Address_Set &||multicast_addresses||)||
|multicast_addresses||List of multicast addresses we need to be subscribed to in order receive all event types in the current consumer subscriptions.|
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).
|void TAO_ECG_Mcast_EH::update_consumer||(||const RtecEventChannelAdmin::ConsumerQOS &||sub||)|| throw (CORBA::SystemException)
The Observer method. Subscribe/unsubscribe to multicast groups according to changes in consumer subscriptions.
Manages connection of our observer to the Event Channel. ORDER DEPENDENCY: this member should be declared AFTER <observer_>.
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.
List of multicast addresses we subscribe to and dgrams we use.