Removed bottleneck in consumer

This commit is contained in:
Robin Kupper
2011-06-17 01:12:20 +02:00
parent 012a2a3f40
commit 25e60d413b
2 changed files with 9 additions and 4 deletions

View File

@@ -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 {

View File

@@ -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();
}