apps/core
1
0
Fork 0
mirror of https://github.com/datarhei/core.git synced 2025-10-06 00:17:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix test

Browse Source
This commit is contained in:
Ingo Oppermann
2023-05-01 16:39:47 +02:00
parent ef138fb90f
commit c23722416b
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
process/process_test.go
View File

@@ -42,14 +42,20 @@ func TestProcess(t *testing.T) {
} }
func TestReconnectProcess(t *testing.T) { func TestReconnectProcess(t *testing.T) {
wg := sync.WaitGroup{}
wg.Add(1)
p, _ := New(Config{ p, _ := New(Config{
Binary: "sleep", Binary: "sleep",
Args: []string{ Args: []string{
"2", "2",
}, },
Reconnect: true, Reconnect: true,
ReconnectDelay: 2 * time.Second, ReconnectDelay: 10 * time.Second,
StaleTimeout: 0, StaleTimeout: 0,
OnExit: func(string) {
wg.Done()
},
}) })
p.Start() p.Start()
@@ -62,6 +68,8 @@ func TestReconnectProcess(t *testing.T) {
return p.Status().State == "finished" return p.Status().State == "finished"
}, 10*time.Second, 500*time.Millisecond) }, 10*time.Second, 500*time.Millisecond)
wg.Wait()
require.Greater(t, p.Status().Reconnect, time.Duration(0)) require.Greater(t, p.Status().Reconnect, time.Duration(0))
p.Stop(false) p.Stop(false)