X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=iolog.h;h=297daf588c281ab34e2e67c674411b29f32d791c;hb=2c2c93d8bd89c0cb15fc2430f9838744153a3946;hp=160c95771008e11774d5d2818b56b34abd307e89;hpb=210dd0fc66b8956065e098bb9314febe8993e849;p=fio.git diff --git a/iolog.h b/iolog.h index 160c9577..297daf58 100644 --- a/iolog.h +++ b/iolog.h @@ -184,6 +184,9 @@ extern void trim_io_piece(struct thread_data *, const 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 *); +extern int iolog_compress_init(struct thread_data *, struct sk_out *); +extern void iolog_compress_exit(struct thread_data *); +extern size_t log_chunk_sizes(struct io_log *); #ifdef CONFIG_ZLIB extern int iolog_file_inflate(const char *); @@ -203,23 +206,10 @@ struct log_params { }; extern void finalize_logs(struct thread_data *td); -extern void add_lat_sample(struct thread_data *, enum fio_ddir, unsigned long, - unsigned int, uint64_t); -extern void add_clat_sample(struct thread_data *, enum fio_ddir, unsigned long, - unsigned int, uint64_t); -extern void add_slat_sample(struct thread_data *, enum fio_ddir, unsigned long, - unsigned int, uint64_t); -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, unsigned int, - struct timeval *); -extern void init_disk_util(struct thread_data *); extern void setup_log(struct io_log **, struct log_params *, const char *); extern void flush_log(struct io_log *, int); +extern void flush_samples(FILE *, void *, uint64_t); extern void free_log(struct io_log *); -extern struct io_log *agg_io_log[DDIR_RWDIR_CNT]; -extern int write_bw_log; -extern void add_agg_sample(unsigned long, enum fio_ddir, unsigned int); extern void fio_writeout_logs(struct thread_data *); extern int iolog_flush(struct io_log *, int); @@ -229,4 +219,11 @@ static inline void init_ipo(struct io_piece *ipo) INIT_FLIST_HEAD(&ipo->trim_list); } +struct iolog_compress { + struct flist_head list; + void *buf; + size_t len; + unsigned int seq; +}; + #endif