From 86d310c80f3f81ed8e99e4e94f4b362700983bb7 Mon Sep 17 00:00:00 2001 From: matst80 Date: Thu, 21 Nov 2024 18:25:13 +0100 Subject: [PATCH] try a buffer --- tcp-connection.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/tcp-connection.go b/tcp-connection.go index 8875a18..af91b0b 100644 --- a/tcp-connection.go +++ b/tcp-connection.go @@ -1,6 +1,7 @@ package main import ( + "bufio" "encoding/binary" "fmt" "log" @@ -111,15 +112,15 @@ func (c *Connection) Call(msg FrameType, data []byte) (*FrameWithPayload, error) func WaitForFrame(conn net.Conn, resultChan chan<- FrameWithPayload) error { var err error var frame Frame - //r := bufio.NewReader(conn) + r := bufio.NewReader(conn) - err = binary.Read(conn, binary.LittleEndian, &frame) + err = binary.Read(r, binary.LittleEndian, &frame) if err != nil { return err } if frame.IsValid() { payload := make([]byte, frame.Length) - _, err = conn.Read(payload) + _, err = r.Read(payload) if err != nil { return err }