| atNextTick(const std::function< void(void)> &callBack) | core::EventReceiver | static |
| blockSize | core::socket::stream::SocketReader | private |
| checkTimeout(const utils::Timeval ¤tTime) | core::DescriptorEventReceiver | |
| 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 | |
| getTotalProcessed() const | core::socket::stream::SocketReader | protected |
| getTotalRead() const | core::socket::stream::SocketReader | protected |
| 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 |
| totalProcessed | core::socket::stream::SocketReader | private |
| totalRead | core::socket::stream::SocketReader | private |
| 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 |