You can not select more than 25 topics Topics must start with a chinese character,a letter or number, can include dashes ('-') and can be up to 35 characters long.

variable_op_pass_unittest.cc 48 kB

5 years ago
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159
  1. /**
  2. * Copyright 2019-2020 Huawei Technologies Co., Ltd
  3. *
  4. * Licensed under the Apache License, Version 2.0 (the "License");
  5. * you may not use this file except in compliance with the License.
  6. * You may obtain a copy of the License at
  7. *
  8. * http://www.apache.org/licenses/LICENSE-2.0
  9. *
  10. * Unless required by applicable law or agreed to in writing, software
  11. * distributed under the License is distributed on an "AS IS" BASIS,
  12. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13. * See the License for the specific language governing permissions and
  14. * limitations under the License.
  15. */
  16. #include <gtest/gtest.h>
  17. #include <memory>
  18. #include <mutex>
  19. #include <thread>
  20. #include <vector>
  21. #include "common/types.h"
  22. #define protected public
  23. #define private public
  24. #include "graph/passes/variable_op_pass.h"
  25. #include "common/op/ge_op_utils.h"
  26. #include "graph/utils/op_desc_utils.h"
  27. #include "graph/utils/attr_utils.h"
  28. #include "graph/utils/graph_utils.h"
  29. #include "graph/op_desc.h"
  30. #include "graph/types.h"
  31. #include "graph/manager/graph_context.h"
  32. #include "graph/optimize/graph_optimize.h"
  33. #include "graph/manager/util/variable_accelerate_ctrl.h"
  34. #include "graph/manager/graph_mem_allocator.h"
  35. #include "graph/manager/graph_var_manager.h"
  36. #include "graph_builder_utils.h"
  37. #include "cce/dnn_struct_base.hpp"
  38. #include "common/formats/format_transfers/format_transfer.h"
  39. #include "common/formats/format_transfers/format_transfer_nchw_nc1hwc0.h"
  40. #include "common/formats/format_transfers/format_transfer_nhwc_nc1hwc0.h"
  41. #include "common/formats/format_transfers/datatype_transfer.h"
  42. #undef private
  43. #undef protected
  44. using namespace std;
  45. using namespace ge;
  46. using namespace cce;
  47. using namespace domi;
  48. class VariableOpPassUnittest : public testing::Test {
  49. protected:
  50. void SetUp() {}
  51. void TearDown() {}
  52. // AUTO GEN PLEASE DO NOT MODIFY IT
  53. };
  54. namespace {
  55. /// c
  56. /// var1ref1 --> netoutput1
  57. /// \ /
  58. /// transdata2
  59. /// |
  60. /// assign1
  61. /// / \
  62. /// transdata1 |
  63. /// | |
  64. /// var1 const1
  65. ComputeGraphPtr BuildGraph1() {
  66. auto builder = ut::GraphBuilder("g1");
  67. auto var1 = builder.AddNode("var1", "Variable", 0, 1);
  68. auto const1 =
  69. builder.AddNode("const1", "Const", 0, 1, FORMAT_NC1HWC0, DT_FLOAT, std::vector<int64_t>({1, 1, 224, 224, 16}));
  70. auto transdata1 = builder.AddNode("transdata1", "TransData", 1, 1, FORMAT_NC1HWC0, DT_FLOAT,
  71. std::vector<int64_t>({1, 1, 224, 224, 16}));
  72. transdata1->GetOpDesc()->MutableInputDesc(0)->SetFormat(FORMAT_NCHW);
  73. transdata1->GetOpDesc()->MutableInputDesc(0)->SetShape(GeShape(std::vector<int64_t>({1, 3, 224, 224})));
  74. auto assign1 =
  75. builder.AddNode("assign1", "Assign", 2, 1, FORMAT_NC1HWC0, DT_FLOAT, std::vector<int64_t>({1, 1, 224, 224, 16}));
  76. auto transdata2 = builder.AddNode("transdata2", "TransData", 1, 1, FORMAT_NC1HWC0, DT_FLOAT,
  77. std::vector<int64_t>({1, 1, 224, 224, 16}));
  78. transdata2->GetOpDesc()->MutableOutputDesc(0)->SetFormat(FORMAT_NCHW);
  79. transdata2->GetOpDesc()->MutableOutputDesc(0)->SetShape(GeShape(std::vector<int64_t>({1, 3, 224, 224})));
  80. auto var1ref1 = builder.AddNode("var1ref1", "Variable", 1, 0);
  81. AttrUtils::SetStr(var1ref1->GetOpDesc(), REF_VAR_SRC_VAR_NAME, "var1");
  82. auto netoutput1 = builder.AddNode("netoutput1", "Netoutput", 2, 0);
  83. builder.AddDataEdge(var1, 0, transdata1, 0);
  84. builder.AddDataEdge(const1, 0, assign1, 1);
  85. builder.AddDataEdge(transdata1, 0, assign1, 0);
  86. builder.AddDataEdge(assign1, 0, transdata2, 0);
  87. builder.AddDataEdge(transdata2, 0, var1ref1, 0);
  88. builder.AddDataEdge(transdata2, 0, netoutput1, 0);
  89. builder.AddControlEdge(var1ref1, netoutput1);
  90. return builder.GetGraph();
  91. }
  92. /// conv1
  93. /// |
  94. /// reshape1
  95. /// |
  96. /// var1
  97. ComputeGraphPtr BuildGraph2() {
  98. auto builder = ut::GraphBuilder("g1");
  99. auto var1 = builder.AddNode("var1", "Variable", 0, 1, FORMAT_ND, DT_FLOAT, std::vector<int64_t>({8 * 8 * 3, 2}));
  100. auto reshape1 =
  101. builder.AddNode("reshape1", "Reshape", 2, 1, FORMAT_HWCN, DT_FLOAT, std::vector<int64_t>({8, 8, 3, 2}));
  102. reshape1->GetOpDesc()->MutableInputDesc(0)->SetFormat(FORMAT_ND);
  103. reshape1->GetOpDesc()->MutableInputDesc(0)->SetShape(GeShape(std::vector<int64_t>({8 * 8 * 3, 2})));
  104. auto conv1 = builder.AddNode("conv1", "Conv2D", 2, 1, FORMAT_HWCN, DT_FLOAT, std::vector<int64_t>({8, 8, 3, 2}));
  105. builder.AddDataEdge(var1, 0, reshape1, 0);
  106. builder.AddDataEdge(reshape1, 0, conv1, 1);
  107. return builder.GetGraph();
  108. }
  109. /// conv1
  110. /// |
  111. /// reformat1
  112. /// |
  113. /// var1
  114. ComputeGraphPtr BuildGraph3() {
  115. auto builder = ut::GraphBuilder("g1");
  116. auto var1 = builder.AddNode("var1", "Variable", 0, 1, FORMAT_NCHW, DT_FLOAT, std::vector<int64_t>({8, 8, 3, 2}));
  117. auto reformat1 =
  118. builder.AddNode("reformat1", "ReFormat", 1, 1, FORMAT_ND, DT_FLOAT, std::vector<int64_t>({8, 8, 3, 2}));
  119. reformat1->GetOpDesc()->MutableInputDesc(0)->SetFormat(FORMAT_NCHW);
  120. reformat1->GetOpDesc()->MutableInputDesc(0)->SetShape(GeShape(std::vector<int64_t>({8, 8, 3, 2})));
  121. auto conv1 = builder.AddNode("conv1", "Conv2D", 2, 1, FORMAT_ND, DT_FLOAT, std::vector<int64_t>({8, 8, 3, 2}));
  122. builder.AddDataEdge(var1, 0, reformat1, 0);
  123. builder.AddDataEdge(reformat1, 0, conv1, 1);
  124. return builder.GetGraph();
  125. }
  126. class NodeBuilder {
  127. public:
  128. NodeBuilder(const std::string &name, const std::string &type) { op_desc_ = std::make_shared<OpDesc>(name, type); }
  129. NodeBuilder &AddInputDesc(std::initializer_list<int64_t> shape, ge::Format format = FORMAT_NCHW,
  130. ge::DataType data_type = DT_FLOAT) {
  131. op_desc_->AddInputDesc(CreateTensorDesc(shape, format, data_type)->Clone());
  132. return *this;
  133. }
  134. NodeBuilder &AddOutputDesc(std::initializer_list<int64_t> shape, ge::Format format = FORMAT_NCHW,
  135. ge::DataType data_type = DT_FLOAT) {
  136. op_desc_->AddOutputDesc(CreateTensorDesc(shape, format, data_type)->Clone());
  137. return *this;
  138. }
  139. ge::NodePtr Build(const ge::ComputeGraphPtr &graph) { return graph->AddNode(op_desc_); }
  140. private:
  141. ge::GeTensorDescPtr CreateTensorDesc(std::initializer_list<int64_t> shape, ge::Format format = FORMAT_NCHW,
  142. ge::DataType data_type = DT_FLOAT) {
  143. GeShape ge_shape{std::vector<int64_t>(shape)};
  144. ge::GeTensorDescPtr tensor_desc = std::make_shared<ge::GeTensorDesc>();
  145. tensor_desc->SetShape(ge_shape);
  146. tensor_desc->SetFormat(format);
  147. tensor_desc->SetDataType(data_type);
  148. return tensor_desc;
  149. }
  150. ge::OpDescPtr op_desc_;
  151. };
  152. std::string var_ref_name_0;
  153. ge::NodePtr CreatVariableRef(ge::NodePtr &final_writable_node, ge::NodePtr &var_node) {
  154. GELOGI("Create VarRef Op: final_writable_node: [%s] var_node: [%s]>>>>", final_writable_node->GetName().c_str(),
  155. var_node->GetName().c_str());
  156. static uint32_t var_ref_count = 0;
  157. std::stringstream var_ref_name;
  158. var_ref_name << "_to_" << final_writable_node->GetName() << "_REF_" << var_ref_count++;
  159. OpDescPtr var_op_desc = var_node->GetOpDesc();
  160. GE_CHK_BOOL_EXEC(var_op_desc != nullptr, return nullptr, "get var opdesc is nullptr");
  161. OpDescPtr var_ref_op_desc = nullptr;
  162. GE_MAKE_SHARED(var_ref_op_desc =
  163. std::make_shared<OpDesc>(var_node->GetName() + var_ref_name.str().c_str(), var_op_desc->GetType()),
  164. return nullptr);
  165. var_ref_op_desc->AddOutputDesc(var_op_desc->GetOutputDesc(0));
  166. var_ref_op_desc->AddInputDesc(var_op_desc->GetOutputDesc(0));
  167. const map<string, ge::GeAttrValue> var_attr_value = var_op_desc->GetAllAttrs();
  168. for (auto const &attrIt : var_attr_value) {
  169. var_ref_op_desc->SetAttr(attrIt.first, attrIt.second);
  170. }
  171. NodePtr var_ref_node = var_node->GetOwnerComputeGraph()->AddNode(var_ref_op_desc);
  172. GE_CHK_BOOL_EXEC(var_ref_node != nullptr, return nullptr, "create var_REF_node failed")
  173. GE_IF_BOOL_EXEC(ge::AttrUtils::SetStr(var_ref_op_desc, REF_VAR_SRC_VAR_NAME, var_op_desc->GetName()),
  174. GELOGI("Set node [%s] VAR_ATTR_VAR_IS_REF [%s]", var_ref_node->GetName().c_str(),
  175. var_op_desc->GetName().c_str()));
  176. var_ref_name_0 = var_ref_node->GetName();
  177. return var_ref_node;
  178. }
  179. bool BuildComputeGraph0(ge::ComputeGraphPtr &graph) {
  180. // graph = std::make_shared<ComputeGraph>("test");
  181. ge::NodePtr node_4d_new =
  182. NodeBuilder("Node4D_new", VARIABLE).AddOutputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32).Build(graph);
  183. ge::NodePtr node_4d_to_5d_1_new = NodeBuilder("4d_to_5d_1_new", TRANSDATA)
  184. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  185. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  186. .Build(graph);
  187. ge::NodePtr node_4d_to_5d_2_new = NodeBuilder("4d_to_5d_2_new", TRANSDATA)
  188. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  189. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_INT32)
  190. .Build(graph);
  191. ge::GraphUtils::AddEdge(node_4d_new->GetOutDataAnchor(0), node_4d_to_5d_1_new->GetInDataAnchor(0));
  192. ge::GraphUtils::AddEdge(node_4d_new->GetOutDataAnchor(0), node_4d_to_5d_2_new->GetInDataAnchor(0));
  193. // Node4D
  194. ge::NodePtr node_4d =
  195. NodeBuilder("Node4D", VARIABLE).AddOutputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32).Build(graph);
  196. // NodeTrans4DTo5D
  197. ge::NodePtr node_4d_to_5d_1 = NodeBuilder("4d_to_5d_1", TRANSDATA)
  198. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  199. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  200. .Build(graph);
  201. ge::NodePtr node_4d_to_5d_2 = NodeBuilder("4d_to_5d_2", TRANSDATA)
  202. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  203. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  204. .Build(graph);
  205. // Node5D
  206. ge::NodePtr node_5d_1 =
  207. NodeBuilder("5D_1", RELU).AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT).Build(graph);
  208. ge::NodePtr node_5d_2 =
  209. NodeBuilder("5D_2", RELU).AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT).Build(graph);
  210. // add edge
  211. ge::GraphUtils::AddEdge(node_4d->GetOutDataAnchor(0), node_4d_to_5d_1->GetInDataAnchor(0));
  212. ge::GraphUtils::AddEdge(node_4d->GetOutDataAnchor(0), node_4d_to_5d_2->GetInDataAnchor(0));
  213. ge::GraphUtils::AddEdge(node_4d_to_5d_1->GetOutDataAnchor(0), node_5d_1->GetInDataAnchor(0));
  214. ge::GraphUtils::AddEdge(node_4d_to_5d_2->GetOutDataAnchor(0), node_5d_2->GetInDataAnchor(0));
  215. // Node4D
  216. ge::NodePtr node_4d_nhwc =
  217. NodeBuilder("Node4D_NHWC", VARIABLE).AddOutputDesc({1, 2, 3, 4}, FORMAT_NHWC, DT_INT32).Build(graph);
  218. // NodeTrans4DTo5D
  219. ge::NodePtr node_4d_to_5d_1_nhwc = NodeBuilder("4d_to_5d_1_NHWC", TRANSDATA)
  220. .AddInputDesc({1, 2, 3, 4}, FORMAT_NHWC, DT_INT32)
  221. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  222. .Build(graph);
  223. // Node5D
  224. ge::NodePtr node_5d_1_nhwc =
  225. NodeBuilder("5D_1_NHWC", RELU).AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT).Build(graph);
  226. // add edge
  227. ge::GraphUtils::AddEdge(node_4d_nhwc->GetOutDataAnchor(0), node_4d_to_5d_1_nhwc->GetInDataAnchor(0));
  228. ge::GraphUtils::AddEdge(node_4d_to_5d_1_nhwc->GetOutDataAnchor(0), node_5d_1_nhwc->GetInDataAnchor(0));
  229. // Node4D
  230. ge::NodePtr node_4d_hwcn =
  231. NodeBuilder("Node4D_HWCN", VARIABLE).AddOutputDesc({1, 2, 3, 4}, FORMAT_HWCN, DT_INT32).Build(graph);
  232. // NodeTrans4DTo5D
  233. ge::NodePtr node_4d_to_5d_1_hwcn = NodeBuilder("4d_to_5d_1_HWCN", TRANSDATA)
  234. .AddInputDesc({1, 2, 3, 4}, FORMAT_HWCN, DT_INT32)
  235. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  236. .Build(graph);
  237. // Node5D
  238. ge::NodePtr node_5d_1_hwcn =
  239. NodeBuilder("5D_1_HWCN", RELU).AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT).Build(graph);
  240. // add edge
  241. ge::GraphUtils::AddEdge(node_4d_hwcn->GetOutDataAnchor(0), node_4d_to_5d_1_hwcn->GetInDataAnchor(0));
  242. ge::GraphUtils::AddEdge(node_4d_to_5d_1_hwcn->GetOutDataAnchor(0), node_5d_1_hwcn->GetInDataAnchor(0));
  243. ge::NodePtr node_4d_chwn =
  244. NodeBuilder("Node4D_CHWN", VARIABLE).AddOutputDesc({1, 2, 3, 4}, FORMAT_CHWN, DT_INT32).Build(graph);
  245. // NodeTrans4DTo5D
  246. ge::NodePtr node_4d_to_5d_1_chwn = NodeBuilder("4d_to_5d_1_CHWN", TRANSDATA)
  247. .AddInputDesc({1, 2, 3, 4}, FORMAT_CHWN, DT_INT32)
  248. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  249. .Build(graph);
  250. // Node5D
  251. ge::NodePtr node_5d_1_chwn =
  252. NodeBuilder("5D_1_CHWN", RELU).AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT).Build(graph);
  253. // add edge
  254. ge::GraphUtils::AddEdge(node_4d_chwn->GetOutDataAnchor(0), node_4d_to_5d_1_chwn->GetInDataAnchor(0));
  255. ge::GraphUtils::AddEdge(node_4d_to_5d_1_chwn->GetOutDataAnchor(0), node_5d_1_chwn->GetInDataAnchor(0));
  256. ge::NodePtr node_4d_d =
  257. NodeBuilder("Node4D_D", VARIABLE).AddOutputDesc({1}, FORMAT_CHWN, DT_INT32).Build(graph);
  258. // NodeTrans4DTo5D
  259. ge::NodePtr node_4d_to_5d_1_d = NodeBuilder("4d_to_5d_1_D", TRANSDATA)
  260. .AddInputDesc({1, 2, 3, 4}, FORMAT_CHWN, DT_INT32)
  261. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  262. .Build(graph);
  263. // Node5D
  264. ge::NodePtr node_5d_1_d =
  265. NodeBuilder("5D_1_D", RELU).AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT).Build(graph);
  266. ge::NodePtr node_apply_monetum = NodeBuilder("apply_monetum", APPLYMOMENTUM)
  267. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  268. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  269. .Build(graph);
  270. ge::NodePtr node_5d_to_4d_1 = NodeBuilder("5d_to_4d_1", TRANSDATA)
  271. .AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  272. .AddOutputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  273. .Build(graph);
  274. ge::NodePtr node_ref = CreatVariableRef(node_5d_to_4d_1, node_4d);
  275. // add edge
  276. ge::GraphUtils::AddEdge(node_4d_d->GetOutDataAnchor(0), node_4d_to_5d_1_d->GetInDataAnchor(0));
  277. ge::GraphUtils::AddEdge(node_4d_to_5d_1_d->GetOutDataAnchor(0), node_5d_1_d->GetInDataAnchor(0));
  278. if (ge::GraphUtils::AddEdge(node_apply_monetum->GetOutDataAnchor(0), node_5d_to_4d_1->GetInDataAnchor(0)) !=
  279. ge::SUCCESS) {
  280. /// GELOGE(FAILED, "ge::GraphUtils::AddEdge(node_apply_monetum->GetOutDataAnchor(0),
  281. /// node_5d_to_4d_1->GetInDataAnchor(0) ) Failed.");
  282. };
  283. ge::GraphUtils::AddEdge(node_5d_to_4d_1->GetOutDataAnchor(0), node_ref->GetInDataAnchor(0));
  284. return true;
  285. }
  286. bool BuildComputeGraph1(ge::ComputeGraphPtr &graph) {
  287. // Node4D
  288. ge::NodePtr node_4d =
  289. NodeBuilder("Node4D", VARIABLE).AddOutputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32).Build(graph);
  290. // NodeTrans4DTo5D
  291. ge::NodePtr node_4d_to_5d_1 = NodeBuilder("4d_to_5d_1", TRANSDATA)
  292. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  293. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  294. .Build(graph);
  295. ge::NodePtr node_4d_to_5d_2 = NodeBuilder("4d_to_5d_2", TRANSDATA)
  296. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  297. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  298. .Build(graph);
  299. // Node5D
  300. ge::NodePtr node_5d_1 =
  301. NodeBuilder("5D_1", RELU).AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT).Build(graph);
  302. ge::NodePtr node_5d_2 =
  303. NodeBuilder("5D_2", RELU).AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT).Build(graph);
  304. ge::NodePtr node_5d_to_4d_1 = NodeBuilder("5d_to_4d_1", TRANSDATA)
  305. .AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_INT32)
  306. .AddOutputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  307. .Build(graph);
  308. ge::NodePtr node_apply_monetum = NodeBuilder("apply_monetum", APPLYMOMENTUM)
  309. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  310. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_INT32)
  311. .Build(graph);
  312. ge::NodePtr node_ref = CreatVariableRef(node_5d_to_4d_1, node_4d);
  313. // add edge
  314. ge::GraphUtils::AddEdge(node_4d->GetOutDataAnchor(0), node_4d_to_5d_1->GetInDataAnchor(0));
  315. ge::GraphUtils::AddEdge(node_4d->GetOutDataAnchor(0), node_4d_to_5d_2->GetInDataAnchor(0));
  316. ge::GraphUtils::AddEdge(node_4d_to_5d_1->GetOutDataAnchor(0), node_5d_1->GetInDataAnchor(0));
  317. ge::GraphUtils::AddEdge(node_4d_to_5d_2->GetOutDataAnchor(0), node_5d_2->GetInDataAnchor(0));
  318. if (ge::GraphUtils::AddEdge(node_apply_monetum->GetOutDataAnchor(0), node_5d_to_4d_1->GetInDataAnchor(0)) !=
  319. ge::SUCCESS) {
  320. /// GELOGE(FAILED, "ge::GraphUtils::AddEdge(node_apply_monetum->GetOutDataAnchor(0),
  321. /// node_5d_to_4d_1->GetInDataAnchor(0) ) Failed.");
  322. };
  323. ge::GraphUtils::AddEdge(node_5d_to_4d_1->GetOutDataAnchor(0), node_ref->GetInDataAnchor(0));
  324. return true;
  325. }
  326. bool BuildComputeGraph4(ge::ComputeGraphPtr &graph) {
  327. // Node4D
  328. ge::NodePtr node_4d =
  329. NodeBuilder("Node4D", VARIABLE).AddOutputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32).Build(graph);
  330. // NodeTrans4DTo5D
  331. ge::NodePtr node_4d_to_5d_1 = NodeBuilder("4d_to_5d_1", TRANSDATA)
  332. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  333. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  334. .Build(graph);
  335. ge::NodePtr node_4d_to_5d_2 = NodeBuilder("4d_to_5d_2", TRANSDATA)
  336. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  337. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  338. .Build(graph);
  339. // Node5D
  340. ge::NodePtr node_5d_1 =
  341. NodeBuilder("5D_1", RELU).AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT).Build(graph);
  342. ge::NodePtr node_5d_2 =
  343. NodeBuilder("5D_2", RELU).AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT).Build(graph);
  344. ge::NodePtr node_5d_to_4d_1 = NodeBuilder("5d_to_4d_1", TRANSDATA)
  345. .AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_INT32)
  346. .AddOutputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  347. .Build(graph);
  348. ge::NodePtr node_5d_to_4d_2 = NodeBuilder("5d_to_4d_2", TRANSDATA)
  349. .AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_INT32)
  350. .AddOutputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  351. .Build(graph);
  352. ge::NodePtr node_apply_monetum = NodeBuilder("apply_monetum", APPLYMOMENTUM)
  353. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  354. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_INT32)
  355. .Build(graph);
  356. ge::NodePtr node_ref = CreatVariableRef(node_5d_to_4d_1, node_4d);
  357. // add edge
  358. ge::GraphUtils::AddEdge(node_4d->GetOutDataAnchor(0), node_4d_to_5d_1->GetInDataAnchor(0));
  359. ge::GraphUtils::AddEdge(node_4d->GetOutDataAnchor(0), node_4d_to_5d_2->GetInDataAnchor(0));
  360. ge::GraphUtils::AddEdge(node_4d_to_5d_1->GetOutDataAnchor(0), node_5d_1->GetInDataAnchor(0));
  361. ge::GraphUtils::AddEdge(node_4d_to_5d_2->GetOutDataAnchor(0), node_5d_2->GetInDataAnchor(0));
  362. ge::GraphUtils::AddEdge(node_apply_monetum->GetOutDataAnchor(0), node_5d_to_4d_1->GetInDataAnchor(0));
  363. ge::GraphUtils::AddEdge(node_5d_to_4d_1->GetOutDataAnchor(0), node_ref->GetInDataAnchor(0));
  364. ge::GraphUtils::AddEdge(node_5d_to_4d_2->GetOutDataAnchor(0), node_ref->GetInDataAnchor(0));
  365. return true;
  366. }
  367. bool BuildComputeGraph5(ge::ComputeGraphPtr &graph) {
  368. // Node4D
  369. ge::NodePtr node_4d =
  370. NodeBuilder("Node4D", VARIABLE).AddOutputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32).Build(graph);
  371. return true;
  372. }
  373. bool BuildComputeGraph6(ge::ComputeGraphPtr &graph) {
  374. // Node4D
  375. ge::NodePtr node_4d =
  376. NodeBuilder("Node4D", VARIABLE).AddOutputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32).Build(graph);
  377. // NodeTrans4DTo5D
  378. ge::NodePtr node_4d_to_5d_1 = NodeBuilder("4d_to_5d_1", TRANSDATA)
  379. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  380. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  381. .Build(graph);
  382. ge::NodePtr node_float_to_int_1 = NodeBuilder("float_to_int_1", CAST)
  383. .AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  384. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_INT32)
  385. .Build(graph);
  386. ge::NodePtr node_4d_to_5d_2 = NodeBuilder("4d_to_5d_2", TRANSDATA)
  387. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  388. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  389. .Build(graph);
  390. ge::NodePtr node_float_to_int_2 = NodeBuilder("float_to_int_2", CAST)
  391. .AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_FLOAT)
  392. .AddOutputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_INT32)
  393. .Build(graph);
  394. // Node5D
  395. ge::NodePtr node_5d_1 =
  396. NodeBuilder("5D_1", RELU).AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_INT32).Build(graph);
  397. ge::NodePtr node_5d_2 =
  398. NodeBuilder("5D_2", RELU).AddInputDesc({1, 2, 3, 4, 5}, FORMAT_NC1HWC0, DT_INT32).Build(graph);
  399. // add edge
  400. ge::GraphUtils::AddEdge(node_4d->GetOutDataAnchor(0), node_4d_to_5d_1->GetInDataAnchor(0));
  401. ge::GraphUtils::AddEdge(node_4d->GetOutDataAnchor(0), node_4d_to_5d_2->GetInDataAnchor(0));
  402. ge::GraphUtils::AddEdge(node_4d_to_5d_1->GetOutDataAnchor(0), node_float_to_int_1->GetInDataAnchor(0));
  403. ge::GraphUtils::AddEdge(node_4d_to_5d_2->GetOutDataAnchor(0), node_float_to_int_2->GetInDataAnchor(0));
  404. ge::GraphUtils::AddEdge(node_float_to_int_1->GetOutDataAnchor(0), node_5d_1->GetInDataAnchor(0));
  405. ge::GraphUtils::AddEdge(node_float_to_int_2->GetOutDataAnchor(0), node_5d_2->GetInDataAnchor(0));
  406. return true;
  407. }
  408. } // namespace
  409. bool BuildComputeGraph7(ge::ComputeGraphPtr &graph) {
  410. // Node4D
  411. ge::NodePtr node_4d =
  412. NodeBuilder("Node4D", VARIABLE).AddOutputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32).Build(graph);
  413. // NodeTrans4DTo5D
  414. ge::NodePtr node_4d_to_4d_1 = NodeBuilder("4d_to_4d_1", TRANSDATA)
  415. .AddInputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  416. .AddOutputDesc({1, 2, 3, 4}, FORMAT_NCHW, DT_INT32)
  417. .Build(graph);
  418. // Node5D
  419. ge::NodePtr node_4d_1 = NodeBuilder("4D_1", RELU).AddInputDesc({1, 2, 3, 4}, FORMAT_NC1HWC0, DT_INT32).Build(graph);
  420. // add edge
  421. ge::GraphUtils::AddEdge(node_4d->GetOutDataAnchor(0), node_4d_to_4d_1->GetInDataAnchor(0));
  422. ge::GraphUtils::AddEdge(node_4d_to_4d_1->GetOutDataAnchor(0), node_4d_1->GetInDataAnchor(0));
  423. return true;
  424. }
  425. class VariableOpPassSimulator {
  426. public:
  427. bool DoTest0() {
  428. ge::ComputeGraphPtr compute_graph = std::make_shared<ComputeGraph>("0");
  429. const std::string var_name = "Node4D";
  430. uint64_t session_id = 0;
  431. uint32_t device_id = 0;
  432. uint64_t job_id = 0;
  433. uint32_t session_version = 0;
  434. std::vector<int64_t> dims(4, 20);
  435. ge::GeShape shape(dims);
  436. MemManager::Instance().Initialize(std::vector<rtMemType_t>({RT_MEMORY_HBM}));
  437. VarManager::Instance(session_id)->Init(session_version, session_id, device_id, job_id);
  438. BuildComputeGraph0(compute_graph);
  439. std::vector<std::string> var_names = {"Node4D_new", "Node4D", "Node4D_NHWC",
  440. "Node4D_HWCN", "Node4D_CHWN", "Node4D_D"};
  441. for (auto name : var_names) {
  442. auto var_node = compute_graph->FindNode(name);
  443. auto var_tensor_desc = var_node->GetOpDesc()->GetOutputDesc(0);
  444. uint8_t *dev_ptr = nullptr;
  445. ge::VarManager::Instance(session_id)->AssignVarMem(name, var_tensor_desc, RT_MEMORY_HBM);
  446. ge::VarManager::Instance(session_id)->SetVarAddr(name, var_tensor_desc, dev_ptr, RT_MEMORY_HBM);
  447. }
  448. ge::GraphNodePtr graph_node = make_shared<GraphNode>(0);
  449. compute_graph->InferShapeInNeed();
  450. graph_node->SetComputeGraph(compute_graph);
  451. auto tmp_graph = GraphUtils::CreateGraphFromComputeGraph(compute_graph);
  452. auto tmp_graph_ptr = std::make_shared<Graph>(tmp_graph);
  453. graph_node->SetGraph(tmp_graph_ptr);
  454. VarAccelerateCtrl ctrl;
  455. ctrl.AddGraph(graph_node->GetGraphId(), compute_graph);
  456. ge::formats::FormatTransferNchwNc1hwc0 ClassObj;
  457. VariableOpPass pass(&ctrl);
  458. pass.Run(compute_graph);
  459. MemManager::Instance().Finalize();
  460. return CheckTest0(compute_graph);
  461. }
  462. bool DoTest1() {
  463. ge::ComputeGraphPtr compute_graph = std::make_shared<ComputeGraph>("0");
  464. const std::string var_name = "Node4D";
  465. uint64_t session_id = 0;
  466. uint32_t device_id = 0;
  467. uint64_t job_id = 0;
  468. uint32_t session_version = 0;
  469. std::vector<int64_t> dims(4, 20);
  470. ge::GeShape shape(dims);
  471. VarManager::Instance(session_id)->Init(session_version, session_id, device_id, job_id);
  472. BuildComputeGraph1(compute_graph);
  473. auto var_node = compute_graph->FindNode(var_name);
  474. auto var_tensor_desc = var_node->GetOpDesc()->GetOutputDesc(0);
  475. uint8_t *dev_ptr = nullptr;
  476. ge::GraphNodePtr graph_node = make_shared<GraphNode>(0);
  477. compute_graph->InferShapeInNeed();
  478. graph_node->SetComputeGraph(compute_graph);
  479. auto tmp_graph = GraphUtils::CreateGraphFromComputeGraph(compute_graph);
  480. auto tmp_graph_ptr = std::make_shared<Graph>(tmp_graph);
  481. graph_node->SetGraph(tmp_graph_ptr);
  482. VarAccelerateCtrl ctrl;
  483. ctrl.AddGraph(graph_node->GetGraphId(), compute_graph);
  484. VariableOpPass pass(&ctrl);
  485. pass.Run(compute_graph);
  486. return CheckTest1(compute_graph);
  487. }
  488. bool DoTest2() {
  489. VarAccelerateCtrl ctrl;
  490. VariableOpPass pass(&ctrl);
  491. return pass.Run(nullptr) == ge::INTERNAL_ERROR;
  492. }
  493. bool DoTest3() {
  494. std::vector<rtMemType_t> mem_type;
  495. std::map<std::string, std::string> empty_options;
  496. mem_type.push_back(RT_MEMORY_HBM);
  497. MemManager::Instance().Initialize(mem_type);
  498. ge::ComputeGraphPtr compute_graph = std::make_shared<ComputeGraph>("0");
  499. std::vector<std::string> var_names = {"Node4D", "Node4D_NHWC", "Node4D_HWCN", "Node4D_CHWN", "Node4D_D"};
  500. std::vector<ge::GeTensorDesc> tensor_descs;
  501. uint64_t session_id = 0;
  502. uint32_t device_id = 0;
  503. uint64_t job_id = 0;
  504. uint32_t session_version = 0;
  505. compute_graph->SetSessionID(session_id);
  506. std::vector<int64_t> dims(4, 20);
  507. ge::GeShape shape(dims);
  508. VarManager::Instance(session_id)->Init(session_version, session_id, device_id, job_id);
  509. BuildComputeGraph0(compute_graph);
  510. for (auto var_name : var_names) {
  511. auto var_node = compute_graph->FindNode(var_name);
  512. auto var_tensor_desc = var_node->GetOpDesc()->GetOutputDesc(0);
  513. uint8_t *dev_ptr = nullptr;
  514. ge::VarManager::Instance(session_id)->AssignVarMem(var_name, var_tensor_desc, RT_MEMORY_HBM);
  515. ge::VarManager::Instance(session_id)->SetVarAddr(var_name, var_tensor_desc, dev_ptr, RT_MEMORY_HBM);
  516. }
  517. ge::GraphNodePtr graph_node = make_shared<GraphNode>(0);
  518. compute_graph->InferShapeInNeed();
  519. graph_node->SetComputeGraph(compute_graph);
  520. auto tmp_graph = GraphUtils::CreateGraphFromComputeGraph(compute_graph);
  521. auto tmp_graph_ptr = std::make_shared<Graph>(tmp_graph);
  522. graph_node->SetGraph(tmp_graph_ptr);
  523. VarAccelerateCtrl ctrl;
  524. ctrl.AddGraph(graph_node->GetGraphId(), compute_graph);
  525. VariableOpPass pass(&ctrl);
  526. auto ret = pass.Run(compute_graph);
  527. MemManager::Instance().Finalize();
  528. return ret == GE_GRAPH_VARIABLE_OP_PASS_FAILED;
  529. }
  530. bool DoTest4() {
  531. ge::ComputeGraphPtr compute_graph = std::make_shared<ComputeGraph>("0");
  532. const std::string var_name = "Node4D";
  533. uint64_t session_id = 0;
  534. uint32_t device_id = 0;
  535. uint64_t job_id = 0;
  536. uint32_t session_version = 0;
  537. std::vector<int64_t> dims(4, 20);
  538. ge::GeShape shape(dims);
  539. VarManager::Instance(session_id)->Init(session_version, session_id, device_id, job_id);
  540. BuildComputeGraph4(compute_graph);
  541. auto var_node = compute_graph->FindNode(var_name);
  542. auto var_tensor_desc = var_node->GetOpDesc()->GetOutputDesc(0);
  543. uint8_t *dev_ptr = nullptr;
  544. ge::GraphNodePtr graph_node = make_shared<GraphNode>(0);
  545. compute_graph->InferShapeInNeed();
  546. graph_node->SetComputeGraph(compute_graph);
  547. auto tmp_graph = GraphUtils::CreateGraphFromComputeGraph(compute_graph);
  548. auto tmp_graph_ptr = std::make_shared<Graph>(tmp_graph);
  549. graph_node->SetGraph(tmp_graph_ptr);
  550. VarAccelerateCtrl ctrl;
  551. ctrl.AddGraph(graph_node->GetGraphId(), compute_graph);
  552. VariableOpPass pass(&ctrl);
  553. auto ret = pass.Run(compute_graph);
  554. return ret == ge::SUCCESS;
  555. }
  556. bool DoTest5() {
  557. ge::ComputeGraphPtr compute_graph = std::make_shared<ComputeGraph>("0");
  558. BuildComputeGraph5(compute_graph);
  559. const std::string var_name = "Node4D";
  560. uint64_t session_id = 0;
  561. uint32_t device_id = 0;
  562. uint64_t job_id = 0;
  563. uint32_t session_version = 0;
  564. std::vector<int64_t> dims(4, 20);
  565. ge::GeShape shape(dims);
  566. VarManager::Instance(session_id)->Init(session_version, session_id, device_id, job_id);
  567. BuildComputeGraph4(compute_graph);
  568. auto var_node = compute_graph->FindNode(var_name);
  569. auto var_tensor_desc = var_node->GetOpDesc()->GetOutputDesc(0);
  570. uint8_t *dev_ptr = nullptr;
  571. ge::GraphNodePtr graph_node = make_shared<GraphNode>(0);
  572. compute_graph->InferShapeInNeed();
  573. graph_node->SetComputeGraph(compute_graph);
  574. auto tmp_graph = GraphUtils::CreateGraphFromComputeGraph(compute_graph);
  575. auto tmp_graph_ptr = std::make_shared<Graph>(tmp_graph);
  576. graph_node->SetGraph(tmp_graph_ptr);
  577. VarAccelerateCtrl ctrl;
  578. ctrl.AddGraph(graph_node->GetGraphId(), compute_graph);
  579. VariableOpPass pass(&ctrl);
  580. auto ret = pass.Run(compute_graph);
  581. return ret == ge::SUCCESS;
  582. }
  583. bool DoTest6() {
  584. ge::ComputeGraphPtr compute_graph = std::make_shared<ComputeGraph>("0");
  585. const std::string var_name = "Node4D";
  586. uint64_t session_id = 0;
  587. uint32_t device_id = 0;
  588. uint64_t job_id = 0;
  589. uint32_t session_version = 0;
  590. std::vector<int64_t> dims(4, 20);
  591. ge::GeShape shape(dims);
  592. MemManager::Instance().Initialize(std::vector<rtMemType_t>({RT_MEMORY_HBM}));
  593. VarManager::Instance(session_id)->Init(session_version, session_id, device_id, job_id);
  594. BuildComputeGraph6(compute_graph);
  595. auto var_node = compute_graph->FindNode(var_name);
  596. auto var_tensor_desc = var_node->GetOpDesc()->GetOutputDesc(0);
  597. uint8_t *dev_ptr = nullptr;
  598. ge::VarManager::Instance(session_id)->AssignVarMem(var_name, var_tensor_desc, RT_MEMORY_HBM);
  599. ge::VarManager::Instance(session_id)->SetVarAddr(var_name, var_tensor_desc, dev_ptr, RT_MEMORY_HBM);
  600. ge::GraphNodePtr graph_node = make_shared<GraphNode>(0);
  601. compute_graph->InferShapeInNeed();
  602. graph_node->SetComputeGraph(compute_graph);
  603. auto tmp_graph = GraphUtils::CreateGraphFromComputeGraph(compute_graph);
  604. auto tmp_graph_ptr = std::make_shared<Graph>(tmp_graph);
  605. graph_node->SetGraph(tmp_graph_ptr);
  606. VarAccelerateCtrl ctrl;
  607. ctrl.AddGraph(graph_node->GetGraphId(), compute_graph);
  608. ge::formats::FormatTransferNchwNc1hwc0 ClassObj;
  609. VariableOpPass pass(&ctrl);
  610. auto ret = pass.Run(compute_graph);
  611. MemManager::Instance().Finalize();
  612. return CheckTest6(compute_graph);
  613. }
  614. bool DoTest7() {
  615. ge::ComputeGraphPtr compute_graph = std::make_shared<ComputeGraph>("0");
  616. const std::string var_name = "Node4D";
  617. uint64_t session_id = 0;
  618. uint32_t device_id = 0;
  619. uint64_t job_id = 0;
  620. uint32_t session_version = 0;
  621. std::vector<int64_t> dims(4, 20);
  622. ge::GeShape shape(dims);
  623. VarManager::Instance(session_id)->Init(session_version, session_id, device_id, job_id);
  624. BuildComputeGraph7(compute_graph);
  625. auto var_node = compute_graph->FindNode(var_name);
  626. auto var_tensor_desc = var_node->GetOpDesc()->GetOutputDesc(0);
  627. uint8_t *dev_ptr = nullptr;
  628. ge::GraphNodePtr graph_node = make_shared<GraphNode>(0);
  629. compute_graph->InferShapeInNeed();
  630. graph_node->SetComputeGraph(compute_graph);
  631. auto tmp_graph = GraphUtils::CreateGraphFromComputeGraph(compute_graph);
  632. auto tmp_graph_ptr = std::make_shared<Graph>(tmp_graph);
  633. graph_node->SetGraph(tmp_graph_ptr);
  634. VarAccelerateCtrl ctrl;
  635. ctrl.AddGraph(graph_node->GetGraphId(), compute_graph);
  636. VariableOpPass pass(&ctrl);
  637. auto ret = pass.Run(compute_graph);
  638. return CheckTest7(compute_graph);
  639. }
  640. bool DoTest8() {
  641. ge::ComputeGraphPtr compute_graph = std::make_shared<ComputeGraph>("0");
  642. const std::string var_name = "Node4D";
  643. uint64_t session_id = 0;
  644. uint32_t device_id = 0;
  645. uint64_t job_id = 0;
  646. uint32_t session_version = 0;
  647. std::vector<int64_t> dims(4, 20);
  648. ge::GeShape shape(dims);
  649. VarManager::Instance(session_id)->Init(session_version, session_id, device_id, job_id);
  650. BuildComputeGraph0(compute_graph);
  651. auto var_node = compute_graph->FindNode(var_name);
  652. auto var_tensor_desc = var_node->GetOpDesc()->GetOutputDesc(0);
  653. uint8_t *dev_ptr = nullptr;
  654. ge::GraphNodePtr graph_node = make_shared<GraphNode>(0);
  655. compute_graph->InferShapeInNeed();
  656. graph_node->SetComputeGraph(compute_graph);
  657. auto tmp_graph = GraphUtils::CreateGraphFromComputeGraph(compute_graph);
  658. auto tmp_graph_ptr = std::make_shared<Graph>(tmp_graph);
  659. graph_node->SetGraph(tmp_graph_ptr);
  660. VarAccelerateCtrl ctrl;
  661. ctrl.AddGraph(graph_node->GetGraphId(), compute_graph);
  662. VariableOpPass pass(&ctrl);
  663. pass.Run(compute_graph);
  664. return CheckTest8(compute_graph);
  665. }
  666. private:
  667. bool CheckTest0(const ge::ComputeGraphPtr compute_graph) {
  668. const auto &variable_node = compute_graph->FindNode("Node4D");
  669. auto variable_node_format = variable_node->GetOpDesc()->GetOutputDesc(0).GetFormat();
  670. auto variable_node_data_type = variable_node->GetOpDesc()->GetOutputDesc(0).GetDataType();
  671. auto variable_node_shape = variable_node->GetOpDesc()->GetOutputDesc(0).GetShape().GetDims();
  672. if (variable_node_format != FORMAT_NC1HWC0 || variable_node_data_type != DT_FLOAT ||
  673. variable_node_shape.size() != 5) {
  674. std::cout << "var format not changed !" << std::endl;
  675. return false;
  676. }
  677. const auto &variable_ref_node = compute_graph->FindNode(var_ref_name_0);
  678. GELOGD("var_ref_name_0 is %s", var_ref_name_0.c_str());
  679. auto variable_ref_node_format = variable_ref_node->GetOpDesc()->GetInputDesc(0).GetFormat();
  680. auto variable_ref_node_data_type = variable_ref_node->GetOpDesc()->GetInputDesc(0).GetDataType();
  681. auto variable_ref_node_shape = variable_ref_node->GetOpDesc()->GetInputDesc(0).GetShape().GetDims();
  682. if (variable_ref_node_format != FORMAT_NC1HWC0 || variable_ref_node_data_type != DT_FLOAT ||
  683. variable_ref_node_shape.size() != 5) {
  684. GELOGI("wanted data format is (%d,%d,%u)", FORMAT_NC1HWC0, DT_FLOAT, 5);
  685. GELOGI("variable_ref_node_format is (%d,%d,%u)", variable_ref_node_format, variable_ref_node_data_type,
  686. variable_ref_node_shape.size());
  687. std::cout << "var ref format not changed !" << std::endl;
  688. return false;
  689. }
  690. ge::NodePtr trans_node = compute_graph->FindNode("4d_to_5d_1");
  691. if (trans_node != nullptr) {
  692. std::cout << "4d_to_5d_1 not empty !" << std::endl;
  693. return false;
  694. }
  695. trans_node = compute_graph->FindNode("4d_to_5d_2");
  696. if (trans_node != nullptr) {
  697. std::cout << "4d_to_5d_2 not empty !" << std::endl;
  698. return false;
  699. }
  700. trans_node = compute_graph->FindNode("5d_to_4d_1");
  701. if (trans_node != nullptr) {
  702. std::cout << "5d_to_4d_1 not empty !" << std::endl;
  703. return false;
  704. }
  705. trans_node = compute_graph->FindNode("4d_to_5d_1_new");
  706. if (trans_node == nullptr) {
  707. std::cout << "4d_to_5d_1_new is empty !" << std::endl;
  708. return false;
  709. }
  710. auto new_variable_node = compute_graph->FindNode("Node4D_new");
  711. auto new_variable_node_format = new_variable_node->GetOpDesc()->GetOutputDesc(0).GetFormat();
  712. auto new_variable_node_data_type = new_variable_node->GetOpDesc()->GetOutputDesc(0).GetDataType();
  713. auto new_variable_node_shape = new_variable_node->GetOpDesc()->GetOutputDesc(0).GetShape().GetDims();
  714. if (new_variable_node_format != FORMAT_NCHW || new_variable_node_data_type != DT_INT32 ||
  715. new_variable_node_shape.size() != 4) {
  716. std::cout << "Node4D_new format Changed ! wanted data format is ( " << FORMAT_NC1HWC0 << ", " << DT_INT32
  717. << ", 4) " << std::endl;
  718. std::cout << "current is ( " << new_variable_node_format << ", " << new_variable_node_data_type << ", "
  719. << new_variable_node_shape.size() << ")" << std::endl;
  720. return false;
  721. }
  722. return true;
  723. };
  724. bool CheckTest1(const ge::ComputeGraphPtr compute_graph) {
  725. const auto &variable_node = compute_graph->FindNode("Node4D");
  726. auto variable_node_format = variable_node->GetOpDesc()->GetOutputDesc(0).GetFormat();
  727. auto variable_node_data_type = variable_node->GetOpDesc()->GetOutputDesc(0).GetDataType();
  728. auto variable_node_shape = variable_node->GetOpDesc()->GetOutputDesc(0).GetShape().GetDims();
  729. if (variable_node_format != FORMAT_NCHW || variable_node_data_type != DT_INT32 || variable_node_shape.size() != 4) {
  730. std::cout << "var format changed !" << std::endl;
  731. return false;
  732. }
  733. const auto &variable_ref_node = compute_graph->FindNode(var_ref_name_0);
  734. GELOGD("var_ref_name_0 is %s", var_ref_name_0.c_str());
  735. auto variable_ref_node_format = variable_ref_node->GetOpDesc()->GetInputDesc(0).GetFormat();
  736. auto variable_ref_node_data_type = variable_ref_node->GetOpDesc()->GetInputDesc(0).GetDataType();
  737. auto variable_ref_node_shape = variable_ref_node->GetOpDesc()->GetInputDesc(0).GetShape().GetDims();
  738. if (variable_ref_node_format != FORMAT_NCHW || variable_ref_node_data_type != DT_INT32 ||
  739. variable_ref_node_shape.size() != 4) {
  740. GELOGI("wanted data format is (%d,%d,%u)", FORMAT_NCHW, DT_INT32, 4);
  741. GELOGI("variable_ref_node_format is (%d,%d,%u)", variable_ref_node_format, variable_ref_node_data_type,
  742. variable_ref_node_shape.size());
  743. std::cout << "var ref format not changed !" << std::endl;
  744. return false;
  745. }
  746. ge::NodePtr trans_node = compute_graph->FindNode("4d_to_5d_1");
  747. if (trans_node == nullptr) {
  748. std::cout << "4d_to_5d_1 empty !" << std::endl;
  749. return false;
  750. }
  751. trans_node = compute_graph->FindNode("4d_to_5d_2");
  752. if (trans_node == nullptr) {
  753. std::cout << "4d_to_5d_2 empty !" << std::endl;
  754. return false;
  755. }
  756. trans_node = compute_graph->FindNode("5d_to_4d_1");
  757. if (trans_node == nullptr) {
  758. std::cout << "5d_to_4d_1 not empty !" << std::endl;
  759. return false;
  760. }
  761. return true;
  762. };
  763. bool CheckTest6(const ge::ComputeGraphPtr compute_graph) {
  764. const auto &variable_node = compute_graph->FindNode("Node4D");
  765. auto variable_node_format = variable_node->GetOpDesc()->GetOutputDesc(0).GetFormat();
  766. auto variable_node_data_type = variable_node->GetOpDesc()->GetOutputDesc(0).GetDataType();
  767. auto variable_node_shape = variable_node->GetOpDesc()->GetOutputDesc(0).GetShape().GetDims();
  768. if (variable_node_format != FORMAT_NC1HWC0 || variable_node_data_type != DT_INT32 ||
  769. variable_node_shape.size() != 5) {
  770. std::cout << "var format not changed !" << std::endl;
  771. return false;
  772. }
  773. ge::NodePtr trans_node = compute_graph->FindNode("4d_to_5d_1");
  774. if (trans_node != nullptr) {
  775. std::cout << "4d_to_5d_1 not empty !" << std::endl;
  776. return false;
  777. }
  778. trans_node = compute_graph->FindNode("4d_to_5d_2");
  779. if (trans_node != nullptr) {
  780. std::cout << "4d_to_5d_2 not empty !" << std::endl;
  781. return false;
  782. }
  783. trans_node = compute_graph->FindNode("float_to_int_1");
  784. if (trans_node != nullptr) {
  785. std::cout << "float_to_int_1 not empty !" << std::endl;
  786. return false;
  787. }
  788. trans_node = compute_graph->FindNode("float_to_int_2");
  789. if (trans_node != nullptr) {
  790. std::cout << "float_to_int_1 not empty !" << std::endl;
  791. return false;
  792. }
  793. return true;
  794. };
  795. bool CheckTest7(const ge::ComputeGraphPtr compute_graph) {
  796. const auto &variable_node = compute_graph->FindNode("Node4D");
  797. auto variable_node_format = variable_node->GetOpDesc()->GetOutputDesc(0).GetFormat();
  798. auto variable_node_data_type = variable_node->GetOpDesc()->GetOutputDesc(0).GetDataType();
  799. auto variable_node_shape = variable_node->GetOpDesc()->GetOutputDesc(0).GetShape().GetDims();
  800. if (variable_node_format != FORMAT_NC1HWC0 || variable_node_data_type != DT_INT32 ||
  801. variable_node_shape.size() != 5) {
  802. std::cout << "var format not changed !" << std::endl;
  803. return false;
  804. }
  805. ge::NodePtr trans_node = compute_graph->FindNode("4d_to_4d_1");
  806. if (trans_node != nullptr) {
  807. std::cout << "4d_to_5d_1 not empty !" << std::endl;
  808. return false;
  809. }
  810. return true;
  811. };
  812. bool CheckTest8(const ge::ComputeGraphPtr compute_graph) {
  813. const auto &variable_node = compute_graph->FindNode("Node4D");
  814. auto variable_node_format = variable_node->GetOpDesc()->GetOutputDesc(0).GetFormat();
  815. auto variable_node_data_type = variable_node->GetOpDesc()->GetOutputDesc(0).GetDataType();
  816. auto variable_node_shape = variable_node->GetOpDesc()->GetOutputDesc(0).GetShape().GetDims();
  817. return true;
  818. };
  819. };
  820. TEST_F(VariableOpPassUnittest, testTransDataRemove) {
  821. VariableOpPassSimulator varibale_op_pass_simulator;
  822. bool result = varibale_op_pass_simulator.DoTest0();
  823. EXPECT_EQ(result, true);
  824. }
  825. TEST_F(VariableOpPassUnittest, testVariableRef) {
  826. VariableOpPassSimulator varibale_op_pass_simulator;
  827. bool result = varibale_op_pass_simulator.DoTest1();
  828. EXPECT_EQ(result, true);
  829. }
  830. TEST_F(VariableOpPassUnittest, testNullGraph) {
  831. VariableOpPassSimulator varibale_op_pass_simulator;
  832. bool result = varibale_op_pass_simulator.DoTest2();
  833. EXPECT_EQ(result, true);
  834. }
  835. TEST_F(VariableOpPassUnittest, testCovarageTransVarData) {
  836. VariableOpPassSimulator varibale_op_pass_simulator;
  837. bool result = varibale_op_pass_simulator.DoTest3();
  838. EXPECT_EQ(result, false);
  839. }
  840. TEST_F(VariableOpPassUnittest, testIllegallyRef) {
  841. VariableOpPassSimulator varibale_op_pass_simulator;
  842. bool result = varibale_op_pass_simulator.DoTest4();
  843. EXPECT_EQ(result, true);
  844. }
  845. TEST_F(VariableOpPassUnittest, testSingleNode) {
  846. VariableOpPassSimulator varibale_op_pass_simulator;
  847. bool result = varibale_op_pass_simulator.DoTest5();
  848. EXPECT_EQ(result, true);
  849. }
  850. TEST_F(VariableOpPassUnittest, testUnMathed) {
  851. VariableOpPassSimulator varibale_op_pass_simulator;
  852. bool result = varibale_op_pass_simulator.DoTest6();
  853. EXPECT_EQ(result, true);
  854. }
  855. TEST_F(VariableOpPassUnittest, testSameOp) {
  856. VariableOpPassSimulator varibale_op_pass_simulator;
  857. bool result = varibale_op_pass_simulator.DoTest7();
  858. EXPECT_EQ(true, true);
  859. }
  860. TEST_F(VariableOpPassUnittest, testErrorReturn) {
  861. VariableOpPassSimulator varibale_op_pass_simulator;
  862. bool result = varibale_op_pass_simulator.DoTest8();
  863. EXPECT_EQ(true, true);
  864. }
  865. TEST_F(VariableOpPassUnittest, Reshape) {
  866. // init
  867. MemManager::Instance().Initialize(std::vector<rtMemType_t>({RT_MEMORY_HBM}));
  868. VarManager::Instance(0)->Init(0, 0, 0, 0);
  869. auto graph = BuildGraph2();
  870. graph->SetSessionID(0);
  871. auto var1 = graph->FindNode("var1");
  872. VarManager::Instance(0)->AssignVarMem(var1->GetName(), var1->GetOpDesc()->GetOutputDesc(0), RT_MEMORY_HBM);
  873. uint8_t *dev_ptr = nullptr;
  874. VarManager::Instance(0)->SetVarAddr(var1->GetName(), var1->GetOpDesc()->GetOutputDesc(0), dev_ptr, RT_MEMORY_HBM);
  875. ge::GraphNodePtr graph_node = make_shared<GraphNode>(0);
  876. graph->InferShapeInNeed();
  877. graph_node->SetComputeGraph(graph);
  878. auto tmp_graph = GraphUtils::CreateGraphFromComputeGraph(graph);
  879. auto tmp_graph_ptr = std::make_shared<Graph>(tmp_graph);
  880. graph_node->SetGraph(tmp_graph_ptr);
  881. VarAccelerateCtrl ctrl;
  882. ctrl.AddGraph(graph_node->GetGraphId(), graph);
  883. VariableOpPass pass(&ctrl);
  884. EXPECT_EQ(pass.Run(graph), ge::SUCCESS);
  885. MemManager::Instance().Finalize();
  886. EXPECT_EQ(var1->GetOutNodes().size(), 1);
  887. EXPECT_EQ(var1->GetOutDataNodes().at(0)->GetName(), "conv1");
  888. EXPECT_EQ(var1->GetOpDesc()->GetOutputDesc(0).GetFormat(), FORMAT_HWCN);
  889. EXPECT_EQ(var1->GetOpDesc()->GetOutputDesc(0).GetShape().GetDims(), std::vector<int64_t>({8, 8, 3, 2}));
  890. }
  891. TEST_F(VariableOpPassUnittest, ReFormat) {
  892. // init
  893. MemManager::Instance().Initialize(std::vector<rtMemType_t>({RT_MEMORY_HBM}));
  894. VarManager::Instance(0)->Init(0, 0, 0, 0);
  895. auto graph = BuildGraph3();
  896. graph->SetSessionID(0);
  897. auto var1 = graph->FindNode("var1");
  898. VarManager::Instance(0)->AssignVarMem(var1->GetName(), var1->GetOpDesc()->GetOutputDesc(0), RT_MEMORY_HBM);
  899. uint8_t *dev_ptr = nullptr;
  900. VarManager::Instance(0)->SetVarAddr(var1->GetName(), var1->GetOpDesc()->GetOutputDesc(0), dev_ptr, RT_MEMORY_HBM);
  901. ge::GraphNodePtr graph_node = make_shared<GraphNode>(0);
  902. graph->InferShapeInNeed();
  903. graph_node->SetComputeGraph(graph);
  904. auto tmp_graph = GraphUtils::CreateGraphFromComputeGraph(graph);
  905. auto tmp_graph_ptr = std::make_shared<Graph>(tmp_graph);
  906. graph_node->SetGraph(tmp_graph_ptr);
  907. VarAccelerateCtrl ctrl;
  908. ctrl.AddGraph(graph_node->GetGraphId(), graph);
  909. VariableOpPass pass(&ctrl);
  910. EXPECT_EQ(pass.Run(graph), ge::SUCCESS);
  911. MemManager::Instance().Finalize();
  912. EXPECT_EQ(var1->GetOutNodes().size(), 1);
  913. EXPECT_EQ(var1->GetOutDataNodes().at(0)->GetName(), "conv1");
  914. EXPECT_EQ(var1->GetOpDesc()->GetOutputDesc(0).GetFormat(), FORMAT_ND);
  915. EXPECT_EQ(var1->GetOpDesc()->GetOutputDesc(0).GetShape().GetDims(), std::vector<int64_t>({8, 8, 3, 2}));
  916. }
  917. TEST_F(VariableOpPassUnittest, InvalidSrcShape2) {
  918. formats::FormatTransferNchwNc1hwc0 t1;
  919. formats::FormatTransferNhwcNc1hwc0 t2;
  920. formats::TransArgs args = formats::TransArgs();
  921. formats::TransResult ret;
  922. t2.TransFormat(args, ret);
  923. }

图引擎模块(GE)是MindSpore的一个子模块,其代码由C++实现,位于前端模块ME和底层硬件之间,起到承接作用。图引擎模块以ME下发的图作为输入,然后进行一系列的深度图优化操作,最后输出一张可以在底层硬件上高效运行的图。GE针对昇腾AI处理器的硬件结构特点,做了特定的优化工作,以此来充分发挥出昇腾AI处理器的强大算力。在进行模型训练/推理时,GE会被自动调用而用户并不感知。GE主要由GE API和GE Core两部分组成,详细的架构图如下所示