Batch handle_immediate_ops more

2026-04-22 01:41:29 +03:00
parent 64dd98a4d6
commit a1ac51da24
3 changed files with 7 additions and 5 deletions
@@ -571,7 +571,7 @@ static void try_send_rdma_wr(osd_client_t *cl, ibv_sge *sge, int op_sge)
 int osd_messenger_t::try_send_rdma_copy(osd_client_t *cl, uint8_t *dst, int dst_len)
 {
    int total_dst_len = dst_len;
-    while (dst_len > 0 && cl->write_ops.size())
+    while (dst_len > 0 && (cl->write_op || cl->write_ops.size()))
    {
        if (!cl->write_op)
        {
@@ -762,5 +762,4 @@ void osd_messenger_t::handle_rdma_events(msgr_rdma_context_t *rdma_context)
            }
        }
    } while (event_count > 0);
-    handle_immediate_ops();
 }