Function TestDefaultCtx_signalReleased_Idempotent

ctx_reclaim_test.go:116–135

TestDefaultCtx_signalReleased_Idempotent guards the sync.Once semantics: even if the request release path fires multiple times, the latch must close once.

(t *testing.T)

// TestDefaultCtx_signalReleased_Idempotent guards the sync.Once semantics: even
// if the request release path fires multiple times, the latch must close once.
func TestDefaultCtx_signalReleased_Idempotent(t *testing.T) {
	t.Parallel()
	app, c := acquireReclaimTestCtx(t)

	handlerDone := make(chan struct{})
	c.ScheduleReclaim(handlerDone, nil)

	require.NotPanics(t, func() {
		c.signalReleased()
		c.signalReleased()
		c.signalReleased()
	})

	close(handlerDone)
	require.Eventually(t, func() bool {
		return !c.IsAbandoned()
	}, time.Second, 5*time.Millisecond, "ctx must still be reclaimed exactly once")

	_ = app
}

// TestApp_releaseDefaultCtx_AbandonedSignalsReclaim exercises the internal
// releaseDefaultCtx path (called by defaultRequestHandler's defer) for an