graph.cc 2.3 KB
Newer Older
X
Xin Pan 已提交
1
/* Copyright (c) 2018 PaddlePaddle Authors. All Rights Reserved.
X
start  
Xin Pan 已提交
2 3 4 5 6 7 8 9 10 11 12 13 14 15

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 "paddle/fluid/framework/ir/graph.h"
16 17
#include "paddle/fluid/framework/program_desc.h"
#include "paddle/fluid/framework/var_desc.h"
X
start  
Xin Pan 已提交
18 19

namespace paddle {
X
Xin Pan 已提交
20 21
namespace framework {

X
Xin Pan 已提交
22
// NOTE(paddle-dev): This graph contains circle.
X
clean  
Xin Pan 已提交
23
Graph::Graph(const ProgramDesc &program) : program_(program) {
24 25 26 27 28
  std::unordered_map<std::string, VarDesc *> all_vars;
  for (auto *var : program.Block(0).AllVars()) {
    all_vars.emplace(var->Name(), var);
  }

X
Xin Pan 已提交
29
  std::map<std::string, ir::Node *> var_nodes;
30
  for (auto *op : program.Block(0).AllOps()) {
X
clean  
Xin Pan 已提交
31
    ir::Node *node = CreateOpNode(op);
32 33 34

    for (auto &each_var_name : op->InputArgumentNames()) {
      ir::Node *var = nullptr;
X
Xin Pan 已提交
35 36 37
      if (var_nodes.find(each_var_name) != var_nodes.end()) {
        var = var_nodes.at(each_var_name);
      } else if (all_vars.count(each_var_name) != 0) {
X
clean  
Xin Pan 已提交
38
        var = CreateVarNode(all_vars.at(each_var_name));
X
Xin Pan 已提交
39
        var_nodes[each_var_name] = var;
40
      } else {
X
clean  
Xin Pan 已提交
41 42 43
        // TODO(paddle-dev): Seems some assumption doesn't hold?
        LOG(ERROR) << op->Type()
                   << " input var not in all_var list: " << each_var_name;
X
polish  
Xin Pan 已提交
44
        var = CreateEmptyNode(each_var_name, ir::Node::Type::kVariable);
X
Xin Pan 已提交
45
        var_nodes[each_var_name] = var;
46 47 48 49 50 51
      }
      node->inputs.push_back(var);
      var->outputs.push_back(node);
    }

    for (auto &each_var_name : op->OutputArgumentNames()) {
X
Xin Pan 已提交
52 53 54 55 56 57 58
      ir::Node *var = nullptr;
      if (var_nodes.find(each_var_name) != var_nodes.end()) {
        var = var_nodes.at(each_var_name);
      } else {
        var = CreateVarNode(all_vars.at(each_var_name));
        var_nodes[each_var_name] = var;
      }
59 60 61 62
      node->outputs.push_back(var);
      var->inputs.push_back(node);
    }
  }
X
Xin Pan 已提交
63 64
}
}  // namespace framework
X
start  
Xin Pan 已提交
65
}  // namespace paddle