2009Scape/Server
1
0
Fork 1
mirror of https://gitlab.com/2009scape/2009scape.git synced 2026-08-28 05:45:10 -06:00
Code Issues Projects Releases Packages Wiki Activity

Static clearQueue() to PacketProcessor

Browse source
This commit is contained in:
dam 2026-07-03 20:48:29 +03:00
parent 6627efd780
commit f2625b1f3d
No known key found for this signature in database
GPG key ID: 4AF4E722399663FB
3 changed files with 9 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
Server/src/main/core/net/packet/PacketProcessor.kt
View file

@ -71,6 +71,12 @@ object PacketProcessor {
}
}
@JvmStatic fun clearQueue() {
synchronized(queueLock) {
queue.clear()
}
}
@JvmStatic fun processQueue() {
synchronized(queueLock) {
if (queue.isEmpty()) {

2
Server/src/test/kotlin/content/CombatMovementTests.kt
View file

@ -199,7 +199,7 @@ class CombatMovementTests {
enableRun(victim)
enablePvp(attacker, victim)
CombatMovementIntents.clear()
PacketProcessor.queue.clear()
PacketProcessor.clearQueue()
TestUtils.advanceTicks(1, false)
CombatMovementIntents.clear()

4
Server/src/test/kotlin/content/CombatPerformanceTests.kt
View file

@ -100,7 +100,7 @@ class CombatPerformanceTests {
}
private fun measureCombatTick(load: CombatLoad, tick: Int): Long {
PacketProcessor.queue.clear()
PacketProcessor.clearQueue()
load.resetPairPositionsAndMovement(tick)
load.requestAllCombatMovement()
@ -175,7 +175,7 @@ class CombatPerformanceTests {
}
GameWorld.Pulser.updateAll()
UpdateSequence.renderablePlayers.sync()
PacketProcessor.queue.clear()
PacketProcessor.clearQueue()
GameWorld.settings!!.wild_pvp_enabled = previousWildPvp
}