TRestTask.cxx

 
 
#include "TRestTask.h"
 
#include "TFunction.h"
#include "TMethodArg.h"
#include "TRestManager.h"
#include "TRestReflector.h"
#include "TRestStringHelper.h"
 
using namespace std;
 
ClassImp(TRestTask);
 
#ifdef WIN32
// in windows the pointer address from string conversion is without "0x", we must add
// the prefix so that ROOT can correctly initialize run/metadata objects
#define PTR_ADDR_PREFIX "0x"
#else
#define PTR_ADDR_PREFIX ""
#endif  // WIN32
 
TRestTask::TRestTask() {
    Initialize();
    fNRequiredArgument = 0;
    if (this->ClassName() != (string) "TRestTask") {
        fMode = TASK_CLASS;
    }
}
 
TRestTask::TRestTask(TString TaskString, REST_TASKMODE mode) {
    Initialize();
    fNRequiredArgument = 0;
    fMode = mode;
 
    if (mode == TASK_MACRO) {
        // we parse the macro file, get the method's name and argument list
        string filename = TRestTools::SeparatePathAndName((string)TaskString).second;
        int n = filename.find_last_of('.');
        string funcName = "";
        if (n > 0) {
            funcName = filename.substr(0, n);
        } else {
            funcName = TaskString;
        }
        TFunction* f = gROOT->GetGlobalFunction(funcName.c_str());
        if (f == nullptr) {
            fMode = TASK_ERROR;
        } else {
            fNRequiredArgument = f->GetNargs() - f->GetNargsOpt();
            fInvokeMethod = funcName;
            // indicates whether the argument is string/TString/const char *. If so, the value would be 1. We
            // need to add "" mark when constructing command. Otherwise the value is 0.
 
            TList* list = f->GetListOfMethodArgs();
            for (int i = 0; i < list->GetSize(); i++) {
                TMethodArg* arg = (TMethodArg*)list->At(i);
                string type = arg->GetTypeName();
                fArgumentTypes.push_back(type == "string" || type == "char" || type == "TString");
                fArgumentNames.push_back(arg->GetName());
            }
            string fConstructedCommand = "";
        }
 
    } else if (mode == TASK_CPPCMD) {
        // we parse the command, get the target object, method to be invoked, and
        // the argument list
        string cmd = (string)TaskString;
 
        string name;
        string call;
        if (Split(cmd, "->").size() != 2) {
            RESTWarning << "command"
                        << " \"" << cmd << "\" "
                        << "is illegal!" << RESTendl;
            fMode = TASK_ERROR;
            return;
        } else {
            name = Split(cmd, "->")[0];
            call = Split(cmd, "->")[1];
        }
 
        int p1 = call.find_first_of("(");
        int p2 = call.find_last_of(")");
        if (p1 == -1 || p2 == -1 || p1 >= p2) {
            RESTWarning << "command"
                        << " \"" << cmd << "\" "
                        << "is illegal!" << RESTendl;
            fMode = TASK_ERROR;
            return;
        }
        fInvokeObject = name;
        fInvokeMethod = call.substr(0, p1);
 
        string args = call.substr(p1 + 1, p2 - p1 - 1);
        fArgumentValues = Split(args, ",");
        fConstructedCommand = cmd;
    } else if (mode == TASK_CLASS) {
        // I don't think we can get here
    } else if (mode == TASK_SHELLCMD) {
        fConstructedCommand = TaskString;
        fInvokeMethod = Split(fConstructedCommand, " ")[0];
    }
}
 
void TRestTask::InitFromConfigFile() { ReadAllParameters(); }
 
void TRestTask::SetArgumentValue(vector<string> arg) {
    if (arg.size() < fNRequiredArgument) {
        PrintArgumentHelp();
        exit(0);
    }
    fArgumentValues = arg;
}
 
void TRestTask::RunTask(TRestManager* mgr) {
    if (fInvokeMethod == "") {
        RESTError << "no task specified for TRestTask!!!" << RESTendl;
        exit(-1);
    } else {
        if (fMode == TASK_MACRO) {
            // call gInterpreter to run a command
            for (unsigned int i = 0; i < fArgumentValues.size(); i++) {
                if (fArgumentValues[i] == "NOT SET") {
                    RESTError << "TRestTask : argument " << i << " not set! Task will not run!" << RESTendl;
                }
            }
 
            fConstructedCommand = fInvokeMethod + "(";
            for (unsigned int i = 0; i < fArgumentValues.size(); i++) {
                if (fArgumentTypes[i] == 1) {
                    fConstructedCommand += "\"" + Replace(fArgumentValues[i], "\\", "\\\\", 0) + "\"";
                } else {
                    fConstructedCommand += fArgumentValues[i];
                }
 
                if (i < fArgumentValues.size() - 1) fConstructedCommand += ",";
            }
            fConstructedCommand += ")";
 
            cout << "Command : " << fConstructedCommand << endl;
 
            gInterpreter->ProcessLine(fConstructedCommand.c_str());
            return;
        } else if (fMode == TASK_CPPCMD) {
            //
            if (mgr == nullptr) {
                RESTError << "no target specified for the command:" << RESTendl;
                RESTError << fConstructedCommand << RESTendl;
                exit(-1);
            } else {
                TRestMetadata* meta = mgr->GetMetadata(fInvokeObject);
                if (meta == nullptr) {
                    RESTError << "cannot file metadata: " << fInvokeObject << " in TRestManager" << RESTendl;
                    RESTError << "command: " << fConstructedCommand << RESTendl;
                    exit(-1);
                } else {
                    string type = meta->ClassName();
                    string cmd = Form("%s* %s = (%s*)%s;", type.c_str(), fInvokeObject.c_str(), type.c_str(),
                                      (PTR_ADDR_PREFIX + ToString(meta)).c_str());
 
                    TInterpreter::EErrorCode err;
                    gInterpreter->ProcessLine(cmd.c_str(), &err);
                    if (err != TInterpreter::kNoError) {
                        RESTError << "TRestTask::RunTask(): unknown error" << RESTendl;
                        RESTError << "code: " << err << RESTendl;
                        exit(-1);
                    }
                    gInterpreter->ProcessLine(fConstructedCommand.c_str(), &err);
                    if (err != TInterpreter::kNoError) {
                        RESTError << "TRestTask: failed to execute cpp command, error code: " << err
                                  << RESTendl;
                        RESTError << fConstructedCommand << RESTendl;
                        RESTError << "Check your <AddTask section!" << RESTendl;
                        exit(-1);
                    }
                }
            }
        } else if (fMode == TASK_SHELLCMD) {
            int z = system(fConstructedCommand.c_str());
            if (z != 0) RESTError << "Problem launching : " << fConstructedCommand << RESTendl;
        }
    }
}
 
void TRestTask::PrintArgumentHelp() {
    if (fMode == 0) {
        RESTError << fInvokeMethod << "() Gets invalided input!" << RESTendl;
        cout << "You should give the following arguments (* is mandatory input):" << endl;
        unsigned int n = fArgumentNames.size();
        for (unsigned int i = 0; i < n; i++) {
            cout << (i < fNRequiredArgument ? "*" : "") << fArgumentNames[i] << endl;
        }
    } else if (fMode == 1) {
    } else if (fMode == 2) {
        RESTError << "Macro class \"" << this->ClassName() << "\" gets invalided input!" << RESTendl;
        RESTError << "You should give the following arguments ( * : necessary input):" << RESTendl;
        unsigned int n = RESTValue(this).GetNumberOfDataMembers();
        for (unsigned int i = 1; i < n; i++) {
            if (i < fNRequiredArgument + 1) RESTError << "*";
            RESTError << RESTValue(this).GetDataMember(i).name << RESTendl;
        }
    }
}
 
TRestTask* TRestTask::GetTaskFromMacro(TString taskName) {
// string macfile = TRestTools::SearchFileInPath({REST_PATH + "/macros"}, "REST_" + (string)taskName + ".C")
#ifdef WIN32
    auto macfiles = TRestTools::GetFilesMatchingPattern(REST_PATH + "/macros/*" + (string)taskName + ".*");
#else
    string macfilelists =
        TRestTools::Execute("find $REST_PATH/macros -name *" + (string)taskName + (string) ".*");
    auto macfiles = Split(macfilelists, "\n");
#endif
 
    if (macfiles.size() != 0 && macfiles[0] != "") {
        RESTInfo << "Found MacroFile " << macfiles[0] << TRestStringOutput::RESTendl;
        // system("echo \"#define REST_MANAGER\" > /tmp/tmpMacro.c");
        // system(("cat " + macfiles[0] + " >> /tmp/tmpMacro.c").c_str());
        if (gInterpreter->LoadFile(macfiles[0].c_str()) == 0) {
            TRestTask* tsk = new TRestTask(macfiles[0].c_str(), TASK_MACRO);
            if (tsk->GetMode() == TASK_ERROR) {
                RESTError
                    << "Task file: " << macfiles[0]
                    << " loaded but method not found. Make sure it contains the method with same name as "
                       "file name"
                    << TRestStringOutput::RESTendl;
                return nullptr;
            }
            return tsk;
        } else {
            RESTError << "Task file: " << macfiles[0] << " contains error" << TRestStringOutput::RESTendl;
            return nullptr;
        }
 
    } else {
        // initialize from a class which is inherited from TRestTask
        TRestTask* tsk = REST_Reflection::Assembly((string)taskName);
        if (tsk != nullptr && tsk->InheritsFrom("TRestTask")) {
            tsk->SetMode(TASK_CLASS);
            return tsk;
        }
    }
    RESTError << "REST ERROR. Task : " << taskName << " not found!!" << TRestStringOutput::RESTendl;
    return nullptr;
}
 
TRestTask* TRestTask::GetTaskFromCommand(TString cmd) {
    REST_TASKMODE mode = TASK_CPPCMD;
    if (((string)cmd).find("->") == string::npos) mode = TASK_SHELLCMD;
 
    auto tsk = new TRestTask(cmd, mode);
    if (tsk->GetMode() == TASK_ERROR) {
        delete tsk;
        return nullptr;
    } else {
        return tsk;
    }
}