Line data Source code
1 : /**
2 : * Copyright (c) 2025 Huawei Technologies Co., Ltd.
3 : * This program is free software, you can redistribute it and/or modify it under the terms and conditions of
4 : * CANN Open Software License Agreement Version 2.0 (the "License").
5 : * Please refer to the License for details. You may not use this file except in compliance with the License.
6 : * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR IMPLIED,
7 : * INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY, OR FITNESS FOR A PARTICULAR PURPOSE.
8 : * See LICENSE in the root of the software repository for the full text of the License.
9 : */
10 :
11 : #ifndef HCCLV2_CCU_TEMP_ALL_REDUCE_MESH_1D_ONE_SHOT_H_
12 : #define HCCLV2_CCU_TEMP_ALL_REDUCE_MESH_1D_ONE_SHOT_H_
13 : #include <vector>
14 : #include <map>
15 : #include <string>
16 : #include <hccl/hccl_types.h>
17 : #include "template_utils.h"
18 : #include "reduce_op.h"
19 : #include "hccl/base.h"
20 : #include "types/types.h"
21 : #include "string_util.h"
22 : #include "env_config.h"
23 : #include "data_type.h"
24 : #include "ccu_alg_template_base.h"
25 : #include "ccu_instruction_all_reduce_mesh1d.h"
26 : #include "ccu_alg_template_base.h"
27 :
28 : namespace Hccl {
29 :
30 :
31 : class CcuTempAllReduceMesh1DOneShot : public CcuAlgTemplateBase {
32 : public:
33 : explicit CcuTempAllReduceMesh1DOneShot(const RankId virtualRank, const u32 tempRankSize,
34 : const std::vector<std::vector<RankId>> &tempVTopo,
35 : const std::map<RankId, u32> &tempVirtRankMap);
36 : ~CcuTempAllReduceMesh1DOneShot() override;
37 :
38 0 : std::string Describe() const override
39 : {
40 0 : return StringFormat("Template of CcuTempAllReduceMesh1DOneShot tempRankSize [%u].", tempRankSize_);
41 : }
42 :
43 : HcclResult Run(const TempFuncs &tempFuncs, const RankSliceInfo &sliceInfoVec, const BuffInfo &buffInfo,
44 : const ResLinks &tempLinks, std::vector<InsQuePtr> &tempInsQues) override;
45 : HcclResult CalcRes(AlgTempResReq &tempResReq) override;
46 : HcclResult CalcSliceInfo(const AllignInfo &allignInfo, const u64 dataSize, RankSliceInfo &sliceInfoVec) override;
47 : // init reduceInfo
48 : void InitReduceInfo(const ReduceOp &reduceOp, const DataType &dataType);
49 :
50 : private:
51 : HcclResult CalcInputOutputAddr(const TempFuncs &tempFuncs, uint64_t &inputAddr, uint64_t &outputAddr);
52 : HcclResult PrepareLinks(const ResLinks &tempLinks, std::vector<LinkData> &links) const;
53 : HcclResult PrepareRankGroup(RankGroup &rankGroup);
54 :
55 : private:
56 : ReduceOp reduceOp_;
57 : DataType dataType_;
58 : };
59 :
60 : } // namespace Hccl
61 :
62 : #endif // HCCLV2_CCU_TEMP_ALL_REDUCE_MESH_1D_H_
|