Method main

ZezeJava/ZezeJava/src/main/java/Zeze/Dbh2/BenchClient.java:31–130

(String[] args)

	}

	public static void main(String[] args) {
		try {
			Task.tryInitThreadPool();

			var tableNumber = 1;
			var threadNumber = 128;
			var valueSize = 100;
			var masterIp = "127.0.0.1";
			var masterPort = 10999;
			var tableAccess = 1;
			var selector = Runtime.getRuntime().availableProcessors();
			var get = false;

			var serviceManager = Application.createServiceManager(Config.load(), "Dbh2ServiceManager");
			assert serviceManager != null;
			serviceManager.start();
			serviceManager.waitReady();

			for (int i = 0; i < args.length; ++i) {
				switch (args[i]) {
				case "-tableNumber":
					tableNumber = Integer.parseInt(args[++i]);
					break;
				case "-threadNumber":
					threadNumber = Integer.parseInt(args[++i]);
					break;
				case "-valueSize":
					valueSize = Integer.parseInt(args[++i]);
					break;
				case "-masterIp":
					masterIp = args[++i];
					break;
				case "-masterPort":
					masterPort = Integer.parseInt(args[++i]);
					break;
				case "-tableAccess":
					tableAccess = Integer.parseInt(args[++i]);
					break;
				case "-selector":
					selector = Integer.parseInt(args[++i]);
					break;
				case "-get":
					get = true;
					break;
				default:
					throw new RuntimeException("unknown option: " + args[i]);
				}
			}

			Zeze.Net.Selectors.getInstance().add(selector - 1);
			ZezeCounter.tryInit();

			var dbh2AgentManager = new Dbh2AgentManager(serviceManager, null);
			dbh2AgentManager.start();
			var database = newDatabase(dbh2AgentManager, masterIp, masterPort);
			var tables = new ArrayList<Zeze.Transaction.Database.AbstractKVTable>();
			for (int i = 0; i < tableNumber; ++i) {
				var tableName = "table" + i;