add a mutex for the buffered reader to match the concurency behavior of net.Conn.

peterguy · peterguy · commit 9973e054a236 · 2026-03-08T18:34:10.000-07:00
diff --git a/internal/api/proxy.go b/internal/api/proxy.go
@@ -10,14 +10,18 @@ import (
 	"net"
 	"net/http"
 	"net/url"
+	"sync"
 )
 
 type connWithBufferedReader struct {
 	net.Conn
-	r *bufio.Reader
+	r  *bufio.Reader
+	mu sync.Mutex
 }
 
 func (c *connWithBufferedReader) Read(p []byte) (int, error) {
+	c.mu.Lock()
+	defer c.mu.Unlock()
 	return c.r.Read(p)
 }
 

Original file line number	Diff line number	Diff line change
`@@ -10,14 +10,18 @@ import (`
`10`	`10`	`"net"`
`11`	`11`	`"net/http"`
`12`	`12`	`"net/url"`
	`13`	`+ "sync"`
`13`	`14`	`)`
`14`	`15`
`15`	`16`	`type connWithBufferedReader struct {`
`16`	`17`	`net.Conn`
`17`		`- r *bufio.Reader`
	`18`	`+ r *bufio.Reader`
	`19`	`+ mu sync.Mutex`
`18`	`20`	`}`
`19`	`21`
`20`	`22`	`func (c *connWithBufferedReader) Read(p []byte) (int, error) {`
	`23`	`+ c.mu.Lock()`
	`24`	`+ defer c.mu.Unlock()`
`21`	`25`	`return c.r.Read(p)`
`22`	`26`	`}`
`23`	`27`