Limit P2P channels per peer to not exceeding max channels (#1594)

* Limit P2P channels per peer to not exceeding max channels

* [UT] test single GPU cases for all collectives

* [UT] fix out of range root value
Tá an tiomantas seo le fáil i:
Wenkai Du údaraithe agus GitHub tiomanta 2025-03-11 09:32:09 -07:00
1 tuismitheoir f6c6d451a9
tiomantas 4237caad69
3 comhad athraithe
+4 -2

Níor tháinig aon chomhaid le do chuardach

+1 -1
Féach ar an gComhad
@@ -204,7 +204,7 @@ namespace RcclUnitTesting
getArchInfo(&isGfx12, "gfx12");
showNames = GetEnvVar("UT_SHOW_NAMES" , 1);
minGpus = GetEnvVar("UT_MIN_GPUS" , 2);
minGpus = GetEnvVar("UT_MIN_GPUS" , 1);
maxGpus = GetEnvVar("UT_MAX_GPUS" , numDetectedGpus);
processMask = GetEnvVar("UT_PROCESS_MASK", UT_SINGLE_PROCESS | UT_MULTI_PROCESS);
verbose = GetEnvVar("UT_VERBOSE" , 0);
+1 -1
Féach ar an gComhad
@@ -695,7 +695,7 @@ namespace RcclUnitTesting
&numInputElements,
&numOutputElements);
optionalArgs.redOp = redOps[rdIdx];
optionalArgs.root = roots[rtIdx];
optionalArgs.root = roots[rtIdx] % this->numActiveRanks;
this->SetCollectiveArgs(funcTypes[ftIdx],
dataTypes[dtIdx],
numInputElements,