infer.h 31.2 KB
Newer Older
W
wangguibao 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
// Copyright (c) 2019 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.

#pragma once
W
wangguibao 已提交
16
#include <sys/stat.h>
W
wangguibao 已提交
17
#include <sys/types.h>
W
wangguibao 已提交
18
#include <unistd.h>
W
wangguibao 已提交
19
#include <string>
M
MRXLT 已提交
20
#include <utility>
W
wangguibao 已提交
21
#include <vector>
G
guru4elephant 已提交
22 23 24
#include "core/predictor/common/inner_common.h"
#include "core/predictor/framework/factory.h"
#include "core/predictor/framework/infer_data.h"
W
wangjiawei04 已提交
25
#include "paddle_inference_api.h"  // NOLINT
W
wangguibao 已提交
26 27 28 29
namespace baidu {
namespace paddle_serving {
namespace predictor {

W
wangguibao 已提交
30 31
using configure::ModelToolkitConf;

32 33 34 35 36
class InferEngineCreationParams {
 public:
  InferEngineCreationParams() {
    _path = "";
    _enable_memory_optimization = false;
M
MRXLT 已提交
37
    _enable_ir_optimization = false;
38 39
    _static_optimization = false;
    _force_update_static_cache = false;
M
MRXLT 已提交
40
    _use_trt = false;
Z
zhangjun 已提交
41 42 43
    _use_lite = false;
    _use_xpu = false;
  }
44 45 46 47 48 49 50

  void set_path(const std::string& path) { _path = path; }

  void set_enable_memory_optimization(bool enable_memory_optimization) {
    _enable_memory_optimization = enable_memory_optimization;
  }

M
MRXLT 已提交
51 52 53 54
  void set_enable_ir_optimization(bool enable_ir_optimization) {
    _enable_ir_optimization = enable_ir_optimization;
  }

M
MRXLT 已提交
55 56
  void set_use_trt(bool use_trt) { _use_trt = use_trt; }

Z
zhangjun 已提交
57 58 59 60
  void set_use_lite(bool use_lite) { _use_lite = use_lite; }

  void set_use_xpu(bool use_xpu) { _use_xpu = use_xpu; }

61 62 63 64
  bool enable_memory_optimization() const {
    return _enable_memory_optimization;
  }

M
MRXLT 已提交
65 66
  bool enable_ir_optimization() const { return _enable_ir_optimization; }

M
MRXLT 已提交
67 68
  bool use_trt() const { return _use_trt; }

Z
zhangjun 已提交
69 70 71 72
  bool use_lite() const { return _use_lite; }

  bool use_xpu() const { return _use_xpu; }

73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91
  void set_static_optimization(bool static_optimization = false) {
    _static_optimization = static_optimization;
  }

  void set_force_update_static_cache(bool force_update_static_cache = false) {
    _force_update_static_cache = force_update_static_cache;
  }

  bool static_optimization() const { return _static_optimization; }

  bool force_update_static_cache() const { return _force_update_static_cache; }

  std::string get_path() const { return _path; }

  void dump() const {
    LOG(INFO) << "InferEngineCreationParams: "
              << "model_path = " << _path << ", "
              << "enable_memory_optimization = " << _enable_memory_optimization
              << ", "
Z
zhangjun 已提交
92 93 94
              << "enable_tensorrt = " << _use_trt << ", "
              << "enable_lite = " << _use_lite << ", "
              << "enable_xpu = " << _use_xpu << ", "
M
MRXLT 已提交
95
              << "enable_ir_optimization = " << _enable_ir_optimization << ", "
96 97 98 99 100 101 102
              << "static_optimization = " << _static_optimization << ", "
              << "force_update_static_cache = " << _force_update_static_cache;
  }

 private:
  std::string _path;
  bool _enable_memory_optimization;
M
MRXLT 已提交
103
  bool _enable_ir_optimization;
104 105
  bool _static_optimization;
  bool _force_update_static_cache;
M
MRXLT 已提交
106
  bool _use_trt;
Z
zhangjun 已提交
107 108
  bool _use_lite;
  bool _use_xpu;
109 110
};

W
wangguibao 已提交
111
class InferEngine {
W
wangguibao 已提交
112 113 114 115 116 117 118 119 120 121
 public:
  virtual ~InferEngine() {}

  virtual int proc_initialize(const configure::EngineDesc& conf, bool version) {
    return proc_initialize_impl(conf, version);
  }
  virtual int proc_finalize() { return proc_finalize_impl(); }
  virtual int thrd_initialize() { return thrd_initialize_impl(); }
  virtual int thrd_clear() { return thrd_clear_impl(); }
  virtual int thrd_finalize() { return thrd_finalize_impl(); }
W
wangjiawei04 已提交
122
  virtual int infer() { return infer_impl(); }
W
wangguibao 已提交
123 124 125 126 127 128 129 130 131 132 133 134

  virtual int reload() = 0;

  virtual uint64_t version() const = 0;

  // begin: framework inner call
  virtual int proc_initialize_impl(const configure::EngineDesc& conf,
                                   bool version) = 0;
  virtual int thrd_initialize_impl() = 0;
  virtual int thrd_finalize_impl() = 0;
  virtual int thrd_clear_impl() = 0;
  virtual int proc_finalize_impl() = 0;
W
wangjiawei04 已提交
135 136
  virtual std::vector<std::string> GetInputNames() = 0;
  virtual std::vector<std::string> GetOutputNames() = 0;
W
wangjiawei04 已提交
137 138 139 140
  virtual std::unique_ptr<paddle_infer::Tensor> GetInputHandle(
      const std::string& name) = 0;
  virtual std::unique_ptr<paddle_infer::Tensor> GetOutputHandle(
      const std::string& name) = 0;
W
wangjiawei04 已提交
141
  virtual int infer_impl() = 0;
W
wangguibao 已提交
142 143 144 145 146 147
  // end: framework inner call
};

class ReloadableInferEngine : public InferEngine {
 public:
  virtual ~ReloadableInferEngine() {}
W
wangguibao 已提交
148

W
wangguibao 已提交
149 150 151 152 153
  union last_check_status {
    time_t last_timestamp;
    uint64_t last_md5sum;
    uint64_t last_revision;
  };
W
wangguibao 已提交
154

155
  virtual int load(const InferEngineCreationParams& params) = 0;
W
wangguibao 已提交
156 157 158 159 160 161 162 163

  int proc_initialize_impl(const configure::EngineDesc& conf, bool version) {
    _reload_tag_file = conf.reloadable_meta();
    _reload_mode_tag = conf.reloadable_type();
    _model_data_path = conf.model_data_path();
    _infer_thread_num = conf.runtime_thread_num();
    _infer_batch_size = conf.batch_infer_size();
    _infer_batch_align = conf.enable_batch_align();
164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179

    bool enable_memory_optimization = false;
    if (conf.has_enable_memory_optimization()) {
      enable_memory_optimization = conf.enable_memory_optimization();
    }

    bool static_optimization = false;
    if (conf.has_static_optimization()) {
      static_optimization = conf.static_optimization();
    }

    bool force_update_static_cache = false;
    if (conf.has_force_update_static_cache()) {
      force_update_static_cache = conf.force_update_static_cache();
    }

M
MRXLT 已提交
180 181 182 183 184
    if (conf.has_enable_ir_optimization()) {
      _infer_engine_params.set_enable_ir_optimization(
          conf.enable_ir_optimization());
    }

185 186 187 188 189 190 191 192
    _infer_engine_params.set_path(_model_data_path);
    if (enable_memory_optimization) {
      _infer_engine_params.set_enable_memory_optimization(true);
      _infer_engine_params.set_static_optimization(static_optimization);
      _infer_engine_params.set_force_update_static_cache(
          force_update_static_cache);
    }

M
MRXLT 已提交
193 194 195 196
    if (conf.has_use_trt()) {
      _infer_engine_params.set_use_trt(conf.use_trt());
    }

Z
zhangjun 已提交
197 198 199 200
    if (conf.has_use_lite()) {
      _infer_engine_params.set_use_lite(conf.use_lite());
    }

Z
zhangjun 已提交
201
    if (conf.has_use_xpu()) {
Z
zhangjun 已提交
202 203 204
      _infer_engine_params.set_use_xpu(conf.use_xpu());
    }

205
    if (!check_need_reload() || load(_infer_engine_params) != 0) {
W
wangguibao 已提交
206 207
      LOG(ERROR) << "Failed load model_data_path" << _model_data_path;
      return -1;
W
wangguibao 已提交
208
    }
W
wangguibao 已提交
209 210 211 212

    if (parse_version_info(conf, version) != 0) {
      LOG(ERROR) << "Failed parse version info";
      return -1;
W
wangguibao 已提交
213
    }
W
wangguibao 已提交
214 215 216 217 218 219 220 221 222

    LOG(WARNING) << "Succ load model_data_path" << _model_data_path;
    return 0;
  }

  int proc_initialize(const configure::EngineDesc& conf, bool version) {
    if (proc_initialize_impl(conf, version) != 0) {
      LOG(ERROR) << "Failed proc initialize impl";
      return -1;
W
wangguibao 已提交
223
    }
W
wangguibao 已提交
224 225
    return 0;
  }
W
wangguibao 已提交
226

W
wangjiawei04 已提交
227
  int infer() { return infer_impl(); }
W
wangguibao 已提交
228

W
wangguibao 已提交
229 230 231 232
  int thrd_initialize() {
    if (_infer_thread_num > 0) {
      return 0;
    }
W
wangguibao 已提交
233

W
wangguibao 已提交
234 235
    return thrd_initialize_impl();
  }
W
wangguibao 已提交
236

W
wangguibao 已提交
237 238 239 240
  int thrd_clear() {
    if (_infer_thread_num > 0) {
      return 0;
    }
W
wangguibao 已提交
241

W
wangguibao 已提交
242 243
    return thrd_clear_impl();
  }
W
wangguibao 已提交
244

W
wangguibao 已提交
245 246 247 248 249
  int proc_finalize() {
    if (proc_finalize_impl() != 0) {
      LOG(ERROR) << "Failed proc finalize impl";
      return -1;
    }
W
wangguibao 已提交
250

W
wangguibao 已提交
251 252
    return 0;
  }
W
wangguibao 已提交
253

W
wangguibao 已提交
254 255 256
  int reload() {
    if (check_need_reload()) {
      LOG(WARNING) << "begin reload model[" << _model_data_path << "].";
257
      return load(_infer_engine_params);
W
wangguibao 已提交
258 259 260 261 262 263 264
    }
    return 0;
  }

  uint64_t version() const { return _version; }

  uint32_t thread_num() const { return _infer_thread_num; }
W
wangguibao 已提交
265

W
wangguibao 已提交
266 267 268 269 270
 private:
  int parse_version_info(const configure::EngineDesc& config, bool version) {
    _version = uint64_t(-1);
    return 0;
  }
W
wangguibao 已提交
271

W
wangguibao 已提交
272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294
  bool check_need_reload() {
    if (_reload_mode_tag == "timestamp_ne") {
      return check_timestamp_ne();
    } else if (_reload_mode_tag == "timestamp_gt") {
      return check_timestamp_gt();
    } else if (_reload_mode_tag == "md5sum") {
      return check_md5sum();
    } else if (_reload_mode_tag == "revision") {
      return check_revision();
    } else if (_reload_mode_tag == "none") {
      return false;
    } else {
      LOG(ERROR) << "Not support check type: " << _reload_mode_tag;
      return false;
    }
  }

  bool check_timestamp_ne() {
    struct stat st;
    if (stat(_reload_tag_file.c_str(), &st) != 0) {
      LOG(ERROR) << "Failed stat config file:" << _reload_tag_file;
      return false;
    }
W
wangguibao 已提交
295

W
wangguibao 已提交
296 297 298
    if ((st.st_mode & S_IFREG) && st.st_mtime != _last_status.last_timestamp) {
      _last_status.last_timestamp = st.st_mtime;
      return true;
W
wangguibao 已提交
299 300
    }

W
wangguibao 已提交
301 302
    return false;
  }
W
wangguibao 已提交
303

W
wangguibao 已提交
304 305 306 307 308 309
  bool check_timestamp_gt() {
    struct stat st;
    if (stat(_reload_tag_file.c_str(), &st) != 0) {
      LOG(ERROR) << "Failed stat config file:" << _reload_tag_file;
      return false;
    }
W
wangguibao 已提交
310

W
wangguibao 已提交
311 312 313
    if ((st.st_mode & S_IFREG) && st.st_mtime > _last_status.last_timestamp) {
      _last_status.last_timestamp = st.st_mtime;
      return true;
W
wangguibao 已提交
314 315
    }

W
wangguibao 已提交
316 317 318 319 320 321 322 323 324
    return false;
  }

  bool check_md5sum() { return false; }

  bool check_revision() { return false; }

 protected:
  std::string _model_data_path;
325
  InferEngineCreationParams _infer_engine_params;
W
wangguibao 已提交
326 327 328 329 330 331 332 333 334 335

 private:
  std::string _reload_tag_file;
  std::string _reload_mode_tag;
  last_check_status _last_status;
  uint32_t _infer_thread_num;
  uint32_t _infer_batch_size;
  bool _infer_batch_align;
  uint64_t _version;
};
W
wangguibao 已提交
336

W
wangguibao 已提交
337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363
template <typename EngineCore>
struct ModelData {
  ModelData() : current_idx(1) {
    cores[0] = NULL;
    cores[1] = NULL;
  }

  ~ModelData() {
    delete cores[0];
    delete cores[1];
  }

  EngineCore* cores[2];
  uint32_t current_idx;
};

template <typename EngineCore>
class DBReloadableInferEngine : public ReloadableInferEngine {
 public:
  virtual ~DBReloadableInferEngine() {}

  int proc_initialize(const configure::EngineDesc& conf, bool version) {
    THREAD_KEY_CREATE(&_skey, NULL);
    THREAD_MUTEX_INIT(&_mutex, NULL);
    return ReloadableInferEngine::proc_initialize(conf, version);
  }

364
  virtual int load(const InferEngineCreationParams& params) {
W
wangguibao 已提交
365 366
    if (_reload_vec.empty()) {
      return 0;
W
wangguibao 已提交
367 368
    }

W
wangguibao 已提交
369
    for (uint32_t ti = 0; ti < _reload_vec.size(); ++ti) {
370
      if (load_data(_reload_vec[ti], params) != 0) {
W
wangguibao 已提交
371 372 373 374 375
        LOG(ERROR) << "Failed reload engine model: " << ti;
        return -1;
      }
    }

376
    LOG(WARNING) << "Succ load engine, path: " << params.get_path();
W
wangguibao 已提交
377

W
wangguibao 已提交
378 379
    return 0;
  }
W
wangguibao 已提交
380

381 382
  int load_data(ModelData<EngineCore>* md,
                const InferEngineCreationParams& params) {
W
wangguibao 已提交
383 384 385
    uint32_t next_idx = (md->current_idx + 1) % 2;
    if (md->cores[next_idx]) {
      delete md->cores[next_idx];
W
wangguibao 已提交
386 387
    }

W
wangguibao 已提交
388
    md->cores[next_idx] = new (std::nothrow) EngineCore;
389 390 391 392

    params.dump();
    if (!md->cores[next_idx] || md->cores[next_idx]->create(params) != 0) {
      LOG(ERROR) << "Failed create model, path: " << params.get_path();
W
wangguibao 已提交
393
      return -1;
W
wangguibao 已提交
394
    }
W
wangguibao 已提交
395 396 397
    md->current_idx = next_idx;
    return 0;
  }
W
wangguibao 已提交
398

W
wangguibao 已提交
399 400
  virtual int thrd_initialize_impl() {
    // memory pool to be inited in non-serving-threads
W
wangguibao 已提交
401

W
wangguibao 已提交
402
    ModelData<EngineCore>* md = new (std::nothrow) ModelData<EngineCore>;
403 404 405
    if (!md || load_data(md, _infer_engine_params) != 0) {
      LOG(ERROR) << "Failed create thread data from "
                 << _infer_engine_params.get_path();
W
wangguibao 已提交
406
      return -1;
W
wangguibao 已提交
407 408
    }

W
wangguibao 已提交
409 410 411 412 413 414 415 416 417 418 419
    THREAD_SETSPECIFIC(_skey, md);
    _reload_vec.push_back(md);
    return 0;
  }

  int thrd_clear_impl() {
    // for non-serving-threads
    return 0;
  }

  int thrd_finalize_impl() { return 0; }
W
wangguibao 已提交
420

W
wangguibao 已提交
421 422 423 424 425
  int proc_finalize_impl() {
    THREAD_KEY_DELETE(_skey);
    THREAD_MUTEX_DESTROY(&_mutex);
    return 0;
  }
W
wangguibao 已提交
426

W
wangguibao 已提交
427 428 429 430 431 432
  EngineCore* get_core() {
    ModelData<EngineCore>* md =
        (ModelData<EngineCore>*)THREAD_GETSPECIFIC(_skey);
    if (!md) {
      LOG(ERROR) << "Failed get thread specific data";
      return NULL;
W
wangguibao 已提交
433
    }
W
wangguibao 已提交
434 435
    return md->cores[md->current_idx];
  }
W
wangguibao 已提交
436

W
wangguibao 已提交
437 438 439 440
 protected:
  THREAD_KEY_T _skey;
  THREAD_MUTEX_T _mutex;
  std::vector<ModelData<EngineCore>*> _reload_vec;
W
wangguibao 已提交
441

W
wangguibao 已提交
442 443
 private:
};
W
wangguibao 已提交
444

W
wangguibao 已提交
445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460
// 多个EngineCore共用同一份模型数据
template <typename EngineCore>
class CloneDBReloadableInferEngine
    : public DBReloadableInferEngine<EngineCore> {
 public:
  virtual ~CloneDBReloadableInferEngine() {}

  virtual int proc_initialize(const configure::EngineDesc& conf, bool version) {
    _pd = new (std::nothrow) ModelData<EngineCore>;
    if (!_pd) {
      LOG(ERROR) << "Failed to allocate for ProcData";
      return -1;
    }
    return DBReloadableInferEngine<EngineCore>::proc_initialize(conf, version);
  }

461
  virtual int load(const InferEngineCreationParams& params) {
W
wangguibao 已提交
462 463
    // 加载进程级模型数据
    if (!_pd ||
464 465
        DBReloadableInferEngine<EngineCore>::load_data(_pd, params) != 0) {
      LOG(ERROR) << "Failed to create common model from [" << params.get_path()
W
wangguibao 已提交
466 467 468 469
                 << "].";
      return -1;
    }
    LOG(WARNING) << "Succ load common model[" << _pd->cores[_pd->current_idx]
470
                 << "], path[" << params.get_path() << "].";
W
wangguibao 已提交
471 472 473 474 475 476 477 478 479 480 481 482 483

    if (DBReloadableInferEngine<EngineCore>::_reload_vec.empty()) {
      return 0;
    }

    for (uint32_t ti = 0;
         ti < DBReloadableInferEngine<EngineCore>::_reload_vec.size();
         ++ti) {
      if (load_data(DBReloadableInferEngine<EngineCore>::_reload_vec[ti],
                    _pd->cores[_pd->current_idx]) != 0) {
        LOG(ERROR) << "Failed reload engine model: " << ti;
        return -1;
      }
W
wangguibao 已提交
484 485
    }

486
    LOG(WARNING) << "Succ load clone model, path[" << params.get_path() << "]";
W
wangguibao 已提交
487

W
wangguibao 已提交
488 489
    return 0;
  }
W
wangguibao 已提交
490

W
wangguibao 已提交
491 492 493 494 495
  // 加载线程级对象,多个线程级对象共用pd_core的模型数据
  int load_data(ModelData<EngineCore>* td, EngineCore* pd_core) {
    uint32_t next_idx = (td->current_idx + 1) % 2;
    if (td->cores[next_idx]) {
      delete td->cores[next_idx];
W
wangguibao 已提交
496 497
    }

W
wangguibao 已提交
498 499 500 501 502 503
    td->cores[next_idx] = new (std::nothrow) EngineCore;
    if (!td->cores[next_idx] ||
        td->cores[next_idx]->clone(pd_core->get()) != 0) {
      LOG(ERROR) << "Failed clone model from pd_core[ " << pd_core << "], idx["
                 << next_idx << "]";
      return -1;
W
wangguibao 已提交
504
    }
W
wangguibao 已提交
505 506 507 508 509 510
    td->current_idx = next_idx;
    LOG(WARNING) << "td_core[" << td->cores[td->current_idx]
                 << "] clone model from pd_core[" << pd_core
                 << "] succ, cur_idx[" << td->current_idx << "].";
    return 0;
  }
W
wangguibao 已提交
511

W
wangguibao 已提交
512 513 514 515 516 517 518 519 520 521 522 523
  virtual int thrd_initialize_impl() {
    ModelData<EngineCore>* md = new (std::nothrow) ModelData<EngineCore>;
    if (!md || load_data(md, _pd->cores[_pd->current_idx]) != 0) {
      LOG(ERROR) << "Failed clone thread data, origin_core["
                 << _pd->cores[_pd->current_idx] << "].";
      return -1;
    }

    THREAD_SETSPECIFIC(DBReloadableInferEngine<EngineCore>::_skey, md);
    DBReloadableInferEngine<EngineCore>::_reload_vec.push_back(md);
    return 0;
  }
W
wangguibao 已提交
524

W
wangguibao 已提交
525 526 527
 protected:
  ModelData<EngineCore>*
      _pd;  // 进程级EngineCore,多个线程级EngineCore共用该对象的模型数据
W
wangguibao 已提交
528 529
};

W
wangguibao 已提交
530
template <typename FluidFamilyCore>
M
bug fix  
MRXLT 已提交
531
#ifdef WITH_TRT
M
MRXLT 已提交
532
class FluidInferEngine : public DBReloadableInferEngine<FluidFamilyCore> {
M
bug fix  
MRXLT 已提交
533 534 535 536
#else
class FluidInferEngine : public CloneDBReloadableInferEngine<FluidFamilyCore> {
#endif
 public:  // NOLINT
W
wangguibao 已提交
537 538
  FluidInferEngine() {}
  ~FluidInferEngine() {}
W
wangjiawei04 已提交
539
  std::vector<std::string> GetInputNames() {
W
wangjiawei04 已提交
540 541
    FluidFamilyCore* core =
        DBReloadableInferEngine<FluidFamilyCore>::get_core();
W
wangjiawei04 已提交
542 543 544 545 546
    if (!core || !core->get()) {
      LOG(ERROR) << "Failed get fluid core in GetInputHandle()";
    }
    return core->GetInputNames();
  }
W
wangguibao 已提交
547

W
wangjiawei04 已提交
548
  std::vector<std::string> GetOutputNames() {
W
wangjiawei04 已提交
549 550
    FluidFamilyCore* core =
        DBReloadableInferEngine<FluidFamilyCore>::get_core();
W
wangjiawei04 已提交
551 552 553 554 555 556
    if (!core || !core->get()) {
      LOG(ERROR) << "Failed get fluid core in GetInputHandle()";
    }
    return core->GetOutputNames();
  }

W
wangjiawei04 已提交
557 558 559 560
  std::unique_ptr<paddle_infer::Tensor> GetInputHandle(
      const std::string& name) {
    FluidFamilyCore* core =
        DBReloadableInferEngine<FluidFamilyCore>::get_core();
W
wangjiawei04 已提交
561 562 563 564 565 566
    if (!core || !core->get()) {
      LOG(ERROR) << "Failed get fluid core in GetInputHandle()";
    }
    return core->GetInputHandle(name);
  }

W
wangjiawei04 已提交
567 568 569 570
  std::unique_ptr<paddle_infer::Tensor> GetOutputHandle(
      const std::string& name) {
    FluidFamilyCore* core =
        DBReloadableInferEngine<FluidFamilyCore>::get_core();
W
wangjiawei04 已提交
571 572 573 574 575
    if (!core || !core->get()) {
      LOG(ERROR) << "Failed get fluid core in GetOutputHandle()";
    }
    return core->GetOutputHandle(name);
  }
W
wangguibao 已提交
576

W
wangjiawei04 已提交
577
  int infer_impl() {
W
wangguibao 已提交
578 579 580 581 582
    FluidFamilyCore* core =
        DBReloadableInferEngine<FluidFamilyCore>::get_core();
    if (!core || !core->get()) {
      LOG(ERROR) << "Failed get fluid core in infer_impl()";
      return -1;
W
wangguibao 已提交
583 584
    }

W
wangjiawei04 已提交
585
    if (!core->Run()) {
W
wangguibao 已提交
586 587 588 589 590
      LOG(ERROR) << "Failed run fluid family core";
      return -1;
    }
    return 0;
  }
W
wangguibao 已提交
591 592
};

W
wangguibao 已提交
593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617
typedef FactoryPool<InferEngine> StaticInferFactory;

class VersionedInferEngine : public InferEngine {
 public:
  VersionedInferEngine() { _versions.clear(); }
  ~VersionedInferEngine() {}

  int proc_initialize(const configure::EngineDesc& conf) {
    if (proc_initialize(conf, false) != 0) {
      LOG(ERROR) << "Failed proc intialize engine: " << conf.name().c_str();
      return -1;
    }

    LOG(WARNING) << "Succ proc initialize engine: " << conf.name().c_str();
    return 0;
  }

  int proc_initialize(const configure::EngineDesc& conf, bool version) {
    std::string engine_type = conf.type();
    InferEngine* engine =
        StaticInferFactory::instance().generate_object(engine_type);
    if (!engine) {
      LOG(ERROR) << "Failed generate engine with type:" << engine_type;
      return -1;
    }
618
#ifndef BCLOUD
M
MRXLT 已提交
619
    VLOG(2) << "FLAGS_logtostderr " << FLAGS_logtostderr;
M
MRXLT 已提交
620
    int tmp = FLAGS_logtostderr;
W
wangguibao 已提交
621 622 623 624
    if (engine->proc_initialize(conf, version) != 0) {
      LOG(ERROR) << "Failed initialize engine, type:" << engine_type;
      return -1;
    }
M
bug fix  
MRXLT 已提交
625
    VLOG(2) << "FLAGS_logtostderr " << FLAGS_logtostderr;
M
MRXLT 已提交
626
    FLAGS_logtostderr = tmp;
627 628 629 630 631 632
#else
    if (engine->proc_initialize(conf, version) != 0) {
      LOG(ERROR) << "Failed initialize engine, type:" << engine_type;
      return -1;
    }
#endif
W
wangguibao 已提交
633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657
    auto r = _versions.insert(std::make_pair(engine->version(), engine));
    if (!r.second) {
      LOG(ERROR) << "Failed insert item: " << engine->version()
                 << ", type: " << engine_type;
      return -1;
    }
    LOG(WARNING) << "Succ proc initialize version engine: "
                 << engine->version();
    return 0;
  }

  int proc_finalize() {
    for (auto iter = _versions.begin(); iter != _versions.end(); ++iter) {
      if (iter->second->proc_finalize() != 0) {
        LOG(ERROR) << "Failed proc finalize version engine: " << iter->first;
      }
      LOG(WARNING) << "Succ proc finalize version engine: " << iter->first;
    }
    return 0;
  }

  int thrd_initialize() {
    for (auto iter = _versions.begin(); iter != _versions.end(); ++iter) {
      if (iter->second->thrd_initialize() != 0) {
        LOG(ERROR) << "Failed thrd initialize version engine: " << iter->first;
W
wangguibao 已提交
658
        return -1;
W
wangguibao 已提交
659 660
      }
      LOG(WARNING) << "Succ thrd initialize version engine: " << iter->first;
W
wangguibao 已提交
661
    }
W
wangguibao 已提交
662 663
    return 0;
  }
W
wangguibao 已提交
664

W
wangguibao 已提交
665 666 667 668
  int thrd_clear() {
    for (auto iter = _versions.begin(); iter != _versions.end(); ++iter) {
      if (iter->second->thrd_clear() != 0) {
        LOG(ERROR) << "Failed thrd clear version engine: " << iter->first;
W
wangguibao 已提交
669
        return -1;
W
wangguibao 已提交
670
      }
W
wangguibao 已提交
671
    }
W
wangguibao 已提交
672 673
    return 0;
  }
W
wangguibao 已提交
674

W
wangguibao 已提交
675 676 677 678 679 680 681
  int thrd_finalize() {
    for (auto iter = _versions.begin(); iter != _versions.end(); ++iter) {
      if (iter->second->thrd_finalize() != 0) {
        LOG(ERROR) << "Failed thrd finalize version engine: " << iter->first;
        return -1;
      }
      LOG(WARNING) << "Succ thrd finalize version engine: " << iter->first;
W
wangguibao 已提交
682
    }
W
wangguibao 已提交
683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715
    return 0;
  }

  int reload() {
    for (auto iter = _versions.begin(); iter != _versions.end(); ++iter) {
      if (iter->second->reload() != 0) {
        LOG(ERROR) << "Failed reload version engine: " << iter->first;
        return -1;
      }
      LOG(WARNING) << "Succ reload version engine: " << iter->first;
    }
    return 0;
  }

  uint64_t version() const {
    InferEngine* engine = default_engine();
    if (engine) {
      return engine->version();
    } else {
      return uint64_t(-1);
    }
  }

  // inference interface
  InferEngine* default_engine() const {
    if (_versions.size() != 1) {
      LOG(ERROR) << "Ambiguous default engine version:" << _versions.size();
      return NULL;
    }

    return _versions.begin()->second;
  }

W
wangjiawei04 已提交
716
  int infer() {
W
wangguibao 已提交
717 718 719 720 721
    InferEngine* engine = default_engine();
    if (!engine) {
      LOG(WARNING) << "fail to get default engine";
      return -1;
    }
W
wangjiawei04 已提交
722 723 724
    return engine->infer();
  }

W
wangjiawei04 已提交
725 726 727 728 729 730 731 732 733 734 735 736 737 738
  std::vector<std::string> GetInputNames() {
    InferEngine* engine = default_engine();
    if (!engine) {
      LOG(WARNING) << "fail to get default engine";
    }
    return engine->GetInputNames();
  }
  std::vector<std::string> GetOutputNames() {
    InferEngine* engine = default_engine();
    if (!engine) {
      LOG(WARNING) << "fail to get default engine";
    }
    return engine->GetOutputNames();
  }
W
wangjiawei04 已提交
739 740
  std::unique_ptr<paddle_infer::Tensor> GetInputHandle(
      const std::string& name) {
W
wangjiawei04 已提交
741 742 743 744 745 746 747
    InferEngine* engine = default_engine();
    if (!engine) {
      LOG(WARNING) << "fail to get default engine";
    }
    return engine->GetInputHandle(name);
  }

W
wangjiawei04 已提交
748 749
  std::unique_ptr<paddle_infer::Tensor> GetOutputHandle(
      const std::string& name) {
W
wangjiawei04 已提交
750 751 752 753 754
    InferEngine* engine = default_engine();
    if (!engine) {
      LOG(WARNING) << "fail to get default engine";
    }
    return engine->GetOutputHandle(name);
W
wangguibao 已提交
755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772
  }

  template <typename T>
  T* get_core() {
    InferEngine* engine = default_engine();
    if (!engine) {
      LOG(WARNING) << "fail to get core";
      return NULL;
    }
    auto db_engine = dynamic_cast<DBReloadableInferEngine<T>*>(engine);
    if (db_engine) {
      return db_engine->get_core();
    }
    LOG(WARNING) << "fail to get core";
    return NULL;
  }

  // versioned inference interface
W
wangjiawei04 已提交
773
  int infer(uint64_t version) {
W
wangguibao 已提交
774 775 776 777 778 779
    auto iter = _versions.find(version);
    if (iter == _versions.end()) {
      LOG(ERROR) << "Not found version engine: " << version;
      return -1;
    }

W
wangjiawei04 已提交
780 781
    return iter->second->infer();
  }
W
wangjiawei04 已提交
782 783 784 785
  std::vector<std::string> GetInputNames(uint64_t version) {
    auto iter = _versions.find(version);
    if (iter == _versions.end()) {
      LOG(ERROR) << "Not found version engine: " << version;
W
wangjiawei04 已提交
786
    }
W
wangjiawei04 已提交
787 788 789 790 791 792 793 794 795 796
    return iter->second->GetInputNames();
  }

  std::vector<std::string> GetOutputNames(uint64_t version) {
    auto iter = _versions.find(version);
    if (iter == _versions.end()) {
      LOG(ERROR) << "Not found version engine: " << version;
    }
    return iter->second->GetOutputNames();
  }
W
wangjiawei04 已提交
797

W
wangjiawei04 已提交
798 799
  std::unique_ptr<paddle_infer::Tensor> GetInputHandle(
      uint64_t version, const std::string& name) {
W
wangjiawei04 已提交
800 801 802 803 804 805 806
    auto iter = _versions.find(version);
    if (iter == _versions.end()) {
      LOG(ERROR) << "Not found version engine: " << version;
    }
    return iter->second->GetInputHandle(name);
  }

W
wangjiawei04 已提交
807 808
  std::unique_ptr<paddle_infer::Tensor> GetOutputHandle(
      uint64_t version, const std::string& name) {
W
wangjiawei04 已提交
809 810 811 812 813
    auto iter = _versions.find(version);
    if (iter == _versions.end()) {
      LOG(ERROR) << "Not found version engine: " << version;
    }
    return iter->second->GetOutputHandle(name);
W
wangguibao 已提交
814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839
  }

  template <typename T>
  T* get_core(uint64_t version) {
    auto iter = _versions.find(version);
    if (iter == _versions.end()) {
      LOG(ERROR) << "Not found version engine: " << version;
      return NULL;
    }

    auto db_engine = dynamic_cast<DBReloadableInferEngine<T>*>(iter->second);
    if (db_engine) {
      return db_engine->get_core();
    }
    LOG(WARNING) << "fail to get core for " << version;
    return NULL;
  }

  // --
  int proc_initialize_impl(const configure::EngineDesc& conf, bool) {
    return -1;
  }
  int thrd_initialize_impl() { return -1; }
  int thrd_finalize_impl() { return -1; }
  int thrd_clear_impl() { return -1; }
  int proc_finalize_impl() { return -1; }
W
wangjiawei04 已提交
840
  int infer_impl() { return -1; }
W
wangguibao 已提交
841 842 843

 private:
  boost::unordered_map<uint64_t, InferEngine*> _versions;
W
wangguibao 已提交
844 845
};

W
wangguibao 已提交
846 847 848 849 850 851 852 853 854 855 856 857 858 859 860
class InferManager {
 public:
  static InferManager& instance() {
    static InferManager ins;
    return ins;
  }

  int proc_initialize(const char* path, const char* file) {
    ModelToolkitConf model_toolkit_conf;
    if (configure::read_proto_conf(path, file, &model_toolkit_conf) != 0) {
      LOG(ERROR) << "failed load infer config, path: " << path << "/" << file;
      return -1;
    }
    size_t engine_num = model_toolkit_conf.engines_size();
    for (size_t ei = 0; ei < engine_num; ++ei) {
B
barrierye 已提交
861 862
      LOG(INFO) << "model_toolkit_conf.engines(" << ei
                << ").name: " << model_toolkit_conf.engines(ei).name();
W
wangguibao 已提交
863 864 865 866 867 868 869 870
      std::string engine_name = model_toolkit_conf.engines(ei).name();
      VersionedInferEngine* engine = new (std::nothrow) VersionedInferEngine();
      if (!engine) {
        LOG(ERROR) << "Failed generate versioned engine: " << engine_name;
        return -1;
      }
      if (engine->proc_initialize(model_toolkit_conf.engines(ei)) != 0) {
        LOG(ERROR) << "Failed initialize version engine, name:" << engine_name;
W
wangguibao 已提交
871
        return -1;
W
wangguibao 已提交
872 873 874 875 876 877 878
      }
      auto r = _map.insert(std::make_pair(engine_name, engine));
      if (!r.second) {
        LOG(ERROR) << "Failed insert item: " << engine_name;
        return -1;
      }
      LOG(WARNING) << "Succ proc initialize engine: " << engine_name;
W
wangguibao 已提交
879
    }
W
wangguibao 已提交
880 881 882 883 884 885 886
    return 0;
  }

  int thrd_initialize() {
    for (auto it = _map.begin(); it != _map.end(); ++it) {
      if (it->second->thrd_initialize() != 0) {
        LOG(ERROR) << "Failed thrd initialize engine, name: " << it->first;
W
wangguibao 已提交
887
        return -1;
W
wangguibao 已提交
888 889
      }
      LOG(WARNING) << "Succ thrd initialize engine, name: " << it->first;
W
wangguibao 已提交
890
    }
W
wangguibao 已提交
891 892
    return 0;
  }
W
wangguibao 已提交
893

W
wangguibao 已提交
894 895 896 897 898 899 900 901 902
  int thrd_clear() {
    for (auto it = _map.begin(); it != _map.end(); ++it) {
      if (it->second->thrd_clear() != 0) {
        LOG(ERROR) << "Failed thrd clear engine, name: " << it->first;
        return -1;
      }
    }
    return 0;
  }
W
wangguibao 已提交
903

W
wangguibao 已提交
904 905 906 907 908 909 910 911 912
  int reload() {
    for (auto it = _map.begin(); it != _map.end(); ++it) {
      if (it->second->reload() != 0) {
        LOG(ERROR) << "Failed reload engine, name: " << it->first;
        return -1;
      }
    }
    return 0;
  }
W
wangguibao 已提交
913

W
wangguibao 已提交
914 915 916 917 918 919 920 921 922 923
  int thrd_finalize() {
    for (auto it = _map.begin(); it != _map.end(); ++it) {
      if (it->second->thrd_finalize() != 0) {
        LOG(ERROR) << "Failed thrd finalize engine, name: " << it->first;
        return -1;
      }
      LOG(WARNING) << "Succ thrd finalize engine, name: " << it->first;
    }
    return 0;
  }
W
wangguibao 已提交
924

W
wangguibao 已提交
925 926 927 928 929 930 931 932
  int proc_finalize() {
    for (auto it = _map.begin(); it != _map.end(); ++it) {
      if (it->second->proc_finalize() != 0) {
        LOG(ERROR) << "Failed proc finalize engine, name: " << it->first;
        return -1;
      }
      LOG(WARNING) << "Succ proc finalize engine, name: " << it->first;
    }
W
wangguibao 已提交
933
    _map.clear();
W
wangguibao 已提交
934 935 936 937
    return 0;
  }

  // Inference interface
W
wangjiawei04 已提交
938
  int infer(const char* model_name) {
W
wangguibao 已提交
939 940 941 942 943
    auto it = _map.find(model_name);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model_name;
      return -1;
    }
W
wangjiawei04 已提交
944 945
    return it->second->infer();
  }
W
wangjiawei04 已提交
946 947 948 949 950 951 952 953 954 955 956 957 958 959 960

  std::vector<std::string> GetInputNames(const char* model_name) {
    auto it = _map.find(model_name);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model_name;
    }
    return it->second->GetInputNames();
  }
  std::vector<std::string> GetOutputNames(const char* model_name) {
    auto it = _map.find(model_name);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model_name;
    }
    return it->second->GetOutputNames();
  }
W
wangjiawei04 已提交
961 962
  std::unique_ptr<paddle_infer::Tensor> GetInputHandle(
      const char* model_name, const std::string& name) {
W
wangjiawei04 已提交
963 964 965 966 967 968
    auto it = _map.find(model_name);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model_name;
    }
    return it->second->GetInputHandle(name);
  }
W
wangjiawei04 已提交
969 970
  std::unique_ptr<paddle_infer::Tensor> GetOutputHandle(
      const char* model_name, const std::string& name) {
W
wangjiawei04 已提交
971 972 973 974 975
    auto it = _map.find(model_name);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model_name;
    }
    return it->second->GetOutputHandle(name);
W
wangguibao 已提交
976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994
  }

  template <typename T>
  T* get_core(const char* model_name) {
    auto it = _map.find(model_name);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model_name;
      return NULL;
    }
    auto infer_engine =
        dynamic_cast<DBReloadableInferEngine<T>*>(it->second->default_engine());
    if (infer_engine) {
      return infer_engine->get_core();
    }
    LOG(WARNING) << "fail to get core for " << model_name;
    return NULL;
  }

  // Versioned inference interface
W
wangjiawei04 已提交
995
  int infer(const char* model_name, uint64_t version) {
W
wangguibao 已提交
996 997 998 999 1000
    auto it = _map.find(model_name);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model_name;
      return -1;
    }
W
wangjiawei04 已提交
1001 1002
    return it->second->infer(version);
  }
W
wangjiawei04 已提交
1003 1004
  std::vector<std::string> GetInputNames(const char* model_name,
                                         uint64_t version) {
W
wangjiawei04 已提交
1005 1006 1007 1008 1009
    auto it = _map.find(model_name);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model_name;
    }
    return it->second->GetInputNames(version);
W
wangguibao 已提交
1010 1011
  }

W
wangjiawei04 已提交
1012 1013
  std::vector<std::string> GetOutputNames(const char* model_name,
                                          uint64_t version) {
W
wangjiawei04 已提交
1014 1015 1016 1017 1018 1019 1020
    auto it = _map.find(model_name);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model_name;
    }
    return it->second->GetOutputNames(version);
  }

W
wangjiawei04 已提交
1021 1022
  std::unique_ptr<paddle_infer::Tensor> GetInputHandle(
      const char* model_name, uint64_t version, const std::string& name) {
W
wangjiawei04 已提交
1023 1024 1025 1026 1027 1028
    auto it = _map.find(model_name);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model_name;
    }
    return it->second->GetInputHandle(version, name);
  }
W
wangjiawei04 已提交
1029 1030
  std::unique_ptr<paddle_infer::Tensor> GetOutputHandle(
      const char* model_name, uint64_t version, const std::string& name) {
W
wangjiawei04 已提交
1031 1032 1033 1034 1035
    auto it = _map.find(model_name);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model_name;
    }
    return it->second->GetOutputHandle(version, name);
W
wangguibao 已提交
1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065
  }
  template <typename T>
  T* get_core(const char* model_name, uint64_t version) {
    auto it = _map.find(model_name);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model_name;
      return NULL;
    }
    return it->second->get_core<T>(version);
  }

  int query_version(const std::string& model, uint64_t& version) {  // NOLINT
    auto it = _map.find(model);
    if (it == _map.end()) {
      LOG(WARNING) << "Cannot find engine in map, model name:" << model;
      return -1;
    }
    auto infer_engine = it->second->default_engine();
    if (!infer_engine) {
      LOG(WARNING) << "Cannot get default engine for model:" << model;
      return -1;
    }
    version = infer_engine->version();
    LOG(INFO) << "Succ get version: " << version << " for model: " << model;
    return 0;
  }

 private:
  boost::unordered_map<std::string, VersionedInferEngine*> _map;
};
W
wangguibao 已提交
1066

W
wangguibao 已提交
1067 1068 1069
}  // namespace predictor
}  // namespace paddle_serving
}  // namespace baidu