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
|
package test_helpers
import (
"sync"
"github.com/onsi/ginkgo/v2/internal/interrupt_handler"
)
type FakeInterruptHandler struct {
c chan interface{}
lock *sync.Mutex
level interrupt_handler.InterruptLevel
cause interrupt_handler.InterruptCause
interruptPlaceholderMessage string
emittedInterruptPlaceholderMessage string
}
func NewFakeInterruptHandler() *FakeInterruptHandler {
handler := &FakeInterruptHandler{
c: make(chan interface{}),
lock: &sync.Mutex{},
level: interrupt_handler.InterruptLevelUninterrupted,
}
return handler
}
func (handler *FakeInterruptHandler) Interrupt(cause interrupt_handler.InterruptCause) {
handler.lock.Lock()
handler.cause = cause
handler.level += 1
if handler.level > interrupt_handler.InterruptLevelBailOut {
handler.level = interrupt_handler.InterruptLevelBailOut
} else {
close(handler.c)
handler.c = make(chan interface{})
}
handler.lock.Unlock()
}
func (handler *FakeInterruptHandler) Status() interrupt_handler.InterruptStatus {
handler.lock.Lock()
defer handler.lock.Unlock()
return interrupt_handler.InterruptStatus{
Channel: handler.c,
Level: handler.level,
Cause: handler.cause,
}
}
|
