msgLogger.c

Go to the documentation of this file.

/*
 *Caius Howcroft<howcroft@hep.phy.cam.ac.uk>
 */

#include "minosDaq.h"
#include "msgLog.h"
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <argp.h>
 #include <time.h>
const char* argp_program_bug_address = "Caius Howcroft<howcroft@hep.phy.cam.ac.uk>";
const char* argp_program_version  = "msgLogger 0.1";
static char args_doc[] = "USER MESSAGE";

typedef struct arguments_t
{
  char prio[5];
  char message[100];   /*the user message*/
  int  nodeId;         /*current node id */         
  long pid;            /*Process ID*/
  char procname[126];  /*The prcess name*/
  long count;          /*the process count*/
  long stime;          /*the message timestamp*/
  int echo;            /*echo message to stdout*/

}arguments;


static const struct argp_option options[] =
{
  {"priority", 'l', "D1/D2/D3/I/N/W/E/C", 0, "Message Priority", 0},
  {"node", 'n', "INT", 0, "Minos Node ID", 0},
  {"name", 's', "PROCNAME", 0, "Process Name", 0},
  {0,  0, 0, 0,"Expert Actions:",0},
  {"count", 'c', "INT", 0, "Set message count number", 1},
  {"time", 't', "INT", 0, "Set message time (UNIX time)", 1},
  {"echo", 'e', 0, 0, "Echo message to stdout", 1},
  {"pid", 'p', "INT", 0, "Process PID", 0},
  {0}
};

static error_t parse_opt (int key, char *arg, struct argp_state *state)
{
  arguments* args = (arguments*)state->input;
  switch (key)
    {
    case 'l':
      strncpy(args->prio, arg, 5);
      break;
    case 'e':    
      args->echo = 1;
      break;
    case 'c':
      args->count = strtol(arg, (char**)NULL, 0);
      break;
    case 't':
      args->stime = strtol(arg, (char**)NULL, 0);
      break;
    case 's':
      strncpy(args->procname,arg , 126);
      break;
    case 'n':
      args->nodeId = strtol(arg, (char**)NULL, 0);
      break;
    case 'p':
      args->pid = strtol(arg, (char**)NULL, 0);
      break;
    case ARGP_KEY_ARG:
      return ARGP_ERR_UNKNOWN;
      break;
    case ARGP_KEY_ARGS:
      { 
        int i=0;
        for(i=state->next ; i<state->argc;++i)
          {
            strncat(args->message, " ", 100);
            strncat(args->message, state->argv[i], 100);        
          }
        break;
      }
    case ARGP_KEY_END:
      break;
    default:
      return ARGP_ERR_UNKNOWN;
    }
  return 0;
}

static const char doc[] =
"msgLogger - MINOS Logger script\v Forwards messages to Run Control over UDP.";

static struct argp argparms = {options, 
                               parse_opt, 
                               args_doc, 
                               doc};


int main(int argc, char** argv)
{
  long defaultId = MINOS_QUASI_ONLINE;
  //default args
  arguments dargs;
  strcpy(dargs.prio, "I");
  dargs.pid=getppid();
  strcpy(dargs.procname, "?");
  dargs.count=-1;
  dargs.stime = time(NULL);
  dargs.echo=0;
  dargs.nodeId = defaultId;
  strcpy(dargs.message, "");
  //process args
  argp_parse (&argparms, argc, argv, 0, 0, &dargs);
  
  msgLogInit(dargs.procname);
  msgLogNodeIdSet(dargs.nodeId);
  logDebugLevelSet(10);
  if(dargs.count!=-1) msgLogResetMsgCount(dargs.count);
  msgLogPidSet(dargs.pid);
  if(dargs.echo)msgLogLocalEchoSet(1);
  else msgLogLocalEchoSet(0);
  switch(dargs.prio[0])
    {
    case 'I':
    case 'i':
      logInfo("%s", dargs.message);
      break;
    case 'N':
    case 'n':
      logNotice("%s", dargs.message);
      break;
    case 'W':
    case 'w':
      logWarn("%s", dargs.message);
      break;
    case 'E':
    case 'e':
      logError("%s", dargs.message);
      break;
    case 'C':
    case 'c':
      logCritical("%s", dargs.message);
      break;
    case 'D':
    case 'd':
      {
        int dbl=0;
        switch(dargs.prio[1]){
        case '3':dbl=3; break;
        case '2':dbl=2; break;
        case '1':dbl=3; break;
        default: break;
        };
        logDebug(dbl, "%s", dargs.message);
        break;
      }
    };
  msgLogCleanup();
  return msgLogGetMsgCount();
}

---