win_iocp_socket_service_base.ipp 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821
  1. //
  2. // detail/impl/win_iocp_socket_service_base.ipp
  3. // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  4. //
  5. // Copyright (c) 2003-2023 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. #ifndef ASIO_DETAIL_IMPL_WIN_IOCP_SOCKET_SERVICE_BASE_IPP
  11. #define ASIO_DETAIL_IMPL_WIN_IOCP_SOCKET_SERVICE_BASE_IPP
  12. #if defined(_MSC_VER) && (_MSC_VER >= 1200)
  13. # pragma once
  14. #endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
  15. #include "asio/detail/config.hpp"
  16. #if defined(ASIO_HAS_IOCP)
  17. #include "asio/detail/win_iocp_socket_service_base.hpp"
  18. #include "asio/detail/push_options.hpp"
  19. namespace asio {
  20. namespace detail {
  21. win_iocp_socket_service_base::win_iocp_socket_service_base(
  22. execution_context& context)
  23. : context_(context),
  24. iocp_service_(use_service<win_iocp_io_context>(context)),
  25. reactor_(0),
  26. connect_ex_(0),
  27. nt_set_info_(0),
  28. mutex_(),
  29. impl_list_(0)
  30. {
  31. }
  32. void win_iocp_socket_service_base::base_shutdown()
  33. {
  34. // Close all implementations, causing all operations to complete.
  35. asio::detail::mutex::scoped_lock lock(mutex_);
  36. base_implementation_type* impl = impl_list_;
  37. while (impl)
  38. {
  39. close_for_destruction(*impl);
  40. impl = impl->next_;
  41. }
  42. }
  43. void win_iocp_socket_service_base::construct(
  44. win_iocp_socket_service_base::base_implementation_type& impl)
  45. {
  46. impl.socket_ = invalid_socket;
  47. impl.state_ = 0;
  48. impl.cancel_token_.reset();
  49. #if defined(ASIO_ENABLE_CANCELIO)
  50. impl.safe_cancellation_thread_id_ = 0;
  51. #endif // defined(ASIO_ENABLE_CANCELIO)
  52. // Insert implementation into linked list of all implementations.
  53. asio::detail::mutex::scoped_lock lock(mutex_);
  54. impl.next_ = impl_list_;
  55. impl.prev_ = 0;
  56. if (impl_list_)
  57. impl_list_->prev_ = &impl;
  58. impl_list_ = &impl;
  59. }
  60. void win_iocp_socket_service_base::base_move_construct(
  61. win_iocp_socket_service_base::base_implementation_type& impl,
  62. win_iocp_socket_service_base::base_implementation_type& other_impl)
  63. noexcept
  64. {
  65. impl.socket_ = other_impl.socket_;
  66. other_impl.socket_ = invalid_socket;
  67. impl.state_ = other_impl.state_;
  68. other_impl.state_ = 0;
  69. impl.cancel_token_ = other_impl.cancel_token_;
  70. other_impl.cancel_token_.reset();
  71. #if defined(ASIO_ENABLE_CANCELIO)
  72. impl.safe_cancellation_thread_id_ = other_impl.safe_cancellation_thread_id_;
  73. other_impl.safe_cancellation_thread_id_ = 0;
  74. #endif // defined(ASIO_ENABLE_CANCELIO)
  75. // Insert implementation into linked list of all implementations.
  76. asio::detail::mutex::scoped_lock lock(mutex_);
  77. impl.next_ = impl_list_;
  78. impl.prev_ = 0;
  79. if (impl_list_)
  80. impl_list_->prev_ = &impl;
  81. impl_list_ = &impl;
  82. }
  83. void win_iocp_socket_service_base::base_move_assign(
  84. win_iocp_socket_service_base::base_implementation_type& impl,
  85. win_iocp_socket_service_base& other_service,
  86. win_iocp_socket_service_base::base_implementation_type& other_impl)
  87. {
  88. close_for_destruction(impl);
  89. if (this != &other_service)
  90. {
  91. // Remove implementation from linked list of all implementations.
  92. asio::detail::mutex::scoped_lock lock(mutex_);
  93. if (impl_list_ == &impl)
  94. impl_list_ = impl.next_;
  95. if (impl.prev_)
  96. impl.prev_->next_ = impl.next_;
  97. if (impl.next_)
  98. impl.next_->prev_= impl.prev_;
  99. impl.next_ = 0;
  100. impl.prev_ = 0;
  101. }
  102. impl.socket_ = other_impl.socket_;
  103. other_impl.socket_ = invalid_socket;
  104. impl.state_ = other_impl.state_;
  105. other_impl.state_ = 0;
  106. impl.cancel_token_ = other_impl.cancel_token_;
  107. other_impl.cancel_token_.reset();
  108. #if defined(ASIO_ENABLE_CANCELIO)
  109. impl.safe_cancellation_thread_id_ = other_impl.safe_cancellation_thread_id_;
  110. other_impl.safe_cancellation_thread_id_ = 0;
  111. #endif // defined(ASIO_ENABLE_CANCELIO)
  112. if (this != &other_service)
  113. {
  114. // Insert implementation into linked list of all implementations.
  115. asio::detail::mutex::scoped_lock lock(other_service.mutex_);
  116. impl.next_ = other_service.impl_list_;
  117. impl.prev_ = 0;
  118. if (other_service.impl_list_)
  119. other_service.impl_list_->prev_ = &impl;
  120. other_service.impl_list_ = &impl;
  121. }
  122. }
  123. void win_iocp_socket_service_base::destroy(
  124. win_iocp_socket_service_base::base_implementation_type& impl)
  125. {
  126. close_for_destruction(impl);
  127. // Remove implementation from linked list of all implementations.
  128. asio::detail::mutex::scoped_lock lock(mutex_);
  129. if (impl_list_ == &impl)
  130. impl_list_ = impl.next_;
  131. if (impl.prev_)
  132. impl.prev_->next_ = impl.next_;
  133. if (impl.next_)
  134. impl.next_->prev_= impl.prev_;
  135. impl.next_ = 0;
  136. impl.prev_ = 0;
  137. }
  138. asio::error_code win_iocp_socket_service_base::close(
  139. win_iocp_socket_service_base::base_implementation_type& impl,
  140. asio::error_code& ec)
  141. {
  142. if (is_open(impl))
  143. {
  144. ASIO_HANDLER_OPERATION((iocp_service_.context(),
  145. "socket", &impl, impl.socket_, "close"));
  146. // Check if the reactor was created, in which case we need to close the
  147. // socket on the reactor as well to cancel any operations that might be
  148. // running there.
  149. select_reactor* r = static_cast<select_reactor*>(
  150. interlocked_compare_exchange_pointer(
  151. reinterpret_cast<void**>(&reactor_), 0, 0));
  152. if (r)
  153. r->deregister_descriptor(impl.socket_, impl.reactor_data_, true);
  154. socket_ops::close(impl.socket_, impl.state_, false, ec);
  155. if (r)
  156. r->cleanup_descriptor_data(impl.reactor_data_);
  157. }
  158. else
  159. {
  160. ec = asio::error_code();
  161. }
  162. impl.socket_ = invalid_socket;
  163. impl.state_ = 0;
  164. impl.cancel_token_.reset();
  165. #if defined(ASIO_ENABLE_CANCELIO)
  166. impl.safe_cancellation_thread_id_ = 0;
  167. #endif // defined(ASIO_ENABLE_CANCELIO)
  168. return ec;
  169. }
  170. socket_type win_iocp_socket_service_base::release(
  171. win_iocp_socket_service_base::base_implementation_type& impl,
  172. asio::error_code& ec)
  173. {
  174. if (!is_open(impl))
  175. return invalid_socket;
  176. cancel(impl, ec);
  177. if (ec)
  178. return invalid_socket;
  179. nt_set_info_fn fn = get_nt_set_info();
  180. if (fn == 0)
  181. {
  182. ec = asio::error::operation_not_supported;
  183. return invalid_socket;
  184. }
  185. HANDLE sock_as_handle = reinterpret_cast<HANDLE>(impl.socket_);
  186. ULONG_PTR iosb[2] = { 0, 0 };
  187. void* info[2] = { 0, 0 };
  188. if (fn(sock_as_handle, iosb, &info, sizeof(info),
  189. 61 /* FileReplaceCompletionInformation */))
  190. {
  191. ec = asio::error::operation_not_supported;
  192. return invalid_socket;
  193. }
  194. socket_type tmp = impl.socket_;
  195. impl.socket_ = invalid_socket;
  196. return tmp;
  197. }
  198. asio::error_code win_iocp_socket_service_base::cancel(
  199. win_iocp_socket_service_base::base_implementation_type& impl,
  200. asio::error_code& ec)
  201. {
  202. if (!is_open(impl))
  203. {
  204. ec = asio::error::bad_descriptor;
  205. return ec;
  206. }
  207. ASIO_HANDLER_OPERATION((iocp_service_.context(),
  208. "socket", &impl, impl.socket_, "cancel"));
  209. if (FARPROC cancel_io_ex_ptr = ::GetProcAddress(
  210. ::GetModuleHandleA("KERNEL32"), "CancelIoEx"))
  211. {
  212. // The version of Windows supports cancellation from any thread.
  213. typedef BOOL (WINAPI* cancel_io_ex_t)(HANDLE, LPOVERLAPPED);
  214. cancel_io_ex_t cancel_io_ex = reinterpret_cast<cancel_io_ex_t>(
  215. reinterpret_cast<void*>(cancel_io_ex_ptr));
  216. socket_type sock = impl.socket_;
  217. HANDLE sock_as_handle = reinterpret_cast<HANDLE>(sock);
  218. if (!cancel_io_ex(sock_as_handle, 0))
  219. {
  220. DWORD last_error = ::GetLastError();
  221. if (last_error == ERROR_NOT_FOUND)
  222. {
  223. // ERROR_NOT_FOUND means that there were no operations to be
  224. // cancelled. We swallow this error to match the behaviour on other
  225. // platforms.
  226. ec = asio::error_code();
  227. }
  228. else
  229. {
  230. ec = asio::error_code(last_error,
  231. asio::error::get_system_category());
  232. }
  233. }
  234. else
  235. {
  236. ec = asio::error_code();
  237. }
  238. }
  239. #if defined(ASIO_ENABLE_CANCELIO)
  240. else if (impl.safe_cancellation_thread_id_ == 0)
  241. {
  242. // No operations have been started, so there's nothing to cancel.
  243. ec = asio::error_code();
  244. }
  245. else if (impl.safe_cancellation_thread_id_ == ::GetCurrentThreadId())
  246. {
  247. // Asynchronous operations have been started from the current thread only,
  248. // so it is safe to try to cancel them using CancelIo.
  249. socket_type sock = impl.socket_;
  250. HANDLE sock_as_handle = reinterpret_cast<HANDLE>(sock);
  251. if (!::CancelIo(sock_as_handle))
  252. {
  253. DWORD last_error = ::GetLastError();
  254. ec = asio::error_code(last_error,
  255. asio::error::get_system_category());
  256. }
  257. else
  258. {
  259. ec = asio::error_code();
  260. }
  261. }
  262. else
  263. {
  264. // Asynchronous operations have been started from more than one thread,
  265. // so cancellation is not safe.
  266. ec = asio::error::operation_not_supported;
  267. }
  268. #else // defined(ASIO_ENABLE_CANCELIO)
  269. else
  270. {
  271. // Cancellation is not supported as CancelIo may not be used.
  272. ec = asio::error::operation_not_supported;
  273. }
  274. #endif // defined(ASIO_ENABLE_CANCELIO)
  275. // Cancel any operations started via the reactor.
  276. if (!ec)
  277. {
  278. select_reactor* r = static_cast<select_reactor*>(
  279. interlocked_compare_exchange_pointer(
  280. reinterpret_cast<void**>(&reactor_), 0, 0));
  281. if (r)
  282. r->cancel_ops(impl.socket_, impl.reactor_data_);
  283. }
  284. return ec;
  285. }
  286. asio::error_code win_iocp_socket_service_base::do_open(
  287. win_iocp_socket_service_base::base_implementation_type& impl,
  288. int family, int type, int protocol, asio::error_code& ec)
  289. {
  290. if (is_open(impl))
  291. {
  292. ec = asio::error::already_open;
  293. return ec;
  294. }
  295. socket_holder sock(socket_ops::socket(family, type, protocol, ec));
  296. if (sock.get() == invalid_socket)
  297. return ec;
  298. HANDLE sock_as_handle = reinterpret_cast<HANDLE>(sock.get());
  299. if (iocp_service_.register_handle(sock_as_handle, ec))
  300. return ec;
  301. impl.socket_ = sock.release();
  302. switch (type)
  303. {
  304. case SOCK_STREAM: impl.state_ = socket_ops::stream_oriented; break;
  305. case SOCK_DGRAM: impl.state_ = socket_ops::datagram_oriented; break;
  306. default: impl.state_ = 0; break;
  307. }
  308. impl.cancel_token_.reset(static_cast<void*>(0), socket_ops::noop_deleter());
  309. ec = asio::error_code();
  310. return ec;
  311. }
  312. asio::error_code win_iocp_socket_service_base::do_assign(
  313. win_iocp_socket_service_base::base_implementation_type& impl,
  314. int type, socket_type native_socket, asio::error_code& ec)
  315. {
  316. if (is_open(impl))
  317. {
  318. ec = asio::error::already_open;
  319. return ec;
  320. }
  321. HANDLE sock_as_handle = reinterpret_cast<HANDLE>(native_socket);
  322. if (iocp_service_.register_handle(sock_as_handle, ec))
  323. return ec;
  324. impl.socket_ = native_socket;
  325. switch (type)
  326. {
  327. case SOCK_STREAM: impl.state_ = socket_ops::stream_oriented; break;
  328. case SOCK_DGRAM: impl.state_ = socket_ops::datagram_oriented; break;
  329. default: impl.state_ = 0; break;
  330. }
  331. impl.cancel_token_.reset(static_cast<void*>(0), socket_ops::noop_deleter());
  332. ec = asio::error_code();
  333. return ec;
  334. }
  335. void win_iocp_socket_service_base::start_send_op(
  336. win_iocp_socket_service_base::base_implementation_type& impl,
  337. WSABUF* buffers, std::size_t buffer_count,
  338. socket_base::message_flags flags, bool noop, operation* op)
  339. {
  340. update_cancellation_thread_id(impl);
  341. iocp_service_.work_started();
  342. if (noop)
  343. iocp_service_.on_completion(op);
  344. else if (!is_open(impl))
  345. iocp_service_.on_completion(op, asio::error::bad_descriptor);
  346. else
  347. {
  348. DWORD bytes_transferred = 0;
  349. int result = ::WSASend(impl.socket_, buffers,
  350. static_cast<DWORD>(buffer_count), &bytes_transferred, flags, op, 0);
  351. DWORD last_error = ::WSAGetLastError();
  352. if (last_error == ERROR_PORT_UNREACHABLE)
  353. last_error = WSAECONNREFUSED;
  354. if (result != 0 && last_error != WSA_IO_PENDING)
  355. iocp_service_.on_completion(op, last_error, bytes_transferred);
  356. else
  357. iocp_service_.on_pending(op);
  358. }
  359. }
  360. void win_iocp_socket_service_base::start_send_to_op(
  361. win_iocp_socket_service_base::base_implementation_type& impl,
  362. WSABUF* buffers, std::size_t buffer_count, const void* addr,
  363. int addrlen, socket_base::message_flags flags, operation* op)
  364. {
  365. update_cancellation_thread_id(impl);
  366. iocp_service_.work_started();
  367. if (!is_open(impl))
  368. iocp_service_.on_completion(op, asio::error::bad_descriptor);
  369. else
  370. {
  371. DWORD bytes_transferred = 0;
  372. int result = ::WSASendTo(impl.socket_, buffers,
  373. static_cast<DWORD>(buffer_count), &bytes_transferred, flags,
  374. static_cast<const socket_addr_type*>(addr), addrlen, op, 0);
  375. DWORD last_error = ::WSAGetLastError();
  376. if (last_error == ERROR_PORT_UNREACHABLE)
  377. last_error = WSAECONNREFUSED;
  378. if (result != 0 && last_error != WSA_IO_PENDING)
  379. iocp_service_.on_completion(op, last_error, bytes_transferred);
  380. else
  381. iocp_service_.on_pending(op);
  382. }
  383. }
  384. void win_iocp_socket_service_base::start_receive_op(
  385. win_iocp_socket_service_base::base_implementation_type& impl,
  386. WSABUF* buffers, std::size_t buffer_count,
  387. socket_base::message_flags flags, bool noop, operation* op)
  388. {
  389. update_cancellation_thread_id(impl);
  390. iocp_service_.work_started();
  391. if (noop)
  392. iocp_service_.on_completion(op);
  393. else if (!is_open(impl))
  394. iocp_service_.on_completion(op, asio::error::bad_descriptor);
  395. else
  396. {
  397. DWORD bytes_transferred = 0;
  398. DWORD recv_flags = flags;
  399. int result = ::WSARecv(impl.socket_, buffers,
  400. static_cast<DWORD>(buffer_count),
  401. &bytes_transferred, &recv_flags, op, 0);
  402. DWORD last_error = ::WSAGetLastError();
  403. if (last_error == ERROR_NETNAME_DELETED)
  404. last_error = WSAECONNRESET;
  405. else if (last_error == ERROR_PORT_UNREACHABLE)
  406. last_error = WSAECONNREFUSED;
  407. if (result != 0 && last_error != WSA_IO_PENDING)
  408. iocp_service_.on_completion(op, last_error, bytes_transferred);
  409. else
  410. iocp_service_.on_pending(op);
  411. }
  412. }
  413. int win_iocp_socket_service_base::start_null_buffers_receive_op(
  414. win_iocp_socket_service_base::base_implementation_type& impl,
  415. socket_base::message_flags flags, reactor_op* op, operation* iocp_op)
  416. {
  417. if ((impl.state_ & socket_ops::stream_oriented) != 0)
  418. {
  419. // For stream sockets on Windows, we may issue a 0-byte overlapped
  420. // WSARecv to wait until there is data available on the socket.
  421. ::WSABUF buf = { 0, 0 };
  422. start_receive_op(impl, &buf, 1, flags, false, iocp_op);
  423. return -1;
  424. }
  425. else
  426. {
  427. int op_type = (flags & socket_base::message_out_of_band)
  428. ? select_reactor::except_op : select_reactor::read_op;
  429. start_reactor_op(impl, op_type, op);
  430. return op_type;
  431. }
  432. }
  433. void win_iocp_socket_service_base::start_receive_from_op(
  434. win_iocp_socket_service_base::base_implementation_type& impl,
  435. WSABUF* buffers, std::size_t buffer_count, void* addr,
  436. socket_base::message_flags flags, int* addrlen, operation* op)
  437. {
  438. update_cancellation_thread_id(impl);
  439. iocp_service_.work_started();
  440. if (!is_open(impl))
  441. iocp_service_.on_completion(op, asio::error::bad_descriptor);
  442. else
  443. {
  444. DWORD bytes_transferred = 0;
  445. DWORD recv_flags = flags;
  446. int result = ::WSARecvFrom(impl.socket_, buffers,
  447. static_cast<DWORD>(buffer_count), &bytes_transferred, &recv_flags,
  448. static_cast<socket_addr_type*>(addr), addrlen, op, 0);
  449. DWORD last_error = ::WSAGetLastError();
  450. if (last_error == ERROR_PORT_UNREACHABLE)
  451. last_error = WSAECONNREFUSED;
  452. if (result != 0 && last_error != WSA_IO_PENDING)
  453. iocp_service_.on_completion(op, last_error, bytes_transferred);
  454. else
  455. iocp_service_.on_pending(op);
  456. }
  457. }
  458. void win_iocp_socket_service_base::start_accept_op(
  459. win_iocp_socket_service_base::base_implementation_type& impl,
  460. bool peer_is_open, socket_holder& new_socket, int family, int type,
  461. int protocol, void* output_buffer, DWORD address_length, operation* op)
  462. {
  463. update_cancellation_thread_id(impl);
  464. iocp_service_.work_started();
  465. if (!is_open(impl))
  466. iocp_service_.on_completion(op, asio::error::bad_descriptor);
  467. else if (peer_is_open)
  468. iocp_service_.on_completion(op, asio::error::already_open);
  469. else
  470. {
  471. asio::error_code ec;
  472. new_socket.reset(socket_ops::socket(family, type, protocol, ec));
  473. if (new_socket.get() == invalid_socket)
  474. iocp_service_.on_completion(op, ec);
  475. else
  476. {
  477. DWORD bytes_read = 0;
  478. BOOL result = ::AcceptEx(impl.socket_, new_socket.get(), output_buffer,
  479. 0, address_length, address_length, &bytes_read, op);
  480. DWORD last_error = ::WSAGetLastError();
  481. if (!result && last_error != WSA_IO_PENDING)
  482. iocp_service_.on_completion(op, last_error);
  483. else
  484. iocp_service_.on_pending(op);
  485. }
  486. }
  487. }
  488. void win_iocp_socket_service_base::restart_accept_op(
  489. socket_type s, socket_holder& new_socket, int family, int type,
  490. int protocol, void* output_buffer, DWORD address_length,
  491. long* cancel_requested, operation* op)
  492. {
  493. new_socket.reset();
  494. iocp_service_.work_started();
  495. // Check if we were cancelled after the first AcceptEx completed.
  496. if (cancel_requested)
  497. if (::InterlockedExchangeAdd(cancel_requested, 0) == 1)
  498. iocp_service_.on_completion(op, asio::error::operation_aborted);
  499. asio::error_code ec;
  500. new_socket.reset(socket_ops::socket(family, type, protocol, ec));
  501. if (new_socket.get() == invalid_socket)
  502. iocp_service_.on_completion(op, ec);
  503. else
  504. {
  505. DWORD bytes_read = 0;
  506. BOOL result = ::AcceptEx(s, new_socket.get(), output_buffer,
  507. 0, address_length, address_length, &bytes_read, op);
  508. DWORD last_error = ::WSAGetLastError();
  509. if (!result && last_error != WSA_IO_PENDING)
  510. iocp_service_.on_completion(op, last_error);
  511. else
  512. {
  513. #if defined(_WIN32_WINNT) && (_WIN32_WINNT >= 0x0600)
  514. if (cancel_requested)
  515. {
  516. if (::InterlockedExchangeAdd(cancel_requested, 0) == 1)
  517. {
  518. HANDLE sock_as_handle = reinterpret_cast<HANDLE>(s);
  519. ::CancelIoEx(sock_as_handle, op);
  520. }
  521. }
  522. #endif // defined(_WIN32_WINNT) && (_WIN32_WINNT >= 0x0600)
  523. iocp_service_.on_pending(op);
  524. }
  525. }
  526. }
  527. void win_iocp_socket_service_base::start_reactor_op(
  528. win_iocp_socket_service_base::base_implementation_type& impl,
  529. int op_type, reactor_op* op)
  530. {
  531. select_reactor& r = get_reactor();
  532. update_cancellation_thread_id(impl);
  533. if (is_open(impl))
  534. {
  535. r.start_op(op_type, impl.socket_, impl.reactor_data_, op, false, false);
  536. return;
  537. }
  538. else
  539. op->ec_ = asio::error::bad_descriptor;
  540. iocp_service_.post_immediate_completion(op, false);
  541. }
  542. int win_iocp_socket_service_base::start_connect_op(
  543. win_iocp_socket_service_base::base_implementation_type& impl,
  544. int family, int type, const void* addr, std::size_t addrlen,
  545. win_iocp_socket_connect_op_base* op, operation* iocp_op)
  546. {
  547. // If ConnectEx is available, use that.
  548. if (family == ASIO_OS_DEF(AF_INET)
  549. || family == ASIO_OS_DEF(AF_INET6))
  550. {
  551. if (connect_ex_fn connect_ex = get_connect_ex(impl, type))
  552. {
  553. union address_union
  554. {
  555. socket_addr_type base;
  556. sockaddr_in4_type v4;
  557. sockaddr_in6_type v6;
  558. } a;
  559. using namespace std; // For memset.
  560. memset(&a, 0, sizeof(a));
  561. a.base.sa_family = family;
  562. socket_ops::bind(impl.socket_, &a.base,
  563. family == ASIO_OS_DEF(AF_INET)
  564. ? sizeof(a.v4) : sizeof(a.v6), op->ec_);
  565. if (op->ec_ && op->ec_ != asio::error::invalid_argument)
  566. {
  567. iocp_service_.post_immediate_completion(op, false);
  568. return -1;
  569. }
  570. op->connect_ex_ = true;
  571. update_cancellation_thread_id(impl);
  572. iocp_service_.work_started();
  573. BOOL result = connect_ex(impl.socket_,
  574. static_cast<const socket_addr_type*>(addr),
  575. static_cast<int>(addrlen), 0, 0, 0, iocp_op);
  576. DWORD last_error = ::WSAGetLastError();
  577. if (!result && last_error != WSA_IO_PENDING)
  578. iocp_service_.on_completion(iocp_op, last_error);
  579. else
  580. iocp_service_.on_pending(iocp_op);
  581. return -1;
  582. }
  583. }
  584. // Otherwise, fall back to a reactor-based implementation.
  585. select_reactor& r = get_reactor();
  586. update_cancellation_thread_id(impl);
  587. if ((impl.state_ & socket_ops::non_blocking) != 0
  588. || socket_ops::set_internal_non_blocking(
  589. impl.socket_, impl.state_, true, op->ec_))
  590. {
  591. if (socket_ops::connect(impl.socket_, addr, addrlen, op->ec_) != 0)
  592. {
  593. if (op->ec_ == asio::error::in_progress
  594. || op->ec_ == asio::error::would_block)
  595. {
  596. op->ec_ = asio::error_code();
  597. r.start_op(select_reactor::connect_op, impl.socket_,
  598. impl.reactor_data_, op, false, false);
  599. return select_reactor::connect_op;
  600. }
  601. }
  602. }
  603. r.post_immediate_completion(op, false);
  604. return -1;
  605. }
  606. void win_iocp_socket_service_base::close_for_destruction(
  607. win_iocp_socket_service_base::base_implementation_type& impl)
  608. {
  609. if (is_open(impl))
  610. {
  611. ASIO_HANDLER_OPERATION((iocp_service_.context(),
  612. "socket", &impl, impl.socket_, "close"));
  613. // Check if the reactor was created, in which case we need to close the
  614. // socket on the reactor as well to cancel any operations that might be
  615. // running there.
  616. select_reactor* r = static_cast<select_reactor*>(
  617. interlocked_compare_exchange_pointer(
  618. reinterpret_cast<void**>(&reactor_), 0, 0));
  619. if (r)
  620. r->deregister_descriptor(impl.socket_, impl.reactor_data_, true);
  621. asio::error_code ignored_ec;
  622. socket_ops::close(impl.socket_, impl.state_, true, ignored_ec);
  623. if (r)
  624. r->cleanup_descriptor_data(impl.reactor_data_);
  625. }
  626. impl.socket_ = invalid_socket;
  627. impl.state_ = 0;
  628. impl.cancel_token_.reset();
  629. #if defined(ASIO_ENABLE_CANCELIO)
  630. impl.safe_cancellation_thread_id_ = 0;
  631. #endif // defined(ASIO_ENABLE_CANCELIO)
  632. }
  633. void win_iocp_socket_service_base::update_cancellation_thread_id(
  634. win_iocp_socket_service_base::base_implementation_type& impl)
  635. {
  636. #if defined(ASIO_ENABLE_CANCELIO)
  637. if (impl.safe_cancellation_thread_id_ == 0)
  638. impl.safe_cancellation_thread_id_ = ::GetCurrentThreadId();
  639. else if (impl.safe_cancellation_thread_id_ != ::GetCurrentThreadId())
  640. impl.safe_cancellation_thread_id_ = ~DWORD(0);
  641. #else // defined(ASIO_ENABLE_CANCELIO)
  642. (void)impl;
  643. #endif // defined(ASIO_ENABLE_CANCELIO)
  644. }
  645. select_reactor& win_iocp_socket_service_base::get_reactor()
  646. {
  647. select_reactor* r = static_cast<select_reactor*>(
  648. interlocked_compare_exchange_pointer(
  649. reinterpret_cast<void**>(&reactor_), 0, 0));
  650. if (!r)
  651. {
  652. r = &(use_service<select_reactor>(context_));
  653. interlocked_exchange_pointer(reinterpret_cast<void**>(&reactor_), r);
  654. }
  655. return *r;
  656. }
  657. win_iocp_socket_service_base::connect_ex_fn
  658. win_iocp_socket_service_base::get_connect_ex(
  659. win_iocp_socket_service_base::base_implementation_type& impl, int type)
  660. {
  661. #if defined(ASIO_DISABLE_CONNECTEX)
  662. (void)impl;
  663. (void)type;
  664. return 0;
  665. #else // defined(ASIO_DISABLE_CONNECTEX)
  666. if (type != ASIO_OS_DEF(SOCK_STREAM)
  667. && type != ASIO_OS_DEF(SOCK_SEQPACKET))
  668. return 0;
  669. void* ptr = interlocked_compare_exchange_pointer(&connect_ex_, 0, 0);
  670. if (!ptr)
  671. {
  672. GUID guid = { 0x25a207b9, 0xddf3, 0x4660,
  673. { 0x8e, 0xe9, 0x76, 0xe5, 0x8c, 0x74, 0x06, 0x3e } };
  674. DWORD bytes = 0;
  675. if (::WSAIoctl(impl.socket_, SIO_GET_EXTENSION_FUNCTION_POINTER,
  676. &guid, sizeof(guid), &ptr, sizeof(ptr), &bytes, 0, 0) != 0)
  677. {
  678. // Set connect_ex_ to a special value to indicate that ConnectEx is
  679. // unavailable. That way we won't bother trying to look it up again.
  680. ptr = this;
  681. }
  682. interlocked_exchange_pointer(&connect_ex_, ptr);
  683. }
  684. return reinterpret_cast<connect_ex_fn>(ptr == this ? 0 : ptr);
  685. #endif // defined(ASIO_DISABLE_CONNECTEX)
  686. }
  687. win_iocp_socket_service_base::nt_set_info_fn
  688. win_iocp_socket_service_base::get_nt_set_info()
  689. {
  690. void* ptr = interlocked_compare_exchange_pointer(&nt_set_info_, 0, 0);
  691. if (!ptr)
  692. {
  693. if (HMODULE h = ::GetModuleHandleA("NTDLL.DLL"))
  694. ptr = reinterpret_cast<void*>(GetProcAddress(h, "NtSetInformationFile"));
  695. // On failure, set nt_set_info_ to a special value to indicate that the
  696. // NtSetInformationFile function is unavailable. That way we won't bother
  697. // trying to look it up again.
  698. interlocked_exchange_pointer(&nt_set_info_, ptr ? ptr : this);
  699. }
  700. return reinterpret_cast<nt_set_info_fn>(ptr == this ? 0 : ptr);
  701. }
  702. void* win_iocp_socket_service_base::interlocked_compare_exchange_pointer(
  703. void** dest, void* exch, void* cmp)
  704. {
  705. #if defined(_M_IX86)
  706. return reinterpret_cast<void*>(InterlockedCompareExchange(
  707. reinterpret_cast<PLONG>(dest), reinterpret_cast<LONG>(exch),
  708. reinterpret_cast<LONG>(cmp)));
  709. #else
  710. return InterlockedCompareExchangePointer(dest, exch, cmp);
  711. #endif
  712. }
  713. void* win_iocp_socket_service_base::interlocked_exchange_pointer(
  714. void** dest, void* val)
  715. {
  716. #if defined(_M_IX86)
  717. return reinterpret_cast<void*>(InterlockedExchange(
  718. reinterpret_cast<PLONG>(dest), reinterpret_cast<LONG>(val)));
  719. #else
  720. return InterlockedExchangePointer(dest, val);
  721. #endif
  722. }
  723. } // namespace detail
  724. } // namespace asio
  725. #include "asio/detail/pop_options.hpp"
  726. #endif // defined(ASIO_HAS_IOCP)
  727. #endif // ASIO_DETAIL_IMPL_WIN_IOCP_SOCKET_SERVICE_BASE_IPP