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