src/progress.c

   1 #ifndef __NEATCC__
   2 #include <stdlib.h>
   3 #include <string.h>
   4 #include <time.h>
   5
   6 #include "jam.h"
   7 #include "lists.h"
   8 #include "parse.h"
   9 #include "rules.h"
  10 #include "newstr.h"
  11 #include "hash.h"
  12 #include "variable.h"
  13 #include "search.h"
  14
  15 #include "progress.h"
  16
  17
  18 #define PROGRESS_WINDOW  (10)
  19
  20
  21 typedef struct {
  22   time_t when;
  23   int completed;
  24 } TIMESTAMP;
  25
  26
  27 struct _PROGRESS {
  28   int total;
  29   int stampcount;
  30   TIMESTAMP stamps[PROGRESS_WINDOW];
  31 };
  32
  33
  34 static double getTimeDelta (void) {
  35   static double res = 10.0;
  36   static int checked = 0;
  37   //
  38   if (!checked) {
  39     LIST *var = var_get("K8JAM-PROGRESS-TIME-DELTA"); /*FIXME: a perfectly idiotic name*/
  40     if (var) {
  41       TARGET *t = bindtarget(var->string);
  42       pushsettings(t->settings);
  43       t->boundname = search(t->name, &t->time);
  44       popsettings(t->settings);
  45       if (t->boundname) {
  46         res = atof(t->boundname);
  47         if (res < 0.0) res = 0.0;
  48       }
  49       checked = 1;
  50     }
  51   }
  52   return res;
  53 }
  54
  55
  56 #define LAST_STAMP(p)   ((p)->stamps[(p)->stampcount-1])
  57 #define FIRST_STAMP(p)  ((p)->stamps[0])
  58
  59
  60 PROGRESS *progress_start (int total) {
  61   PROGRESS *p = malloc(sizeof(PROGRESS));
  62   p->total = total;
  63   p->stampcount = 0;
  64   progress_update(p, 0);
  65   return p;
  66 }
  67
  68
  69 static double progress_estimate (PROGRESS *progress) {
  70   int count;
  71   int left;
  72   double elapsed;
  73   double rate;
  74   //
  75   if (progress->stampcount < 2) return 0.0;
  76   count = LAST_STAMP(progress).completed-FIRST_STAMP(progress).completed;
  77   left = progress->total-LAST_STAMP(progress).completed;
  78   elapsed = (double)(LAST_STAMP(progress).when-FIRST_STAMP(progress).when);
  79   if (elapsed <= 0.1) elapsed = 0.1;
  80   rate = count/elapsed;
  81   return left/rate;
  82 }
  83
  84
  85 double progress_update (PROGRESS *progress, int completed) {
  86   time_t now;
  87   double dd = getTimeDelta();
  88   //
  89   time(&now);
  90   /* only return progress every 10 seconds */
  91   if (progress->stampcount > 0 && (dd <= 0.00001 || difftime(now, LAST_STAMP(progress).when) < dd)) return 0.0;
  92   if (progress->stampcount == PROGRESS_WINDOW) {
  93     memmove(progress->stamps, progress->stamps+1, sizeof(progress->stamps[0])*(PROGRESS_WINDOW-1));
  94     --progress->stampcount;
  95   }
  96   ++progress->stampcount;
  97   LAST_STAMP(progress).completed = completed;
  98   LAST_STAMP(progress).when = now;
  99   return progress_estimate(progress);
 100 }
 101 #endif