Changeset 15754

Timestamp:

Dec 6, 2007, 3:44:20 PM (18 years ago)

Author:

eugene

Message:

add command to reset task stats

Location:

trunk/Ohana/src/opihi

Files:

• include/pantasks.h (modified) (1 diff)
• pantasks/TaskOps.c (modified) (1 diff)
• pantasks/status.c (modified) (2 diffs)

trunk/Ohana/src/opihi/include/pantasks.h

@@ -181 +181 @@
 Task *SetNewTask (Task *task);
 void ListTaskStats (char *regex);
+void ResetTaskStats (char *regex);
 void UpdateTaskTimerStats (Task *task, int mode, double dtime);
 

trunk/Ohana/src/opihi/pantasks/TaskOps.c

@@ -216 +216 @@
 }
 
+/* list known tasks */
+void ResetTaskStats (char *regex) {
+
+  int i, valid, nameLength;
+  char format[128];
+  regex_t preg;
+
+  if (Ntasks == 0) {
+    return;
+  }
+
+  if (regex != NULL) {
+    regcomp (&preg, regex, REG_EXTENDED);
+  }
+
+  /* find string lengths */
+  nameLength = 0;
+  for (i = 0; i < Ntasks; i++) {
+    nameLength = MAX (nameLength, strlen(tasks[i][0].name));
+  }
+
+  for (i = 0; i < Ntasks; i++) {
+      
+    if ((regex != NULL) && regexec (&preg, tasks[i][0].name, 0, NULL, 0)) continue;
+
+    tasks[i][0].Njobs = 0;
+    tasks[i][0].dtimeMin_alljobs = 0;
+    tasks[i][0].dtimeAve_alljobs = 0;
+    tasks[i][0].dtimeMax_alljobs;
+
+    tasks[i][0].Nsuccess = 0;
+    tasks[i][0].dtimeMin_success = 0;
+    tasks[i][0].dtimeAve_success = 0;
+    tasks[i][0].dtimeMax_success = 0;
+
+    tasks[i][0].Nfailure = 0;
+    tasks[i][0].dtimeMin_failure = 0;
+    tasks[i][0].dtimeAve_failure = 0;
+    tasks[i][0].dtimeMax_failure = 0;
+  }
+  return;
+}
+
 /* show details of a task */
 int ShowTask (char *name) {

trunk/Ohana/src/opihi/pantasks/status.c

@@ -31 +31 @@
   }
 
+  if ((N = get_argument (argc, argv, "-taskstatsreset"))) {
+    remove_argument (N, &argc, argv);
+    if (argc == 2) {
+      ResetTaskStats (argv[N]);
+    } else {
+      ResetTaskStats (NULL);
+    }      
+    return (TRUE);
+  }
+
   gprint (GP_LOG, "\n");
   if (CheckTasksGetState()) {
@@ -56 +66 @@
   gprint (GP_LOG, "       -taskinfo  : details for tasks\n");
   gprint (GP_LOG, "       -taskstats : processing statistics for tasks\n");
+  gprint (GP_LOG, "       -taskstatsreset : reset processing statistics for tasks\n");
   return (FALSE);
 }