diff options
Diffstat (limited to 'src/misc/argcheck.cc')
-rw-r--r-- | src/misc/argcheck.cc | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/misc/argcheck.cc b/src/misc/argcheck.cc index 27623b2..c262f8c 100644 --- a/src/misc/argcheck.cc +++ b/src/misc/argcheck.cc @@ -45,11 +45,11 @@ ncclResult_t ArgsCheck(struct ncclInfo* info) { } // Type is OK, compute nbytes. Convert Allgather/Broadcast/P2P calls to chars. info->nBytes = info->count * ncclTypeSize(info->datatype); - if (info->coll == ncclCollAllGather || info->coll == ncclCollBroadcast) { + if (info->coll == ncclFuncAllGather || info->coll == ncclFuncBroadcast) { info->count = info->nBytes; info->datatype = ncclInt8; } - if (info->coll == ncclCollAllGather || info->coll == ncclCollReduceScatter) info->nBytes *= info->comm->nRanks; // count is per rank + if (info->coll == ncclFuncAllGather || info->coll == ncclFuncReduceScatter) info->nBytes *= info->comm->nRanks; // count is per rank if (info->op < 0 || info->op >= ncclNumOps) { WARN("%s : invalid reduction operation %d", info->opName, info->op); @@ -57,7 +57,7 @@ ncclResult_t ArgsCheck(struct ncclInfo* info) { } if (info->comm->checkPointers) { - if (info->coll == ncclCollSendRecv) { + if (info->coll == ncclFuncSendRecv) { if (strcmp(info->opName, "Send") == 0) { NCCLCHECK(CudaPtrCheck(info->sendbuff, info->comm, "sendbuff", "Send")); } else { @@ -65,10 +65,10 @@ ncclResult_t ArgsCheck(struct ncclInfo* info) { } } else { // Check CUDA device pointers - if (info->coll != ncclCollBroadcast || info->comm->rank == info->root) { + if (info->coll != ncclFuncBroadcast || info->comm->rank == info->root) { NCCLCHECK(CudaPtrCheck(info->sendbuff, info->comm, "sendbuff", info->opName)); } - if (info->coll != ncclCollReduce || info->comm->rank == info->root) { + if (info->coll != ncclFuncReduce || info->comm->rank == info->root) { NCCLCHECK(CudaPtrCheck(info->recvbuff, info->comm, "recvbuff", info->opName)); } } |