Function TestUpdateRace

wgengine/netlog/netlog_test.go:149–187

(t *testing.T)

}

func TestUpdateRace(t *testing.T) {
	var logger Logger
	logger.recordsChan = make(chan record, 1)
	go func(recordsChan chan record) {
		for range recordsChan {
		}
	}(logger.recordsChan)

	var group sync.WaitGroup
	defer group.Wait()
	for i := range 1000 {
		group.Go(func() {
			src, dst := randAddrPort(), randAddrPort()
			for j := range 1000 {
				if i%2 == 0 {
					logger.updateVirtConn(0x1, src, dst, rand.IntN(10), rand.IntN(1000), j%2 == 0)
				} else {
					logger.updatePhysConn(0x1, src, dst, rand.IntN(10), rand.IntN(1000), j%2 == 0)
				}
			}
		})
		group.Go(func() {
			for range 1000 {
				logger.ReconfigNetworkMap(new(netmap.NetworkMap))
			}
		})
		group.Go(func() {
			for range 1000 {
				logger.ReconfigRoutes(new(router.Config))
			}
		})
	}

	group.Wait()
	logger.mu.Lock()
	close(logger.recordsChan)
	logger.recordsChan = nil
	logger.mu.Unlock()
}

func randAddrPort() netip.AddrPort {
	var b [4]uint8