TAO_RTEvent
2.1.8
|
Send events received from a "local" EC using UDP. NOT THREAD-SAFE. This class connect as a consumer to an EventChannel and forwards the events it receives from that EC using UDP. More...
#include <ECG_UDP_Sender.h>
Public Member Functions | |
int | mtu (CORBA::ULong mtu) |
Accessors. More... | |
CORBA::ULong | mtu (void) const |
Accessors. More... | |
int | get_local_addr (ACE_INET_Addr &addr) |
Get the local endpoint used to send the events. More... | |
virtual void | disconnect_push_consumer (void) |
The PushConsumer methods. More... | |
virtual void | push (const RtecEventComm::EventSet &events) |
The PushConsumer methods. More... | |
![]() | |
void | set_deactivator (TAO_EC_Object_Deactivator &deactivator) |
Protected Member Functions | |
TAO_ECG_UDP_Sender (CORBA::Boolean crc=0) | |
![]() | |
TAO_EC_Deactivated_Object (void) | |
~TAO_EC_Deactivated_Object (void) | |
Private Types | |
typedef TAO_EC_Auto_Command < TAO_ECG_UDP_Sender_Disconnect_Command > | ECG_Sender_Auto_Proxy_Disconnect |
Private Member Functions | |
void | new_connect (const RtecEventChannelAdmin::ConsumerQOS &sub) |
Helpers for the connect() method. More... | |
void | reconnect (const RtecEventChannelAdmin::ConsumerQOS &sub) |
Helpers for the connect() method. More... | |
Private Attributes | |
RtecEventChannelAdmin::ProxyPushSupplier_var | supplier_proxy_ |
Proxy used to receive events from the Event Channel. More... | |
RtecEventChannelAdmin::EventChannel_var | lcl_ec_ |
Event Channel to which we act as a consumer. More... | |
RtecUDPAdmin::AddrServer_var | addr_server_ |
We query this object to determine where the events should be sent. More... | |
TAO_ECG_CDR_Message_Sender | cdr_sender_ |
Helper for fragmenting and sending cdr-encoded events using udp. More... | |
ECG_Sender_Auto_Proxy_Disconnect | auto_proxy_disconnect_ |
Manages our connection to Supplier Proxy. More... | |
static PortableServer::Servant_var < TAO_ECG_UDP_Sender > | create (CORBA::Boolean crc=0) |
Initialization and termination methods. More... | |
~TAO_ECG_UDP_Sender (void) | |
Initialization and termination methods. More... | |
void | init (RtecEventChannelAdmin::EventChannel_ptr lcl_ec, RtecUDPAdmin::AddrServer_ptr addr_server, TAO_ECG_Refcounted_Endpoint endpoint_rptr) |
void | connect (const RtecEventChannelAdmin::ConsumerQOS &sub) |
Connect or reconnect to the EC with the given subscriptions. More... | |
void | shutdown (void) |
Additional Inherited Members | |
![]() | |
TAO_EC_Object_Deactivator | deactivator_ |
Utility for deactivating ourselves from POA. More... | |
Send events received from a "local" EC using UDP. NOT THREAD-SAFE. This class connect as a consumer to an EventChannel and forwards the events it receives from that EC using UDP.
|
private |
TAO_ECG_UDP_Sender::~TAO_ECG_UDP_Sender | ( | void | ) |
Initialization and termination methods.
Create a new TAO_ECG_UDP_Sender object. (Constructor access is restricted to insure that all TAO_ECG_UDP_Sender objects are heap-allocated.)
|
protected |
Constructor (protected). Clients can create new TAO_ECG_UDP_Sender objects using the static create() method.
void TAO_ECG_UDP_Sender::connect | ( | const RtecEventChannelAdmin::ConsumerQOS & | sub | ) |
Connect or reconnect to the EC with the given subscriptions.
|
static |
Initialization and termination methods.
Create a new TAO_ECG_UDP_Sender object. (Constructor access is restricted to insure that all TAO_ECG_UDP_Sender objects are heap-allocated.)
|
virtual |
The PushConsumer methods.
Invokes shutdown (), which may result in the object being deleted, if refcounting is used to manage its lifetime.
int TAO_ECG_UDP_Sender::get_local_addr | ( | ACE_INET_Addr & | addr | ) |
Get the local endpoint used to send the events.
void TAO_ECG_UDP_Sender::init | ( | RtecEventChannelAdmin::EventChannel_ptr | lcl_ec, |
RtecUDPAdmin::AddrServer_ptr | addr_server, | ||
TAO_ECG_Refcounted_Endpoint | endpoint_rptr | ||
) |
lcl_ec | Event Channel to which we will act as a consumer of events. |
addr_server | Address server used to obtain event type to multicast group mapping. |
endpoint_rptr | Endpoint for sending udp/multicast messages. Endpoint's dgram must be open! |
To insure proper resource clean up, if init () is successful, shutdown () must be called when the sender is no longer needed. This is done by disconnect_push_consumer() method. If disconnect_push_consumer() will not be called, it is the responsibility of the user. Furthermore, if shutdown() is not explicitly called by either disconnect_push_consumer () or the user, the sender will clean up the resources in its destructor, however, certain entities involved in cleanup must still exist at that point, e.g., POA.
int TAO_ECG_UDP_Sender::mtu | ( | CORBA::ULong | mtu | ) |
Accessors.
The sender may need to fragment the message, otherwise the network may drop the packets. Setting the MTU can fail if the value is too small (at least the header + 8 bytes must fit).
CORBA::ULong TAO_ECG_UDP_Sender::mtu | ( | void | ) | const |
Accessors.
The sender may need to fragment the message, otherwise the network may drop the packets. Setting the MTU can fail if the value is too small (at least the header + 8 bytes must fit).
|
private |
Helpers for the connect() method.
|
virtual |
The PushConsumer methods.
Invokes shutdown (), which may result in the object being deleted, if refcounting is used to manage its lifetime.
|
private |
Helpers for the connect() method.
void TAO_ECG_UDP_Sender::shutdown | ( | void | ) |
Deactivate from POA and disconnect from EC, if necessary. Shut down all sender components. Calling this method may result in decrementing of the reference count (due to deactivation) and deletion of the object.
|
private |
We query this object to determine where the events should be sent.
|
private |
Manages our connection to Supplier Proxy.
|
private |
Helper for fragmenting and sending cdr-encoded events using udp.
|
private |
Event Channel to which we act as a consumer.
|
private |
Proxy used to receive events from the Event Channel.