Overview
| Comment: | Added error handler for open-run-close with a random (up to two minutes) delay |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | test-specific-db | v1.46 |
| Files: | files | file ages | folders |
| SHA1: |
4dcf1382a6926b4343f56099d91c3222 |
| User & Date: | matt on 2012-09-27 17:59:10 |
| Other Links: | branch diff | manifest | tags |
Context
|
2012-09-27
| ||
| 22:22 | Added fossil signature to help check-in: 44cc049083 user: matt tags: test-specific-db, v1.4601 | |
| 17:59 | Added error handler for open-run-close with a random (up to two minutes) delay check-in: 4dcf1382a6 user: matt tags: test-specific-db, v1.46 | |
| 17:23 | Pulling back values for parallel test check-in: 1dd4b7f24f user: mrwellan tags: test-specific-db | |
Changes
Modified dashboard.scm from [9bc1b8f5fe] to [d1f6d7963a].
| ︙ | ︙ | |||
470 471 472 473 474 475 476 | iup:hbox (map (lambda (state) (iup:toggle state #:action (lambda (obj val) (mark-for-update) (if (eq? val 1) (hash-table-set! *state-ignore-hash* state #t) (hash-table-delete! *state-ignore-hash* state))))) | | | 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 |
iup:hbox
(map (lambda (state)
(iup:toggle state #:action (lambda (obj val)
(mark-for-update)
(if (eq? val 1)
(hash-table-set! *state-ignore-hash* state #t)
(hash-table-delete! *state-ignore-hash* state)))))
'("RUNNING" "COMPLETED" "INCOMPLETE" "LAUNCHED" "NOT_STARTED" "KILLED" "DELETED")))
(iup:valuator #:valuechanged_cb (lambda (obj)
(let ((val (inexact->exact (round (/ (string->number (iup:attribute obj "VALUE")) 10))))
(oldmax (string->number (iup:attribute obj "MAX")))
(maxruns *tot-run-count*))
(set! *start-run-offset* val)
(mark-for-update)
(debug:print 6 "*start-run-offset* " *start-run-offset* " maxruns: " maxruns ", val: " val " oldmax: " oldmax)
|
| ︙ | ︙ |
Modified db.scm from [3b6d743f09] to [76b911ed38].
| ︙ | ︙ | |||
65 66 67 68 69 70 71 |
(sqlite3:set-busy-handler! db handler)
(if (not dbexists)
(db:initialize db))
(db:set-sync db)
db))
(define (open-run-close proc idb . params)
| > | | | | | | > > > > > > > > > > | 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 |
(sqlite3:set-busy-handler! db handler)
(if (not dbexists)
(db:initialize db))
(db:set-sync db)
db))
(define (open-run-close proc idb . params)
(let ((runner (lambda ()
(let* ((db (if idb idb (open-db)))
(res #f))
(db:set-sync db)
(set! res (apply proc db params))
(if (not idb)(sqlite3:finalize! db))
res))))
(handle-exceptions
exn
(begin
(debug:print 0 "EXCEPTION: database probably overloaded?")
(debug:print 0 " " exn)
(print-call-chain)
(thread-sleep! (random 120))
(debug:print 0 "trying db call one more time....")
(runner))
(runner))))
(define *global-delta* 0)
(define *last-global-delta-printed* 0)
(define (open-run-close-measure proc idb . params)
(let* ((start-ms (current-milliseconds))
(db (if idb idb (open-db)))
|
| ︙ | ︙ |
Modified launch.scm from [843bb8d015] to [b831ce6e73].
| ︙ | ︙ | |||
121 122 123 124 125 126 127 | (kill-job? #f) (exit-info (vector #t #t #t)) (job-thread #f) (runit (lambda () ;; (let-values ;; (((pid exit-status exit-code) ;; (run-n-wait fullrunscript))) | | | 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 | (kill-job? #f) (exit-info (vector #t #t #t)) (job-thread #f) (runit (lambda () ;; (let-values ;; (((pid exit-status exit-code) ;; (run-n-wait fullrunscript))) (open-run-close test-set-status! #f test-id "RUNNING" "n/a" #f #f) ;; if there is a runscript do it first (if fullrunscript (let ((pid (process-run fullrunscript))) (let loop ((i 0)) (let-values (((pid-val exit-status exit-code) (process-wait pid #t))) (mutex-lock! m) |
| ︙ | ︙ |