socrates/Stats
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Set the SaveTask schedule to async so it won't slow down the server

Browse Source 
anymore if the MySQL connection is slow.
This commit is contained in:
Pascal Koenig
2011-10-09 14:46:05 +02:00
parent c66ce29467
commit da2642e299
3 changed files with 37 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
.build.number Normal file
View File

@@ -0,0 +1,3 @@
#Build Number for ANT. Do not edit!
#Sun Oct 09 14:44:39 CEST 2011
build.number=4

2
build.xml
View File

@@ -5,7 +5,7 @@
<property name="dist" value="dist" />
<property name="src" value="src" />
<property name="name" value="Stats" />
<property name="version" value="0.99.1" />
<property name="version" value="0.99.2" />
<property name="resources" value="resources" />
<property name="author" value="nidefawl" />

36
src/com/nidefawl/Stats/Stats.java
View File

@@ -41,7 +41,7 @@ import com.nidefawl.Stats.util.Updater;
public class Stats extends JavaPlugin {
public final static Logger log = Logger.getLogger("Minecraft");
public static final String version = "0.99.1";
public static final String version = "0.99.2";
public static final String logprefix = "[Stats-" + version + "]";
public final static String defaultCategory = "stats";
public boolean enabled = false;
@@ -479,7 +479,8 @@ public class Stats extends JavaPlugin {
for (Player p : getServer().getOnlinePlayers()) {
load(p);
}
getServer().getScheduler().scheduleSyncRepeatingTask(this, new SaveTask(this), StatsSettings.delay * 20, StatsSettings.delay * 20);
getServer().getScheduler().scheduleAsyncRepeatingTask(this, new SaveTask(this), StatsSettings.delay * 20, StatsSettings.delay * 20);
}
@@ -491,12 +492,41 @@ public class Stats extends JavaPlugin {
statsInstance = plugin;
}
@Override
public void run() {
if (!statsInstance.enabled)
return;
statsInstance.saveAll();
}
public void saveAll() {
if (StatsSettings.debugOutput)
log.info("Stats debug: saving " + this.statsInstance.stats.size() + " players stats");
try {
Connection conn = StatsSQLConnectionManager.getConnection(StatsSettings.useMySQL);
if (conn == null)
return;
conn.setAutoCommit(false);
} catch (SQLException e) {
e.printStackTrace();
}
for (PlayerStat stat : this.statsInstance.stats.values()) {
if (stat == null || this.statsInstance.getServer().getPlayer(stat.getName()) == null) {
stat.unload = true;
continue;
}
this.statsInstance.updateTimedStats(stat);
stat.save(false);
}
StatsSQLConnectionManager.closeConnection(StatsSettings.useMySQL);
for (PlayerStat stat : this.statsInstance.stats.values()) {
if (!stat.unload)
continue;
LogError("onPlayerQuit did not happen, unloading " + stat.getName() + " now");
this.statsInstance.logout(stat.getName());
this.statsInstance.unload(stat.getName());
}
}
}
public void onDisable() {