X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=diskutil.c;h=cbde42e908f71629cd9575e783fb4d390554f369;hp=e29d1c34af24d116f9a601437adb798a8ec194cf;hb=976406b8a0d823f053400178b7b86f32a973762d;hpb=95820b6e6c92025df8d89c0bf39b174e53137c41 diff --git a/diskutil.c b/diskutil.c index e29d1c34..cbde42e9 100644 --- a/diskutil.c +++ b/diskutil.c @@ -236,7 +236,7 @@ static void find_add_disk_slaves(struct thread_data *td, char *path, * are links to the real directories for the slave * devices? */ - linklen = readlink(temppath, slavepath, PATH_MAX - 0); + linklen = readlink(temppath, slavepath, PATH_MAX - 1); if (linklen < 0) { perror("readlink() for slave device."); return; @@ -605,21 +605,19 @@ void print_disk_util(struct disk_util_stat *dus, struct disk_util_agg *agg, log_info("\n"); } -static void print_disk_util_json(struct disk_util *du, struct json_array *array) +void json_array_add_disk_util(struct disk_util_stat *dus, + struct disk_util_agg *agg, struct json_array *array) { - double util = 0; - struct disk_util_stat *dus = &du->dus; - struct disk_util_agg *agg = &du->agg; struct json_object *obj; - - obj = json_create_object(); - json_array_add_value_object(array, obj); + double util = 0; if (dus->msec) util = (double) 100 * dus->io_ticks / (double) dus->msec; if (util > 100.0) util = 100.0; + obj = json_create_object(); + json_array_add_value_object(array, obj); json_object_add_value_string(obj, "name", dus->name); json_object_add_value_int(obj, "read_ios", dus->ios[0]); @@ -654,11 +652,27 @@ static void print_disk_util_json(struct disk_util *du, struct json_array *array) json_object_add_value_float(obj, "aggr_util", agg->max_util.u.f); } +static void json_object_add_disk_utils(struct json_object *obj, + struct flist_head *head) +{ + struct json_array *array = json_create_array(); + struct flist_head *entry; + struct disk_util *du; + + json_object_add_value_array(obj, "disk_util", array); + + flist_for_each(entry, head) { + du = flist_entry(entry, struct disk_util, list); + + aggregate_slaves_stats(du); + json_array_add_disk_util(&du->dus, &du->agg, array); + } +} + void show_disk_util(int terse, struct json_object *parent) { struct flist_head *entry; struct disk_util *du; - struct json_array *array = NULL; fio_mutex_down(disk_util_mutex); @@ -667,23 +681,18 @@ void show_disk_util(int terse, struct json_object *parent) return; } - if (!terse) + if (!terse && !parent) log_info("\nDisk stats (read/write):\n"); if (output_format == FIO_OUTPUT_JSON) { - array = json_create_array(); - json_object_add_value_array(parent, "disk_util", array); - } - - flist_for_each(entry, &disk_list) { - du = flist_entry(entry, struct disk_util, list); + json_object_add_disk_utils(parent, &disk_list); + } else + flist_for_each(entry, &disk_list) { + du = flist_entry(entry, struct disk_util, list); - aggregate_slaves_stats(du); - if (output_format == FIO_OUTPUT_JSON) - print_disk_util_json(du, array); - else + aggregate_slaves_stats(du); print_disk_util(&du->dus, &du->agg, terse); - } + } fio_mutex_up(disk_util_mutex); }