diff options
Diffstat (limited to 'boost/process/detail/windows/async_out.hpp')
-rw-r--r-- | boost/process/detail/windows/async_out.hpp | 34 |
1 files changed, 17 insertions, 17 deletions
diff --git a/boost/process/detail/windows/async_out.hpp b/boost/process/detail/windows/async_out.hpp index 6bcb5e82ae..525cbafef0 100644 --- a/boost/process/detail/windows/async_out.hpp +++ b/boost/process/detail/windows/async_out.hpp @@ -80,10 +80,10 @@ struct async_out_buffer : ::boost::process::detail::windows::handler_base_ext, template <typename Executor> inline void on_success(Executor&) { - auto pipe = this->pipe; - boost::asio::async_read(*pipe, buf, - [pipe](const boost::system::error_code&, std::size_t){}); - std::move(*pipe).sink().close(); + auto pipe_ = this->pipe; + boost::asio::async_read(*pipe_, buf, + [pipe_](const boost::system::error_code&, std::size_t){}); + std::move(*pipe_).sink().close(); this->pipe = nullptr; } @@ -122,34 +122,34 @@ struct async_out_future : ::boost::process::detail::windows::handler_base_ext, template <typename Executor> inline void on_success(Executor&) { - auto pipe = this->pipe; - auto buffer = this->buffer; - auto promise = this->promise; - std::move(*pipe).sink().close(); - boost::asio::async_read(*pipe, *buffer, - [pipe, buffer, promise](const boost::system::error_code& ec, std::size_t) + auto pipe_ = this->pipe; + auto buffer_ = this->buffer; + auto promise_ = this->promise; + std::move(*pipe_).sink().close(); + boost::asio::async_read(*pipe_, *buffer_, + [pipe_, buffer_, promise_](const boost::system::error_code& ec, std::size_t) { if (ec && (ec.value() != ::boost::winapi::ERROR_BROKEN_PIPE_)) { std::error_code e(ec.value(), std::system_category()); - promise->set_exception(std::make_exception_ptr(process_error(e))); + promise_->set_exception(std::make_exception_ptr(process_error(e))); } else { - std::istream is (buffer.get()); + std::istream is (buffer_.get()); Type arg; - if (buffer->size() > 0) + if (buffer_->size() > 0) { - arg.resize(buffer->size()); - is.read(&*arg.begin(), buffer->size()); + arg.resize(buffer_->size()); + is.read(&*arg.begin(), buffer_->size()); } - promise->set_value(std::move(arg)); + promise_->set_value(std::move(arg)); } }); - this->pipe = nullptr; + this->pipe = nullptr; this->buffer = nullptr; this->promise = nullptr; |