, including all inherited members.
abort(const std::string &reason) | AcsBulkdata::BulkDataNTArrayThread | [private] |
addDataEvent(const uint8_t *buffer, const size_t size) | AcsBulkdata::BulkDataNTArrayThread | |
BulkDataNTArrayThread(const ACE_CString &name, const std::string &streamName, const std::string &sendFlowName, const std::string &qosLib, const double &throttling, const double &sendTimeout, const double &ACKTimeout) | AcsBulkdata::BulkDataNTArrayThread | |
BulkDataNTArrayThread(const BulkDataNTArrayThread &toCopy) | AcsBulkdata::BulkDataNTArrayThread | [private] |
cancel() | ACS::ThreadBase | |
check() | ACS::ThreadBase | |
commonStart() | ACS::Thread | [virtual] |
commonStop() | ACS::Thread | [virtual] |
create(const long _thrFlags=THR_NEW_LWP|THR_DETACHED) | ACS::ThreadBase | [protected] |
defaultResponseTime | ACS::ThreadBase | [static] |
defaultSleepTime | ACS::ThreadBase | [static] |
deleteFrontEndBuffer(const ACS::TimeInterval _to, std::list< std::pair< uint8_t *, size_t > > &out) | AcsBulkdata::BulkDataNTArrayThread | [private] |
DoneThread | ACS::ThreadBase | [static] |
exit() | AcsBulkdata::BulkDataNTArrayThread | [inline, private, virtual] |
exitRequested() const | ACS::ThreadBase | [inline] |
getLogger() const | Logging::Loggable | [virtual] |
getName() const | AcsBulkdata::BulkDataNTArrayThread | [inline] |
getPriority() | ACS::ThreadBase | |
getResponseTime() const | ACS::ThreadBase | [inline] |
getSleepTime() const | ACS::ThreadBase | [inline] |
getThreadID() | ACS::ThreadBase | [inline] |
getThreadManager() const | ACS::Thread | [protected] |
getThreadProcedure() const | ACS::ThreadBase | [inline] |
handleSequenceLoop() | AcsBulkdata::BulkDataNTArrayThread | [private] |
InitThread | ACS::ThreadBase | [static] |
isAlive() const | ACS::ThreadBase | [inline] |
isResponding() const | ACS::ThreadBase | |
isStopped() const | ACS::ThreadBase | [inline] |
isSuspended() const | ACS::ThreadBase | [inline] |
Loggable() | Logging::Loggable | |
Loggable(const std::string &loggerName) | Logging::Loggable | |
Loggable(Logger::LoggerSmartPtr logger) | Logging::Loggable | |
logger_mp | ACS::Thread | [protected] |
m_accessMutex | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_accessTimeout | AcsBulkdata::BulkDataNTArrayThread | [private, static] |
m_ACKTimeout | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_addDataEventLogFlag | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_condition | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_eventListMutex | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_frontEndBuffer | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_newDataCondition | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_qosLib | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_sendFlowName | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_sendTimeout | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_sequenceStopFlag | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_stopCondition | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_Streamer | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_streamName | AcsBulkdata::BulkDataNTArrayThread | [private] |
m_throttling | AcsBulkdata::BulkDataNTArrayThread | [private] |
makeTimeInterval() | ACS::ThreadBase | |
name | AcsBulkdata::BulkDataNTArrayThread | [private] |
NullThreadBase | ACS::ThreadBase | [static] |
onStart() | ACS::Thread | [inline, virtual] |
onStop() | ACS::Thread | [inline, virtual] |
operator=(const BulkDataNTArrayThread &) | AcsBulkdata::BulkDataNTArrayThread | [private] |
relyDataToStreamer(std::list< std::pair< uint8_t *, size_t > > &data) | AcsBulkdata::BulkDataNTArrayThread | [private] |
restart() | ACS::ThreadBase | |
resume() | ACS::ThreadBase | [virtual] |
run() | AcsBulkdata::BulkDataNTArrayThread | [virtual] |
runLoop() | ACS::Thread | [inline, virtual] |
sequenceAlreadyRunningFlag | AcsBulkdata::BulkDataNTArrayThread | [private] |
SequenceEndStatus enum name | AcsBulkdata::BulkDataNTArrayThread | [private] |
SequenceEndStatus_EXCEPTION enum value | AcsBulkdata::BulkDataNTArrayThread | [private] |
SequenceEndStatus_OK enum value | AcsBulkdata::BulkDataNTArrayThread | [private] |
SequenceEndStatus_STOPPED enum value | AcsBulkdata::BulkDataNTArrayThread | [private] |
SequenceEndStatus_TIMEOUT enum value | AcsBulkdata::BulkDataNTArrayThread | [private] |
setInitializers(InitThreadFunc InitThread_, DoneThreadFunc DoneThread_) | ACS::ThreadBase | [inline, static] |
setLogger(Logger::LoggerSmartPtr logger) | Logging::Loggable | [inline, virtual] |
setPriority(int _priority) | ACS::ThreadBase | |
setResponseTime(const TimeInterval &_responseTime) | ACS::ThreadBase | [inline] |
setSleepTime(const TimeInterval &_sleepTime) | ACS::ThreadBase | [inline] |
setStopped() | ACS::ThreadBase | [inline] |
sleep(TimeInterval timeIn100ns=0) const | ACS::ThreadBase | |
SLEEP_ERROR enum value | ACS::ThreadBase | |
SLEEP_INTERRUPTED enum value | ACS::ThreadBase | |
SLEEP_OK enum value | ACS::ThreadBase | |
SLEEP_SUSPEND enum value | ACS::ThreadBase | |
SleepReturn enum name | ACS::ThreadBase | |
startSequence() | AcsBulkdata::BulkDataNTArrayThread | |
stop(bool terminating=false) | ACS::ThreadBase | |
stopSequence() | AcsBulkdata::BulkDataNTArrayThread | |
suspend() | ACS::ThreadBase | |
terminate() | ACS::ThreadBase | |
Thread(const ACE_CString &name, const TimeInterval &responseTime=ThreadBase::defaultResponseTime, const TimeInterval &sleepTime=ThreadBase::defaultSleepTime, const bool del=false, const long _thrFlags=THR_NEW_LWP|THR_DETACHED, const size_t stackSize=ACE_DEFAULT_THREAD_STACKSIZE) | ACS::Thread | |
ThreadBase(const ACE_CString &_name, ACE_Thread_Manager *_threadManager, void *_threadProcedure, void *_parameter, const TimeInterval &_responseTime=ThreadBase::defaultResponseTime, const TimeInterval &_sleepTime=ThreadBase::defaultSleepTime, const bool _create=true, const long _thrFlags=THR_NEW_LWP|THR_DETACHED, const size_t _stackSize=ACE_DEFAULT_THREAD_STACKSIZE) | ACS::ThreadBase | |
threadSvc(void *param) | ACS::Thread | [protected, static] |
thrMgr_mp | ACS::Thread | [protected] |
waitForDataEvent(const ACS::TimeInterval to, std::list< std::pair< uint8_t *, size_t > > &out) | AcsBulkdata::BulkDataNTArrayThread | [private] |
yield() | ACS::ThreadBase | [protected, virtual] |
~BulkDataNTArrayThread() | AcsBulkdata::BulkDataNTArrayThread | |
~Loggable() | Logging::Loggable | [virtual] |
~Thread() | ACS::Thread | [virtual] |
~ThreadBase() | ACS::ThreadBase | [virtual] |