Function main

lib_acl_cpp/samples/benchmark/rosksdb/main.cpp:111–164

}

int main(int argc, char* argv[]) {
	const char* dbpath = "./db";
	int ch, max = 1000, nthread = 1;
	acl::string action("get");

	while ((ch = getopt(argc, argv, "hn:a:c:")) > 0) {
		switch (ch) {
		case 'h':
			usage(argv[0]);
			return 0;
		case 'n':
			max = atoi(optarg);
			break;
		case 'a':
			action = optarg;
			break;
		case 'c':
			nthread = atoi(optarg);
			break;
		default:
			break;
		}
	}

	std::vector<acl::thread*> threads;
	for (int i = 0; i < nthread; i++) {
		DB* db;
		Options options;
		options.IncreaseParallelism();
		//	options.OptimizeLevelStyleCompaction();
		options.create_if_missing = true;

		acl::string path;
		path << dbpath << i;
		Status s = DB::Open(options, path.c_str(), &db);
		if (!s.ok()) {
			printf("Open rockdb(%s) failed(%s)!\r\n",
				dbpath, s.getState());
			return 1;
		}

		acl::thread* thr = new db_thread(i, db, action, max);
		threads.push_back(thr);
		thr->start();
	}

	for (std::vector<acl::thread*>::iterator it = threads.begin();
		it != threads.end(); ++it) {
		(*it)->wait();
		delete *it;
	}

	return 0;
}