nodemanager/data/TaskInfo.cpp

#include "TaskInfo.h"
#include "../utils/JsonHelper.h"
#include "../utils/String.h"

using namespace web;
using namespace hpc::data;
using namespace hpc::utils;

json::value TaskInfo::ToJson() const
{
    json::value j;

    j["TaskId"] = this->TaskId;
    j["TaskRequeueCount"] = this->taskRequeueCount;
    j["ExitCode"] = this->ExitCode;
    j["Exited"] = this->Exited;
    j["KernelProcessorTime"] = this->KernelProcessorTimeMs;
    j["UserProcessorTime"] = this->UserProcessorTimeMs;
    j["WorkingSet"] = this->WorkingSetKb;
    j["NumberOfProcesses"] = this->GetProcessCount();
    j["PrimaryTask"] = this->IsPrimaryTask;
    j["Message"] = JsonHelper<std::string>::ToJson(this->Message);
    j["ProcessIds"] = JsonHelper<std::string>::ToJson(String::Join<','>(this->ProcessIds));

    return j;
}

json::value TaskInfo::ToCompletionEventArgJson() const
{
    json::value j = this->ToJson();

    json::value jobIdArg;
    jobIdArg["JobId"] = this->JobId;
    jobIdArg["TaskInfo"] = j;
    jobIdArg["NodeName"] = json::value::string(this->NodeName);

    return jobIdArg;
}

void TaskInfo::AssignFromStat(const ProcessStatistics& stat)
{
    this->KernelProcessorTimeMs = stat.KernelTimeMs;
    this->UserProcessorTimeMs = stat.UserTimeMs;
    this->ProcessIds = stat.ProcessIds;
    this->WorkingSetKb = stat.WorkingSetKb;
}