Commit b11bdbb5 authored by Dominik Charousset's avatar Dominik Charousset

Prevent redundant upstream messages

parent 072086f8
...@@ -55,7 +55,11 @@ void stream_manager::handle(inbound_path*, downstream_msg::close&) { ...@@ -55,7 +55,11 @@ void stream_manager::handle(inbound_path*, downstream_msg::close&) {
// nop // nop
} }
void stream_manager::handle(inbound_path*, downstream_msg::forced_close& x) { void stream_manager::handle(inbound_path* in, downstream_msg::forced_close& x) {
CAF_ASSERT(in != nullptr);
CAF_LOG_TRACE(CAF_ARG2("slots", in->slots) << CAF_ARG(x));
// Reset the actor handle to make sure no further message travels upstream.
in->hdl = nullptr;
abort(std::move(x.reason)); abort(std::move(x.reason));
} }
......
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