summaryrefslogtreecommitdiff
path: root/src/third_party/asio-master/asio/include/asio/detail/impl/reactive_descriptor_service.ipp
diff options
context:
space:
mode:
Diffstat (limited to 'src/third_party/asio-master/asio/include/asio/detail/impl/reactive_descriptor_service.ipp')
-rw-r--r--src/third_party/asio-master/asio/include/asio/detail/impl/reactive_descriptor_service.ipp21
1 files changed, 15 insertions, 6 deletions
diff --git a/src/third_party/asio-master/asio/include/asio/detail/impl/reactive_descriptor_service.ipp b/src/third_party/asio-master/asio/include/asio/detail/impl/reactive_descriptor_service.ipp
index 7aaf3620f16..8a340ed7f8b 100644
--- a/src/third_party/asio-master/asio/include/asio/detail/impl/reactive_descriptor_service.ipp
+++ b/src/third_party/asio-master/asio/include/asio/detail/impl/reactive_descriptor_service.ipp
@@ -2,7 +2,7 @@
// detail/impl/reactive_descriptor_service.ipp
// ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
//
-// Copyright (c) 2003-2016 Christopher M. Kohlhoff (chris at kohlhoff dot com)
+// Copyright (c) 2003-2017 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)
@@ -89,10 +89,12 @@ void reactive_descriptor_service::destroy(
reactor_.deregister_descriptor(impl.descriptor_, impl.reactor_data_,
(impl.state_ & descriptor_ops::possible_dup) == 0);
- }
- asio::error_code ignored_ec;
- descriptor_ops::close(impl.descriptor_, impl.state_, ignored_ec);
+ asio::error_code ignored_ec;
+ descriptor_ops::close(impl.descriptor_, impl.state_, ignored_ec);
+
+ reactor_.cleanup_descriptor_data(impl.reactor_data_);
+ }
}
asio::error_code reactive_descriptor_service::assign(
@@ -130,9 +132,15 @@ asio::error_code reactive_descriptor_service::close(
reactor_.deregister_descriptor(impl.descriptor_, impl.reactor_data_,
(impl.state_ & descriptor_ops::possible_dup) == 0);
- }
- descriptor_ops::close(impl.descriptor_, impl.state_, ec);
+ descriptor_ops::close(impl.descriptor_, impl.state_, ec);
+
+ reactor_.cleanup_descriptor_data(impl.reactor_data_);
+ }
+ else
+ {
+ ec = asio::error_code();
+ }
// The descriptor is closed by the OS even if close() returns an error.
//
@@ -157,6 +165,7 @@ reactive_descriptor_service::release(
"descriptor", &impl, impl.descriptor_, "release"));
reactor_.deregister_descriptor(impl.descriptor_, impl.reactor_data_, false);
+ reactor_.cleanup_descriptor_data(impl.reactor_data_);
construct(impl);
}