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);
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;
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