31 using namespace rsc::logging;
39 Logger::getLogger(
"rsb.transport.socket.LifecycledBusServer")), server(
44 RSCDEBUG(
logger,
"Destructing");
48 this->
server->deactivate();
52 this->
server->addSink(sink);
56 this->
server->removeSink(sink);
60 this->
server->addConnection(connection);
64 this->
server->removeConnection(connection);
68 return this->
server->isTcpnodelay();
72 this->
server->handle(event);
76 return server->getService();
80 RSCDEBUG(
logger,
"Activating");
85 RSCDEBUG(
logger,
"Deactivating");
86 this->
server->deactivate();
91 this->
server->handleIncoming(event, connection);
virtual bool isTcpnodelay() const
virtual AsioServiceContextPtr getService() const
boost::shared_ptr< InConnector > InConnectorPtr
void handleIncoming(EventPtr event, BusConnectionPtr connection)
Instances of this class provide access to a socket-based bus.
rsc::logging::LoggerPtr logger
boost::shared_ptr< AsioServiceContext > AsioServiceContextPtr
boost::shared_ptr< BusConnection > BusConnectionPtr
Instances of this class receive events from a bus that is accessed via a socket connection.
boost::shared_ptr< BusServer > BusServerPtr
virtual ~LifecycledBusServer()
Instances of this class provide access to a socket-based bus for local and remote bus clients...
virtual void addConnection(BusConnectionPtr connection)
Adds connection to the list of connections of the bus.
virtual void removeConnection(BusConnectionPtr connection)
Removes connection from the list of connections of this bus.
virtual void addSink(InConnectorPtr sink)
virtual void handle(EventPtr event)
Handle event.
virtual void printContents(std::ostream &stream) const
virtual void removeSink(InConnector *sink)
boost::shared_ptr< Event > EventPtr