TAO_EC_RTCORBA_Dispatching Class Reference

RTCORBA-based dispatching strategy. More...

#include <EC_RTCORBA_Dispatching.h>

Inheritance diagram for TAO_EC_RTCORBA_Dispatching:

[legend]Collaboration diagram for TAO_EC_RTCORBA_Dispatching:

[legend]List of all members.

Public Member Functions
	TAO_EC_RTCORBA_Dispatching (const RTCORBA::ThreadpoolLanes &lanes, RTCORBA::PriorityMapping *mapping, RTCORBA::Current_ptr current)
	Constructor.
	~TAO_EC_RTCORBA_Dispatching (void)
	Destructor.
virtual void	activate (void)
virtual void	shutdown (void)
virtual void	push (TAO_EC_ProxyPushSupplier *proxy, RtecEventComm::PushConsumer_ptr consumer, const RtecEventComm::EventSet &event, TAO_EC_QOS_Info &qos_info)
virtual void	push_nocopy (TAO_EC_ProxyPushSupplier *proxy, RtecEventComm::PushConsumer_ptr consumer, RtecEventComm::EventSet &event, TAO_EC_QOS_Info &qos_info)
Private Attributes
RTCORBA::ThreadpoolLanes	lanes_
	The thread pools...
RTCORBA::PriorityMapping *	priority_mapping_
	Used to map between CORBA and native priorities.
RTCORBA::Current_var	current_
	Used to get the current RTCORBA priority.
ACE_Thread_Manager	thread_manager_
	Use our own thread manager.
TAO_EC_Dispatching_Task *	tasks_
	The dispatching task(s), one per lane.

---

Detailed Description

RTCORBA-based dispatching strategy.

Definition at line 37 of file EC_RTCORBA_Dispatching.h.

---

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_EC_RTCORBA_Dispatching::TAO_EC_RTCORBA_Dispatching (  const RTCORBA::ThreadpoolLanes &  lanes, RTCORBA::PriorityMapping *  mapping, RTCORBA::Current_ptr  current )

Constructor. Definition at line 11 of file EC_RTCORBA_Dispatching.cpp. References ACE_NEW, lanes_, and ACE_Task_Base::thr_mgr(). : lanes_ (lanes) , priority_mapping_ (mapping) , current_ (RTCORBA::Current::_duplicate (current)) { CORBA::ULong number_lanes = this->lanes_.length (); ACE_NEW (this->tasks_, TAO_EC_Dispatching_Task[number_lanes]); for (CORBA::ULong i = 0; i != this->lanes_.length (); ++i) this->tasks_[i].thr_mgr (&this->thread_manager_); }

TAO_EC_RTCORBA_Dispatching::~TAO_EC_RTCORBA_Dispatching (  void   )

Destructor. Definition at line 24 of file EC_RTCORBA_Dispatching.cpp. { delete[] this->tasks_; }

---

Member Function Documentation

void TAO_EC_RTCORBA_Dispatching::activate (  void   )  [virtual]

Initialize all the data structures, activate any internal threads, etc. Implements TAO_EC_Dispatching. Definition at line 30 of file EC_RTCORBA_Dispatching.cpp. References ACE_Task_Base::activate(), lanes_, and priority_mapping_. { for (CORBA::ULong i = 0; i != this->lanes_.length (); ++i) { CORBA::ULong nthreads = this->lanes_[i].static_threads; if (nthreads == 0) { nthreads = 1; } RTCORBA::Priority corba_priority = this->lanes_[i].lane_priority; RTCORBA::NativePriority native_priority; if (this->priority_mapping_->to_native (corba_priority, native_priority) != 0) { this->tasks_[i].activate ( THR_SCHED_FIFO | THR_NEW_LWP | THR_JOINABLE, nthreads, 0, native_priority); } } }

void TAO_EC_RTCORBA_Dispatching::push (  TAO_EC_ProxyPushSupplier *  proxy, RtecEventComm::PushConsumer_ptr  consumer, const RtecEventComm::EventSet &  event, TAO_EC_QOS_Info &  qos_info )  [virtual]

Definition at line 70 of file EC_RTCORBA_Dispatching.cpp. References ACE_ENV_ARG_PARAMETER, RtecEventComm::EventSet, and push_nocopy(). { RtecEventComm::EventSet event_copy = event; this->push_nocopy (proxy, consumer, event_copy, qos_info ACE_ENV_ARG_PARAMETER); }

void TAO_EC_RTCORBA_Dispatching::push_nocopy (  TAO_EC_ProxyPushSupplier *  proxy, RtecEventComm::PushConsumer_ptr  consumer, RtecEventComm::EventSet &  event, TAO_EC_QOS_Info &  qos_info )  [virtual]

Definition at line 81 of file EC_RTCORBA_Dispatching.cpp. References ACE_CHECK, ACE_ENV_ARG_PARAMETER, ACE_ENV_SINGLE_ARG_PARAMETER, RtecEventComm::EventSet, lanes_, and TAO_EC_Dispatching_Task::push(). Referenced by push(). { RTCORBA::Priority current_priority = this->current_->the_priority (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; for (CORBA::ULong i = 0; i != this->lanes_.length (); ++i) { if (this->lanes_[i].lane_priority != current_priority) continue; // @@ If there were no threads available we may need to create // some... this->tasks_[i].push (proxy, consumer, event ACE_ENV_ARG_PARAMETER); ACE_CHECK; break; } }

void TAO_EC_RTCORBA_Dispatching::shutdown (  void   )  [virtual]

Deactivate any internal threads and cleanup internal data structures, it should only return once the threads have finished their jobs. Implements TAO_EC_Dispatching. Definition at line 53 of file EC_RTCORBA_Dispatching.cpp. References lanes_, ACE_Thread_Manager::num_threads_in_task(), ACE_Task< ACE_SYNCH >::putq(), and ACE_Thread_Manager::wait(). { for (CORBA::ULong i = 0; i != this->lanes_.length (); ++i) { int nthreads = this->thread_manager_.num_threads_in_task (&this->tasks_[i]); if (nthreads <= 0) continue; for (int j = 0; j != nthreads; ++j) { this->tasks_[i].putq (new TAO_EC_Shutdown_Task_Command); } } this->thread_manager_.wait (); }

---

Member Data Documentation

RTCORBA::Current_var TAO_EC_RTCORBA_Dispatching::current_ [private]

Used to get the current RTCORBA priority. Definition at line 70 of file EC_RTCORBA_Dispatching.h.

RTCORBA::ThreadpoolLanes TAO_EC_RTCORBA_Dispatching::lanes_ [private]

The thread pools... Definition at line 64 of file EC_RTCORBA_Dispatching.h. Referenced by activate(), push_nocopy(), shutdown(), and TAO_EC_RTCORBA_Dispatching().

RTCORBA::PriorityMapping* TAO_EC_RTCORBA_Dispatching::priority_mapping_ [private]

Used to map between CORBA and native priorities. Definition at line 67 of file EC_RTCORBA_Dispatching.h. Referenced by activate().

TAO_EC_Dispatching_Task* TAO_EC_RTCORBA_Dispatching::tasks_ [private]

The dispatching task(s), one per lane. Definition at line 76 of file EC_RTCORBA_Dispatching.h.

ACE_Thread_Manager TAO_EC_RTCORBA_Dispatching::thread_manager_ [private]

Use our own thread manager. Definition at line 73 of file EC_RTCORBA_Dispatching.h.

---

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

• EC_RTCORBA_Dispatching.h
• EC_RTCORBA_Dispatching.cpp

---