309 {
311
312 {
314
316
317 legacyClient.
connect(legacyRemoteAddress,
318 [instanceName = legacyClient.
getConfig()->getInstanceName()](
321 switch (state) {
322 case core::socket::State::OK:
323 VLOG(1) << instanceName << ": connected to '" << socketAddress.toString() << "'";
324 break;
325 case core::socket::State::DISABLED:
326 VLOG(1) << instanceName << ": disabled";
327 break;
328 case core::socket::State::ERROR:
329 LOG(ERROR) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
330 break;
331 case core::socket::State::FATAL:
332 LOG(FATAL) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
333 break;
334 }
335 });
336
338
340
341 tlsClient.
connect(tlsRemoteAddress,
342 [instanceName = tlsClient.
getConfig()->getInstanceName()](
345 switch (state) {
346 case core::socket::State::OK:
347 VLOG(1) << instanceName << ": connected to '" << socketAddress.toString() << "'";
348 break;
349 case core::socket::State::DISABLED:
350 VLOG(1) << instanceName << ": disabled";
351 break;
352 case core::socket::State::ERROR:
353 LOG(ERROR) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
354 break;
355 case core::socket::State::FATAL:
356 LOG(FATAL) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
357 break;
358 }
359 });
360 }
361
363}
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