Commit a8048a75 authored by Dominik Charousset's avatar Dominik Charousset

Detect nop in register_reading

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