Mercurial > code

annotate C++/examples/Socket/non-blocking-connect.cpp @ 473:5a9671dabb15

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Socket: - Fix epoll which wrongly reset flags, - Fix wrongly use of SOCKET_DEFAULT_BACKEND, - Fix error in GCC using constexpr, switch to inline, - Add more documentation about non-blocking sockets, - Remove Socket::setBlockMode, - Start updating all doxygen comments, - Put back UDP.
author David Demelier <markand@malikania.fr>
date Thu, 05 Nov 2015 22:28:40 +0100
parents 41d1a36cc461
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
458
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
1 /*
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
2 * non-blocking-connect.cpp -- example of non blocking connect
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
3 *
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
4 * Options:
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
5 * - WITH_HOST (string literal), the host to try (default: "malikania.fr")
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
6 * - WITH_PORT (int), the port to use (default: 80)
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
7 * - WITH_TIMEOUT (int), number of seconds before giving up (default: 30)
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
8 * - WITH_SSL (bool), true to test with SSL (default: false)
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
9 */
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
10
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
11 #include <iostream>
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
12
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
13 #if !defined(WITH_HOST)
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
14 # define WITH_HOST "malikania.fr"
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
15 #endif
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
16
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
17 #if !defined(WITH_PORT)
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
18 # define WITH_PORT 80
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
19 #endif
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
20
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
21 #if !defined(WITH_TIMEOUT)
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
22 # define WITH_TIMEOUT 30
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
23 #endif
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
24
461
41d1a36cc461 Socket:
David Demelier <markand@malikania.fr>
parents: 459
diff changeset
25 #include "ElapsedTimer.h"
458
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
26 #include "Sockets.h"
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
27
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
28 int main()
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
29 {
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
30 #if defined(WITH_SSL)
473
5a9671dabb15 Socket:
David Demelier <markand@malikania.fr>
parents: 461
diff changeset
31 net::SocketTls<net::address::Ip> socket;
458
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
32 #else
473
5a9671dabb15 Socket:
David Demelier <markand@malikania.fr>
parents: 461
diff changeset
33 net::SocketTcp<net::address::Ip> socket;
458
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
34 #endif
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
35
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
36 net::Listener<> listener;
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
37 ElapsedTimer timer;
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
38
473
5a9671dabb15 Socket:
David Demelier <markand@malikania.fr>
parents: 461
diff changeset
39 // 1. Set to non-blocking.
5a9671dabb15 Socket:
David Demelier <markand@malikania.fr>
parents: 461
diff changeset
40 socket.set(net::option::SockBlockMode{false});
458
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
41
459
819bccefce8e Socket:
David Demelier <markand@malikania.fr>
parents: 458
diff changeset
42 try {
819bccefce8e Socket:
David Demelier <markand@malikania.fr>
parents: 458
diff changeset
43 std::cout << "Trying to connect to " << WITH_HOST << ":" << WITH_PORT << std::endl;
473
5a9671dabb15 Socket:
David Demelier <markand@malikania.fr>
parents: 461
diff changeset
44
5a9671dabb15 Socket:
David Demelier <markand@malikania.fr>
parents: 461
diff changeset
45 // 2. Initial connection process.
5a9671dabb15 Socket:
David Demelier <markand@malikania.fr>
parents: 461
diff changeset
46 socket.connect(net::address::Ip{WITH_HOST, WITH_PORT});
459
819bccefce8e Socket:
David Demelier <markand@malikania.fr>
parents: 458
diff changeset
47
819bccefce8e Socket:
David Demelier <markand@malikania.fr>
parents: 458
diff changeset
48 while (socket.state() != net::State::Connected) {
458
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
49 listener.remove(socket.handle());
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
50
473
5a9671dabb15 Socket:
David Demelier <markand@malikania.fr>
parents: 461
diff changeset
51 // 2. Now complete by waiting for the appropriate condition.
5a9671dabb15 Socket:
David Demelier <markand@malikania.fr>
parents: 461
diff changeset
52 listener.set(socket.handle(), socket.condition());
459
819bccefce8e Socket:
David Demelier <markand@malikania.fr>
parents: 458
diff changeset
53 listener.wait(std::chrono::seconds(WITH_TIMEOUT));
819bccefce8e Socket:
David Demelier <markand@malikania.fr>
parents: 458
diff changeset
54 socket.connect();
458
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
55 }
459
819bccefce8e Socket:
David Demelier <markand@malikania.fr>
parents: 458
diff changeset
56 } catch (const net::Error &error) {
473
5a9671dabb15 Socket:
David Demelier <markand@malikania.fr>
parents: 461
diff changeset
57 std::cerr << "error: " << error.what() << std::endl;
459
819bccefce8e Socket:
David Demelier <markand@malikania.fr>
parents: 458
diff changeset
58 std::exit(1);
458
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
59 }
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
60
461
41d1a36cc461 Socket:
David Demelier <markand@malikania.fr>
parents: 459
diff changeset
61 if (socket.state() == net::State::Connected) {
41d1a36cc461 Socket:
David Demelier <markand@malikania.fr>
parents: 459
diff changeset
62 std::cout << "Successfully connected!" << std::endl;
41d1a36cc461 Socket:
David Demelier <markand@malikania.fr>
parents: 459
diff changeset
63 }
458
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
64
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
65 return 0;
db738947f359 Socket:
David Demelier <markand@malikania.fr>
parents:
diff changeset
66 }