Commit 7f3c980c authored by Ilpo Järvinen's avatar Ilpo Järvinen Committed by Shuah Khan

selftests/resctrl: Don't pass test name to fill_buf

Test name is passed to fill_buf functions so that they can loop around
buffer only once. This is required for CAT test case.

To loop around buffer only once, caller doesn't need to let fill_buf
know which test case it is. Instead, pass a boolean argument 'once'
which makes fill_buf more generic.

As run_benchmark() no longer needs to pass the test name to
run_fill_buf(), a few test running functions can be simplified to not
write the test name into the default benchmark_cmd. The has_ben
argument can also be removed now from those test running functions.
Co-developed-by: default avatarFenghua Yu <fenghua.yu@intel.com>
Signed-off-by: default avatarFenghua Yu <fenghua.yu@intel.com>
Signed-off-by: default avatarIlpo Järvinen <ilpo.jarvinen@linux.intel.com>
Reviewed-by: default avatarReinette Chatre <reinette.chatre@intel.com>
Tested-by: default avatarBabu Moger <babu.moger@amd.com>
Tested-by: default avatarShaopeng Tan (Fujitsu) <tan.shaopeng@fujitsu.com>
Signed-off-by: default avatarShuah Khan <skhan@linuxfoundation.org>
parent f4123975
...@@ -247,8 +247,7 @@ int cat_val(struct resctrl_val_param *param) ...@@ -247,8 +247,7 @@ int cat_val(struct resctrl_val_param *param)
if (ret) if (ret)
break; break;
if (run_fill_buf(param->span, memflush, operation, if (run_fill_buf(param->span, memflush, operation, true)) {
resctrl_val)) {
fprintf(stderr, "Error-running fill buffer\n"); fprintf(stderr, "Error-running fill buffer\n");
ret = -1; ret = -1;
goto pe_close; goto pe_close;
......
...@@ -101,15 +101,14 @@ static void fill_one_span_write(unsigned char *buf, size_t buf_size) ...@@ -101,15 +101,14 @@ static void fill_one_span_write(unsigned char *buf, size_t buf_size)
} }
} }
static int fill_cache_read(unsigned char *buf, size_t buf_size, static int fill_cache_read(unsigned char *buf, size_t buf_size, bool once)
char *resctrl_val)
{ {
int ret = 0; int ret = 0;
FILE *fp; FILE *fp;
while (1) { while (1) {
ret = fill_one_span_read(buf, buf_size); ret = fill_one_span_read(buf, buf_size);
if (!strncmp(resctrl_val, CAT_STR, sizeof(CAT_STR))) if (once)
break; break;
} }
...@@ -125,19 +124,18 @@ static int fill_cache_read(unsigned char *buf, size_t buf_size, ...@@ -125,19 +124,18 @@ static int fill_cache_read(unsigned char *buf, size_t buf_size,
return 0; return 0;
} }
static int fill_cache_write(unsigned char *buf, size_t buf_size, static int fill_cache_write(unsigned char *buf, size_t buf_size, bool once)
char *resctrl_val)
{ {
while (1) { while (1) {
fill_one_span_write(buf, buf_size); fill_one_span_write(buf, buf_size);
if (!strncmp(resctrl_val, CAT_STR, sizeof(CAT_STR))) if (once)
break; break;
} }
return 0; return 0;
} }
static int fill_cache(size_t buf_size, int memflush, int op, char *resctrl_val) static int fill_cache(size_t buf_size, int memflush, int op, bool once)
{ {
unsigned char *buf; unsigned char *buf;
int ret; int ret;
...@@ -151,9 +149,9 @@ static int fill_cache(size_t buf_size, int memflush, int op, char *resctrl_val) ...@@ -151,9 +149,9 @@ static int fill_cache(size_t buf_size, int memflush, int op, char *resctrl_val)
mem_flush(buf, buf_size); mem_flush(buf, buf_size);
if (op == 0) if (op == 0)
ret = fill_cache_read(buf, buf_size, resctrl_val); ret = fill_cache_read(buf, buf_size, once);
else else
ret = fill_cache_write(buf, buf_size, resctrl_val); ret = fill_cache_write(buf, buf_size, once);
free(buf); free(buf);
...@@ -166,12 +164,12 @@ static int fill_cache(size_t buf_size, int memflush, int op, char *resctrl_val) ...@@ -166,12 +164,12 @@ static int fill_cache(size_t buf_size, int memflush, int op, char *resctrl_val)
return 0; return 0;
} }
int run_fill_buf(size_t span, int memflush, int op, char *resctrl_val) int run_fill_buf(size_t span, int memflush, int op, bool once)
{ {
size_t cache_size = span; size_t cache_size = span;
int ret; int ret;
ret = fill_cache(cache_size, memflush, op, resctrl_val); ret = fill_cache(cache_size, memflush, op, once);
if (ret) { if (ret) {
printf("\n Error in fill cache\n"); printf("\n Error in fill cache\n");
return -1; return -1;
......
...@@ -97,7 +97,7 @@ int write_bm_pid_to_resctrl(pid_t bm_pid, char *ctrlgrp, char *mongrp, ...@@ -97,7 +97,7 @@ int write_bm_pid_to_resctrl(pid_t bm_pid, char *ctrlgrp, char *mongrp,
char *resctrl_val); char *resctrl_val);
int perf_event_open(struct perf_event_attr *hw_event, pid_t pid, int cpu, int perf_event_open(struct perf_event_attr *hw_event, pid_t pid, int cpu,
int group_fd, unsigned long flags); int group_fd, unsigned long flags);
int run_fill_buf(size_t span, int memflush, int op, char *resctrl_val); int run_fill_buf(size_t span, int memflush, int op, bool once);
int resctrl_val(char **benchmark_cmd, struct resctrl_val_param *param); int resctrl_val(char **benchmark_cmd, struct resctrl_val_param *param);
int mbm_bw_change(size_t span, int cpu_no, char *bw_report, char **benchmark_cmd); int mbm_bw_change(size_t span, int cpu_no, char *bw_report, char **benchmark_cmd);
void tests_cleanup(void); void tests_cleanup(void);
......
...@@ -70,7 +70,7 @@ void tests_cleanup(void) ...@@ -70,7 +70,7 @@ void tests_cleanup(void)
cat_test_cleanup(); cat_test_cleanup();
} }
static void run_mbm_test(bool has_ben, char **benchmark_cmd, size_t span, static void run_mbm_test(char **benchmark_cmd, size_t span,
int cpu_no, char *bw_report) int cpu_no, char *bw_report)
{ {
int res; int res;
...@@ -88,8 +88,6 @@ static void run_mbm_test(bool has_ben, char **benchmark_cmd, size_t span, ...@@ -88,8 +88,6 @@ static void run_mbm_test(bool has_ben, char **benchmark_cmd, size_t span,
goto umount; goto umount;
} }
if (!has_ben)
sprintf(benchmark_cmd[4], "%s", MBA_STR);
res = mbm_bw_change(span, cpu_no, bw_report, benchmark_cmd); res = mbm_bw_change(span, cpu_no, bw_report, benchmark_cmd);
ksft_test_result(!res, "MBM: bw change\n"); ksft_test_result(!res, "MBM: bw change\n");
if ((get_vendor() == ARCH_INTEL) && res) if ((get_vendor() == ARCH_INTEL) && res)
...@@ -123,7 +121,7 @@ static void run_mba_test(char **benchmark_cmd, int cpu_no, char *bw_report) ...@@ -123,7 +121,7 @@ static void run_mba_test(char **benchmark_cmd, int cpu_no, char *bw_report)
umount_resctrlfs(); umount_resctrlfs();
} }
static void run_cmt_test(bool has_ben, char **benchmark_cmd, int cpu_no) static void run_cmt_test(char **benchmark_cmd, int cpu_no)
{ {
int res; int res;
...@@ -140,8 +138,6 @@ static void run_cmt_test(bool has_ben, char **benchmark_cmd, int cpu_no) ...@@ -140,8 +138,6 @@ static void run_cmt_test(bool has_ben, char **benchmark_cmd, int cpu_no)
goto umount; goto umount;
} }
if (!has_ben)
sprintf(benchmark_cmd[4], "%s", CMT_STR);
res = cmt_resctrl_val(cpu_no, 5, benchmark_cmd); res = cmt_resctrl_val(cpu_no, 5, benchmark_cmd);
ksft_test_result(!res, "CMT: test\n"); ksft_test_result(!res, "CMT: test\n");
if ((get_vendor() == ARCH_INTEL) && res) if ((get_vendor() == ARCH_INTEL) && res)
...@@ -274,7 +270,7 @@ int main(int argc, char **argv) ...@@ -274,7 +270,7 @@ int main(int argc, char **argv)
sprintf(benchmark_cmd[1], "%zu", span); sprintf(benchmark_cmd[1], "%zu", span);
strcpy(benchmark_cmd[2], "1"); strcpy(benchmark_cmd[2], "1");
strcpy(benchmark_cmd[3], "0"); strcpy(benchmark_cmd[3], "0");
strcpy(benchmark_cmd[4], ""); strcpy(benchmark_cmd[4], "false");
benchmark_cmd[5] = NULL; benchmark_cmd[5] = NULL;
} }
...@@ -292,13 +288,13 @@ int main(int argc, char **argv) ...@@ -292,13 +288,13 @@ int main(int argc, char **argv)
ksft_set_plan(tests ? : 4); ksft_set_plan(tests ? : 4);
if (mbm_test) if (mbm_test)
run_mbm_test(has_ben, benchmark_cmd, span, cpu_no, bw_report); run_mbm_test(benchmark_cmd, span, cpu_no, bw_report);
if (mba_test) if (mba_test)
run_mba_test(benchmark_cmd, cpu_no, bw_report); run_mba_test(benchmark_cmd, cpu_no, bw_report);
if (cmt_test) if (cmt_test)
run_cmt_test(has_ben, benchmark_cmd, cpu_no); run_cmt_test(benchmark_cmd, cpu_no);
if (cat_test) if (cat_test)
run_cat_test(cpu_no, no_of_bits); run_cat_test(cpu_no, no_of_bits);
......
...@@ -304,8 +304,8 @@ void run_benchmark(int signum, siginfo_t *info, void *ucontext) ...@@ -304,8 +304,8 @@ void run_benchmark(int signum, siginfo_t *info, void *ucontext)
{ {
int operation, ret, memflush; int operation, ret, memflush;
char **benchmark_cmd; char **benchmark_cmd;
char resctrl_val[64];
size_t span; size_t span;
bool once;
FILE *fp; FILE *fp;
benchmark_cmd = info->si_ptr; benchmark_cmd = info->si_ptr;
...@@ -323,9 +323,14 @@ void run_benchmark(int signum, siginfo_t *info, void *ucontext) ...@@ -323,9 +323,14 @@ void run_benchmark(int signum, siginfo_t *info, void *ucontext)
span = strtoul(benchmark_cmd[1], NULL, 10); span = strtoul(benchmark_cmd[1], NULL, 10);
memflush = atoi(benchmark_cmd[2]); memflush = atoi(benchmark_cmd[2]);
operation = atoi(benchmark_cmd[3]); operation = atoi(benchmark_cmd[3]);
sprintf(resctrl_val, "%s", benchmark_cmd[4]); if (!strcmp(benchmark_cmd[4], "true"))
once = true;
else if (!strcmp(benchmark_cmd[4], "false"))
once = false;
else
PARENT_EXIT("Invalid once parameter");
if (run_fill_buf(span, memflush, operation, resctrl_val)) if (run_fill_buf(span, memflush, operation, once))
fprintf(stderr, "Error in running fill buffer\n"); fprintf(stderr, "Error in running fill buffer\n");
} else { } else {
/* Execute specified benchmark */ /* Execute specified benchmark */
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment