Function TestPutToOutput_OutwgBalance

core/pool/pool_test.go:520–544

(t *testing.T)

}

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

	// fill OutputCh so next send will block
	for i := 0; i < cap(pool.OutputCh); i++ {
		pool.OutputCh <- newTestBaseline()
		pool.Outwg.Add(1) // manual balance for the fills
	}

	mustFinish(t, 2*time.Second, "putToOutput on full ch not unblocked by cancel", func() {
		go func() {
			time.Sleep(50 * time.Millisecond)
			cancel()
		}()
		pool.putToOutput(newTestBaseline())
	})

	// drain and done for fills
	for i := 0; i < cap(pool.OutputCh); i++ {
		<-pool.OutputCh
		pool.Outwg.Done()
	}
	pool.Outwg.Wait()
}

// ---------------------------------------------------------------------------
// putToFuzzy