[fio.git] / engines / cmdprio.h

/*
 * IO priority handling declarations and helper functions common to the
 * libaio and io_uring engines.
 */

#ifndef FIO_CMDPRIO_H
#define FIO_CMDPRIO_H

#include "../fio.h"

/* read and writes only, no trim */
#define CMDPRIO_RWDIR_CNT 2

enum {
	CMDPRIO_MODE_NONE,
	CMDPRIO_MODE_PERC,
	CMDPRIO_MODE_BSSPLIT,
};

struct cmdprio_prio {
	int32_t prio;
	uint32_t perc;
	uint16_t clat_prio_index;
};

struct cmdprio_bsprio {
	uint64_t bs;
	uint32_t tot_perc;
	unsigned int nr_prios;
	struct cmdprio_prio *prios;
};

struct cmdprio_bsprio_desc {
	struct cmdprio_bsprio *bsprios;
	unsigned int nr_bsprios;
};

struct cmdprio_options {
	unsigned int percentage[CMDPRIO_RWDIR_CNT];
	unsigned int class[CMDPRIO_RWDIR_CNT];
	unsigned int level[CMDPRIO_RWDIR_CNT];
	char *bssplit_str;
};

struct cmdprio {
	struct cmdprio_options *options;
	struct cmdprio_prio perc_entry[CMDPRIO_RWDIR_CNT];
	struct cmdprio_bsprio_desc bsprio_desc[CMDPRIO_RWDIR_CNT];
	unsigned int mode;
};

bool fio_cmdprio_set_ioprio(struct thread_data *td, struct cmdprio *cmdprio,
			    struct io_u *io_u);

void fio_cmdprio_cleanup(struct cmdprio *cmdprio);

int fio_cmdprio_init(struct thread_data *td, struct cmdprio *cmdprio,
		     struct cmdprio_options *options);

#endif
Commit	Line	Data
	1	/*
	2	* IO priority handling declarations and helper functions common to the
	3	* libaio and io_uring engines.
	4	*/
	5
	6	#ifndef FIO_CMDPRIO_H
	7	#define FIO_CMDPRIO_H
	8
	9	#include "../fio.h"
	10
	11	/* read and writes only, no trim */
	12	#define CMDPRIO_RWDIR_CNT 2
	13
	14	enum {
	15	CMDPRIO_MODE_NONE,
	16	CMDPRIO_MODE_PERC,
	17	CMDPRIO_MODE_BSSPLIT,
	18	};
	19
	20	struct cmdprio_prio {
	21	int32_t prio;
	22	uint32_t perc;
	23	uint16_t clat_prio_index;
	24	};
	25
	26	struct cmdprio_bsprio {
	27	uint64_t bs;
	28	uint32_t tot_perc;
	29	unsigned int nr_prios;
	30	struct cmdprio_prio *prios;
	31	};
	32
	33	struct cmdprio_bsprio_desc {
	34	struct cmdprio_bsprio *bsprios;
	35	unsigned int nr_bsprios;
	36	};
	37
	38	struct cmdprio_options {
	39	unsigned int percentage[CMDPRIO_RWDIR_CNT];
	40	unsigned int class[CMDPRIO_RWDIR_CNT];
	41	unsigned int level[CMDPRIO_RWDIR_CNT];
	42	char *bssplit_str;
	43	};
	44
	45	struct cmdprio {
	46	struct cmdprio_options *options;
	47	struct cmdprio_prio perc_entry[CMDPRIO_RWDIR_CNT];
	48	struct cmdprio_bsprio_desc bsprio_desc[CMDPRIO_RWDIR_CNT];
	49	unsigned int mode;
	50	};
	51
	52	bool fio_cmdprio_set_ioprio(struct thread_data td, struct cmdprio cmdprio,
	53	struct io_u *io_u);
	54
	55	void fio_cmdprio_cleanup(struct cmdprio *cmdprio);
	56
	57	int fio_cmdprio_init(struct thread_data td, struct cmdprio cmdprio,
	58	struct cmdprio_options *options);
	59
	60	#endif