summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/main/java/org/bukkit/craftbukkit/ChunkCompressionThread.java7
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);
+ }
}
}