RSB
0.7.0
|
#include <Bus.h>
Public Member Functions | |
Bus () | |
virtual | ~Bus () |
std::string | getClassName () const |
void | addSink (InConnectorPtr sink) |
void | removeSink (InConnector *sink) |
void | handle (EventPtr event) |
Handle event. | |
Public Member Functions inherited from rsb::eventprocessing::Handler | |
virtual | ~Handler () |
Private Types | |
typedef std::list < boost::weak_ptr< InConnector > > | SinkList |
typedef std::map< Scope, SinkList > | SinkMap |
Private Member Functions | |
void | handleNoLock (EventPtr event) |
Private Attributes | |
rsc::logging::LoggerPtr | logger |
SinkMap | sinks |
boost::recursive_mutex | mutex |
bool | singleThreaded |
|
private |
|
private |
|
virtual |
void rsb::inprocess::Bus::addSink | ( | InConnectorPtr | sink | ) |
|
virtual |
Handle event.
event | The event that should be handled. |
Implements rsb::eventprocessing::Handler.
Definition at line 140 of file Bus.cpp.
References handleNoLock(), mutex, and singleThreaded.
Referenced by rsb::inprocess::OutConnector::handle().
|
private |
void rsb::inprocess::Bus::removeSink | ( | InConnector * | sink | ) |
Definition at line 103 of file Bus.cpp.
References rsb::inprocess::InConnector::getScope(), logger, mutex, sinks, and rsb::Scope::superScopes().
|
private |
Definition at line 72 of file Bus.h.
Referenced by addSink(), handleNoLock(), removeSink(), and ~Bus().
|
private |
Definition at line 75 of file Bus.h.
Referenced by addSink(), handle(), and removeSink().
|
private |
|
private |
Definition at line 74 of file Bus.h.
Referenced by addSink(), handleNoLock(), removeSink(), and ~Bus().