Commit 091cdf1e authored by Dominik Charousset's avatar Dominik Charousset

Remove stream aborters when removing downstreams

parent b37f3e10
......@@ -110,10 +110,12 @@ void downstream_policy::close() {
}
void downstream_policy::abort(strong_actor_ptr& cause, const error& reason) {
for (auto& x : paths_)
CAF_LOG_TRACE(CAF_ARG(cause) << CAF_ARG(reason));
for (auto& x : paths_) {
if (x->hdl != cause)
unsafe_send_as(self_, x->hdl,
make<stream_msg::abort>(this->sid_, reason));
unsafe_send_as(self_, x->hdl, make<stream_msg::abort>(sid_, reason));
stream_aborter::del(x->hdl, self_->address(), sid_);
}
}
downstream_path* downstream_policy::find(const strong_actor_ptr& ptr) const {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment