Upstream/AuthMeReloaded
1
0
Fork 0
mirror of https://github.com/AuthMe/AuthMeReloaded.git synced 2024-10-31 07:39:42 +01:00
Code Issues Projects Releases Wiki Activity

Add a join blocker in case Cache Loading

Browse Source
This commit is contained in:
vanhec_a 2015-10-31 17:34:16 +01:00
parent e466f01791
commit f722fa161a
3 changed files with 30 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/fr/xephi/authme/AuthMe.java
View File

@ -106,7 +106,18 @@ public class AuthMe extends JavaPlugin {
public ConcurrentHashMap<String, String> cap = new ConcurrentHashMap<>();
public ConcurrentHashMap<String, String> realIp = new ConcurrentHashMap<>();
public static AuthMe getInstance() {
// In case we need to cache PlayerAuths, prevent connection before it's done
private boolean canConnect = true;
public boolean isCanConnect() {
return canConnect;
}
public void setCanConnect(boolean canConnect) {
this.canConnect = canConnect;
}
public static AuthMe getInstance() {
return authme;
}

4
src/main/java/fr/xephi/authme/datasource/CacheDataSource.java
View File

@ -20,9 +20,10 @@ public class CacheDataSource implements DataSource {
private final ExecutorService exec;
private final ConcurrentHashMap<String, PlayerAuth> cache = new ConcurrentHashMap<>();
public CacheDataSource(AuthMe pl, DataSource src) {
public CacheDataSource(final AuthMe pl, DataSource src) {
this.source = src;
this.exec = Executors.newCachedThreadPool();
pl.setCanConnect(false);
/*
* We need to load all players in cache ... It will took more time to
@ -35,6 +36,7 @@ public class CacheDataSource implements DataSource {
for (PlayerAuth auth : source.getAllAuths()) {
cache.put(auth.getNickname().toLowerCase(), auth);
}
pl.setCanConnect(true);
}
});
}

15
src/main/java/fr/xephi/authme/process/join/AsyncronousJoin.java
View File

@ -58,6 +58,21 @@ public class AsyncronousJoin {
plugin.ess.getUser(player).setSocialSpyEnabled(false);
}
if (!plugin.isCanConnect())
{
final GameMode gM = AuthMePlayerListener.gameMode.get(name);
sched.scheduleSyncDelayedTask(plugin, new Runnable() {
@Override
public void run() {
AuthMePlayerListener.causeByAuthMe.putIfAbsent(name, true);
player.setGameMode(gM);
player.kickPlayer("Server is loading, please wait before joining!");
}
});
}
final String ip = plugin.getIP(player);
if (Settings.isAllowRestrictedIp && !Settings.getRestrictedIp(name, ip)) {
final GameMode gM = AuthMePlayerListener.gameMode.get(name);