59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
-
-
-
+
+
+
-
-
+
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
-
-
-
-
-
+
+
+
+
-
-
-
+
+
+
-
+
-
+
|
(defstruct runs:testdat
hed tal reg reruns test-record
test-name item-path jobgroup
waitons testmode newtal itemmaps prereqs-not-met)
;; Fourth try, do accounting through time
;;
(define (runs:parallel-runners-mgmt-4 rdat)
(let ((time-to-check 2.8) ;; 28
(time-to-wait 3.0)
(define (runs:parallel-runners-mgmt rdat)
(let ((time-to-check 10) ;; 28
(time-to-wait 12)
(now-time (current-seconds)))
(if (> (- now-time (runs:dat-last-fuel-check rdat)) time-to-check) ;; time to check
(let* ((mgmt-mode (runs:dat-runners-mgmt-mode rdat)) ;;
(fuel-used (rmt:get-var "runners-fuel")))
(cond
((not fuel-used) ;; first in, initialize to 1
(debug:print-info 0 *default-log-port* " adjusting num-runners up to 1, currently it is not defined")
(rmt:set-var "fuel-used" now-time)
(set! fuel-used now-time)
(runs:dat-last-fuel-check-set! rdat now-time))
(else ;; add fuel used since last time
(rmt:add-var "fuel-used" (- now-time (runs:dat-last-fuel-check rdat)))))
(if (> fuel-used now-time) ;; are we over-drawn? If so, kill time, do not add time to fuel used
(begin ;; gonna rest
(debug:print-info 0 *default-log-port* "Too much fuel used, taking a break. fuel-used="
fuel-used ", now-time=" now-time)
(thread-sleep! time-to-wait)
(runs:dat-last-fuel-check-set! rdat (current-seconds)) ;; work done from here (i.e. seconds of "fuel") will be added to fuel-used
)
(begin ;; no fuel deficit, back to work
(debug:print-info 0 *default-log-port* "No deficit, keep running"))
)))))
((or proc runs:parallel-runners-mgmt-4) rdat)
((or proc runs:parallel-runners-mgmt) rdat)
(let loop ()
(let* ((wstart (current-seconds)))
(if (< wstart endt)
(let* ((work-time (random 10)))
#;(debug:print-info 0 *default-log-port* "working for " work-time
" seconds. Total work: " rtime ", elapsed time: " (- wstart startt))
(thread-sleep! work-time)
(set! rtime (+ rtime work-time))
((or proc runs:parallel-runners-mgmt-4) rdat)
((or proc runs:parallel-runners-mgmt) rdat)
(loop)))))
(let* ((done-time (current-seconds)))
(debug:print-info 0 *default-log-port* "DONE: rtime=" rtime ", elapsed time=" (- done-time startt)
", ratio=" (/ rtime (- done-time startt))))))
;; ;; Third try, use a running average
;; ;;
|