File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -169,18 +169,15 @@ namespace nvexec::STDEXEC_STREAM_DETAIL_NS {
169169 template <class Error >
170170 void _set_error_impl (Error&& err) noexcept {
171171 // TODO: What memory orderings are actually needed here?
172- auto old_state = op_state_->__state_ .exchange (_when_all::error);
173- // If the previous state was __error or __stopped , then we have already requested
172+ auto old_state = op_state_->state_ .exchange (_when_all::error);
173+ // If the previous state was error or stopped , then we have already requested
174174 // stop on the stop source. Otherwise, request stop.
175175 if (old_state == _when_all::started) {
176- op_state_->__stop_source_ .request_stop ();
176+ op_state_->stop_source_ .request_stop ();
177177 }
178178 // If we are the first child to complete with an error, we must save the error.
179179 // (Any subsequent errors are ignores.)
180180 if (old_state != _when_all::error) {
181- op_state_->stop_source_ .request_stop ();
182- // We won the race, free to write the error into the operation
183- // state without worry.
184181 op_state_->errors_ .template emplace <__decay_t <Error>>(static_cast <Error&&>(err));
185182 }
186183 op_state_->arrive ();
You can’t perform that action at this time.
0 commit comments