|
SNode.C
|
#include <SocketServer.h>
Public Types | |
| using | SocketConnection = typename SocketAcceptor::SocketConnection |
| using | SocketAddress = typename SocketAcceptor::SocketAddress |
| using | Config = typename SocketAcceptor::Config |
Public Types inherited from core::socket::Socket< SocketAcceptorT::Config > | |
| using | Config = SocketAcceptorT::Config |
Public Member Functions | |
| SocketServer (const std::string &name, const std::function< void(SocketConnection *)> &onConnect, const std::function< void(SocketConnection *)> &onConnected, const std::function< void(SocketConnection *)> &onDisconnect, Args &&... args) | |
| SocketServer (const std::function< void(SocketConnection *)> &onConnect, const std::function< void(SocketConnection *)> &onConnected, const std::function< void(SocketConnection *)> &onDisconnect, Args &&... args) | |
| SocketServer (const std::string &name, Args &&... args) | |
| SocketServer (Args &&... args) | |
| void | listen (const std::function< void(const SocketAddress &, core::socket::State)> &onStatus) const |
| void | listen (const SocketAddress &localAddress, const std::function< void(const SocketAddress &, core::socket::State)> &onStatus) const |
| void | listen (const SocketAddress &localAddress, int backlog, const std::function< void(const SocketAddress &, core::socket::State)> &onStatus) const |
| std::function< void(SocketConnection *)> & | getOnConnect () |
| std::function< void(SocketConnection *)> | setOnConnect (const std::function< void(SocketConnection *)> &onConnect, bool initialize=false) |
| std::function< void(SocketConnection *)> & | getOnConnected () |
| std::function< void(SocketConnection *)> | setOnConnected (const std::function< void(SocketConnection *)> &onConnected, bool initialize=false) |
| std::function< void(SocketConnection *)> & | getOnDisconnect () |
| std::function< void(SocketConnection *)> | setOnDisconnect (const std::function< void(SocketConnection *)> &onDisconnect, bool initialize=false) |
| std::shared_ptr< SocketContextFactory > | getSocketContextFactory () |
Public Member Functions inherited from core::socket::Socket< SocketAcceptorT::Config > | |
| Socket (const std::string &name) | |
| Socket (const std::shared_ptr< Config > &config) | |
| Socket (Socket &&) noexcept=delete | |
| Socket & | operator= (Socket &&) noexcept=delete |
| virtual | ~Socket () |
| Config & | getConfig () const |
Private Types | |
| using | SocketAcceptor = SocketAcceptorT |
| using | SocketContextFactory = SocketContextFactoryT |
| using | Super = core::socket::Socket< typename SocketAcceptor::Config > |
Private Member Functions | |
| SocketServer (const std::shared_ptr< Config > &config, const std::shared_ptr< SocketContextFactory > &socketContextFactory, const std::function< void(SocketConnection *)> &onConnect, const std::function< void(SocketConnection *)> &onConnected, const std::function< void(SocketConnection *)> &onDisconnect) | |
| void | realListen (const std::function< void(const SocketAddress &, core::socket::State)> &onStatus, unsigned int tries, double retryTimeoutScale) const |
Private Attributes | |
| std::shared_ptr< SocketContextFactory > | socketContextFactory |
| std::function< void(SocketConnection *)> | onConnect |
| std::function< void(SocketConnection *)> | onConnected |
| std::function< void(SocketConnection *)> | onDisconnect |
Additional Inherited Members | |
Protected Member Functions inherited from core::socket::Socket< SocketAcceptorT::Config > | |
| Socket (const Socket &)=default | |
| Socket & | operator= (const Socket &)=default |
Protected Attributes inherited from core::socket::Socket< SocketAcceptorT::Config > | |
| std::shared_ptr< Config > | config |
Definition at line 68 of file SocketServer.h.
| using core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::Config = typename SocketAcceptor::Config |
Definition at line 78 of file SocketServer.h.
|
private |
Definition at line 70 of file SocketServer.h.
| using core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::SocketAddress = typename SocketAcceptor::SocketAddress |
Definition at line 77 of file SocketServer.h.
| using core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::SocketConnection = typename SocketAcceptor::SocketConnection |
Definition at line 76 of file SocketServer.h.
|
private |
Definition at line 71 of file SocketServer.h.
|
private |
Definition at line 73 of file SocketServer.h.
|
inlineprivate |
Definition at line 81 of file SocketServer.h.
References core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onConnect, core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onConnected, core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onDisconnect, and core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::socketContextFactory.
|
inline |
Definition at line 94 of file SocketServer.h.
References core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onConnect, and core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::socketContextFactory.
|
inline |
Definition at line 143 of file SocketServer.h.
|
inline |
Definition at line 151 of file SocketServer.h.
|
inlineexplicit |
Definition at line 155 of file SocketServer.h.
|
inline |
Definition at line 237 of file SocketServer.h.
References core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onConnect.
|
inline |
Definition at line 253 of file SocketServer.h.
References core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onConnected.
|
inline |
Definition at line 269 of file SocketServer.h.
References core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onDisconnect.
|
inline |
Definition at line 285 of file SocketServer.h.
References core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::socketContextFactory.
|
inline |
Definition at line 222 of file SocketServer.h.
|
inline |
Definition at line 229 of file SocketServer.h.
|
inline |
Definition at line 218 of file SocketServer.h.
References core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::realListen().
Referenced by main(), express::legacy::in::Server(), express::legacy::in6::Server(), express::legacy::rc::Server(), express::legacy::un::Server(), express::tls::in::Server(), express::tls::in6::Server(), express::tls::rc::Server(), and express::tls::un::Server().
|
inlineprivate |
Definition at line 160 of file SocketServer.h.
References core::socket::State::ERROR, core::socket::State::FATAL, utils::Random::getInRange(), core::INITIALIZED, core::socket::State::NO_RETRY, core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onConnect, core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onConnected, core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onDisconnect, core::socket::State::operator&(), core::socket::State::operator&=(), core::socket::State::operator==(), core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::realListen(), core::RUNNING, core::timer::Timer::singleshotTimer(), core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::socketContextFactory, and core::SNodeC::state().
Referenced by core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::listen(), and core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::realListen().
|
inline |
Definition at line 241 of file SocketServer.h.
References core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onConnect.
|
inline |
Definition at line 257 of file SocketServer.h.
References core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onConnected.
|
inline |
Definition at line 273 of file SocketServer.h.
References core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::onDisconnect.
|
private |
Definition at line 292 of file SocketServer.h.
Referenced by core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::getOnConnect(), core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::realListen(), core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::setOnConnect(), core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::SocketServer(), and core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::SocketServer().
|
private |
Definition at line 293 of file SocketServer.h.
Referenced by core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::getOnConnected(), core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::realListen(), core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::setOnConnected(), and core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::SocketServer().
|
private |
Definition at line 294 of file SocketServer.h.
Referenced by core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::getOnDisconnect(), core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::realListen(), core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::setOnDisconnect(), and core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::SocketServer().
|
private |
Definition at line 290 of file SocketServer.h.
Referenced by core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::getSocketContextFactory(), core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::realListen(), core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::SocketServer(), and core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::SocketServer().