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

no read deadline
All checks were successful
Build and Publish / BuildAndDeployAmd64 (push) Successful in 27s
Details
Build and Publish / BuildAndDeploy (push) Successful in 2m6s
Details

Browse Source
This commit is contained in:
matst80
2024-11-12 20:37:04 +01:00
parent 5f1f7ee25a
commit 983d1d52ae
1 changed files with 0 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
cart-packet-queue.go
View File

@@ -5,7 +5,6 @@ import (
"fmt" "fmt"
"log" "log"
"sync" "sync"
"time"
) )
type CartPacketQueue struct { type CartPacketQueue struct {
@@ -40,12 +39,10 @@ func (p *CartPacketQueue) HandleConnection(connection *PersistentConnection) err
defer p.RemoveListeners() defer p.RemoveListeners()
defer connection.Close() defer connection.Close()
var packet CartPacket var packet CartPacket
connection.SetReadDeadline(time.Now().Add(time.Millisecond * 200))
reader := bufio.NewReader(connection) reader := bufio.NewReader(connection)
for { for {
err := ReadCartPacket(reader, &packet) err := ReadCartPacket(reader, &packet)
if err != nil { if err != nil {
log.Printf("Error receiving packet: %v\n", err) log.Printf("Error receiving packet: %v\n", err)
return connection.HandleConnectionError(err) return connection.HandleConnectionError(err)
} }