Skip to content
Open
3 changes: 1 addition & 2 deletions apps/nccl/src/allgather.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -103,12 +103,11 @@ __global__ void __launch_bounds__(1024, 1)
}
}

deviceSyncer.sync(gridDim.x);

if (threadIdx.x < nPeer) {
smChans[threadIdx.x].relaxedSignal();
smChans[threadIdx.x].wait();
}
__syncthreads();
}

template <bool IsOutOfPlace, typename T>
Expand Down
Loading