FIX::SocketConnector Class Reference

Connects sockets to remote ports and addresses. More...

#include <SocketConnector.h>

Collaboration diagram for FIX::SocketConnector:

Classes
class	Strategy

Public Member Functions
	SocketConnector (int timeout=0)
int	connect (const std::string &address, int port, bool noDelay, int sendBufSize, int rcvBufSize, const std::string &sourceAddress="", int sourcePort=0)
int	connect (const std::string &address, int port, bool noDelay, int sendBufSize, int rcvBufSize, Strategy &)
void	block (Strategy &strategy, bool poll=0, double timeout=0.0)
SocketMonitor &	getMonitor ()

Private Attributes
SocketMonitor	m_monitor

Detailed Description

Connects sockets to remote ports and addresses.

Definition at line 35 of file SocketConnector.h.

Constructor & Destructor Documentation

SocketConnector()

FIX::SocketConnector::SocketConnector

(

int

timeout = 0

)

Definition at line 82 of file SocketConnector.cpp.

: m_monitor( timeout ) {}

References m_monitor.

Referenced by FIX::SocketConnector::Strategy::onConnect(), FIX::SocketConnector::Strategy::onData(), FIX::SocketConnector::Strategy::onDisconnect(), FIX::SocketConnector::Strategy::onError(), FIX::SocketConnector::Strategy::onTimeout(), and FIX::SocketConnector::Strategy::onWrite().

Member Function Documentation

block()

void FIX::SocketConnector::block	(	Strategy &	strategy,
		bool	poll = 0,
		double	timeout = 0.0 )

Definition at line 114 of file SocketConnector.cpp.

{
  ConnectorWrapper wrapper( *this, strategy );
  m_monitor.block( wrapper, poll, timeout );
}

References m_monitor.

connect() [1/2]

int FIX::SocketConnector::connect	(	const std::string &	address,
		int	port,
		bool	noDelay,
		int	sendBufSize,
		int	rcvBufSize,
		const std::string &	sourceAddress = "",
		int	sourcePort = 0 )

Definition at line 85 of file SocketConnector.cpp.

{
  int socket = socket_createConnector();
 
  if ( socket != -1 )
  {
    if( noDelay )
      socket_setsockopt( socket, TCP_NODELAY );
    if( sendBufSize )
      socket_setsockopt( socket, SO_SNDBUF, sendBufSize );
    if( rcvBufSize )
      socket_setsockopt( socket, SO_RCVBUF, rcvBufSize );
    if ( !sourceAddress.empty() || sourcePort )
          socket_bind( socket, sourceAddress.c_str(), sourcePort );
    m_monitor.addConnect( socket );
    socket_connect( socket, address.c_str(), port );
  }
  return socket;
}

References m_monitor, FIX::socket_bind(), FIX::socket_connect(), FIX::socket_createConnector(), and FIX::socket_setsockopt().

Referenced by connect().

connect() [2/2]

int FIX::SocketConnector::connect	(	const std::string &	address,
		int	port,
		bool	noDelay,
		int	sendBufSize,
		int	rcvBufSize,
		Strategy &	strategy )

Definition at line 107 of file SocketConnector.cpp.

{
  int socket = connect( address, port, noDelay, sendBufSize, rcvBufSize, "", 0);
  return socket;
}

References connect().

getMonitor()

SocketMonitor & FIX::SocketConnector::getMonitor ( )

inline

Definition at line 48 of file SocketConnector.h.

{ return m_monitor; }

References m_monitor.

Referenced by FIX::SocketConnection::read().

Member Data Documentation

m_monitor

SocketMonitor FIX::SocketConnector::m_monitor

private

Definition at line 51 of file SocketConnector.h.

Referenced by block(), connect(), getMonitor(), and SocketConnector().

---

The documentation for this class was generated from the following files:

• SocketConnector.h
• SocketConnector.cpp