1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
| | ;;; watchdog.scm -- Monitor fibers scheduling.
;;; This file is part of Cuirass.
;;;
;;; Cuirass is free software: you can redistribute it and/or modify
;;; it under the terms of the GNU General Public License as published by
;;; the Free Software Foundation, either version 3 of the License, or
;;; (at your option) any later version.
;;;
;;; Cuirass is distributed in the hope that it will be useful,
;;; but WITHOUT ANY WARRANTY; without even the implied warranty of
;;; MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
;;; GNU General Public License for more details.
;;;
;;; You should have received a copy of the GNU General Public License
;;; along with Cuirass. If not, see <http://www.gnu.org/licenses/>.
(define-module (cuirass watchdog)
#:use-module (cuirass logging)
#:use-module (cuirass utils)
#:use-module (fibers)
#:use-module (fibers channels)
#:use-module (fibers internal)
#:use-module (fibers operations)
#:use-module (ice-9 match)
#:use-module (ice-9 threads)
#:export (start-watchdog))
(define* (watchdog-fiber scheduler channel
#:key
timeout)
"Spawn a fiber running on SCHEDULER that sends over CHANNEL, every TIMEOUT
seconds, the scheduler name and the current time."
(spawn-fiber
(lambda ()
(while #t
(put-message channel (list (scheduler-name scheduler)
(current-time)))
(sleep timeout)))
scheduler))
(define* (start-watchdog #:key (timeout 5))
"Start a watchdog checking that each Fibers scheduler is not blocked for
more than TIMEOUT seconds.
The watchdog mechanism consists in spawning a dedicated fiber per running
Fiber scheduler, using the above watchdog-fiber method. Those fibers send a
ping signal periodically to a separate thread. If no signal is received from
one of the schedulers for more than TIMEOUT seconds, a warning message is
printed."
(define (check-timeouts pings)
(for-each
(match-lambda
((scheduler . time)
(let* ((cur-time (current-time))
(diff-ping (- cur-time time)))
(when (> diff-ping timeout)
(log-message "Scheduler ~a blocked since ~a seconds."
scheduler diff-ping)))))
pings))
(let ((watchdog-channel (make-channel)))
(parameterize (((@@ (fibers internal) current-fiber) #f))
(call-with-new-thread
(lambda ()
(let loop ((pings '()))
(let ((operation-timeout 2))
(match (perform-operation
(with-timeout
(get-operation watchdog-channel)
#:seconds operation-timeout
#:wrap (const 'timeout)))
((scheduler ping)
(loop (assq-set! pings scheduler ping)))
('timeout
(check-timeouts pings)
(loop pings))))))))
(fold-all-schedulers
(lambda (name scheduler seed)
(watchdog-fiber scheduler watchdog-channel
#:timeout timeout))
'())))
|