[rdma]fix and update (#977)

Author: qicosmos

include/ylt/coro_io/ibverbs/ib_device.hpp

@@ -174,7 +174,8 @@ class ib_device_t {
       throw std::system_error(ec);
     }
 
-    ELOG_TRACE << "Active MTU: " << detail::mtu_str(attr_.active_mtu) << ", "
+    ELOG_TRACE << name_ << " Active MTU: " << detail::mtu_str(attr_.active_mtu)
+               << ", "
                << "Max MTU: " << detail::mtu_str(attr_.max_mtu);
 
     find_best_gid_index();

include/ylt/coro_io/ibverbs/ib_socket.hpp

@@ -823,11 +823,12 @@ class ib_socket_t {
         }
 
         if (ec) {
+          auto send_cb = std::move(self->send_cb_);
           self->close();
           ib_socket_shared_state_t::resume(std::pair{ec, std::size_t{0}},
                                            self->recv_cb_);
           ib_socket_shared_state_t::resume(std::pair{ec, std::size_t{0}},
-                                           self->send_cb_);
+                                           send_cb);
           break;
         }
       }

include/ylt/metric/metric.hpp

@@ -8,18 +8,8 @@
 #include <regex>
 #include <span>
 #include <string>
-#include <thread>
 #include <vector>
 
-#include "async_simple/coro/Lazy.h"
-#include "async_simple/coro/SyncAwait.h"
-#include "cinatra/cinatra_log_wrapper.hpp"
-#if __has_include("ylt/coro_io/coro_io.hpp")
-#include "ylt/coro_io/coro_io.hpp"
-#else
-#include "cinatra/ylt/coro_io/coro_io.hpp"
-#endif
-
 #ifdef CINATRA_ENABLE_METRIC_JSON
 namespace iguana {
 

include/ylt/metric/metric_manager.hpp

@@ -1,8 +1,17 @@
 #pragma once
+#include <iostream>
 #include <shared_mutex>
 #include <system_error>
+#include <thread>
 #include <utility>
 
+#include "async_simple/coro/Lazy.h"
+#include "async_simple/coro/SyncAwait.h"
+#if __has_include("ylt/coro_io/coro_io.hpp")
+#include "ylt/coro_io/coro_io.hpp"
+#else
+#include "cinatra/ylt/coro_io/coro_io.hpp"
+#endif
 #include "metric.hpp"
 #include "ylt/util/map_sharded.hpp"
 
@@ -11,14 +20,14 @@ class manager_helper {
  public:
   static bool register_metric(auto& metric_map, auto metric) {
     if (metric::metric_t::g_user_metric_count > ylt_metric_capacity) {
-      CINATRA_LOG_ERROR << "metric count at capacity size: "
-                        << metric::metric_t::g_user_metric_count;
+      std::cerr << "metric count at capacity size: "
+                << metric::metric_t::g_user_metric_count << std::endl;
       return false;
     }
     auto&& [it, r] = metric_map.try_emplace(metric->str_name(), metric);
     if (!r) {
-      CINATRA_LOG_ERROR << "duplicate registered metric name: "
-                        << metric->str_name();
+      std::cerr << "duplicate registered metric name: " << metric->str_name()
+                << std::endl;
       return false;
     }
 

src/coro_rpc/benchmark/bench.cpp

@@ -184,7 +184,9 @@ int main(int argc, char** argv) {
   easylog::set_async(false);
 
 #ifdef YLT_ENABLE_IBV
-  coro_io::g_ib_buffer_pool({.buffer_size = conf.buffer_size});
+  if (conf.enable_ib) {
+    coro_io::g_ib_buffer_pool({.buffer_size = conf.buffer_size});
+  }
 #endif
 
   if (conf.client_concurrency == 0) {