Paper/patches/server/0094-Optimize-UserCache-Thr...

112 lines
4.8 KiB
Diff
Raw Normal View History

2021-06-11 12:02:28 +00:00
From 0000000000000000000000000000000000000000 Mon Sep 17 00:00:00 2001
From: Aikar <aikar@aikar.co>
Date: Mon, 16 May 2016 20:47:41 -0400
Subject: [PATCH] Optimize UserCache / Thread Safe
Because Techable keeps complaining about how this isn't thread safe,
easier to do this than replace the entire thing.
Additionally, move Saving of the User cache to be done async, incase
the user never changed the default setting for Spigot's save on stop only.
2021-06-12 05:20:08 +00:00
1.17: TODO does this need the synchronized blocks anymore?
2021-06-11 12:02:28 +00:00
diff --git a/src/main/java/net/minecraft/server/MinecraftServer.java b/src/main/java/net/minecraft/server/MinecraftServer.java
2021-06-12 05:20:08 +00:00
index ef231e11b90b24418a77b62f5fe766c9ac10c09b..74073d3f8c9dda6f10e9fb34071dae079b73fb24 100644
2021-06-11 12:02:28 +00:00
--- a/src/main/java/net/minecraft/server/MinecraftServer.java
+++ b/src/main/java/net/minecraft/server/MinecraftServer.java
2021-06-12 05:20:08 +00:00
@@ -963,7 +963,7 @@ public abstract class MinecraftServer extends ReentrantBlockableEventLoop<TickTa
2021-06-11 12:02:28 +00:00
} catch (java.lang.InterruptedException ignored) {} // Paper
if (org.spigotmc.SpigotConfig.saveUserCacheOnStopOnly) {
2021-06-12 05:20:08 +00:00
MinecraftServer.LOGGER.info("Saving usercache.json");
2021-06-11 12:02:28 +00:00
- this.getProfileCache().save();
2021-06-12 05:20:08 +00:00
+ this.getProfileCache().save(false); // Paper
2021-06-11 12:02:28 +00:00
}
// Spigot end
diff --git a/src/main/java/net/minecraft/server/dedicated/DedicatedServer.java b/src/main/java/net/minecraft/server/dedicated/DedicatedServer.java
2021-06-12 05:20:08 +00:00
index 566390d02b2af4a0f2c867b7ff8116a8301e8497..e2095308a8ec8471b04acce929d314fd828bc3de 100644
2021-06-11 12:02:28 +00:00
--- a/src/main/java/net/minecraft/server/dedicated/DedicatedServer.java
+++ b/src/main/java/net/minecraft/server/dedicated/DedicatedServer.java
2021-06-12 05:20:08 +00:00
@@ -256,7 +256,7 @@ public class DedicatedServer extends MinecraftServer implements ServerInterface
2021-06-11 12:02:28 +00:00
}
if (this.convertOldUsers()) {
- this.getProfileCache().save();
2021-06-12 05:20:08 +00:00
+ this.getProfileCache().save(false); // Paper
2021-06-11 12:02:28 +00:00
}
if (!OldUsersConverter.serverReadyAfterUserconversion(this)) {
diff --git a/src/main/java/net/minecraft/server/players/GameProfileCache.java b/src/main/java/net/minecraft/server/players/GameProfileCache.java
2021-06-12 05:20:08 +00:00
index 8b972d0fec5636b1979abf4055ea8d29530158f4..95682f63c7ae1460b069e13f11295f72c1f262a8 100644
2021-06-11 12:02:28 +00:00
--- a/src/main/java/net/minecraft/server/players/GameProfileCache.java
+++ b/src/main/java/net/minecraft/server/players/GameProfileCache.java
2021-06-12 05:20:08 +00:00
@@ -117,7 +117,7 @@ public class GameProfileCache {
2021-06-11 12:02:28 +00:00
return GameProfileCache.usesAuthentication;
}
2021-06-12 05:20:08 +00:00
- public void add(GameProfile profile) {
+ public synchronized void add(GameProfile profile) { // Paper - synchronize
2021-06-11 12:02:28 +00:00
Calendar calendar = Calendar.getInstance();
calendar.setTime(new Date());
2021-06-12 05:20:08 +00:00
@@ -126,7 +126,7 @@ public class GameProfileCache {
GameProfileCache.GameProfileInfo usercache_usercacheentry = new GameProfileCache.GameProfileInfo(profile, date);
2021-06-11 12:02:28 +00:00
this.safeAdd(usercache_usercacheentry);
- if( !org.spigotmc.SpigotConfig.saveUserCacheOnStopOnly ) this.save(); // Spigot - skip saving if disabled
2021-06-12 05:20:08 +00:00
+ if( !org.spigotmc.SpigotConfig.saveUserCacheOnStopOnly ) this.save(true); // Spigot - skip saving if disabled // Paper - async
2021-06-11 12:02:28 +00:00
}
private long getNextOperation() {
2021-06-12 05:20:08 +00:00
@@ -134,7 +134,7 @@ public class GameProfileCache {
2021-06-11 12:02:28 +00:00
}
@Nullable
2021-06-12 05:20:08 +00:00
- public GameProfile getProfile(String s) {
+ public synchronized GameProfile getProfile(String s) { // Paper - synchronize
2021-06-11 12:02:28 +00:00
String s1 = s.toLowerCase(Locale.ROOT);
GameProfileCache.GameProfileInfo usercache_usercacheentry = (GameProfileCache.GameProfileInfo) this.profilesByName.get(s1);
boolean flag = false;
2021-06-12 05:20:08 +00:00
@@ -160,7 +160,7 @@ public class GameProfileCache {
2021-06-11 12:02:28 +00:00
}
if (flag && !org.spigotmc.SpigotConfig.saveUserCacheOnStopOnly) { // Spigot - skip saving if disabled
- this.save();
2021-06-12 05:20:08 +00:00
+ this.save(true); // Paper
2021-06-11 12:02:28 +00:00
}
return gameprofile;
2021-06-12 05:20:08 +00:00
@@ -273,7 +273,7 @@ public class GameProfileCache {
2021-06-11 12:02:28 +00:00
return arraylist;
}
- public void save() {
2021-06-12 05:20:08 +00:00
+ public void save(boolean asyncSave) { // Paper
2021-06-11 12:02:28 +00:00
JsonArray jsonarray = new JsonArray();
2021-06-12 05:20:08 +00:00
DateFormat dateformat = GameProfileCache.createDateFormat();
2021-06-11 12:02:28 +00:00
2021-06-12 05:20:08 +00:00
@@ -281,6 +281,7 @@ public class GameProfileCache {
jsonarray.add(GameProfileCache.writeGameProfile(usercache_usercacheentry, dateformat));
2021-06-11 12:02:28 +00:00
});
String s = this.gson.toJson(jsonarray);
+ Runnable save = () -> { // Paper
try {
BufferedWriter bufferedwriter = Files.newWriter(this.file, StandardCharsets.UTF_8);
2021-06-12 05:20:08 +00:00
@@ -305,6 +306,14 @@ public class GameProfileCache {
2021-06-11 12:02:28 +00:00
} catch (IOException ioexception) {
;
}
+ // Paper start
+ };
+ if (asyncSave) {
2021-06-12 05:20:08 +00:00
+ net.minecraft.server.MCUtil.scheduleAsyncTask(save);
2021-06-11 12:02:28 +00:00
+ } else {
+ save.run();
+ }
+ // Paper end
}