core::socket::stream::legacy::SocketConnection< PhysicalSocketT, ConfigT > Member List

This is the complete list of members for core::socket::stream::legacy::SocketConnection< PhysicalSocketT, ConfigT >, including all inherited members.

core::atNextTick(const std::function< void(void)> &callBack)	core::EventReceiver	protectedstatic
core::socket::stream::legacy::SocketWriter::atNextTick(const std::function< void(void)> &callBack)	core::EventReceiver	protectedstatic
core::blockSize	core::socket::stream::SocketReader	private
core::checkTimeout(const utils::Timeval &currentTime)	core::DescriptorEventReceiver	protected
core::socket::stream::legacy::SocketWriter::checkTimeout(const utils::Timeval &currentTime)	core::DescriptorEventReceiver	protected
close() final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
Config typedef	core::socket::stream::legacy::SocketConnection< PhysicalSocketT, ConfigT >	private
config	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	private
connectionName	core::socket::stream::SocketConnection	protected
connectSocketContext(const std::shared_ptr< SocketContextFactory > &socketContextFactory)	core::socket::stream::SocketConnection	protected
cursor	core::socket::stream::SocketReader	private
core::descriptorEventPublisher	core::DescriptorEventReceiver	private
core::DescriptorEventReceiver(const std::string &name, DescriptorEventPublisher &descriptorEventPublisher, const utils::Timeval &timeout=TIMEOUT::DISABLE)	core::DescriptorEventReceiver	protected
core::socket::stream::legacy::SocketWriter::DescriptorEventReceiver(const std::string &name, DescriptorEventPublisher &descriptorEventPublisher, const utils::Timeval &timeout=TIMEOUT::DISABLE)	core::DescriptorEventReceiver	protected
destruct()	core::EventReceiver	protectedvirtual
core::disable()	core::DescriptorEventReceiver	protected
core::socket::stream::legacy::SocketWriter::disable()	core::DescriptorEventReceiver	protected
core::dispatchEvent() final	core::eventreceiver::ReadEventReceiver	privatevirtual
doRead()	core::socket::stream::SocketReader	private
doWrite()	core::socket::stream::SocketWriter	private
doWriteShutdown(const std::function< void()> &onShutdown) override	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	protectedvirtual
durationToString(const std::chrono::time_point< std::chrono::system_clock > &bevore, const std::chrono::time_point< std::chrono::system_clock > &later=std::chrono::system_clock::now())	core::socket::stream::SocketConnection	privatestatic
core::enable(int fd)	core::DescriptorEventReceiver	protected
core::socket::stream::legacy::SocketWriter::enable(int fd)	core::DescriptorEventReceiver	protected
core::enabled	core::DescriptorEventReceiver	private
core::event	core::EventReceiver	private
core::eventCounter	core::DescriptorEventReceiver	private
core::EventReceiver(const std::string &name)	core::EventReceiver	protected
core::EventReceiver(EventReceiver &)=delete	core::EventReceiver	protected
core::EventReceiver(EventReceiver &&)=delete	core::EventReceiver	protected
core::socket::stream::legacy::SocketWriter::EventReceiver(const std::string &name)	core::EventReceiver	protected
core::socket::stream::legacy::SocketWriter::EventReceiver(EventReceiver &)=delete	core::EventReceiver	protected
core::socket::stream::legacy::SocketWriter::EventReceiver(EventReceiver &&)=delete	core::EventReceiver	protected
getConfig() const	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >
getConnectionName() const	core::socket::stream::SocketConnection
getFd() const final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
getInstanceName() const	core::socket::stream::SocketConnection
getLocalAddress() const final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
core::getName() const	core::EventReceiver	protected
core::socket::stream::legacy::SocketWriter::getName() const	core::EventReceiver	protected
getOnlineDuration() const	core::socket::stream::SocketConnection
getOnlineSince() const	core::socket::stream::SocketConnection
core::getRegisteredFd() const	core::DescriptorEventReceiver	protected
core::socket::stream::legacy::SocketWriter::getRegisteredFd() const	core::DescriptorEventReceiver	protected
getRemoteAddress() const final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
getSocketContext() const	core::socket::stream::SocketConnection
core::getTimeout(const utils::Timeval &currentTime) const	core::DescriptorEventReceiver	protected
core::socket::stream::legacy::SocketWriter::getTimeout(const utils::Timeval &currentTime) const	core::DescriptorEventReceiver	protected
getTotalProcessed() const override	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
getTotalQueued() const override	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
getTotalRead() const override	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
getTotalSent() const override	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
core::initialTimeout	core::DescriptorEventReceiver	private
instanceName	core::socket::stream::SocketConnection	protected
core::isEnabled() const	core::DescriptorEventReceiver	protected
core::socket::stream::legacy::SocketWriter::isEnabled() const	core::DescriptorEventReceiver	protected
core::isSuspended() const	core::DescriptorEventReceiver	protected
core::socket::stream::legacy::SocketWriter::isSuspended() const	core::DescriptorEventReceiver	protected
core::lastTriggered	core::DescriptorEventReceiver	private
localAddress	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	private
markShutdown	core::socket::stream::SocketWriter	protected
core::maxInactivity	core::DescriptorEventReceiver	private
observationCounter	core::Observer	private
observed()	core::Observer	protected
core::observedFd	core::DescriptorEventReceiver	private
Observer()=default	core::Observer	protected
Observer(Observer &)=delete	core::Observer	protected
Observer(Observer &&)=delete	core::Observer	protected
onDisconnect	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	private
core::onEvent(const utils::Timeval &currentTime) final	core::DescriptorEventReceiver	privatevirtual
onlineSinceTimePoint	core::socket::stream::SocketConnection	protected
onReadError(int errnum)	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	protected
onReceivedFromPeer(std::size_t available) final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	privatevirtual
onShutdown	core::socket::stream::SocketWriter	protected
onSignal(int signum) final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	privatevirtual
core::onStatus	core::socket::stream::SocketReader	private
onWriteError(int errnum)	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	protected
core::operator=(EventReceiver &)=delete	core::EventReceiver	protected
core::operator=(EventReceiver &&)=delete	core::EventReceiver	protected
core::socket::stream::legacy::SocketWriter::operator=(EventReceiver &)=delete	core::EventReceiver	protected
core::socket::stream::legacy::SocketWriter::operator=(EventReceiver &&)=delete	core::EventReceiver	protected
physicalSocket	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	private
PhysicalSocket typedef	core::socket::stream::legacy::SocketConnection< PhysicalSocketT, ConfigT >	private
read(char *chunk, std::size_t chunkLen)	core::socket::stream::SocketReader	protectedvirtual
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) final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
readTimeout() final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	privatevirtual
core::relax()	core::EventReceiver	protected
core::socket::stream::legacy::SocketWriter::relax()	core::EventReceiver	protected
remoteAddress	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	private
core::resume()	core::DescriptorEventReceiver	protected
core::socket::stream::legacy::SocketWriter::resume()	core::DescriptorEventReceiver	protected
sendToPeer(const char *chunk, std::size_t chunkLen) final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
sendToPeer(const char *chunk, std::size_t chunkLen)=0	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
sendToPeer(const std::string &data)	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >
sentToPeer(const std::vector< uint8_t > &data)	core::socket::stream::SocketConnection
sentToPeer(const std::vector< char > &data)	core::socket::stream::SocketConnection
core::setBlockSize(std::size_t readBlockSize)	core::socket::stream::SocketReader	protected
core::socket::stream::legacy::SocketWriter::setBlockSize(std::size_t writeBlockSize)	core::socket::stream::SocketWriter	protected
core::setDisabled()	core::DescriptorEventReceiver	private
core::setEnabled(const utils::Timeval &currentTime)	core::DescriptorEventReceiver	private
setSocketContext(SocketContext *socketContext)	core::socket::stream::SocketConnection	protected
setTimeout(const utils::Timeval &timeout) final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
core::shutdownInProgress	core::socket::stream::SocketReader	private
core::socket::stream::legacy::SocketWriter::shutdownInProgress	core::socket::stream::SocketWriter	protected
shutdownRead() final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
shutdownWrite(bool forceClose) final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
core::socket::stream::legacy::SocketWriter::shutdownWrite(const std::function< void()> &onShutdown)	core::socket::stream::SocketWriter	protected
core::signalEvent(int sigNum) final	core::socket::stream::SocketReader	privatevirtual
size	core::socket::stream::SocketReader	private
SocketAcceptor	core::socket::stream::legacy::SocketConnection< PhysicalSocketT, ConfigT >	friend
SocketAddress typedef	core::socket::stream::legacy::SocketConnection< PhysicalSocketT, ConfigT >
SocketConnection(PhysicalSocket &&physicalSocket, const std::function< void(SocketConnection *)> &onDisconnect, const std::shared_ptr< Config > &config)	core::socket::stream::legacy::SocketConnection< PhysicalSocketT, ConfigT >
SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >::SocketConnection(int fd, const net::config::ConfigInstance *config)	core::socket::stream::SocketConnection
SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >::SocketConnection(const SocketConnection &)=delete	core::socket::stream::SocketConnection
SocketConnectionT()=delete	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >
SocketConnectionT(PhysicalSocket &&physicalSocket, const std::function< void()> &onDisconnectm, const std::shared_ptr< Config > &config)	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	protected
SocketConnector	core::socket::stream::legacy::SocketConnection< PhysicalSocketT, ConfigT >	friend
socketContext	core::socket::stream::SocketConnection	protected
SocketReader typedef	core::socket::stream::legacy::SocketConnection< PhysicalSocketT, ConfigT >	private
core::socket::stream::legacy::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
SocketWriter typedef	core::socket::stream::legacy::SocketConnection< PhysicalSocketT, ConfigT >	private
core::socket::stream::legacy::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
core::span()	core::EventReceiver	protected
core::socket::stream::legacy::SocketWriter::span()	core::EventReceiver	protected
streamEof() final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
streamToPeer(core::pipe::Source *source) final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	virtual
Super typedef	core::socket::stream::legacy::SocketConnection< PhysicalSocketT, ConfigT >	private
core::suspend()	core::DescriptorEventReceiver	protected
core::socket::stream::legacy::SocketWriter::suspend()	core::DescriptorEventReceiver	protected
core::suspended	core::DescriptorEventReceiver	private
core::terminateTimeout	core::socket::stream::SocketReader	protected
core::socket::stream::legacy::SocketWriter::terminateTimeout	core::socket::stream::SocketWriter	protected
core::timeoutEvent() final	core::eventreceiver::ReadEventReceiver	privatevirtual
timePointToString(const std::chrono::time_point< std::chrono::system_clock > &timePoint)	core::socket::stream::SocketConnection	privatestatic
totalProcessed	core::socket::stream::SocketReader	private
totalQueued	core::socket::stream::SocketWriter	private
totalRead	core::socket::stream::SocketReader	private
totalSent	core::socket::stream::SocketWriter	private
core::triggered(const utils::Timeval &currentTime)	core::DescriptorEventReceiver	private
unObserved()	core::Observer	protected
unobservedEvent() final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	privatevirtual
write(const char *chunk, std::size_t chunkLen)	core::socket::stream::SocketWriter	protectedvirtual
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() final	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	privatevirtual
~EventReceiver()=default	core::EventReceiver	protectedvirtual
~Observer()	core::Observer	protectedvirtual
~SocketConnection()	core::socket::stream::SocketConnection	protectedvirtual
~SocketConnectionT() override	core::socket::stream::SocketConnectionT< PhysicalSocketT, core::socket::stream::legacy::SocketReader, core::socket::stream::legacy::SocketWriter, ConfigT >	protected
~SocketReader() override	core::socket::stream::legacy::SocketReader	protected
~SocketWriter() override	core::socket::stream::legacy::SocketWriter	protected