annotated repo_test
This commit is contained in:
parent
fb911a4542
commit
b45924a234
@ -15,6 +15,7 @@ func TestMonitorShutdown(t *testing.T) {
|
|||||||
// Three shutdown handlers.
|
// Three shutdown handlers.
|
||||||
var wg sync.WaitGroup
|
var wg sync.WaitGroup
|
||||||
wg.Add(3)
|
wg.Add(3)
|
||||||
|
//stm: @NODE_SHUTDOWN_001
|
||||||
h := ShutdownHandler{
|
h := ShutdownHandler{
|
||||||
Component: "handler",
|
Component: "handler",
|
||||||
StopFunc: func(_ context.Context) error {
|
StopFunc: func(_ context.Context) error {
|
||||||
@ -23,6 +24,7 @@ func TestMonitorShutdown(t *testing.T) {
|
|||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//stm: @NODE_SHUTDOWN_002
|
||||||
finishCh := MonitorShutdown(signalCh, h, h, h)
|
finishCh := MonitorShutdown(signalCh, h, h, h)
|
||||||
|
|
||||||
// Nothing here after 10ms.
|
// Nothing here after 10ms.
|
||||||
|
Loading…
Reference in New Issue
Block a user