mirror of
https://github.com/PaperMC/Paper.git
synced 2025-01-06 00:07:56 +01:00
Fix AdvancementDataPlayer leak due from quitting early in login
Move the criterion storage to the AdvancementDataPlayer object itself, so the criterion object stores no references - and thus needs no cleanup.
This commit is contained in:
parent
760f623ace
commit
7b340b4aa2
@ -0,0 +1,41 @@
|
|||||||
|
--- a/net/minecraft/advancements/critereon/SimpleCriterionTrigger.java
|
||||||
|
+++ b/net/minecraft/advancements/critereon/SimpleCriterionTrigger.java
|
||||||
|
@@ -15,32 +15,32 @@
|
||||||
|
import net.minecraft.world.level.storage.loot.LootContext;
|
||||||
|
|
||||||
|
public abstract class SimpleCriterionTrigger<T extends SimpleCriterionTrigger.SimpleInstance> implements CriterionTrigger<T> {
|
||||||
|
- private final Map<PlayerAdvancements, Set<CriterionTrigger.Listener<T>>> players = Maps.newIdentityHashMap();
|
||||||
|
+ // private final Map<PlayerAdvancements, Set<CriterionTrigger.Listener<T>>> players = Maps.newIdentityHashMap(); // Paper - fix AdvancementDataPlayer leak; moved into AdvancementDataPlayer to fix memory leak
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public final void addPlayerListener(PlayerAdvancements manager, CriterionTrigger.Listener<T> conditions) {
|
||||||
|
- this.players.computeIfAbsent(manager, managerx -> Sets.newHashSet()).add(conditions);
|
||||||
|
+ manager.criterionData.computeIfAbsent(this, managerx -> Sets.newHashSet()).add(conditions); // Paper - fix AdvancementDataPlayer leak
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public final void removePlayerListener(PlayerAdvancements manager, CriterionTrigger.Listener<T> conditions) {
|
||||||
|
- Set<CriterionTrigger.Listener<T>> set = this.players.get(manager);
|
||||||
|
+ Set<CriterionTrigger.Listener<T>> set = (Set) manager.criterionData.get(this); // Paper - fix AdvancementDataPlayer leak
|
||||||
|
if (set != null) {
|
||||||
|
set.remove(conditions);
|
||||||
|
if (set.isEmpty()) {
|
||||||
|
- this.players.remove(manager);
|
||||||
|
+ manager.criterionData.remove(this); // Paper - fix AdvancementDataPlayer leak
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public final void removePlayerListeners(PlayerAdvancements tracker) {
|
||||||
|
- this.players.remove(tracker);
|
||||||
|
+ tracker.criterionData.remove(this); // Paper - fix AdvancementDataPlayer leak
|
||||||
|
}
|
||||||
|
|
||||||
|
protected void trigger(ServerPlayer player, Predicate<T> predicate) {
|
||||||
|
PlayerAdvancements playerAdvancements = player.getAdvancements();
|
||||||
|
- Set<CriterionTrigger.Listener<T>> set = this.players.get(playerAdvancements);
|
||||||
|
+ Set<CriterionTrigger.Listener<T>> set = (Set) playerAdvancements.criterionData.get(this); // Paper - fix AdvancementDataPlayer leak
|
||||||
|
if (set != null && !set.isEmpty()) {
|
||||||
|
LootContext lootContext = EntityPredicate.createContext(player, player);
|
||||||
|
List<CriterionTrigger.Listener<T>> list = null;
|
@ -1,6 +1,14 @@
|
|||||||
--- a/net/minecraft/server/PlayerAdvancements.java
|
--- a/net/minecraft/server/PlayerAdvancements.java
|
||||||
+++ b/net/minecraft/server/PlayerAdvancements.java
|
+++ b/net/minecraft/server/PlayerAdvancements.java
|
||||||
@@ -162,6 +162,7 @@
|
@@ -63,6 +63,7 @@
|
||||||
|
private AdvancementHolder lastSelectedTab;
|
||||||
|
private boolean isFirstPacket = true;
|
||||||
|
private final Codec<PlayerAdvancements.Data> codec;
|
||||||
|
+ public final Map<net.minecraft.advancements.critereon.SimpleCriterionTrigger<?>, Set<CriterionTrigger.Listener<?>>> criterionData = new java.util.IdentityHashMap<>(); // Paper - fix advancement data player leakage
|
||||||
|
|
||||||
|
public PlayerAdvancements(DataFixer dataFixer, PlayerList playerManager, ServerAdvancementManager advancementLoader, Path filePath, ServerPlayer owner) {
|
||||||
|
this.playerList = playerManager;
|
||||||
|
@@ -162,6 +163,7 @@
|
||||||
}
|
}
|
||||||
|
|
||||||
public void save() {
|
public void save() {
|
||||||
@ -8,7 +16,7 @@
|
|||||||
JsonElement jsonelement = (JsonElement) this.codec.encodeStart(JsonOps.INSTANCE, this.asData()).getOrThrow();
|
JsonElement jsonelement = (JsonElement) this.codec.encodeStart(JsonOps.INSTANCE, this.asData()).getOrThrow();
|
||||||
|
|
||||||
try {
|
try {
|
||||||
@@ -196,6 +197,7 @@
|
@@ -196,6 +198,7 @@
|
||||||
AdvancementHolder advancementholder = loader.get(minecraftkey);
|
AdvancementHolder advancementholder = loader.get(minecraftkey);
|
||||||
|
|
||||||
if (advancementholder == null) {
|
if (advancementholder == null) {
|
||||||
@ -16,7 +24,7 @@
|
|||||||
PlayerAdvancements.LOGGER.warn("Ignored advancement '{}' in progress file {} - it doesn't exist anymore?", minecraftkey, this.playerSavePath);
|
PlayerAdvancements.LOGGER.warn("Ignored advancement '{}' in progress file {} - it doesn't exist anymore?", minecraftkey, this.playerSavePath);
|
||||||
} else {
|
} else {
|
||||||
this.startProgress(advancementholder, advancementprogress);
|
this.startProgress(advancementholder, advancementprogress);
|
||||||
@@ -223,10 +225,17 @@
|
@@ -223,10 +226,17 @@
|
||||||
boolean flag1 = advancementprogress.isDone();
|
boolean flag1 = advancementprogress.isDone();
|
||||||
|
|
||||||
if (advancementprogress.grantProgress(criterionName)) {
|
if (advancementprogress.grantProgress(criterionName)) {
|
||||||
|
Loading…
Reference in New Issue
Block a user