cdanesi/ajQueue
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix rare concurrency error

Browse Source
This commit is contained in:
ajgeiss0702
2022-08-05 12:29:51 -07:00
parent c2bac1c640
commit b545687b8d
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/src/main/java/us/ajg0702/queue/common/QueueManagerImpl.java
+4 -2
View File
@@ -352,7 +352,8 @@ public class QueueManagerImpl implements QueueManager {
AdaptedPlayer player = queuePlayer.getPlayer(); AdaptedPlayer player = queuePlayer.getPlayer();
if(player == null) continue; if(player == null) continue;
if(!getSingleServer(player).equals(server)) continue; QueueServer singleServer = getSingleServer(player);
if(singleServer == null || !singleServer.equals(server)) continue;
if(!server.isJoinable(player)) { if(!server.isJoinable(player)) {
player.sendActionBar(msgs.getComponent("spigot.actionbar.offline", player.sendActionBar(msgs.getComponent("spigot.actionbar.offline",
@@ -392,7 +393,8 @@ public class QueueManagerImpl implements QueueManager {
AdaptedPlayer player = queuePlayer.getPlayer(); AdaptedPlayer player = queuePlayer.getPlayer();
if(player == null) continue; if(player == null) continue;
if(!getSingleServer(player).equals(server)) continue; QueueServer singleServer = getSingleServer(player);
if(singleServer == null || !singleServer.equals(server)) continue;
int time = (int) Math.round(pos * main.getTimeBetweenPlayers()); int time = (int) Math.round(pos * main.getTimeBetweenPlayers());