feedc0de/LogBlock
1
0
Fork 0
forked from LogBlock/LogBlock
Code Pull Requests Activity

Dump queue while disabling after 10 tries, even when MySQL server is

Browse Source 
connected.
This commit is contained in:
Robin Kupper
2011-10-23 13:03:34 +02:00
parent f5e79a9bf7
commit feccb1539c
1 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/de/diddiz/LogBlock/LogBlock.java
View File

@@ -226,25 +226,23 @@ public class LogBlock extends JavaPlugin
consumer.queueLeave(player); consumer.queueLeave(player);
if (consumer.getQueueSize() > 0) { if (consumer.getQueueSize() > 0) {
getLogger().info("[LogBlock] Waiting for consumer ..."); getLogger().info("[LogBlock] Waiting for consumer ...");
int lastSize = -1, fails = 0; int tries = 10;
while (consumer.getQueueSize() > 0) { while (consumer.getQueueSize() > 0) {
getLogger().info("[LogBlock] Remaining queue size: " + consumer.getQueueSize()); getLogger().info("[LogBlock] Remaining queue size: " + consumer.getQueueSize());
if (lastSize == consumer.getQueueSize()) { if (tries > 0)
fails++; getLogger().info("[LogBlock] Remaining tries: " + tries);
getLogger().info("[LogBlock] Remaining tries: " + (10 - fails)); else {
} else
fails = 0;
if (fails == 10) {
getLogger().info("Unable to save queue to database. Trying to write to a local file."); getLogger().info("Unable to save queue to database. Trying to write to a local file.");
try { try {
consumer.writeToFile(); consumer.writeToFile();
getLogger().info("Successfully dumped queue.");
} catch (final FileNotFoundException ex) { } catch (final FileNotFoundException ex) {
getLogger().info("Failed to write. Given up."); getLogger().info("Failed to write. Given up.");
break; break;
} }
} }
lastSize = consumer.getQueueSize();
consumer.run(); consumer.run();
tries--;
} }
} }
} }