The DataArrayTcpServer class. More...
#include <AsyncFw/DataArrayTcpServer>
Public Member Functions | |
| DataArrayTcpServer (const std::string &="TcpServer") | |
| void | quit () override |
| bool | listen (const std::string &address, uint16_t port) |
| void | close () |
| void | setAlwaysConnect (const std::vector< std::string > &list) |
| bool | listening () |
| void | tlsSetup (const TlsContext &data) |
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 &) | |
| AbstractThread * | thread () |
| std::string | name () const |
| AbstractThread::LockGuard | threads (std::vector< AbstractThreadPool::Thread * > **) |
Additional Inherited Members | |
Public Types inherited from AsyncFw::DataArrayAbstractTcp | |
| enum | Result { ErrorTransmitInvoke = -100 , ErrorTransmitNotActive = -101 , ErrorTransmit = -102 } |
Static Public Member Functions inherited from AsyncFw::AbstractThreadPool | |
| static std::vector< AbstractThreadPool * > | pools () |
Public Attributes inherited from AsyncFw::DataArrayAbstractTcp | |
| FunctionConnectorProtected< DataArrayAbstractTcp >::Connector< const DataArraySocket *, const DataArray *, uint32_t > | received {AbstractFunctionConnector::DirectOnly} |
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 *) |
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_ |
The DataArrayTcpServer class.
|
overridevirtual |
Reimplemented from AsyncFw::AbstractThreadPool.