diff options
| author | snowleo <schneeleo@gmail.com> | 2012-10-08 22:48:52 +0200 |
|---|---|---|
| committer | snowleo <schneeleo@gmail.com> | 2012-10-08 22:48:52 +0200 |
| commit | 591d4af167977f7862fcb6e341d1056289fc7d43 (patch) | |
| tree | 2ccfa37e121401b51a8d52ce2927d15787ef8ffc | |
| parent | 524531a0902a5d368decce6ce6bd714c7d429062 (diff) | |
| download | Essentials-591d4af167977f7862fcb6e341d1056289fc7d43.tar Essentials-591d4af167977f7862fcb6e341d1056289fc7d43.tar.gz Essentials-591d4af167977f7862fcb6e341d1056289fc7d43.tar.lz Essentials-591d4af167977f7862fcb6e341d1056289fc7d43.tar.xz Essentials-591d4af167977f7862fcb6e341d1056289fc7d43.zip | |
Show write queue size on /gc
| -rw-r--r-- | Essentials/src/net/ess3/commands/Commandgc.java | 3 | ||||
| -rw-r--r-- | Essentials/src/net/ess3/storage/StorageQueue.java | 6 |
2 files changed, 6 insertions, 3 deletions
diff --git a/Essentials/src/net/ess3/commands/Commandgc.java b/Essentials/src/net/ess3/commands/Commandgc.java index 6f7a0b78b..a79635cf7 100644 --- a/Essentials/src/net/ess3/commands/Commandgc.java +++ b/Essentials/src/net/ess3/commands/Commandgc.java @@ -6,8 +6,6 @@ import org.bukkit.World; import org.bukkit.command.CommandSender; - - public class Commandgc extends EssentialsCommand { @Override @@ -31,6 +29,7 @@ public class Commandgc extends EssentialsCommand sender.sendMessage(_("gcmax", (Runtime.getRuntime().maxMemory() / 1024 / 1024))); sender.sendMessage(_("gctotal", (Runtime.getRuntime().totalMemory() / 1024 / 1024))); sender.sendMessage(_("gcfree", (Runtime.getRuntime().freeMemory() / 1024 / 1024))); + sender.sendMessage("Essentials write queue size: " + ess.getStorageQueue().getQueueSize()); //TODO:TL for (World w : server.getWorlds()) { diff --git a/Essentials/src/net/ess3/storage/StorageQueue.java b/Essentials/src/net/ess3/storage/StorageQueue.java index 304de4ae6..f2859f51e 100644 --- a/Essentials/src/net/ess3/storage/StorageQueue.java +++ b/Essentials/src/net/ess3/storage/StorageQueue.java @@ -7,7 +7,6 @@ import java.util.concurrent.Delayed; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.logging.Level; -import java.util.logging.Logger; import net.ess3.api.IPlugin; @@ -86,6 +85,11 @@ public class StorageQueue implements Runnable } } + public int getQueueSize() + { + return queue.size(); + } + private class WriteRequest implements Delayed { |