fix: stop timer when read triggered by err

cloudwego · Nov 28, 2023 · c9e1a04 · c9e1a04
1 parent 27be26a
commit c9e1a04
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/connection_impl.go b/connection_impl.go
@@ -413,6 +413,7 @@ func (c *connection) waitRead(n int) (err error) {
 			if err != nil {
 				return err
 			}
+			continue
 		}
 	}
 	return nil
@@ -447,7 +448,7 @@ func (c *connection) waitReadWithTimeout(n int) (err error) {
 				return Exception(ErrReadTimeout, c.remoteAddr.String())
 			case err = <-c.readTrigger:
 				if err != nil {
-					return err
+					goto RET
 				}
 				continue
 			}