analyzer.cc 4.0 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
// Copyright (c) 2018 PaddlePaddle Authors. All Rights Reserved.
//
// 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/inference/analysis/analyzer.h"
G
gongweibao 已提交
16
#include <string>
17 18 19
#include "paddle/fluid/inference/analysis/data_flow_graph_to_fluid_pass.h"
#include "paddle/fluid/inference/analysis/dfg_graphviz_draw_pass.h"
#include "paddle/fluid/inference/analysis/fluid_to_data_flow_graph_pass.h"
20
#include "paddle/fluid/inference/analysis/fluid_to_ir_pass.h"
Y
Yan Chunwei 已提交
21
#include "paddle/fluid/inference/analysis/model_store_pass.h"
22 23 24 25
#include "paddle/fluid/inference/analysis/pass_manager.h"
#include "paddle/fluid/inference/analysis/tensorrt_subgraph_node_mark_pass.h"
#include "paddle/fluid/inference/analysis/tensorrt_subgraph_pass.h"

26
DEFINE_bool(IA_enable_tensorrt_subgraph_engine, false,
27 28
            "Enable subgraph to TensorRT engine for acceleration");

29 30 31
DEFINE_bool(IA_enable_ir, false, "Turn on IR support");

DEFINE_string(IA_graphviz_log_root, "./",
32 33
              "Graphviz debuger for data flow graphs.");

34
DEFINE_string(IA_output_storage_path, "", "optimized model output path");
Y
Yan Chunwei 已提交
35

36
namespace paddle {
37 38 39
namespace inference {
namespace analysis {

40 41 42 43
class DfgPassManagerImpl final : public DfgPassManager {
 public:
  DfgPassManagerImpl() {
    // TODO(Superjomn) set the key with pass reprs.
44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71
    LOG(INFO)
        << "-----------------------------------------------------------------";
    if (FLAGS_IA_enable_ir) {
      AddPass("fluid-to-ir-pass", new FluidToIrPass);
    } else {
      AddPass("fluid-to-data-flow-graph", new FluidToDataFlowGraphPass);
    }
    TryAddTensorRtPass();
    AddPass("data-flow-graph-to-fluid", new DataFlowGraphToFluidPass);
    if (!FLAGS_IA_output_storage_path.empty()) {
      AddPass("model-store-pass", new ModelStorePass);
    }
    LOG(INFO)
        << "-----------------------------------------------------------------";
  }

  std::string repr() const override { return "dfg-pass-manager"; }
  std::string description() const override { return "DFG pass manager."; }

 private:
  void AddPass(const std::string& name, Pass* pass) {
    VLOG(3) << "Adding pass " << name;
    Register(name, pass);
    AddGraphvizDebugerPass(pass);
  }

  void TryAddTensorRtPass() {
    if (FLAGS_IA_enable_tensorrt_subgraph_engine) {
72 73
      auto trt_teller = [&](const Node* node) {
        std::unordered_set<std::string> teller_set(
74
            {"elementwise_add", "mul", "conv2d", "pool2d", "relu", "softmax",
N
nhzlx 已提交
75
             "depthwise_conv2d", "batch_norm", "concat"});
76
        if (!node->IsFunction()) return false;
77 78

        const auto* func = static_cast<const Function*>(node);
W
Wu Yi 已提交
79
        if (teller_set.count(func->func_type())) {
80
          return true;
W
Wu Yi 已提交
81
        } else {
82 83
          return false;
        }
84
      };
85

86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113
      AddPass("tensorrt-subgraph-marker",
              new TensorRTSubgraphNodeMarkPass(trt_teller));
      AddPass("tensorrt-subgraph", new TensorRTSubGraphPass(trt_teller));
    }
  }

  // Add the graphviz debuger pass if the parent pass has one.
  void AddGraphvizDebugerPass(Pass* pass) {
    auto* debuger_pass = pass->CreateGraphvizDebugerPass();
    if (debuger_pass) {
      LOG(INFO) << " - register debug pass [" << debuger_pass->repr() << "]";
      Register(debuger_pass->repr(), debuger_pass);
    }
  }
};

Analyzer::Analyzer() { Register("manager1", new DfgPassManagerImpl); }

void Analyzer::Run(Argument* argument) {
  for (auto& x : data_) {
    PADDLE_ENFORCE(x->Initialize(argument));
    x->RunAll();
    PADDLE_ENFORCE(x->Finalize());
  }
}

}  // namespace analysis
}  // namespace inference
G
gongweibao 已提交
114
}  // namespace paddle