test6

Signed-off-by: monkey92t <[email protected]>

Author: monkey92t

internal/pool/conn.go

@@ -19,7 +19,7 @@ type Conn struct {
 	netConn net.Conn
 
 	// for checking the health status of the connection, it may be nil.
-	rawConn syscall.RawConn
+	sysConn syscall.Conn
 
 	rd *proto.Reader
 	bw *bufio.Writer
@@ -60,7 +60,7 @@ func (cn *Conn) SetNetConn(netConn net.Conn) {
 }
 
 func (cn *Conn) setRawConn() {
-	cn.rawConn = nil
+	cn.sysConn = nil
 	conn := cn.netConn
 	if conn == nil {
 		return
@@ -70,9 +70,7 @@ func (cn *Conn) setRawConn() {
 	}
 
 	if sysConn, ok := conn.(syscall.Conn); ok {
-		if rawConn, err := sysConn.SyscallConn(); err == nil {
-			cn.rawConn = rawConn
-		}
+		cn.sysConn = sysConn
 	}
 }
 

internal/pool/conn_check.go

@@ -10,7 +10,7 @@ import (
 
 var errUnexpectedRead = errors.New("unexpected read from socket")
 
-func connCheck(rawConn syscall.RawConn) error {
+func connCheck(sysConn syscall.Conn) error {
 	//// Reset previous timeout.
 	//_ = conn.SetDeadline(time.Time{})
 	//
@@ -22,10 +22,10 @@ func connCheck(rawConn syscall.RawConn) error {
 	//if !ok {
 	//	return nil
 	//}
-	//rawConn, err := sysConn.SyscallConn()
-	//if err != nil {
-	//	return err
-	//}
+	rawConn, err := sysConn.SyscallConn()
+	if err != nil {
+		return err
+	}
 
 	var sysErr error
 

internal/pool/conn_check_dummy.go

@@ -6,6 +6,6 @@ import (
 	"syscall"
 )
 
-func connCheck(_ syscall.RawConn) error {
+func connCheck(_ syscall.Conn) error {
 	return nil
 }

internal/pool/pool.go

@@ -511,10 +511,10 @@ func (p *ConnPool) isHealthyConn(cn *Conn) bool {
 		return false
 	}
 
-	if cn.rawConn != nil {
+	if cn.sysConn != nil {
 		// reset previous timeout.
 		_ = cn.netConn.SetDeadline(zeroTime)
-		if connCheck(cn.rawConn) != nil {
+		if connCheck(cn.sysConn) != nil {
 			return false
 		}
 	}