42 static int get_io_ticks(struct disk_util *du, struct disk_util_stat *dus)  in get_io_ticks()  argument
66 				(unsigned long long *) &dus->s.ios[0],  in get_io_ticks()
67 				(unsigned long long *) &dus->s.merges[0],  in get_io_ticks()
69 				(unsigned long long *) &dus->s.ticks[0],  in get_io_ticks()
70 				(unsigned long long *) &dus->s.ios[1],  in get_io_ticks()
71 				(unsigned long long *) &dus->s.merges[1],  in get_io_ticks()
73 				(unsigned long long *) &dus->s.ticks[1],  in get_io_ticks()
75 				(unsigned long long *) &dus->s.io_ticks,  in get_io_ticks()
76 				(unsigned long long *) &dus->s.time_in_queue);  in get_io_ticks()
79 	dus->s.sectors[0] = sectors[0];  in get_io_ticks()
80 	dus->s.sectors[1] = sectors[1];  in get_io_ticks()
86 	struct disk_util_stat __dus, *dus, *ldus;  in update_io_tick_disk()  local
94 	dus = &du->dus;  in update_io_tick_disk()
97 	dus->s.sectors[0] += (__dus.s.sectors[0] - ldus->s.sectors[0]);  in update_io_tick_disk()
98 	dus->s.sectors[1] += (__dus.s.sectors[1] - ldus->s.sectors[1]);  in update_io_tick_disk()
99 	dus->s.ios[0] += (__dus.s.ios[0] - ldus->s.ios[0]);  in update_io_tick_disk()
100 	dus->s.ios[1] += (__dus.s.ios[1] - ldus->s.ios[1]);  in update_io_tick_disk()
101 	dus->s.merges[0] += (__dus.s.merges[0] - ldus->s.merges[0]);  in update_io_tick_disk()
102 	dus->s.merges[1] += (__dus.s.merges[1] - ldus->s.merges[1]);  in update_io_tick_disk()
103 	dus->s.ticks[0] += (__dus.s.ticks[0] - ldus->s.ticks[0]);  in update_io_tick_disk()
104 	dus->s.ticks[1] += (__dus.s.ticks[1] - ldus->s.ticks[1]);  in update_io_tick_disk()
105 	dus->s.io_ticks += (__dus.s.io_ticks - ldus->s.io_ticks);  in update_io_tick_disk()
106 	dus->s.time_in_queue += (__dus.s.time_in_queue - ldus->s.time_in_queue);  in update_io_tick_disk()
109 	dus->s.msec += mtime_since(&du->time, &t);  in update_io_tick_disk()
307 	strncpy((char *) du->dus.name, basename(path), FIO_DU_NAME_SZ - 1);  in disk_util_add()
321 		dprint(FD_DISKUTIL, "found %s in list\n", __du->dus.name);  in disk_util_add()
323 		if (!strcmp((char *) du->dus.name, (char *) __du->dus.name)) {  in disk_util_add()
330 	dprint(FD_DISKUTIL, "add %s to list\n", du->dus.name);  in disk_util_add()
531 	struct disk_util_stat *dus;  in aggregate_slaves_stats()  local
538 		dus = &slavedu->dus;  in aggregate_slaves_stats()
539 		agg->ios[0] += dus->s.ios[0];  in aggregate_slaves_stats()
540 		agg->ios[1] += dus->s.ios[1];  in aggregate_slaves_stats()
541 		agg->merges[0] += dus->s.merges[0];  in aggregate_slaves_stats()
542 		agg->merges[1] += dus->s.merges[1];  in aggregate_slaves_stats()
543 		agg->sectors[0] += dus->s.sectors[0];  in aggregate_slaves_stats()
544 		agg->sectors[1] += dus->s.sectors[1];  in aggregate_slaves_stats()
545 		agg->ticks[0] += dus->s.ticks[0];  in aggregate_slaves_stats()
546 		agg->ticks[1] += dus->s.ticks[1];  in aggregate_slaves_stats()
547 		agg->time_in_queue += dus->s.time_in_queue;  in aggregate_slaves_stats()
550 		util = (double) (100 * dus->s.io_ticks / (double) slavedu->dus.s.msec);  in aggregate_slaves_stats()
580 void print_disk_util(struct disk_util_stat *dus, struct disk_util_agg *agg,  in print_disk_util()  argument
585 	if (dus->s.msec)  in print_disk_util()
586 		util = (double) 100 * dus->s.io_ticks / (double) dus->s.msec;  in print_disk_util()
596 				dus->name,  in print_disk_util()
597 				(unsigned long long) dus->s.ios[0],  in print_disk_util()
598 				(unsigned long long) dus->s.ios[1],  in print_disk_util()
599 				(unsigned long long) dus->s.merges[0],  in print_disk_util()
600 				(unsigned long long) dus->s.merges[1],  in print_disk_util()
601 				(unsigned long long) dus->s.ticks[0],  in print_disk_util()
602 				(unsigned long long) dus->s.ticks[1],  in print_disk_util()
603 				(unsigned long long) dus->s.time_in_queue,  in print_disk_util()
607 				dus->name,  in print_disk_util()
608 				(unsigned long long) dus->s.ios[0],  in print_disk_util()
609 				(unsigned long long) dus->s.ios[1],  in print_disk_util()
610 				(unsigned long long) dus->s.merges[0],  in print_disk_util()
611 				(unsigned long long) dus->s.merges[1],  in print_disk_util()
612 				(unsigned long long) dus->s.ticks[0],  in print_disk_util()
613 				(unsigned long long) dus->s.ticks[1],  in print_disk_util()
614 				(unsigned long long) dus->s.time_in_queue,  in print_disk_util()
628 void json_array_add_disk_util(struct disk_util_stat *dus,  in json_array_add_disk_util()  argument
634 	if (dus->s.msec)  in json_array_add_disk_util()
635 		util = (double) 100 * dus->s.io_ticks / (double) dus->s.msec;  in json_array_add_disk_util()
642 	json_object_add_value_string(obj, "name", dus->name);  in json_array_add_disk_util()
643 	json_object_add_value_int(obj, "read_ios", dus->s.ios[0]);  in json_array_add_disk_util()
644 	json_object_add_value_int(obj, "write_ios", dus->s.ios[1]);  in json_array_add_disk_util()
645 	json_object_add_value_int(obj, "read_merges", dus->s.merges[0]);  in json_array_add_disk_util()
646 	json_object_add_value_int(obj, "write_merges", dus->s.merges[1]);  in json_array_add_disk_util()
647 	json_object_add_value_int(obj, "read_ticks", dus->s.ticks[0]);  in json_array_add_disk_util()
648 	json_object_add_value_int(obj, "write_ticks", dus->s.ticks[1]);  in json_array_add_disk_util()
649 	json_object_add_value_int(obj, "in_queue", dus->s.time_in_queue);  in json_array_add_disk_util()
688 		json_array_add_disk_util(&du->dus, &du->agg, array);  in json_object_add_disk_utils()
720 			print_disk_util(&du->dus, &du->agg, terse);  in show_disk_util()