| atNextTick(const std::function< void(void)> &callBack) | core::EventReceiver | static |
| blockSize | core::socket::stream::SocketWriter | private |
| checkTimeout(const utils::Timeval ¤tTime) | core::DescriptorEventReceiver | |
| 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::WriteEventReceiver | privatevirtual |
| doSSLHandshake(const std::function< void()> &onSuccess, const std::function< void()> &onTimeout, const std::function< void(int)> &onStatus)=0 | core::socket::stream::tls::SocketWriter | protectedpure virtual |
| doWrite() | core::socket::stream::SocketWriter | private |
| doWriteShutdown(const std::function< void()> &onShutdown)=0 | core::socket::stream::SocketWriter | privatepure 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 | |
| getTotalQueued() const | core::socket::stream::SocketWriter | protected |
| getTotalSent() const | core::socket::stream::SocketWriter | protected |
| initialTimeout | core::DescriptorEventReceiver | private |
| isEnabled() const | core::DescriptorEventReceiver | |
| isSuspended() const | core::DescriptorEventReceiver | |
| lastTriggered | core::DescriptorEventReceiver | private |
| markShutdown | core::socket::stream::SocketWriter | protected |
| 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 |
| onShutdown | core::socket::stream::SocketWriter | protected |
| onSignal(int sigNum)=0 | core::socket::stream::SocketWriter | privatepure virtual |
| onStatus | core::socket::stream::SocketWriter | private |
| operator=(EventReceiver &)=delete | core::EventReceiver | |
| operator=(EventReceiver &&)=delete | core::EventReceiver | |
| relax() | core::EventReceiver | |
| resume() | core::DescriptorEventReceiver | protected |
| sendToPeer(const char *chunk, std::size_t chunkLen) | core::socket::stream::SocketWriter | protected |
| setBlockSize(std::size_t writeBlockSize) | core::socket::stream::SocketWriter | protected |
| setDisabled() | core::DescriptorEventReceiver | private |
| setEnabled(const utils::Timeval ¤tTime) | core::DescriptorEventReceiver | private |
| setTimeout(const utils::Timeval &timeout) | core::DescriptorEventReceiver | |
| shutdownInProgress | core::socket::stream::SocketWriter | protected |
| shutdownWrite(const std::function< void()> &onShutdown) | core::socket::stream::SocketWriter | protected |
| signalEvent(int sigNum) final | core::socket::stream::SocketWriter | privatevirtual |
| SocketWriter()=delete | core::socket::stream::SocketWriter | |
| SocketWriter(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::SocketWriter | explicitprotected |
| source | core::socket::stream::SocketWriter | private |
| span() | core::EventReceiver | |
| ssl | core::socket::stream::tls::SocketWriter | protected |
| streamEof() | core::socket::stream::SocketWriter | protected |
| streamToPeer(core::pipe::Source *source) | core::socket::stream::SocketWriter | protected |
| Super typedef | core::socket::stream::tls::SocketWriter | private |
| suspend() | core::DescriptorEventReceiver | protected |
| suspended | core::DescriptorEventReceiver | private |
| terminateTimeout | core::socket::stream::SocketWriter | protected |
| timeoutEvent() final | core::eventreceiver::WriteEventReceiver | privatevirtual |
| totalQueued | core::socket::stream::SocketWriter | private |
| totalSent | core::socket::stream::SocketWriter | private |
| triggered(const utils::Timeval ¤tTime) | core::DescriptorEventReceiver | private |
| unObserved() | core::Observer | protected |
| unobservedEvent()=0 | core::Observer | protectedpure virtual |
| write(const char *chunk, std::size_t chunkLen) override | core::socket::stream::tls::SocketWriter | privatevirtual |
| writeEvent() final | core::socket::stream::SocketWriter | privatevirtual |
| WriteEventReceiver(const std::string &name, const utils::Timeval &timeout) | core::eventreceiver::WriteEventReceiver | protected |
| writePuffer | core::socket::stream::SocketWriter | protected |
| writeTimeout() | core::eventreceiver::WriteEventReceiver | protectedvirtual |
| ~EventReceiver()=default | core::EventReceiver | protectedvirtual |
| ~Observer() | core::Observer | virtual |