model_store_pass.cc 2.5 KB
Newer Older
Y
Yan Chunwei 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
// 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 <stdio.h>
#include <stdlib.h>
G
gongweibao 已提交
17 18
#include <string>

Y
Yan Chunwei 已提交
19 20
#include "paddle/fluid/inference/analysis/analyzer.h"
#include "paddle/fluid/inference/analysis/argument.h"
G
gongweibao 已提交
21
#include "paddle/fluid/inference/analysis/model_store_pass.h"
Y
Yan Chunwei 已提交
22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37

namespace paddle {
namespace inference {
namespace analysis {

void ModelStorePass::Run(DataFlowGraph *x) {
  if (!argument_->fluid_model_param_path) {
    PADDLE_ENFORCE_NOT_NULL(argument_->fluid_model_dir);
    argument_->fluid_model_param_path.reset(
        new std::string(*argument_->fluid_model_dir + "param"));
  }
  PADDLE_ENFORCE_NOT_NULL(argument_->model_output_store_path);
  // Directly copy param file to destination.
  std::stringstream ss;
  // NOTE these commands only works on linux.
  ss << "mkdir -p " << *argument_->model_output_store_path;
38
  VLOG(3) << "run command: " << ss.str();
Y
Yan Chunwei 已提交
39 40 41 42 43
  PADDLE_ENFORCE_EQ(system(ss.str().c_str()), 0);
  ss.str("");

  ss << "cp " << *argument_->fluid_model_dir << "/*"
     << " " << *argument_->model_output_store_path;
44
  VLOG(3) << "run command: " << ss.str();
Y
Yan Chunwei 已提交
45 46 47 48 49 50
  PADDLE_ENFORCE_EQ(system(ss.str().c_str()), 0);

  // Store program
  PADDLE_ENFORCE_NOT_NULL(argument_->transformed_program_desc,
                          "program desc is not transformed, should call "
                          "DataFlowGraphToFluidPass first.");
51 52
  VLOG(3) << "store analyzed program to "
          << *argument_->model_output_store_path;
Y
Yan Chunwei 已提交
53 54 55 56 57 58 59 60 61 62
  const std::string program_output_path =
      *argument_->model_output_store_path + "/__model__";
  std::ofstream file(program_output_path, std::ios::binary);
  PADDLE_ENFORCE(file.is_open(), "failed to open %s to write.",
                 program_output_path);
  const std::string serialized_message =
      argument_->transformed_program_desc->SerializeAsString();
  file.write(serialized_message.c_str(), serialized_message.size());
}

63 64
bool ModelStorePass::Finalize() { return true; }

Y
Yan Chunwei 已提交
65 66 67
}  // namespace analysis
}  // namespace inference
}  // namespace paddle