core/connpool: reset deadlines for pooled conns

ignoramous · ignoramous · commit cb33c6fe4c99 · 2025-05-23T23:29:52.000+05:30
diff --git a/intra/core/connpool.go b/intra/core/connpool.go
@@ -255,6 +255,8 @@ func (c *ConnPool[T]) Put(conn net.Conn) (ok bool) {
 		return
 	}
 
+	aconn.resetDeadline()
+
 	select {
 	case c.p <- aconn:
 		aconn.keepalive(true)
@@ -437,6 +439,10 @@ func (a agingconn) canread() error {
 	return JoinErr(ctlErr, checkErr) // may return nil
 }
 
+func (a agingconn) resetDeadline() {
+	a.c.SetDeadline(time.Time{})
+}
+
 func logev(err error) log.LogFn {
 	return logevif(err != nil)
 }

Original file line number	Diff line number	Diff line change
`@@ -255,6 +255,8 @@ func (c *ConnPool[T]) Put(conn net.Conn) (ok bool) {`
`255`	`255`	`return`
`256`	`256`	`}`
`257`	`257`
	`258`	`+ aconn.resetDeadline()`
	`259`	`+`
`258`	`260`	`select {`
`259`	`261`	`case c.p <- aconn:`
`260`	`262`	`aconn.keepalive(true)`
`@@ -437,6 +439,10 @@ func (a agingconn) canread() error {`
`437`	`439`	`return JoinErr(ctlErr, checkErr) // may return nil`
`438`	`440`	`}`
`439`	`441`
	`442`	`+func (a agingconn) resetDeadline() {`
	`443`	`+ a.c.SetDeadline(time.Time{})`
	`444`	`+}`
	`445`	`+`
`440`	`446`	`func logev(err error) log.LogFn {`
`441`	`447`	`return logevif(err != nil)`
`442`	`448`	`}`