atNextTick(const std::function< void(void)> &callBack) | core::EventReceiver | static |
blockSize | core::socket::stream::SocketReader | private |
checkTimeout(const utils::Timeval ¤tTime) | core::DescriptorEventReceiver | |
closeNotifyIsEOF | core::socket::stream::tls::SocketReader | protected |
cursor | core::socket::stream::SocketReader | private |
descriptorEventPublisher | core::DescriptorEventReceiver | private |
DescriptorEventReceiver(const std::string &name, DescriptorEventPublisher &descriptorEventPublisher, const utils::Timeval &timeout=TIMEOUT::DISABLE) | core::DescriptorEventReceiver | |
destruct() | core::EventReceiver | virtual |
disable() | core::DescriptorEventReceiver | protected |
dispatchEvent() final | core::eventreceiver::ReadEventReceiver | privatevirtual |
doRead() | core::socket::stream::SocketReader | private |
doSSLHandshake(const std::function< void()> &onSuccess, const std::function< void()> &onTimeout, const std::function< void(int)> &onStatus)=0 | core::socket::stream::tls::SocketReader | protectedpure virtual |
enable(int fd) | core::DescriptorEventReceiver | protected |
enabled | core::DescriptorEventReceiver | private |
event | core::EventReceiver | private |
eventCounter | core::DescriptorEventReceiver | private |
EventReceiver(const std::string &name) | core::EventReceiver | |
EventReceiver(EventReceiver &)=delete | core::EventReceiver | |
EventReceiver(EventReceiver &&)=delete | core::EventReceiver | |
getName() const | core::EventReceiver | |
getRegisteredFd() const | core::DescriptorEventReceiver | |
getTimeout(const utils::Timeval ¤tTime) const | core::DescriptorEventReceiver | |
initialTimeout | core::DescriptorEventReceiver | private |
isEnabled() const | core::DescriptorEventReceiver | |
isSuspended() const | core::DescriptorEventReceiver | |
lastTriggered | core::DescriptorEventReceiver | private |
maxInactivity | core::DescriptorEventReceiver | private |
observed() | core::Observer | protected |
observedFd | core::DescriptorEventReceiver | private |
Observer()=default | core::Observer | |
core::DescriptorEventReceiver::Observer(Observer &)=delete | core::Observer | |
core::DescriptorEventReceiver::Observer(Observer &&)=delete | core::Observer | |
onEvent(const utils::Timeval ¤tTime) final | core::DescriptorEventReceiver | privatevirtual |
onReadShutdown()=0 | core::socket::stream::tls::SocketReader | privatepure virtual |
onReceivedFromPeer(std::size_t available)=0 | core::socket::stream::SocketReader | privatepure virtual |
onSignal(int signum) | core::DescriptorEventReceiver | private |
onStatus | core::socket::stream::SocketReader | private |
operator=(EventReceiver &)=delete | core::EventReceiver | |
operator=(EventReceiver &&)=delete | core::EventReceiver | |
read(char *chunk, std::size_t chunkLen) override | core::socket::stream::tls::SocketReader | privatevirtual |
readBuffer | core::socket::stream::SocketReader | private |
readEvent() final | core::socket::stream::SocketReader | privatevirtual |
ReadEventReceiver(const std::string &name, const utils::Timeval &timeout) | core::eventreceiver::ReadEventReceiver | protected |
readFromPeer(char *chunk, std::size_t chunkLen) | core::socket::stream::SocketReader | protected |
readTimeout() | core::eventreceiver::ReadEventReceiver | protectedvirtual |
relax() | core::EventReceiver | |
resume() | core::DescriptorEventReceiver | protected |
setBlockSize(std::size_t readBlockSize) | core::socket::stream::SocketReader | protected |
setDisabled() | core::DescriptorEventReceiver | private |
setEnabled(const utils::Timeval ¤tTime) | core::DescriptorEventReceiver | private |
setTimeout(const utils::Timeval &timeout) | core::DescriptorEventReceiver | |
shutdownInProgress | core::socket::stream::SocketReader | private |
shutdownRead() | core::socket::stream::SocketReader | protected |
signalEvent(int sigNum) final | core::socket::stream::SocketReader | privatevirtual |
size | core::socket::stream::SocketReader | private |
SocketReader()=delete | core::socket::stream::SocketReader | |
SocketReader(const std::string &instanceName, const std::function< void(int)> &onStatus, const utils::Timeval &timeout, std::size_t blockSize, const utils::Timeval &terminateTimeout) | core::socket::stream::SocketReader | explicitprotected |
span() | core::EventReceiver | |
ssl | core::socket::stream::tls::SocketReader | protected |
Super typedef | core::socket::stream::tls::SocketReader | private |
suspend() | core::DescriptorEventReceiver | protected |
suspended | core::DescriptorEventReceiver | private |
terminateTimeout | core::socket::stream::SocketReader | protected |
timeoutEvent() final | core::eventreceiver::ReadEventReceiver | privatevirtual |
triggered(const utils::Timeval ¤tTime) | core::DescriptorEventReceiver | private |
unObserved() | core::Observer | protected |
unobservedEvent()=0 | core::Observer | protectedpure virtual |
~EventReceiver()=default | core::EventReceiver | protectedvirtual |
~Observer() | core::Observer | virtual |