昇腾社区首页
中文
注册

aclnnDistributeBarrier

产品支持情况

产品 是否支持
[object Object]Atlas A3 训练系列产品/Atlas A3 推理系列产品[object Object]
[object Object]Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件[object Object] ×
[object Object]Atlas 200I/500 A2 推理产品[object Object] ×
[object Object]Atlas 推理系列产品 [object Object] ×
[object Object]Atlas 训练系列产品[object Object] ×

功能说明

算子功能:完成通信域内的全卡同步,xRef仅用于构建Tensor依赖,接口内不对xRef做任何操作。

函数原型

每个算子分为undefined,必须先调用 “aclnnDistributeBarrierGetWorkspaceSize”接口获取计算所需workspace大小以及包含了算子计算流程的执行器,再调用“aclnnDistributeBarrier”接口执行计算。

  • aclnnStatus aclnnDistributeBarrierGetWorkspaceSize(aclTensor* xRef, const char* group, int64_t worldSize, uint64_t* workspaceSize, aclOpExecutor** executor)
  • aclnnStatus aclnnDistributeBarrier(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, aclrtStream stream)

aclnnDistributeBarrierGetWorkspaceSize

  • 参数说明

    • xRef(aclTensor*,计算输入):Device侧的aclTensor,无业务语义,仅用于输入Tensor依赖,接口内不做任何操作。数据类型支持BFLOAT16, FLOAT16、FLOAT32、BOOL、INT8、INT16、INT32、INT64、UINT8、UINT16、UINT32、UINT64。 undefined要求为ND,支持undefined
    • group(char*,计算输入): 通信域名称,进行所有卡同步的通信域,string数据类型,字符串长度范围为[1, 128)。
    • worldSize(int64_t,计算输入):通信域size,int数据类型,取值范围[2, 384]。
    • workspaceSize(uint64_t*,出参):返回需要在Device侧申请的workspace大小。
    • executor(aclOpExecutor**,出参):返回op执行器,包含了算子计算流程。
  • 返回值

    返回aclnnStatus状态码,具体参见undefined

    [object Object]

aclnnDistributeBarrier

  • 参数说明:

    • workspace(void*,入参):在Device侧申请的workspace内存地址。
    • workspaceSize(uint64_t,入参):在Device侧申请的workspace大小,由第一段接口aclnnDistributeBarrierGetWorkspaceSize获取。
    • executor(aclOpExecutor*,入参):op执行器,包含了算子计算流程。
    • stream(aclrtStream,入参):指定执行任务的Stream。
  • 返回值:

    返回aclnnStatus状态码,具体参见undefined

约束说明

  • 通信域使用约束:

    • 一个模型中的aclnnDistributeBarrier需要使用单独通信域,该通信域中不允许有其他算子。
  • 使用场景说明:

    • 在需要进行全卡同步的网络模型中调用该算子,可以屏蔽快慢卡引入的性能波动问题,协助分析性能。
    • 可以连续调用,入图时,需将上个算子的输入、下个算子的输出作为入参传入接口。

调用示例

  • 文件准备:
    1.新建barrierDemo目录,按照下方指导在barrierDemo下新建aclnnBarrierDemo.cpp,buildBarrier.sh文件并按照如下代码修改。

    2.安装cann包,并根据下方指导编译运行barrierDemo。

  • 编译脚本

    [object Object]
  • 编译与运行:

    [object Object]
  • 示例代码如下,仅供参考

    [object Object]