optimize: ignore EOF when read a closed connection

cloudwego · Jul 13, 2023 · fa52e82 · fa52e82
1 parent 14cb7b8
commit fa52e82
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/poll_default_bsd.go b/poll_default_bsd.go
@@ -112,7 +112,7 @@ func (p *defaultPoll) Wait() error {
 				}
 			}
 			if triggerHup && triggerRead && operator.Inputs != nil { // read all left data if peer send and close
-				if err = readall(operator, barriers[i]); err != nil {
+				if err = readall(operator, barriers[i]); err != nil && !errors.Is(err, ErrEOF) {
 					logger.Printf("NETPOLL: readall(fd=%d) before close: %s", operator.FD, err.Error())
 				}
 			}

diff --git a/poll_default_linux.go b/poll_default_linux.go
@@ -15,6 +15,7 @@
 package netpoll
 
 import (
+	"errors"
 	"runtime"
 	"sync"
 	"sync/atomic"
@@ -164,7 +165,7 @@ func (p *defaultPoll) handler(events []epollevent) (closed bool) {
 			}
 		}
 		if triggerHup && triggerRead && operator.Inputs != nil { // read all left data if peer send and close
-			if err := readall(operator, p.barriers[i]); err != nil {
+			if err := readall(operator, p.barriers[i]); err != nil && !errors.Is(err, ErrEOF) {
 				logger.Printf("NETPOLL: readall(fd=%d) before close: %s", operator.FD, err.Error())
 			}
 		}