Function TestPutToOutput_AfterCancel

core/pool/pool_test.go:502–518

(t *testing.T)

}

func TestPutToOutput_AfterCancel(t *testing.T) {
	ctx, cancel := context.WithCancel(context.Background())
	pool := newTestBasePool(ctx, cancel)
	cancel()

	mustFinish(t, 2*time.Second, "putToOutput blocked after cancel", func() {
		pool.putToOutput(newTestBaseline())
	})
	// select may have picked OutputCh (buffer available) or ctx.Done();
	// drain if sent so Outwg stays balanced.
	select {
	case <-pool.OutputCh:
		pool.Outwg.Done()
	default:
	}
	pool.Outwg.Wait()
}

func TestPutToOutput_OutwgBalance(t *testing.T) {
	ctx, cancel := context.WithCancel(context.Background())