The singleton instance of this class is responsible for managing bus provider objects. More...

#include <Factory.h>

Collaboration diagram for rsb::transport::socket::Factory:

Public Member Functions
	~Factory ()
BusPtr	getBus (const Server &serverMode, const std::string &host, const boost::uint16_t &port, bool tcpnodelay, ConnectorBase *connector)
	Returns either a BusClient or Server depending on the chosen serverMode and the existence of a server in the current process.

Private Types
typedef std::pair< std::string, boost::uint16_t >	Endpoint
typedef boost::shared_ptr < boost::asio::ip::tcp::socket >	SocketPtr
typedef boost::shared_ptr < boost::asio::io_service::work >	WorkPtr
typedef std::map< Endpoint, BusPtr >	BusClientMap
typedef std::map< Endpoint, BusServerPtr >	BusServerMap

Private Member Functions
	Factory ()
BusPtr	getBusClientFor (const std::string &host, boost::uint16_t port, bool tcpnodelay, ConnectorBase *connector)
BusServerPtr	getBusServerFor (const std::string &host, boost::uint16_t port, bool tcpnodelay, ConnectorBase *connector)
void	removeBusClient (BusPtr bus)
void	removeBusServer (BusPtr bus)

Static Private Member Functions
static void	checkOptions (BusPtr bus, bool tcpnodelay)

Private Attributes
rsc::logging::LoggerPtr	logger
BusClientMap	busClients
BusServerMap	busServers
boost::mutex	busMutex
boost::asio::io_service	service
WorkPtr	keepAlive
boost::thread	thread

Friends
class	rsc::patterns::Singleton< Factory >
class	Bus
class	BusServer

Detailed Description

The singleton instance of this class is responsible for managing bus provider objects.

For each endpoint (i.e. address and port), at most one client or server bus provider can exist.

Attention: This class is not thread safe and needs to be accessed in a synchronized manner, except for getBus.

Author: jmoringe

Definition at line 59 of file Factory.h.

Member Typedef Documentation

typedef std::map<Endpoint, BusPtr> rsb::transport::socket::Factory::BusClientMap

private

Definition at line 82 of file Factory.h.

typedef std::map<Endpoint, BusServerPtr> rsb::transport::socket::Factory::BusServerMap

private

Definition at line 83 of file Factory.h.

typedef std::pair<std::string, boost::uint16_t> rsb::transport::socket::Factory::Endpoint

private

Definition at line 77 of file Factory.h.

typedef boost::shared_ptr<boost::asio::ip::tcp::socket> rsb::transport::socket::Factory::SocketPtr

private

Definition at line 78 of file Factory.h.

typedef boost::shared_ptr<boost::asio::io_service::work> rsb::transport::socket::Factory::WorkPtr

private

Definition at line 80 of file Factory.h.

Constructor & Destructor Documentation

rsb::transport::socket::Factory::~Factory ( )

Definition at line 57 of file Factory.cpp.

References busClients, keepAlive, logger, and thread.

rsb::transport::socket::Factory::Factory ( )

private

Definition at line 50 of file Factory.cpp.

References logger.

Member Function Documentation

void rsb::transport::socket::Factory::checkOptions	(	BusPtr	bus,
		bool	tcpnodelay
	)

staticprivate

Definition at line 249 of file Factory.cpp.

Referenced by getBusClientFor(), and getBusServerFor().

Here is the caller graph for this function:

BusPtr rsb::transport::socket::Factory::getBus	(	const Server &	serverMode,
		const std::string &	host,
		const boost::uint16_t &	port,
		bool	tcpnodelay,
		ConnectorBase *	connector
	)

Returns either a BusClient or Server depending on the chosen serverMode and the existence of a server in the current process.

Definition at line 221 of file Factory.cpp.

References busMutex, getBusClientFor(), getBusServerFor(), logger, rsb::transport::socket::SERVER_AUTO, rsb::transport::socket::SERVER_NO, and rsb::transport::socket::SERVER_YES.

Referenced by rsb::transport::socket::ConnectorBase::activate().

Here is the call graph for this function:

Here is the caller graph for this function:

BusPtr rsb::transport::socket::Factory::getBusClientFor	(	const std::string &	host,
		boost::uint16_t	port,
		bool	tcpnodelay,
		ConnectorBase *	connector
	)

private

Definition at line 68 of file Factory.cpp.

References Bus, busClients, checkOptions(), logger, and service.

Referenced by getBus().

Here is the call graph for this function:

Here is the caller graph for this function:

BusServerPtr rsb::transport::socket::Factory::getBusServerFor	(	const std::string &	host,
		boost::uint16_t	port,
		bool	tcpnodelay,
		ConnectorBase *	connector
	)