//Model_procccess.cpp /** * @file model_process.cpp * * Copyright (C) 2020. Huawei Technologies Co., Ltd. All rights reserved. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. */ #include "model_process.h" #include "utils.h" #include #include #include #include using namespace std; extern bool g_isDevice; extern bool f_isTXT; ModelProcess::ModelProcess() :modelId_(0), modelMemSize_(0), modelWeightSize_(0), modelMemPtr_(nullptr), modelWeightPtr_(nullptr), loadFlag_(false), modelDesc_(nullptr), input_(nullptr), output_(nullptr), numInputs_(0), numOutputs_(0) { } ModelProcess::~ModelProcess() { Unload(); DestroyDesc(); DestroyInput(); DestroyOutput(); } Result ModelProcess::LoadModelFromFileWithMem(const char *modelPath) { if (loadFlag_) { ERROR_LOG("has already loaded a model"); return FAILED; } aclError ret = aclmdlQuerySize(modelPath, &modelMemSize_, &modelWeightSize_); if (ret != ACL_ERROR_NONE) { ERROR_LOG("query model failed, model file is %s", modelPath); return FAILED; } ret = aclrtMalloc(&modelMemPtr_, modelMemSize_, ACL_MEM_MALLOC_NORMAL_ONLY); if (ret != ACL_ERROR_NONE) { ERROR_LOG("malloc buffer for mem failed, require size is %zu", modelMemSize_); return FAILED; } ret = aclrtMalloc(&modelWeightPtr_, modelWeightSize_, ACL_MEM_MALLOC_NORMAL_ONLY); if (ret != ACL_ERROR_NONE) { ERROR_LOG("malloc buffer for weight failed, require size is %zu", modelWeightSize_); return FAILED; } ret = aclmdlLoadFromFileWithMem(modelPath, &modelId_, modelMemPtr_, modelMemSize_, modelWeightPtr_, modelWeightSize_); if (ret != ACL_ERROR_NONE) { ERROR_LOG("load model from file failed, model file is %s", modelPath); return FAILED; } loadFlag_ = true; INFO_LOG("load model %s success", modelPath); return SUCCESS; } Result ModelProcess::CreateDesc() { modelDesc_ = aclmdlCreateDesc(); if (modelDesc_ == nullptr) { ERROR_LOG("create model description failed"); return FAILED; } aclError ret = aclmdlGetDesc(modelDesc_, modelId_); if (ret != ACL_ERROR_NONE) { ERROR_LOG("get model description failed"); return FAILED; } INFO_LOG("create model description success"); return SUCCESS; } Result ModelProcess::PrintDesc() { aclError ret; DEBUG_LOG("start print model description"); size_t numInputs = aclmdlGetNumInputs(modelDesc_); size_t numOutputs = aclmdlGetNumOutputs(modelDesc_); DEBUG_LOG("NumInputs: %zu", numInputs); DEBUG_LOG("NumOutputs: %zu", numOutputs); aclmdlIODims dimsInput; aclmdlIODims dimsOutput; aclmdlIODims dimsCurrentOutput; for (size_t i = 0; i < numInputs; i++){ DEBUG_LOG("the size of %zu input: %zu", i, aclmdlGetInputSizeByIndex(modelDesc_, i)); ret = aclmdlGetInputDims(modelDesc_, i, &dimsInput); DEBUG_LOG("the dims of %zu input:", i); for (size_t j = 0; j < dimsInput.dimCount; j++){ cout << dimsInput.dims[j] << " "; } cout << endl; DEBUG_LOG("the name of %zu input: %s", i, aclmdlGetInputNameByIndex(modelDesc_, i)); DEBUG_LOG("the Format of %zu input: %u", i, aclmdlGetInputFormat(modelDesc_, i)); DEBUG_LOG("the DataType of %zu input: %u", i, aclmdlGetInputFormat(modelDesc_, i)); } for (size_t i = 0; i < numOutputs; i++){ DEBUG_LOG("the size of %zu output: %zu", i, aclmdlGetOutputSizeByIndex(modelDesc_, i)); ret = aclmdlGetOutputDims(modelDesc_, i, &dimsOutput); DEBUG_LOG("the dims of %zu output:", i); for (size_t j = 0; j < dimsOutput.dimCount; j++){ cout <(dims); ret = aclmdlGetOutputDims(modelDesc_, i, dim); if (ret != ACL_ERROR_NONE) { ERROR_LOG("aclmdlGetOutputDims failed, ret[%d]", ret); return; } void *outHostData = NULL; ret = ACL_ERROR_NONE; void *outData = NULL; if (!g_isDevice) { ret = aclrtMallocHost(&outHostData, len); if (ret != ACL_ERROR_NONE) { ERROR_LOG("aclrtMallocHost failed, ret[%d]", ret); return; } ret = aclrtMemcpy(outHostData, len, data, len, ACL_MEMCPY_DEVICE_TO_HOST); if (ret != ACL_ERROR_NONE) { ERROR_LOG("aclrtMemcpy failed, ret[%d]", ret); return; } switch (datatype) { case 0: outData = reinterpret_cast(outHostData); break; case 1: outData = reinterpret_cast(outHostData); break; case 2: outData = reinterpret_cast(outHostData); break; case 3: outData = reinterpret_cast(outHostData); break; case 4: outData = reinterpret_cast(outHostData); break; case 6: outData = reinterpret_cast(outHostData); break; case 7: outData = reinterpret_cast(outHostData); break; case 8: outData = reinterpret_cast(outHostData); break; case 9: outData = reinterpret_cast(outHostData); break; case 10: outData = reinterpret_cast(outHostData); break; case 11: outData = reinterpret_cast(outHostData); break; case 12: outData = reinterpret_cast(outHostData); break; default : printf("undefined data type!\n"); break; } } else { outData = reinterpret_cast(data); } if (f_isTXT) { ofstream outstr(times+"/"+modelName+"_output_"+to_string(i)+".txt", ios::out); switch (datatype) { case 0: for (int i = 0; i < len/sizeof(float); i++) { float out = *((float*)outData+i); outstr << out << " "; for (int j = 0; j < dim->dimCount; j++) { if (i !=0 && i%dim->dims[j] == 0 && dim->dims[j] > 10) {outstr << "\n" ;} } } break; case 1: for (int i = 0; i < len/sizeof(aclFloat16); i++) { aclFloat16 out = *((aclFloat16*)outData+i); outstr << out << " "; for (int j = 0; j < dim->dimCount; j++) { if (i !=0 && i%dim->dims[j] == 0 && dim->dims[j] > 10) {outstr << "\n" ;} } } break; case 2: for (int i = 0; i < len/sizeof(int8_t); i++) { int8_t out = *((int8_t*)outData+i); outstr << out << " "; for (int j = 0; j < dim->dimCount; j++) { if (i !=0 && i%dim->dims[j] == 0 && dim->dims[j] > 10) {outstr << "\n" ;} } } break; case 3: for (int i = 0; i < len/sizeof(int); i++) { int out = *((int*)outData+i); outstr << out << " "; for (int j = 0; j < dim->dimCount; j++) { if (i !=0 && i%dim->dims[j] == 0 && dim->dims[j] > 10) {outstr << "\n" ;} } } break; case 4: for (int i = 0; i < len/sizeof(uint8_t); i++) { uint8_t out = *((uint8_t*)outData+i); outstr << out << " "; for (int j = 0; j < dim->dimCount; j++) { if (i !=0 && i%dim->dims[j] == 0 && dim->dims[j] > 10) {outstr << "\n" ;} } } break; case 6: for (int i = 0; i < len/sizeof(int16_t); i++) { int16_t out = *((int16_t*)outData+i); outstr << out << " "; for (int j = 0; j < dim->dimCount; j++) { if (i !=0 && i%dim->dims[j] == 0 && dim->dims[j] > 10) {outstr << "\n" ;} } } break; case 7: for (int i = 0; i < len/sizeof(uint16_t); i++) { uint16_t out = *((uint16_t*)outData+i); outstr << out << " "; for (int j = 0; j < dim->dimCount; j++) { if (i !=0 && i%dim->dims[j] == 0 && dim->dims[j] > 10) {outstr << "\n" ;} } } break; case 8: for (int i = 0; i < len/sizeof(uint32_t); i++) { uint32_t out = *((uint32_t*)outData+i); outstr << out << " "; for (int j = 0; j < dim->dimCount; j++) { if (i !=0 && i%dim->dims[j] == 0 && dim->dims[j] > 10) {outstr << "\n" ;} } } break; case 9: for (int i = 0; i < len/sizeof(int64_t); i++) { int64_t out = *((int64_t*)outData+i); outstr << out << " "; for (int j = 0; j < dim->dimCount; j++) { if (i !=0 && i%dim->dims[j] == 0 && dim->dims[j] > 10) {outstr << "\n" ;} } } break; case 10: for (int i = 0; i < len/sizeof(uint64_t); i++) { uint64_t out = *((uint64_t*)outData+i); outstr << out << " "; for (int j = 0; j < dim->dimCount; j++) { if (i !=0 && i%dim->dims[j] == 0 && dim->dims[j] > 10) {outstr << "\n" ;} } } break; case 11: for (int i = 0; i < len/sizeof(double); i++) { double out = *((double*)outData+i); outstr << out << " "; for (int j = 0; j < dim->dimCount; j++) { if (i !=0 && i%dim->dims[j] == 0 && dim->dims[j] > 10) {outstr << "\n" ;} } } break; case 12: for (int i = 0; i < len/sizeof(bool); i++) { int out = *((bool*)outData+i); outstr << out << " "; for (int j = 0; j < dim->dimCount; j++) { if (i !=0 && i%dim->dims[j] == 0 && dim->dims[j] > 10) {outstr << "\n" ;} } } break; default : printf("undefined data type!\n"); break; } outstr.close(); } else { ofstream outstr(times+"/"+modelName+"_output_"+to_string(i)+".bin", ios::out|ios::binary); outstr.write((char*)outData, len); outstr.close(); } if (!g_isDevice) { ret = aclrtFreeHost(outHostData); if (ret != ACL_ERROR_NONE) { ERROR_LOG("aclrtFreeHost failed, ret[%d]", ret); return; } } } INFO_LOG("output data success"); return; } void ModelProcess::DestroyOutput() { if (output_ == nullptr) { return; } for (size_t i = 0; i < aclmdlGetDatasetNumBuffers(output_); ++i) { aclDataBuffer* dataBuffer = aclmdlGetDatasetBuffer(output_, i); void* data = aclGetDataBufferAddr(dataBuffer); (void)aclrtFree(data); (void)aclDestroyDataBuffer(dataBuffer); } (void)aclmdlDestroyDataset(output_); output_ = nullptr; } Result ModelProcess::Execute() { aclError ret = aclmdlExecute(modelId_, input_, output_); if (ret != ACL_ERROR_NONE) { ERROR_LOG("execute model failed, modelId is %u", modelId_); return FAILED; } INFO_LOG("model execute success"); return SUCCESS; } void ModelProcess::Unload() { if (!loadFlag_) { WARN_LOG("no model had been loaded, unload failed"); return; } aclError ret = aclmdlUnload(modelId_); if (ret != ACL_ERROR_NONE) { ERROR_LOG("unload model failed, modelId is %u", modelId_); } if (modelDesc_ != nullptr) { (void)aclmdlDestroyDesc(modelDesc_); modelDesc_ = nullptr; } if (modelMemPtr_ != nullptr) { aclrtFree(modelMemPtr_); modelMemPtr_ = nullptr; modelMemSize_ = 0; } if (modelWeightPtr_ != nullptr) { aclrtFree(modelWeightPtr_); modelWeightPtr_ = nullptr; modelWeightSize_ = 0; } loadFlag_ = false; INFO_LOG("unload model success, model Id is %u", modelId_); }