From 25e60d413b5436120ac3eb107cb8cef2279cc412 Mon Sep 17 00:00:00 2001 From: Robin Kupper Date: Fri, 17 Jun 2011 01:12:20 +0200 Subject: [PATCH] Removed bottleneck in consumer --- src/de/diddiz/LogBlock/CommandsHandler.java | 9 +++++++++ src/de/diddiz/LogBlock/Consumer.java | 4 ---- 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/src/de/diddiz/LogBlock/CommandsHandler.java b/src/de/diddiz/LogBlock/CommandsHandler.java index c47d45c..167e91a 100644 --- a/src/de/diddiz/LogBlock/CommandsHandler.java +++ b/src/de/diddiz/LogBlock/CommandsHandler.java @@ -16,6 +16,7 @@ import java.util.logging.Level; import java.util.logging.Logger; import org.bukkit.ChatColor; import org.bukkit.Location; +import org.bukkit.World; import org.bukkit.command.Command; import org.bukkit.command.CommandExecutor; import org.bukkit.command.CommandSender; @@ -294,6 +295,14 @@ public class CommandsHandler implements CommandExecutor sender.sendMessage(ChatColor.RED + "You aren't allowed to do this"); } else sender.sendMessage(ChatColor.RED + "You have to be a player."); + } else if (command.equals("spam")) { + final Consumer consumer = logblock.getConsumer(); + final World world = logblock.getServer().getWorlds().get(0); + for (int i = 0; i < 10000; i++) { + final Location loc = new Location(world, Math.random() * 100 - 50, Math.random() * 127, Math.random() * 100 - 50); + world.getBlockAt(loc).setTypeId(4); + consumer.queueBlockPlace("Test", loc, 4, (byte)0); + } } else if (command.equals("lookup") || QueryParams.isKeyWord(args[0])) { if (logblock.hasPermission(sender, "logblock.lookup")) try { diff --git a/src/de/diddiz/LogBlock/Consumer.java b/src/de/diddiz/LogBlock/Consumer.java index 1ec3b08..526e3c7 100644 --- a/src/de/diddiz/LogBlock/Consumer.java +++ b/src/de/diddiz/LogBlock/Consumer.java @@ -270,8 +270,6 @@ public class Consumer extends TimerTask log.warning("[LogBlock Consumer] Failed to get generated keys. Unable to log chest access."); } count++; - if (count % 100 == 0) - conn.commit(); } conn.commit(); } @@ -292,8 +290,6 @@ public class Consumer extends TimerTask } state.execute("INSERT INTO `" + config.tables.get(k.worldHash) + "-kills` (date, killer, victim, weapon) VALUES (now(), " + players.get(k.killer.hashCode()) + ", " + k.weapon + ")"); count++; - if (count % 100 == 0) - conn.commit(); } conn.commit(); }