From 1f42d485f816e2e5b39bbb604505005198cc2a5c Mon Sep 17 00:00:00 2001
From: Wenkai Du <43822138+wenkaidu@users.noreply.github.com>
Date: Tue, 21 Feb 2023 07:49:54 -0800
Subject: [PATCH] Fix P2P scheduling (#690)

[ROCm/rccl commit: 86e7b71234f3884d86bccfe9f00217427af15afb]
---
 projects/rccl/src/enqueue.cc | 4 ----
 1 file changed, 4 deletions(-)

diff --git a/projects/rccl/src/enqueue.cc b/projects/rccl/src/enqueue.cc
index f4162bb278..33502ef928 100644
--- a/projects/rccl/src/enqueue.cc
+++ b/projects/rccl/src/enqueue.cc
@@ -645,8 +645,6 @@ static ncclResult_t scheduleP2pTasksToPlan(
               ncclIntruQueueDequeue(&peers[recvPeer].recvQueue);
               tasks->nTasksP2p -= 1;
             }
-          } else {
-            NCCLCHECK(addP2pToPlan(comm, plan, nWorkBudget, /*isSendNotRecv=*/false, recvPeer, 0, nullptr, 0, recvIdx));
           }
           if (sendChunkBytes != 0) {
             if (sendChunkBytes == -1) sendChunkBytes = 0;
@@ -660,8 +658,6 @@ static ncclResult_t scheduleP2pTasksToPlan(
               ncclIntruQueueDequeue(&peers[sendPeer].sendQueue);
               tasks->nTasksP2p -= 1;
             }
-          } else {
-            NCCLCHECK(addP2pToPlan(comm, plan, nWorkBudget, /*isSendNotRecv=*/true, sendPeer, 0, nullptr, 0, sendIdx));
           }
         } while (sendBytes != 0 || recvBytes != 0);
       }