fix 664 (#674)

valyala · Oct 16, 2019 · 044d35e · 044d35e
1 parent ffcdb75
commit 044d35e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/fasthttputil/pipeconns.go b/fasthttputil/pipeconns.go
@@ -166,7 +166,9 @@ func (c *pipeConn) readNextByteBuffer(mayBlock bool) error {
 		select {
 		case c.b = <-c.rCh:
 		case <-readDeadlineCh:
+			c.readDeadlineChLock.Lock()
 			c.readDeadlineCh = closedDeadlineCh
+			c.readDeadlineChLock.Unlock()
 			// rCh may contain data when deadline is reached.
 			// Read the data before returning ErrTimeout.
 			select {