queue trim

packet-queue.go

@@ -42,12 +42,12 @@ func NewPacketQueue(connection net.Conn) *PacketQueue {
 			}
 
 			queue.mu.Lock()
+			now := time.Now().Add(-time.Millisecond * 500)
 			for i, packet := range queue.Packets {
-				if time.Since(packet.Added) > time.Second {
+				if packet.Added.After(now) {
 					stillInQueue := queue.Packets[i:]
-					log.Printf("DEBUG: Requeueing %v packets\n", stillInQueue)
+					log.Printf("DEBUG: Requeueing %d packets\n", len(stillInQueue))
 					queue.Packets = stillInQueue
-					packetQueue.Set(float64(len(queue.Packets)))
 					break
 				}
 			}
@@ -58,7 +58,7 @@ func NewPacketQueue(connection net.Conn) *PacketQueue {
 			})
 			queue.mu.Unlock()
 			packetsReceived.Inc()
-			packetQueue.Inc()
+			packetQueue.Set(float64(len(queue.Packets)))
 		}
 	}()
 	return queue