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