Merge pull request bfenetworks#1210 from xuleiming/develop

fix "bfe_http : readloop goroutine leak bfenetworks#1209"
iyangsj · Jan 14, 2025 · b1c83a2 · b1c83a2
2 parents ea2c62e + 0e06df7
commit b1c83a2
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/bfe_http/transport.go b/bfe_http/transport.go
@@ -885,6 +885,10 @@ func (pc *persistConn) readLoop() {
 			err = ReadRespHeaderError{Err: err}
 		}
 
+		pc.lk.Lock()
+		pc.numExpectedResponses--
+		pc.lk.Unlock()
+
 		rc.ch <- responseAndError{resp, err}
 
 		// Wait for the just-returned response body to be fully consumed
@@ -1051,10 +1055,6 @@ WaitResponse:
 		}
 	}
 
-	pc.lk.Lock()
-	pc.numExpectedResponses--
-	pc.lk.Unlock()
-
 	if re.err != nil {
 		pc.t.setReqConn(req.Request, nil)
 	}