Skip to content

Commit 7dcd999

Browse files
committed
Reapply "[skip ci] add more debug to PlayerChannelInjector.kt and SurfBukkitVisualizerApiImpl.kt [please revert after testing]"
This reverts commit fd23b6c.
1 parent 0e516c4 commit 7dcd999

File tree

2 files changed

+30
-3
lines changed

2 files changed

+30
-3
lines changed

surf-api-bukkit/surf-api-bukkit-server/src/main/kotlin/dev/slne/surf/surfapi/bukkit/server/impl/visualizer/SurfBukkitVisualizerApiImpl.kt

Lines changed: 26 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ import dev.slne.surf.surfapi.bukkit.server.impl.visualizer.visualizer.AbstractSu
1111
import dev.slne.surf.surfapi.bukkit.server.impl.visualizer.visualizer.SurfVisualizerAreaImpl
1212
import dev.slne.surf.surfapi.bukkit.server.impl.visualizer.visualizer.SurfVisualizerMultipleLocationsImpl
1313
import dev.slne.surf.surfapi.bukkit.server.impl.visualizer.visualizer.SurfVisualizerSingleLocationImpl
14+
import dev.slne.surf.surfapi.core.api.util.logger
1415
import org.bukkit.Chunk
1516
import org.bukkit.Location
1617
import org.bukkit.World
@@ -60,16 +61,38 @@ class SurfBukkitVisualizerApiImpl : SurfBukkitVisualizerApi {
6061
visualizers.asMap().values.filter { it.isVisualizing() && it.visibleTo(player) }
6162

6263

64+
private val log = logger()
6365
fun processChunkReceiveUpdateForPlayer(player: Player, chunk: Chunk) {
64-
getActiveVisualizers(player).forEach { it.onPlayerReceiveChunk(player, chunk) }
66+
val active = getActiveVisualizers(player)
67+
68+
if (active.isNotEmpty()) {
69+
log.atInfo()
70+
.log("Received update for player ${player.name} for ${active.size} visualizers")
71+
}
72+
73+
active.forEach { it.onPlayerReceiveChunk(player, chunk) }
6574
}
6675

6776
fun processChunkUnloadForPlayer(player: Player, chunk: Chunk) {
68-
getActiveVisualizers(player).forEach { it.onPlayerUnloadChunk(player, chunk) }
77+
val active = getActiveVisualizers(player)
78+
79+
if (active.isNotEmpty()) {
80+
log.atInfo()
81+
.log("Received unload for player ${player.name} for ${active.size} visualizers")
82+
}
83+
84+
active.forEach { it.onPlayerUnloadChunk(player, chunk) }
6985
}
7086

7187
fun processPlayerQuit(player: Player) {
72-
visualizers.asMap().values.forEach { it.removeViewer(player) }
88+
val active = visualizers.asMap().values
89+
90+
if (active.isNotEmpty()) {
91+
log.atInfo()
92+
.log("Player ${player.name} quit, removing from ${active.size} visualizers")
93+
}
94+
95+
active.forEach { it.removeViewer(player) }
7396
}
7497
}
7598

surf-api-bukkit/surf-api-bukkit-server/src/main/kotlin/dev/slne/surf/surfapi/bukkit/server/packet/listener/PlayerChannelInjector.kt

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,10 @@ object PlayerChannelInjector : Listener {
4949

5050
private val playerInjectorCache = Caffeine.newBuilder()
5151
.weakValues()
52+
.removalListener<UUID, Connection> { key, value, cause ->
53+
log.atWarning()
54+
.log("Player connection cache for $key was removed due to $cause")
55+
}
5256
.expireAfterAccess(1.minutes)
5357
.build<UUID, Connection>()
5458

0 commit comments

Comments
 (0)