[coro_io][ibverbs] fix error handle of fd falsely wake up (#1024)

Author: qicosmos

include/ylt/coro_io/ibverbs/ib_socket.hpp

@@ -271,17 +271,21 @@ struct ib_socket_shared_state_t
     int r = ibv_get_cq_event(channel_.get(), &cq, &ev_ctx);
     // assert(r >= 0);
     std::error_code ec;
-    if (r) {
-      ELOG_INFO << "there isn't any Completion event to read";
-      return std::make_error_code(std::errc{std::errc::io_error});
+    if (r) [[unlikely]] {
+      ELOG_WARN << "there isn't any Completion event to read, errno" << errno;
+      if (errno != EAGAIN && errno != EWOULDBLOCK) [[unlikely]] {
+        ELOG_WARN << "failed to get comp_channel event";
+        return std::make_error_code(std::errc{std::errc::io_error});
+      }
+      return {};
     }
     ibv_ack_cq_events(cq, 1);
     r = ibv_req_notify_cq(cq, 0);
-    if (r) {
+    if (r) [[unlikely]] {
       ELOG_ERROR << std::make_error_code(std::errc{r}).message();
       return std::make_error_code(std::errc{r});
     }
-    struct ibv_wc wc{};
+    struct ibv_wc wc {};
     int ne = 0;
     std::vector<resume_struct> vec;
     callback_t tmp_recv_callback;

include/ylt/coro_rpc/impl/coro_rpc_client.hpp

@@ -1270,6 +1270,8 @@ class coro_rpc_client {
         co_return rpc_error{errc::timed_out};
       }
       else {
+        ELOG_ERROR << "write error: " << ret.first.value() << ", "
+                   << ret.first.message();
         co_return rpc_error{errc::io_error, ret.first.message()};
       }
     }

include/ylt/version.hpp

@@ -20,4 +20,4 @@
 // YLT_VERSION % 100 is the sub-minor version
 // YLT_VERSION / 100 % 1000 is the minor version
 // YLT_VERSION / 100000 is the major version
-#define YLT_VERSION 501  // 0.5.1
+#define YLT_VERSION 503  // 0.5.3

src/coro_rpc/benchmark/bench.cpp

@@ -109,6 +109,9 @@ async_simple::coro::Lazy<void> watcher(const bench_config& conf) {
       break;
     }
     auto thp = g_throughput_count.exchange(0);
+    if (thp == 0) {
+      continue;
+    }
     total += thp;
     auto qps = g_qps_count.exchange(0);
     total_qps += qps;