From 1dd2a1cf90eb0bc0675a1156318db31749eaaae6 Mon Sep 17 00:00:00 2001 From: Aman Gupta Date: Tue, 1 Sep 2026 20:49:22 +0800 Subject: [PATCH] fix flush for apple rdma --- ggml/src/ggml-rpc/ggml-rpc.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ggml/src/ggml-rpc/ggml-rpc.cpp b/ggml/src/ggml-rpc/ggml-rpc.cpp index 93bcbab164..67b3334f9e 100644 --- a/ggml/src/ggml-rpc/ggml-rpc.cpp +++ b/ggml/src/ggml-rpc/ggml-rpc.cpp @@ -2238,13 +2238,13 @@ bool rpc_server::comm_allreduce(const rpc_msg_comm_allreduce_req & request) { // rank 0 sends first, rank 1 receives first, so large payloads cannot deadlock if (state.rank == 0) { - if (!state.peer->send_data(state.send_buf.data(), wire_bytes) || + if (!state.peer->send_data(state.send_buf.data(), wire_bytes) || !state.peer->flush() || !state.peer->recv_data(state.recv_buf.data(), wire_bytes)) { return false; } } else { if (!state.peer->recv_data(state.recv_buf.data(), wire_bytes) || - !state.peer->send_data(state.send_buf.data(), wire_bytes)) { + !state.peer->send_data(state.send_buf.data(), wire_bytes) || !state.peer->flush()) { return false; } }