mats/go-cart-actor
1
0
Fork 0
Code Issues Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

try a buffer
All checks were successful
Build and Publish / BuildAndDeployAmd64 (push) Successful in 28s
Details
Build and Publish / BuildAndDeploy (push) Successful in 2m27s
Details

Browse Source
This commit is contained in:
matst80
2024-11-21 18:25:13 +01:00
parent bb55c5cb6f
commit 86d310c80f
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
tcp-connection.go
View File

@@ -1,6 +1,7 @@
package main package main
import ( import (
"bufio"
"encoding/binary" "encoding/binary"
"fmt" "fmt"
"log" "log"
@@ -111,15 +112,15 @@ func (c *Connection) Call(msg FrameType, data []byte) (*FrameWithPayload, error)
func WaitForFrame(conn net.Conn, resultChan chan<- FrameWithPayload) error { func WaitForFrame(conn net.Conn, resultChan chan<- FrameWithPayload) error {
var err error var err error
var frame Frame 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 { if err != nil {
return err return err
} }
if frame.IsValid() { if frame.IsValid() {
payload := make([]byte, frame.Length) payload := make([]byte, frame.Length)
_, err = conn.Read(payload) _, err = r.Read(payload)
if err != nil { if err != nil {
return err return err
} }