winrt_socket_connect_op.hpp 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899
  1. //
  2. // detail/winrt_socket_connect_op.hpp
  3. // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  4. //
  5. // Copyright (c) 2003-2022 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_WINRT_SOCKET_CONNECT_OP_HPP
  11. #define ASIO_DETAIL_WINRT_SOCKET_CONNECT_OP_HPP
  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_WINDOWS_RUNTIME)
  17. #include "asio/detail/bind_handler.hpp"
  18. #include "asio/detail/buffer_sequence_adapter.hpp"
  19. #include "asio/detail/fenced_block.hpp"
  20. #include "asio/detail/handler_alloc_helpers.hpp"
  21. #include "asio/detail/handler_invoke_helpers.hpp"
  22. #include "asio/detail/handler_work.hpp"
  23. #include "asio/detail/memory.hpp"
  24. #include "asio/detail/winrt_async_op.hpp"
  25. #include "asio/error.hpp"
  26. #include "asio/detail/push_options.hpp"
  27. namespace asio {
  28. namespace detail {
  29. template <typename Handler, typename IoExecutor>
  30. class winrt_socket_connect_op :
  31. public winrt_async_op<void>
  32. {
  33. public:
  34. ASIO_DEFINE_HANDLER_PTR(winrt_socket_connect_op);
  35. winrt_socket_connect_op(Handler& handler, const IoExecutor& io_ex)
  36. : winrt_async_op<void>(&winrt_socket_connect_op::do_complete),
  37. handler_(ASIO_MOVE_CAST(Handler)(handler)),
  38. work_(handler_, io_ex)
  39. {
  40. }
  41. static void do_complete(void* owner, operation* base,
  42. const asio::error_code&, std::size_t)
  43. {
  44. // Take ownership of the operation object.
  45. winrt_socket_connect_op* o(static_cast<winrt_socket_connect_op*>(base));
  46. ptr p = { asio::detail::addressof(o->handler_), o, o };
  47. ASIO_HANDLER_COMPLETION((*o));
  48. // Take ownership of the operation's outstanding work.
  49. handler_work<Handler, IoExecutor> w(
  50. ASIO_MOVE_CAST2(handler_work<Handler, IoExecutor>)(
  51. o->work_));
  52. // Make a copy of the handler so that the memory can be deallocated before
  53. // the upcall is made. Even if we're not about to make an upcall, a
  54. // sub-object of the handler may be the true owner of the memory associated
  55. // with the handler. Consequently, a local copy of the handler is required
  56. // to ensure that any owning sub-object remains valid until after we have
  57. // deallocated the memory here.
  58. detail::binder1<Handler, asio::error_code>
  59. handler(o->handler_, o->ec_);
  60. p.h = asio::detail::addressof(handler.handler_);
  61. p.reset();
  62. // Make the upcall if required.
  63. if (owner)
  64. {
  65. fenced_block b(fenced_block::half);
  66. ASIO_HANDLER_INVOCATION_BEGIN((handler.arg1_));
  67. w.complete(handler, handler.handler_);
  68. ASIO_HANDLER_INVOCATION_END;
  69. }
  70. }
  71. private:
  72. Handler handler_;
  73. handler_work<Handler, IoExecutor> executor_;
  74. };
  75. } // namespace detail
  76. } // namespace asio
  77. #include "asio/detail/pop_options.hpp"
  78. #endif // defined(ASIO_WINDOWS_RUNTIME)
  79. #endif // ASIO_DETAIL_WINRT_SOCKET_CONNECT_OP_HPP