51 {
53
54 using SocketClient = apps::echo::model::STREAM::EchoSocketClient;
56 const SocketClient client = apps::echo::model::STREAM::getClient();
57
58 client.connect(
59 [instanceName = client.getConfig()->getInstanceName()](
const SocketAddress& socketAddress,
const core::socket::State& state) {
60 switch (state) {
61 case core::socket::State::OK:
62 VLOG(1) << instanceName << ": connected to '" << socketAddress.toString() << "'";
63 break;
64 case core::socket::State::DISABLED:
65 VLOG(1) << instanceName << ": disabled";
66 break;
67 case core::socket::State::ERROR:
68 LOG(ERROR) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
69 break;
70 case core::socket::State::FATAL:
71 LOG(FATAL) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
72 break;
73 }
74 });
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
94}
static void init(int argc, char *argv[])
static int start(const utils::Timeval &timeOut={LONG_MAX, 0})
net::in::stream::tls::SocketClient< apps::http::SimpleSocketProtocolFactory > SocketClient
SocketClient::SocketAddress SocketAddress