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]