spigot/CraftBukkit-Patches/0081-Convert-player-skulls-async.patch
2018-07-15 10:00:00 +10:00

221 lines
9.7 KiB
Diff

From 3b1501f34a8b49534c85b17d52ea824ef827e29e Mon Sep 17 00:00:00 2001
From: Thinkofdeath <thethinkofdeath@gmail.com>
Date: Sun, 20 Apr 2014 13:18:55 +0100
Subject: [PATCH] Convert player skulls async
diff --git a/src/main/java/net/minecraft/server/ItemSkullPlayer.java b/src/main/java/net/minecraft/server/ItemSkullPlayer.java
index 28916b0e..a21ec22a 100644
--- a/src/main/java/net/minecraft/server/ItemSkullPlayer.java
+++ b/src/main/java/net/minecraft/server/ItemSkullPlayer.java
@@ -38,8 +38,16 @@ public class ItemSkullPlayer extends ItemBlockWallable {
if (nbttagcompound.hasKeyOfType("SkullOwner", 8) && !StringUtils.isBlank(nbttagcompound.getString("SkullOwner"))) {
GameProfile gameprofile = new GameProfile((UUID) null, nbttagcompound.getString("SkullOwner"));
- gameprofile = TileEntitySkull.b(gameprofile);
- nbttagcompound.set("SkullOwner", GameProfileSerializer.serialize(new NBTTagCompound(), gameprofile));
+ // Spigot start
+ TileEntitySkull.b(gameprofile, new com.google.common.base.Predicate<GameProfile>() {
+
+ @Override
+ public boolean apply(GameProfile gameprofile) {
+ nbttagcompound.set("SkullOwner", GameProfileSerializer.serialize(new NBTTagCompound(), gameprofile));
+ return false;
+ }
+ }, false);
+ // Spigot end
return true;
} else {
// CraftBukkit start
diff --git a/src/main/java/net/minecraft/server/TileEntitySkull.java b/src/main/java/net/minecraft/server/TileEntitySkull.java
index c6f69153..db4967f2 100644
--- a/src/main/java/net/minecraft/server/TileEntitySkull.java
+++ b/src/main/java/net/minecraft/server/TileEntitySkull.java
@@ -7,6 +7,23 @@ import com.mojang.authlib.properties.Property;
import java.util.UUID;
import javax.annotation.Nullable;
+// Spigot start
+import com.google.common.base.Predicate;
+import com.google.common.cache.LoadingCache;
+import com.google.common.cache.CacheBuilder;
+import com.google.common.cache.CacheLoader;
+import com.google.common.util.concurrent.Futures;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
+
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
+import com.mojang.authlib.Agent;
+import com.mojang.authlib.ProfileLookupCallback;
+import java.util.concurrent.Callable;
+// Spigot end
+
public class TileEntitySkull extends TileEntity implements ITickable {
private GameProfile a;
@@ -15,6 +32,58 @@ public class TileEntitySkull extends TileEntity implements ITickable {
public boolean drop = true;
private static UserCache h;
private static MinecraftSessionService i;
+ // Spigot start
+ public static final ExecutorService executor = Executors.newFixedThreadPool(3,
+ new ThreadFactoryBuilder()
+ .setNameFormat("Head Conversion Thread - %1$d")
+ .build()
+ );
+ public static final LoadingCache<String, GameProfile> skinCache = CacheBuilder.newBuilder()
+ .maximumSize( 5000 )
+ .expireAfterAccess( 60, TimeUnit.MINUTES )
+ .build( new CacheLoader<String, GameProfile>()
+ {
+ @Override
+ public GameProfile load(String key) throws Exception
+ {
+ final GameProfile[] profiles = new GameProfile[1];
+ ProfileLookupCallback gameProfileLookup = new ProfileLookupCallback() {
+
+ @Override
+ public void onProfileLookupSucceeded(GameProfile gp) {
+ profiles[0] = gp;
+ }
+
+ @Override
+ public void onProfileLookupFailed(GameProfile gp, Exception excptn) {
+ profiles[0] = gp;
+ }
+ };
+
+ MinecraftServer.getServer().getGameProfileRepository().findProfilesByNames(new String[] { key }, Agent.MINECRAFT, gameProfileLookup);
+
+ GameProfile profile = profiles[ 0 ];
+ if (profile == null) {
+ UUID uuid = EntityHuman.a(new GameProfile(null, key));
+ profile = new GameProfile(uuid, key);
+
+ gameProfileLookup.onProfileLookupSucceeded(profile);
+ } else
+ {
+
+ Property property = Iterables.getFirst( profile.getProperties().get( "textures" ), null );
+
+ if ( property == null )
+ {
+ profile = TileEntitySkull.i.fillProfileProperties( profile, true );
+ }
+ }
+
+
+ return profile;
+ }
+ } );
+ // Spigot end
public TileEntitySkull() {
super(TileEntityTypes.p);
@@ -89,35 +158,70 @@ public class TileEntitySkull extends TileEntity implements ITickable {
}
private void f() {
- this.a = b(this.a);
- this.update();
+ // Spigot start
+ GameProfile profile = this.getGameProfile();
+ b(profile, new Predicate<GameProfile>() {
+
+ @Override
+ public boolean apply(GameProfile input) {
+ a = input;
+ update();
+ return false;
+ }
+ }, false);
+ // Spigot end
}
- public static GameProfile b(GameProfile gameprofile) {
+ // Spigot start - Support async lookups
+ public static Future<GameProfile> b(final GameProfile gameprofile, final Predicate<GameProfile> callback, boolean sync) {
if (gameprofile != null && !UtilColor.b(gameprofile.getName())) {
if (gameprofile.isComplete() && gameprofile.getProperties().containsKey("textures")) {
- return gameprofile;
- } else if (TileEntitySkull.h != null && TileEntitySkull.i != null) {
- GameProfile gameprofile1 = TileEntitySkull.h.getProfile(gameprofile.getName());
+ callback.apply(gameprofile);
+ } else if (MinecraftServer.getServer() == null) {
+ callback.apply(gameprofile);
+ } else {
+ GameProfile profile = skinCache.getIfPresent(gameprofile.getName().toLowerCase(java.util.Locale.ROOT));
+ if (profile != null && Iterables.getFirst(profile.getProperties().get("textures"), (Object) null) != null) {
+ callback.apply(profile);
- if (gameprofile1 == null) {
- return gameprofile;
+ return Futures.immediateFuture(profile);
} else {
- Property property = (Property) Iterables.getFirst(gameprofile1.getProperties().get("textures"), (Object) null);
-
- if (property == null) {
- gameprofile1 = TileEntitySkull.i.fillProfileProperties(gameprofile1, true);
+ Callable<GameProfile> callable = new Callable<GameProfile>() {
+ @Override
+ public GameProfile call() {
+ final GameProfile profile = skinCache.getUnchecked(gameprofile.getName().toLowerCase(java.util.Locale.ROOT));
+ MinecraftServer.getServer().processQueue.add(new Runnable() {
+ @Override
+ public void run() {
+ if (profile == null) {
+ callback.apply(gameprofile);
+ } else {
+ callback.apply(profile);
+ }
+ }
+ });
+ return profile;
+ }
+ };
+ if (sync) {
+ try {
+ return Futures.immediateFuture(callable.call());
+ } catch (Exception ex) {
+ com.google.common.base.Throwables.throwIfUnchecked(ex);
+ throw new RuntimeException(ex); // Not possible
+ }
+ } else {
+ return executor.submit(callable);
}
-
- return gameprofile1;
}
- } else {
- return gameprofile;
}
} else {
- return gameprofile;
+ callback.apply(gameprofile);
}
+
+ return Futures.immediateFuture(gameprofile);
}
+ // Spigot end
// CraftBukkit start
public static void a(IBlockAccess iblockaccess, BlockPosition blockposition) {
diff --git a/src/main/java/org/bukkit/craftbukkit/inventory/CraftMetaSkull.java b/src/main/java/org/bukkit/craftbukkit/inventory/CraftMetaSkull.java
index e3951103..4cfc70aa 100644
--- a/src/main/java/org/bukkit/craftbukkit/inventory/CraftMetaSkull.java
+++ b/src/main/java/org/bukkit/craftbukkit/inventory/CraftMetaSkull.java
@@ -77,7 +77,8 @@ class CraftMetaSkull extends CraftMetaItem implements SkullMeta {
if (profile != null) {
// Fill in textures
- profile = TileEntitySkull.b(profile);
+ // Must be done sync due to way client handles textures
+ profile = com.google.common.util.concurrent.Futures.getUnchecked(TileEntitySkull.b(profile, com.google.common.base.Predicates.alwaysTrue(), true)); // Spigot
NBTTagCompound owner = new NBTTagCompound();
GameProfileSerializer.serialize(owner, profile);
--
2.17.1