blob: 23c9ad84b9f76de7b29e7e047e3cea9e06a59010 (
plain)
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
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
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
;;;; session-related tests
;;;; This software is part of the SBCL system. See the README file for
;;;; more information.
;;;;
;;;; While most of SBCL is derived from the CMU CL system, the test
;;;; files (like this one) were written from scratch after the fork
;;;; from CMU CL.
;;;
;;;; This software is in the public domain and is provided with
;;;; absoluely no warranty. See the COPYING and CREDITS files for
;;;; more information.
#-sb-thread (invoke-restart 'run-tests::skip-file)
(setf sb-unix::*on-dangerous-wait* :error)
(defun make-quiet-io-stream (&key
(input (make-synonym-stream '*standard-input*))
(output (make-broadcast-stream)))
(make-two-way-stream input output))
(defun get-foreground-quietly ()
(let ((*query-io* (make-quiet-io-stream)))
(sb-thread:get-foreground)))
;; this used to deadlock on session-lock
(with-test (:name (:no-session-deadlock))
(make-join-thread (lambda () (sb-ext:gc))))
(with-test (:name (:make-thread-while-holding-session-lock))
(let ((thr1 nil)
(thr2 nil)
(sem1 (sb-thread:make-semaphore))
(sem2 (sb-thread:make-semaphore)))
(sb-thread::with-session-lock (sb-thread::*session*)
(setq thr1 (sb-thread:make-thread
#'sb-thread:signal-semaphore :arguments sem1)
thr2 (sb-thread:make-thread
#'sb-thread:signal-semaphore :arguments sem2))
;; This used to hang right here because threads could not make progress
;; in their lisp-side trampoline.
(sb-thread:wait-on-semaphore sem1)
(sb-thread:wait-on-semaphore sem2))
(sb-thread:join-thread thr1)
(sb-thread:join-thread thr2)))
(with-test (:name (:debugger-no-hang-on-session-lock-if-interrupted)
:broken-on :win32)
(sb-debug::enable-debugger)
(let ((main-thread sb-thread:*current-thread*))
(make-join-thread
(lambda ()
(sleep 2)
(sb-thread:interrupt-thread
main-thread (lambda ()
(sb-thread::with-interrupts
(break))))
(sleep 2)
(sb-thread:interrupt-thread main-thread #'continue))
:name "interruptor"))
;; Somewhat verify output.
(let* ((error-output (make-string-output-stream))
(debug-output (make-string-output-stream)))
(let ((*error-output* error-output)
(*debug-io* (make-quiet-io-stream :output debug-output)))
(sb-thread::with-session-lock (sb-thread::*session*)
(sleep 3)))
(let ((output (get-output-stream-string error-output)))
(assert (search "debugger invoked" output))
(assert (search "break" output)))
(let ((output (get-output-stream-string debug-output)))
(assert (search "Type HELP for debugger help" output))
(assert (search "[CONTINUE" output))
(assert (search "Return from BREAK" output)))))
;;; The sequence of actions in this test creates a situation in which
;;; the list of interactive threads of the current session contains a
;;; single thread.
(with-test (:name (sb-thread:get-foreground :infinite-loop :bug-1682671))
(let ((state nil)
(lock (sb-thread:make-mutex :name "get-foreground test lock"))
(variable (sb-thread:make-waitqueue :name "get-foreground test waitqueue")))
(flet ((enter-state (new-state)
(sb-thread:with-mutex (lock)
(setf state new-state)
(sb-thread:condition-notify variable)))
(wait-for-state (goal)
(sb-thread:with-mutex (lock)
(loop :until (eq state goal) :do
(sb-thread:condition-wait variable lock)))))
(make-join-thread (lambda ()
(enter-state :ready)
(get-foreground-quietly)
(enter-state :done))
:name "get-foreground test thread 2")
(wait-for-state :ready)
(sb-thread:release-foreground)
(wait-for-state :done)
(get-foreground-quietly))))
(with-test (:name (sb-thread:release-foreground :bug-1682867))
(let ((thread (make-join-thread (lambda ())
:name "release-foreground test thread")))
(sb-thread:release-foreground thread)
(let ((interactive-threads
(sb-thread::with-session-lock (sb-thread::*session*)
(copy-list (sb-thread::interactive-threads)))))
(assert (not (member sb-thread::*current-thread*
interactive-threads))))))
;;; On termination, interactive (including foreground) threads remove
;;; themselves from the list of interactive threads in their
;;; session. However, this did not previously include notifying the
;;; interactive threads waitqueue, resulting in GET-FOREGROUND hanging
;;; after termination of the previous foreground thread.
(with-test (:name (sb-thread:get-foreground :hang :missing-broadcast))
(let ((thread (make-join-thread
(lambda () (sleep 1))
:name "get-foreground hang missing-broadcast test")))
(sb-thread:release-foreground thread)
(get-foreground-quietly)))
;;; Releasing foreground to an already dead thread previously made the
;;; dead thread the foreground thread. At that point, all succeeding
;;; GET-FOREGROUND calls would just hang.
(with-test (:name (sb-thread:get-foreground :hang :already-dead))
(let ((thread (sb-thread:make-thread
(lambda ())
:name "get-foreground hang already-dead test")))
(sb-thread:join-thread thread)
(sb-thread:release-foreground thread)
(get-foreground-quietly)))
(with-test (:name :new-session)
(let ((old-session sb-thread::*session*))
(sb-thread:with-new-session ()
(let ((new-session sb-thread::*session*))
(assert (not (eq old-session new-session)))
;; this thread should not be in session-threads of the old session
(assert (not (member sb-thread:*current-thread*
(sb-thread::session-threads old-session))))
(assert (member sb-thread:*current-thread*
(sb-thread::session-threads new-session)))))))
|
