* Copyright (c) 2025 Huawei Technologies Co., Ltd.
* This program is free software, you can redistribute it and/or modify it under the terms and conditions of
* CANN Open Software License Agreement Version 2.0 (the "License").
* Please refer to the License for details. You may not use this file except in compliance with the License.
* THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR IMPLIED,
* INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY, OR FITNESS FOR A PARTICULAR PURPOSE.
* See LICENSE in the root of the software repository for the full text of the License.
*/
#ifndef GE_GRAPH_LOAD_NEW_MODEL_MANAGER_ZERO_COPY_OFFSET_H_
#define GE_GRAPH_LOAD_NEW_MODEL_MANAGER_ZERO_COPY_OFFSET_H_
#include <map>
#include <set>
#include <string>
#include <vector>
#include "graph/utils/tensor_utils.h"
#include "graph/load/model_manager/task_info/task_info.h"
#include "ge/ge_api_error_codes.h"
#include "graph/debug/ge_attr_define.h"
#include "graph/op_desc.h"
namespace ge {
class ZeroCopyOffset {
public:
ZeroCopyOffset() = default;
~ZeroCopyOffset() = default;
Status InitInputDataInfo(const int64_t output_size, void *const virtual_addr,
const OpDescPtr &op_desc, bool &fusion_flag);
Status SetInputOutsideAddrs(const int64_t output_offset, const uintptr_t addr_val, const bool fusion_flag,
std::set<uint64_t> &real_virtual_addrs);
static void IsL2Fusion(const std::vector<int64_t> &fusion_basic_addrs, const int64_t tensor_addr, bool &fusion_flag);
Status InitOutputDataInfo(const std::vector<int64_t> &input_size_list, const std::vector<uint64_t> &virtual_addr_list,
const OpDescPtr &op_desc, const size_t idx, bool &fusion_flag);
Status SetOutputOutsideAddrs(const int64_t input_offset, const bool fusion_flag, const uintptr_t addr_val,
std::vector<uint64_t> &tensor_addrs);
void SetOutsideAddrsValue(const uintptr_t outside_addr, const bool is_tiling,
const uintptr_t args_base, const size_t offset);
void SetLogicalOutsideAddrs(const uintptr_t logical_addr, const bool is_tiling, const uintptr_t device_addr);
void *GetBasicAddr() const { return basic_addr_; }
size_t GetDataCount() const { return data_count_; }
size_t GetAddrCount() const { return addr_count_; }
const std::vector<std::pair<int64_t, uint64_t>> &GetDataInfo() const { return data_info_; }
const std::vector<int64_t> &GetRelativeOffset() const { return relative_offset_; }
int64_t GetDataSize() const { return data_size_; }
const std::vector<std::map<uintptr_t, std::vector<uintptr_t>>> &GetOutsideAddrs() const { return outside_addrs_; }
const std::map<uintptr_t, bool> &GetOutsideAddrsIsTiling() const {return outside_addrs_is_tiling_; }
const std::string &GetOpName() const { return op_name_; }
bool IsRelativeOffsetValid() const { return valid_relative_offset_; }
private:
void *basic_addr_ = nullptr;
std::string op_name_;
size_t data_count_ = 0U;
std::vector<std::pair<int64_t, uint64_t>> data_info_;
std::vector<int64_t> relative_offset_;
int64_t data_size_ = 0;
size_t addr_count_ = 0U;
std::vector<std::map<uintptr_t, std::vector<uintptr_t>>> outside_addrs_;
std::map<uintptr_t, bool> outside_addrs_is_tiling_;
std::vector<int64_t> zero_copy_basic_offset_;
std::vector<int64_t> zero_copy_relative_offset_;
bool valid_relative_offset_ = false;
};
}
#endif