AceSmartSoft API Documentation
Public Member Functions | Protected Member Functions | Protected Attributes | List of all members
SmartACE::ReactorTask Class Reference

#include <smartReactorTask.hh>

Inheritance diagram for SmartACE::ReactorTask:
SmartACE::Task

Public Member Functions

 ReactorTask (Smart::IComponent *component)
 
virtual ~ReactorTask ()
 
virtual void activateCustomEventsMode (const ACE_Time_Value &idleTime=ACE_Time_Value::zero)
 
virtual void deactivateCustomEventsMode ()
 
void initReactor (size_t max_number_of_handles=ACE::max_handles())
 
void finiReactor ()
 
int startReactor ()
 
int startReactor (const ACE_Sched_Params &sched_params, const int &cpuAffinity=-1)
 
bool isReactorRunning () const
 
int stopReactor (const bool &waitForCompletion=true)
 
ACE_Reactor * getImpl ()
 
ACE_thread_t getReactorOwnerThread () const
 
- Public Member Functions inherited from SmartACE::Task
 Task (Smart::IComponent *component=0)
 Constructor. More...
 
virtual ~Task ()
 Destructor. More...
 
virtual int start ()
 Creates and starts a new thread (if not yet started) More...
 
virtual int start (const ACE_Sched_Params &sched_params, const int &cpuAffinity=-1)
 control method to start the internal thread using given scheduling parameters More...
 
virtual int stop (const bool wait_till_stopped=true)
 Closes currently active thread (if it was started before) More...
 

Protected Member Functions

int task_execution ()
 
virtual int customEventsCallback ()
 
virtual void on_shutdown ()
 
- Protected Member Functions inherited from SmartACE::Task
virtual bool test_canceled ()
 Tests whether the thread has been signaled to stop. More...
 
virtual void sleep_for (const Smart::Duration &rel_time)
 Blocks execution of the calling thread during the span of time specified by rel_time. More...
 
virtual int svc (void)
 implements ACE_Task<ACE_MT_SYNCH> More...
 
int setCpuAffinity (const int &cpuCore)
 
int setSchedParams (const ACE_Sched_Params &sched_params)
 

Protected Attributes

ACE_Thread_Mutex mutex
 
ACE_Reactor reactor
 
bool useCustomEventsMode
 
ACE_Time_Value reactorIdleTime
 

Constructor & Destructor Documentation

◆ ReactorTask()

SmartACE::ReactorTask::ReactorTask ( Smart::IComponent *  component)

◆ ~ReactorTask()

virtual SmartACE::ReactorTask::~ReactorTask ( )
virtual

Member Function Documentation

◆ activateCustomEventsMode()

virtual void SmartACE::ReactorTask::activateCustomEventsMode ( const ACE_Time_Value &  idleTime = ACE_Time_Value::zero)
virtual

◆ customEventsCallback()

virtual int SmartACE::ReactorTask::customEventsCallback ( )
protectedvirtual

◆ deactivateCustomEventsMode()

virtual void SmartACE::ReactorTask::deactivateCustomEventsMode ( )
virtual

◆ finiReactor()

void SmartACE::ReactorTask::finiReactor ( )

◆ getImpl()

ACE_Reactor* SmartACE::ReactorTask::getImpl ( )
inline

◆ getReactorOwnerThread()

ACE_thread_t SmartACE::ReactorTask::getReactorOwnerThread ( ) const

◆ initReactor()

void SmartACE::ReactorTask::initReactor ( size_t  max_number_of_handles = ACE::max_handles())

◆ isReactorRunning()

bool SmartACE::ReactorTask::isReactorRunning ( ) const

◆ on_shutdown()

virtual void SmartACE::ReactorTask::on_shutdown ( )
protectedvirtual

◆ startReactor() [1/2]

int SmartACE::ReactorTask::startReactor ( )

◆ startReactor() [2/2]

int SmartACE::ReactorTask::startReactor ( const ACE_Sched_Params &  sched_params,
const int &  cpuAffinity = -1 
)

◆ stopReactor()

int SmartACE::ReactorTask::stopReactor ( const bool &  waitForCompletion = true)

◆ task_execution()

int SmartACE::ReactorTask::task_execution ( )
protected

Member Data Documentation

◆ mutex

ACE_Thread_Mutex SmartACE::ReactorTask::mutex
mutableprotected

◆ reactor

ACE_Reactor SmartACE::ReactorTask::reactor
protected

◆ reactorIdleTime

ACE_Time_Value SmartACE::ReactorTask::reactorIdleTime
protected

◆ useCustomEventsMode

bool SmartACE::ReactorTask::useCustomEventsMode
protected

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