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

remove dead packages even if no new messages exist
All checks were successful
Build and Publish / BuildAndDeploy (push) Successful in 1m53s
Details

Browse Source
This commit is contained in:
matst80
2024-11-10 11:41:30 +01:00
parent 9d3d61bd83
commit 015e9d8d48
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
packet-queue.go
View File

@@ -43,14 +43,18 @@ func NewPacketQueue(connection net.Conn) *PacketQueue {
queue.mu.Lock() queue.mu.Lock()
now := time.Now().Add(-time.Millisecond * 500) now := time.Now().Add(-time.Millisecond * 500)
keepIndex := -1
for i, packet := range queue.Packets { for i, packet := range queue.Packets {
if packet.Added.After(now) { if packet.Added.After(now) {
stillInQueue := queue.Packets[i:] keepIndex = i
log.Printf("DEBUG: Requeueing %d packets\n", len(stillInQueue))
queue.Packets = stillInQueue
break break
} }
} }
if keepIndex == -1 {
queue.Packets = queue.Packets[:0]
} else {
queue.Packets = queue.Packets[keepIndex:]
}
queue.Packets = append(queue.Packets, PacketWithData{ queue.Packets = append(queue.Packets, PacketWithData{
MessageType: messageType, MessageType: messageType,
Added: ts, Added: ts,