Redstoner/Modules
Archived
0
Fork 0
Code Activity

Turned saving into scheduled task

Browse Source
This commit is contained in:
Pepich
2018-03-12 02:44:51 +01:00
parent 73e39d928b
commit d396ea3a31
1 changed files with 25 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/com/redstoner/modules/datamanager/DataManager.java
View File

@@ -36,7 +36,7 @@ import com.redstoner.modules.Module;
@Commands(CommandHolderType.Stream) @Commands(CommandHolderType.Stream)
@AutoRegisterListener @AutoRegisterListener
@Version(major = 4, minor = 1, revision = 5, compatible = 4) @Version(major = 4, minor = 1, revision = 6, compatible = 4)
public final class DataManager implements CoreModule, Listener public final class DataManager implements CoreModule, Listener
{ {
protected final File dataFolder = new File(Main.plugin.getDataFolder(), "data"); protected final File dataFolder = new File(Main.plugin.getDataFolder(), "data");
@@ -45,8 +45,10 @@ public final class DataManager implements CoreModule, Listener
protected ArrayList<String> module_index; protected ArrayList<String> module_index;
int old_hash = 0; int old_hash = 0;
protected HashMap<String, HashMap<String, Boolean>> states = new HashMap<>(); protected HashMap<String, HashMap<String, Boolean>> states = new HashMap<>();
private DataManager previous_instance = null; private static DataManager previous_instance = null;
protected ArrayList<String> subcommands; protected ArrayList<String> subcommands;
protected List<String> scheduled_saves = new ArrayList<>();
int task_id;
@Override @Override
public void postEnable() public void postEnable()
@@ -75,6 +77,24 @@ public final class DataManager implements CoreModule, Listener
fixJson(); fixJson();
updateIndex(); updateIndex();
CommandManager.registerCommand(getClass().getResourceAsStream("DataManager.cmd"), this, Main.plugin); CommandManager.registerCommand(getClass().getResourceAsStream("DataManager.cmd"), this, Main.plugin);
// Schedule save every ten seconds
task_id = Bukkit.getScheduler().runTaskTimerAsynchronously(Main.plugin, new Runnable()
{
@Override
public void run()
{
for (String id : scheduled_saves)
{
scheduled_saves.remove(id);
Object raw = data.get(id);
if (raw == null || ((JSONObject) raw).size() == 0)
return;
JSONObject json = (JSONObject) raw;
JsonManager.save(json, new File(dataFolder, id + ".json"));
}
}
}, 0, 10000).getTaskId();
} }
@Override @Override
@@ -86,6 +106,7 @@ public final class DataManager implements CoreModule, Listener
saveAndUnload(p); saveAndUnload(p);
} }
JsonManager.save(config_data, new File(dataFolder, "configs.json")); JsonManager.save(config_data, new File(dataFolder, "configs.json"));
Bukkit.getScheduler().cancelTask(task_id);
} }
@Command(hook = "import_file") @Command(hook = "import_file")
@@ -535,12 +556,9 @@ public final class DataManager implements CoreModule, Listener
{} {}
} }
protected synchronized void save_(String id) protected void save_(String id)
{ {
Object raw = data.get(id); scheduled_saves.add(id);
if (raw == null || ((JSONObject) raw).size() == 0)
return;
JsonManager.save((JSONObject) raw, new File(dataFolder, id + ".json"));
} }
protected void saveAndUnload(CommandSender sender) protected void saveAndUnload(CommandSender sender)