JobCPathHandler.cxx

Go to the documentation of this file.

// $Id: JobCPathHandler.cxx,v 1.4 2009/02/28 21:46:13 gmieg Exp $
//
// Interface between JobCommand's and JobCPath classes
//
// messier@huhepl.harvard.edu
#include <cstring> // strcmp()

#include "JobControl/JobCPathHandler.h"
#include "MessageService/MsgService.h"
#include "JobControl/JobCommand.h"
#include "JobControl/JobCPath.h"
#include "JobControl/JobCNode.h"

CVSID("$Id: JobCPathHandler.cxx,v 1.4 2009/02/28 21:46:13 gmieg Exp $");

//......................................................................

static void sorry(const char* method) 
{
  MSG("JobC",Msg::kWarning) << 
    "Sorry, method " << method << " not implemented." << endl;
}

//......................................................................

JobCPathHandler::JobCPathHandler() : fPath(0) { }

//......................................................................

JobCPathHandler::JobCPathHandler(JobCPath* p) : fPath(p) { }

//......................................................................

JobCPathHandler::~JobCPathHandler() { }

//......................................................................

void JobCPathHandler::HandleCommand(JobCommand *cmd) 
{
//======================================================================
// Purpose: Switch yard for commands that act on paths as a whole
// 
// Inputs: path - the job path to act on
//         cmd  - the job command to use to decide how to act on the 
//                path
//======================================================================
  const char *c = cmd->PopCmd();
  if (c) {
    if (strcmp(c,"Run")==0)    {this->PathRunCommand   (fPath, cmd); return;}
    if (strcmp(c,"Filter")==0) {this->PathFilterCommand(fPath, cmd); return;}
    if (strcmp(c,"Report")==0) {this->PathReportCommand(fPath, cmd); return;}
    if (strcmp(c,"Reset")==0)  {this->PathResetCommand (fPath, cmd); return;}
    MSG("JobC", Msg::kWarning) << 
      "Unknown command '" << c << "'." <<
      " Try one of the following:\n" <<
      " Run,Filter,Report,Reset\n";
  }
}

//......................................................................

void JobCPathHandler::PathRunCommand(JobCPath *p, JobCommand *cmd) 
{
//======================================================================
// Purpose: handle a /<path>/Run [Nin,Npass,Nfail] [n] command
//
// Inputs: p   - the path <path>
//         cmd - the job command
//======================================================================
  // Figure out how many options we've been given
  const char* c[2];
  int nopt = 0;
  while (cmd->HaveOpt() && nopt<2) {
    c[nopt] = cmd->PopOpt();
    ++nopt;
  }

  // No options - run until there are no records left to process
  if (nopt == 0) {
    p->Run();
    return;
  }

  // One option -- assume this is some number of events to process
  if (nopt == 1) {
    int n = atoi(c[0]);
    p->RunNin(n);   
    return;
  }

  // Two options -- [Nin,Npass,Nfail] [# records]
  if (nopt == 2) {
    int n = atoi(c[1]);
    if (strcmp(c[0],"Nin")==0)   { p->RunNin(n);   return; }
    if (strcmp(c[0],"Npass")==0) { p->RunNpass(n); return; }
    if (strcmp(c[0],"Nfail")==0) { p->RunNfail(n); return; }
  }
  
  // Errors fall through
  const char* nm = p->GetName();
  MSG("JobC", Msg::kWarning) << 
    "usage: \n" 
    " " << nm << "/Run Nin   [n] - run until n records have been input\n" <<
    " " << nm << "/Run Npass [n] - run until n records pass\n"
    " " << nm << "/Run Nfail [n] - run until n records fail\n"
    " " << nm << "/Run [n]       - same as /Run Nin [n]\n";
}

//......................................................................

void JobCPathHandler::PathFilterCommand(JobCPath* p, JobCommand* cmd) 
{ 
//======================================================================
// Purpose: Process filter command
//======================================================================
  while (cmd->HaveOpt()) {
    const char* node  = cmd->PopOpt();
    const char* onOff = cmd->PopOpt();
    if (node == 0 || onOff == 0) {
      MSG("JobC",Msg::kWarning) <<
        "Usage: Filter <module>::<method> [on,reverse,off] ...\n" <<
        "       Filter all [on,off]\n";
      return;
    }
    
    string onOffs(onOff);
    string nodes(node);
    if (nodes == "ALL" || nodes == "all") {
      if (onOffs == "on" || onOffs == "ON") {
        p->SetAllFilters(true);
        return;
      }
      else if (onOffs == "reverse" || onOffs == "REVERSE") {
        p->ReverseAllFilters();
        return;
      }
    }
    
    // Get the module method pair that describe the node
    string mod;
    string method;
    JobCommand::SplitLine(node,':',mod,method);
    JobCNode* nodep = p->FindNode(mod.c_str(), method.c_str());
    if (nodep == 0) {
      MSG("JobC",Msg::kWarning) <<
        "Can't find node " << mod << "::" << method << ". Skipped.\n";
    }
    else {
      if (onOffs == "on" || onOffs == "ON") {
        nodep->FilterOn();
      }
      else if (onOffs == "reverse" || onOffs == "REVERSE") {
        nodep->ReverseFilter();
      }
      else {
        nodep->FilterOff();
      }
    }
  }
}

//......................................................................

void JobCPathHandler::PathReportCommand(JobCPath* p, JobCommand* /*cmd*/) 
{ 
//======================================================================
// Purpose: Print the status of a given path
//======================================================================
  MSG("JobC",Msg::kInfo) << (*p) << endl;
}

//......................................................................

void JobCPathHandler::PathResetCommand(JobCPath* /*p*/, 
                                       JobCommand* /*cmd*/)  
{ 
  sorry("PathResetCommand"); 
}

---