[ibverbs] fix log & default config

Author: poor-circle

include/ylt/coro_io/ibverbs/ib_device.hpp

@@ -122,16 +122,15 @@ inline void print_async_event(struct ibv_context* ctx,
   switch (event->event_type) {
     /* QP events */
     case IBV_EVENT_QP_FATAL:
-      ELOG_ERROR << "QP fatal event for QP number:"
-                 << event->element.qp->qp_num;
+      ELOG_WARN << "QP fatal event for QP number:" << event->element.qp->qp_num;
       break;
     case IBV_EVENT_QP_REQ_ERR:
-      ELOG_ERROR << "QP Requestor error for QP number:"
-                 << event->element.qp->qp_num;
+      ELOG_WARN << "QP Requestor error for QP number:"
+                << event->element.qp->qp_num;
       break;
     case IBV_EVENT_QP_ACCESS_ERR:
-      ELOG_ERROR << "QP access error event for QP number:"
-                 << event->element.qp->qp_num;
+      ELOG_WARN << "QP access error event for QP number:"
+                << event->element.qp->qp_num;
       break;
     case IBV_EVENT_COMM_EST:
       ELOG_INFO << "QP communication established event for QP number:"
@@ -146,8 +145,8 @@ inline void print_async_event(struct ibv_context* ctx,
                 << event->element.qp->qp_num;
       break;
     case IBV_EVENT_PATH_MIG_ERR:
-      ELOG_ERROR << "QP Path migration error event for QP number:"
-                 << event->element.qp->qp_num;
+      ELOG_WARN << "QP Path migration error event for QP number:"
+                << event->element.qp->qp_num;
       break;
     case IBV_EVENT_QP_LAST_WQE_REACHED:
       ELOG_INFO << "QP last WQE reached event for QP number:"
@@ -156,12 +155,12 @@ inline void print_async_event(struct ibv_context* ctx,
 
     /* CQ events */
     case IBV_EVENT_CQ_ERR:
-      ELOG_ERROR << "CQ error for CQ with handle " << event->element.cq;
+      ELOG_WARN << "CQ error for CQ with handle " << event->element.cq;
       break;
 
     /* SRQ events */
     case IBV_EVENT_SRQ_ERR:
-      ELOG_ERROR << "SRQ error for SRQ with handle " << event->element.srq;
+      ELOG_WARN << "SRQ error for SRQ with handle " << event->element.srq;
       break;
     case IBV_EVENT_SRQ_LIMIT_REACHED:
       ELOG_INFO << "SRQ limit reached event for SRQ with handle "
@@ -174,8 +173,8 @@ inline void print_async_event(struct ibv_context* ctx,
                 << event->element.port_num;
       break;
     case IBV_EVENT_PORT_ERR:
-      ELOG_ERROR << "Port error event for port number "
-                 << event->element.port_num;
+      ELOG_WARN << "Port error event for port number "
+                << event->element.port_num;
       break;
     case IBV_EVENT_LID_CHANGE:
       ELOG_INFO << "LID change event for port number "
@@ -200,8 +199,8 @@ inline void print_async_event(struct ibv_context* ctx,
 
     /* RDMA device events */
     case IBV_EVENT_DEVICE_FATAL:
-      ELOG_ERROR << "Fatal error event for device "
-                 << ibv_get_device_name(ctx->device);
+      ELOG_WARN << "Fatal error event for device "
+                << ibv_get_device_name(ctx->device);
       break;
 
     default:

include/ylt/coro_io/ibverbs/ib_socket.hpp

@@ -473,12 +473,12 @@ class ib_socket_t {
   // workaround for some compiler error if we put ib_socket_config_base_t as
   // nested struct
   struct config_t {
-    uint32_t cq_size = 512;
+    uint32_t cq_size = 128;
     uint16_t recv_buffer_cnt = 8;
     uint16_t send_buffer_cnt = 4;
     ibv_qp_type qp_type = IBV_QPT_RC;
-    ibv_qp_cap cap = {.max_send_wr = 256,
-                      .max_recv_wr = 256,
+    ibv_qp_cap cap = {.max_send_wr = 32,
+                      .max_recv_wr = 32,
                       .max_send_sge = 3,
                       .max_recv_sge = 1,
                       .max_inline_data = 256};
@@ -970,7 +970,6 @@ class ib_socket_t {
       auto err_code = std::make_error_code(std::errc{ec});
       ELOG_ERROR << "modify qp to init failed: " << err_code.message()
                  << ", QP=" << state_->qp_->qp_num;
-      ;
       throw std::system_error(err_code);
     }
   }
@@ -1004,7 +1003,6 @@ class ib_socket_t {
       auto err_code = std::make_error_code(std::errc{ec});
       ELOG_ERROR << "modify qp to rtr failed: " << err_code.message()
                  << ", QP=" << state_->qp_->qp_num;
-      ;
       throw std::system_error(err_code);
     }
   }
@@ -1023,7 +1021,6 @@ class ib_socket_t {
       auto err_code = std::make_error_code(std::errc{ec});
       ELOG_ERROR << "modify qp to rts failed: " << err_code.message()
                  << ", QP=" << state_->qp_->qp_num;
-      ;
       throw std::system_error(err_code);
     }
   }