aclnnBatchMatMul
aclnnAvgPool2dBackward
接口原型
每个算子有两段接口,必须先调用“aclnnXxxGetWorkspaceSize”接口获取入参并根据计算流程计算所需workspace大小,再调用“aclnnXxx”接口执行计算。两段式接口如下:
- **第一段接口:**aclnnStatus aclnnAvgPool2dBackwardGetWorkspaceSize(const aclTensor *gradOutput, const aclTensor *self, const aclIntArray *kernelSize, const aclIntArray *stride, const aclIntArray *padding, bool ceilMode, bool countIncludePad, int64_t divisorOverride, int8_t cubeMathType, aclTensor *gradInput , uint64_t &workspaceSize, aclOpExecutor **executor)
- **第二段接口:**aclnnStatus aclnnAvgPool2dBackward(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, aclrtStream stream)
功能描述
-
算子功能:二维平均池化(aclnnAvgPool2d)的反向传播,计算二维平均池化正向传播的输入梯度。
-
计算公式:
假设二维平均池化正向的输入特征张量为X,输出特征张量为Y,池化窗口大小为k∗k,步长为s,则X的梯度∂L/∂X计算公式为
各参数含义如下:
- L为损失函数,⌊⋅⌋表示向下取整。
- Xi, j:输入特征图中第i行,第j列的像素值。
- Y⌊(i∗s+m)/k⌋, ⌊(j∗s+n)/k⌋:输出特征图中第⌊(i∗s+m)/k⌋行,第⌊(j∗s+n)/k⌋列的像素值。
aclnnAvgPool2dBackwardGetWorkspaceSize
-
接口定义:
aclnnStatus aclnnAvgPool2dBackwardGetWorkspaceSize(const aclTensor *gradOutput, const aclTensor *self, const aclIntArray *kernelSize, const aclIntArray *stride, const aclIntArray *padding, bool ceilMode, bool countIncludePad, int64_t divisorOverride, int8_t cubeMathType, aclTensor *gradInput , uint64_t &workspaceSize, aclOpExecutor **executor)
-
参数说明:
- gradOutput:Device侧的aclTensor,公式中的∂L/∂Y,数据类型支持FLOAT16和FLOAT。支持非连续的Tensor。数据格式支持NCHW和NCL。
- self:Device侧的aclTensor,平均池化正向过程中的输入张量X,数据类型支持FLOAT16和FLOAT。支持非连续的Tensor。数据格式支持NCHW和NCL。
- kernelSize:Host侧的aclIntArray,INT64的数组,长度为1(kH=kW)或2(kH, kW),表示池化窗口大小。数值必须大于0。
- stride:Host侧的aclIntArray,INT64的数组,长度为为1(sH=sW)或2(sH, sW),表示步长大小。数值必须大于0。
- padding:Host侧的aclIntArray,平均池化正向传播过程中对于输入的填充,数据类型为INT64,长度为1(padH=padW)或2(padH, padW),表示输入的H、W方向上padding补0的层数。支持padding小于0,padding的上限不能超过kernelSize对应位置的一半,比如kernelSize的H为2,padding的H最大只能为1。
- ceilMode:Host侧的布尔型,表示平均池化正向过程中推导输出shape是否向上取整。数据类型支持BOOL。
- countIncludePad:Host侧的布尔型,计算平均池化时是否包括padding填充。数据类型支持BOOL。
- divisorOverride:Host侧的整型,表示取平均的除数。数据类型支持INT64。支持范围为[-255, 255]。如果该值为0,表示不影响padding是否参与平均计算。
- cubeMathType:Host侧的整型,判断Cube单元应该使用哪种计算逻辑进行运算,支持INT8类型的枚举值,枚举值如下:
- 0:KEPP_DTYPE,保持输入的数据类型进行计算。
- 1:ALLOW_FP32_DOWN_PRECISION,允许转换输入数据类型降低精度计算。
- gradInput:Device侧的aclTensor,公式中的∂L/∂X。数据类型支持FLOAT16和FLOAT。支持非连续的Tensor。支持数据格式为NCHW和NCL。数据类型、数据格式需要与self一致。
- workspaceSize:返回用户需要在Device侧申请的workspace大小。
- executor:返回op执行器,包含了算子计算流程。
-
返回值:
返回aclnnStatus状态码,具体参见aclnn返回码。
:::note 说明 第一段接口完成入参校验,出现以下场景时报错:
- 返回161001(ACLNN_ERR_PARAM_NULLPTR):传入的gradOutput、self、kernelSize、stride、padding或gradInput是空指针。
- 返回161002(ACLNN_ERR_PARAM_INVALID):
- 传入的gradOutput或gradInput的数据类型或数据格式不在支持的范围之内。
- 传入的self和gradInput数据类型或数据格式不一致。
- 传入的gradOutput、self、kernelSize、stride或gradInput维度不在支持的范围内。
- 传入的gradOutput、self、kernelSize、stride或gradInput在某维度的值小于0。
- 传入的cubeMathType取值不在支持范围内。
- padding不能超过kernelSize对应位置的1/2,比如paddingH=2, kerneSizeH=2,paddingH>1/2*kerneSizeH。 :::
aclnnAvgPool2dBackward
-
接口定义:
aclnnStatus aclnnAvgPool2dBackward(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, aclrtStream stream)
-
参数说明:
- workspace:在Device侧申请的workspace内存起址。
- workspaceSize:在Device侧申请的workspace大小,由第一段接口aclnnAvgPool2dBackwardGetWorkspaceSize获取。
- executor:op执行器,包含了算子计算流程。
- stream:指定执行任务的AscendCL stream流。
-
返回值:
返回aclnnStatus状态码,具体参见aclnn返回码。
调用示例
<br> 1<br> 2<br> 3<br> 4<br> 5<br> 6<br> 7<br> 8<br> 9<br> 10<br> 11<br> 12<br> 13<br> 14<br> 15<br> 16<br> 17<br> 18<br> 19<br> 20<br> 21<br> 22<br> 23<br> 24<br> 25<br> 26<br> 27<br> 28<br> 29<br> 30<br> 31<br> 32<br> 33<br> 34<br> 35<br> 36<br> 37<br> 38<br> 39<br> 40<br> 41<br> 42<br> 43<br> 44<br> 45<br> 46<br> 47<br> 48<br> 49<br> 50<br> 51<br> 52<br> 53<br> 54<br> 55<br> 56<br> 57<br> 58<br> 59<br> 60<br> 61<br> 62<br> 63<br> 64<br> 65<br> 66<br> 67<br> 68<br> 69<br> 70<br> 71<br> 72<br> 73<br> 74<br> 75<br> 76<br> 77<br> 78<br> 79<br> 80<br> 81<br> 82<br> 83<br> 84<br> 85<br> 86<br> 87<br> 88<br> 89<br> 90<br> 91<br> 92<br> 93<br> 94<br> 95<br> 96<br> 97<br> 98<br> 99<br>100<br>101<br>102<br>103<br>104<br>105<br>106<br>107<br>108<br>109<br>110<br>111<br>112<br>113<br>114<br>115<br>116<br>117<br>118<br>119<br>120<br>121<br>122<br>123<br>124<br>125<br>126<br>127<br>128<br>129<br>130<br>131<br>132<br>133<br>134<br>135<br>136<br>137<br>138<br>139<br>140<br>141<br>142<br>143<br>144<br>145<br>146<br>147<br>148<br>149<br>150<br>151<br>152<br> | cpp<br>#include <vector><br>#include "acl/acl.h"<br>#include "aclnnop/aclnn_avgpool2dbackward.h"<br>#define CHECK_RET(cond, return_expr) \<br> do { \<br> if (!(cond)) { \<br> return_expr; \<br> } \<br> } while (0)<br>#define LOG_PRINT(message, ...) \<br> do { \<br> printf(message, ##__VA_ARGS__); \<br> } while (0)<br>int64_t GetShapeSize(const std::vector<int64_t>& shape) {<br> int64_t shapeSize = 1;<br> for (auto i : shape) {<br> shapeSize *= i;<br> }<br> return shapeSize;<br>}<br>int Init(int32_t deviceId, aclrtContext* context, aclrtStream* stream) {<br> // 固定写法,AscendCL初始化<br> auto ret = aclInit(nullptr);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclInit failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtSetDevice(deviceId);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSetDevice failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtCreateContext(context, deviceId);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtCreateContext failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtSetCurrentContext(*context);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSetCurrentContext failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtCreateStream(stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtCreateStream failed. ERROR: %d\n", ret); return ret);<br> return 0;<br>}<br>template <typename T><br>int CreateAclTensor(const std::vector<T>& hostData, const std::vector<int64_t>& shape, void** deviceAddr,<br> aclDataType dataType, aclTensor** tensor) {<br> auto size = GetShapeSize(shape) * sizeof(T);<br> // 调用aclrtMalloc申请device侧内存<br> auto ret = aclrtMalloc(deviceAddr, size, ACL_MEM_MALLOC_HUGE_FIRST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtMalloc failed. ERROR: %d\n", ret); return ret);<br> // 调用aclrtMemcpy将host侧数据拷贝到device侧内存上<br> ret = aclrtMemcpy(*deviceAddr, size, hostData.data(), size, ACL_MEMCPY_HOST_TO_DEVICE);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtMemcpy failed. ERROR: %d\n", ret); return ret);<br> // 计算连续tensor的strides<br> std::vector<int64_t> stride(shape.size(), 1);<br> for (int64_t i = shape.size() - 2; i >= 0; i--) {<br> stride[i] = shape[i + 1] * stride[i + 1];<br> }<br> // 调用aclCreateTensor接口创建aclTensor<br> *tensor = aclCreateTensor(shape.data(), shape.size(), dataType, stride.data(), 0, aclFormat::ACL_FORMAT_ND,<br> shape.data(), shape.size(), *deviceAddr);<br> return 0;<br>}<br>int main() {<br> // 1. (固定写法)device/context/stream初始化,参考AscendCL对外接口列表<br> // 根据自己的实际device填写deviceId<br> int32_t deviceId = 0;<br> aclrtContext context;<br> aclrtStream stream;<br> auto ret = Init(deviceId, &context, &stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("Init acl failed. ERROR: %d\n", ret); return ret);<br> // 2. 构造输入与输出,需要根据API的接口自定义构造<br> std::vector<int64_t> gradOutputShape = {1, 16, 1, 1};<br> std::vector<int64_t> selfShape = {1, 16, 4, 4};<br> std::vector<int64_t> kernelDims = {4, 4};<br> std::vector<int64_t> strideDims = {1, 1};<br> std::vector<int64_t> paddingDims = {0, 0};<br> bool ceilMode = false;<br> int64_t divisorOverride = 0;<br> bool countIncludePad = true;<br> int8_t cubeMathType = 1;<br> std::vector<int64_t> gradInputShape = {1, 16, 4, 4};<br> void* gradOutputDeviceAddr = nullptr;<br> void* selfDeviceAddr = nullptr;<br> void* gradInputDeviceAddr = nullptr;<br> aclTensor* gradOutput = nullptr;<br> aclTensor* self = nullptr;<br> aclTensor* gradInput = nullptr;<br> std::vector<float> gradOutputHostData(GetShapeSize(gradOutputShape) * 2, 1);<br> std::vector<float> selfHostData(GetShapeSize(self) * 2, 1);<br> std::vector<float> gradInputHostData(GetShapeSize(gradInputShape) * 2, 1);<br> // gradOutput aclTensor<br> ret = CreateAclTensor(gradOutputHostData, gradOutputShape, &gradOutputDeviceAddr, aclDataType::ACL_FLOAT, &gradOutput);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建self aclTensor<br> ret = CreateAclTensor(selfHostData, selfShape, &selfDeviceAddr, aclDataType::ACL_FLOAT, &self);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建 gradInput aclTensor<br> ret = CreateAclTensor(gradInputputHostData, gradInputShape, &gradInputDeviceAddr, aclDataType::ACL_FLOAT, &gradInput);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建kernel aclIntArray<br> aclIntArray *kernelSize = aclCreateIntArray(kernelDims.data(), 2);<br> CHECK_RET(kernelSize != nullptr, return ACLNN_ERR_PARAM_NULLPTR);<br> // 创建stride aclIntArray<br> aclIntArray *stride = aclCreateIntArray(strideDims.data(), 2);<br> CHECK_RET(stride != nullptr, return ACLNN_ERR_PARAM_NULLPTR);<br> // 创建paddings aclIntArray<br> aclIntArray *padding = aclCreateIntArray(paddingDims.data(), 2);<br> CHECK_RET(padding != nullptr, return ACLNN_ERR_PARAM_NULLPTR);<br> // 3. 调用CANN算子库API,需要修改为具体的API名称<br> uint64_t workspaceSize = 0;<br> aclOpExecutor* executor;<br> // 调用aclnnAvgPool2dBackward第一段接口<br> ret = aclnnAvgPool2dBackwardGetWorkspaceSize(gradOutput,self,kernelSize,stride,padding,ceilMode,<br> countIncludePad,divisorOverride,cubeMathType,gradInput,&workspaceSize, &executor);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclnnAvgPool2dBackwardGetWorkspaceSize failed. ERROR: %d\n", ret); return ret);<br> // 根据第一段接口计算出的workspaceSize申请device内存<br> void* workspaceAddr = nullptr;<br> if (workspaceSize > 0) {<br> ret = aclrtMalloc(&workspaceAddr, workspaceSize, ACL_MEM_MALLOC_HUGE_FIRST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("allocate workspace failed. ERROR: %d\n", ret); return ret);<br> }<br> // 调用aclnnAvgPool2dBackward第二段接口<br> ret = aclnnAvgPool2dBackward(workspaceAddr, workspaceSize, executor, stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclnnAvgPool2dBackward failed. ERROR: %d\n", ret); return ret);<br> // 4. (固定写法)同步等待任务执行结束<br> ret = aclrtSynchronizeStream(stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSynchronizeStream failed. ERROR: %d\n", ret); return ret);<br> // 5. 获取输出的值,将device侧内存上的结果拷贝至host侧,需要根据具体API的接口定义修改<br> auto size = GetShapeSize(gradInputShape);<br> std::vector<float> outData(size, 0);<br> ret = aclrtMemcpy(outData.data(), outData.size() * sizeof(outData[0]), gradInputDeviceAddr,<br> size * sizeof(outData[0]), ACL_MEMCPY_DEVICE_TO_HOST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("copy result from device to host failed. ERROR: %d\n", ret); return ret);<br> for (int64_t i = 0; i < size; i++) {<br> LOG_PRINT("out result[%ld] is: %f\n", i, outData[i]);<br> }<br> // 6. 释放aclTensor和aclScalar,需要根据具体API的接口定义修改<br> aclDestroyTensor(gradOutput);<br> aclDestroyTensor(self);<br> aclDestroyTensor(gradInput);<br> aclDestroyIntArray(kernelSize);<br> aclDestroyIntArray(stride);<br> aclDestroyIntArray(padding);<br> return 0;<br>}<br> |
|---|
父主题: NN类算子接口
aclnnBaddbmm/aclnnInplaceBaddbmm
接口原型
:::note 说明
-
aclnnBaddbmm和aclnnInplaceBaddbmm实现相同的功能,其使用区别如下,请根据自身实际场景选择合适的算子。
- aclnnBaddbmm:需新建一个输出张量对象存储计算结果。
- aclnnInplaceBaddbmm:无需新建输出张量对象,直接在输入张量的内存中存储计算结果。
-
每个算子分为两段接口,必须先调用“aclnnXxxGetWorkspaceSize”接口获取入参并根据计算流程计算所需workspace大小,再调用“aclnnXxx”接口执行计算。 :::
-
aclnnBaddbmm两段式接口如下:
- **第一段接口:**aclnnStatus aclnnBaddbmmGetWorkSpaceSize(const aclTensor *self, const aclTensor *batch1, const aclTensor *batch2, const aclScalar *beta, const aclScalar *alpha, aclTensor *out, int8_t cubeMathType, uint64_t *workspaceSize, aclOpExecutor **executor)
- **第二段接口:**aclnnStatus aclnnBaddbmm(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, aclrtStream stream)
-
aclnnInplaceBaddbmm两段式接口如下:
- **第一段接口:**aclnnStatus aclnnInplaceBaddbmmGetWorkSpaceSize(const aclTensor *selfRef, const aclTensor *batch1, const aclTensor *batch2, const aclScalar *beta, const aclScalar *alpha, int8_t cubeMathType, uint64_t *workspaceSize, aclOpExecutor **executor)
- 第二段接口:aclnnStatus aclnnInplaceBaddbmm(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, aclrtStream stream)
功能描述
-
算子功能:计算α与batch1、batch2矩阵乘结果的乘积,再与β和self的乘积求和。其中batch1、batch2必须是3维张量,两个shape不支持做broadcast,而self需支持和batch1@batch2的结果做broadcast。
-
计算公式:
-
示例:
假设self的shape是(A, M, K),batch1@batch2的shape是(1, M, 1),那么输出out的shape为(A, M, K)。每一个维度的数字需要相等或其中一个为1。
注意,若此时batch1@batch2的shape是(2, M, 2),那么算子会因不能完成broadcast出现报错。
aclnnBaddbmmGetWorkspaceSize
-
接口定义:
aclnnStatus aclnnBaddbmmGetWorkSpaceSize(const aclTensor *self, const aclTensor *batch1, const aclTensor *batch2, const aclScalar *beta, const aclScalar *alpha, aclTensor *out, int8_t cubeMathType, uint64_t *workspaceSize, aclOpExecutor **executor)
-
参数说明:
-
self:Device侧的aclTensor,数据类型支持FLOAT16、FLOAT、BFLOAT16(仅Atlas A2训练系列产品支持),且数据类型与batch1@batch2的数据类型需满足数据类型推导规则,shape需要与batch1@batch2满足broadcast关系。数据格式支持ND,支持非连续Tensor,支持空Tensor。
:::note 说明
- 对于数据类型,只能batch1@batch2的dtype向self推导,不能反过来,因此若self为FLOAT16,batch1@batch2为FLOAT,会报错。
- 对于shape,只能是self通过broadcast变成和batch1@batch2一样的shape,不可以是batch1@batch2的shape通过broadcast变成和self一样。例如self的shape是(1, 3, 5), batch1@batch2的shape是(1, 1, 1),执行会报错。 :::
-
batch1:Device侧的aclTensor,数据类型支持FLOAT16、FLOAT、BFLOAT16(仅Atlas A2训练系列产品支持),且数据类型与batch2、self的数据类型需满足数据类型推导规则。shape需要与batch2满足bmm输入约束条件。数据格式支持ND,支持非连续Tensor,支持空Tensor。
-
batch2:Device侧的aclTensor,数据类型支持FLOAT16、FLOAT、BFLOAT16(仅Atlas A2训练系列产品支持),且数据类型与batch1、self的数据类型需满足数据类型推导规则。shape需要与batch1满足bmm输入约束条件。数据格式支持ND,支持非连续Tensor,支持空Tensor。
-
beta:Host侧的aclScalar,数据类型支持FLOAT、FLOAT16、DOUBLE、INT32、INT64、INT16、INT8、UINT8、BOOL,且数据类型需要可转换成self与batch1@batch2推导后的数据类型。
-
alpha:Host侧的aclScalar,数据类型支持FLOAT、FLOAT16、DOUBLE、INT32、INT64、INT16、INT8、UINT8、BOOL,且数据类型需要可转换成self与batch1@batch2推导后的数据类型。
-
out:Device侧的aclTensor,数据类型支持FLOAT16、FLOAT、BFLOAT16(仅Atlas A2训练系列产品支持),且数据类型需要与self保持一致,shape要求与batch1@batch2的shape保持一致。数据格式支持ND,支持非连续Tensor,支持空Tensor。
-
cubeMathType:Host侧的整型,判断Cube单元应该使用哪种计算逻辑进行运算,支持INT8类型的枚举值,枚举值如下:
- 0:KEPP_DTYPE,保持输入的数据类型进行计算。
- 1:ALLOW_FP32_DOWN_PRECISION,允许转换输入数据类型降低精度计算。
-
workspaceSize:返回用户需要在Device侧申请的workspace大小。
-
executor:返回op执行器,包含了算子计算流程。
-
-
返回值:
返回aclnnStatus状态码,具体参见aclnn返回码。
:::note 说明 第一段接口完成入参校验,出现以下场景时报错:
- 返回161001(ACLNN_ERR_PARAM_NULLPTR):传入的self、batch1或batch2是空指针。
- 返回161002(ACLNN_ERR_PARAM_INVALID):
- self、batch1、batch2或out的数据类型或数据格式不在支持的范围内。
- self、batch1、batch2或out的数据类型不一致。
- self、batch1、batch2或out的数据格式不一致。
- self不能与batch1@batch2做broadcast操作。 :::
aclnnBaddbmm
-
接口定义:
aclnnStatus aclnnBaddbmm(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, aclrtStream stream)
-
参数说明:
- workspace:在Device侧申请的workspace内存起址。
- workspaceSize:在Device侧申请的workspace大小,由第一段接口aclnnBaddbmmGetWorkspaceSize获取。
- executor:op执行器,包含了算子计算流程。
- stream:指定执行任务的AscendCL stream流。
-
返回值:
返回aclnnStatus状态码,具体参见aclnn返回码。
aclnnInplaceBaddbmmGetWorkspaceSize
-
接口定义:
aclnnStatus aclnnInplaceBaddbmmGetWorkSpaceSize(const aclTensor *selfRef, const aclTensor *batch1, const aclTensor *batch2, const aclScalar *beta, const aclScalar *alpha, int8_t cubeMathType, uint64_t *workspaceSize, aclOpExecutor **executor)
-
参数说明:
-
selfRef:Device侧的aclTensor,输入/输出张量,数据类型支持FLOAT16、FLOAT、BFLOAT16(仅Atlas A2训练系列产品支持),且数据类型与batch1@batch2的数据类型需满足数据类型推导规则,shape需要与batch1@batch2满足broadcast关系。数据格式支持ND,支持非连续Tensor,支持空Tensor。
:::note 说明
- 对于数据类型,只能batch1@batch2的dtype向selfRef推导,不能反过来,因此若selfRef为FLOAT16,batch1@batch2为FLOAT,会报错。
- 对于shape,只能是selfRef通过broadcast变成和batch1@batch2一样的shape,不可以是batch1@batch2的shape通过broadcast变成和selfRef一样。例如selfRef的shape是(1, 3, 5), batch1@batch2的shape是(1, 1, 1),执行会报错。 :::
-
batch1:Device侧的aclTensor,数据类型支持FLOAT16、FLOAT、BFLOAT16(仅Atlas A2训练系列产品支持),且数据类型与batch2、selfRef的数据类型需满足数据类型推导规则。shape需要与batch2满足bmm输入约束条件。数据格式支持ND,支持非连续Tensor,支持空Tensor。
-
batch2:Device侧的aclTensor,数据类型支持FLOAT16、FLOAT、BFLOAT16(仅Atlas A2训练系列产品支持),且数据类型与batch1、selfRef的数据类型需满足数据类型推导规则。shape需要与batch1满足bmm输入约束条件。数据格式支持ND,支持非连续Tensor,支持空Tensor。
-
beta:Host侧的aclScalar,数据类型支持FLOAT、FLOAT16、DOUBLE、INT32、INT64、INT16、INT8、UINT8、BOOL,且数据类型需要可转换成selfRef与batch1@batch2推导后的数据类型。
-
alpha:Host侧的aclScalar,数据类型支持FLOAT、FLOAT16、DOUBLE、INT32、INT64、INT16、INT8、UINT8、BOOL,且数据类型需要可转换成selfRef与batch1@batch2推导后的数据类型。
-
cubeMathType:Host侧的整型,判断Cube单元应该使用哪种计算逻辑进行运算,支持INT8类型的枚举值,枚举值如下:
- 0:KEPP_DTYPE,保持输入的数据类型进行计算。
- 1:ALLOW_FP32_DOWN_PRECISION,允许转换输入数据类型降低精度计算。
-
workspaceSize:返回用户需要在Device侧申请的workspace大小。
-
executor:返回op执行器,包含了算子计算流程。
-
-
返回值:
返回aclnnStatus状态码,具体参见aclnn返回码。
:::note 说明 第一段接口完成入参校验,出现以下场景时报错:
- 返回161001(ACLNN_ERR_PARAM_NULLPTR):传入的selfRef、batch1或batch2是空指针。
- 返回161002(ACLNN_ERR_PARAM_INVALID):
- selfRef、batch1、batch2或out的数据类型或数据格式不在支持的范围内。
- selfRef、batch1、batch2或out的数据类型不一致。
- selfRef、batch1、batch2或out的数据格式不一致。
- selfRef不能与batch1@batch2做broadcast操作。
- batch1和batch2的第一维度不相等。
- batch1和batch2的维度不是三维。
- batch1的最后一维和batch2的倒数第二维不相等。 :::
aclnnInplaceBaddbmm
-
接口定义:
aclnnStatus aclnnInplaceBaddbmm(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, aclrtStream stream)
-
参数说明:
- workspace:在Device侧申请的workspace内存起址。
- workspaceSize:在Device侧申请的workspace大小,由第一段接口aclnnInplaceBaddbmmGetWorkspaceSize获取。
- executor:op执行器,包含了算子计算流程。
- stream:指定执行任务的AscendCL stream流。
-
返回值:
返回aclnnStatus状态码,具体参见aclnn返回码。
调用示例
<br> 1<br> 2<br> 3<br> 4<br> 5<br> 6<br> 7<br> 8<br> 9<br> 10<br> 11<br> 12<br> 13<br> 14<br> 15<br> 16<br> 17<br> 18<br> 19<br> 20<br> 21<br> 22<br> 23<br> 24<br> 25<br> 26<br> 27<br> 28<br> 29<br> 30<br> 31<br> 32<br> 33<br> 34<br> 35<br> 36<br> 37<br> 38<br> 39<br> 40<br> 41<br> 42<br> 43<br> 44<br> 45<br> 46<br> 47<br> 48<br> 49<br> 50<br> 51<br> 52<br> 53<br> 54<br> 55<br> 56<br> 57<br> 58<br> 59<br> 60<br> 61<br> 62<br> 63<br> 64<br> 65<br> 66<br> 67<br> 68<br> 69<br> 70<br> 71<br> 72<br> 73<br> 74<br> 75<br> 76<br> 77<br> 78<br> 79<br> 80<br> 81<br> 82<br> 83<br> 84<br> 85<br> 86<br> 87<br> 88<br> 89<br> 90<br> 91<br> 92<br> 93<br> 94<br> 95<br> 96<br> 97<br> 98<br> 99<br>100<br>101<br>102<br>103<br>104<br>105<br>106<br>107<br>108<br>109<br>110<br>111<br>112<br>113<br>114<br>115<br>116<br>117<br>118<br>119<br>120<br>121<br>122<br>123<br>124<br>125<br>126<br>127<br>128<br>129<br>130<br>131<br>132<br>133<br>134<br>135<br>136<br>137<br>138<br>139<br>140<br>141<br>142<br>143<br>144<br>145<br>146<br>147<br>148<br>149<br>150<br>151<br>152<br> | cpp<br>#include <iostream><br>#include <vector><br>#include "acl/acl.h"<br>#include "aclnnop/aclnn_baddbmm.h"<br>#define CHECK_RET(cond, return_expr) \<br> do { \<br> if (!(cond)) { \<br> return_expr; \<br> } \<br> } while (0)<br>#define LOG_PRINT(message, ...) \<br> do { \<br> printf(message, ##__VA_ARGS__); \<br> } while (0)<br>int64_t GetShapeSize(const std::vector<int64_t>& shape) {<br> int64_t shapeSize = 1;<br> for (auto i : shape) {<br> shapeSize *= i;<br> }<br> return shapeSize;<br>}<br>int Init(int32_t deviceId, aclrtContext* context, aclrtStream* stream) {<br> // 固定写法,AscendCL初始化<br> auto ret = aclInit(nullptr);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclInit failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtSetDevice(deviceId);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSetDevice failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtCreateContext(context, deviceId);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtCreateContext failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtSetCurrentContext(*context);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSetCurrentContext failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtCreateStream(stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtCreateStream failed. ERROR: %d\n", ret); return ret);<br> return 0;<br>}<br>template <typename T><br>int CreateAclTensor(const std::vector<T>& hostData, const std::vector<int64_t>& shape, void** deviceAddr,<br> aclDataType dataType, aclTensor** tensor) {<br> auto size = GetShapeSize(shape) * sizeof(T);<br> // 调用aclrtMalloc申请device侧内存<br> auto ret = aclrtMalloc(deviceAddr, size, ACL_MEM_MALLOC_HUGE_FIRST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtMalloc failed. ERROR: %d\n", ret); return ret);<br> // 调用aclrtMemcpy将Host侧数据拷贝到device侧内存上<br> ret = aclrtMemcpy(*deviceAddr, size, hostData.data(), size, ACL_MEMCPY_HOST_TO_DEVICE);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtMemcpy failed. ERROR: %d\n", ret); return ret);<br> // 计算连续tensor的strides<br> std::vector<int64_t> strides(shape.size(), 1);<br> for (int64_t i = shape.size() - 2; i >= 0; i--) {<br> strides[i] = shape[i + 1] * strides[i + 1];<br> }<br> // 调用aclCreateTensor接口创建aclTensor<br> *tensor = aclCreateTensor(shape.data(), shape.size(), dataType, strides.data(), 0, aclFormat::ACL_FORMAT_ND,<br> shape.data(), shape.size(), *deviceAddr);<br> return 0;<br>}<br>int main() {<br> // 1. (固定写法)device/context/stream初始化,参考AscendCL对外接口列表<br> // 根据自己的实际device填写deviceId<br> int32_t deviceId = 0;<br> aclrtContext context;<br> aclrtStream stream;<br> auto ret = Init(deviceId, &context, &stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("Init acl failed. ERROR: %d\n", ret); return ret);<br> // 2. 构造输入与输出,需要根据API的接口自定义构造<br> std::vector<int64_t> selfShape = {1, 2, 4};<br> std::vector<int64_t> batch1Shape = {1, 2, 3};<br> std::vector<int64_t> batch2Shape = {1, 3, 4};<br> std::vector<int64_t> outShape = {1, 2, 4};<br> void* selfDeviceAddr = nullptr;<br> void* batch1DeviceAddr = nullptr;<br> void* batch2DeviceAddr = nullptr;<br> void* outDeviceAddr = nullptr;<br> aclTensor* self = nullptr;<br> aclTensor* batch1 = nullptr;<br> aclTensor* batch2 = nullptr;<br> aclScalar* alpha = nullptr;<br> aclScalar* beta = nullptr;<br> aclTensor* out = nullptr;<br> std::vector<float> selfHostData = {0, 1, 2, 3, 4, 5, 6, 7};<br> std::vector<float> batch1HostData = {1, 1, 1, 2, 2, 2};<br> std::vector<float> batch2HostData = {1, 1, 1, 2, 2, 2, 3, 3, 3, 4, 4, 4};<br> std::vector<float> outHostData(8, 0);<br> int8_t cubeMathType = 1;<br> float alphaValue = 1.2f;<br> float betaValue = 1.0f;<br> // 创建self aclTensor<br> ret = CreateAclTensor(selfHostData, selfShape, &selfDeviceAddr, aclDataType::ACL_FLOAT, &self);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建batch1 aclTensor<br> ret = CreateAclTensor(batch1HostData, batch1Shape, &batch1DeviceAddr, aclDataType::ACL_FLOAT, &batch1);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建batch2 aclTensor<br> ret = CreateAclTensor(batch2HostData, batch2Shape, &batch2DeviceAddr, aclDataType::ACL_FLOAT, &batch2);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建alpha aclScalar<br> alpha = aclCreateScalar(&alphaValue,aclDataType::ACL_FLOAT);<br> CHECK_RET(alpha != nullptr, return ret);<br> // 创建beta aclScalar<br> beta = aclCreateScalar(&betaValue,aclDataType::ACL_FLOAT);<br> CHECK_RET(beta != nullptr, return ret);<br> // 创建out aclTensor<br> ret = CreateAclTensor(outHostData, outShape, &outDeviceAddr, aclDataType::ACL_FLOAT, &out);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 3. 调用CANN算子库API,需要修改为具体的API名称<br> uint64_t workspaceSize = 0;<br> aclOpExecutor* executor;<br> // 调用aclnnBaddbmm第一段接口<br> ret = aclnnBaddbmmGetWorkspaceSize(self, batch1, batch2, alpha, beta, out, cubeMathType, &workspaceSize, &executor);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclnnBaddbmmGetWorkspaceSize failed. ERROR: %d\n", ret); return ret);<br> // 根据第一段接口计算出的workspaceSize申请device内存<br> void* workspaceAddr = nullptr;<br> if (workspaceSize > 0) {<br> ret = aclrtMalloc(&workspaceAddr, workspaceSize, ACL_MEM_MALLOC_HUGE_FIRST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("allocate workspace failed. ERROR: %d\n", ret); return ret);<br> }<br> // 调用aclnnBaddbmm第二段接口<br> ret = aclnnBaddbmm(workspaceAddr, workspaceSize, executor, stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclnnBaddbmm failed. ERROR: %d\n", ret); return ret);<br> // 4. (固定写法)同步等待任务执行结束<br> ret = aclrtSynchronizeStream(stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSynchronizeStream failed. ERROR: %d\n", ret); return ret);<br> // 5. 获取输出的值,将device侧内存上的结果拷贝至Host侧,需要根据具体API的接口定义修改<br> auto size = GetShapeSize(outShape);<br> std::vector<float> resultData(size, 0);<br> ret = aclrtMemcpy(resultData.data(), resultData.size() * sizeof(resultData[0]), outDeviceAddr,<br> size * sizeof(resultData[0]), ACL_MEMCPY_DEVICE_TO_HOST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("copy result from device to host failed. ERROR: %d\n", ret); return ret);<br> for (int64_t i = 0; i < size; i++) {<br> LOG_PRINT("result[%ld] is: %f\n", i, resultData[i]);<br> }<br> // 6. 释放aclTensor和aclScalar,需要根据具体API的接口定义修改<br> aclDestroyTensor(self);<br> aclDestroyTensor(batch1);<br> aclDestroyTensor(batch2);<br> aclDestroyScalar(alpha);<br> aclDestroyScalar(beta);<br> aclDestroyTensor(out);<br> return 0;<br>}<br> |
|---|
父主题: NN类算子接口
aclnnBatchMatMul
接口原型
每个算子有两段接口,必须先调用“aclnnXxxGetWorkspaceSize”接口获取入参并根据计算流程计算所需workspace大小,再调用“aclnnXxx”接口执行计算。两段式接口如下:
- **第一段接口:**aclnnStatus aclnnBatchMatMulGetWorkspaceSize(const aclTensor *self, const aclTensor *mat2, aclTensor *out, int8_t cubeMathType, uint64_t *workspaceSize, aclOpExecutor **executor)
- 第二段接口:aclnnStatus aclnnBatchMatMul(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, aclrtStream stream)
功能描述
-
算子功能:完成两个3维矩阵乘计算。
-
计算公式:
-
示例:
假设张量self的shape是(A, M, K),张量mat2的shape是(A, K, N),则输出out的shape是(A, M, N)。第一维相等,后两維做矩阵乘运算。
注意,如果mat2的shape是(1, K, N),会因为不能完成broadcast而报错。
aclnnBatchMatMulGetWorkSpaceSize
-
接口定义:
aclnnStatus aclnnBatchMatMulGetWorkspaceSize(const aclTensor *self, const aclTensor *mat2, aclTensor *out, int8_t cubeMathType, uint64_t *workspaceSize, aclOpExecutor **executor)
-
参数说明:
- self:矩阵乘运算的第一个输入,Device侧的aclTensor,shape仅支持3维。数据类型支持FLOAT16、FLOAT、BFLOAT16(仅Atlas A2训练系列产品支持),且数据类型与mat2的数据类型需满足数据类型推导规则,支持非连续的Tensor,支持空Tensor,数据格式支持ND。
- mat2:矩阵乘运算的第二个输入,Device侧的aclTensor,shape仅支持3维。数据类型支持FLOAT16、FLOAT、BFLOAT16(仅Atlas A2训练系列产品支持),且数据类型与self的数据类型需满足数据类型推导规则,支持非连续的Tensor,支持空Tensor,数据格式支持ND。
- out:输出Tensor,Device侧的aclTensor。数据类型支持FLOAT16、FLOAT、BFLOAT16(仅Atlas A2训练系列产品支持)。数据类型与self保持一致。支持非连续的Tensor,数据格式支持ND。
- cubeMathType:Host侧的整型,判断Cube单元应该使用哪种计算逻辑进行运算,支持INT8类型的枚举值,枚举值如下:
- 0:KEPP_DTYPE,保持输入的数据类型进行计算。
- 1:ALLOW_FP32_DOWN_PRECISION,允许转换输入数据类型降低精度计算。
- workspaceSize:返回用户需要在Device侧申请的workspace大小。
- executor:返回op执行器,包含了算子计算流程。
-
返回值:
返回aclnnStatus状态码,具体参见aclnn返回码。
:::note 说明 第一段接口完成入参校验,出现以下场景时报错:
- 返回161001(ACLNN_ERR_PARAM_NULLPTR):传入的self、mat2或out是空指针。
- 返回161002(ACLNN_ERR_PARAM_INVALID):
- self、mat2或out的数据类型或数据格式不在支持的范围内。
- self、mat2或out的数据类型或数据格式不一致。
- self和mat2的第一维度不相等。
- self和mat2的维度不是三维。
- self的最后一维和mat2的倒数第二维不相等。 :::
aclnnBatchMatMul
-
接口定义:
aclnnStatus aclnnBatchMatMul(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, aclrtStream stream)
-
参数说明:
- workspace:在Device侧申请的workspace内存起址。
- workspaceSize:在Device侧申请的workspace大小,由第一段接口aclnnBatchMatMulGetWorkSpaceSize获取。
- executor:op执行器,包含了算子计算流程。
- stream:指定执行任务的AscendCL stream流。
-
返回值:
返回aclnnStatus状态码,具体参见aclnn返回码。
约束与限制
本算子仅支持3维张量计算,不支持broadcast。如需进行更高维度的矩阵乘计算或需要支持broadcast,可调用aclnnMatmul实现。
调用示例
<br> 1<br> 2<br> 3<br> 4<br> 5<br> 6<br> 7<br> 8<br> 9<br> 10<br> 11<br> 12<br> 13<br> 14<br> 15<br> 16<br> 17<br> 18<br> 19<br> 20<br> 21<br> 22<br> 23<br> 24<br> 25<br> 26<br> 27<br> 28<br> 29<br> 30<br> 31<br> 32<br> 33<br> 34<br> 35<br> 36<br> 37<br> 38<br> 39<br> 40<br> 41<br> 42<br> 43<br> 44<br> 45<br> 46<br> 47<br> 48<br> 49<br> 50<br> 51<br> 52<br> 53<br> 54<br> 55<br> 56<br> 57<br> 58<br> 59<br> 60<br> 61<br> 62<br> 63<br> 64<br> 65<br> 66<br> 67<br> 68<br> 69<br> 70<br> 71<br> 72<br> 73<br> 74<br> 75<br> 76<br> 77<br> 78<br> 79<br> 80<br> 81<br> 82<br> 83<br> 84<br> 85<br> 86<br> 87<br> 88<br> 89<br> 90<br> 91<br> 92<br> 93<br> 94<br> 95<br> 96<br> 97<br> 98<br> 99<br>100<br>101<br>102<br>103<br>104<br>105<br>106<br>107<br>108<br>109<br>110<br>111<br>112<br>113<br>114<br>115<br>116<br>117<br>118<br>119<br>120<br>121<br>122<br>123<br>124<br>125<br>126<br>127<br>128<br>129<br>130<br> | cpp<br>#include <iostream><br>#include <vector><br>#include "acl/acl.h"<br>#include "aclnnop/aclnn_batch_matmul.h"<br>#define CHECK_RET(cond, return_expr) \<br> do { \<br> if (!(cond)) { \<br> return_expr; \<br> } \<br> } while (0)<br>#define LOG_PRINT(message, ...) \<br> do { \<br> printf(message, ##__VA_ARGS__); \<br> } while (0)<br>int64_t GetShapeSize(const std::vector<int64_t>& shape) {<br> int64_t shapeSize = 1;<br> for (auto i : shape) {<br> shapeSize *= i;<br> }<br> return shapeSize;<br>}<br>int Init(int32_t deviceId, aclrtContext* context, aclrtStream* stream) {<br> // 固定写法,AscendCL初始化<br> auto ret = aclInit(nullptr);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclInit failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtSetDevice(deviceId);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSetDevice failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtCreateContext(context, deviceId);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtCreateContext failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtSetCurrentContext(*context);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSetCurrentContext failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtCreateStream(stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtCreateStream failed. ERROR: %d\n", ret); return ret);<br> return 0;<br>}<br>template <typename T><br>int CreateAclTensor(const std::vector<T>& hostData, const std::vector<int64_t>& shape, void** deviceAddr,<br> aclDataType dataType, aclTensor** tensor) {<br> auto size = GetShapeSize(shape) * sizeof(T);<br> // 调用aclrtMalloc申请device侧内存<br> auto ret = aclrtMalloc(deviceAddr, size, ACL_MEM_MALLOC_HUGE_FIRST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtMalloc failed. ERROR: %d\n", ret); return ret);<br> // 调用aclrtMemcpy将Host侧数据拷贝到device侧内存上<br> ret = aclrtMemcpy(*deviceAddr, size, hostData.data(), size, ACL_MEMCPY_HOST_TO_DEVICE);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtMemcpy failed. ERROR: %d\n", ret); return ret);<br> // 计算连续tensor的strides<br> std::vector<int64_t> strides(shape.size(), 1);<br> for (int64_t i = shape.size() - 2; i >= 0; i--) {<br> strides[i] = shape[i + 1] * strides[i + 1];<br> }<br> // 调用aclCreateTensor接口创建aclTensor<br> *tensor = aclCreateTensor(shape.data(), shape.size(), dataType, strides.data(), 0, aclFormat::ACL_FORMAT_ND,<br> shape.data(), shape.size(), *deviceAddr);<br> return 0;<br>}<br>int main() {<br> // 1. (固定写法)device/context/stream初始化,参考AscendCL对外接口列表<br> // 根据自己的实际device填写deviceId<br> int32_t deviceId = 0;<br> aclrtContext context;<br> aclrtStream stream;<br> auto ret = Init(deviceId, &context, &stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("Init acl failed. ERROR: %d\n", ret); return ret);<br> // 2. 构造输入与输出,需要根据API的接口自定义构造<br> std::vector<int64_t> selfShape = {1, 2, 3};<br> std::vector<int64_t> mat2Shape = {1, 3, 4};<br> std::vector<int64_t> outShape = {1, 2, 4};<br> void* selfDeviceAddr = nullptr;<br> void* mat2DeviceAddr = nullptr;<br> void* outDeviceAddr = nullptr;<br> aclTensor* self = nullptr;<br> aclTensor* mat2 = nullptr;<br> aclTensor* out = nullptr;<br> std::vector<float> selfHostData = {0, 1, 2, 3, 4, 5};<br> std::vector<float> mat2HostData = {1, 1, 1, 2, 2, 2, 3, 3, 3, 4, 4, 4};<br> std::vector<float> outHostData(8, 0);<br> int8_t cubeMathType = 1;<br> // 创建self aclTensor<br> ret = CreateAclTensor(selfHostData, selfShape, &selfDeviceAddr, aclDataType::ACL_FLOAT, &self);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建mat2 aclTensor<br> ret = CreateAclTensor(mat2HostData, mat2Shape, &mat2DeviceAddr, aclDataType::ACL_FLOAT, &mat2);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建out aclTensor<br> ret = CreateAclTensor(outHostData, outShape, &outDeviceAddr, aclDataType::ACL_FLOAT, &out);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 3. 调用CANN算子库API,需要修改为具体的API名称<br> uint64_t workspaceSize = 0;<br> aclOpExecutor* executor;<br> // 调用aclnnBatchMatMul第一段接口<br> ret = aclnnBatchMatMulGetWorkspaceSize(self, mat2, out, cubeMathType, &workspaceSize, &executor);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclnnBatchMatMulGetWorkspaceSize failed. ERROR: %d\n", ret); return ret);<br> // 根据第一段接口计算出的workspaceSize申请device内存<br> void* workspaceAddr = nullptr;<br> if (workspaceSize > 0) {<br> ret = aclrtMalloc(&workspaceAddr, workspaceSize, ACL_MEM_MALLOC_HUGE_FIRST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("allocate workspace failed. ERROR: %d\n", ret); return ret);<br> }<br> // 调用aclnnBatchMatMul第二段接口<br> ret = aclnnBatchMatMul(workspaceAddr, workspaceSize, executor, stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclnnBatchMatMul failed. ERROR: %d\n", ret); return ret);<br> // 4. (固定写法)同步等待任务执行结束<br> ret = aclrtSynchronizeStream(stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSynchronizeStream failed. ERROR: %d\n", ret); return ret);<br> // 5. 获取输出的值,将device侧内存上的结果拷贝至Host侧,需要根据具体API的接口定义修改<br> auto size = GetShapeSize(outShape);<br> std::vector<float> resultData(size, 0);<br> ret = aclrtMemcpy(resultData.data(), resultData.size() * sizeof(resultData[0]), outDeviceAddr,<br> size * sizeof(resultData[0]), ACL_MEMCPY_DEVICE_TO_HOST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("copy result from device to host failed. ERROR: %d\n", ret); return ret);<br> for (int64_t i = 0; i < size; i++) {<br> LOG_PRINT("result[%ld] is: %f\n", i, resultData[i]);<br> }<br> // 6. 释放aclTensor和aclScalar,需要根据具体API的接口定义修改<br> aclDestroyTensor(self);<br> aclDestroyTensor(mat2);<br> aclDestroyTensor(out);<br> return 0;<br>}<br> |
|---|
父主题: NN类算子接口
aclnnBatchNorm
接口原型
每个算子有两段接口,必须先调用“aclnnXxxGetWorkspaceSize”接口获取入参并根据计算流程计算所需workspace大小,再调用“aclnnXxx”接口执行计算。两段式接口如下:
- **第一段接口:**aclnnStatus aclnnBatchNormGetWorkspaceSize(const aclTensor *input, const aclTensor *weight, const aclTensor *bias, aclTensor *runningMean, aclTensor *runningVar, bool training, double momentum, double eps, aclTensor *output, aclTensor *saveMean, aclTensor *saveInvstd, uint64_t *workspaceSize, aclOpExecutor **executor)
- 第二段接口:aclnnStatus aclnnBatchNorm(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, const aclrtStream stream)
功能描述
-
算子功能:对一批数据做正则化处理(Batch Normalization),处理后的数据符合标准正态分布(均值为0、标准差为1)。
-
计算公式:
其中E[x]表示均值,Var(x)表示方差,ε表示一个极小的浮点数(防止分母为0)。
aclnnBatchNormGetWorkspaceSize
-
接口定义:
aclnnStatus aclnnBatchNormGetWorkspaceSize(const aclTensor *input, const aclTensor *weight, const aclTensor *bias, aclTensor *runningMean, aclTensor *runningVar, bool training, double momentum, double eps, aclTensor *output, aclTensor *saveMean, aclTensor *saveInvstd, uint64_t *workspaceSize, aclOpExecutor **executor)
-
参数说明:
- input:Device侧的aclTensor,数据类型仅支持FLOAT、FLOAT16,支持非连续的Tensor,支持的shape和格式有:二维(对应格式为NC)、三维(对应的格式为NCL)、四维(对应的格式为NCHW)、五维(对应的格式为NCDHW)。
- weight:可选参数,Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- bias:可选参数,Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- runningMean:可选参数,Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- runningVar:可选参数,Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- training:Host侧的bool值,标记是否训练场景,True表示训练场景,False表示推理场景。
- momentum:Host侧的double值,计算滑动平均的均值。
- eps:Host侧的double值,用于防止分母为0。
- output:Device侧的aclTensor,数据类型与input一致,支持非连续的Tensor,支持的shape和格式有:二维(对应格式为NC)、三维(对应的格式为NCL)、四维(对应的格式为NCHW)、五维(对应的格式为NCDHW)。
- saveMean:Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- saveInvstd:Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- workspaceSize:返回用户需要在Device侧申请的workspace大小。
- executor:返回op执行器,包含了算子计算流程。
-
返回值:
返回aclnnStatus状态码,具体参见aclnn返回码。
:::note 说明 第一段接口完成入参校验,出现以下场景时报错:
- 返回161001(ACLNN_ERR_PARAM_NULLPTR):传入的指针类型参数是空指针。
- 返回161002(ACLNN_ERR_PARAM_INVALID):
- 参数input和output数据类型和数据格式不在支持的范围内。
- 参数input和output数据的shape不在支持的范围内。 :::
aclnnBatchNorm
-
接口定义:
aclnnStatus aclnnBatchNorm(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, const aclrtStream stream)
-
参数说明:
- workspace:在Device侧申请的workspace内存起址。
- workspaceSize:在Device侧申请的workspace大小,由第一段接口aclnnBatchNormGetWorkspaceSize获取。
- executor:op执行器,包含了算子计算流程。
- stream:指定执行任务的AscendCL stream流。
-
返回值:
返回aclnnStatus状态码,具体参见aclnn返回码。
调用示例
<br> 1<br> 2<br> 3<br> 4<br> 5<br> 6<br> 7<br> 8<br> 9<br> 10<br> 11<br> 12<br> 13<br> 14<br> 15<br> 16<br> 17<br> 18<br> 19<br> 20<br> 21<br> 22<br> 23<br> 24<br> 25<br> 26<br> 27<br> 28<br> 29<br> 30<br> 31<br> 32<br> 33<br> 34<br> 35<br> 36<br> 37<br> 38<br> 39<br> 40<br> 41<br> 42<br> 43<br> 44<br> 45<br> 46<br> 47<br> 48<br> 49<br> 50<br> 51<br> 52<br> 53<br> 54<br> 55<br> 56<br> 57<br> 58<br> 59<br> 60<br> 61<br> 62<br> 63<br> 64<br> 65<br> 66<br> 67<br> 68<br> 69<br> 70<br> 71<br> 72<br> 73<br> 74<br> 75<br> 76<br> 77<br> 78<br> 79<br> 80<br> 81<br> 82<br> 83<br> 84<br> 85<br> 86<br> 87<br> 88<br> 89<br> 90<br> 91<br> 92<br> 93<br> 94<br> 95<br> 96<br> 97<br> 98<br> 99<br>100<br>101<br>102<br>103<br>104<br>105<br>106<br>107<br>108<br>109<br>110<br>111<br>112<br>113<br>114<br>115<br>116<br>117<br>118<br>119<br>120<br>121<br>122<br>123<br>124<br>125<br>126<br>127<br>128<br>129<br>130<br>131<br>132<br>133<br>134<br>135<br>136<br>137<br>138<br>139<br>140<br>141<br>142<br>143<br>144<br>145<br>146<br>147<br>148<br>149<br>150<br>151<br>152<br>153<br>154<br>155<br>156<br>157<br>158<br>159<br>160<br>161<br>162<br>163<br> | cpp<br>#include <iostream><br>#include <vector><br>#include "acl/acl.h"<br>#include "aclnnop/aclnn_batch_norm.h"<br>#define CHECK_RET(cond, return_expr) \<br> do { \<br> if (!(cond)) { \<br> return_expr; \<br> } \<br> } while (0)<br>#define LOG_PRINT(message, ...) \<br> do { \<br> printf(message, ##__VA_ARGS__); \<br> } while (0)<br>int64_t GetShapeSize(const std::vector<int64_t>& shape) {<br> int64_t shape_size = 1;<br> for (auto i : shape) {<br> shape_size *= i;<br> }<br> return shape_size;<br>}<br>int Init(int32_t deviceId, aclrtContext* context, aclrtStream* stream) {<br> // 固定写法,AscendCL初始化<br> auto ret = aclInit(nullptr);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclInit failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtSetDevice(deviceId);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSetDevice failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtCreateContext(context, deviceId);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtCreateContext failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtSetCurrentContext(*context);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSetCurrentContext failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtCreateStream(stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtCreateStream failed. ERROR: %d\n", ret); return ret);<br> return 0;<br>}<br>template <typename T><br>int CreateAclTensor(const std::vector<T>& hostData, const std::vector<int64_t>& shape, void** deviceAddr,<br> aclDataType dataType, aclTensor** tensor) {<br> auto size = GetShapeSize(shape) * sizeof(T);<br> // 调用aclrtMalloc申请device侧内存<br> auto ret = aclrtMalloc(deviceAddr, size, ACL_MEM_MALLOC_HUGE_FIRST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtMalloc failed. ERROR: %d\n", ret); return ret);<br> // 调用aclrtMemcpy将Host侧数据拷贝到device侧内存上<br> ret = aclrtMemcpy(*deviceAddr, size, hostData.data(), size, ACL_MEMCPY_HOST_TO_DEVICE);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtMemcpy failed. ERROR: %d\n", ret); return ret);<br> // 计算连续tensor的strides<br> std::vector<int64_t> strides(shape.size(), 1);<br> for (int64_t i = shape.size() - 2; i >= 0; i--) {<br> strides[i] = shape[i + 1] * strides[i + 1];<br> }<br> // 调用aclCreateTensor接口创建aclTensor<br> *tensor = aclCreateTensor(shape.data(), shape.size(), dataType, strides.data(), 0, aclFormat::ACL_FORMAT_ND,<br> shape.data(), shape.size(), *deviceAddr);<br> return 0;<br>}<br>int main() {<br> // 1. (固定写法)device/context/stream初始化, 参考AscendCL对外接口列表<br> // 根据自己的实际device填写deviceId<br> int32_t deviceId = 0;<br> aclrtContext context;<br> aclrtStream stream;<br> auto ret = Init(deviceId, &context, &stream);<br> // check根据自己的需要处理<br> CHECK_RET(ret == 0, LOG_PRINT("Init acl failed. ERROR: %d\n", ret); return ret);<br> // 2. 构造输入与输出,需要根据API的接口自定义构造<br> std::vector<int64_t> inputShape = {2, 3, 2};<br> std::vector<int64_t> meanShape = {3};<br> void* inputDeviceAddr = nullptr;<br> void* weightDeviceAddr = nullptr;<br> void* biasDeviceAddr = nullptr;<br> void* runningMeanDeviceAddr = nullptr;<br> void* runningVarDeviceAddr = nullptr;<br> void* outDeviceAddr = nullptr;<br> void* saveMeanDeviceAddr = nullptr;<br> void* saveInvstdDeviceAddr = nullptr;<br> aclTensor* input = nullptr;<br> aclTensor* weight = nullptr;<br> aclTensor* bias = nullptr;<br> aclTensor* runningMean = nullptr;<br> aclTensor* runningVar = nullptr;<br> aclTensor* out = nullptr;<br> aclTensor* saveMean = nullptr;<br> aclTensor* saveInvstd = nullptr;<br> std::vector<float> inputHostData = {0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11};<br> std::vector<float> zeroHostData = {0, 0, 0};<br> std::vector<float> oneHostData = {1, 1, 1};<br> // 创建input aclTensor<br> ret = CreateAclTensor(inputHostData, inputShape, &inputDeviceAddr, aclDataType::ACL_FLOAT, &input);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建weight aclTensor<br> ret = CreateAclTensor(oneHostData, meanShape, &weightDeviceAddr, aclDataType::ACL_FLOAT, &weight);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建bias aclTensor<br> ret = CreateAclTensor(zeroHostData, meanShape, &biasDeviceAddr, aclDataType::ACL_FLOAT, &bias);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建runningMean aclTensor<br> ret = CreateAclTensor(zeroHostData, meanShape, &runningMeanDeviceAddr, aclDataType::ACL_FLOAT, &runningMean);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建runningVar aclTensor<br> ret = CreateAclTensor(oneHostData, meanShape, &runningVarDeviceAddr, aclDataType::ACL_FLOAT, &runningVar);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建out aclTensor<br> ret = CreateAclTensor(inputHostData, inputShape, &outDeviceAddr, aclDataType::ACL_FLOAT, &out);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建saveMean aclTensor<br> ret = CreateAclTensor(zeroHostData, meanShape, &saveMeanDeviceAddr, aclDataType::ACL_FLOAT, &saveMean);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建saveInvstd aclTensor<br> ret = CreateAclTensor(zeroHostData, meanShape, &saveInvstdDeviceAddr, aclDataType::ACL_FLOAT, &saveInvstd);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 3.调用CANN算子库API,需要修改为具体的算子接口<br> uint64_t workspaceSize = 0;<br> aclOpExecutor* executor;<br> // 调用aclnnBatchNorm第一段接口<br> ret = aclnnBatchNormGetWorkspaceSize(input, weight, bias, runningMean, runningVar, true, 0.1, 1e-5, out, saveMean,<br> saveInvstd, &workspaceSize, &executor);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclnnBatchNormGetWorkspaceSize failed. ERROR: %d\n", ret); return ret);<br> // 根据第一段接口计算出的workspaceSize申请device内存<br> void* workspaceAddr = nullptr;<br> if (workspaceSize > 0) {<br> ret = aclrtMalloc(&workspaceAddr, workspaceSize, ACL_MEM_MALLOC_HUGE_FIRST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("allocate workspace failed. ERROR: %d\n", ret); return ret;);<br> }<br> // 调用aclnnBatchNorm第二段接口<br> ret = aclnnBatchNorm(workspaceAddr, workspaceSize, executor, stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclnnBatchNorm failed. ERROR: %d\n", ret); return ret);<br> // 4. (固定写法)同步等待任务执行结束<br> ret = aclrtSynchronizeStream(stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSynchronizeStream failed. ERROR: %d\n", ret); return ret);<br> // 5. 获取输出的值,将device侧内存上的结果拷贝至Host侧,需要根据具体API的接口定义修改<br> auto size = GetShapeSize(inputShape);<br> std::vector<float> resultData(size, 0);<br> ret = aclrtMemcpy(resultData.data(), resultData.size() * sizeof(resultData[0]), outDeviceAddr, size * sizeof(float),<br> ACL_MEMCPY_DEVICE_TO_HOST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("copy result from device to host failed. ERROR: %d\n", ret); return ret);<br> for (int64_t i = 0; i < size; i++) {<br> LOG_PRINT("result[%ld] is: %f\n", i, resultData[i]);<br> }<br> // 6. 释放aclTensor和aclScalar,需要根据具体API的接口定义修改<br> aclDestroyTensor(input);<br> aclDestroyTensor(weight);<br> aclDestroyTensor(bias);<br> aclDestroyTensor(runningMean);<br> aclDestroyTensor(runningVar);<br> aclDestroyTensor(out);<br> aclDestroyTensor(saveMean);<br> aclDestroyTensor(saveInvstd);<br> return 0;<br>}<br> |
|---|
父主题: NN类算子接口
aclnnBatchNormBackward
接口原型
每个算子有两段接口,必须先调用“aclnnXxxGetWorkspaceSize”接口获取入参并根据计算流程计算所需workspace大小,再调用“aclnnXxx”接口执行计算。两段式接口如下:
- **第一段接口:**aclnnStatus aclnnBatchNormBackwardGetWorkspaceSize(const aclTensor *gradOut, const aclTensor *input, const aclTensor *weight, const aclTensor *runningMean, const aclTensor *runningVar, const aclTensor *saveMean, const aclTensor *saveInvstd, bool training, double eps, const aclBoolArray *outputMask, aclTensor *gradInput, aclTensor *gradWeight, aclTensor *gradBias, uint64_t *workspaceSize, aclOpExecutor **executor)
- 第二段接口:aclnnStatus aclnnBatchNormBackward(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, const aclrtStream stream)
功能描述
-
算子功能:aclnnBatchNorm的反向计算。
-
计算公式:

aclnnBatchNormBackwardGetWorkspaceSize
-
接口定义:
aclnnStatus aclnnBatchNormBackwardGetWorkspaceSize(const aclTensor *gradOut, const aclTensor *input, const aclTensor *weight, const aclTensor *runningMean, const aclTensor *runningVar, const aclTensor *saveMean, const aclTensor *saveInvstd, bool training, double eps, const aclBoolArray *outputMask, aclTensor *gradInput, aclTensor *gradWeight, aclTensor *gradBias, uint64_t *workspaceSize, aclOpExecutor **executor)
-
参数说明:
- gradOut:Device侧的aclTensor,数据类型仅支持FLOAT、FLOAT16,支持非连续的Tensor,支持的shape和格式有:二维(对应格式为NC)、三维(对应的格式为NCL)、四维(对应的格式为NCHW)、五维(对应的格式为NCDHW)。
- input:Device侧的aclTensor,数据类型仅支持FLOAT、FLOAT16,支持非连续的Tensor,支持的shape和格式有:二维(对应格式为NC)、三维(对应的格式为NCL)、四维(对应的格式为NCHW)、五维(对应的格式为NCDHW)。
- weight:可选参数,Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- runningMean:可选参数,Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- runningVar:可选参数,Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- saveMean:可选参数,Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- saveInvstd:可选参数,Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- training:Host侧的bool值,标记是否训练场景,True表示训练场景,False表示推理场景。
- eps:Host侧的double值,用于防止分母为0。
- outputMask:aclBoolArray类型,输出的掩码。3个bool类型的标记,分别表示是否计算gradInput、gradWeight、gradBias3个输出。
- gradInput:Device侧的aclTensor,数据类型与input一致,支持非连续的Tensor,支持的shape和格式有:二维(对应格式为NC)、三维(对应的格式为NCL)、四维(对应的格式为NCHW)、五维(对应的格式为NCDHW)。
- gradWeight:Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- gradBias:Device侧的aclTensor,数据类型仅支持FLOAT,支持非连续的Tensor,数据格式为ND。shape为1维,长度与input入参中C轴的长度相等。
- workspaceSize:返回用户需要在Device侧申请的workspace大小。
- executor:返回op执行器,包含了算子计算流程。
-
返回值:
返回aclnnStatus状态码,具体参见aclnn返回码。
:::note 说明 第一段接口完成入参校验,出现以下场景时报错:
- 返回161001(ACLNN_ERR_PARAM_NULLPTR): 传入的指针类型入参是空指针。
- 返回161002(ACLNN_ERR_PARAM_INVALID):
- 参数input,gradOut,gradInput数据类型和数据格式不在支持的范围内。
- 参数input,gradOut,gradInput数据的shape不在支持的范围内。 :::
aclnnBatchNormBackward
-
接口定义:
aclnnStatus aclnnBatchNormBackward(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, const aclrtStream stream)
-
参数说明:
- workspace:在Device侧申请的workspace内存起址。
- workspaceSize:在Device侧申请的workspace大小,由第一段接口aclnnBatchNormBackwardGetWorkspaceSize获取。
- executor:op执行器,包含了算子计算流程。
- stream:指定执行任务的AscendCL stream流。
-
返回值:
返回aclnnStatus状态码,具体参见aclnn返回码。
调用示例
<br> 1<br> 2<br> 3<br> 4<br> 5<br> 6<br> 7<br> 8<br> 9<br> 10<br> 11<br> 12<br> 13<br> 14<br> 15<br> 16<br> 17<br> 18<br> 19<br> 20<br> 21<br> 22<br> 23<br> 24<br> 25<br> 26<br> 27<br> 28<br> 29<br> 30<br> 31<br> 32<br> 33<br> 34<br> 35<br> 36<br> 37<br> 38<br> 39<br> 40<br> 41<br> 42<br> 43<br> 44<br> 45<br> 46<br> 47<br> 48<br> 49<br> 50<br> 51<br> 52<br> 53<br> 54<br> 55<br> 56<br> 57<br> 58<br> 59<br> 60<br> 61<br> 62<br> 63<br> 64<br> 65<br> 66<br> 67<br> 68<br> 69<br> 70<br> 71<br> 72<br> 73<br> 74<br> 75<br> 76<br> 77<br> 78<br> 79<br> 80<br> 81<br> 82<br> 83<br> 84<br> 85<br> 86<br> 87<br> 88<br> 89<br> 90<br> 91<br> 92<br> 93<br> 94<br> 95<br> 96<br> 97<br> 98<br> 99<br>100<br>101<br>102<br>103<br>104<br>105<br>106<br>107<br>108<br>109<br>110<br>111<br>112<br>113<br>114<br>115<br>116<br>117<br>118<br>119<br>120<br>121<br>122<br>123<br>124<br>125<br>126<br>127<br>128<br>129<br>130<br>131<br>132<br>133<br>134<br>135<br>136<br>137<br>138<br>139<br>140<br>141<br>142<br>143<br>144<br>145<br>146<br>147<br>148<br>149<br>150<br>151<br>152<br>153<br>154<br>155<br>156<br>157<br>158<br>159<br>160<br>161<br>162<br>163<br>164<br>165<br>166<br>167<br>168<br>169<br>170<br>171<br>172<br>173<br>174<br>175<br>176<br>177<br>178<br> | cpp<br>#include <iostream><br>#include <vector><br>#include "acl/acl.h"<br>#include "aclnnop/aclnn_batch_norm_backward.h"<br>#define CHECK_RET(cond, return_expr) \<br> do { \<br> if (!(cond)) { \<br> return_expr; \<br> } \<br> } while (0)<br>#define LOG_PRINT(message, ...) \<br> do { \<br> printf(message, ##__VA_ARGS__); \<br> } while (0)<br>int64_t GetShapeSize(const std::vector<int64_t>& shape) {<br> int64_t shape_size = 1;<br> for (auto i : shape) {<br> shape_size *= i;<br> }<br> return shape_size;<br>}<br>int Init(int32_t deviceId, aclrtContext* context, aclrtStream* stream) {<br> // 固定写法,AscendCL初始化<br> auto ret = aclInit(nullptr);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclInit failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtSetDevice(deviceId);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSetDevice failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtCreateContext(context, deviceId);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtCreateContext failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtSetCurrentContext(*context);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSetCurrentContext failed. ERROR: %d\n", ret); return ret);<br> ret = aclrtCreateStream(stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtCreateStream failed. ERROR: %d\n", ret); return ret);<br> return 0;<br>}<br>template <typename T><br>int CreateAclTensor(const std::vector<T>& hostData, const std::vector<int64_t>& shape, void** deviceAddr,<br> aclDataType dataType, aclTensor** tensor) {<br> auto size = GetShapeSize(shape) * sizeof(T);<br> // 调用aclrtMalloc申请device侧内存<br> auto ret = aclrtMalloc(deviceAddr, size, ACL_MEM_MALLOC_HUGE_FIRST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtMalloc failed. ERROR: %d\n", ret); return ret);<br> // 调用aclrtMemcpy将Host侧数据拷贝到device侧内存上<br> ret = aclrtMemcpy(*deviceAddr, size, hostData.data(), size, ACL_MEMCPY_HOST_TO_DEVICE);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtMemcpy failed. ERROR: %d\n", ret); return ret);<br> // 计算连续tensor的strides<br> std::vector<int64_t> strides(shape.size(), 1);<br> for (int64_t i = shape.size() - 2; i >= 0; i--) {<br> strides[i] = shape[i + 1] * strides[i + 1];<br> }<br> // 调用aclCreateTensor接口创建aclTensor<br> *tensor = aclCreateTensor(shape.data(), shape.size(), dataType, strides.data(), 0, aclFormat::ACL_FORMAT_ND,<br> shape.data(), shape.size(), *deviceAddr);<br> return 0;<br>}<br>int main() {<br> // 1. (固定写法)device/context/stream初始化, 参考AscendCL对外接口列表<br> // 根据自己的实际device填写deviceId<br> int32_t deviceId = 0;<br> aclrtContext context;<br> aclrtStream stream;<br> auto ret = Init(deviceId, &context, &stream);<br> // check根据自己的需要处理<br> CHECK_RET(ret == 0, LOG_PRINT("Init acl failed. ERROR: %d\n", ret); return ret);<br> // 2. 构造输入与输出,需要根据API的接口自定义构造<br> std::vector<int64_t> inputShape = {2, 3, 2};<br> std::vector<int64_t> meanShape = {3};<br> void* gradOutDeviceAddr = nullptr;<br> void* inputDeviceAddr = nullptr;<br> void* weightDeviceAddr = nullptr;<br> void* runningMeanDeviceAddr = nullptr;<br> void* runningVarDeviceAddr = nullptr;<br> void* saveMeanDeviceAddr = nullptr;<br> void* saveInvstdDeviceAddr = nullptr;<br> void* gradInputDeviceAddr = nullptr;<br> void* gradWeightDeviceAddr = nullptr;<br> void* gradBiasDeviceAddr = nullptr;<br> aclTensor* gradOut = nullptr;<br> aclTensor* input = nullptr;<br> aclTensor* weight = nullptr;<br> aclTensor* runningMean = nullptr;<br> aclTensor* runningVar = nullptr;<br> aclTensor* saveMean = nullptr;<br> aclTensor* saveInvstd = nullptr;<br> aclTensor* gradInput = nullptr;<br> aclTensor* gradWeight = nullptr;<br> aclTensor* gradBias = nullptr;<br> std::vector<float> inputHostData = {0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11};<br> std::vector<float> zeroHostData = {0, 0, 0};<br> std::vector<float> oneHostData = {1, 1, 1};<br> // 创建gradOut aclTensor<br> ret = CreateAclTensor(inputHostData, inputShape, &gradOutDeviceAddr, aclDataType::ACL_FLOAT, &gradOut);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建input aclTensor<br> ret = CreateAclTensor(inputHostData, inputShape, &inputDeviceAddr, aclDataType::ACL_FLOAT, &input);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建weight aclTensor<br> ret = CreateAclTensor(oneHostData, meanShape, &weightDeviceAddr, aclDataType::ACL_FLOAT, &weight);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建runningMean aclTensor<br> ret = CreateAclTensor(zeroHostData, meanShape, &runningMeanDeviceAddr, aclDataType::ACL_FLOAT, &runningMean);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建runningVar aclTensor<br> ret = CreateAclTensor(oneHostData, meanShape, &runningVarDeviceAddr, aclDataType::ACL_FLOAT, &runningVar);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建saveMean aclTensor<br> ret = CreateAclTensor(zeroHostData, meanShape, &saveMeanDeviceAddr, aclDataType::ACL_FLOAT, &saveMean);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建saveInvstd aclTensor<br> ret = CreateAclTensor(zeroHostData, meanShape, &saveInvstdDeviceAddr, aclDataType::ACL_FLOAT, &saveInvstd);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建gradInput aclTensor<br> ret = CreateAclTensor(inputHostData, inputShape, &gradInputDeviceAddr, aclDataType::ACL_FLOAT, &gradInput);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建gradWeight aclTensor<br> ret = CreateAclTensor(zeroHostData, meanShape, &gradWeightDeviceAddr, aclDataType::ACL_FLOAT, &gradWeight);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> // 创建gradBias aclTensor<br> ret = CreateAclTensor(zeroHostData, meanShape, &gradBiasDeviceAddr, aclDataType::ACL_FLOAT, &gradBias);<br> CHECK_RET(ret == ACL_SUCCESS, return ret);<br> std::array<bool, 3> value = {true, true, true};<br> auto outputMask = aclCreateBoolArray(value.data(), value.size());<br> // 3.调用CANN算子库API,需要修改为具体的算子接口<br> uint64_t workspaceSize = 0;<br> aclOpExecutor* executor;<br> // 调用aclnnBatchNormBackward第一段接口<br> ret = aclnnBatchNormBackwardGetWorkspaceSize(gradOut, input, weight, runningMean, runningVar, saveMean, saveInvstd,<br> true, 1e-5, outputMask, gradInput, gradWeight, gradBias,<br> &workspaceSize, &executor);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclnnBatchNormBackwardGetWorkspaceSize failed. ERROR: %d\n", ret); return ret);<br> // 根据第一段接口计算出的workspaceSize申请device内存<br> void* workspaceAddr = nullptr;<br> if (workspaceSize > 0) {<br> ret = aclrtMalloc(&workspaceAddr, workspaceSize, ACL_MEM_MALLOC_HUGE_FIRST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("allocate workspace failed. ERROR: %d\n", ret); return ret;);<br> }<br> // 调用aclnnBatchNormBackward第二段接口<br> ret = aclnnBatchNormBackward(workspaceAddr, workspaceSize, executor, stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclnnBatchNormBackward failed. ERROR: %d\n", ret); return ret);<br> // 4. (固定写法)同步等待任务执行结束<br> ret = aclrtSynchronizeStream(stream);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSynchronizeStream failed. ERROR: %d\n", ret); return ret);<br> // 5. 获取输出的值,将device侧内存上的结果拷贝至Host侧,需要根据具体API的接口定义修改<br> auto size = GetShapeSize(inputShape);<br> std::vector<float> resultData(size, 0);<br> ret = aclrtMemcpy(resultData.data(), resultData.size() * sizeof(resultData[0]), gradInput, size * sizeof(float),<br> ACL_MEMCPY_DEVICE_TO_HOST);<br> CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("copy result from device to host failed. ERROR: %d\n", ret); return ret);<br> for (int64_t i = 0; i < size; i++) {<br> LOG_PRINT("result[%ld] is: %f\n", i, resultData[i]);<br> }<br> // 6. 释放aclTensor和aclScalar,需要根据具体API的接口定义修改<br> aclDestroyTensor(gradOut);<br> aclDestroyTensor(input);<br> aclDestroyTensor(weight);<br> aclDestroyTensor(runningMean);<br> aclDestroyTensor(runningVar);<br> aclDestroyTensor(saveMean);<br> aclDestroyTensor(saveInvstd);<br> aclDestroyTensor(gradInput);<br> aclDestroyTensor(gradWeight);<br> aclDestroyTensor(gradBias);<br> return 0;<br>}<br> |
|---|
父主题: NN类算子接口
在线提单