Commit 5b0e9dd5 authored by Dominik Charousset's avatar Dominik Charousset

Fix drop behavior of stream_distribution_tree

parent 5f377269
...@@ -114,9 +114,7 @@ public: ...@@ -114,9 +114,7 @@ public:
void handle(stream_slots slots, upstream_msg::drop& x) override { void handle(stream_slots slots, upstream_msg::drop& x) override {
CAF_LOG_TRACE(CAF_ARG(slots) << CAF_ARG(x)); CAF_LOG_TRACE(CAF_ARG(slots) << CAF_ARG(x));
CAF_IGNORE_UNUSED(x); CAF_IGNORE_UNUSED(x);
auto slot = slots.receiver; super::handle(slots, x);
if (out().remove_path(slots.receiver, none, true))
policy_.path_dropped(slot);
} }
void handle(stream_slots slots, upstream_msg::forced_drop& x) override { void handle(stream_slots slots, upstream_msg::forced_drop& x) override {
......
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