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