debug: fix timer leak

cloudwego · Nov 28, 2023 · 9471908 · 9471908
1 parent fa44790
commit 9471908
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/connection_impl.go b/connection_impl.go
@@ -410,9 +410,9 @@ func (c *connection) waitRead(n int) (err error) {
 			return Exception(ErrConnClosed, "wait read")
 		default:
 			err = <-c.readTrigger
-			//if err != nil {
-			//	return err
-			//}
+			if err != nil {
+				return err
+			}
 			continue
 		}
 	}
@@ -447,9 +447,9 @@ func (c *connection) waitReadWithTimeout(n int) (err error) {
 				}
 				return Exception(ErrReadTimeout, c.remoteAddr.String())
 			case err = <-c.readTrigger:
-				//if err != nil {
-				//	return err
-				//}
+				if err != nil {
+					goto RET
+				}
 				continue
 			}
 		}