From 9a5ef5664076a99023044b2ddc047db4370835a0 Mon Sep 17 00:00:00 2001 From: anvishwa-amd Date: Mon, 16 Mar 2026 18:59:48 +0000 Subject: [PATCH] rebase changes --- gloo/cuda_collectives_native.h | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/gloo/cuda_collectives_native.h b/gloo/cuda_collectives_native.h index dbc62cb3f..7e62d6507 100644 --- a/gloo/cuda_collectives_native.h +++ b/gloo/cuda_collectives_native.h @@ -83,10 +83,8 @@ class CudaLocalNativeReduce : public LocalOp { // Enable peer access for devA to memory on devB CUDA_CHECK(cudaSetDevice(devA)); - (void)cudaDeviceEnablePeerAccess(devB, 0); - - // Use cudaGetLastError so that any error is cleared. - auto err = cudaGetLastError(); + cudaError_t err = cudaDeviceEnablePeerAccess(devB, 0); + // peer access already enabled if (err != cudaErrorPeerAccessAlreadyEnabled) { CUDA_CHECK(err); } @@ -196,10 +194,8 @@ class CudaLocalNativeBroadcast : public LocalOp { // Enable peer access for devA to memory on devB CUDA_CHECK(cudaSetDevice(devA)); - (void)cudaDeviceEnablePeerAccess(devB, 0); - - // Use cudaGetLastError so that any error is cleared. - auto err = cudaGetLastError(); + cudaError_t err = cudaDeviceEnablePeerAccess(devB, 0); + // peer access already enabled if (err != cudaErrorPeerAccessAlreadyEnabled) { CUDA_CHECK(err); }