Searched refs:REDUCTION_COLLECTIVE (Results 1 – 13 of 13) sorted by relevance
25 NcclReducer() : NcclBase(REDUCTION_COLLECTIVE, "NcclReduce") {} in NcclReducer()
38 case REDUCTION_COLLECTIVE: in InitializeCollectiveParams()
213 col_params_->instance.type = REDUCTION_COLLECTIVE; in CollectiveReduceOpKernel()527 col_params->instance.type = REDUCTION_COLLECTIVE; in ComputeAsync()
449 : NcclTestBase(/*collective_type=*/REDUCTION_COLLECTIVE, in NcclReducerTest()
33 RingReducer() : RingAlg(REDUCTION_COLLECTIVE, "Reduce") {} in RingReducer()
300 const Tensor* input = (col_params->instance.type == REDUCTION_COLLECTIVE || in ExecuteAsync()410 col_params.instance.type == REDUCTION_COLLECTIVE) { in CreateCollective()
50 CHECK_EQ(col_params->instance.type, REDUCTION_COLLECTIVE); in InitializeCollectiveParams()
217 col_params_->instance.type = REDUCTION_COLLECTIVE; in Init()580 cp->instance.type = REDUCTION_COLLECTIVE; in SetUpCollectiveParams()
175 cp->instance.type = REDUCTION_COLLECTIVE; in TEST_F()
64 case REDUCTION_COLLECTIVE: in GetCollectiveName()
136 case REDUCTION_COLLECTIVE: { in Enqueue()
44 REDUCTION_COLLECTIVE = 0, enumerator
201 cp->instance.type = REDUCTION_COLLECTIVE; in CreateCollectiveParams()