SNode.C
Loading...
Searching...
No Matches
core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args > Class Template Reference

#include <SocketClient.h>

Inheritance diagram for core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >:
Collaboration diagram for core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >:

Public Types

using SocketConnection = typename SocketConnector::SocketConnection
using SocketAddress = typename SocketConnector::SocketAddress
using Config = typename SocketConnector::Config
Public Types inherited from core::socket::Socket< SocketConnectorT::Config >
using Config

Public Member Functions

 SocketClient (const std::string &name, const std::function< void(SocketConnection *)> &onConnect, const std::function< void(SocketConnection *)> &onConnected, const std::function< void(SocketConnection *)> &onDisconnect, Args &&... args)
 SocketClient (const std::function< void(SocketConnection *)> &onConnect, const std::function< void(SocketConnection *)> &onConnected, const std::function< void(SocketConnection *)> &onDisconnect, Args &&... args)
 SocketClient (const std::string &name, Args &&... args)
 SocketClient (Args &&... args)
void connect (const std::function< void(const SocketAddress &, core::socket::State)> &onStatus) const
void connect (const SocketAddress &remoteAddress, const std::function< void(const SocketAddress &, core::socket::State)> &onStatus) const
void connect (const SocketAddress &remoteAddress, const SocketAddress &localAddress, 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 () const
Public Member Functions inherited from core::socket::Socket< SocketConnectorT::Config >
 Socket (const std::string &name)
virtual ~Socket ()
Config & getConfig () const

Private Types

using SocketConnector = SocketConnectorT
using SocketContextFactory = SocketContextFactoryT
using Super = core::socket::Socket<typename SocketConnector::Config>

Private Member Functions

 SocketClient (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 realConnect (const std::function< void(const SocketAddress &, core::socket::State)> &onStatus, unsigned int tries, double retryTimeoutScale) const

Private Attributes

const 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< SocketConnectorT::Config >
Socket & operator= (const Socket &)=default
Protected Attributes inherited from core::socket::Socket< SocketConnectorT::Config >
std::shared_ptr< Config > config

Detailed Description

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
requires std::is_base_of_v<core::eventreceiver::ConnectEventReceiver, SocketConnectorT> && std::is_base_of_v<core::socket::stream::SocketContextFactory, SocketContextFactoryT>
class core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >

Sequence diagram showing how a connect to a peer is performed.

Definition at line 73 of file SocketClient.h.

Member Typedef Documentation

◆ Config

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
using core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::Config = typename SocketConnector::Config

Definition at line 83 of file SocketClient.h.

◆ SocketAddress

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
using core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::SocketAddress = typename SocketConnector::SocketAddress

Definition at line 82 of file SocketClient.h.

◆ SocketConnection

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
using core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::SocketConnection = typename SocketConnector::SocketConnection

Definition at line 81 of file SocketClient.h.

◆ SocketConnector

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
using core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::SocketConnector = SocketConnectorT
private

Definition at line 75 of file SocketClient.h.

◆ SocketContextFactory

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
using core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::SocketContextFactory = SocketContextFactoryT
private

Definition at line 76 of file SocketClient.h.

◆ Super

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
using core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::Super = core::socket::Socket<typename SocketConnector::Config>
private

Definition at line 78 of file SocketClient.h.

Constructor & Destructor Documentation

◆ SocketClient() [1/5]

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::SocketClient ( 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 )
inlineprivate

Definition at line 86 of file SocketClient.h.

91 : Super(config)
92 , socketContextFactory(socketContextFactory)
93 , onConnect(onConnect)
94 , onConnected(onConnected)
95 , onDisconnect(onDisconnect) {
96 }
core::socket::stream::SocketClient::socketContextFactory
const std::shared_ptr< SocketContextFactory > socketContextFactory
Definition SocketClient.h:319
core::socket::stream::SocketClient::onConnect
std::function< void(SocketConnection *)> onConnect
Definition SocketClient.h:321
core::socket::stream::SocketClient::onDisconnect
std::function< void(SocketConnection *)> onDisconnect
Definition SocketClient.h:323
core::socket::stream::SocketClient::Super
core::socket::Socket< typename SocketConnector::Config > Super
Definition SocketClient.h:78
core::socket::stream::SocketClient::onConnected
std::function< void(SocketConnection *)> onConnected
Definition SocketClient.h:322

◆ SocketClient() [2/5]

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::SocketClient ( const std::string & name,
const std::function< void(SocketConnection *)> & onConnect,
const std::function< void(SocketConnection *)> & onConnected,
const std::function< void(SocketConnection *)> & onDisconnect,
Args &&... args )
inline

Definition at line 99 of file SocketClient.h.

104 : Super(name)
105 , socketContextFactory(std::make_shared<SocketContextFactory>(std::forward<Args>(args)...))
106 , onConnect([onConnect](SocketConnection* socketConnection) { // onConnect
107 LOG(DEBUG) << socketConnection->getConnectionName() << ": OnConnect";
108
109 LOG(DEBUG) << " Local: " << socketConnection->getLocalAddress().toString();
110 LOG(DEBUG) << " Peer: " << socketConnection->getRemoteAddress().toString();
111
112 if (onConnect) {
113 onConnect(socketConnection);
114 }
115 })
116 , onConnected([onConnected](SocketConnection* socketConnection) { // onConnected
117 LOG(DEBUG) << socketConnection->getConnectionName() << ": OnConnected";
118
119 LOG(DEBUG) << " Local: " << socketConnection->getLocalAddress().toString();
120 LOG(DEBUG) << " Peer: " << socketConnection->getRemoteAddress().toString();
121
122 if (onConnected) {
123 onConnected(socketConnection);
124 }
125 })
126 , onDisconnect([onDisconnect](SocketConnection* socketConnection) { // onDisconnect
127 LOG(DEBUG) << socketConnection->getConnectionName() << ": OnDisconnect";
128
129 LOG(DEBUG) << " Local: " << socketConnection->getLocalAddress().toString();
130 LOG(DEBUG) << " Peer: " << socketConnection->getRemoteAddress().toString();
131
132 LOG(DEBUG) << " Online Since: " << socketConnection->getOnlineSince();
133 LOG(DEBUG) << " Online Duration: " << socketConnection->getOnlineDuration();
134
135 LOG(DEBUG) << " Total Queued: " << socketConnection->getTotalQueued();
136 LOG(DEBUG) << " Total Sent: " << socketConnection->getTotalSent();
137 LOG(DEBUG) << " Write Delta: " << socketConnection->getTotalQueued() - socketConnection->getTotalSent();
138 LOG(DEBUG) << " Total Read: " << socketConnection->getTotalRead();
139 LOG(DEBUG) << " Total Processed: " << socketConnection->getTotalProcessed();
140 LOG(DEBUG) << " Read Delta: " << socketConnection->getTotalRead() - socketConnection->getTotalProcessed();
141
142 if (onDisconnect) {
143 onDisconnect(socketConnection);
144 }
145 }) {
146 }
core::socket::stream::SocketClient::SocketConnection
typename SocketConnector::SocketConnection SocketConnection
Definition SocketClient.h:81

◆ SocketClient() [3/5]

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::SocketClient ( const std::function< void(SocketConnection *)> & onConnect,
const std::function< void(SocketConnection *)> & onConnected,
const std::function< void(SocketConnection *)> & onDisconnect,
Args &&... args )
inline

Definition at line 148 of file SocketClient.h.

152 : SocketClient("", onConnect, onConnected, onDisconnect, std::forward<Args>(args)...) {
153 }
core::socket::stream::SocketClient::SocketClient
SocketClient(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)
Definition SocketClient.h:86

◆ SocketClient() [4/5]

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::SocketClient ( const std::string & name,
Args &&... args )
inline

Definition at line 156 of file SocketClient.h.

157 : SocketClient(name, {}, {}, {}, std::forward<Args>(args)...) {
158 }

◆ SocketClient() [5/5]

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::SocketClient ( Args &&... args)
inlineexplicit

Definition at line 160 of file SocketClient.h.

161 : SocketClient("", std::forward<Args>(args)...) {
162 }

Member Function Documentation

◆ connect() [1/3]

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
void core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::connect ( const SocketAddress & remoteAddress,
const SocketAddress & localAddress,
const std::function< void(const SocketAddress &, core::socket::State)> & onStatus ) const
inline

Definition at line 258 of file SocketClient.h.

260 {
261 Super::config->Local::setSocketAddress(localAddress);
262
263 connect(remoteAddress, onStatus);
264 }
core::socket::stream::SocketClient::connect
void connect(const std::function< void(const SocketAddress &, core::socket::State)> &onStatus) const
Definition SocketClient.h:247

◆ connect() [2/3]

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
void core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::connect ( const SocketAddress & remoteAddress,
const std::function< void(const SocketAddress &, core::socket::State)> & onStatus ) const
inline

Definition at line 251 of file SocketClient.h.

252 {
253 Super::config->Remote::setSocketAddress(remoteAddress);
254
255 connect(onStatus);
256 }

Referenced by tls::getClient(), legacy::getLegacyClient(), and main().

Here is the caller graph for this function:

◆ connect() [3/3]

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
void core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::connect ( const std::function< void(const SocketAddress &, core::socket::State)> & onStatus) const
inline

Definition at line 247 of file SocketClient.h.

247 {
248 realConnect(onStatus, 0, 1);
249 }
core::socket::stream::SocketClient::realConnect
void realConnect(const std::function< void(const SocketAddress &, core::socket::State)> &onStatus, unsigned int tries, double retryTimeoutScale) const
Definition SocketClient.h:165

Referenced by main().

Here is the caller graph for this function:

◆ getOnConnect()

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
std::function< void(SocketConnection *)> & core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::getOnConnect ( )
inline

Definition at line 266 of file SocketClient.h.

266 {
267 return onConnect;
268 }

◆ getOnConnected()

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
std::function< void(SocketConnection *)> & core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::getOnConnected ( )
inline

Definition at line 282 of file SocketClient.h.

282 {
283 return onConnected();
284 }

◆ getOnDisconnect()

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
std::function< void(SocketConnection *)> & core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::getOnDisconnect ( )
inline

Definition at line 298 of file SocketClient.h.

298 {
299 return onDisconnect;
300 }

◆ getSocketContextFactory()

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
std::shared_ptr< SocketContextFactory > core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::getSocketContextFactory ( ) const
inline

Definition at line 314 of file SocketClient.h.

314 {
315 return socketContextFactory;
316 }

◆ realConnect()

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
void core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::realConnect ( const std::function< void(const SocketAddress &, core::socket::State)> & onStatus,
unsigned int tries,
double retryTimeoutScale ) const
inlineprivate

Definition at line 165 of file SocketClient.h.

167 {
168 if (core::SNodeC::state() == core::State::RUNNING || core::SNodeC::state() == core::State::INITIALIZED) {
169 new SocketConnector(
170 socketContextFactory,
171 onConnect,
172 onConnected,
173 [config = this->config,
174 onConnect = this->onConnect,
175 onConnected = this->onConnected,
176 onDisconnect = this->onDisconnect,
177 socketContextFactory = this->socketContextFactory,
178 onStatus](SocketConnection* socketConnection) {
179 onDisconnect(socketConnection);
180
181 if (config->getReconnect() && core::eventLoopState() == core::State::RUNNING) {
182 double relativeReconnectTimeout = config->getReconnectTime();
183
184 LOG(INFO) << config->getInstanceName() << ": Reconnect in " << relativeReconnectTimeout << " seconds";
185
186 core::timer::Timer::singleshotTimer(
187 [config, onConnect, onConnected, onDisconnect, onStatus, socketContextFactory]() mutable {
188 if (config->getReconnect()) {
189 SocketClient(config, socketContextFactory, onConnect, onConnected, onDisconnect)
190 .realConnect(onStatus, 0, config->getRetryBase());
191 } else {
192 LOG(INFO) << config->getInstanceName() << ": Reconnect disabled during wait";
193 }
194 },
195 relativeReconnectTimeout);
196 }
197 },
198 [config = this->config,
199 onConnect = this->onConnect,
200 onConnected = this->onConnected,
201 onDisconnect = this->onDisconnect,
202 socketContextFactory = this->socketContextFactory,
203 onStatus,
204 tries,
205 retryTimeoutScale](const SocketAddress& socketAddress, core::socket::State state) mutable {
206 const bool retryFlag = (state & core::socket::State::NO_RETRY) == 0;
207 state &= ~core::socket::State::NO_RETRY;
208 onStatus(socketAddress, state);
209
210 if (retryFlag && config->getRetry() // Shall we potentially retry? In case are the ...
211 && (config->getRetryTries() == 0 || tries < config->getRetryTries()) // ... limits not reached and has an ...
212 && (state == core::socket::State::ERROR ||
213 (state == core::socket::State::FATAL && config->getRetryOnFatal()))) { // error occurred?
214 double relativeRetryTimeout =
215 config->getRetryLimit() > 0
216 ? std::min<double>(config->getRetryTimeout() * retryTimeoutScale, config->getRetryLimit())
217 : config->getRetryTimeout() * retryTimeoutScale;
218 relativeRetryTimeout -= utils::Random::getInRange(-config->getRetryJitter(), config->getRetryJitter()) *
219 relativeRetryTimeout / 100.;
220
221 LOG(INFO) << config->getInstanceName() << ": Retry connect in " << relativeRetryTimeout << " seconds";
222
223 core::timer::Timer::singleshotTimer(
224 [config,
225 onConnect,
226 onConnected,
227 onDisconnect,
228 onStatus,
229 tries,
230 retryTimeoutScale,
231 socketContextFactory]() mutable {
232 if (config->getRetry()) {
233 SocketClient(config, socketContextFactory, onConnect, onConnected, onDisconnect)
234 .realConnect(onStatus, tries + 1, retryTimeoutScale * config->getRetryBase());
235 } else {
236 LOG(INFO) << config->getInstanceName() << ": Retry connect disabled during wait";
237 }
238 },
239 relativeRetryTimeout);
240 }
241 },
242 Super::config);
243 }
244 }
core::socket::stream::SocketClient::SocketAddress
typename SocketConnector::SocketAddress SocketAddress
Definition SocketClient.h:82
core::timer::Timer::singleshotTimer
static Timer singleshotTimer(const std::function< void()> &dispatcher, const utils::Timeval &timeout)
Definition Timer.cpp:57
utils::Random::getInRange
static double getInRange(double ll, double ul)
Definition Random.cpp:52

Referenced by core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::connect(), and core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::realConnect().

Here is the caller graph for this function:

◆ setOnConnect()

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
std::function< void(SocketConnection *)> core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::setOnConnect ( const std::function< void(SocketConnection *)> & onConnect,
bool initialize = false )
inline

Definition at line 270 of file SocketClient.h.

271 {
272 std::function<void(SocketConnection*)> oldOnConnect = this->onConnect;
273
274 this->onConnect = initialize ? onConnect : [oldOnConnect, onConnect](SocketConnection* socketConnection) {
275 oldOnConnect(socketConnection);
276 onConnect(socketConnection);
277 };
278
279 return oldOnConnect;
280 }

◆ setOnConnected()

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
std::function< void(SocketConnection *)> core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::setOnConnected ( const std::function< void(SocketConnection *)> & onConnected,
bool initialize = false )
inline

Definition at line 286 of file SocketClient.h.

287 {
288 std::function<void(SocketConnection*)> oldOnConnected = this->onConnected;
289
290 this->onConnected = initialize ? onConnected : [oldOnConnected, onConnected](SocketConnection* socketConnection) {
291 oldOnConnected(socketConnection);
292 onConnected(socketConnection);
293 };
294
295 return oldOnConnected;
296 }

◆ setOnDisconnect()

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
std::function< void(SocketConnection *)> core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::setOnDisconnect ( const std::function< void(SocketConnection *)> & onDisconnect,
bool initialize = false )
inline

Definition at line 302 of file SocketClient.h.

303 {
304 std::function<void(SocketConnection*)> oldOnDisconnect = this->onDisconnect;
305
306 this->onDisconnect = initialize ? onDisconnect : [oldOnDisconnect, onDisconnect](SocketConnection* socketConnection) {
307 oldOnDisconnect(socketConnection);
308 onDisconnect(socketConnection);
309 };
310
311 return oldOnDisconnect;
312 }

Member Data Documentation

◆ onConnect

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
std::function<void(SocketConnection*)> core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::onConnect
private

Definition at line 321 of file SocketClient.h.

Referenced by core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::getOnConnect(), core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::realConnect(), core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::setOnConnect(), core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::SocketClient(), and core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::SocketClient().

◆ onConnected

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
std::function<void(SocketConnection*)> core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::onConnected
private

Definition at line 322 of file SocketClient.h.

Referenced by core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::getOnConnected(), core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::realConnect(), core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::setOnConnected(), and core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::SocketClient().

◆ onDisconnect

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
std::function<void(SocketConnection*)> core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::onDisconnect
private

Definition at line 323 of file SocketClient.h.

Referenced by core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::getOnDisconnect(), core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::setOnDisconnect(), and core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::SocketClient().

◆ socketContextFactory

template<typename SocketConnectorT, typename SocketContextFactoryT, typename... Args>
const std::shared_ptr<SocketContextFactory> core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::socketContextFactory
private

Definition at line 319 of file SocketClient.h.

Referenced by core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::getSocketContextFactory(), core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::realConnect(), core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::SocketClient(), and core::socket::stream::SocketClient< SocketConnectorT< net::in6::phy::stream::PhysicalSocketClient, ConfigSocketClientT >, SocketContextFactoryT, Args... >::SocketClient().

The documentation for this class was generated from the following file: