X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=iolog.h;h=d157fa281bd2828f93e050906f71a21cd5ae817f;hp=ee289448137d329a293e6a4ee3443561aabccac6;hb=81647a9a229b92635062e0a1ee570997634b7848;hpb=af2fde1961fe6847b7f3dbbc74aa46ec09d0e129 diff --git a/iolog.h b/iolog.h index ee289448..d157fa28 100644 --- a/iolog.h +++ b/iolog.h @@ -4,7 +4,7 @@ #include "lib/rbtree.h" #include "lib/ieee754.h" #include "flist.h" -#include "ioengine.h" +#include "ioengines.h" /* * Use for maintaining statistics @@ -131,6 +131,11 @@ struct io_log { pthread_mutex_t chunk_lock; unsigned int chunk_seq; struct flist_head chunk_list; + + pthread_mutex_t deferred_free_lock; +#define IOLOG_MAX_DEFER 8 + void *deferred_items[IOLOG_MAX_DEFER]; + unsigned int deferred; }; /* @@ -259,7 +264,7 @@ struct log_params { static inline bool per_unit_log(struct io_log *log) { - return log && !log->avg_msec; + return log && (!log->avg_msec || log->log_gz || log->log_gz_store); } static inline bool inline_log(struct io_log *log) @@ -269,6 +274,14 @@ static inline bool inline_log(struct io_log *log) log->log_type == IO_LOG_TYPE_SLAT; } +static inline void ipo_bytes_align(unsigned int replay_align, struct io_piece *ipo) +{ + if (!replay_align) + return; + + ipo->offset &= ~(replay_align - (uint64_t)1); +} + extern void finalize_logs(struct thread_data *td, bool); extern void setup_log(struct io_log **, struct log_params *, const char *); extern void flush_log(struct io_log *, bool);