[fio.git] / iolog.h

#ifndef FIO_IOLOG_H
#define FIO_IOLOG_H

#include "rbtree.h"
#include "lib/ieee754.h"
#include "ioengine.h"

/*
 * Use for maintaining statistics
 */
struct io_stat {
	uint64_t max_val;
	uint64_t min_val;
	uint64_t samples;

	fio_fp64_t mean;
	fio_fp64_t S;
};

/*
 * A single data sample
 */
struct io_sample {
	unsigned long time;
	unsigned long val;
	enum fio_ddir ddir;
	unsigned int bs;
};

/*
 * Dynamically growing data sample log
 */
struct io_log {
	/*
	 * Entries already logged
	 */
	unsigned long nr_samples;
	unsigned long max_samples;
	struct io_sample *log;

	/*
	 * Windowed average, for logging single entries average over some
	 * period of time.
	 */
	struct io_stat avg_window[2];
	unsigned long avg_msec;
	unsigned long avg_last;
};

enum {
	IP_F_ONRB	= 1,
	IP_F_ONLIST	= 2,
	IP_F_TRIMMED	= 4,
};

/*
 * When logging io actions, this matches a single sent io_u
 */
struct io_piece {
	union {
		struct rb_node rb_node;
		struct flist_head list;
	};
	struct flist_head trim_list;
	union {
		int fileno;
		struct fio_file *file;
	};
	unsigned long long offset;
	unsigned long len;
	unsigned int flags;
	enum fio_ddir ddir;
	union {
		unsigned long delay;
		unsigned int file_action;
	};
};

/*
 * Log exports
 */
enum file_log_act {
	FIO_LOG_ADD_FILE,
	FIO_LOG_OPEN_FILE,
	FIO_LOG_CLOSE_FILE,
	FIO_LOG_UNLINK_FILE,
};

extern int __must_check read_iolog_get(struct thread_data *, struct io_u *);
extern void log_io_u(struct thread_data *, struct io_u *);
extern void log_file(struct thread_data *, struct fio_file *, enum file_log_act);
extern int __must_check init_iolog(struct thread_data *td);
extern void log_io_piece(struct thread_data *, struct io_u *);
extern void queue_io_piece(struct thread_data *, struct io_piece *);
extern void prune_io_piece_log(struct thread_data *);
extern void write_iolog_close(struct thread_data *);

/*
 * Logging
 */
extern void add_lat_sample(struct thread_data *, enum fio_ddir, unsigned long,
				unsigned int);
extern void add_clat_sample(struct thread_data *, enum fio_ddir, unsigned long,
				unsigned int);
extern void add_slat_sample(struct thread_data *, enum fio_ddir, unsigned long,
				unsigned int);
extern void add_bw_sample(struct thread_data *, enum fio_ddir, unsigned int,
				struct timeval *);
extern void add_iops_sample(struct thread_data *, enum fio_ddir, struct timeval *);
extern void init_disk_util(struct thread_data *);
extern void update_rusage_stat(struct thread_data *);
extern void update_io_ticks(void);
extern void setup_log(struct io_log **, unsigned long);
extern void finish_log(struct thread_data *, struct io_log *, const char *);
extern void finish_log_named(struct thread_data *, struct io_log *, const char *, const char *);
extern void __finish_log(struct io_log *, const char *);
extern struct io_log *agg_io_log[2];
extern int write_bw_log;
extern void add_agg_sample(unsigned long, enum fio_ddir, unsigned int);

static inline void init_ipo(struct io_piece *ipo)
{
	memset(ipo, 0, sizeof(*ipo));
	INIT_FLIST_HEAD(&ipo->trim_list);
}

#endif
Commit	Line	Data
5995a6a4 JA	1	#ifndef FIO_IOLOG_H
	2	#define FIO_IOLOG_H
	3
ec41265e	4	#include "rbtree.h"
c7c6cb4c	5	#include "lib/ieee754.h"
ec41265e	6	#include "ioengine.h"
802ad4a8	7
5995a6a4 JA	8	/*
	9	* Use for maintaining statistics
	10	*/
	11	struct io_stat {
7b9f733a JA	12	uint64_t max_val;
	13	uint64_t min_val;
	14	uint64_t samples;
5995a6a4	15
802ad4a8 JA	16	fio_fp64_t mean;
802ad4a8 JA	17	fio_fp64_t S;
5995a6a4 JA	18	};
	19
	20	/*
	21	* A single data sample
	22	*/
	23	struct io_sample {
	24	unsigned long time;
	25	unsigned long val;
	26	enum fio_ddir ddir;
	27	unsigned int bs;
	28	};
	29
	30	/*
	31	* Dynamically growing data sample log
	32	*/
	33	struct io_log {
b8bc8cba JA	34	/*
	35	* Entries already logged
	36	*/
5995a6a4 JA	37	unsigned long nr_samples;
	38	unsigned long max_samples;
	39	struct io_sample *log;
b8bc8cba JA	40
	41	/*
	42	* Windowed average, for logging single entries average over some
	43	* period of time.
	44	*/
	45	struct io_stat avg_window[2];
	46	unsigned long avg_msec;
	47	unsigned long avg_last;
5995a6a4 JA	48	};
5995a6a4 JA	49
0d29de83 JA	50	enum {
	51	IP_F_ONRB = 1,
	52	IP_F_ONLIST = 2,
	53	IP_F_TRIMMED = 4,
	54	};
	55
5995a6a4 JA	56	/*
	57	* When logging io actions, this matches a single sent io_u
	58	*/
	59	struct io_piece {
	60	union {
	61	struct rb_node rb_node;
	62	struct flist_head list;
	63	};
0d29de83	64	struct flist_head trim_list;
5995a6a4 JA	65	union {
	66	int fileno;
	67	struct fio_file *file;
	68	};
	69	unsigned long long offset;
	70	unsigned long len;
a917a8b3	71	unsigned int flags;
5995a6a4 JA	72	enum fio_ddir ddir;
	73	union {
	74	unsigned long delay;
	75	unsigned int file_action;
	76	};
	77	};
	78
	79	/*
	80	* Log exports
	81	*/
	82	enum file_log_act {
	83	FIO_LOG_ADD_FILE,
	84	FIO_LOG_OPEN_FILE,
	85	FIO_LOG_CLOSE_FILE,
	86	FIO_LOG_UNLINK_FILE,
	87	};
	88
	89	extern int __must_check read_iolog_get(struct thread_data , struct io_u );
	90	extern void log_io_u(struct thread_data , struct io_u );
	91	extern void log_file(struct thread_data , struct fio_file , enum file_log_act);
	92	extern int __must_check init_iolog(struct thread_data *td);
	93	extern void log_io_piece(struct thread_data , struct io_u );
	94	extern void queue_io_piece(struct thread_data , struct io_piece );
	95	extern void prune_io_piece_log(struct thread_data *);
	96	extern void write_iolog_close(struct thread_data *);
	97
	98	/*
	99	* Logging
	100	*/
02af0988 JA	101	extern void add_lat_sample(struct thread_data *, enum fio_ddir, unsigned long,
02af0988 JA	102	unsigned int);
5995a6a4 JA	103	extern void add_clat_sample(struct thread_data *, enum fio_ddir, unsigned long,
	104	unsigned int);
	105	extern void add_slat_sample(struct thread_data *, enum fio_ddir, unsigned long,
	106	unsigned int);
	107	extern void add_bw_sample(struct thread_data *, enum fio_ddir, unsigned int,
	108	struct timeval *);
c8eeb9df	109	extern void add_iops_sample(struct thread_data , enum fio_ddir, struct timeval );
5995a6a4 JA	110	extern void init_disk_util(struct thread_data *);
	111	extern void update_rusage_stat(struct thread_data *);
	112	extern void update_io_ticks(void);
b8bc8cba	113	extern void setup_log(struct io_log **, unsigned long);
5995a6a4 JA	114	extern void finish_log(struct thread_data , struct io_log , const char *);
	115	extern void finish_log_named(struct thread_data , struct io_log , const char , const char );
	116	extern void __finish_log(struct io_log , const char );
	117	extern struct io_log *agg_io_log[2];
	118	extern int write_bw_log;
	119	extern void add_agg_sample(unsigned long, enum fio_ddir, unsigned int);
	120
0d29de83 JA	121	static inline void init_ipo(struct io_piece *ipo)
	122	{
	123	memset(ipo, 0, sizeof(*ipo));
	124	INIT_FLIST_HEAD(&ipo->trim_list);
	125	}
	126
5995a6a4	127	#endif