Function TestSendProcess_FullBufferUnblocksOnCancel

core/pool/pool_test.go:413–428

(t *testing.T)

}

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

	for i := 0; i < cap(pool.processCh); i++ {
		pool.processCh <- newTestBaseline()
	}

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

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