UCT/DEVICE: add db index

Author: JeynmannZ

src/uct/ib/mlx5/gdaki/gdaki.cuh

@@ -273,20 +273,12 @@ UCS_F_DEVICE void uct_rc_mlx5_gda_db(uct_rc_gdaki_dev_ep_t *ep,
         wqe_base = wqe_base_orig;
     }
 
-    if (no_delay) {
+    if ((no_delay && READ_ONCE(ep->sq_ready_index) == wqe_next) ||
+        (!no_delay && ((wqe_base ^ wqe_next) & 128))) {
         uct_rc_mlx5_gda_lock(&ep->sq_lock);
         const uint64_t ready_index = ep->sq_ready_index;
-        uct_rc_mlx5_gda_ring_db(ep, ready_index);
-        uct_rc_mlx5_gda_update_dbr(ep, ready_index);
-        uct_rc_mlx5_gda_ring_db(ep, ready_index);
-        uct_rc_mlx5_gda_unlock(&ep->sq_lock);
-        return;
-    }
-
-    if (READ_ONCE(ep->sq_ready_index) == wqe_next) {
-        uct_rc_mlx5_gda_lock(&ep->sq_lock);
-        const uint64_t ready_index = ep->sq_ready_index;
-        if (ready_index == wqe_next) {
+        if (ep->sq_db_index != ready_index) {
+            ep->sq_db_index = ready_index;
             uct_rc_mlx5_gda_ring_db(ep, ready_index);
             uct_rc_mlx5_gda_update_dbr(ep, ready_index);
             uct_rc_mlx5_gda_ring_db(ep, ready_index);

src/uct/ib/mlx5/gdaki/gdaki_dev.h

@@ -19,6 +19,7 @@ typedef struct {
 
     uint64_t                     sq_rsvd_index;
     uint64_t                     sq_ready_index;
+    uint64_t                     sq_db_index;
     int                          sq_lock;
 
     uint8_t                      *sq_wqe_daddr;