AsyncFw 1.2
Async Framework is c++ runtime with timers, poll notifiers, sockets, coroutines, etc.
 
Loading...
Searching...
No Matches
AsyncFw::DataArrayAbstractTcp Class Reference

The DataArrayAbstractTcp class. More...

#include <AsyncFw/DataArrayAbstractTcp>

Inheritance diagram for AsyncFw::DataArrayAbstractTcp:
[legend]
Collaboration diagram for AsyncFw::DataArrayAbstractTcp:
[legend]

Public Types

enum  Result { ErrorTransmitInvoke = -100 , ErrorTransmitNotActive = -101 , ErrorTransmit = -102 }
 

Public Member Functions

 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 ()
 
AbstractThreadthread ()
 
std::string name () const
 
AbstractThread::LockGuard threads (std::vector< AbstractThreadPool::Thread * > **)
 

Public Attributes

FunctionConnectorProtected< DataArrayAbstractTcp >::Connector< const DataArraySocket *, const DataArray *, uint32_t > received {AbstractFunctionConnector::DirectOnly}
 

Protected Member Functions

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

Protected Attributes

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
 
AbstractThreadthread_
 

Additional Inherited Members

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

Detailed Description


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