31 {
33
34 using SocketClient = apps::echo::model::STREAM::EchoSocketClient;
36 const SocketClient client = apps::echo::model::STREAM::getClient();
37
38 client.connect(
39 [instanceName = client.getConfig().getInstanceName()](
const SocketAddress& socketAddress,
const core::socket::State& state) {
40 switch (state) {
41 case core::socket::State::OK:
42 VLOG(1) << instanceName << ": connected to '" << socketAddress.toString() << "'";
43 break;
44 case core::socket::State::DISABLED:
45 VLOG(1) << instanceName << ": disabled";
46 break;
47 case core::socket::State::ERROR:
48 LOG(ERROR) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
49 break;
50 case core::socket::State::FATAL:
51 LOG(FATAL) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
52 break;
53 }
54 });
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
74}
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