|
|
|
@ -14,8 +14,99 @@ limitations under the License. */
|
|
|
|
|
|
|
|
|
|
#include "paddle/fluid/framework/ir/graph_to_program_pass.h"
|
|
|
|
|
|
|
|
|
|
#include <string>
|
|
|
|
|
#include <vector>
|
|
|
|
|
#include "gtest/gtest.h"
|
|
|
|
|
#include "paddle/fluid/framework/program_desc.h"
|
|
|
|
|
|
|
|
|
|
namespace paddle {
|
|
|
|
|
namespace framework {
|
|
|
|
|
namespace ir {} // namespace ir
|
|
|
|
|
namespace ir {
|
|
|
|
|
|
|
|
|
|
void BuildNoCircleGraph(Graph* g) {
|
|
|
|
|
OpDesc op1;
|
|
|
|
|
op1.SetType("op1");
|
|
|
|
|
OpDesc op2;
|
|
|
|
|
op2.SetType("op2");
|
|
|
|
|
OpDesc op3;
|
|
|
|
|
op3.SetType("op3");
|
|
|
|
|
OpDesc op4;
|
|
|
|
|
op4.SetType("op4");
|
|
|
|
|
OpDesc op5;
|
|
|
|
|
op5.SetType("op5");
|
|
|
|
|
VarDesc var1("var1");
|
|
|
|
|
VarDesc var2("var2");
|
|
|
|
|
VarDesc var3("var3");
|
|
|
|
|
VarDesc var4("var4");
|
|
|
|
|
|
|
|
|
|
ir::Node* o1 = g->CreateOpNode(&op1);
|
|
|
|
|
ir::Node* o2 = g->CreateOpNode(&op2);
|
|
|
|
|
ir::Node* o3 = g->CreateOpNode(&op3);
|
|
|
|
|
ir::Node* o4 = g->CreateOpNode(&op4);
|
|
|
|
|
ir::Node* o5 = g->CreateOpNode(&op5);
|
|
|
|
|
ir::Node* v1 = g->CreateVarNode(&var1);
|
|
|
|
|
ir::Node* v2 = g->CreateVarNode(&var2);
|
|
|
|
|
ir::Node* v3 = g->CreateVarNode(&var3);
|
|
|
|
|
ir::Node* v4 = g->CreateVarNode(&var4);
|
|
|
|
|
|
|
|
|
|
// o1->v1->o2
|
|
|
|
|
o1->outputs.push_back(v1);
|
|
|
|
|
o2->inputs.push_back(v1);
|
|
|
|
|
v1->inputs.push_back(o1);
|
|
|
|
|
v1->outputs.push_back(o2);
|
|
|
|
|
// o2->v2->o3
|
|
|
|
|
// o2->v2->o4
|
|
|
|
|
o2->outputs.push_back(v2);
|
|
|
|
|
o3->inputs.push_back(v2);
|
|
|
|
|
o4->inputs.push_back(v2);
|
|
|
|
|
v2->outputs.push_back(o3);
|
|
|
|
|
v2->outputs.push_back(o4);
|
|
|
|
|
v2->inputs.push_back(o2);
|
|
|
|
|
// o2->v3->o5
|
|
|
|
|
o2->outputs.push_back(v3);
|
|
|
|
|
o5->inputs.push_back(v3);
|
|
|
|
|
v3->inputs.push_back(o2);
|
|
|
|
|
v3->outputs.push_back(o5);
|
|
|
|
|
// o3-v4->o5
|
|
|
|
|
o3->outputs.push_back(v4);
|
|
|
|
|
o5->inputs.push_back(v4);
|
|
|
|
|
v4->inputs.push_back(o3);
|
|
|
|
|
v4->outputs.push_back(o5);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
TEST(GraphToProgramPass, Basic) {
|
|
|
|
|
ProgramDesc prog;
|
|
|
|
|
std::unique_ptr<Graph> g(new Graph(prog));
|
|
|
|
|
BuildNoCircleGraph(g.get());
|
|
|
|
|
|
|
|
|
|
auto pass = paddle::framework::ir::PassRegistry::Instance().Get(
|
|
|
|
|
"graph_to_program_pass");
|
|
|
|
|
|
|
|
|
|
ProgramDesc compiled_prog;
|
|
|
|
|
pass->SetNotOwned<paddle::framework::ProgramDesc>("program", &compiled_prog);
|
|
|
|
|
pass->Apply(std::move(g));
|
|
|
|
|
std::vector<OpDesc*> ops = compiled_prog.Block(0).AllOps();
|
|
|
|
|
compiled_prog.Flush();
|
|
|
|
|
LOG(ERROR) << compiled_prog.Proto()->DebugString();
|
|
|
|
|
EXPECT_EQ(ops[0]->Type(), "op1");
|
|
|
|
|
EXPECT_EQ(ops[1]->Type(), "op2");
|
|
|
|
|
if (ops[2]->Type() == "op3") {
|
|
|
|
|
EXPECT_EQ(ops[3]->Type(), "op4");
|
|
|
|
|
} else if (ops[2]->Type() == "op4") {
|
|
|
|
|
EXPECT_EQ(ops[3]->Type(), "op3");
|
|
|
|
|
}
|
|
|
|
|
EXPECT_EQ(ops[4]->Type(), "op5");
|
|
|
|
|
|
|
|
|
|
std::unordered_set<std::string> vars;
|
|
|
|
|
for (VarDesc* v : compiled_prog.Block(0).AllVars()) {
|
|
|
|
|
vars.insert(v->Name());
|
|
|
|
|
}
|
|
|
|
|
EXPECT_TRUE(vars.find("var1") != vars.end());
|
|
|
|
|
EXPECT_TRUE(vars.find("var2") != vars.end());
|
|
|
|
|
EXPECT_TRUE(vars.find("var3") != vars.end());
|
|
|
|
|
}
|
|
|
|
|
} // namespace ir
|
|
|
|
|
} // namespace framework
|
|
|
|
|
} // namespace paddle
|
|
|
|
|
|
|
|
|
|
USE_PASS(graph_to_program_pass);
|
|
|
|
|