, including all inherited members.
abort() | AcsBulkdata::StreamerThread | |
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] |
data_buffers | AcsBulkdata::StreamerThread | [private] |
defaultResponseTime | ACS::ThreadBase | [static] |
defaultSleepTime | ACS::ThreadBase | [static] |
DoneThread | ACS::ThreadBase | [static] |
exit() | ACS::ThreadBase | [inline, virtual] |
exitRequested() const | ACS::ThreadBase | [inline] |
getLogger() const | Logging::Loggable | [virtual] |
getName() const | ACS::ThreadBase | [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] |
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_abortReadySem | AcsBulkdata::StreamerThread | [private] |
m_accessMutex | AcsBulkdata::StreamerThread | [private] |
m_accessTimeout | AcsBulkdata::StreamerThread | [private, static] |
m_ACKTimeout | AcsBulkdata::StreamerThread | [private] |
m_data | AcsBulkdata::StreamerThread | [private] |
m_dataReadySem | AcsBulkdata::StreamerThread | [private] |
m_isAbort | AcsBulkdata::StreamerThread | [private] |
m_isThreadRunning | AcsBulkdata::StreamerThread | [private] |
m_qosLib | AcsBulkdata::StreamerThread | [private] |
m_senderStream | AcsBulkdata::StreamerThread | [private] |
m_sendFlow | AcsBulkdata::StreamerThread | [private] |
m_sendFlowName | AcsBulkdata::StreamerThread | [private] |
m_sendTimeout | AcsBulkdata::StreamerThread | [private] |
m_streamName | AcsBulkdata::StreamerThread | [private] |
m_throttling | AcsBulkdata::StreamerThread | [private] |
makeTimeInterval() | ACS::ThreadBase | |
NullThreadBase | ACS::ThreadBase | [static] |
onStart() | ACS::Thread | [inline, virtual] |
onStop() | ACS::Thread | [inline, virtual] |
operator=(const StreamerThread &src) | AcsBulkdata::StreamerThread | [private] |
restart() | ACS::ThreadBase | |
resume() | ACS::ThreadBase | [virtual] |
run() | AcsBulkdata::StreamerThread | [virtual] |
runLoop() | ACS::Thread | [inline, virtual] |
send(uint8_t *data, size_t size) | AcsBulkdata::StreamerThread | |
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 | |
stop(bool terminating=false) | ACS::ThreadBase | |
StreamerThread(const char *threadName, const std::string &streamName, const std::string &sendFlowName, const std::string &qosLib, const double &throttling, const double &sendTimeout, const double &ACKTimeout) | AcsBulkdata::StreamerThread | |
StreamerThread(const StreamerThread &src) | AcsBulkdata::StreamerThread | [private] |
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] |
wait(const char *uid, const ACS::TimeInterval timeout) | AcsBulkdata::StreamerThread | [inline] |
yield() | ACS::ThreadBase | [protected, virtual] |
~Loggable() | Logging::Loggable | [virtual] |
~StreamerThread() | AcsBulkdata::StreamerThread | |
~Thread() | ACS::Thread | [virtual] |
~ThreadBase() | ACS::ThreadBase | [virtual] |