Function TestGenericCombinerDoesntRace

modules/frontend/combiner/common_test.go:165–216

(t *testing.T)

}

func TestGenericCombinerDoesntRace(t *testing.T) {
	combiner := newTestCombiner()
	end := make(chan struct{})
	wg := sync.WaitGroup{}

	concurrent := func(f func()) {
		wg.Add(1)
		go func() {
			defer wg.Done()
			for {
				select {
				case <-end:
					return
				default:
					f()
				}
			}
		}()
	}
	concurrent(func() {
		_ = combiner.AddResponse(newTestResponse(t))
	})

	concurrent(func() {
		// this test is going to add a failed response which cuts off certain code paths. just wait a bit to test the other paths
		time.Sleep(10 * time.Millisecond)
		_ = combiner.AddResponse(newFailedTestResponse())
	})

	concurrent(func() {
		combiner.ShouldQuit()
	})

	concurrent(func() {
		combiner.StatusCode()
	})

	concurrent(func() {
		_, _ = combiner.HTTPFinal()
	})

	concurrent(func() {
		_, _ = combiner.GRPCFinal()
	})

	concurrent(func() {
		_, _ = combiner.GRPCDiff()
	})

	close(end)
	wg.Wait()
}

type testPipelineResponse struct {
	r            *http.Response