97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
(if (not (file-exists? softlocks-dir))
(create-directory softlocks-dir #t))
(let* ((my-lock-file (conc softlocks-dir "/" key "-" (get-host-name) "-" (current-process-id) ".softlock"))
(lock-files (filter (lambda (x)
(not (equal? x my-lock-file)))
(glob (conc softlocks-dir "/" key "*.softlock"))))
(fresh-locks (any (lambda (x) ;; do we have any locks younger than 10 seconds
(let ((mod-time (file-modification-time x)))
(cond
((> (- (current-seconds) mod-time) 3600) ;; too old to keep, remove it
(delete-file* x) #f)
((< mod-time 10) #t)
(else #f))))
lock-files)))
(if fresh-locks
(begin
(if (runs:lownoise "runners-softlock-wait" 360)
(debug:print-info 0 *default-log-port* "Other runners in flight, giving up some time..."))
(thread-sleep! 10))
(begin
(if (runs:lownoise "runners-softlock-nowait" 360)
(debug:print-info 0 *default-log-port* "No runners in flight, updating softlock"))
(with-output-to-file my-lock-file
(lambda ()
(print (current-seconds))))))
(runs:dat-last-fuel-check-set! rdat (current-seconds))))))
;; Fourth try, do accounting through time
;;
(define (runs:parallel-runners-mgmt rdat)
(let ((time-to-check 10) ;; 28
(time-to-wait 12)
|
|
>
|
|
>
|
<
|
>
|
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
(if (not (file-exists? softlocks-dir))
(create-directory softlocks-dir #t))
(let* ((my-lock-file (conc softlocks-dir "/" key "-" (get-host-name) "-" (current-process-id) ".softlock"))
(lock-files (filter (lambda (x)
(not (equal? x my-lock-file)))
(glob (conc softlocks-dir "/" key "*.softlock"))))
(fresh-locks (any (lambda (x) ;; do we have any locks younger than 10 seconds
(let* ((mod-time (file-modification-time x))
(age (- (current-seconds) mod-time)))
(cond
((> age 3600) ;; too old to keep, remove it
(delete-file* x) #f)
((< age 10) #t)
(else #f))))
lock-files)))
(if fresh-locks
(begin
(if (runs:lownoise "runners-softlock-wait" 360)
(debug:print-info 0 *default-log-port* "Other runners in flight, giving up some time..."))
(thread-sleep! 10))
(begin
(if (runs:lownoise "runners-softlock-nowait" 360)
(debug:print-info 0 *default-log-port* "No runners in flight, updating softlock"))
(let* ((ouf (open-output-file my-lock-file)))
(with-output-to-port ouf
(lambda ()(print (current-seconds))))
(close-output-port ouf))))
(runs:dat-last-fuel-check-set! rdat (current-seconds))))))
;; Fourth try, do accounting through time
;;
(define (runs:parallel-runners-mgmt rdat)
(let ((time-to-check 10) ;; 28
(time-to-wait 12)
|