IN DEVELOPPEMENT !!!! Begin to increase performances

src/main/java/fr/xephi/authme/process/logout/AsyncronousLogout.java

@@ -0,0 +1,94 @@
+package fr.xephi.authme.process.logout;
+
+import org.bukkit.Location;
+import org.bukkit.entity.Player;
+import org.bukkit.scheduler.BukkitScheduler;
+
+import fr.xephi.authme.AuthMe;
+import fr.xephi.authme.Utils;
+import fr.xephi.authme.Utils.groupType;
+import fr.xephi.authme.cache.auth.PlayerAuth;
+import fr.xephi.authme.cache.auth.PlayerCache;
+import fr.xephi.authme.cache.backup.DataFileCache;
+import fr.xephi.authme.cache.backup.FileCache;
+import fr.xephi.authme.cache.limbo.LimboCache;
+import fr.xephi.authme.datasource.DataSource;
+import fr.xephi.authme.events.AuthMeTeleportEvent;
+import fr.xephi.authme.settings.Messages;
+import fr.xephi.authme.settings.Settings;
+
+public class AsyncronousLogout {
+
+    protected Player player;
+    protected String name;
+    protected AuthMe plugin;
+    protected DataSource database;
+    protected boolean canLogout = true;
+    private Messages m = Messages.getInstance();
+    private Utils utils = Utils.getInstance();
+    private FileCache playerBackup;
+
+    public AsyncronousLogout(Player player, AuthMe plugin, DataSource database) {
+        this.player = player;
+        this.plugin = plugin;
+        this.database = database;
+        this.name = player.getName().toLowerCase();
+        this.playerBackup = new FileCache(plugin);
+    }
+
+    private void preLogout() {
+        if (!PlayerCache.getInstance().isAuthenticated(name)) {
+            m.send(player, "not_logged_in");
+            canLogout = false;
+        }
+    }
+
+    public void process() {
+        preLogout();
+        if (!canLogout)
+            return;
+        final Player p = player;
+        BukkitScheduler sched = p.getServer().getScheduler();
+        PlayerAuth auth = PlayerCache.getInstance().getAuth(name);
+        if (Settings.isSessionsEnabled)
+            auth.setLastLogin(0L);
+        database.updateSession(auth);
+        auth.setQuitLocX(p.getLocation().getX());
+        auth.setQuitLocY(p.getLocation().getY());
+        auth.setQuitLocZ(p.getLocation().getZ());
+        auth.setWorld(p.getWorld().getName());
+        database.updateQuitLoc(auth);
+
+        PlayerCache.getInstance().removePlayer(name);
+        database.setUnlogged(name);
+        if (Settings.isTeleportToSpawnEnabled && !Settings.noTeleport) {
+            Location spawnLoc = plugin.getSpawnLocation(p);
+            final AuthMeTeleportEvent tpEvent = new AuthMeTeleportEvent(p, spawnLoc);
+            sched.scheduleSyncDelayedTask(plugin, new Runnable() {
+
+                @Override
+                public void run() {
+                    plugin.getServer().getPluginManager().callEvent(tpEvent);
+                    if (!tpEvent.isCancelled()) {
+                        if (tpEvent.getTo() != null)
+                            p.teleport(tpEvent.getTo());
+                    }
+                }
+            });
+        }
+
+        if (LimboCache.getInstance().hasLimboPlayer(name))
+            LimboCache.getInstance().deleteLimboPlayer(name);
+        LimboCache.getInstance().addLimboPlayer(player);
+        utils.setGroup(player, groupType.NOTLOGGEDIN);
+        if (Settings.protectInventoryBeforeLogInEnabled) {
+            player.getInventory().clear();
+            // create cache file for handling lost of inventories on unlogged in
+            // status
+            DataFileCache playerData = new DataFileCache(LimboCache.getInstance().getLimboPlayer(name).getInventory(), LimboCache.getInstance().getLimboPlayer(name).getArmour());
+            if (playerData != null)
+                playerBackup.createCache(player, playerData, LimboCache.getInstance().getLimboPlayer(name).getGroup(), LimboCache.getInstance().getLimboPlayer(name).getOperator(), LimboCache.getInstance().getLimboPlayer(name).isFlying());
+        }
+        sched.scheduleSyncDelayedTask(plugin, new ProcessSyncronousPlayerLogout(p, plugin));
+    }
+}

src/main/java/fr/xephi/authme/process/logout/ProcessSyncronousPlayerLogout.java

@@ -0,0 +1,70 @@
+package fr.xephi.authme.process.logout;
+
+import me.muizers.Notifications.Notification;
+
+import org.bukkit.Bukkit;
+import org.bukkit.entity.Player;
+import org.bukkit.potion.PotionEffect;
+import org.bukkit.potion.PotionEffectType;
+import org.bukkit.scheduler.BukkitScheduler;
+import org.bukkit.scheduler.BukkitTask;
+
+import fr.xephi.authme.AuthMe;
+import fr.xephi.authme.ConsoleLogger;
+import fr.xephi.authme.cache.limbo.LimboCache;
+import fr.xephi.authme.events.LogoutEvent;
+import fr.xephi.authme.settings.Messages;
+import fr.xephi.authme.settings.Settings;
+import fr.xephi.authme.task.MessageTask;
+import fr.xephi.authme.task.TimeoutTask;
+
+public class ProcessSyncronousPlayerLogout implements Runnable {
+
+    protected Player player;
+    protected AuthMe plugin;
+    protected String name;
+    private Messages m = Messages.getInstance();
+
+    public ProcessSyncronousPlayerLogout(Player player, AuthMe plugin) {
+        this.player = player;
+        this.plugin = plugin;
+        this.name = player.getName().toLowerCase();
+    }
+
+    @Override
+    public void run() {
+        int delay = Settings.getRegistrationTimeout * 20;
+        int interval = Settings.getWarnMessageInterval;
+        BukkitScheduler sched = player.getServer().getScheduler();
+        if (delay != 0) {
+            BukkitTask id = sched.runTaskLater(plugin, new TimeoutTask(plugin, name), delay);
+            LimboCache.getInstance().getLimboPlayer(name).setTimeoutTaskId(id);
+        }
+        BukkitTask msgT = sched.runTask(plugin, new MessageTask(plugin, name, m.send("login_msg"), interval));
+        LimboCache.getInstance().getLimboPlayer(name).setMessageTaskId(msgT);
+        try {
+            if (player.isInsideVehicle())
+                player.getVehicle().eject();
+        } catch (NullPointerException npe) {
+        }
+        if (Settings.applyBlindEffect)
+            player.addPotionEffect(new PotionEffect(PotionEffectType.BLINDNESS, Settings.getRegistrationTimeout * 20, 2));
+        player.setOp(false);
+        player.setAllowFlight(true);
+        player.setFlying(true);
+        // Player is now logout... Time to fire event !
+        sched.scheduleSyncDelayedTask(plugin, new Runnable() {
+
+            @Override
+            public void run() {
+                Bukkit.getServer().getPluginManager().callEvent(new LogoutEvent(player));
+            }
+        });
+        m.send(player, "logout");
+        ConsoleLogger.info(player.getDisplayName() + " logged out");
+        if (plugin.notifications != null) {
+            plugin.notifications.showNotification(new Notification("[AuthMe] " + player.getName() + " logged out!"));
+        }
+    }
+
+}