From 219040a04c983288e94618aecb1d64fd033346df Mon Sep 17 00:00:00 2001 From: aceld Date: Fri, 18 Sep 2020 18:20:26 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E6=B7=BB=E5=8A=A0=E4=BC=98?= =?UTF-8?q?=E5=8C=96contenxt=E5=AF=BC=E8=87=B4=E7=9A=84select=20=E4=B8=ADb?= =?UTF-8?q?reak=E6=97=A0=E6=B3=95=E9=80=80=E5=87=BAfor=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- znet/connection.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/znet/connection.go b/znet/connection.go index 2119c06..cea50e1 100644 --- a/znet/connection.go +++ b/znet/connection.go @@ -108,7 +108,7 @@ func (c *Connection) StartReader() { headData := make([]byte, dp.GetHeadLen()) if _, err := io.ReadFull(c.Conn, headData); err != nil { fmt.Println("read msg head error ", err) - break + return } //fmt.Printf("read headData %+v\n", headData) @@ -116,7 +116,7 @@ func (c *Connection) StartReader() { msg, err := dp.Unpack(headData) if err != nil { fmt.Println("unpack error ", err) - break + return } //根据 dataLen 读取 data，放在msg.Data中 @@ -125,7 +125,7 @@ func (c *Connection) StartReader() { data = make([]byte, msg.GetDataLen()) if _, err := io.ReadFull(c.Conn, data); err != nil { fmt.Println("read msg data error ", err) - break + return } } msg.SetData(data)