Skip to content

Commit 78e610e

Browse files
committed
PacketLimiter: Fix global queue
1 parent d48cef0 commit 78e610e

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/main/kotlin/com/lambda/module/modules/network/PacketLimiter.kt

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,9 @@ object PacketLimiter : Module(
7272
listen<PacketEvent.Send.Pre>(Int.MAX_VALUE) {
7373
if (it.packet::class.java.name in ignorePackets) return@listen
7474

75+
if (!globalQueue.add(it)) {
76+
it.cancel()
77+
}
7578
// [email protected]("Packet sent: ${it.packet::class.simpleName} (${packetQueue.size} / $limit) ${Instant.now()}")
7679
val queue = packetQueueMap.getOrPut(it.packet::class.java.name) {
7780
LimitedDecayQueue(limit, interval)

0 commit comments

Comments
 (0)