TAO_RTEvent
2.2.0
|
Extend the EC_Gateway_IIOP interface to support scheduling. More...
#include <EC_Gateway_Sched.h>
Public Member Functions | |
TAO_EC_Gateway_Sched (void) | |
~TAO_EC_Gateway_Sched (void) | |
void | init (RtecEventChannelAdmin::EventChannel_ptr supplier_ec, RtecEventChannelAdmin::EventChannel_ptr consumer_ec, RtecScheduler::Scheduler_ptr supplier_sched, RtecScheduler::Scheduler_ptr consumer_sched, const char *consumer_name, const char *supplier_name) |
Public Member Functions inherited from TAO_EC_Gateway_IIOP | |
TAO_EC_Gateway_IIOP (void) | |
virtual | ~TAO_EC_Gateway_IIOP (void) |
int | init (RtecEventChannelAdmin::EventChannel_ptr supplier_ec, RtecEventChannelAdmin::EventChannel_ptr consumer_ec) |
void | disconnect_push_supplier (void) |
The channel is disconnecting. More... | |
void | disconnect_push_consumer (void) |
The channel is disconnecting. More... | |
void | push (const RtecEventComm::EventSet &events) |
int | shutdown (void) |
Disconnect and shutdown the gateway. More... | |
virtual void | close (void) |
virtual void | update_consumer (const RtecEventChannelAdmin::ConsumerQOS &sub) |
virtual void | update_supplier (const RtecEventChannelAdmin::SupplierQOS &pub) |
void | reconnect_consumer_ec (void) |
CORBA::Boolean | consumer_ec_non_existent (CORBA::Boolean_out disconnected) |
Check whether the consumer event channel is non existent or not. More... | |
void | cleanup_consumer_proxies (void) |
int | cleanup_consumer_ec (void) |
int | cleanup_supplier_ec (void) |
void | suspend_supplier_ec (void) |
Suspend the connection to the supplier ec. More... | |
void | resume_supplier_ec (void) |
Resume the connection to the supplier ec. More... | |
Public Member Functions inherited from TAO_EC_Gateway | |
TAO_EC_Gateway (void) | |
Default constructor. More... | |
virtual | ~TAO_EC_Gateway (void) |
Destructor. More... | |
void | observer_handle (RtecEventChannelAdmin::Observer_Handle h) |
Obtain and modify the observer handle. More... | |
RtecEventChannelAdmin::Observer_Handle | observer_handle (void) const |
Additional Inherited Members | |
Protected Types inherited from TAO_EC_Gateway_IIOP | |
typedef ACE_Map_Manager < RtecEventComm::EventSourceID, RtecEventChannelAdmin::ProxyPushConsumer_ptr, ACE_Null_Mutex > | Consumer_Map |
typedef ACE_Map_Iterator < RtecEventComm::EventSourceID, RtecEventChannelAdmin::ProxyPushConsumer_ptr, ACE_Null_Mutex > | Consumer_Map_Iterator |
Protected Member Functions inherited from TAO_EC_Gateway_IIOP | |
int | init_i (RtecEventChannelAdmin::EventChannel_ptr supplier_ec, RtecEventChannelAdmin::EventChannel_ptr consumer_ec) |
Do the real work in init() More... | |
Protected Attributes inherited from TAO_EC_Gateway_IIOP | |
TAO_SYNCH_MUTEX | lock_ |
Lock to synchronize internal changes. More... | |
CORBA::ULong | busy_count_ |
int | update_posted_ |
RtecEventChannelAdmin::ConsumerQOS | c_qos_ |
int | cleanup_posted_ |
int | supplier_ec_suspended_ |
RtecEventChannelAdmin::EventChannel_var | supplier_ec_ |
RtecEventChannelAdmin::EventChannel_var | consumer_ec_ |
The event channel acting as consumer of this gateway. More... | |
RtecBase::handle_t | supplier_info_ |
Our RT_Infos for the event channel that is the supplier. More... | |
RtecBase::handle_t | consumer_info_ |
Our RT_Infos for the event channel that is the consumer. More... | |
ACE_PushConsumer_Adapter < TAO_EC_Gateway_IIOP > | consumer_ |
Our consumer personality.... More... | |
bool | consumer_is_active_ |
If it is true then we must deactivate the consumer. More... | |
ACE_PushSupplier_Adapter < TAO_EC_Gateway_IIOP > | supplier_ |
Our supplier personality.... More... | |
bool | supplier_is_active_ |
If it is true then we must deactivate the supplier. More... | |
Consumer_Map | consumer_proxy_map_ |
RtecEventChannelAdmin::ProxyPushConsumer_var | default_consumer_proxy_ |
RtecEventChannelAdmin::ProxyPushSupplier_var | supplier_proxy_ |
TAO_ECG_ConsumerEC_Control * | ec_control_ |
TAO_EC_Gateway_IIOP_Factory * | factory_ |
The Gateway IIOP Factory for all the settings. More... | |
int | use_ttl_ |
If 1, we use the TTL flags, if 0, we just ignore TTL. More... | |
int | use_consumer_proxy_map_ |
Extend the EC_Gateway_IIOP interface to support scheduling.
TAO_EC_Gateway_Sched::TAO_EC_Gateway_Sched | ( | void | ) |
TAO_EC_Gateway_Sched::~TAO_EC_Gateway_Sched | ( | void | ) |
void TAO_EC_Gateway_Sched::init | ( | RtecEventChannelAdmin::EventChannel_ptr | supplier_ec, |
RtecEventChannelAdmin::EventChannel_ptr | consumer_ec, | ||
RtecScheduler::Scheduler_ptr | supplier_sched, | ||
RtecScheduler::Scheduler_ptr | consumer_sched, | ||
const char * | consumer_name, | ||
const char * | supplier_name | ||
) |
To do its job this class requires to know the local and remote ECs it will connect to; furthermore it also requires to build RT_Infos for the local and remote schedulers.