Commit 9e2b8bba authored by Dominik Charousset's avatar Dominik Charousset

Detect nop in register_reading

parent 6519dd74
...@@ -110,9 +110,10 @@ void multiplexer::register_reading(const socket_manager_ptr& mgr) { ...@@ -110,9 +110,10 @@ void multiplexer::register_reading(const socket_manager_ptr& mgr) {
if (std::this_thread::get_id() == tid_) { if (std::this_thread::get_id() == tid_) {
if (mgr->mask() != operation::none) { if (mgr->mask() != operation::none) {
CAF_ASSERT(index_of(mgr) != -1); CAF_ASSERT(index_of(mgr) != -1);
mgr->mask_add(operation::read); if (mgr->mask_add(operation::read)) {
auto& fd = pollset_[index_of(mgr)]; auto& fd = pollset_[index_of(mgr)];
fd.events |= input_mask; fd.events |= input_mask;
}
} else if (mgr->mask_add(operation::read)) { } else if (mgr->mask_add(operation::read)) {
add(mgr); add(mgr);
} }
......
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