Fix a bug of recycling bytes in loopWrite

yxw2014 · Sep 24, 2019 · fe0c167 · fe0c167
1 parent 1ab43e6
commit fe0c167
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/eventloop.go b/eventloop.go
@@ -214,14 +214,14 @@ func (l *loop) loopWrite(svr *server, conn *conn) error {
 
 	out := conn.outBuf.Bytes()
 	n, err := unix.Write(conn.fd, out)
+	ringbuffer.Recycle(out)
 	if err != nil {
 		if err == unix.EAGAIN {
 			return nil
 		}
 		return l.loopCloseConn(svr, conn, err)
 	}
 	conn.outBuf.Advance(n)
-	ringbuffer.Recycle(out)
 
 	if conn.outBuf.Length() == 0 {
 		l.poller.ModRead(conn.fd)