Skip to content

Commit b828b64

Browse files
authored
[https://nvbugs/5612529][fix] Fix transferAgent_test (#8710)
Signed-off-by: Chuang Zhu <[email protected]>
1 parent cf8a1d2 commit b828b64

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

cpp/tests/unit_tests/executor/transferAgentTest.cpp

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -259,9 +259,9 @@ TEST_F(TransferAgentTest, SyncMessage)
259259
checked = nixlAgent0->checkRemoteDescs(agent1, regMem3.getDescs());
260260
} while (!checked);
261261
auto syncMessage = std::string("agent_sync_message");
262-
nixlAgent0->notifySyncMessage(agent1, syncMessage);
263262
TransferRequest writeReq{TransferOp::kWRITE, regMem0.getDescs(), regMem3.getDescs(), agent1};
264263
auto status = nixlAgent0->submitTransferRequests(writeReq);
264+
nixlAgent0->notifySyncMessage(agent1, syncMessage);
265265

266266
auto notif = nixlAgent1->getNotifiedSyncMessages();
267267
for (std::size_t i = 0; i < MAX_QUERY_TIMES && notif.size() == 0; i++)
@@ -307,9 +307,10 @@ TEST_F(TransferAgentTest, SyncMessage)
307307
} while (!checked2);
308308

309309
std::string syncMessage4 = "four_agent_sync_message";
310-
nixlAgent1->notifySyncMessage(agent0, syncMessage4);
311310
TransferRequest writeReq1{TransferOp::kWRITE, regMem2.getDescs(), regMem1.getDescs(), agent0};
312311
auto status1 = nixlAgent1->submitTransferRequests(writeReq1);
312+
nixlAgent1->notifySyncMessage(agent0, syncMessage4);
313+
313314
auto notif4 = nixlAgent0->getNotifiedSyncMessages();
314315
for (std::size_t i = 0; i < MAX_QUERY_TIMES && notif4.size() == 0; i++)
315316
{

0 commit comments

Comments
 (0)