|
using | Super = core::socket::stream::SocketConnection |
|
using | Config = ConfigT |
|
using | PhysicalSocket = PhysicalSocketT |
|
using | SocketReader = core::socket::stream::legacy::SocketReader |
|
using | SocketWriter = core::socket::stream::legacy::SocketWriter |
|
using | SocketAddress = typename PhysicalSocket::SocketAddress |
|
| SocketConnectionT (PhysicalSocket &&physicalSocket, const std::function< void()> &onDisconnectm, const std::shared_ptr< Config > &config) |
|
| ~SocketConnectionT () override |
|
void | doWriteShutdown (const std::function< void()> &onShutdown) override |
|
void | onWriteError (int errnum) |
|
void | onReadError (int errnum) |
|
virtual | ~SocketConnection () |
|
void | setSocketContext (SocketContext *socketContext) |
|
void | connectSocketContext (const std::shared_ptr< SocketContextFactory > &socketContextFactory) |
|
| ~SocketReader () override |
|
| SocketReader (const std::string &instanceName, const std::function< void(int)> &onStatus, const utils::Timeval &timeout, std::size_t blockSize, const utils::Timeval &terminateTimeout) |
|
std::size_t | getTotalRead () const |
|
std::size_t | getTotalProcessed () const |
|
virtual ssize_t | read (char *chunk, std::size_t chunkLen) |
|
void | setBlockSize (std::size_t readBlockSize) |
|
std::size_t | readFromPeer (char *chunk, std::size_t chunkLen) |
|
void | shutdownRead () |
|
| SocketReader ()=delete |
|
| ReadEventReceiver (const std::string &name, const utils::Timeval &timeout) |
|
bool | enable (int fd) |
|
void | disable () |
|
void | suspend () |
|
void | resume () |
|
| DescriptorEventReceiver (const std::string &name, DescriptorEventPublisher &descriptorEventPublisher, const utils::Timeval &timeout=TIMEOUT::DISABLE) |
|
int | getRegisteredFd () const |
|
bool | isEnabled () const |
|
bool | isSuspended () const |
|
void | setTimeout (const utils::Timeval &timeout) |
|
utils::Timeval | getTimeout (const utils::Timeval ¤tTime) const |
|
void | checkTimeout (const utils::Timeval ¤tTime) |
|
void | observed () |
|
void | unObserved () |
|
| Observer ()=default |
|
| Observer (Observer &)=delete |
|
| Observer (Observer &&)=delete |
|
virtual | ~Observer () |
|
virtual | ~EventReceiver ()=default |
|
| EventReceiver (const std::string &name) |
|
| EventReceiver (EventReceiver &)=delete |
|
| EventReceiver (EventReceiver &&)=delete |
|
EventReceiver & | operator= (EventReceiver &)=delete |
|
EventReceiver & | operator= (EventReceiver &&)=delete |
|
virtual void | destruct () |
|
void | span () |
|
void | relax () |
|
const std::string & | getName () const |
|
| ~SocketWriter () override |
|
| SocketWriter (const std::string &instanceName, const std::function< void(int)> &onStatus, const utils::Timeval &timeout, std::size_t blockSize, const utils::Timeval &terminateTimeout) |
|
std::size_t | getTotalSent () const |
|
std::size_t | getTotalQueued () const |
|
virtual ssize_t | write (const char *chunk, std::size_t chunkLen) |
|
void | setBlockSize (std::size_t writeBlockSize) |
|
void | sendToPeer (const char *chunk, std::size_t chunkLen) |
|
bool | streamToPeer (core::pipe::Source *source) |
|
void | streamEof () |
|
void | shutdownWrite (const std::function< void()> &onShutdown) |
|
| SocketWriter ()=delete |
|
| WriteEventReceiver (const std::string &name, const utils::Timeval &timeout) |
|
static void | atNextTick (const std::function< void(void)> &callBack) |
|
core::socket::stream::SocketContext * | socketContext = nullptr |
|
std::string | instanceName |
|
std::string | connectionName |
|
std::chrono::time_point< std::chrono::system_clock > | onlineSinceTimePoint |
|
utils::Timeval | terminateTimeout |
|
bool | markShutdown = false |
|
std::function< void()> | onShutdown |
|
std::vector< char > | writePuffer |
|
bool | shutdownInProgress = false |
|
utils::Timeval | terminateTimeout |
|
template<typename PhysicalSocketT, typename ConfigT>
class core::socket::stream::legacy::SocketConnection< PhysicalSocketT, ConfigT >
Definition at line 58 of file SocketConnection.h.