Commit f8699277 authored by Dominik Charousset's avatar Dominik Charousset

Fix error handling

parent a8048a75
...@@ -109,14 +109,16 @@ public: ...@@ -109,14 +109,16 @@ public:
} }
prepare_next_read(); prepare_next_read();
} }
return true;
} else { } else {
auto err = get<sec>(ret); auto err = get<sec>(ret);
if (err != sec::unavailable_or_would_block) {
CAF_LOG_DEBUG("receive failed" << CAF_ARG(err)); CAF_LOG_DEBUG("receive failed" << CAF_ARG(err));
worker_.handle_error(err); worker_.handle_error(err);
return false; return false;
} }
} }
return true;
}
template <class Parent> template <class Parent>
bool handle_write_event(Parent& parent) { bool handle_write_event(Parent& parent) {
...@@ -225,10 +227,12 @@ private: ...@@ -225,10 +227,12 @@ private:
} }
} else { } else {
auto err = get<sec>(ret); auto err = get<sec>(ret);
if (err != sec::unavailable_or_would_block) {
CAF_LOG_DEBUG("send failed" << CAF_ARG(err)); CAF_LOG_DEBUG("send failed" << CAF_ARG(err));
worker_.handle_error(err); worker_.handle_error(err);
return false; return false;
} }
}
return true; return true;
} }
......
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