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 : #include "mem_transport_callback_lite.h"
12 :
13 : namespace Hccl {
14 :
15 4 : MemTransportCallbackLite::MemTransportCallbackLite(const LinkData link, MirrorTaskManagerLite& mirrorTaskManagerLite)
16 4 : : link_(link),
17 4 : mirrorTaskManagerLite_(mirrorTaskManagerLite)
18 4 : {}
19 :
20 0 : void MemTransportCallbackLite::operator()(u32 streamId, u32 taskId, const TaskParam& taskParam)
21 : {
22 : std::unique_ptr<TaskInfo> taskInfo = std::make_unique<TaskInfo>(
23 0 : streamId, taskId, link_.GetRemoteRankId(), taskParam, mirrorTaskManagerLite_.GetCurrDfxOpInfo());
24 :
25 0 : mirrorTaskManagerLite_.AddTaskInfo(std::move(taskInfo));
26 0 : return;
27 0 : }
28 :
29 : } // namespace Hccl
|