From e0571c7ed17eadb89b251944da2c85e347501e97 Mon Sep 17 00:00:00 2001 From: kercylan98 Date: Wed, 5 Jul 2023 13:53:34 +0800 Subject: [PATCH] =?UTF-8?q?perf:=20=E7=A7=BB=E9=99=A4=E5=90=91=E8=BF=9E?= =?UTF-8?q?=E6=8E=A5=E5=8F=91=E9=80=81=E6=95=B0=E6=8D=AE=E6=97=B6=E7=9A=84?= =?UTF-8?q?=E7=A9=BA=E5=8C=85=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 移除之后将允许发送空的数据包,否则在收到空数据包时将导致连接被关闭 --- server/conn.go | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/server/conn.go b/server/conn.go index bd9a330..e228d84 100644 --- a/server/conn.go +++ b/server/conn.go @@ -184,13 +184,13 @@ func (slf *Conn) writeLoop(wait *sync.WaitGroup) { slf.mutex.Unlock() for i := 0; i < len(packets); i++ { data := packets[i] - if len(data.packet) == 0 { - for _, packet := range packets { - slf.packetPool.Release(packet) - } - slf.Close() - return - } + //if len(data.packet) == 0 { + // for _, packet := range packets { + // slf.packetPool.Release(packet) + // } + // slf.Close() + // return + //} var err error if slf.IsWebsocket() { if data.websocketMessageType <= 0 {