33 #include <boost/shared_ptr.hpp> 35 #include <boost/thread/recursive_mutex.hpp> 37 #include <rsc/logging/Logger.h> 39 #include "../../Event.h" 40 #include "../../Scope.h" 42 #include "../../eventprocessing/Handler.h" 44 #include "../../protocol/Notification.h" 46 #include "../AsioServiceContext.h" 49 #include "rsb/rsbexports.h" 79 bool tcpnodelay =
false);
82 virtual void addSink(InConnectorPtr sink);
102 virtual bool isTcpnodelay()
const;
104 virtual void handle(
EventPtr event);
108 virtual void printContents(std::ostream& stream)
const;
110 virtual const std::string getTransportURL()
const;
115 ConnectionList getConnections()
const;
116 boost::recursive_mutex& getConnectionLock();
118 virtual void handleIncoming(
EventPtr event,
122 typedef std::list<boost::weak_ptr<InConnector> >
SinkList;
rsc::logging::LoggerPtr logger
ConnectionList connections
boost::shared_ptr< InConnector > InConnectorPtr
Instances of this class provide access to a socket-based bus.
boost::shared_ptr< AsioServiceContext > AsioServiceContextPtr
boost::shared_ptr< BusConnection > BusConnectionPtr
std::list< boost::weak_ptr< InConnector > > SinkList
Instances of this class receive events from a bus that is accessed via a socket connection.
This class is intended to be used as a base class for connector classes of the socket-based transport...
AsioServiceContextPtr asioService
std::map< Scope, SinkList > SinkMap
Instances of this class implement connections to a socket-based bus.
boost::recursive_mutex connectorLock
boost::recursive_mutex connectionLock
Implementations of this class can be used in contexts where an "event sink" is required.
boost::shared_ptr< Event > EventPtr
std::list< BusConnectionPtr > ConnectionList