opt: bring down the maxBytesTransferET and defer write in ET mode (#…

…606) * opt: don't write data immediately when there is data pending in ET mode * opt: bring down the maxBytesTransferET from 4MB to 1MB
panjf2000 · May 30, 2024 · cda1839 · cda1839
1 parent ef2f817
commit cda1839
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 7 deletions.
diff --git a/connection_unix.go b/connection_unix.go
@@ -143,9 +143,6 @@ func (c *conn) write(data []byte) (n int, err error) {
 	// of network packets.
 	if !c.outboundBuffer.IsEmpty() {
 		_, _ = c.outboundBuffer.Write(data)
-		if isET {
-			err = c.loop.write(c)
-		}
 		return
 	}
 
@@ -193,9 +190,6 @@ func (c *conn) writev(bs [][]byte) (n int, err error) {
 	// of network packets.
 	if !c.outboundBuffer.IsEmpty() {
 		_, _ = c.outboundBuffer.Writev(bs)
-		if isET {
-			err = c.loop.write(c)
-		}
 		return
 	}
 

diff --git a/eventloop_unix.go b/eventloop_unix.go
@@ -118,7 +118,7 @@ func (el *eventloop) read0(itf interface{}) error {
 	return el.read(itf.(*conn))
 }
 
-const maxBytesTransferET = 1 << 22
+const maxBytesTransferET = 1 << 20
 
 func (el *eventloop) read(c *conn) error {
 	if !c.opened {