#include <AsyncFw/DataArrayTcpClient>

Inheritance diagram for AsyncFw::DataArrayTcpClient:

Collaboration diagram for AsyncFw::DataArrayTcpClient:

Public Types
enum	Result { ErrorExchangeNotActive = -103 , ErrorExchangeTransmit = -104 , ErrorExchangeConnectionClose = -105 , ErrorExchangeTimeout = -106 , ErrorExchangeThread = -107 }

Public Types inherited from AsyncFw::DataArrayAbstractTcp
enum	Result { ErrorTransmitInvoke = -100 , ErrorTransmitNotActive = -101 , ErrorTransmit = -102 }

Public Member Functions
	DataArrayTcpClient (const std::string &="TcpClient")

void	connectToHost (DataArraySocket *socket, const std::string &, uint16_t, int=0)

void	connectToHost (const DataArraySocket *, int=0)

Thread *	createThread ()

DataArraySocket *	createSocket (Thread *thread=nullptr)

void	removeSocket (DataArraySocket *)

int	exchange (const DataArraySocket , const DataArray &, const DataArray , uint32_t, int=5000)

std::size_t	socketLimit ()

int	connectTimeout () const

void	setConnectTimeout (int timeout)

int	reconnectTimeout () const

void	setReconnectTimeout (int timeout)

Public Member Functions inherited from AsyncFw::DataArrayAbstractTcp
	DataArrayAbstractTcp (const std::string &)

void	init (int readTimeout=30000, int waitKeepAliveAnswerTimeout=0, int waitForEncryptedTimeout=10000, int maxThreads=4, int maxSockets=8, int maxReadBuffers=16, int maxReadSize=16 1024 1024, int maxWriteBuffers=16, int maxWriteSize=16 1024 1024, int socketReadBufferSize=1024 *512)

int	transmit (const DataArraySocket *, const DataArray &, uint32_t, bool=false)

void	disconnectFromHost (const DataArraySocket *)

int	sockets (std::vector< DataArraySocket * > *=nullptr)

void	setEncryptDisabled (const std::vector< std::string > &list)

void	setEncryptDisabled (const std::string &, bool=true)

void	initTls (DataArraySocket *, const TlsContext &)

Public Member Functions inherited from AsyncFw::AbstractThreadPool
	AbstractThreadPool (const std::string &)

virtual void	quit ()

AbstractThread *	thread ()

std::string	name () const

AbstractThread::LockGuard	threads (std::vector< AbstractThreadPool::Thread * > **)

Public Attributes
FunctionConnectorProtected< DataArrayTcpClient >::Connector< const DataArraySocket * >	connectionStateChanged {AbstractFunctionConnector::DirectOnly}

Public Attributes inherited from AsyncFw::DataArrayAbstractTcp
FunctionConnectorProtected< DataArrayAbstractTcp >::Connector< const DataArraySocket , const DataArray , uint32_t >	received {AbstractFunctionConnector::DirectOnly}

Protected Member Functions
virtual void	socketStateChanged (const DataArraySocket *)

Protected Member Functions inherited from AsyncFw::DataArrayAbstractTcp
Thread *	findMinimalSocketsThread ()

Protected Member Functions inherited from AsyncFw::AbstractThreadPool
virtual void	appendThread (AbstractThreadPool::Thread *)

virtual void	removeThread (AbstractThreadPool::Thread *)

Additional Inherited Members
Static Public Member Functions inherited from AsyncFw::AbstractThreadPool
static std::vector< AbstractThreadPool * >	pools ()

Protected Attributes inherited from AsyncFw::DataArrayAbstractTcp
int	readTimeout

int	waitKeepAliveAnswerTimeout

int	waitForEncryptedTimeout

std::size_t	maxThreads

std::size_t	maxSockets

int	socketReadBufferSize

int	maxReadBuffers

int	maxReadSize

int	maxWriteBuffers

int	maxWriteSize

std::vector< std::string >	disabledEncrypt_ = {"127.0.0.1"}

Protected Attributes inherited from AsyncFw::AbstractThreadPool
std::vector< AbstractThreadPool::Thread * >	threads_

std::mutex	mutex

AbstractThread *	thread_

Detailed Description

The DataArrayTcpClient class.

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

main/DataArrayTcpClient.h
main/DataArrayTcpClient.cpp

Public Types

Public Member Functions

Public Attributes

Protected Member Functions

Additional Inherited Members

Detailed Description