SNode.C
|
#include <SocketReader.h>
Public Member Functions | |
~SocketReader () override | |
![]() | |
SocketReader ()=delete | |
![]() | |
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) |
![]() | |
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 |
Private Types | |
using | Super = core::socket::stream::SocketReader |
Additional Inherited Members | |
![]() | |
static void | atNextTick (const std::function< void(void)> &callBack) |
![]() | |
SocketReader (const std::string &instanceName, const std::function< void(int)> &onStatus, const utils::Timeval &timeout, std::size_t blockSize, const utils::Timeval &terminateTimeout) | |
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 () |
![]() | |
ReadEventReceiver (const std::string &name, const utils::Timeval &timeout) | |
virtual void | readTimeout () |
![]() | |
bool | enable (int fd) |
void | disable () |
void | suspend () |
void | resume () |
![]() | |
void | observed () |
void | unObserved () |
virtual void | unobservedEvent ()=0 |
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 |
![]() | |
static void | atNextTick (const std::function< void(void)> &callBack) |
![]() | |
utils::Timeval | terminateTimeout |
Definition at line 31 of file SocketReader.h.
|
private |
Definition at line 33 of file SocketReader.h.
|
override |
Definition at line 28 of file SocketReader.cpp.