Function benchmarkFile

wgengine/filter/filter_test.go:1256–1326

(b *testing.B, file string, opt benchOpt)

}

func benchmarkFile(b *testing.B, file string, opt benchOpt) {
	var matches []Match
	bts, err := os.ReadFile(file)
	if err != nil {
		b.Fatal(err)
	}
	if err := json.Unmarshal(bts, &matches); err != nil {
		b.Fatal(err)
	}

	var localNets netipx.IPSetBuilder
	pfx := []netip.Prefix{
		netip.MustParsePrefix("100.96.14.120/32"),
		netip.MustParsePrefix("fd7a:115c:a1e0:ab12:4843:cd96:6260:e78/128"),
	}
	for _, p := range pfx {
		localNets.AddPrefix(p)
	}

	var logIPs netipx.IPSetBuilder
	logIPs.AddPrefix(tsaddr.CGNATRange())
	logIPs.AddPrefix(tsaddr.TailscaleULARange())

	f := New(matches, nil, must.Get(localNets.IPSet()), must.Get(logIPs.IPSet()), nil, logger.Discard)
	var srcIP, dstIP netip.Addr
	if opt.v4 {
		srcIP = netip.MustParseAddr("1.2.3.4")
		dstIP = pfx[0].Addr()
	} else {
		srcIP = netip.MustParseAddr("2012::3456")
		dstIP = pfx[1].Addr()
	}
	if !opt.validLocalDst {
		dstIP = dstIP.Next() // to make it not in localNets
	}
	proto := ipproto.TCP
	if opt.udp {
		proto = ipproto.UDP
	}
	const sport = 33123
	const dport = 443
	pkt := parsed(proto, srcIP.String(), dstIP.String(), sport, dport)
	if opt.tcpNotSYN {
		pkt.TCPFlags = packet.TCPPsh // anything that's not SYN
	}
	if opt.udpOpen {
		tuple := flowtrack.MakeTuple(proto,
			netip.AddrPortFrom(srcIP, sport),
			netip.AddrPortFrom(dstIP, dport),
		)
		f.state.mu.Lock()
		f.state.lru.Add(tuple, struct{}{})
		f.state.mu.Unlock()
	}

	want := Drop
	if opt.wantAccept {
		want = Accept