File tree Expand file tree Collapse file tree 1 file changed +7
-7
lines changed Expand file tree Collapse file tree 1 file changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -26,7 +26,7 @@ import (
26
26
func reinitialize () {
27
27
notify .Store (make (chan struct {}))
28
28
done .Store (make (chan struct {}))
29
- hardShutdown . Store (true )
29
+ AllowSignalHardShutdown (true )
30
30
31
31
exitFunc .Store (func (code int ) {
32
32
fmt .Println ("Exiting" )
@@ -49,9 +49,9 @@ func TestListen(t *testing.T) {
49
49
Wait ()
50
50
51
51
go func () {
52
- <- ShutdownInitiated ()
53
52
m .Lock ()
54
53
defer m .Unlock ()
54
+ <- ShutdownInitiated ()
55
55
stopping = true
56
56
<- ShutdownComplete ()
57
57
stopped = true
@@ -86,9 +86,9 @@ func TestListen2(t *testing.T) {
86
86
var stopping , stopped bool
87
87
88
88
go func () {
89
- <- ShutdownInitiated ()
90
89
m .Lock ()
91
90
defer m .Unlock ()
91
+ <- ShutdownInitiated ()
92
92
stopping = true
93
93
<- ShutdownComplete ()
94
94
stopped = true
@@ -123,9 +123,9 @@ func TestListenTimeout(t *testing.T) {
123
123
var stopping , stopped bool
124
124
125
125
go func () {
126
- <- ShutdownInitiated ()
127
126
m .Lock ()
128
127
defer m .Unlock ()
128
+ <- ShutdownInitiated ()
129
129
stopping = true
130
130
<- ShutdownComplete ()
131
131
stopped = true
@@ -166,9 +166,9 @@ func TestListenTimeoutTimeout(t *testing.T) {
166
166
var stopping , stopped bool
167
167
168
168
go func () {
169
- <- ShutdownInitiated ()
170
169
m .Lock ()
171
170
defer m .Unlock ()
171
+ <- ShutdownInitiated ()
172
172
stopping = true
173
173
<- ShutdownComplete ()
174
174
stopped = true
@@ -209,9 +209,9 @@ func TestListenTimeoutDone(t *testing.T) {
209
209
var stopping , stopped bool
210
210
211
211
go func () {
212
- <- ShutdownInitiated ()
213
212
m .Lock ()
214
213
defer m .Unlock ()
214
+ <- ShutdownInitiated ()
215
215
stopping = true
216
216
<- ShutdownComplete ()
217
217
stopped = true
@@ -246,9 +246,9 @@ func TestListenTimeoutDoneNoHardShutdown(t *testing.T) {
246
246
var stopping , stopped bool
247
247
248
248
go func () {
249
- <- ShutdownInitiated ()
250
249
m .Lock ()
251
250
defer m .Unlock ()
251
+ <- ShutdownInitiated ()
252
252
stopping = true
253
253
<- ShutdownComplete ()
254
254
stopped = true
You can’t perform that action at this time.
0 commit comments