Function TestAddAddition_FullBufferUnblocksOnCancel

core/pool/pool_test.go:334–350

(t *testing.T)

}

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

	// fill buffer
	for i := 0; i < cap(pool.additionCh); i++ {
		pool.additionCh <- &Unit{path: "/fill"}
	}

	mustFinish(t, 2*time.Second, "addAddition on full buffer not unblocked by cancel", func() {
		go func() {
			time.Sleep(50 * time.Millisecond)
			cancel()
		}()
		pool.addAddition(&Unit{path: "/blocked", source: parsers.WordSource})
	})
}

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