fesa-core  4.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::AbstractEventSourceprotected
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
getType() 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
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)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
Thread()fesa::Thread
tid_fesa::Threadprotected
~AbstractEventSource()fesa::AbstractEventSourcevirtual
~Thread()fesa::Threadvirtual