The DataArrayAbstractTcp class.
More...
#include <AsyncFw/DataArrayAbstractTcp>
|
| enum | Result { ErrorTransmitInvoke = -100
, ErrorTransmitNotActive = -101
, ErrorTransmit = -102
} |
| |
|
|
| 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 &) |
| |
|
| AbstractThreadPool (const std::string &) |
| |
|
virtual void | quit () |
| |
|
AbstractThread * | thread () |
| |
|
std::string | name () const |
| |
|
AbstractThread::LockGuard | threads (std::vector< AbstractThreadPool::Thread * > **) |
| |
|
|
Thread * | findMinimalSocketsThread () |
| |
|
virtual void | appendThread (AbstractThreadPool::Thread *) |
| |
|
virtual void | removeThread (AbstractThreadPool::Thread *) |
| |
|
|
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"} |
| |
|
std::vector< AbstractThreadPool::Thread * > | threads_ |
| |
|
std::mutex | mutex |
| |
|
AbstractThread * | thread_ |
| |
The documentation for this class was generated from the following files: