Commit de6aae61 authored by Dominik Charousset's avatar Dominik Charousset

Properly fix responses to high prio async messages

parent 25ff0831
...@@ -66,7 +66,7 @@ public: ...@@ -66,7 +66,7 @@ public:
} }
inline bool is_async() const { inline bool is_async() const {
return value_ == 0; return value_ == 0 || value_ == high_prioity_flag_mask;
} }
inline bool is_response() const { inline bool is_response() const {
......
...@@ -35,7 +35,7 @@ response_promise::response_promise(local_actor* self, mailbox_element& src) ...@@ -35,7 +35,7 @@ response_promise::response_promise(local_actor* self, mailbox_element& src)
id_(src.mid) { id_(src.mid) {
// form an invalid request promise when initialized from a // form an invalid request promise when initialized from a
// response ID, since CAF always drops messages in this case // response ID, since CAF always drops messages in this case
if (src.mid.is_request()) { if (! src.mid.is_response()) {
source_ = std::move(src.sender); source_ = std::move(src.sender);
stages_ = std::move(src.stages); stages_ = std::move(src.stages);
} }
......
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