OpenHarmony-v5.1.0-Release/s

/**
 * Copyright 2020 Huawei Technologies Co., Ltd
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "tools/benchmark/benchmark_base.h"
#include <cinttypes>
#include <algorithm>
#include <utility>
#include <regex>
#include <functional>
#include "schema/model_generated.h"
#include "src/common/common.h"
#include "src/tensor.h"
#ifdef ENABLE_ARM64
#include <linux/perf_event.h>
#include <sys/ioctl.h>
#include <asm/unistd.h>
#include <unistd.h>
#endif
#ifdef SUPPORT_NNIE
#include "include/hi_common.h"
#include "include/hi_comm_vb.h"
#include "include/mpi_sys.h"
#include "include/mpi_vb.h"
#endif

namespace mindspore {
namespace lite {
constexpr int kThreadNumMin = 1;
constexpr int kParallelThreadNumMin = 1;
constexpr int kColumnLen = 4;
constexpr int kPrintColNum = 5;
constexpr int kPrintRowLenMax = 100;

constexpr float kInputDataFloatMin = 0.1f;
constexpr float kInputDataFloatMax = 1.0f;
constexpr double kInputDataDoubleMin = 0.1;
constexpr double kInputDataDoubleMax = 1.0;
constexpr int64_t kInputDataInt64Min = 0;
constexpr int64_t kInputDataInt64Max = 1;
constexpr int32_t kInputDataInt32Min = 0;
constexpr int32_t kInputDataInt32Max = 1;
constexpr int16_t kInputDataInt16Min = 0;
constexpr int16_t kInputDataInt16Max = 1;
constexpr int16_t kInputDataInt8Min = -127;
constexpr int16_t kInputDataInt8Max = 127;
constexpr int16_t kInputDataUint8Min = 0;
constexpr int16_t kInputDataUint8Max = 254;
#ifdef SUPPORT_NNIE
constexpr int kNNIEMaxPoolCnt = 2;
constexpr int kNNIEBlkSize = 768 * 576 * 2;
#endif

const std::unordered_map<int, std::string> kTypeIdMap{
  {kNumberTypeFloat16, "Float16"}, {kNumberTypeFloat, "Float32"},    {kNumberTypeFloat32, "Float32"},
  {kNumberTypeInt8, "Int8"},       {kNumberTypeInt16, "Int16"},      {kNumberTypeInt, "Int32"},
  {kNumberTypeInt32, "Int32"},     {kNumberTypeUInt8, "UInt8"},      {kNumberTypeUInt16, "UInt16"},
  {kNumberTypeUInt, "UInt32"},     {kNumberTypeUInt32, "UInt32"},    {kObjectTypeString, "String"},
  {kNumberTypeBool, "Bool"},       {kObjectTypeTensorType, "Tensor"}};

const std::unordered_map<mindspore::Format, std::string> kTensorFormatMap{
  {mindspore::NCHW, "NCHW"}, {mindspore::NHWC, "NHWC"},     {mindspore::NHWC4, "NHWC4"}, {mindspore::HWKC, "HWKC"},
  {mindspore::HWCK, "HWCK"}, {mindspore::KCHW, "KCHW"},     {mindspore::CKHW, "CKHW"},   {mindspore::KHWC, "KHWC"},
  {mindspore::CHWK, "CHWK"}, {mindspore::HW, "HW"},         {mindspore::HW4, "HW4"},     {mindspore::NC, "NC"},
  {mindspore::NC4, "NC4"},   {mindspore::NC4HW4, "NC4HW4"}, {mindspore::NCDHW, "NCDHW"}};

int BenchmarkBase::GenerateRandomData(size_t size, void *data, int data_type) {
  if (data == nullptr) {
    return RET_ERROR;
  }
  if (size == 0) {
    return RET_OK;
  }
  switch (data_type) {
    case kNumberTypeFloat32:
    case kNumberTypeFloat:
      FillInputData<float>(size, data, std::uniform_real_distribution<float>(kInputDataFloatMin, kInputDataFloatMax));
      break;
    case kNumberTypeFloat64:
      FillInputData<double>(size, data,
                            std::uniform_real_distribution<double>(kInputDataDoubleMin, kInputDataDoubleMax));
      break;
    case kNumberTypeInt64:
      FillInputData<int64_t>(size, data,
                             std::uniform_int_distribution<int64_t>(kInputDataInt64Min, kInputDataInt64Max));
      break;
    case kNumberTypeInt:
    case kNumberTypeInt32:
      FillInputData<int32_t>(size, data,
                             std::uniform_int_distribution<int32_t>(kInputDataInt32Min, kInputDataInt32Max));
      break;
    case kNumberTypeInt16:
      FillInputData<int16_t>(size, data,
                             std::uniform_int_distribution<int16_t>(kInputDataInt16Min, kInputDataInt16Max));
      break;
    case kNumberTypeInt8:
      FillInputData<int8_t>(size, data, std::uniform_int_distribution<int16_t>(kInputDataInt8Min, kInputDataInt8Max));
      break;
    case kNumberTypeUInt8:
      FillInputData<uint8_t>(size, data,
                             std::uniform_int_distribution<uint16_t>(kInputDataUint8Min, kInputDataUint8Max));
      break;
    default:
      char *casted_data = static_cast<char *>(data);
      for (size_t i = 0; i < size; i++) {
        casted_data[i] = static_cast<char>(i);
      }
  }
  return RET_OK;
}

// calibData is FP32
int BenchmarkBase::ReadCalibData() {
  const char *calib_data_path = flags_->benchmark_data_file_.c_str();
  // read calib data
  std::ifstream in_file(calib_data_path);
  if (!in_file.good()) {
    std::cerr << "file: " << calib_data_path << " is not exist" << std::endl;
    MS_LOG(ERROR) << "file: " << calib_data_path << " is not exist";
    return RET_ERROR;
  }

  if (!in_file.is_open()) {
    std::cerr << "file: " << calib_data_path << " open failed" << std::endl;
    MS_LOG(ERROR) << "file: " << calib_data_path << " open failed";
    in_file.close();
    return RET_ERROR;
  }
  MS_LOG(INFO) << "Start reading calibData file";
  std::string line;
  std::string tensor_name;

  while (!in_file.eof()) {
    (void)getline(in_file, line);
    std::stringstream string_line1(line);
    size_t dim = 0;
    string_line1 >> tensor_name >> dim;
    std::vector<size_t> dims;
    for (size_t i = 0; i < dim; i++) {
      size_t tmp_dim;
      string_line1 >> tmp_dim;
      dims.push_back(tmp_dim);
    }
    auto ret = ReadTensorData(in_file, tensor_name, dims);
    if (ret != RET_OK) {
      MS_LOG(ERROR) << "Read tensor data failed, tensor name: " << tensor_name;
      in_file.close();
      return RET_ERROR;
    }
  }
  in_file.close();
  MS_LOG(INFO) << "Finish reading calibData file";
  return RET_OK;
}

int BenchmarkBase::ReadTensorData(std::ifstream &in_file_stream, const std::string &tensor_name,
                                  const std::vector<size_t> &dims) {
  std::string line;
  (void)getline(in_file_stream, line);
  std::stringstream line_stream(line);
  if (this->benchmark_data_.find(tensor_name) != this->benchmark_data_.end()) {
    return RET_OK;
  }
  std::vector<float> data;
  std::vector<std::string> strings_data;
  size_t shape_size = 1;
  if (!dims.empty()) {
    for (size_t i = 0; i < dims.size(); ++i) {
      if (dims[i] == 0) {
        MS_LOG(ERROR) << "dim is 0.";
        return RET_ERROR;
      }
      MS_CHECK_FALSE_MSG(SIZE_MUL_OVERFLOW(shape_size, dims[i]), RET_ERROR, "mul overflow");
      shape_size *= dims[i];
    }
  }
  auto tensor_data_type = GetDataTypeByTensorName(tensor_name);
  if (tensor_data_type == static_cast<int>(kTypeUnknown)) {
    MS_LOG(ERROR) << "get data type failed.";
    return RET_ERROR;
  }
  if (tensor_data_type == static_cast<int>(kObjectTypeString)) {
    strings_data.push_back(line);
    for (size_t i = 1; i < shape_size; i++) {
      getline(in_file_stream, line);
      strings_data.push_back(line);
    }
  } else {
    for (size_t i = 0; i < shape_size; i++) {
      float tmp_data;
      line_stream >> tmp_data;
      data.push_back(tmp_data);
    }
  }
  auto *check_tensor = new (std::nothrow) CheckTensor(dims, data, strings_data);
  if (check_tensor == nullptr) {
    MS_LOG(ERROR) << "New CheckTensor failed, tensor name: " << tensor_name;
    return RET_ERROR;
  }
  this->benchmark_tensor_names_.push_back(tensor_name);
  this->benchmark_data_.insert(std::make_pair(tensor_name, check_tensor));
  return RET_OK;
}

int BenchmarkBase::CompareStringData(const std::string &name, const std::vector<std::string> &calib_strings,
                                     const std::vector<std::string> &output_strings) {
  size_t compare_num = std::min(calib_strings.size(), output_strings.size());
  size_t print_num = std::min(compare_num, static_cast<size_t>(kNumPrintMin));

  std::cout << "Data of node " << name << " : " << std::endl;
  for (size_t i = 0; i < compare_num; i++) {
    if (i < print_num) {
      std::cout << "  " << output_strings[i] << std::endl;
    }
    if (calib_strings[i] != output_strings[i]) {
      MS_LOG(ERROR) << "Compare failed, index: " << i;
      std::cerr << "Compare failed, index: " << i << std::endl;
      return RET_ERROR;
    }
  }
  return RET_OK;
}

void BenchmarkFlags::InitInputDataList() {
  if (in_data_file_.empty()) {
    input_data_list_ = {};
    return;
  }
  std::regex re{"[\\s,]+"};
  input_data_list_ = std::vector<std::string>{
    std::sregex_token_iterator(in_data_file_.begin(), in_data_file_.end(), re, -1), std::sregex_token_iterator()};
}

bool ParseResizeDimsStringV2(const std::string &input_string,
                             std::map<std::string, std::vector<int64_t>> *graph_input_shape_map) {
  // define regex pattern that matches "inTensor1:1,32,32,32;inTensor2:1,1,32,32,4"
  std::regex pattern("^(\\w+:\\d+(?:,\\d+)*)(?:;(\\w+:\\d+(?:,\\d+)*))*;?$");
  std::vector<int64_t> shape;
  if (std::regex_match(input_string, pattern)) {
    auto group_splits = lite::StrSplit(input_string, std::string(";"));
    for (auto group : group_splits) {
      if (group.empty()) {
        continue;
      }
      shape.clear();
      auto string_split = lite::StrSplit(group, std::string(":"));
      auto name = string_split[0];
      for (size_t i = 1; i < string_split.size() - 1; ++i) {
        name += ":" + string_split[i];
      }
      auto dim_strs = string_split[string_split.size() - 1];
      auto dims = lite::StrSplit(dim_strs, std::string(","));
      for (const auto &dim : dims) {
        int64_t dim_value;
        // try {
          dim_value = std::stoi(dim);
        // } catch (const std::exception &e) {
        //   MS_LOG(ERROR) << "Get dim failed: " << e.what();
        //   return false;
        // }
        shape.push_back(dim_value);
      }
      if ((*graph_input_shape_map).find(name) != (*graph_input_shape_map).end()) {
        MS_LOG(ERROR) << "The input shape string is not valid, found duplicate name [" << name << "].";
        return false;
      }
      (*graph_input_shape_map)[name] = shape;
    }
  } else {
    MS_LOG(ERROR) << "The input shape string is not valid, please specify input names followed by their shapes. Wrap "
                     "the whole string in "
                     "double-quotes(\"\"). e.g. "
                     "\"inTensor1:1,32,32,32;inTensor2:1,1,32,32,4\"";
    return false;
  }
  return !(*graph_input_shape_map).empty();
}

int BenchmarkFlags::InitResizeDimsList() {
  std::string content = this->resize_dims_in_;
  std::string content_v2 = this->resize_dims_in_v2_;
  if (!content_v2.empty()) {  // use newer flag "--inputShape" first
    std::map<std::string, std::vector<int64_t>> graph_input_shape_map;
    bool success = ParseResizeDimsStringV2(content_v2, &graph_input_shape_map);
    if (!success) {
      MS_LOG(ERROR) << "Parse inputShape string \"" << content_v2 << "\" failed, please check input.";
      return RET_PARAM_INVALID;
    }
    this->graph_input_shape_map_ = graph_input_shape_map;
    std::vector<int> shape;
    for (const auto &group : graph_input_shape_map) {
      shape.clear();
      std::cout << "Resize Dims: ";
      for (int number : group.second) {
        std::cout << number << " ";
        shape.emplace_back(number);
      }
      std::cout << std::endl;
      this->resize_dims_.emplace_back(shape);
    }
  } else {
    if (content.empty()) {
      return RET_OK;
    }
    MS_LOG(WARNING) << "The --inputShapes flag has been deprecated, the replacement flag is --inputShape. Please "
                       "update your command line usage.";
    std::vector<int> shape;
    auto shape_strs = StrSplit(content, std::string(DELIM_COLON));
    for (const auto &shape_str : shape_strs) {
      shape.clear();
      auto dim_strs = StrSplit(shape_str, std::string(DELIM_COMMA));
      std::cout << "Resize Dims: ";
      for (const auto &dim_str : dim_strs) {
        std::cout << dim_str << " ";
        shape.emplace_back(static_cast<int>(std::stoi(dim_str)));
      }
      std::cout << std::endl;
      this->resize_dims_.emplace_back(shape);
    }
  }
  return RET_OK;
}

void BenchmarkFlags::InitCoreList() {
  std::string core_list_str = this->core_list_str_;
  if (core_list_str.empty()) {
    return;
  }
  auto core_ids = StrSplit(core_list_str, std::string(DELIM_COMMA));
  std::cout << "core list: ";
  for (const auto &core_id : core_ids) {
    std::cout << core_id << " ";
    this->core_list_.emplace_back(static_cast<int>(std::stoi(core_id)));
  }
  std::cout << std::endl;
}

int BenchmarkBase::CheckModelValid() {
  this->flags_->in_data_type_ = this->flags_->in_data_type_in_ == "img" ? kImage : kBinary;

  if (!flags_->benchmark_data_type_.empty()) {
    if (data_type_map_.find(flags_->benchmark_data_type_) == data_type_map_.end()) {
      MS_LOG(ERROR) << "CalibDataType not supported: " << flags_->benchmark_data_type_.c_str();
      return RET_ERROR;
    }
    msCalibDataType = data_type_map_.at(flags_->benchmark_data_type_);
    MS_LOG(INFO) << "CalibDataType = " << flags_->benchmark_data_type_.c_str();
    std::cout << "CalibDataType = " << flags_->benchmark_data_type_.c_str() << std::endl;
  }

  if (flags_->model_file_.empty()) {
    MS_LOG(ERROR) << "modelPath is required";
    std::cerr << "modelPath is required" << std::endl;
    return RET_ERROR;
  }

  if (ModelTypeMap.find(flags_->model_type_) == ModelTypeMap.end()) {
    MS_LOG(ERROR) << "Invalid model type: " << flags_->model_type_;
    std::cerr << "Invalid model type: " << flags_->model_type_ << std::endl;
    return RET_ERROR;
  }
  return RET_OK;
}

int BenchmarkBase::CheckThreadNumValid() {
  if (this->flags_->num_threads_ < kThreadNumMin) {
    MS_LOG(ERROR) << "numThreads:" << this->flags_->num_threads_ << " must be greater than 0";
    std::cerr << "numThreads:" << this->flags_->num_threads_ << " must be greater than 0" << std::endl;
    return RET_ERROR;
  }

  if (flags_->enable_parallel_) {
    if (flags_->num_threads_ < kParallelThreadNumMin) {
      MS_LOG(ERROR) << "enable parallel need more than 1 thread.";
      std::cerr << "enable parallel need more than 1 thread." << std::endl;
      return RET_ERROR;
    }
  }
  return RET_OK;
}

int BenchmarkBase::CheckDeviceTypeValid() {
  if (flags_->device_ != "CPU" && flags_->device_ != "GPU" && flags_->device_ != "NPU" &&
      flags_->device_ != "Ascend" && flags_->device_ != "NNRT") {
    MS_LOG(ERROR) << "Device type:" << flags_->device_ << " is not supported.";
    std::cerr << "Device type:" << flags_->device_ << " is not supported." << std::endl;
    return RET_ERROR;
  }
  return RET_OK;
}

int BenchmarkBase::InitDumpConfigFromJson(const char *path) {
#ifndef BENCHMARK_CLIP_JSON
  auto real_path = RealPath(path);
  std::ifstream ifs(real_path);
  if (!ifs.good()) {
    MS_LOG(ERROR) << "file: " << real_path << " is not exist";
    return RET_ERROR;
  }
  if (!ifs.is_open()) {
    MS_LOG(ERROR) << "file: " << real_path << " open failed";
    return RET_ERROR;
  }

//  try {
    dump_cfg_json_ = nlohmann::json::parse(ifs);
//  } catch (const nlohmann::json::parse_error &error) {
//    MS_LOG(ERROR) << "parse json file failed, please check your file.";
//    return RET_ERROR;
//  }
  if (dump_cfg_json_[dump::kSettings] == nullptr) {
    MS_LOG(ERROR) << "\"common_dump_settings\" is required.";
    return RET_ERROR;
  }
  if (dump_cfg_json_[dump::kSettings][dump::kMode] == nullptr) {
    MS_LOG(ERROR) << "\"dump_mode\" is required.";
    return RET_ERROR;
  }
  if (dump_cfg_json_[dump::kSettings][dump::kPath] == nullptr) {
    MS_LOG(ERROR) << "\"path\" is required.";
    return RET_ERROR;
  }
  if (dump_cfg_json_[dump::kSettings][dump::kNetName] == nullptr) {
    dump_cfg_json_[dump::kSettings][dump::kNetName] = "default";
  }
  if (dump_cfg_json_[dump::kSettings][dump::kInputOutput] == nullptr) {
    dump_cfg_json_[dump::kSettings][dump::kInputOutput] = 0;
  }
  if (dump_cfg_json_[dump::kSettings][dump::kKernels] != nullptr &&
      !dump_cfg_json_[dump::kSettings][dump::kKernels].empty()) {
    if (dump_cfg_json_[dump::kSettings][dump::kMode] == 0) {
      MS_LOG(ERROR) << R"("dump_mode" should be 1 when "kernels" isn't empty.)";
      return RET_ERROR;
    }
  }

  auto abs_path = dump_cfg_json_[dump::kSettings][dump::kPath].get<std::string>();
  auto net_name = dump_cfg_json_[dump::kSettings][dump::kNetName].get<std::string>();
  if (abs_path.back() == '\\' || abs_path.back() == '/') {
    dump_file_output_dir_ = abs_path + net_name;
  } else {
#ifdef _WIN32
    dump_file_output_dir_ = abs_path + "\\" + net_name;
#else
    dump_file_output_dir_ = abs_path + "/" + net_name;
#endif
  }

  auto status = CreateOutputDir(&dump_file_output_dir_);
  if (status != RET_OK) {
    MS_LOG(ERROR) << "create data output directory failed.";
    return RET_ERROR;
  }
#endif
  return RET_OK;
}

int BenchmarkBase::InitCallbackParameter() {
  int ret = RET_OK;
  if (flags_->time_profiling_) {
    ret = InitTimeProfilingCallbackParameter();
  } else if (flags_->perf_profiling_) {
    ret = InitPerfProfilingCallbackParameter();
  } else if (flags_->print_tensor_data_) {
    ret = InitPrintTensorDataCallbackParameter();
  } else if (flags_->dump_tensor_data_) {
    ret = InitDumpTensorDataCallbackParameter();
  }
  return ret;
}

int BenchmarkBase::Init() {
  MS_CHECK_FALSE(this->flags_ == nullptr, RET_ERROR);
  MS_LOG(INFO) << "ModelPath = " << this->flags_->model_file_;
  MS_LOG(INFO) << "ModelType = " << this->flags_->model_type_;
  MS_LOG(INFO) << "InDataPath = " << this->flags_->in_data_file_;
  MS_LOG(INFO) << "GroupInfoFile = " << this->flags_->group_info_file_;
  MS_LOG(INFO) << "ConfigFilePath = " << this->flags_->config_file_;
  MS_LOG(INFO) << "InDataType = " << this->flags_->in_data_type_in_;
  MS_LOG(INFO) << "LoopCount = " << this->flags_->loop_count_;
  MS_LOG(INFO) << "DeviceType = " << this->flags_->device_;
  MS_LOG(INFO) << "AccuracyThreshold = " << this->flags_->accuracy_threshold_;
  MS_LOG(INFO) << "CosineDistanceThreshold = " << this->flags_->cosine_distance_threshold_;
  MS_LOG(INFO) << "WarmUpLoopCount = " << this->flags_->warm_up_loop_count_;
  MS_LOG(INFO) << "NumThreads = " << this->flags_->num_threads_;
  MS_LOG(INFO) << "InterOpParallelNum = " << this->flags_->inter_op_parallel_num_;
  MS_LOG(INFO) << "Fp16Priority = " << this->flags_->enable_fp16_;
  MS_LOG(INFO) << "EnableParallel = " << this->flags_->enable_parallel_;
  MS_LOG(INFO) << "calibDataPath = " << this->flags_->benchmark_data_file_;
  MS_LOG(INFO) << "EnableGLTexture = " << this->flags_->enable_gl_texture_;

  std::cout << "ModelPath = " << this->flags_->model_file_ << std::endl;
  std::cout << "ModelType = " << this->flags_->model_type_ << std::endl;
  std::cout << "InDataPath = " << this->flags_->in_data_file_ << std::endl;
  std::cout << "GroupInfoFile = " << this->flags_->group_info_file_ << std::endl;
  std::cout << "ConfigFilePath = " << this->flags_->config_file_ << std::endl;
  std::cout << "InDataType = " << this->flags_->in_data_type_in_ << std::endl;
  std::cout << "LoopCount = " << this->flags_->loop_count_ << std::endl;
  std::cout << "DeviceType = " << this->flags_->device_ << std::endl;
  std::cout << "AccuracyThreshold = " << this->flags_->accuracy_threshold_ << std::endl;
  std::cout << "CosineDistanceThreshold = " << this->flags_->cosine_distance_threshold_ << std::endl;
  std::cout << "WarmUpLoopCount = " << this->flags_->warm_up_loop_count_ << std::endl;
  std::cout << "NumThreads = " << this->flags_->num_threads_ << std::endl;
  std::cout << "InterOpParallelNum = " << this->flags_->inter_op_parallel_num_ << std::endl;
  std::cout << "Fp16Priority = " << this->flags_->enable_fp16_ << std::endl;
  std::cout << "EnableParallel = " << this->flags_->enable_parallel_ << std::endl;
  std::cout << "calibDataPath = " << this->flags_->benchmark_data_file_ << std::endl;
  std::cout << "EnableGLTexture = " << this->flags_->enable_gl_texture_ << std::endl;
  if (this->flags_->loop_count_ < 1) {
    MS_LOG(ERROR) << "LoopCount:" << this->flags_->loop_count_ << " must be greater than 0";
    std::cerr << "LoopCount:" << this->flags_->loop_count_ << " must be greater than 0" << std::endl;
    return RET_ERROR;
  }

  if (this->flags_->enable_gl_texture_ == true && this->flags_->device_ != "GPU") {
    MS_LOG(ERROR) << "device must be GPU if you want to enable GLTexture";
    std::cerr << "ERROR: device must be GPU if you want to enable GLTexture" << std::endl;
    return RET_ERROR;
  }

  auto thread_ret = CheckThreadNumValid();
  if (thread_ret != RET_OK) {
    MS_LOG(ERROR) << "Invalid numThreads.";
    std::cerr << "Invalid numThreads." << std::endl;
    return RET_ERROR;
  }

  static std::vector<std::string> CPU_BIND_MODE_MAP = {"NO_BIND", "HIGHER_CPU", "MID_CPU"};
  if (this->flags_->cpu_bind_mode_ >= 1) {
    MS_LOG(INFO) << "cpuBindMode = " << CPU_BIND_MODE_MAP[this->flags_->cpu_bind_mode_];
    std::cout << "cpuBindMode = " << CPU_BIND_MODE_MAP[this->flags_->cpu_bind_mode_] << std::endl;
  } else {
    MS_LOG(INFO) << "cpuBindMode = NO_BIND";
    std::cout << "cpuBindMode = NO_BIND" << std::endl;
  }

  auto model_ret = CheckModelValid();
  if (model_ret != RET_OK) {
    MS_LOG(ERROR) << "Invalid Model File.";
    std::cerr << "Invalid Model File." << std::endl;
    return RET_ERROR;
  }

  flags_->InitInputDataList();
  flags_->InitCoreList();
  MS_CHECK_FALSE_MSG(flags_->InitResizeDimsList() != RET_OK, RET_ERROR, "init resize dims failed.");
  if (!flags_->resize_dims_.empty() && !flags_->input_data_list_.empty() &&
      flags_->resize_dims_.size() != flags_->input_data_list_.size()) {
    MS_LOG(ERROR) << "Size of input resizeDims should be equal to size of input inDataPath";
    std::cerr << "Size of input resizeDims should be equal to size of input inDataPath" << std::endl;
    return RET_ERROR;
  }

  if (CheckDeviceTypeValid() != RET_OK) {
    MS_LOG(ERROR) << "Device type is invalid.";
    return RET_ERROR;
  }

  if (flags_->time_profiling_ && flags_->perf_profiling_) {
    MS_LOG(INFO) << "time_profiling is enabled, will not run perf_profiling.";
  }

  // get dump data output path
  auto dump_cfg_path = std::getenv(dump::kConfigPath);
  if (dump_cfg_path != nullptr) {
    flags_->dump_tensor_data_ = true;
    if (InitDumpConfigFromJson(dump_cfg_path) != RET_OK) {
      MS_LOG(ERROR) << "parse dump config file failed.";
      return RET_ERROR;
    }
  } else {
    MS_LOG(INFO) << "No MINDSPORE_DUMP_CONFIG in env, don't need to dump data";
  }

  auto status = InitCallbackParameter();
  if (status != RET_OK) {
    MS_LOG(ERROR) << "Init callback Parameter failed.";
    std::cerr << "Init callback Parameter failed." << std::endl;
    return RET_ERROR;
  }

  return RET_OK;
}

int BenchmarkBase::PrintResult(const std::vector<std::string> &title,
                               const std::map<std::string, std::pair<int, float>> &result) {
  std::vector<size_t> columnLenMax(kPrintColNum);
  std::vector<std::vector<std::string>> rows;

  for (auto &iter : result) {
    char stringBuf[kPrintColNum][kPrintRowLenMax] = {};
    std::vector<std::string> columns;
    size_t len = 0;
    int index = 0;
    len = iter.first.size();
    if (len > columnLenMax.at(index)) {
      columnLenMax.at(index) = len + kColumnLen;
    }
    columns.push_back(iter.first);

    index++;
    len = snprintf(stringBuf[index], sizeof(stringBuf[index]), "%f",
                   iter.second.second / static_cast<float>(flags_->loop_count_));
    if (len > columnLenMax.at(index)) {
      columnLenMax.at(index) = len + kColumnLen;
    }
    columns.emplace_back(stringBuf[index]);

    index++;
    len = snprintf(stringBuf[index], sizeof(stringBuf[index]), "%f", iter.second.second / op_cost_total_);
    if (len > columnLenMax.at(index)) {
      columnLenMax.at(index) = len + kColumnLen;
    }
    columns.emplace_back(stringBuf[index]);

    index++;
    len = snprintf(stringBuf[index], sizeof(stringBuf[index]), "%d", iter.second.first);
    if (len > columnLenMax.at(index)) {
      columnLenMax.at(index) = len + kColumnLen;
    }
    columns.emplace_back(stringBuf[index]);

    index++;
    len = snprintf(stringBuf[index], sizeof(stringBuf[index]), "%f", iter.second.second);
    if (len > columnLenMax.at(index)) {
      columnLenMax.at(index) = len + kColumnLen;
    }
    columns.emplace_back(stringBuf[index]);

    rows.push_back(columns);
  }

  printf("-------------------------------------------------------------------------\n");
  for (int i = 0; i < kPrintColNum; i++) {
    auto printBuf = title[i];
    if (printBuf.size() > columnLenMax.at(i)) {
      columnLenMax.at(i) = printBuf.size();
    }
    printBuf.resize(columnLenMax.at(i), ' ');
    printf("%s\t", printBuf.c_str());
  }
  printf("\n");
  for (auto &row : rows) {
    for (int j = 0; j < kPrintColNum; j++) {
      auto printBuf = row[j];
      printBuf.resize(columnLenMax.at(j), ' ');
      printf("%s\t", printBuf.c_str());
    }
    printf("\n");
  }
  return RET_OK;
}

#ifdef ENABLE_ARM64
int BenchmarkBase::PrintPerfResult(const std::vector<std::string> &title,
                                   const std::map<std::string, std::pair<int, struct PerfCount>> &result) {
  std::vector<size_t> columnLenMax(kPrintColNum);
  std::vector<std::vector<std::string>> rows;

  for (auto &iter : result) {
    char stringBuf[kPrintColNum][kPrintRowLenMax] = {};
    std::vector<std::string> columns;
    size_t len = 0;
    int index = 0;
    len = iter.first.size();
    if (len > columnLenMax.at(index)) {
      columnLenMax.at(index) = len + kColumnLen;
    }
    columns.push_back(iter.first);
    index++;
    float tmp = float_t(flags_->num_threads_) * iter.second.second.value[0] / float_t(flags_->loop_count_) / kFloatMSEC;
    len = snprintf(stringBuf[index], sizeof(stringBuf[index]), "%.2f", tmp);
    if (len > columnLenMax.at(index)) {
      columnLenMax.at(index) = len + kColumnLen;
    }
    columns.emplace_back(stringBuf[index]);
    index++;
    len = snprintf(stringBuf[index], sizeof(stringBuf[index]), "%f", iter.second.second.value[0] / op_cost_total_);
    if (len > columnLenMax.at(index)) {
      columnLenMax.at(index) = len + kColumnLen;
    }
    columns.emplace_back(stringBuf[index]);

    index++;
    tmp = float_t(flags_->num_threads_) * iter.second.second.value[1] / float_t(flags_->loop_count_) / kFloatMSEC;
    len = snprintf(stringBuf[index], sizeof(stringBuf[index]), "%.2f", tmp);
    if (len > columnLenMax.at(index)) {
      columnLenMax.at(index) = len + kColumnLen;
    }
    columns.emplace_back(stringBuf[index]);

    index++;
    len = snprintf(stringBuf[index], sizeof(stringBuf[index]), "%f", iter.second.second.value[1] / op_cost2_total_);
    if (len > columnLenMax.at(index)) {
      columnLenMax.at(index) = len + kColumnLen;
    }
    columns.emplace_back(stringBuf[index]);

    rows.push_back(columns);
  }

  printf("-------------------------------------------------------------------------\n");
  for (int i = 0; i < kPrintColNum; i++) {
    auto printBuf = title[i];
    if (printBuf.size() > columnLenMax.at(i)) {
      columnLenMax.at(i) = printBuf.size();
    }
    printBuf.resize(columnLenMax.at(i), ' ');
    printf("%s\t", printBuf.c_str());
  }
  printf("\n");
  for (auto &row : rows) {
    for (int j = 0; j < kPrintColNum; j++) {
      auto printBuf = row[j];
      printBuf.resize(columnLenMax.at(j), ' ');
      printf("%s\t", printBuf.c_str());
    }
    printf("\n");
  }
  return RET_OK;
}
#endif

#ifdef SUPPORT_NNIE
int SvpSysInit() {
  HI_S32 ret = HI_SUCCESS;
  VB_CONFIG_S struVbConf;
  ret = HI_MPI_SYS_Exit();
  if (ret != HI_SUCCESS) {
    MS_LOG(ERROR) << "HI_MPI_SYS_Exit failed!";
    return RET_ERROR;
  }

  ret = HI_MPI_VB_Exit();
  if (ret != HI_SUCCESS) {
    MS_LOG(WARNING) << "HI_MPI_VB_Exit failed!";
    ret = HI_MPI_SYS_Init();
    if (ret != HI_SUCCESS) {
      MS_LOG(ERROR) << "Error:HI_MPI_SYS_Init failed!";
      return RET_ERROR;
    }
    return RET_OK;
  }

  memset(&struVbConf, 0, sizeof(VB_CONFIG_S));
  struVbConf.u32MaxPoolCnt = kNNIEMaxPoolCnt;
  struVbConf.astCommPool[1].u64BlkSize = kNNIEBlkSize;
  struVbConf.astCommPool[1].u32BlkCnt = 1;

  ret = HI_MPI_VB_SetConfig((const VB_CONFIG_S *)&struVbConf);
  if (ret != HI_SUCCESS) {
    MS_LOG(ERROR) << "Error:HI_MPI_VB_SetConf failed!";
    return RET_ERROR;
  }

  ret = HI_MPI_VB_Init();
  if (ret != HI_SUCCESS) {
    MS_LOG(ERROR) << "Error:HI_MPI_VB_Init failed!";
    return RET_ERROR;
  }

  ret = HI_MPI_SYS_Init();
  if (ret != HI_SUCCESS) {
    MS_LOG(ERROR) << "Error:HI_MPI_SYS_Init failed!";
    return RET_ERROR;
  }

  return RET_OK;
}

int SvpSysExit() {
  HI_S32 ret = HI_SUCCESS;

  ret = HI_MPI_SYS_Exit();
  if (ret != HI_SUCCESS) {
    MS_LOG(ERROR) << "HI_MPI_SYS_Exit failed!";
    return RET_ERROR;
  }

  ret = HI_MPI_VB_Exit();
  if (ret != HI_SUCCESS) {
    MS_LOG(WARNING) << "HI_MPI_VB_Exit failed!";
    return RET_OK;
  }

  return RET_OK;
}
#endif

BenchmarkBase::~BenchmarkBase() {
  for (auto &iter : this->benchmark_data_) {
    iter.second->shape.clear();
    iter.second->data.clear();
    delete iter.second;
    iter.second = nullptr;
  }
  this->benchmark_data_.clear();
#ifdef SUPPORT_NNIE
  SvpSysExit();
#endif
}
}  // namespace lite
}  // namespace mindspore