#include <time.h>
#include <fstream>
#include <yaml-cpp/yaml.h>
#include "paddle/fluid/platform/init.h"
#include "paddle/fluid/train/custom_trainer/feed/trainer_context.h"
#include "paddle/fluid/train/custom_trainer/feed/process/process.h"
#include "paddle/fluid/train/custom_trainer/feed/process/init_env_process.h"

using namespace paddle::custom_trainer::feed;

DEFINE_string(feed_trainer_conf_path, "./conf/trainer.yaml", "path of trainer conf");

int main(int argc, char* argv[]) {
    //gflags
    google::ParseCommandLineFlags(&argc, &argv, true);
    std::string gflag_conf = "./conf/gflags.conf";
    google::SetCommandLineOption("flagfile", gflag_conf.c_str()); 

    //load trainer config
    auto trainer_context_ptr = std::make_shared<TrainerContext>();
    trainer_context_ptr->trainer_config = YAML::LoadFile(FLAGS_feed_trainer_conf_path);    
 
    std::vector<std::string> process_name_list = {
        "InitEnvProcess"
    };
    InitEnvProcess init_process;
    init_process.run();

    for (const auto& process_name : process_name_list) {
        Process* process = CREATE_CLASS(Process, process_name);
        if (process == NULL) {
            VLOG(1) << "Process:" << process_name << " does not exist"; 
            return -1;
        }
        if (process->initialize(trainer_context_ptr) != 0) {
            VLOG(1) << "Process:" << process_name << " initialize failed"; 
            return -1;
        }
        trainer_context_ptr->process_list.push_back(std::shared_ptr<Process>(process));
    } 

    for (auto& process : trainer_context_ptr->process_list) {
        process->run();
    }

    return 0;
}