vrr/prima.cpp
2
0
Fork 0
mirror of https://github.com/Lizonghang/prima.cpp.git synced 2025-09-07 12:49:02 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix infinite loop in fio test

Browse source
This commit is contained in:
Lizonghang 2024-12-10 20:58:17 +04:00
parent 8e9ab45458
commit bef2662d42
1 changed files with 15 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
common/profiler.cpp
View file

@ -848,11 +848,12 @@ numjobs=%d
const char * block_size = op_rand ? page_size_str : readahead_str; const char * block_size = op_rand ? page_size_str : readahead_str;
const char * ioengine = "posixaio"; const char * ioengine = "posixaio";
bool retry_with_sync = false;
const char * output_file = "fio_output.log"; const char * output_file = "fio_output.log";
const char * conf_file = "config.fio"; const char * conf_file = "config.fio";
do { int num_try = 0;
int ret;
while (num_try < 2) {
char fio_conf[1024]; char fio_conf[1024];
snprintf(fio_conf, sizeof(fio_conf), fio_conf_template, ioengine, snprintf(fio_conf, sizeof(fio_conf), fio_conf_template, ioengine,
read_type, block_size, test_file, n_threads, read_type, block_size, test_file, n_threads,
@ -867,16 +868,21 @@ numjobs=%d
conf.close(); conf.close();
std::string command = "fio " + std::string(conf_file) + " > " + std::string(output_file) + " 2>&1"; std::string command = "fio " + std::string(conf_file) + " > " + std::string(output_file) + " 2>&1";
int ret = std::system(command.c_str()); ret = std::system(command.c_str());
if (ret == 0) { num_try += 1;
retry_with_sync = false; // Execution succeeded
} else { if (ret != 0) {
LOG_INF("Engine posixaio not loadable, retrying with sync engine\n"); LOG_WRN("Engine posixaio not loadable, retrying with sync engine\n");
ioengine = "sync"; ioengine = "sync";
retry_with_sync = true; } else {
num_try = 2;
} }
} while (retry_with_sync); }
if (ret != 0) {
throw std::runtime_error("Engine posixaio and sync not loadable, fio test failed\n");
}
// parse fio output // parse fio output
std::ifstream result(output_file); std::ifstream result(output_file);