Function TestCrash

service/lifecycle_test.go:51–81

(t *testing.T)

}

func TestCrash(t *testing.T) {
	s := newTestService("Test service")
	l := service.NewLifecycle(s)
	starting := make(chan bool)
	running := make(chan bool)
	crashed := make(chan bool, 1)
	l.OnStarting(func(s service.Service, l service.Lifecycle) {
		starting <- true
	})
	l.OnRunning(func(s service.Service, l service.Lifecycle) {
		running <- true
	})
	l.OnCrashed(func(s service.Service, l service.Lifecycle, err error) {
		crashed <- true
	})
	l.OnStopped(func(s service.Service, l service.Lifecycle) {
		t.Fail()
	})
	l.OnStopping(func(s service.Service, l service.Lifecycle, shutdownContext context.Context) {
		t.Fail()
	})
	go func() {
		if err := l.Run(); err == nil {
			assert.Fail(t, "service did not crash")
		}
	}()
	<-starting
	<-running
	s.Crash()
	<-crashed
}