Upstream/AuthMeReloaded
1
0
Fork 0
mirror of https://github.com/AuthMe/AuthMeReloaded.git synced 2025-01-27 01:51:41 +01:00
Code Issues Projects Releases Wiki Activity

run saveAuth async in CacheDataSource

Browse Source
This commit is contained in:
DNx5 2015-09-15 15:39:45 +07:00
parent 3996c8cfca
commit f975fefd4a
1 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -12,16 +12,18 @@ import java.util.concurrent.ConcurrentHashMap;
public class CacheDataSource implements DataSource {
private final DataSource source;
private final AuthMe plugin;
private ConcurrentHashMap<String, PlayerAuth> cache = new ConcurrentHashMap<>();
public CacheDataSource(AuthMe plugin, DataSource src) {
public CacheDataSource(AuthMe pl, DataSource src) {
this.plugin = pl;
this.source = src;
/*
* We need to load all players in cache ... It will took more time to
* load the server, but it will be much easier to check for an
* isAuthAvailable !
*/
plugin.getServer().getScheduler().runTaskAsynchronously(plugin, new Runnable(){
pl.getServer().getScheduler().runTaskAsynchronously(pl, new Runnable() {
@Override
public void run() {
for (PlayerAuth auth : source.getAllAuths()) {
@ -46,12 +48,17 @@ public class CacheDataSource implements DataSource {
}
@Override
public synchronized boolean saveAuth(PlayerAuth auth) {
if (source.saveAuth(auth)) {
cache.put(auth.getNickname(), auth);
return true;
}
return false;
public synchronized boolean saveAuth(final PlayerAuth auth) {
cache.put(auth.getNickname(), auth);
plugin.getServer().getScheduler().runTaskAsynchronously(plugin, new Runnable() {
@Override
public void run() {
if (!source.saveAuth(auth)) {
cache.remove(auth.getNickname());
}
}
});
return true;
}
@Override