Commit 83b1251f authored by Dominik Charousset's avatar Dominik Charousset

override chained_enqueue in threaded impl

this patch fixes a bug with chained_enqueue, i.e., chained_enqueue
was called on scheduled_actor instead of threaded
parent 7b5ac906
...@@ -129,6 +129,11 @@ class threaded : public Base { ...@@ -129,6 +129,11 @@ class threaded : public Base {
enqueue_impl(this->m_mailbox, hdr, std::move(msg)); enqueue_impl(this->m_mailbox, hdr, std::move(msg));
} }
virtual bool chained_enqueue(const message_header& hdr, any_tuple msg) override {
enqueue(hdr, std::move(msg));
return false;
}
timeout_type init_timeout(const util::duration& rel_time) { timeout_type init_timeout(const util::duration& rel_time) {
auto result = std::chrono::high_resolution_clock::now(); auto result = std::chrono::high_resolution_clock::now();
result += rel_time; result += rel_time;
......
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