Function TestOneServiceStartupCrash

service/pool_test.go:126–169

(t *testing.T)

}

func TestOneServiceStartupCrash(t *testing.T) {
	testLock := &sync.Mutex{}
	pool := service.NewPool(service.NewLifecycleFactory(), log.NewTestLogger(t))
	poolLifecycle := service.NewLifecycle(pool)
	var poolStates []service.State
	var serviceStates []service.State
	startup := make(chan struct{})
	poolLifecycle.OnStarting(func(s service.Service, l service.Lifecycle) {
		startup <- struct{}{}
	})
	poolLifecycle.OnStateChange(func(s service.Service, l service.Lifecycle, state service.State) {
		poolStates = append(poolStates, state)
	})

	s := newTestService("Test service")
	s.CrashStartup()
	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()
		}
	}()

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

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