32 #include <boost/shared_ptr.hpp> 34 #include <boost/thread/recursive_mutex.hpp> 36 #include <rsc/logging/Logger.h> 38 #include "../../Event.h" 39 #include "../../Scope.h" 41 #include "../../eventprocessing/Handler.h" 42 #include "../../eventprocessing/ScopeDispatcher.h" 44 #include "../AsioServiceContext.h" 49 #include "rsb/rsbexports.h" 67 bool tcpnodelay =
false);
70 virtual void addSink(InConnectorPtr sink);
90 virtual bool isTcpnodelay()
const;
97 virtual void printContents(std::ostream& stream)
const;
99 virtual const std::string getTransportURL()
const;
104 ConnectionList getConnections()
const;
105 boost::recursive_mutex& getConnectionLock();
AsioServiceContextPtr asioService
boost::shared_ptr< InConnector > InConnectorPtr
Instances of this class provide access to a socket-based bus.
eventprocessing::WeakScopeDispatcher< InConnector > SinkDispatcher
boost::shared_ptr< AsioServiceContext > AsioServiceContextPtr
boost::recursive_mutex connectorLock
Instances of this class receive events from a bus that is accessed via a socket connection.
ConnectionList connections
rsc::logging::LoggerPtr logger
boost::recursive_mutex connectionLock
boost::shared_ptr< BusConnection > BusConnectionPtr
SinkDispatcher sinkDispatcher
Instances of this class implement connections to a socket-based bus.
boost::shared_ptr< Event > EventPtr
std::list< BusConnectionPtr > ConnectionList