IBSet样例

概述

本样例基于IBSet实现核间同步,适用于以下场景:当不同核之间操作同一块全局内存且可能存在读后写、写后读以及写后写等数据依赖问题时,通过调用该函数来插入同步语句来避免上述数据依赖时可能出现的数据读写错误问题。

支持的产品

  • Ascend 950PR/Ascend 950DT
  • Atlas A3 训练系列产品/Atlas A3 推理系列产品
  • Atlas A2 训练系列产品/Atlas A2 推理系列产品

目录结构介绍

├── ib_set
│   ├── scripts
│   │   ├── gen_data.py         // 输入数据和真值数据生成脚本
│   │   └── verify_result.py    // 验证输出数据和真值数据是否一致的验证脚本
│   ├── CMakeLists.txt          // 编译工程文件
│   ├── data_utils.h            // 数据读入写出函数
│   └── ib_set.asc      // Ascend C算子实现 & 调用样例

算子描述

  • 算子功能:

    当不同核之间操作同一块全局内存且可能存在读后写、写后读以及写后写等数据依赖问题时,通过调用该函数来插入同步语句来避免上述数据依赖时可能出现的数据读写错误问题。调用IBSet设置某一个核的标志位,与IBWait成对出现配合使用,表示核之间的同步等待指令,等待某一个核操作完成。

  • 算子规格:

    算子输入nameshapedata typeformat
    x512halfND
    y512halfND
    算子输出z512halfND
    核函数名ib_set_custom
  • 算子实现:

    • kernel实现

      本算子的Process中为两个核分别调用IBSet核IBWait以便操作同一块全局内存时实现同步,避免数据依赖。Process还包括以下3个基本任务:CopyIn,Compute,CopyOut。CopyIn任务中如果当前blockIdx == 0,那么将Global Memory中输入Tensor xGm和yGm的数据分别搬入到xLocal和yLocal中;如果当前blockIdx == 1,那么将Global Memory中输入Tensor zGm和yGm的数据分别搬入到xLocal和yLocal中。Compute任务负责对xLocal、yLocal执行加法操作,计算结果存储在zLocal中。CopyOut任务负责将输出数据从zLocal搬运至Global Memory上的输出Tensor zGm中。

    • 调用实现
      使用内核调用符<<<>>>调用核函数。

编译运行

在本样例根目录下执行如下步骤,编译并执行算子。

  • 配置环境变量
    请根据当前环境上CANN开发套件包的安装方式,选择对应配置环境变量的命令。

    • 默认路径,root用户安装CANN软件包

      source /usr/local/Ascend/cann/set_env.sh
      
    • 默认路径,非root用户安装CANN软件包

      source $HOME/Ascend/cann/set_env.sh
      
    • 指定路径install_path,安装CANN软件包

      source ${install_path}/cann/set_env.sh
      
  • 样例执行

    mkdir -p build && cd build;   # 创建并进入build目录
    cmake ..;make -j;             # 编译工程
    python3 ../scripts/gen_data.py   # 生成测试输入数据
    ./demo                        # 执行编译生成的可执行程序,执行样例
    python3 ../scripts/verify_result.py output/output.bin output/golden.bin   # 验证输出结果是否正确,确认算法逻辑正确
    

    执行结果如下,说明精度对比成功。

    test pass!