Function BenchmarkCopyZeroAllocNetConnToOSFile

http_timing_test.go:207–283

(b *testing.B)

}

func BenchmarkCopyZeroAllocNetConnToOSFile(b *testing.B) {
	data, err := os.ReadFile("./README.md")
	if err != nil {
		b.Fatal(err)
	}

	ln, err := net.Listen("tcp", "127.0.0.1:0")
	if err != nil {
		b.Fatal(err)
	}

	addr := ln.Addr().String()
	defer ln.Close()

	done := make(chan struct{})
	defer close(done)

	writeDone := make(chan struct{})
	go func() {
		for {
			select {
			case <-done:
				return
			default:
				conn, err := ln.Accept()
				if err != nil {
					b.Error(err)
					return
				}
				_, err = conn.Write(data)
				if err != nil {
					b.Error(err)
				}
				conn.Close()
				writeDone <- struct{}{}
			}
		}
	}()

	tmp, err := os.CreateTemp(os.TempDir(), "test_*")
	if err != nil {
		b.Fatal(err)
	}
	defer os.Remove(tmp.Name())

	file, err := os.OpenFile(tmp.Name(), os.O_WRONLY, 0o444)
	if err != nil {
		b.Fatal(err)
	}
	defer file.Close()

	conn, err := net.Dial("tcp", addr)
	if err != nil {
		b.Fatal(err)
	}
	defer conn.Close()

	b.ResetTimer()