From 7b5df6d341bf1bc722bcc514523b75130f396999 Mon Sep 17 00:00:00 2001 From: Rammiah Date: Fri, 5 Jan 2024 12:20:08 +0800 Subject: [PATCH] fix(net): Buf use Mutex (#5823) Co-authored-by: Andy Hsu --- internal/net/request.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/net/request.go b/internal/net/request.go index 78aa38328430..71f45aa7afc7 100644 --- a/internal/net/request.go +++ b/internal/net/request.go @@ -449,7 +449,7 @@ type Buf struct { size int //expected size ctx context.Context off int - rw sync.RWMutex + rw sync.Mutex //notify chan struct{} } @@ -480,9 +480,9 @@ func (br *Buf) Read(p []byte) (n int, err error) { if br.off >= br.size { return 0, io.EOF } - br.rw.RLock() + br.rw.Lock() n, err = br.buffer.Read(p) - br.rw.RUnlock() + br.rw.Unlock() if err == nil { br.off += n return n, err