Function TestWorkerMaxRequestsHighConcurrency

worker_test.go:222–264

TestWorkerMaxRequestsHighConcurrency verifies max_requests works under concurrent load.

(t *testing.T)

// TestWorkerMaxRequestsHighConcurrency verifies max_requests works under concurrent load.
func TestWorkerMaxRequestsHighConcurrency(t *testing.T) {
	const maxRequests = 10
	const totalRequests = 200

	runTest(t, func(handler func(http.ResponseWriter, *http.Request), _ *httptest.Server, _ int) {
		var (
			mu          sync.Mutex
			instanceIDs = make(map[string]int)
		)
		var wg sync.WaitGroup

		for i := 0; i < totalRequests; i++ {
			wg.Add(1)
			go func() {
				defer wg.Done()
				body, resp := testGet("http://example.com/worker-counter-persistent.php", handler, t)
				assert.Equal(t, 200, resp.StatusCode)

				mu.Lock()
				parts := strings.Split(body, ",")
				if len(parts) == 2 {
					instanceID := strings.TrimPrefix(parts[0], "instance:")
					instanceIDs[instanceID]++
				}
				mu.Unlock()
			}()
		}
		wg.Wait()

		t.Logf("instances: %d", len(instanceIDs))
		assert.Greater(t, len(instanceIDs), 4, "workers should have restarted multiple times")

		for id, count := range instanceIDs {
			assert.LessOrEqual(t, count, maxRequests,
				fmt.Sprintf("instance %s handled %d requests, exceeding max_requests=%d", id, count, maxRequests))
		}
	}, &testOptions{
		workerScript:       "worker-counter-persistent.php",
		nbWorkers:          4,
		nbParallelRequests: 1,
		initOpts:           []frankenphp.Option{frankenphp.WithNumThreads(5), frankenphp.WithMaxRequests(maxRequests)},
	})
}