Function TestTransitionThreadsWhileDoingRequests

phpmainthread_test.go:94–167

try all possible handler transitions takes around 200ms and is supposed to force race conditions

(t *testing.T)

// try all possible handler transitions
// takes around 200ms and is supposed to force race conditions
func TestTransitionThreadsWhileDoingRequests(t *testing.T) {
	t.Cleanup(Shutdown)

	var (
		isDone        atomic.Bool
		wg            sync.WaitGroup
		transitionsWG sync.WaitGroup
	)

	numThreads := 10
	numRequestsPerThread := 100
	worker1Path := filepath.Join(testDataPath, "transition-worker-1.php")
	worker1Name := "worker-1"
	worker2Path := filepath.Join(testDataPath, "transition-worker-2.php")
	worker2Name := "worker-2"

	assert.NoError(t, Init(
		WithNumThreads(numThreads),
		WithWorkers(worker1Name, worker1Path, 1,
			WithWorkerEnv(map[string]string{"ENV1": "foo"}),
			WithWorkerWatchMode([]string{}),
			WithWorkerMaxFailures(0),
		),
		WithWorkers(worker2Name, worker2Path, 1,
			WithWorkerEnv(map[string]string{"ENV1": "foo"}),
			WithWorkerWatchMode([]string{}),
			WithWorkerMaxFailures(0),
		),
	))

	// try all possible permutations of transition, transition every ms
	transitions := allPossibleTransitions(worker1Path, worker2Path)
	transitionsWG.Add(numThreads)
	for i := range numThreads {
		go func(thread *phpThread, start int) {
			defer transitionsWG.Done()
			for {
				for j := start; j < len(transitions); j++ {
					if isDone.Load() {
						return
					}
					transitions[j](thread)
					time.Sleep(time.Millisecond)
				}
				start = 0
			}
		}(phpThreads[i], i)
	}

	// randomly do requests to the 3 endpoints
	wg.Add(numThreads)
	for i := range numThreads {
		go func(i int) {
			for range numRequestsPerThread {
				switch rand.IntN(3) {
				case 0:
					assertRequestBody(t, "http://localhost/transition-worker-1.php", "Hello from worker 1")
				case 1: