From 591d4af167977f7862fcb6e341d1056289fc7d43 Mon Sep 17 00:00:00 2001 From: snowleo Date: Mon, 8 Oct 2012 22:48:52 +0200 Subject: [PATCH] Show write queue size on /gc --- Essentials/src/net/ess3/commands/Commandgc.java | 3 +-- 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 {