somehow Read timeouts are not matched by `errors.Is(err, os.ErrDeadli…

…neExceeded)`
aldas · Jul 27, 2023 · 37ada3c · 37ada3c
1 parent de1ce46
commit 37ada3c
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/server/server.go b/server/server.go
@@ -8,7 +8,6 @@ import (
 	"io"
 	"log"
 	"net"
-	"os"
 	"sync"
 	"sync/atomic"
 	"time"
@@ -215,6 +214,11 @@ func (s *Server) trackConn(c *connection, isAdd bool) {
 	}
 }
 
+func isTimeout(err error) bool {
+	var terr interface{ Timeout() bool }
+	return errors.As(err, &terr) && terr.Timeout()
+}
+
 func (c *connection) handle(ctx context.Context) {
 	cCtx, cCancel := context.WithCancel(ctx)
 	defer cCancel()
@@ -244,7 +248,7 @@ func (c *connection) handle(ctx context.Context) {
 		if debugRawRead {
 			rrt.Read(received[0:n], n, err)
 		}
-		if err != nil && !os.IsTimeout(err) {
+		if err != nil && !isTimeout(err) {
 			if !errors.Is(err, io.EOF) {
 				c.onErrorFunc(err)
 			}