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); }