9
0
mirror of https://github.com/Xiao-MoMi/Custom-Nameplates.git synced 2025-12-19 15:09:23 +00:00

better support

This commit is contained in:
XiaoMoMi
2024-11-19 16:46:01 +08:00
parent 001ecd28ed
commit 3df6d66efb
8 changed files with 135 additions and 59 deletions

View File

@@ -37,6 +37,8 @@ import org.jetbrains.annotations.Nullable;
import java.util.*; import java.util.*;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArraySet; import java.util.concurrent.CopyOnWriteArraySet;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
public abstract class AbstractCNPlayer implements CNPlayer { public abstract class AbstractCNPlayer implements CNPlayer {
@@ -45,19 +47,20 @@ public abstract class AbstractCNPlayer implements CNPlayer {
protected Object player; protected Object player;
private boolean isLoaded = false; private volatile boolean isLoaded = false;
private volatile boolean tempPreviewing = false;
private boolean tempPreviewing = false; private volatile boolean toggleablePreviewing = false;
private boolean toggleablePreviewing = false;
private String equippedNameplate; private String equippedNameplate;
private String equippedBubble; private String equippedBubble;
private final TeamView teamView = new TeamView(); private final TeamView teamView = new TeamView();
// these two maps can be visited by other threads
private final Map<Integer, TimeStampData<String>> cachedValues = new ConcurrentHashMap<>(128); private final Map<Integer, TimeStampData<String>> cachedValues = new ConcurrentHashMap<>(128);
private final Map<Integer, WeakHashMap<CNPlayer, TimeStampData<String>>> cachedRelationalValues = new ConcurrentHashMap<>(128); private final Map<Integer, WeakHashMap<CNPlayer, TimeStampData<String>>> cachedRelationalValues = new ConcurrentHashMap<>(128);
// these two maps can only be modified in the same thread
private final Map<Integer, TimeStampData<Boolean>> cachedRequirements = new Int2ObjectOpenHashMap<>(32); private final Map<Integer, TimeStampData<Boolean>> cachedRequirements = new Int2ObjectOpenHashMap<>(32);
private final Map<Integer, WeakHashMap<CNPlayer, TimeStampData<Boolean>>> cachedRelationalRequirements = new Int2ObjectOpenHashMap<>(32); private final Map<Integer, WeakHashMap<CNPlayer, TimeStampData<Boolean>>> cachedRelationalRequirements = new Int2ObjectOpenHashMap<>(32);
@@ -65,7 +68,8 @@ public abstract class AbstractCNPlayer implements CNPlayer {
private final Map<Placeholder, Set<Feature>> placeholder2Features = new ConcurrentHashMap<>(); private final Map<Placeholder, Set<Feature>> placeholder2Features = new ConcurrentHashMap<>();
private final Map<Feature, Set<Placeholder>> feature2Placeholders = new ConcurrentHashMap<>(); private final Map<Feature, Set<Placeholder>> feature2Placeholders = new ConcurrentHashMap<>();
private final Map<CNPlayer, Tracker> trackers = Collections.synchronizedMap(new WeakHashMap<>()); private final Map<CNPlayer, Tracker> trackers = new WeakHashMap<>();
private final ReadWriteLock trackerLock = new ReentrantReadWriteLock();
protected AbstractCNPlayer(CustomNameplates plugin, Channel channel) { protected AbstractCNPlayer(CustomNameplates plugin, Channel channel) {
this.plugin = plugin; this.plugin = plugin;
@@ -437,58 +441,90 @@ public abstract class AbstractCNPlayer implements CNPlayer {
@Override @Override
public Tracker addPlayerToTracker(CNPlayer another) { public Tracker addPlayerToTracker(CNPlayer another) {
trackerLock.writeLock().lock();
try {
Tracker tracker = trackers.get(another); Tracker tracker = trackers.get(another);
if (tracker != null) { if (tracker != null) {
return tracker; return tracker;
} }
tracker = new Tracker(another); tracker = new Tracker(another);
trackers.put(another, tracker); trackers.put(another, tracker);
// for (Placeholder placeholder : activePlaceholders()) {
// if (placeholder instanceof RelationalPlaceholder relationalPlaceholder) {
// String value = relationalPlaceholder.request(this, another);
// setRelationalValue(relationalPlaceholder, another, value);
// }
// }
return tracker; return tracker;
} finally {
trackerLock.writeLock().unlock();
}
} }
@Override @Override
public void removePlayerFromTracker(CNPlayer another) { public void removePlayerFromTracker(CNPlayer another) {
trackerLock.writeLock().lock();
try {
trackers.remove(another); trackers.remove(another);
} finally {
trackerLock.writeLock().unlock();
}
} }
@Override @Override
public Collection<CNPlayer> nearbyPlayers() { public Collection<CNPlayer> nearbyPlayers() {
trackerLock.readLock().lock();
try {
// Create a snapshot of keys to avoid concurrent modification
return new ObjectArrayList<>(trackers.keySet()); return new ObjectArrayList<>(trackers.keySet());
} finally {
trackerLock.readLock().unlock();
}
} }
@Override @Override
public void trackPassengers(CNPlayer another, int... passengers) { public void trackPassengers(CNPlayer another, int... passengers) {
trackerLock.writeLock().lock();
try {
Tracker tracker = trackers.get(another); Tracker tracker = trackers.get(another);
if (tracker != null) { if (tracker != null) {
for (int passenger : passengers) { for (int passenger : passengers) {
tracker.addPassengerID(passenger); tracker.addPassengerID(passenger);
} }
} }
} finally {
trackerLock.writeLock().unlock();
}
} }
@Override @Override
public void untrackPassengers(CNPlayer another, int... passengers) { public void untrackPassengers(CNPlayer another, int... passengers) {
Optional.ofNullable(trackers.get(another)).ifPresent(tracker -> { trackerLock.writeLock().lock();
try {
Tracker tracker = trackers.get(another);
if (tracker != null) {
for (int passenger : passengers) { for (int passenger : passengers) {
tracker.removePassengerID(passenger); tracker.removePassengerID(passenger);
} }
}); }
} finally {
trackerLock.writeLock().unlock();
}
} }
@Override @Override
public Set<Integer> getTrackedPassengerIds(CNPlayer another) { public Set<Integer> getTrackedPassengerIds(CNPlayer another) {
return Optional.ofNullable(trackers.get(another)).map(Tracker::getPassengerIDs).orElse(new ObjectOpenHashSet<>()); trackerLock.readLock().lock();
try {
Tracker tracker = trackers.get(another);
return tracker != null ? tracker.getPassengerIDs() : new ObjectOpenHashSet<>();
} finally {
trackerLock.readLock().unlock();
}
} }
@Override @Override
public Tracker getTracker(CNPlayer another) { public Tracker getTracker(CNPlayer another) {
trackerLock.readLock().lock();
try {
return trackers.get(another); return trackers.get(another);
} finally {
trackerLock.readLock().unlock();
}
} }
@Override @Override

View File

@@ -34,6 +34,7 @@ public class MainTask implements Runnable {
private int timer; private int timer;
private final CustomNameplates plugin; private final CustomNameplates plugin;
private boolean state;
public MainTask(CustomNameplates plugin) { public MainTask(CustomNameplates plugin) {
this.plugin = plugin; this.plugin = plugin;
@@ -53,6 +54,10 @@ public class MainTask implements Runnable {
@Override @Override
public void run() { public void run() {
// we should skip the task if the server is heavily loaded
if (this.state) return;
this.state = true;
try {
RUN_TICKS++; RUN_TICKS++;
requestedSharedPlaceholders.clear(); requestedSharedPlaceholders.clear();
long time1 = System.nanoTime(); long time1 = System.nanoTime();
@@ -72,6 +77,9 @@ public class MainTask implements Runnable {
if (RUN_TICKS < 0) { if (RUN_TICKS < 0) {
CustomNameplates.getInstance().reload(); CustomNameplates.getInstance().reload();
} }
} finally {
this.state = false;
}
} }
public static HealthyProfile getHealthyProfile() { public static HealthyProfile getHealthyProfile() {

View File

@@ -61,12 +61,18 @@ public class VersionHelper {
private static float version; private static float version;
private static boolean mojmap; private static boolean mojmap;
private static boolean folia; private static boolean folia;
private static boolean mohist;
private static boolean paper;
public static void init(String serverVersion) { public static void init(String serverVersion) {
String[] split = serverVersion.split("\\."); String[] split = serverVersion.split("\\.");
version = Float.parseFloat(split[1] + "." + (split.length == 3 ? split[2] : "0")); version = Float.parseFloat(split[1] + "." + (split.length == 3 ? split[2] : "0"));
checkMojMap(); checkMojMap();
checkFolia(); checkFolia();
checkMohist();
checkPaper();
boolean isModdedServer = mohist;
paper = paper && !isModdedServer;
} }
public static float version() { public static float version() {
@@ -90,6 +96,22 @@ public class VersionHelper {
} }
} }
private static void checkMohist() {
try {
Class.forName("com.mohistmc.api.ServerAPI");
mohist = true;
} catch (ClassNotFoundException ignored) {
}
}
private static void checkPaper() {
try {
Class.forName("com.destroystokyo.paper.Metrics");
paper = true;
} catch (ClassNotFoundException ignored) {
}
}
public static boolean isVersionNewerThan1_21_2() { public static boolean isVersionNewerThan1_21_2() {
return version >= 21.19; return version >= 21.19;
} }
@@ -118,6 +140,14 @@ public class VersionHelper {
return folia; return folia;
} }
public static boolean isMohist() {
return mohist;
}
public static boolean isPaperOrItsForks() {
return paper;
}
public static boolean isMojmap() { public static boolean isMojmap() {
return mojmap; return mojmap;
} }

View File

@@ -25,6 +25,7 @@ import net.momirealms.customnameplates.api.feature.tag.NameTagConfig;
import net.momirealms.customnameplates.api.feature.tag.Tag; import net.momirealms.customnameplates.api.feature.tag.Tag;
import net.momirealms.customnameplates.api.feature.tag.TagRenderer; import net.momirealms.customnameplates.api.feature.tag.TagRenderer;
import net.momirealms.customnameplates.api.feature.tag.UnlimitedTagManager; import net.momirealms.customnameplates.api.feature.tag.UnlimitedTagManager;
import net.momirealms.customnameplates.api.helper.VersionHelper;
import net.momirealms.customnameplates.api.network.Tracker; import net.momirealms.customnameplates.api.network.Tracker;
import java.util.*; import java.util.*;
@@ -301,7 +302,13 @@ public class TagRendererImpl implements TagRenderer {
passengers[index++] = passenger; passengers[index++] = passenger;
} }
Object packet = CustomNameplates.getInstance().getPlatform().setPassengersPacket(owner.entityID(), passengers); Object packet = CustomNameplates.getInstance().getPlatform().setPassengersPacket(owner.entityID(), passengers);
if (VersionHelper.isPaperOrItsForks()) {
CustomNameplates.getInstance().getPacketSender().sendPacket(another, packet); CustomNameplates.getInstance().getPacketSender().sendPacket(another, packet);
} else {
CustomNameplates.getInstance().getScheduler().sync().runLater(() -> {
CustomNameplates.getInstance().getPacketSender().sendPacket(another, packet);
}, 0, null);
}
} }
public void handleEntityDataChange(CNPlayer another, boolean isCrouching) { public void handleEntityDataChange(CNPlayer another, boolean isCrouching) {

View File

@@ -66,8 +66,8 @@ other-settings:
display-system-actionbar: true # Should the plugin display system actionbar and temporarily hide the custom actionbar? display-system-actionbar: true # Should the plugin display system actionbar and temporarily hide the custom actionbar?
hide-team-names: true # Hide the team name sent by other plugins or vanilla team system hide-team-names: true # Hide the team name sent by other plugins or vanilla team system
unsafe-chat-event: false # Listen for canceled(unsafe) chat events from unknown plugins unsafe-chat-event: false # Listen for canceled(unsafe) chat events from unknown plugins
default-condition-refresh-interval: 20 # Set default condition refresh interval default-condition-refresh-interval: 10 # Set default condition refresh interval in ticks
default-placeholder-refresh-interval: 1 # Set default placeholder refresh interval default-placeholder-refresh-interval: 1 # Set default placeholder refresh interval in ticks
placeholder-refresh-interval: # Custom placeholder refresh intervals for performance optimization placeholder-refresh-interval: # Custom placeholder refresh intervals for performance optimization
"%player_name%": 100 "%player_name%": 100
"%vault_prefix%": 20 "%vault_prefix%": 20

View File

@@ -80,7 +80,7 @@ public class BukkitCNPlayer extends AbstractCNPlayer {
@Override @Override
public Vector3 position() { public Vector3 position() {
Location location = player().getLocation(); Location location = player().getLocation();
return new Vector3(location.x(), location.y(), location.z()); return new Vector3(location.getX(), location.getY(), location.getZ());
} }
@Override @Override

View File

@@ -52,13 +52,8 @@ public class BukkitExecutor implements RegionExecutor<Location> {
@Override @Override
public SchedulerTask runLater(Runnable r, long delayTicks, Location l) { public SchedulerTask runLater(Runnable r, long delayTicks, Location l) {
if (delayTicks == 0) { if (delayTicks == 0) {
if (Bukkit.isPrimaryThread()) {
r.run();
return new DummyTask();
} else {
return new BukkitTask(Bukkit.getScheduler().runTask(plugin, r)); return new BukkitTask(Bukkit.getScheduler().runTask(plugin, r));
} }
}
return new BukkitTask(Bukkit.getScheduler().runTaskLater(plugin, r, delayTicks)); return new BukkitTask(Bukkit.getScheduler().runTaskLater(plugin, r, delayTicks));
} }

View File

@@ -1,6 +1,6 @@
# Project settings # Project settings
# Rule: [major update].[feature update].[bug fix] # Rule: [major update].[feature update].[bug fix]
project_version=3.0.12.1 project_version=3.0.13
config_version=32 config_version=32
project_group=net.momirealms project_group=net.momirealms