Commit b21c0235 authored by Dominik Charousset's avatar Dominik Charousset

Fix handshake in incoming_stream_multiplexer

parent 7733a014
...@@ -67,7 +67,7 @@ void incoming_stream_multiplexer::operator()(stream_msg::open& x) { ...@@ -67,7 +67,7 @@ void incoming_stream_multiplexer::operator()(stream_msg::open& x) {
auto ptr = make_mailbox_element( auto ptr = make_mailbox_element(
cme->sender, cme->mid, std::move(cme->stages), cme->sender, cme->mid, std::move(cme->stages),
make<stream_msg::open>(current_stream_msg_->sid, std::move(x.msg), make<stream_msg::open>(current_stream_msg_->sid, std::move(x.msg),
self_->ctrl(), successor, x.priority, self_->ctrl(), x.original_stage, x.priority,
x.redeployable)); x.redeployable));
successor->enqueue(std::move(ptr), self_->context()); successor->enqueue(std::move(ptr), self_->context());
// Send out demand upstream. // Send out demand upstream.
......
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