fix: dont check epollout when epollerr (#183)

cloudwego · Aug 12, 2022 · 063c3c4 · 063c3c4
1 parent 4c6b739
commit 063c3c4
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/poll_default_linux.go b/poll_default_linux.go
@@ -159,10 +159,11 @@ func (p *defaultPoll) handler(events []epollevent) (closed bool) {
 			// So here we need to check this error, if it is EAGAIN then do nothing, otherwise still mark as hup.
 			if _, _, _, _, err := syscall.Recvmsg(operator.FD, nil, nil, syscall.MSG_ERRQUEUE); err != syscall.EAGAIN {
 				p.appendHup(operator)
-				continue
+			} else {
+				operator.done()
 			}
+			continue
 		}
-
 		// check poll out
 		if evt&syscall.EPOLLOUT != 0 {
 			if operator.OnWrite != nil {

diff --git a/poll_race_linux.go b/poll_race_linux.go
@@ -156,8 +156,10 @@ func (p *defaultPoll) handler(events []syscall.EpollEvent) (closed bool) {
 			// So here we need to check this error, if it is EAGAIN then do nothing, otherwise still mark as hup.
 			if _, _, _, _, err := syscall.Recvmsg(operator.FD, nil, nil, syscall.MSG_ERRQUEUE); err != syscall.EAGAIN {
 				p.appendHup(operator)
-				continue
+			} else {
+				operator.done()
 			}
+			continue
 		}
 
 		// check poll out