From 6523663078326fe03bfdd1b8c303e2c393d8e825 Mon Sep 17 00:00:00 2001 From: Chuang Zhu <111838961+chuangz0@users.noreply.github.com> Date: Tue, 28 Oct 2025 05:45:36 +0000 Subject: [PATCH] transferAgent_test Signed-off-by: Chuang Zhu <111838961+chuangz0@users.noreply.github.com> --- cpp/tests/unit_tests/executor/transferAgentTest.cpp | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/cpp/tests/unit_tests/executor/transferAgentTest.cpp b/cpp/tests/unit_tests/executor/transferAgentTest.cpp index 39fbb2267f5..8d9d64599af 100644 --- a/cpp/tests/unit_tests/executor/transferAgentTest.cpp +++ b/cpp/tests/unit_tests/executor/transferAgentTest.cpp @@ -259,9 +259,9 @@ TEST_F(TransferAgentTest, SyncMessage) checked = nixlAgent0->checkRemoteDescs(agent1, regMem3.getDescs()); } while (!checked); auto syncMessage = std::string("agent_sync_message"); - nixlAgent0->notifySyncMessage(agent1, syncMessage); TransferRequest writeReq{TransferOp::kWRITE, regMem0.getDescs(), regMem3.getDescs(), agent1}; auto status = nixlAgent0->submitTransferRequests(writeReq); + nixlAgent0->notifySyncMessage(agent1, syncMessage); auto notif = nixlAgent1->getNotifiedSyncMessages(); for (std::size_t i = 0; i < MAX_QUERY_TIMES && notif.size() == 0; i++) @@ -307,9 +307,10 @@ TEST_F(TransferAgentTest, SyncMessage) } while (!checked2); std::string syncMessage4 = "four_agent_sync_message"; - nixlAgent1->notifySyncMessage(agent0, syncMessage4); TransferRequest writeReq1{TransferOp::kWRITE, regMem2.getDescs(), regMem1.getDescs(), agent0}; auto status1 = nixlAgent1->submitTransferRequests(writeReq1); + nixlAgent1->notifySyncMessage(agent0, syncMessage4); + auto notif4 = nixlAgent0->getNotifiedSyncMessages(); for (std::size_t i = 0; i < MAX_QUERY_TIMES && notif4.size() == 0; i++) {