TAO_EC_Kokyu_Scheduling Class Reference

A scheduling strategy that uses TAO's real-time scheduler. More...

#include <EC_Kokyu_Scheduling.h>

Inheritance diagram for TAO_EC_Kokyu_Scheduling:

[legend]Collaboration diagram for TAO_EC_Kokyu_Scheduling:

[legend]List of all members.

Public Member Functions
	TAO_EC_Kokyu_Scheduling (RtecScheduler::Scheduler_ptr scheduler)
	Constructor.
virtual	~TAO_EC_Kokyu_Scheduling (void)
	Destructor.
virtual void	add_proxy_supplier_dependencies (TAO_EC_ProxyPushSupplier *supplier, TAO_EC_ProxyPushConsumer *consumer)
	Add all the dependencies between supplier and consumer.
virtual void	schedule_event (const RtecEventComm::EventSet &event, TAO_EC_ProxyPushConsumer *consumer, TAO_EC_Supplier_Filter *filter)
Private Member Functions
	TAO_EC_Kokyu_Scheduling (const TAO_EC_Kokyu_Scheduling &)
TAO_EC_Kokyu_Scheduling &	operator= (const TAO_EC_Kokyu_Scheduling &)
void	init_rt_info (void)
	Initialize our RT_Info handle and dependencies.
Private Attributes
RtecScheduler::Scheduler_var	scheduler_
	The scheduler we are going to use.

---

Detailed Description

A scheduling strategy that uses TAO's real-time scheduler.

This implementation of the Scheduling_Strategy uses TAO's real-time scheduler.

Definition at line 40 of file EC_Kokyu_Scheduling.h.

---

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL ACE_INLINE TAO_EC_Kokyu_Scheduling::TAO_EC_Kokyu_Scheduling

(

RtecScheduler::Scheduler_ptr

scheduler

)

Constructor.

Definition at line 8 of file EC_Kokyu_Scheduling.inl.

  :  scheduler_ (RtecScheduler::Scheduler::_duplicate (scheduler))
{
}

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_EC_Kokyu_Scheduling::~TAO_EC_Kokyu_Scheduling

(

void

)

[virtual]

Destructor.

Definition at line 17 of file EC_Kokyu_Scheduling.cpp.

{
}

TAO_EC_Kokyu_Scheduling::TAO_EC_Kokyu_Scheduling

(

const TAO_EC_Kokyu_Scheduling &

)

[private]

---

Member Function Documentation

void TAO_EC_Kokyu_Scheduling::add_proxy_supplier_dependencies	(	TAO_EC_ProxyPushSupplier *	supplier,
		TAO_EC_ProxyPushConsumer *	consumer
	)			[virtual]

Add all the dependencies between supplier and consumer.

Implements TAO_EC_Scheduling_Strategy.

Definition at line 22 of file EC_Kokyu_Scheduling.cpp.

References TAO_EC_ProxyPushSupplier::add_dependencies(), RtecEventChannelAdmin::SupplierQOS::publications, and TAO_EC_ProxyPushConsumer::publications().

{
  const RtecEventChannelAdmin::SupplierQOS& qos =
    consumer->publications ();

  for (CORBA::ULong i = 0; i < qos.publications.length (); ++i)
    {
      const RtecEventComm::EventHeader &header =
        qos.publications[i].event.header;
      TAO_EC_QOS_Info qos_info;
      qos_info.rt_info = qos.publications[i].dependency_info.rt_info;

      RtecScheduler::OS_Priority os_priority;
      RtecScheduler::Preemption_Subpriority_t p_subpriority;
      RtecScheduler::Preemption_Priority_t p_priority;
      this->scheduler_->priority (qos_info.rt_info,
                                  os_priority,
                                  p_subpriority,
                                  p_priority);
      qos_info.preemption_priority = p_priority;

      supplier->add_dependencies (header, qos_info);
    }
}

void TAO_EC_Kokyu_Scheduling::init_rt_info

(

void

)

[private]

Initialize our RT_Info handle and dependencies.

TAO_EC_Kokyu_Scheduling& TAO_EC_Kokyu_Scheduling::operator=

(

const TAO_EC_Kokyu_Scheduling &

)

[private]

void TAO_EC_Kokyu_Scheduling::schedule_event	(	const RtecEventComm::EventSet &	event,
		TAO_EC_ProxyPushConsumer *	consumer,
		TAO_EC_Supplier_Filter *	filter
	)			[virtual]

Schedule an event set and deliver them to the filter in the desired order and grouping.

Implements TAO_EC_Scheduling_Strategy.

Definition at line 50 of file EC_Kokyu_Scheduling.cpp.

References TAO_EC_Filter::matches(), TAO_EC_QOS_Info::preemption_priority, RtecEventChannelAdmin::SupplierQOS::publications, TAO_EC_ProxyPushConsumer::publications(), TAO_EC_Supplier_Filter::push_scheduled_event(), TAO_EC_QOS_Info::rt_info, and scheduler_.

{
  RtecEventChannelAdmin::SupplierQOS qos =
    consumer->publications ();

  for (CORBA::ULong j = 0; j != event.length (); ++j)
    {
      const RtecEventComm::Event& e = event[j];
      RtecEventComm::Event* buffer =
        const_cast<RtecEventComm::Event*> (&e);
      RtecEventComm::EventSet single_event (1, 1, buffer, 0);

      TAO_EC_QOS_Info qos_info;

      for (CORBA::ULong i = 0; i != qos.publications.length (); ++i)
        {
          const RtecEventComm::EventHeader &qos_header =
            qos.publications[i].event.header;

          if (TAO_EC_Filter::matches (e.header, qos_header) == 0)
            continue;

          qos_info.rt_info = qos.publications[i].dependency_info.rt_info;

          RtecScheduler::OS_Priority os_priority;
          RtecScheduler::Preemption_Subpriority_t p_subpriority;
          RtecScheduler::Preemption_Priority_t p_priority;
          this->scheduler_->priority (qos_info.rt_info,
                                      os_priority,
                                      p_subpriority,
                                      p_priority);
          qos_info.preemption_priority = p_priority;
        }

      filter->push_scheduled_event (single_event, qos_info);
    }
}

---

Member Data Documentation

RtecScheduler::Scheduler_var TAO_EC_Kokyu_Scheduling::scheduler_ [private]

The scheduler we are going to use.

Definition at line 65 of file EC_Kokyu_Scheduling.h.

Referenced by schedule_event().

---

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

• EC_Kokyu_Scheduling.h
• EC_Kokyu_Scheduling.cpp
• EC_Kokyu_Scheduling.inl

---