TAO_EC_Gateway_Sched Class Reference

Extend the EC_Gateway_IIOP interface to support scheduling. More...

#include <EC_Gateway_Sched.h>

Inheritance diagram for TAO_EC_Gateway_Sched:

[legend]Collaboration diagram for TAO_EC_Gateway_Sched:

[legend]List of all members.

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)

---

Detailed Description

Extend the EC_Gateway_IIOP interface to support scheduling.

Definition at line 34 of file EC_Gateway_Sched.h.

---

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_EC_Gateway_Sched::TAO_EC_Gateway_Sched

(

void

)

Definition at line 12 of file EC_Gateway_Sched.cpp.

  :  TAO_EC_Gateway_IIOP ()
{
}

TAO_EC_Gateway_Sched::~TAO_EC_Gateway_Sched

(

void

)

Definition at line 17 of file EC_Gateway_Sched.cpp.

{
}

---

Member Function Documentation

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.

Todo:

part of the RT_Info is hardcoded, we need to make it parametric.

Definition at line 22 of file EC_Gateway_Sched.cpp.

References ACE_GUARD, TAO_EC_Gateway_IIOP::consumer_info_, TAO_EC_Gateway_IIOP::init_i(), CORBA::is_nil(), TAO_EC_Gateway_IIOP::supplier_info_, TAO_SYNCH_MUTEX, and time().

{
  ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->lock_);

  this->init_i (supplier_ec, consumer_ec);

  // @@ Should we throw a system exception here?
  if (CORBA::is_nil (supplier_sched)
      || CORBA::is_nil (consumer_sched)
      || consumer_name == 0
      || supplier_name == 0)
    throw CORBA::BAD_PARAM ();

  this->supplier_info_ =
    supplier_sched->create (supplier_name);

  // @@ TODO Many things are hard-coded in the RT_Info here.

  // The worst case execution time is far less than 500 usecs, but
  // that is a safe estimate....
  ACE_Time_Value tv (0, 500);
  TimeBase::TimeT time;
  ORBSVCS_Time::Time_Value_to_TimeT (time, tv);
  supplier_sched->set (this->supplier_info_,
                       RtecScheduler::VERY_HIGH_CRITICALITY,
                       time, time, time,
                       25000 * 10,
                       RtecScheduler::VERY_LOW_IMPORTANCE,
                       time,
                       0,
                       RtecScheduler::OPERATION);

  this->consumer_info_ =
    consumer_sched->create (consumer_name);

  tv = ACE_Time_Value (0, 500);
  ORBSVCS_Time::Time_Value_to_TimeT (time, tv);
  consumer_sched->set (this->consumer_info_,
                       RtecScheduler::VERY_HIGH_CRITICALITY,
                       time, time, time,
                       25000 * 10,
                       RtecScheduler::VERY_LOW_IMPORTANCE,
                       time,
                       1,
                       RtecScheduler::REMOTE_DEPENDANT);
}

---

The documentation for this class was generated from the following files:

• EC_Gateway_Sched.h
• EC_Gateway_Sched.cpp

---