diff options
-rw-r--r-- | src/main/java/org/bukkit/craftbukkit/ChunkCompressionThread.java | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/main/java/org/bukkit/craftbukkit/ChunkCompressionThread.java b/src/main/java/org/bukkit/craftbukkit/ChunkCompressionThread.java index 7490002f..9f9cd483 100644 --- a/src/main/java/org/bukkit/craftbukkit/ChunkCompressionThread.java +++ b/src/main/java/org/bukkit/craftbukkit/ChunkCompressionThread.java @@ -98,7 +98,12 @@ public final class ChunkCompressionThread implements Runnable { private void addToPlayerQueueSize(EntityPlayer player, int amount) { synchronized (queueSizePerPlayer) { Integer count = queueSizePerPlayer.get(player); - queueSizePerPlayer.put(player, (count == null ? 0 : count) + amount); + amount += (count == null) ? 0 : count; + if (amount == 0) { + queueSizePerPlayer.remove(player); + } else { + queueSizePerPlayer.put(player, amount); + } } } |