1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
1161
1162
1163
1164
|
(all-tests-registry (runs:dat-all-tests-registry runsdat))
(run-limits-info (runs:dat-can-run-more-tests runsdat))
;; (runs:can-run-more-tests run-id jobgroup max-concurrent-jobs)) ;; look at the test jobgroup and tot jobs running
(have-resources (and (if *journal-stats*
(let* ((dbfname (conc
(dbfile:run-id->dbnum run-id)
".db"))
(stats (tt:get-journal-stats))
(load (or (alist-ref dbfname stats equal?) 0)))
(if (> load 0.1) ;; dbs too busy to start more tests
(begin
(debug:print-info 0 *default-log-port* "Gating launch due to db load "load" based on journal file observations for "dbfname)
#f)
#t))
#t) ;; if journal monitoring not started do not gate
(car run-limits-info)))
|
|
<
|
1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
1161
1162
1163
|
(all-tests-registry (runs:dat-all-tests-registry runsdat))
(run-limits-info (runs:dat-can-run-more-tests runsdat))
;; (runs:can-run-more-tests run-id jobgroup max-concurrent-jobs)) ;; look at the test jobgroup and tot jobs running
(have-resources (and (if *journal-stats*
(let* ((dbfname (conc
(dbfile:run-id->dbnum run-id)
".db"))
(load (tt:get-journal-stats dbfname)))
(if (> load 0.1) ;; dbs too busy to start more tests
(begin
(debug:print-info 0 *default-log-port* "Gating launch due to db load "load" based on journal file observations for "dbfname)
#f)
#t))
#t) ;; if journal monitoring not started do not gate
(car run-limits-info)))
|