fesa-core
4.3.1
|
This is the complete list of members for fesa::OnSubscriptionEventSource, including all inherited members.
AbstractEventSource(const std::string &eventSourceName, EventSourceType type, const std::string &className, const boost::shared_ptr< Diagnostics > &diagnostics) | fesa::AbstractEventSource | protected |
addEvent(const boost::shared_ptr< fesa::EventElement > &eventElement, const boost::shared_ptr< LogicalEvent > &logicalEvent) | fesa::AbstractEventSource | protectedvirtual |
addEventProducer(MultiThreadedEventSourceProducer *producer) | fesa::MultiThreadedEventSource | |
AdjustProcessScheduling() | fesa::Thread | static |
current() | fesa::Thread | static |
disable() | fesa::MultiThreadedEventSource | virtual |
enable() | fesa::MultiThreadedEventSource | virtual |
firedEventCount_ | fesa::AbstractEventSource | mutableprotected |
getAffinity() const | fesa::Thread | |
getById(pthread_t id) | fesa::Thread | static |
getCurrentThreadName() | fesa::Thread | static |
getEvtSrcID() const | fesa::AbstractEventSource | |
getEvtSrcPriority() const | fesa::AbstractEventSource | |
getID() const | fesa::Thread | inline |
getName() const | fesa::AbstractEventSource | |
getPriority() const | fesa::Thread | inline |
getThreadName(pthread_t threadId) | fesa::Thread | static |
getThreads() | fesa::Thread | static |
getType() const | fesa::AbstractEventSource | |
hasFinished_ | fesa::Thread | protected |
HasMetrics(const std::string &componentName) | fesa::HasMetrics | |
isEnabled() const | fesa::AbstractEventSource | |
isRunning() const | fesa::Thread | inline |
isRunning_ | fesa::Thread | protected |
join(void **status) | fesa::Thread | |
joinHasFinished_ | fesa::Thread | protected |
MultiThreadedEventSource(std::size_t queueSize, const std::string &eventSourceName, const std::string &className, const boost::shared_ptr< Diagnostics > &diagnostics) | fesa::MultiThreadedEventSource | |
MultiThreadedEventSource(std::size_t queueSize, const std::string &eventSourceName, EventSourceType sourceType, const std::string &className, const boost::shared_ptr< Diagnostics > &diagnostics) | fesa::MultiThreadedEventSource | |
OnSubscriptionEventSource(std::size_t queueSize, const boost::shared_ptr< Diagnostics > &diagnostics) | fesa::OnSubscriptionEventSource | |
permanent_ | fesa::Thread | protected |
printConfig(FesaStream *fesaStream) const | fesa::AbstractEventSource | |
printState(std::ostream &stream, double elapsedTime) const | fesa::AbstractEventSource | |
registerMetric(const std::string &name, T &value) | fesa::HasMetrics | protected |
registerMetric(const std::string &name, boost::atomic< T > &value) | fesa::HasMetrics | protected |
registerThreadId(pthread_t threadId, Thread *thread) | fesa::Thread | static |
registerThreadIdName(pthread_t threadId, const std::string &threadName) | fesa::Thread | static |
run() | fesa::AbstractEventSource | protectedvirtual |
setAffinity(cpu_set_t affinity) | fesa::Thread | |
setDetachState(int32_t state) | fesa::Thread | inline |
setPriority(int32_t priority) | fesa::Thread | |
start(bool blockingMode, const std::string &threadName, bool permanent=true) | fesa::Thread | |
stop() | fesa::Thread | virtual |
Thread() | fesa::Thread | |
tid_ | fesa::Thread | protected |
~AbstractEventSource() | fesa::AbstractEventSource | virtual |
~Thread() | fesa::Thread | virtual |