completion_payload.hpp 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222
  1. //
  2. // detail/completion_payload.hpp
  3. // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  4. //
  5. // Copyright (c) 2003-2024 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 BOOST_ASIO_DETAIL_COMPLETION_PAYLOAD_HPP
  11. #define BOOST_ASIO_DETAIL_COMPLETION_PAYLOAD_HPP
  12. #if defined(_MSC_VER) && (_MSC_VER >= 1200)
  13. # pragma once
  14. #endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
  15. #include <boost/asio/detail/config.hpp>
  16. #include <boost/asio/detail/type_traits.hpp>
  17. #include <boost/system/error_code.hpp>
  18. #include <boost/asio/detail/completion_message.hpp>
  19. #if defined(BOOST_ASIO_HAS_STD_VARIANT)
  20. # include <variant>
  21. #else // defined(BOOST_ASIO_HAS_STD_VARIANT)
  22. # include <new>
  23. #endif // defined(BOOST_ASIO_HAS_STD_VARIANT)
  24. #include <boost/asio/detail/push_options.hpp>
  25. namespace boost {
  26. namespace asio {
  27. namespace detail {
  28. template <typename... Signatures>
  29. class completion_payload;
  30. template <typename R>
  31. class completion_payload<R()>
  32. {
  33. public:
  34. explicit completion_payload(completion_message<R()>)
  35. {
  36. }
  37. template <typename Handler>
  38. void receive(Handler& handler)
  39. {
  40. static_cast<Handler&&>(handler)();
  41. }
  42. };
  43. template <typename Signature>
  44. class completion_payload<Signature>
  45. {
  46. public:
  47. completion_payload(completion_message<Signature>&& m)
  48. : message_(static_cast<completion_message<Signature>&&>(m))
  49. {
  50. }
  51. template <typename Handler>
  52. void receive(Handler& handler)
  53. {
  54. message_.receive(handler);
  55. }
  56. private:
  57. completion_message<Signature> message_;
  58. };
  59. #if defined(BOOST_ASIO_HAS_STD_VARIANT)
  60. template <typename... Signatures>
  61. class completion_payload
  62. {
  63. public:
  64. template <typename Signature>
  65. completion_payload(completion_message<Signature>&& m)
  66. : message_(static_cast<completion_message<Signature>&&>(m))
  67. {
  68. }
  69. template <typename Handler>
  70. void receive(Handler& handler)
  71. {
  72. std::visit(
  73. [&](auto& message)
  74. {
  75. message.receive(handler);
  76. }, message_);
  77. }
  78. private:
  79. std::variant<completion_message<Signatures>...> message_;
  80. };
  81. #else // defined(BOOST_ASIO_HAS_STD_VARIANT)
  82. template <typename R1, typename R2>
  83. class completion_payload<R1(), R2(boost::system::error_code)>
  84. {
  85. public:
  86. typedef completion_message<R1()> void_message_type;
  87. typedef completion_message<R2(boost::system::error_code)> error_message_type;
  88. completion_payload(void_message_type&&)
  89. : message_(0, boost::system::error_code()),
  90. empty_(true)
  91. {
  92. }
  93. completion_payload(error_message_type&& m)
  94. : message_(static_cast<error_message_type&&>(m)),
  95. empty_(false)
  96. {
  97. }
  98. template <typename Handler>
  99. void receive(Handler& handler)
  100. {
  101. if (empty_)
  102. completion_message<R1()>(0).receive(handler);
  103. else
  104. message_.receive(handler);
  105. }
  106. private:
  107. error_message_type message_;
  108. bool empty_;
  109. };
  110. template <typename Sig1, typename Sig2>
  111. class completion_payload<Sig1, Sig2>
  112. {
  113. public:
  114. typedef completion_message<Sig1> message_1_type;
  115. typedef completion_message<Sig2> message_2_type;
  116. completion_payload(message_1_type&& m)
  117. : index_(1)
  118. {
  119. new (&storage_.message_1_) message_1_type(static_cast<message_1_type&&>(m));
  120. }
  121. completion_payload(message_2_type&& m)
  122. : index_(2)
  123. {
  124. new (&storage_.message_2_) message_2_type(static_cast<message_2_type&&>(m));
  125. }
  126. completion_payload(completion_payload&& other)
  127. : index_(other.index_)
  128. {
  129. switch (index_)
  130. {
  131. case 1:
  132. new (&storage_.message_1_) message_1_type(
  133. static_cast<message_1_type&&>(other.storage_.message_1_));
  134. break;
  135. case 2:
  136. new (&storage_.message_2_) message_2_type(
  137. static_cast<message_2_type&&>(other.storage_.message_2_));
  138. break;
  139. default:
  140. break;
  141. }
  142. }
  143. ~completion_payload()
  144. {
  145. switch (index_)
  146. {
  147. case 1:
  148. storage_.message_1_.~message_1_type();
  149. break;
  150. case 2:
  151. storage_.message_2_.~message_2_type();
  152. break;
  153. default:
  154. break;
  155. }
  156. }
  157. template <typename Handler>
  158. void receive(Handler& handler)
  159. {
  160. switch (index_)
  161. {
  162. case 1:
  163. storage_.message_1_.receive(handler);
  164. break;
  165. case 2:
  166. storage_.message_2_.receive(handler);
  167. break;
  168. default:
  169. break;
  170. }
  171. }
  172. private:
  173. union storage
  174. {
  175. storage() {}
  176. ~storage() {}
  177. char dummy_;
  178. message_1_type message_1_;
  179. message_2_type message_2_;
  180. } storage_;
  181. unsigned char index_;
  182. };
  183. #endif // defined(BOOST_ASIO_HAS_STD_VARIANT)
  184. } // namespace detail
  185. } // namespace asio
  186. } // namespace boost
  187. #include <boost/asio/detail/pop_options.hpp>
  188. #endif // BOOST_ASIO_DETAIL_COMPLETION_PAYLOAD_HPP