udp.cpp 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673
  1. //
  2. // udp.cpp
  3. // ~~~~~~~
  4. //
  5. // Copyright (c) 2003-2019 Christopher M. Kohlhoff (chris at kohlhoff dot com)
  6. //
  7. // Distributed under the Boost Software License, Version 1.0. (See accompanying
  8. // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
  9. //
  10. // Disable autolinking for unit tests.
  11. #if !defined(BOOST_ALL_NO_LIB)
  12. #define BOOST_ALL_NO_LIB 1
  13. #endif // !defined(BOOST_ALL_NO_LIB)
  14. // Test that header file is self-contained.
  15. #include <boost/asio/ip/udp.hpp>
  16. #include <cstring>
  17. #include <boost/asio/io_context.hpp>
  18. #include "../unit_test.hpp"
  19. #include "../archetypes/async_result.hpp"
  20. #include "../archetypes/gettable_socket_option.hpp"
  21. #include "../archetypes/io_control_command.hpp"
  22. #include "../archetypes/settable_socket_option.hpp"
  23. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  24. # include <boost/bind.hpp>
  25. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  26. # include <functional>
  27. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  28. //------------------------------------------------------------------------------
  29. // ip_udp_socket_compile test
  30. // ~~~~~~~~~~~~~~~~~~~~~~~~~~
  31. // The following test checks that all public member functions on the class
  32. // ip::udp::socket compile and link correctly. Runtime failures are ignored.
  33. namespace ip_udp_socket_compile {
  34. struct connect_handler
  35. {
  36. connect_handler() {}
  37. void operator()(const boost::system::error_code&) {}
  38. #if defined(BOOST_ASIO_HAS_MOVE)
  39. connect_handler(connect_handler&&) {}
  40. private:
  41. connect_handler(const connect_handler&);
  42. #endif // defined(BOOST_ASIO_HAS_MOVE)
  43. };
  44. struct wait_handler
  45. {
  46. wait_handler() {}
  47. void operator()(const boost::system::error_code&) {}
  48. #if defined(BOOST_ASIO_HAS_MOVE)
  49. wait_handler(wait_handler&&) {}
  50. private:
  51. wait_handler(const wait_handler&);
  52. #endif // defined(BOOST_ASIO_HAS_MOVE)
  53. };
  54. struct send_handler
  55. {
  56. send_handler() {}
  57. void operator()(const boost::system::error_code&, std::size_t) {}
  58. #if defined(BOOST_ASIO_HAS_MOVE)
  59. send_handler(send_handler&&) {}
  60. private:
  61. send_handler(const send_handler&);
  62. #endif // defined(BOOST_ASIO_HAS_MOVE)
  63. };
  64. struct receive_handler
  65. {
  66. receive_handler() {}
  67. void operator()(const boost::system::error_code&, std::size_t) {}
  68. #if defined(BOOST_ASIO_HAS_MOVE)
  69. receive_handler(receive_handler&&) {}
  70. private:
  71. receive_handler(const receive_handler&);
  72. #endif // defined(BOOST_ASIO_HAS_MOVE)
  73. };
  74. void test()
  75. {
  76. using namespace boost::asio;
  77. namespace ip = boost::asio::ip;
  78. try
  79. {
  80. io_context ioc;
  81. const io_context::executor_type ioc_ex = ioc.get_executor();
  82. char mutable_char_buffer[128] = "";
  83. const char const_char_buffer[128] = "";
  84. socket_base::message_flags in_flags = 0;
  85. archetypes::settable_socket_option<void> settable_socket_option1;
  86. archetypes::settable_socket_option<int> settable_socket_option2;
  87. archetypes::settable_socket_option<double> settable_socket_option3;
  88. archetypes::gettable_socket_option<void> gettable_socket_option1;
  89. archetypes::gettable_socket_option<int> gettable_socket_option2;
  90. archetypes::gettable_socket_option<double> gettable_socket_option3;
  91. archetypes::io_control_command io_control_command;
  92. archetypes::lazy_handler lazy;
  93. boost::system::error_code ec;
  94. // basic_datagram_socket constructors.
  95. ip::udp::socket socket1(ioc);
  96. ip::udp::socket socket2(ioc, ip::udp::v4());
  97. ip::udp::socket socket3(ioc, ip::udp::v6());
  98. ip::udp::socket socket4(ioc, ip::udp::endpoint(ip::udp::v4(), 0));
  99. ip::udp::socket socket5(ioc, ip::udp::endpoint(ip::udp::v6(), 0));
  100. #if !defined(BOOST_ASIO_WINDOWS_RUNTIME)
  101. ip::udp::socket::native_handle_type native_socket1
  102. = ::socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
  103. ip::udp::socket socket6(ioc, ip::udp::v4(), native_socket1);
  104. #endif // !defined(BOOST_ASIO_WINDOWS_RUNTIME)
  105. ip::udp::socket socket7(ioc_ex);
  106. ip::udp::socket socket8(ioc_ex, ip::udp::v4());
  107. ip::udp::socket socket9(ioc_ex, ip::udp::v6());
  108. ip::udp::socket socket10(ioc_ex, ip::udp::endpoint(ip::udp::v4(), 0));
  109. ip::udp::socket socket11(ioc_ex, ip::udp::endpoint(ip::udp::v6(), 0));
  110. #if !defined(BOOST_ASIO_WINDOWS_RUNTIME)
  111. ip::udp::socket::native_handle_type native_socket2
  112. = ::socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
  113. ip::udp::socket socket12(ioc_ex, ip::udp::v4(), native_socket2);
  114. #endif // !defined(BOOST_ASIO_WINDOWS_RUNTIME)
  115. #if defined(BOOST_ASIO_HAS_MOVE)
  116. ip::udp::socket socket13(std::move(socket6));
  117. #endif // defined(BOOST_ASIO_HAS_MOVE)
  118. // basic_datagram_socket operators.
  119. #if defined(BOOST_ASIO_HAS_MOVE)
  120. socket1 = ip::udp::socket(ioc);
  121. socket1 = std::move(socket2);
  122. #endif // defined(BOOST_ASIO_HAS_MOVE)
  123. // basic_io_object functions.
  124. ip::udp::socket::executor_type ex = socket1.get_executor();
  125. (void)ex;
  126. // basic_socket functions.
  127. ip::udp::socket::lowest_layer_type& lowest_layer = socket1.lowest_layer();
  128. (void)lowest_layer;
  129. const ip::udp::socket& socket14 = socket1;
  130. const ip::udp::socket::lowest_layer_type& lowest_layer2
  131. = socket14.lowest_layer();
  132. (void)lowest_layer2;
  133. socket1.open(ip::udp::v4());
  134. socket1.open(ip::udp::v6());
  135. socket1.open(ip::udp::v4(), ec);
  136. socket1.open(ip::udp::v6(), ec);
  137. #if !defined(BOOST_ASIO_WINDOWS_RUNTIME)
  138. ip::udp::socket::native_handle_type native_socket3
  139. = ::socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
  140. socket1.assign(ip::udp::v4(), native_socket3);
  141. ip::udp::socket::native_handle_type native_socket4
  142. = ::socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
  143. socket1.assign(ip::udp::v4(), native_socket4, ec);
  144. #endif // !defined(BOOST_ASIO_WINDOWS_RUNTIME)
  145. bool is_open = socket1.is_open();
  146. (void)is_open;
  147. socket1.close();
  148. socket1.close(ec);
  149. socket1.release();
  150. socket1.release(ec);
  151. ip::udp::socket::native_handle_type native_socket5
  152. = socket1.native_handle();
  153. (void)native_socket5;
  154. socket1.cancel();
  155. socket1.cancel(ec);
  156. bool at_mark1 = socket1.at_mark();
  157. (void)at_mark1;
  158. bool at_mark2 = socket1.at_mark(ec);
  159. (void)at_mark2;
  160. std::size_t available1 = socket1.available();
  161. (void)available1;
  162. std::size_t available2 = socket1.available(ec);
  163. (void)available2;
  164. socket1.bind(ip::udp::endpoint(ip::udp::v4(), 0));
  165. socket1.bind(ip::udp::endpoint(ip::udp::v6(), 0));
  166. socket1.bind(ip::udp::endpoint(ip::udp::v4(), 0), ec);
  167. socket1.bind(ip::udp::endpoint(ip::udp::v6(), 0), ec);
  168. socket1.connect(ip::udp::endpoint(ip::udp::v4(), 0));
  169. socket1.connect(ip::udp::endpoint(ip::udp::v6(), 0));
  170. socket1.connect(ip::udp::endpoint(ip::udp::v4(), 0), ec);
  171. socket1.connect(ip::udp::endpoint(ip::udp::v6(), 0), ec);
  172. socket1.async_connect(ip::udp::endpoint(ip::udp::v4(), 0),
  173. connect_handler());
  174. socket1.async_connect(ip::udp::endpoint(ip::udp::v6(), 0),
  175. connect_handler());
  176. int i1 = socket1.async_connect(ip::udp::endpoint(ip::udp::v4(), 0), lazy);
  177. (void)i1;
  178. int i2 = socket1.async_connect(ip::udp::endpoint(ip::udp::v6(), 0), lazy);
  179. (void)i2;
  180. socket1.set_option(settable_socket_option1);
  181. socket1.set_option(settable_socket_option1, ec);
  182. socket1.set_option(settable_socket_option2);
  183. socket1.set_option(settable_socket_option2, ec);
  184. socket1.set_option(settable_socket_option3);
  185. socket1.set_option(settable_socket_option3, ec);
  186. socket1.get_option(gettable_socket_option1);
  187. socket1.get_option(gettable_socket_option1, ec);
  188. socket1.get_option(gettable_socket_option2);
  189. socket1.get_option(gettable_socket_option2, ec);
  190. socket1.get_option(gettable_socket_option3);
  191. socket1.get_option(gettable_socket_option3, ec);
  192. socket1.io_control(io_control_command);
  193. socket1.io_control(io_control_command, ec);
  194. bool non_blocking1 = socket1.non_blocking();
  195. (void)non_blocking1;
  196. socket1.non_blocking(true);
  197. socket1.non_blocking(false, ec);
  198. bool non_blocking2 = socket1.native_non_blocking();
  199. (void)non_blocking2;
  200. socket1.native_non_blocking(true);
  201. socket1.native_non_blocking(false, ec);
  202. ip::udp::endpoint endpoint1 = socket1.local_endpoint();
  203. (void)endpoint1;
  204. ip::udp::endpoint endpoint2 = socket1.local_endpoint(ec);
  205. (void)endpoint2;
  206. ip::udp::endpoint endpoint3 = socket1.remote_endpoint();
  207. (void)endpoint3;
  208. ip::udp::endpoint endpoint4 = socket1.remote_endpoint(ec);
  209. (void)endpoint4;
  210. socket1.shutdown(socket_base::shutdown_both);
  211. socket1.shutdown(socket_base::shutdown_both, ec);
  212. socket1.wait(socket_base::wait_read);
  213. socket1.wait(socket_base::wait_write, ec);
  214. socket1.async_wait(socket_base::wait_read, wait_handler());
  215. int i3 = socket1.async_wait(socket_base::wait_write, lazy);
  216. (void)i3;
  217. // basic_datagram_socket functions.
  218. socket1.send(buffer(mutable_char_buffer));
  219. socket1.send(buffer(const_char_buffer));
  220. socket1.send(null_buffers());
  221. socket1.send(buffer(mutable_char_buffer), in_flags);
  222. socket1.send(buffer(const_char_buffer), in_flags);
  223. socket1.send(null_buffers(), in_flags);
  224. socket1.send(buffer(mutable_char_buffer), in_flags, ec);
  225. socket1.send(buffer(const_char_buffer), in_flags, ec);
  226. socket1.send(null_buffers(), in_flags, ec);
  227. socket1.async_send(buffer(mutable_char_buffer), send_handler());
  228. socket1.async_send(buffer(const_char_buffer), send_handler());
  229. socket1.async_send(null_buffers(), send_handler());
  230. socket1.async_send(buffer(mutable_char_buffer), in_flags, send_handler());
  231. socket1.async_send(buffer(const_char_buffer), in_flags, send_handler());
  232. socket1.async_send(null_buffers(), in_flags, send_handler());
  233. int i4 = socket1.async_send(buffer(mutable_char_buffer), lazy);
  234. (void)i4;
  235. int i5 = socket1.async_send(buffer(const_char_buffer), lazy);
  236. (void)i5;
  237. int i6 = socket1.async_send(null_buffers(), lazy);
  238. (void)i6;
  239. int i7 = socket1.async_send(buffer(mutable_char_buffer), in_flags, lazy);
  240. (void)i7;
  241. int i8 = socket1.async_send(buffer(const_char_buffer), in_flags, lazy);
  242. (void)i8;
  243. int i9 = socket1.async_send(null_buffers(), in_flags, lazy);
  244. (void)i9;
  245. socket1.send_to(buffer(mutable_char_buffer),
  246. ip::udp::endpoint(ip::udp::v4(), 0));
  247. socket1.send_to(buffer(mutable_char_buffer),
  248. ip::udp::endpoint(ip::udp::v6(), 0));
  249. socket1.send_to(buffer(const_char_buffer),
  250. ip::udp::endpoint(ip::udp::v4(), 0));
  251. socket1.send_to(buffer(const_char_buffer),
  252. ip::udp::endpoint(ip::udp::v6(), 0));
  253. socket1.send_to(null_buffers(),
  254. ip::udp::endpoint(ip::udp::v4(), 0));
  255. socket1.send_to(null_buffers(),
  256. ip::udp::endpoint(ip::udp::v6(), 0));
  257. socket1.send_to(buffer(mutable_char_buffer),
  258. ip::udp::endpoint(ip::udp::v4(), 0), in_flags);
  259. socket1.send_to(buffer(mutable_char_buffer),
  260. ip::udp::endpoint(ip::udp::v6(), 0), in_flags);
  261. socket1.send_to(buffer(const_char_buffer),
  262. ip::udp::endpoint(ip::udp::v4(), 0), in_flags);
  263. socket1.send_to(buffer(const_char_buffer),
  264. ip::udp::endpoint(ip::udp::v6(), 0), in_flags);
  265. socket1.send_to(null_buffers(),
  266. ip::udp::endpoint(ip::udp::v4(), 0), in_flags);
  267. socket1.send_to(null_buffers(),
  268. ip::udp::endpoint(ip::udp::v6(), 0), in_flags);
  269. socket1.send_to(buffer(mutable_char_buffer),
  270. ip::udp::endpoint(ip::udp::v4(), 0), in_flags, ec);
  271. socket1.send_to(buffer(mutable_char_buffer),
  272. ip::udp::endpoint(ip::udp::v6(), 0), in_flags, ec);
  273. socket1.send_to(buffer(const_char_buffer),
  274. ip::udp::endpoint(ip::udp::v4(), 0), in_flags, ec);
  275. socket1.send_to(buffer(const_char_buffer),
  276. ip::udp::endpoint(ip::udp::v6(), 0), in_flags, ec);
  277. socket1.send_to(null_buffers(),
  278. ip::udp::endpoint(ip::udp::v4(), 0), in_flags, ec);
  279. socket1.send_to(null_buffers(),
  280. ip::udp::endpoint(ip::udp::v6(), 0), in_flags, ec);
  281. socket1.async_send_to(buffer(mutable_char_buffer),
  282. ip::udp::endpoint(ip::udp::v4(), 0), send_handler());
  283. socket1.async_send_to(buffer(mutable_char_buffer),
  284. ip::udp::endpoint(ip::udp::v6(), 0), send_handler());
  285. socket1.async_send_to(buffer(const_char_buffer),
  286. ip::udp::endpoint(ip::udp::v4(), 0), send_handler());
  287. socket1.async_send_to(buffer(const_char_buffer),
  288. ip::udp::endpoint(ip::udp::v6(), 0), send_handler());
  289. socket1.async_send_to(null_buffers(),
  290. ip::udp::endpoint(ip::udp::v4(), 0), send_handler());
  291. socket1.async_send_to(null_buffers(),
  292. ip::udp::endpoint(ip::udp::v6(), 0), send_handler());
  293. socket1.async_send_to(buffer(mutable_char_buffer),
  294. ip::udp::endpoint(ip::udp::v4(), 0), in_flags, send_handler());
  295. socket1.async_send_to(buffer(mutable_char_buffer),
  296. ip::udp::endpoint(ip::udp::v6(), 0), in_flags, send_handler());
  297. socket1.async_send_to(buffer(const_char_buffer),
  298. ip::udp::endpoint(ip::udp::v4(), 0), in_flags, send_handler());
  299. socket1.async_send_to(buffer(const_char_buffer),
  300. ip::udp::endpoint(ip::udp::v6(), 0), in_flags, send_handler());
  301. socket1.async_send_to(null_buffers(),
  302. ip::udp::endpoint(ip::udp::v4(), 0), in_flags, send_handler());
  303. socket1.async_send_to(null_buffers(),
  304. ip::udp::endpoint(ip::udp::v6(), 0), in_flags, send_handler());
  305. int i10 = socket1.async_send_to(buffer(mutable_char_buffer),
  306. ip::udp::endpoint(ip::udp::v4(), 0), lazy);
  307. (void)i10;
  308. int i11 = socket1.async_send_to(buffer(mutable_char_buffer),
  309. ip::udp::endpoint(ip::udp::v6(), 0), lazy);
  310. (void)i11;
  311. int i12 = socket1.async_send_to(buffer(const_char_buffer),
  312. ip::udp::endpoint(ip::udp::v4(), 0), lazy);
  313. (void)i12;
  314. int i13 = socket1.async_send_to(buffer(const_char_buffer),
  315. ip::udp::endpoint(ip::udp::v6(), 0), lazy);
  316. (void)i13;
  317. int i14 = socket1.async_send_to(null_buffers(),
  318. ip::udp::endpoint(ip::udp::v4(), 0), lazy);
  319. (void)i14;
  320. int i15 = socket1.async_send_to(null_buffers(),
  321. ip::udp::endpoint(ip::udp::v6(), 0), lazy);
  322. (void)i15;
  323. int i16 = socket1.async_send_to(buffer(mutable_char_buffer),
  324. ip::udp::endpoint(ip::udp::v4(), 0), in_flags, lazy);
  325. (void)i16;
  326. int i17 = socket1.async_send_to(buffer(mutable_char_buffer),
  327. ip::udp::endpoint(ip::udp::v6(), 0), in_flags, lazy);
  328. (void)i17;
  329. int i18 = socket1.async_send_to(buffer(const_char_buffer),
  330. ip::udp::endpoint(ip::udp::v4(), 0), in_flags, lazy);
  331. (void)i18;
  332. int i19 = socket1.async_send_to(buffer(const_char_buffer),
  333. ip::udp::endpoint(ip::udp::v6(), 0), in_flags, lazy);
  334. (void)i19;
  335. int i20 = socket1.async_send_to(null_buffers(),
  336. ip::udp::endpoint(ip::udp::v4(), 0), in_flags, lazy);
  337. (void)i20;
  338. int i21 = socket1.async_send_to(null_buffers(),
  339. ip::udp::endpoint(ip::udp::v6(), 0), in_flags, lazy);
  340. (void)i21;
  341. socket1.receive(buffer(mutable_char_buffer));
  342. socket1.receive(null_buffers());
  343. socket1.receive(buffer(mutable_char_buffer), in_flags);
  344. socket1.receive(null_buffers(), in_flags);
  345. socket1.receive(buffer(mutable_char_buffer), in_flags, ec);
  346. socket1.receive(null_buffers(), in_flags, ec);
  347. socket1.async_receive(buffer(mutable_char_buffer), receive_handler());
  348. socket1.async_receive(null_buffers(), receive_handler());
  349. socket1.async_receive(buffer(mutable_char_buffer), in_flags,
  350. receive_handler());
  351. socket1.async_receive(null_buffers(), in_flags, receive_handler());
  352. int i22 = socket1.async_receive(buffer(mutable_char_buffer), lazy);
  353. (void)i22;
  354. int i23 = socket1.async_receive(null_buffers(), lazy);
  355. (void)i23;
  356. int i24 = socket1.async_receive(buffer(mutable_char_buffer),
  357. in_flags, lazy);
  358. (void)i24;
  359. int i25 = socket1.async_receive(null_buffers(), in_flags, lazy);
  360. (void)i25;
  361. ip::udp::endpoint endpoint;
  362. socket1.receive_from(buffer(mutable_char_buffer), endpoint);
  363. socket1.receive_from(null_buffers(), endpoint);
  364. socket1.receive_from(buffer(mutable_char_buffer), endpoint, in_flags);
  365. socket1.receive_from(null_buffers(), endpoint, in_flags);
  366. socket1.receive_from(buffer(mutable_char_buffer), endpoint, in_flags, ec);
  367. socket1.receive_from(null_buffers(), endpoint, in_flags, ec);
  368. socket1.async_receive_from(buffer(mutable_char_buffer),
  369. endpoint, receive_handler());
  370. socket1.async_receive_from(null_buffers(),
  371. endpoint, receive_handler());
  372. socket1.async_receive_from(buffer(mutable_char_buffer),
  373. endpoint, in_flags, receive_handler());
  374. socket1.async_receive_from(null_buffers(),
  375. endpoint, in_flags, receive_handler());
  376. int i26 = socket1.async_receive_from(buffer(mutable_char_buffer),
  377. endpoint, lazy);
  378. (void)i26;
  379. int i27 = socket1.async_receive_from(null_buffers(),
  380. endpoint, lazy);
  381. (void)i27;
  382. int i28 = socket1.async_receive_from(buffer(mutable_char_buffer),
  383. endpoint, in_flags, lazy);
  384. (void)i28;
  385. int i29 = socket1.async_receive_from(null_buffers(),
  386. endpoint, in_flags, lazy);
  387. (void)i29;
  388. }
  389. catch (std::exception&)
  390. {
  391. }
  392. }
  393. } // namespace ip_udp_socket_compile
  394. //------------------------------------------------------------------------------
  395. // ip_udp_socket_runtime test
  396. // ~~~~~~~~~~~~~~~~~~~~~~~~~~
  397. // The following test checks the runtime operation of the ip::udp::socket class.
  398. namespace ip_udp_socket_runtime {
  399. void handle_send(size_t expected_bytes_sent,
  400. const boost::system::error_code& err, size_t bytes_sent)
  401. {
  402. BOOST_ASIO_CHECK(!err);
  403. BOOST_ASIO_CHECK(expected_bytes_sent == bytes_sent);
  404. }
  405. void handle_recv(size_t expected_bytes_recvd,
  406. const boost::system::error_code& err, size_t bytes_recvd)
  407. {
  408. BOOST_ASIO_CHECK(!err);
  409. BOOST_ASIO_CHECK(expected_bytes_recvd == bytes_recvd);
  410. }
  411. void test()
  412. {
  413. using namespace std; // For memcmp and memset.
  414. using namespace boost::asio;
  415. namespace ip = boost::asio::ip;
  416. #if defined(BOOST_ASIO_HAS_BOOST_BIND)
  417. namespace bindns = boost;
  418. #else // defined(BOOST_ASIO_HAS_BOOST_BIND)
  419. namespace bindns = std;
  420. using std::placeholders::_1;
  421. using std::placeholders::_2;
  422. #endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
  423. io_context ioc;
  424. ip::udp::socket s1(ioc, ip::udp::endpoint(ip::udp::v4(), 0));
  425. ip::udp::endpoint target_endpoint = s1.local_endpoint();
  426. target_endpoint.address(ip::address_v4::loopback());
  427. ip::udp::socket s2(ioc);
  428. s2.open(ip::udp::v4());
  429. s2.bind(ip::udp::endpoint(ip::udp::v4(), 0));
  430. char send_msg[] = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz";
  431. s2.send_to(buffer(send_msg, sizeof(send_msg)), target_endpoint);
  432. char recv_msg[sizeof(send_msg)];
  433. ip::udp::endpoint sender_endpoint;
  434. size_t bytes_recvd = s1.receive_from(buffer(recv_msg, sizeof(recv_msg)),
  435. sender_endpoint);
  436. BOOST_ASIO_CHECK(bytes_recvd == sizeof(send_msg));
  437. BOOST_ASIO_CHECK(memcmp(send_msg, recv_msg, sizeof(send_msg)) == 0);
  438. memset(recv_msg, 0, sizeof(recv_msg));
  439. target_endpoint = sender_endpoint;
  440. s1.async_send_to(buffer(send_msg, sizeof(send_msg)), target_endpoint,
  441. bindns::bind(handle_send, sizeof(send_msg), _1, _2));
  442. s2.async_receive_from(buffer(recv_msg, sizeof(recv_msg)), sender_endpoint,
  443. bindns::bind(handle_recv, sizeof(recv_msg), _1, _2));
  444. ioc.run();
  445. BOOST_ASIO_CHECK(memcmp(send_msg, recv_msg, sizeof(send_msg)) == 0);
  446. }
  447. } // namespace ip_udp_socket_runtime
  448. //------------------------------------------------------------------------------
  449. // ip_udp_resolver_compile test
  450. // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  451. // The following test checks that all public member functions on the class
  452. // ip::udp::resolver compile and link correctly. Runtime failures are ignored.
  453. namespace ip_udp_resolver_compile {
  454. struct resolve_handler
  455. {
  456. resolve_handler() {}
  457. void operator()(const boost::system::error_code&,
  458. boost::asio::ip::udp::resolver::results_type) {}
  459. #if defined(BOOST_ASIO_HAS_MOVE)
  460. resolve_handler(resolve_handler&&) {}
  461. private:
  462. resolve_handler(const resolve_handler&);
  463. #endif // defined(BOOST_ASIO_HAS_MOVE)
  464. };
  465. void test()
  466. {
  467. using namespace boost::asio;
  468. namespace ip = boost::asio::ip;
  469. try
  470. {
  471. io_context ioc;
  472. const io_context::executor_type ioc_ex = ioc.get_executor();
  473. archetypes::lazy_handler lazy;
  474. boost::system::error_code ec;
  475. #if !defined(BOOST_ASIO_NO_DEPRECATED)
  476. ip::udp::resolver::query q(ip::udp::v4(), "localhost", "0");
  477. #endif // !defined(BOOST_ASIO_NO_DEPRECATED)
  478. ip::udp::endpoint e(ip::address_v4::loopback(), 0);
  479. // basic_resolver constructors.
  480. ip::udp::resolver resolver(ioc);
  481. ip::udp::resolver resolver2(ioc_ex);
  482. #if defined(BOOST_ASIO_HAS_MOVE)
  483. ip::udp::resolver resolver3(std::move(resolver));
  484. #endif // defined(BOOST_ASIO_HAS_MOVE)
  485. // basic_resolver operators.
  486. #if defined(BOOST_ASIO_HAS_MOVE)
  487. resolver = ip::udp::resolver(ioc);
  488. resolver = std::move(resolver3);
  489. #endif // defined(BOOST_ASIO_HAS_MOVE)
  490. // basic_io_object functions.
  491. ip::udp::resolver::executor_type ex = resolver.get_executor();
  492. (void)ex;
  493. // basic_resolver functions.
  494. resolver.cancel();
  495. #if !defined(BOOST_ASIO_NO_DEPRECATED)
  496. ip::udp::resolver::results_type results1 = resolver.resolve(q);
  497. (void)results1;
  498. ip::udp::resolver::results_type results2 = resolver.resolve(q, ec);
  499. (void)results2;
  500. #endif // !defined(BOOST_ASIO_NO_DEPRECATED)
  501. ip::udp::resolver::results_type results3 = resolver.resolve("", "");
  502. (void)results3;
  503. ip::udp::resolver::results_type results4 = resolver.resolve("", "", ec);
  504. (void)results4;
  505. ip::udp::resolver::results_type results5 =
  506. resolver.resolve("", "", ip::udp::resolver::flags());
  507. (void)results5;
  508. ip::udp::resolver::results_type results6 =
  509. resolver.resolve("", "", ip::udp::resolver::flags(), ec);
  510. (void)results6;
  511. ip::udp::resolver::results_type results7 =
  512. resolver.resolve(ip::udp::v4(), "", "");
  513. (void)results7;
  514. ip::udp::resolver::results_type results8 =
  515. resolver.resolve(ip::udp::v4(), "", "", ec);
  516. (void)results8;
  517. ip::udp::resolver::results_type results9 =
  518. resolver.resolve(ip::udp::v4(), "", "", ip::udp::resolver::flags());
  519. (void)results9;
  520. ip::udp::resolver::results_type results10 =
  521. resolver.resolve(ip::udp::v4(), "", "", ip::udp::resolver::flags(), ec);
  522. (void)results10;
  523. ip::udp::resolver::results_type results11 = resolver.resolve(e);
  524. (void)results11;
  525. ip::udp::resolver::results_type results12 = resolver.resolve(e, ec);
  526. (void)results12;
  527. #if !defined(BOOST_ASIO_NO_DEPRECATED)
  528. resolver.async_resolve(q, resolve_handler());
  529. int i1 = resolver.async_resolve(q, lazy);
  530. (void)i1;
  531. #endif // !defined(BOOST_ASIO_NO_DEPRECATED)
  532. resolver.async_resolve("", "", resolve_handler());
  533. int i2 = resolver.async_resolve("", "", lazy);
  534. (void)i2;
  535. resolver.async_resolve("", "",
  536. ip::udp::resolver::flags(), resolve_handler());
  537. int i3 = resolver.async_resolve("", "",
  538. ip::udp::resolver::flags(), lazy);
  539. (void)i3;
  540. resolver.async_resolve(ip::udp::v4(), "", "", resolve_handler());
  541. int i4 = resolver.async_resolve(ip::udp::v4(), "", "", lazy);
  542. (void)i4;
  543. resolver.async_resolve(ip::udp::v4(),
  544. "", "", ip::udp::resolver::flags(), resolve_handler());
  545. int i5 = resolver.async_resolve(ip::udp::v4(),
  546. "", "", ip::udp::resolver::flags(), lazy);
  547. (void)i5;
  548. resolver.async_resolve(e, resolve_handler());
  549. int i6 = resolver.async_resolve(e, lazy);
  550. (void)i6;
  551. }
  552. catch (std::exception&)
  553. {
  554. }
  555. }
  556. } // namespace ip_udp_resolver_compile
  557. //------------------------------------------------------------------------------
  558. BOOST_ASIO_TEST_SUITE
  559. (
  560. "ip/udp",
  561. BOOST_ASIO_TEST_CASE(ip_udp_socket_compile::test)
  562. BOOST_ASIO_TEST_CASE(ip_udp_socket_runtime::test)
  563. BOOST_ASIO_TEST_CASE(ip_udp_resolver_compile::test)
  564. )