opt: prioritize writable events

panjf2000 · Feb 3, 2021 · 0f08c8f · 0f08c8f
1 parent 2404edd
commit 0f08c8f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/loop_linux.go b/loop_linux.go
@@ -40,7 +40,7 @@ func (el *eventloop) handleEvent(fd int, ev uint32) error {
 				return err
 			}
 		}
-		if ev&netpoll.InEvents != 0 {
+		if ev&netpoll.InEvents != 0 && c.outboundBuffer.IsEmpty() {
 			return el.loopRead(c)
 		}
 		return nil

diff --git a/reactor_linux.go b/reactor_linux.go
@@ -74,7 +74,7 @@ func (svr *server) activateSubReactor(el *eventloop, lockOSThread bool) {
 					return err
 				}
 			}
-			if ev&netpoll.InEvents != 0 {
+			if ev&netpoll.InEvents != 0 && c.outboundBuffer.IsEmpty() {
 				return el.loopRead(c)
 			}
 		}