TwiceAsNice  2019-02-18
Classes | Public Member Functions | Private Attributes | List of all members
Tux::BigDataServiceWorker Class Reference

#include <TuxBigDataWorker.h>

Inheritance diagram for Tux::BigDataServiceWorker:
Inheritance graph
Collaboration diagram for Tux::BigDataServiceWorker:
Collaboration graph

Classes

struct  DeviceAsyncImpl
 

Public Member Functions

 BigDataServiceWorker (const Nice::JointPtr &_config)
 
virtual ~BigDataServiceWorker ()
 
virtual void init ()
 
virtual void deinit ()
 
virtual void activate ()
 
virtual void deactivate ()
 
virtual void terminate ()
 schedule EXIT as the next target state. More...
 
virtual void stop ()
 does nothing. More...
 
virtual void abort ()
 does nothing. More...
 
virtual int positionInSteps ()
 
virtual void moveBy (int _n_steps)
 
virtual Nice::SeqInt getBigData (int _n_elements)
 
 BigDataServiceWorker (const Nice::JointPtr &_config)
 
virtual ~BigDataServiceWorker ()
 
virtual void init ()
 
virtual void deinit ()
 
virtual void activate ()
 
virtual void deactivate ()
 
virtual void terminate ()
 schedule EXIT as the next target state. More...
 
virtual void stop ()
 does nothing. More...
 
virtual void abort ()
 does nothing. More...
 
virtual int positionInSteps ()
 
virtual void moveBy (int _n_steps)
 
virtual Nice::SeqInt getBigData (int _n_elements)
 
- Public Member Functions inherited from Tux::BigDataServiceWorkerSkeleton
 BigDataServiceWorkerSkeleton (const Nice::JointPtr &_config)
 
virtual ~BigDataServiceWorkerSkeleton ()
 
- Public Member Functions inherited from Basda::ServiceWorkerSkeleton
const Nice::PropertyPtrcmd ()
 
void setCompletion (const Nice::Completion &_c)
 
void cmdStart (const std::string &_action="")
 
void cmdDone ()
 
void cmdWarning (const std::string &_l)
 
void cmdWarning (const Nice::LoggerObject &_o)
 
void cmdError (const std::string &_l)
 
void cmdError (const Nice::LoggerObject &_o)
 
void cmdError (const Nice::SeqLoggerObject &_oo)
 
void cmdPercent (Nice::Int _v)
 
void cmdAction (Nice::Int _v, const std::string &_s)
 
virtual void cmd (const Nice::Completion &_c)
 
template<typename DataType >
Nice::Completion exec (const Nice::Completion &_c, DataType &_localdata, const DataType &_indata=DataType())
 if currently online, push the state into WORKING More...
 
template<typename DataType >
void execCommand (DataType _cmd)
 
const Nice::PropertyPtrcmd ()
 
void setCompletion (const Nice::Completion &_c)
 
void cmdStart (const std::string &_action="")
 
void cmdDone ()
 
void cmdWarning (const std::string &_l)
 
void cmdWarning (const Nice::LoggerObject &_o)
 
void cmdError (const std::string &_l)
 
void cmdError (const Nice::LoggerObject &_o)
 
void cmdError (const Nice::SeqLoggerObject &_oo)
 
void cmdPercent (Nice::Int _v)
 
void cmdAction (Nice::Int _v, const std::string &_s)
 
virtual void cmd (const Nice::Completion &_c)
 
template<typename DataType >
Nice::Completion exec (const Nice::Completion &_c, DataType &_localdata, const DataType &_indata=DataType())
 
template<typename DataType >
void execCommand (DataType _cmd)
 
- Public Member Functions inherited from Basda::ServiceWorker
const Nice::JointPtrconfig ()
 
Nice::JointPtr cfg ()
 
Nice::JointPtr var ()
 
virtual const std::string & name ()
 
virtual WorkerThreadPtr worker ()
 
virtual Nice::Monitormonitor ()
 
virtual void lock ()
 
virtual void unlock ()
 
bool stateIsSettled ()
 
bool stateHasChanged ()
 
void changeState (Basda::ServiceState _state)
 change state to a new state If the state is the current state, or a negative state, do nothing. Otherwise change the "next" state in the state machine and notify all threads. More...
 
bool tryChangeState (Basda::ServiceState _state, const Nice::Time &_timeout=Nice::Time::seconds(0.0))
 change state to a new state More...
 
void waitForState (Basda::ServiceState _state)
 wait (indefinitely) until the worker has reached a spcifici state More...
 
bool timedWaitForState (Basda::ServiceState _state, const Nice::Time &_timeout)
 wait (indefinitely) until the worker has reached a specific state More...
 
bool changeStateOnlyFromTo (Basda::ServiceState _from, Basda::ServiceState _to)
 wait (indefinitely) until the worker has reached a spcifici state More...
 
Basda::ServiceState state ()
 
Basda::ServiceState stateNow ()
 
Basda::ServiceState stateNext ()
 
Basda::ServiceState stateLast ()
 
bool isTransit ()
 
bool isTerminated ()
 
const Nice::JointPtrconfig ()
 
Nice::JointPtr cfg ()
 
Nice::JointPtr var ()
 
virtual const std::string & name ()
 
virtual WorkerThreadPtr worker ()
 
virtual Nice::Monitormonitor ()
 
virtual void lock ()
 
virtual void unlock ()
 
bool stateIsSettled ()
 
bool stateHasChanged ()
 
void changeState (Basda::ServiceState _state)
 
bool tryChangeState (Basda::ServiceState _state, const Nice::Time &_timeout=Nice::Time::seconds(0.0))
 
void waitForState (Basda::ServiceState _state)
 
bool timedWaitForState (Basda::ServiceState _state, const Nice::Time &_timeout)
 
bool changeStateOnlyFromTo (Basda::ServiceState _from, Basda::ServiceState _to)
 
Basda::ServiceState state ()
 
Basda::ServiceState stateNow ()
 
Basda::ServiceState stateNext ()
 
Basda::ServiceState stateLast ()
 
bool isTransit ()
 
bool isTerminated ()
 

Private Attributes

DeviceAsyncImpl m_deviceAsync
 
Nice::Mutex m_mutex
 

Additional Inherited Members

- Protected Types inherited from Basda::ServiceWorker
typedef void(ServiceWorker::* ServiceWorkerMemFn) ()
 
typedef Branch BranchTable[6][6]
 
typedef IceUtil::Handle< WorkerThreadWorkerThreadPtr
 
typedef void(ServiceWorker::* ServiceWorkerMemFn) ()
 
typedef Branch BranchTable[6][6]
 
typedef IceUtil::Handle< WorkerThreadWorkerThreadPtr
 
- Protected Member Functions inherited from Tux::BigDataServiceWorkerSkeleton
const char * positionInStepsNode ()
 
const char * moveByNode ()
 
void moveByInit (int _n_steps)
 
const char * getBigDataNode ()
 
void getBigDataInit (int _n_elements)
 
virtual void work ()
 
- Protected Member Functions inherited from Basda::ServiceWorkerSkeleton
 ServiceWorkerSkeleton (const Nice::JointPtr &_config)
 
 ServiceWorkerSkeleton (const Nice::JointPtr &_config)
 
- Protected Member Functions inherited from Basda::ServiceWorker
 ServiceWorker (const Nice::JointPtr &_jointPtr)
 ctor More...
 
virtual ~ServiceWorker ()
 dtor Does nothing (in this base class) More...
 
void triggerState (const Basda::ServiceStateMachine &_state)
 change state to a new state More...
 
void sendStateStatus (const std::string &_action, int _percent)
 
void setState (Basda::ServiceState _next)
 
virtual void waitForNewState ()
 
virtual bool timedWaitForNewState (const Nice::Time &_timeout)
 
virtual void preinit ()
 
virtual void packin ()
 schedule ONLINE as the next target state. More...
 
virtual void errorOffline ()
 set the target state to OFFLINE. More...
 
virtual void errorStandby ()
 set the target state to OFFLINE. More...
 
virtual void errorOnline ()
 set the target state to OFFLINE. More...
 
virtual void errorWorking ()
 set the target state to OFFLINE. More...
 
virtual void idleOffline ()
 wait for a state change. More...
 
virtual void idleStandby ()
 wait for a state change. More...
 
virtual void idleOnline ()
 wait for a state change. More...
 
 ServiceWorker (const Nice::JointPtr &_jointPtr)
 
virtual ~ServiceWorker ()
 
void triggerState (const Basda::ServiceStateMachine &_state)
 
void sendStateStatus (const std::string &_action, int _percent)
 
void setState (Basda::ServiceState _next)
 
virtual void waitForNewState ()
 
virtual bool timedWaitForNewState (const Nice::Time &_timeout)
 
virtual void preinit ()
 
virtual void packin ()
 
virtual void errorOffline ()
 
virtual void errorStandby ()
 
virtual void errorOnline ()
 
virtual void errorWorking ()
 
virtual void idleOffline ()
 
virtual void idleStandby ()
 
virtual void idleOnline ()
 
- Protected Attributes inherited from Basda::ServiceWorkerSkeleton
Nice::Completion m_completion
 
Nice::I64 m_id
 
Nice::PropertyPtr m_cmd
 
- Protected Attributes inherited from Basda::ServiceWorker
Nice::JointPtr m_config
 
Nice::PropertyPtr m_state
 
std::string m_name
 
- Static Protected Attributes inherited from Basda::ServiceWorker
static BranchTable s_stateTable
 A table which tells which state should go via which intermediate state to a target state. The 6 states are SHUTDOWN, OFFLINE, STANDBY, ONLINE, WORKING and ERROR. The principles are that. More...
 

Constructor & Destructor Documentation

◆ BigDataServiceWorker() [1/2]

Tux::BigDataServiceWorker::BigDataServiceWorker ( const Nice::JointPtr _config)

◆ ~BigDataServiceWorker() [1/2]

Tux::BigDataServiceWorker::~BigDataServiceWorker ( )
virtual

◆ BigDataServiceWorker() [2/2]

Tux::BigDataServiceWorker::BigDataServiceWorker ( const Nice::JointPtr _config)

◆ ~BigDataServiceWorker() [2/2]

virtual Tux::BigDataServiceWorker::~BigDataServiceWorker ( )
virtual

Member Function Documentation

◆ abort() [1/2]

void Tux::BigDataServiceWorker::abort ( void  )
virtual

does nothing.


Reimplemented from Basda::ServiceWorkerSkeleton.

◆ abort() [2/2]

virtual void Tux::BigDataServiceWorker::abort ( void  )
virtual

does nothing.


Reimplemented from Basda::ServiceWorkerSkeleton.

◆ activate() [1/2]

void Tux::BigDataServiceWorker::activate ( )
virtual

Implements Basda::ServiceWorker.

◆ activate() [2/2]

virtual void Tux::BigDataServiceWorker::activate ( )
virtual

Implements Basda::ServiceWorker.

◆ deactivate() [1/2]

void Tux::BigDataServiceWorker::deactivate ( )
virtual

Implements Basda::ServiceWorker.

◆ deactivate() [2/2]

virtual void Tux::BigDataServiceWorker::deactivate ( )
virtual

Implements Basda::ServiceWorker.

◆ deinit() [1/2]

virtual void Tux::BigDataServiceWorker::deinit ( )
virtual

Implements Basda::ServiceWorker.

◆ deinit() [2/2]

void Tux::BigDataServiceWorker::deinit ( )
virtual

Implements Basda::ServiceWorker.

◆ getBigData() [1/2]

Nice::SeqInt Tux::BigDataServiceWorker::getBigData ( int  _n_elements)
virtual

◆ getBigData() [2/2]

virtual Nice::SeqInt Tux::BigDataServiceWorker::getBigData ( int  _n_elements)
virtual

◆ init() [1/2]

void Tux::BigDataServiceWorker::init ( )
virtual

Implements Basda::ServiceWorker.

◆ init() [2/2]

virtual void Tux::BigDataServiceWorker::init ( )
virtual

Implements Basda::ServiceWorker.

◆ moveBy() [1/2]

void Tux::BigDataServiceWorker::moveBy ( int  _n_steps)
virtual

◆ moveBy() [2/2]

virtual void Tux::BigDataServiceWorker::moveBy ( int  _n_steps)
virtual

◆ positionInSteps() [1/2]

int Tux::BigDataServiceWorker::positionInSteps ( )
virtual

◆ positionInSteps() [2/2]

virtual int Tux::BigDataServiceWorker::positionInSteps ( )
virtual

◆ stop() [1/2]

virtual void Tux::BigDataServiceWorker::stop ( )
virtual

does nothing.


Reimplemented from Basda::ServiceWorkerSkeleton.

◆ stop() [2/2]

void Tux::BigDataServiceWorker::stop ( )
virtual

does nothing.


Reimplemented from Basda::ServiceWorkerSkeleton.

◆ terminate() [1/2]

virtual void Tux::BigDataServiceWorker::terminate ( )
virtual

schedule EXIT as the next target state.


Reimplemented from Basda::ServiceWorker.

◆ terminate() [2/2]

void Tux::BigDataServiceWorker::terminate ( )
virtual

schedule EXIT as the next target state.


Reimplemented from Basda::ServiceWorker.

Member Data Documentation

◆ m_deviceAsync

DeviceAsyncImpl Tux::BigDataServiceWorker::m_deviceAsync
private

◆ m_mutex

Nice::Mutex Tux::BigDataServiceWorker::m_mutex
private

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