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_2D_TWO_SHOT_MEM2MEM_H_
12 : #define HCCLV2_CCU_TEMP_ALL_REDUCE_MESH_2D_TWO_SHOT_MEM2MEM_H_
13 :
14 : #include "string_util.h"
15 : #include "env_config.h"
16 : #include "ccu_alg_template_base.h"
17 : #include "ccu_rank_group.h"
18 : #include "template_utils.h"
19 :
20 : namespace Hccl {
21 : class CcuTempAllReduceMeshTwoShotMem2Mem2D : public CcuAlgTemplateBase {
22 : public:
23 : explicit CcuTempAllReduceMeshTwoShotMem2Mem2D(const RankId virtualRank, const u32 tempRankSize,
24 : const std::vector<std::vector<RankId>> &tempVTopo,
25 : const std::map<RankId, u32> &tempVirtRankMap);
26 : ~CcuTempAllReduceMeshTwoShotMem2Mem2D() override;
27 :
28 0 : std::string Describe() const override
29 : {
30 0 : return StringFormat("Template of All Reduce ccu mesh Mem2Mem 2D with tempRankSize [%u].", tempRankSize_);
31 : }
32 :
33 : HcclResult Run(const TempFuncs &tempFuncs, const RankSliceInfo &sliceInfoVec, const BuffInfo &buffInfo,
34 : const ResLinks &tempLinks, std::vector<InsQuePtr> &tempInsQues) override;
35 : HcclResult CalcRes(AlgTempResReq &tempResReq) override;
36 : HcclResult CalcSliceInfo(const AllignInfo &allignInfo, const u64 dataSize, RankSliceInfo &sliceInfoVec) override;
37 : // init reduceInfo
38 : void InitReduceInfo(const ReduceOp &reduceOp, const DataType &dataType);
39 :
40 : private:
41 : HcclResult PrepareLinks(const ResLinks &tempLinks);
42 : HcclResult PrepareRankGroups();
43 : HcclResult GetBufferAddr(const TempFuncs &tempFuncs, uint64_t &inputAddr, uint64_t &outputAddr);
44 :
45 : // 内部计算用到的变量
46 : ReduceOp reduceOp_;
47 : DataType dataType_;
48 : RankGroup rankGroupY_;
49 : RankGroup rankGroupX_;
50 : std::vector<uint64_t> dimSize_;
51 : std::vector<LinkData> linksX_;
52 : std::vector<LinkData> linksY_;
53 : };
54 :
55 : } // namespace Hccl
56 :
57 : #endif // HCCLV2_CCU_TEMP_ALL_REDUCE_MESH_2D_TWO_SHOT_MEM2MEM_H_
|