Function testRunBlocksAfterShutdown

pkg/routine/routine_test.go:87–117

(t *testing.T)

}

func testRunBlocksAfterShutdown(t *testing.T) {
	var endOfTest sync.WaitGroup
	endOfTest.Add(1)

	// start routine that gets canceled by the shutdown
	routineCtx := make(chan context.Context)
	routine.Run(context.Background(), func(ctx context.Context) {
		routineCtx <- ctx
		endOfTest.Wait()
	})

	// kill this process
	err := syscall.Kill(syscall.Getpid(), syscall.SIGINT)
	require.NoError(t, err)

	// wait until the routine gets canceled because of the shutdown
	<-(<-routineCtx).Done()

	// start routine
	done := make(chan struct{})
	go func() {
		waitForRun(context.Background(), nil)
		done <- struct{}{}
	}()
	select {
	case <-done:
		t.Fatal("routine started after shutdown")
	case <-time.After(10 * time.Millisecond):
		// good
	}
}

func TestRun_cancelsContextsOnSIGINT(t *testing.T) {
	t.Skip("test not working properly in docker, skipping")