зеркало из https://github.com/Azure/go-amqp.git
Fix idle timeout < 1
This commit is contained in:
Родитель
390d7eaeac
Коммит
b9bf967e3a
4
conn.go
4
conn.go
|
@ -431,7 +431,9 @@ func (c *conn) connReader() {
|
|||
// need to read more if buf doesn't contain the complete frame
|
||||
// or there's not enough in buf to parse the header
|
||||
if frameInProgress || buf.len() < frameHeaderSize {
|
||||
_ = c.net.SetReadDeadline(time.Now().Add(c.idleTimeout))
|
||||
if c.idleTimeout > 0 {
|
||||
_ = c.net.SetReadDeadline(time.Now().Add(c.idleTimeout))
|
||||
}
|
||||
err := buf.readFromOnce(c.net)
|
||||
if err != nil {
|
||||
select {
|
||||
|
|
Загрузка…
Ссылка в новой задаче