fesa-core  7.0.0
fesa::OnSubscriptionEventSource Member List

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::AbstractEventSourceprotected
addEvent(const boost::shared_ptr< fesa::EventElement > &eventElement, const boost::shared_ptr< LogicalEvent > &logicalEvent)fesa::AbstractEventSourceprotectedvirtual
addEventProducer(MultiThreadedEventSourceProducer *producer)fesa::MultiThreadedEventSource
AdjustProcessScheduling()fesa::Threadstatic
current()fesa::Threadstatic
disable()fesa::MultiThreadedEventSourcevirtual
enable()fesa::MultiThreadedEventSourcevirtual
firedEventCount_fesa::AbstractEventSourcemutableprotected
getAffinity() const fesa::Thread
getById(pthread_t id)fesa::Threadstatic
getCurrentThreadName()fesa::Threadstatic
getEvtSrcID() const fesa::AbstractEventSource
getEvtSrcPriority() const fesa::AbstractEventSource
getID() const fesa::Threadinline
getName() const fesa::AbstractEventSource
getPriority() const fesa::Threadinline
getThreadName(pthread_t threadId)fesa::Threadstatic
getThreads()fesa::Threadstatic
getThreadType() const fesa::Thread
getType() const fesa::AbstractEventSource
hasConcreteEvent(const std::string &eventName) const fesa::AbstractEventSource
hasFinished_fesa::Threadprotected
HasMetrics(const std::string &componentName)fesa::HasMetrics
isEnabled() const fesa::AbstractEventSource
isRunning() const fesa::Threadinline
isRunning_fesa::Threadprotected
join(void **status)fesa::Thread
joinHasFinished_fesa::Threadprotected
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::Threadprotected
printConfig(FesaStream &fesaStream) const fesa::AbstractEventSource
printState(std::ostream &stream, double elapsedTime) const fesa::AbstractEventSource
registerMetric(const std::string &name, T &value)fesa::HasMetricsprotected
registerMetric(const std::string &name, boost::atomic< T > &value)fesa::HasMetricsprotected
registerThreadId(pthread_t threadId, Thread *thread)fesa::Threadstatic
registerThreadIdName(pthread_t threadId, const std::string &threadName)fesa::Threadstatic
run()fesa::AbstractEventSourceprotectedvirtual
setAffinity(cpu_set_t affinity)fesa::Thread
setDetachState(int32_t state)fesa::Threadinline
setPriority(int32_t priority)fesa::Thread
start(bool blockingMode, const std::string &threadName, bool permanent=true)fesa::Thread
stop()fesa::Threadvirtual
tid_fesa::Threadprotected
~AbstractEventSource()fesa::AbstractEventSourcevirtual
~Thread()fesa::Threadvirtual