Function TestAddAddition_ConcurrentShutdown

core/pool/pool_test.go:352–379

(t *testing.T)

}

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

	var ext sync.WaitGroup
	for i := 0; i < 200; i++ {
		ext.Add(1)
		go func() {
			defer ext.Done()
			pool.addAddition(&Unit{path: "/c", source: parsers.WordSource})
		}()
	}

	time.Sleep(2 * time.Millisecond)
	cancel()

	// drain so senders can unblock
	go func() {
		for range pool.additionCh {
			pool.wg.Done()
		}
	}()

	mustFinish(t, 5*time.Second, "concurrent addAddition+cancel hung", func() {
		ext.Wait()
	})
	close(pool.additionCh)
}

// ---------------------------------------------------------------------------
// sendProcess