Function TestOneServiceCrash

service/pool_test.go:76–124

(t *testing.T)

}

func TestOneServiceCrash(t *testing.T) {
	testLock := &sync.Mutex{}
	pool := service.NewPool(service.NewLifecycleFactory(), log.NewTestLogger(t))
	poolLifecycle := service.NewLifecycle(pool)
	poolStarted := make(chan bool)
	poolStopped := make(chan bool)
	var poolStates []service.State
	var serviceStates []service.State
	poolLifecycle.OnRunning(func(s service.Service, l service.Lifecycle) {
		poolStarted <- true
	})
	poolLifecycle.OnStateChange(func(s service.Service, l service.Lifecycle, state service.State) {
		testLock.Lock()
		defer testLock.Unlock()
		poolStates = append(poolStates, state)
	})

	s := newTestService("Test service")
	pool.Add(s).OnStateChange(func(s service.Service, l service.Lifecycle, state service.State) {
		testLock.Lock()
		defer testLock.Unlock()
		serviceStates = append(serviceStates, state)
	})

	go func() {
		err := poolLifecycle.Run()
		if err == nil {
			t.Fail()
		}
		poolStopped <- true
	}()

	<-poolStarted
	s.Crash()
	err := poolLifecycle.Wait()
	testLock.Lock()
	assert.NotNil(t, err)
	assert.Equal(t, []service.State{
		service.StateStarting,
		service.StateRunning,
		service.StateCrashed,
	}, serviceStates)
	assert.Equal(t, []service.State{
		service.StateStarting,
		service.StateRunning,
		service.StateCrashed,
	}, poolStates)
	testLock.Unlock()
}

func TestOneServiceStartupCrash(t *testing.T) {
	testLock := &sync.Mutex{}