FIX8::ClientConnection Class Reference

Client (initiator) specialisation of Connection. More...

#include <connection.hpp>

Inheritance diagram for FIX8::ClientConnection:

Public Member Functions
	ClientConnection (Poco::Net::StreamSocket *sock, Poco::Net::SocketAddress &addr, Session &session, unsigned hb_interval, ProcessModel pmodel=pm_pipeline, bool no_delay=true, bool secured=false)
virtual	~ClientConnection ()
	Dtor. More...
F8API bool	connect ()
Public Member Functions inherited from FIX8::Connection
	Connection (Poco::Net::StreamSocket *sock, Poco::Net::SocketAddress &addr, Session &session, Role role, const ProcessModel pmodel, unsigned hb_interval, bool secured)
virtual	~Connection ()
	Dtor. More...
Role	get_role () const
ProcessModel	get_pmodel () const
bool	is_secure () const
F8API void	start ()
	Start the reader and writer threads. More...
F8API void	stop ()
	Stop the reader and writer threads. More...
bool	is_connected () const
virtual bool	write (Message *from, bool destroy=true)
virtual bool	write (Message &from)
size_t	write_batch (const std::vector< Message * > &msgs, bool destroy)
int	send (const char *from, size_t sz)
int	send (const f8String &from)
void	set_hb_interval (const unsigned hb_interval)
unsigned	get_hb_interval () const
unsigned	get_hb_interval20pc () const
Poco::Net::SocketAddress	get_peer_socket_address () const
const Poco::Net::SocketAddress &	get_socket_address () const
int	join ()
bool	is_socket_error () const
void	set_recv_buf_sz (const unsigned sz) const
void	set_send_buf_sz (const unsigned sz) const
void	set_tcp_cork_flag (bool way) const
Session &	get_session ()
int	reader_execute ()
bool	reader_poll (const Poco::Timespan &ts=Poco::Timespan()) const
int	writer_execute ()
bool	writer_poll (const Poco::Timespan &ts=Poco::Timespan()) const

Private Attributes
const bool	_no_delay

Additional Inherited Members
Public Types inherited from FIX8::Connection
enum	Role { cn_acceptor, cn_initiator, cn_unknown }
	Roles: acceptor, initiator or unknown. More...
Static Public Member Functions inherited from FIX8::Connection
static void	set_recv_buf_sz (const unsigned sz, Poco::Net::Socket *sock)
static void	set_send_buf_sz (const unsigned sz, Poco::Net::Socket *sock)
Protected Attributes inherited from FIX8::Connection
Poco::Net::StreamSocket *	_sock
Poco::Net::SocketAddress	_addr
f8_atomic< bool >	_connected
Session &	_session
Role	_role
ProcessModel	_pmodel
unsigned	_hb_interval
unsigned	_hb_interval20pc
FIXReader	_reader
FIXWriter	_writer
bool	_secured

Detailed Description

Client (initiator) specialisation of Connection.

Definition at line 693 of file connection.hpp.

Constructor & Destructor Documentation

FIX8::ClientConnection::ClientConnection ( Poco::Net::StreamSocket *  sock, Poco::Net::SocketAddress &  addr, Session &  session, unsigned  hb_interval, ProcessModel  pmodel = pm_pipeline, bool  no_delay = true, bool  secured = false  )

inline

Ctor. Initiator.

Parameters

sock	connected socket
addr	sock address structure
session	session
hb_interval	heartbeat interval
pmodel	process model
no_delay	set or clear the tcp no delay flag on the socket
secured	true for ssl connection

Definition at line 707 of file connection.hpp.

       : Connection(sock, addr, session, cn_initiator, pmodel, hb_interval, secured), _no_delay(no_delay) {}

virtual FIX8::ClientConnection::~ClientConnection ( )

inlinevirtual

Dtor.

Definition at line 713 of file connection.hpp.

{}

Member Function Documentation

bool ClientConnection::connect ( )

virtual

Establish connection.

Returns

true on success

Reimplemented from FIX8::Connection.

Definition at line 337 of file connection.cpp.

References FIX8::hypersleep< h_milliseconds >(), scout_debug, scout_error, and scout_info.

{
   unsigned attempts(0);
   const LoginParameters& lparam(_session.get_login_parameters());
   const Poco::Timespan timeout(lparam._connect_timeout, 0);

   while (attempts < (lparam._reliable ? 1 : lparam._login_retries))
   {
      try
      {
         if (_addr == Poco::Net::SocketAddress())
            throw Poco::Net::InvalidAddressException("empty address");

         scout_info << "Trying to connect to: " << _addr.toString() << " (" << ++attempts << ')' << ( _secured ? " secured" : " not-secured");
         _sock->connect(_addr, timeout);
         if (lparam._recv_buf_sz)
            set_recv_buf_sz(lparam._recv_buf_sz);
         if (lparam._send_buf_sz)
            set_send_buf_sz(lparam._send_buf_sz);
         _sock->setLinger(false, 0);
         _sock->setNoDelay(_no_delay);
         scout_info << "Connection successful";
         return _connected = true;
      }
      catch (Poco::Exception& e)
      {
         if (lparam._reliable)
         {
            scout_debug << "rethrowing Poco::Exception: " << e.displayText();
            throw;
         }
         scout_error << "exception: " << e.displayText();
         hypersleep<h_milliseconds>(lparam._login_retry_interval);
      }
      catch (exception& e)
      {
         if (lparam._reliable)
         {
            scout_debug << "rethrowing exception: " << e.what();
            throw;
         }
         scout_error << "exception: " << e.what();
         hypersleep<h_milliseconds>(lparam._login_retry_interval);
      }
   }

   scout_error << "Connection failed";
   return false;
}

Member Data Documentation

const bool FIX8::ClientConnection::_no_delay

private

Definition at line 695 of file connection.hpp.

---

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

• connection.hpp
• connection.cpp