310 {
312
313 {
315
317
318 legacyClient.
connect(legacyRemoteAddress,
319 [instanceName = legacyClient.
getConfig().getInstanceName()](
322 switch (state) {
323 case core::socket::State::OK:
324 VLOG(1) << instanceName << ": connected to '" << socketAddress.toString() << "'";
325 break;
326 case core::socket::State::DISABLED:
327 VLOG(1) << instanceName << ": disabled";
328 break;
329 case core::socket::State::ERROR:
330 LOG(ERROR) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
331 break;
332 case core::socket::State::FATAL:
333 LOG(FATAL) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
334 break;
335 }
336 });
337
339
341
342 tlsClient.
connect(tlsRemoteAddress,
343 [instanceName = tlsClient.
getConfig().getInstanceName()](
346 switch (state) {
347 case core::socket::State::OK:
348 VLOG(1) << instanceName << ": connected to '" << socketAddress.toString() << "'";
349 break;
350 case core::socket::State::DISABLED:
351 VLOG(1) << instanceName << ": disabled";
352 break;
353 case core::socket::State::ERROR:
354 LOG(ERROR) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
355 break;
356 case core::socket::State::FATAL:
357 LOG(FATAL) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
358 break;
359 }
360 });
361 }
362
364}
static void init(int argc, char *argv[])
static int start(const utils::Timeval &timeOut={LONG_MAX, 0})
Config & getConfig() const
const Super & connect(const std::string &ipOrHostname, uint16_t port, const std::function< void(const SocketAddress &, core::socket::State)> &onStatus) const
net::in::stream::legacy::SocketClient< apps::http::SimpleSocketProtocolFactory > SocketClient
SocketClient::SocketAddress SocketAddress
SocketClient getLegacyClient()
net::in::stream::tls::SocketClient< apps::http::SimpleSocketProtocolFactory > SocketClient
SocketClient::SocketAddress SocketAddress