|
SNode.C
|
#include <SocketWriter.h>
Public Member Functions | |
| ~SocketWriter () override | |
Public Member Functions inherited from core::socket::stream::SocketWriter | |
| SocketWriter ()=delete | |
Public Member Functions inherited from core::DescriptorEventReceiver | |
| 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) |
Public Member Functions inherited from core::EventReceiver | |
| 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::SocketWriter |
Additional Inherited Members | |
Static Public Member Functions inherited from core::EventReceiver | |
| static void | atNextTick (const std::function< void(void)> &callBack) |
Protected Member Functions inherited from 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) | |
| std::size_t | getTotalSent () const |
| std::size_t | getTotalQueued () const |
| virtual ssize_t | write (const char *chunk, std::size_t chunkLen) |
| void | setBlockSize (std::size_t writeBlockSize) |
| void | sendToPeer (const char *chunk, std::size_t chunkLen) |
| bool | streamToPeer (core::pipe::Source *source) |
| void | streamEof () |
| void | shutdownWrite (const std::function< void()> &onShutdown) |
Protected Member Functions inherited from core::eventreceiver::WriteEventReceiver | |
| WriteEventReceiver (const std::string &name, const utils::Timeval &timeout) | |
| virtual void | writeTimeout () |
Protected Member Functions inherited from core::DescriptorEventReceiver | |
| bool | enable (int fd) |
| void | disable () |
| void | suspend () |
| void | resume () |
Protected Member Functions inherited from core::Observer | |
| void | observed () |
| void | unObserved () |
| virtual void | unobservedEvent ()=0 |
| Observer ()=default | |
| Observer (Observer &)=delete | |
| Observer (Observer &&)=delete | |
| virtual | ~Observer () |
Protected Member Functions inherited from core::EventReceiver | |
| 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 Protected Member Functions inherited from core::EventReceiver | |
| static void | atNextTick (const std::function< void(void)> &callBack) |
Protected Attributes inherited from core::socket::stream::SocketWriter | |
| bool | markShutdown = false |
| std::function< void()> | onShutdown |
| std::vector< char > | writePuffer |
| bool | shutdownInProgress = false |
| utils::Timeval | terminateTimeout |
Definition at line 53 of file SocketWriter.h.
|
private |
Definition at line 55 of file SocketWriter.h.
|
override |
Definition at line 50 of file SocketWriter.cpp.