Method InitScheduler

preempt/src/sched/agent.cpp:61–98

}

void SchedAgent::InitScheduler(XSchedulerType scheduler_type, XPolicyType policy_type)
{
    if (scheduler_ != nullptr) return;
    
    auto tmp_scheduler = CreateScheduler(scheduler_type, policy_type);
    tmp_scheduler->SetExecutor(SchedExecutor::Execute);
    tmp_scheduler->Run();

    static const std::string kCmdline = []() -> std::string {
        std::string cmdline;
        
#if defined(_WIN32)
        LPWSTR cmdlineW = GetCommandLineW();
        int size = WideCharToMultiByte(CP_UTF8, 0, cmdlineW, -1, NULL, 0, NULL, NULL);
        if (size > 0) {
            std::vector<char> buffer(size);
            WideCharToMultiByte(CP_UTF8, 0, cmdlineW, -1, buffer.data(), size, NULL, NULL);
            cmdline = buffer.data();
        }
#elif defined(__linux__)
        std::ifstream cmdline_file("/proc/self/cmdline");
        if (cmdline_file.good()) {
            std::string arg;
            while (std::getline(cmdline_file, arg, '\0') && !arg.empty()) {
                cmdline = cmdline + arg + " ";
            }
        }
        cmdline_file.close();
#endif

        return ShrinkString(cmdline, ProcessCreateEvent::CmdlineCapacity() - 1);
    }();

    auto event = std::make_shared<ProcessCreateEvent>(kCmdline);
    tmp_scheduler->RecvEvent(event);

    scheduler_ = tmp_scheduler;
}

void SchedAgent::FiniScheduler()
{