Changeset 11055 for trunk/Ohana/src/opihi/include/pantasks.h

Timestamp:

Jan 11, 2007, 4:51:41 PM (20 years ago)

Author:

eugene

Message:

added timing stats, npending limit

File:

• trunk/Ohana/src/opihi/include/pantasks.h (modified) (6 diffs)

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

@@ -28 +28 @@
 
 enum {RANGE_ABS, RANGE_DAY, RANGE_WEEK};
+enum {TIMER_ALLJOBS, TIMER_SUCCESS, TIMER_FAILURE};
 
 enum {TASK_NONE, 
@@ -42 +43 @@
       TASK_OPTIONS, 
       TASK_PERIODS, 
+      TASK_NPENDING, 
       TASK_EXIT, 
       TASK_EXEC
@@ -86 +88 @@
   int     Njobs;
 
+  int     Npending;  // number of currently pending jobs
+  int     NpendingMax;  // max number of pending jobs allowed
+
   float   poll_period;
   float   exec_period;
@@ -95 +100 @@
   int Nfailure;
   int Ntimeout;
+
+  double dtimeAve_alljobs, dtimeMin_alljobs, dtimeMax_alljobs;
+  double dtimeAve_success, dtimeMin_success, dtimeMax_success;
+  double dtimeAve_failure, dtimeMin_failure, dtimeMax_failure;
 
   int active;
@@ -140 +149 @@
   int         stdout_fd;                /* stdout pipe (local only) */
   int         stderr_fd;                /* stderr pipe (local only) */
+
+  double dtime;
 } Job;
 
@@ -167 +178 @@
 int RemoveTask (Task *task);
 Task *SetNewTask (Task *task);
+void ListTaskStats ();
+void UpdateTaskTimerStats (Task *task, int mode, double dtime);
 
 int NextJobID ();