]> git.proxmox.com Git - ceph.git/blobdiff - ceph/src/boost/boost/asio/detail/impl/winrt_ssocket_service_base.ipp
import new upstream nautilus stable release 14.2.8
[ceph.git] / ceph / src / boost / boost / asio / detail / impl / winrt_ssocket_service_base.ipp
index e6254aed9308eb058f29d68221a8c4ec5b6cd998..3f2dd817c68b6b7da5d7b8c2e82a7d6e9d09dc73 100644 (file)
@@ -2,7 +2,7 @@
 // detail/impl/winrt_ssocket_service_base.ipp
 // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 //
-// Copyright (c) 2003-2018 Christopher M. Kohlhoff (chris at kohlhoff dot com)
+// Copyright (c) 2003-2019 Christopher M. Kohlhoff (chris at kohlhoff dot com)
 //
 // Distributed under the Boost Software License, Version 1.0. (See accompanying
 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
@@ -31,9 +31,9 @@ namespace asio {
 namespace detail {
 
 winrt_ssocket_service_base::winrt_ssocket_service_base(
-    boost::asio::io_context& io_context)
-  : io_context_(use_service<io_context_impl>(io_context)),
-    async_manager_(use_service<winrt_async_manager>(io_context)),
+    execution_context& context)
+  : scheduler_(use_service<scheduler_impl>(context)),
+    async_manager_(use_service<winrt_async_manager>(context)),
     mutex_(),
     impl_list_(0)
 {
@@ -67,6 +67,7 @@ void winrt_ssocket_service_base::construct(
 void winrt_ssocket_service_base::base_move_construct(
     winrt_ssocket_service_base::base_implementation_type& impl,
     winrt_ssocket_service_base::base_implementation_type& other_impl)
+  BOOST_ASIO_NOEXCEPT
 {
   impl.socket_ = other_impl.socket_;
   other_impl.socket_ = nullptr;
@@ -399,7 +400,7 @@ void winrt_ssocket_service_base::start_connect_op(
   if (!is_open(impl))
   {
     op->ec_ = boost::asio::error::bad_descriptor;
-    io_context_.post_immediate_completion(op, is_continuation);
+    scheduler_.post_immediate_completion(op, is_continuation);
     return;
   }
 
@@ -428,7 +429,7 @@ void winrt_ssocket_service_base::start_connect_op(
 
   if (op->ec_)
   {
-    io_context_.post_immediate_completion(op, is_continuation);
+    scheduler_.post_immediate_completion(op, is_continuation);
     return;
   }
 
@@ -443,7 +444,7 @@ void winrt_ssocket_service_base::start_connect_op(
   {
     op->ec_ = boost::system::error_code(
         e->HResult, boost::system::system_category());
-    io_context_.post_immediate_completion(op, is_continuation);
+    scheduler_.post_immediate_completion(op, is_continuation);
   }
 }
 
@@ -494,14 +495,14 @@ void winrt_ssocket_service_base::start_send_op(
   if (flags)
   {
     op->ec_ = boost::asio::error::operation_not_supported;
-    io_context_.post_immediate_completion(op, is_continuation);
+    scheduler_.post_immediate_completion(op, is_continuation);
     return;
   }
 
   if (!is_open(impl))
   {
     op->ec_ = boost::asio::error::bad_descriptor;
-    io_context_.post_immediate_completion(op, is_continuation);
+    scheduler_.post_immediate_completion(op, is_continuation);
     return;
   }
 
@@ -512,7 +513,7 @@ void winrt_ssocket_service_base::start_send_op(
 
     if (bufs.all_empty())
     {
-      io_context_.post_immediate_completion(op, is_continuation);
+      scheduler_.post_immediate_completion(op, is_continuation);
       return;
     }
 
@@ -523,7 +524,7 @@ void winrt_ssocket_service_base::start_send_op(
   {
     op->ec_ = boost::system::error_code(e->HResult,
         boost::system::system_category());
-    io_context_.post_immediate_completion(op, is_continuation);
+    scheduler_.post_immediate_completion(op, is_continuation);
   }
 }
 
@@ -585,14 +586,14 @@ void winrt_ssocket_service_base::start_receive_op(
   if (flags)
   {
     op->ec_ = boost::asio::error::operation_not_supported;
-    io_context_.post_immediate_completion(op, is_continuation);
+    scheduler_.post_immediate_completion(op, is_continuation);
     return;
   }
 
   if (!is_open(impl))
   {
     op->ec_ = boost::asio::error::bad_descriptor;
-    io_context_.post_immediate_completion(op, is_continuation);
+    scheduler_.post_immediate_completion(op, is_continuation);
     return;
   }
 
@@ -603,7 +604,7 @@ void winrt_ssocket_service_base::start_receive_op(
 
     if (bufs.all_empty())
     {
-      io_context_.post_immediate_completion(op, is_continuation);
+      scheduler_.post_immediate_completion(op, is_continuation);
       return;
     }
 
@@ -616,7 +617,7 @@ void winrt_ssocket_service_base::start_receive_op(
   {
     op->ec_ = boost::system::error_code(e->HResult,
         boost::system::system_category());
-    io_context_.post_immediate_completion(op, is_continuation);
+    scheduler_.post_immediate_completion(op, is_continuation);
   }
 }