X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=iolog.c;h=4a7d939af251c77ae2de82d2ad57b15a9f04d4b4;hb=a1f871c72971efe84cd42670d5df4c4dc56dbd3f;hp=100b5d79eb14001cdbdddda7cc17c337765f0b52;hpb=0c56718d787c5846db7e75d5a01b88342797c681;p=fio.git diff --git a/iolog.c b/iolog.c index 100b5d79..4a7d939a 100644 --- a/iolog.c +++ b/iolog.c @@ -28,19 +28,14 @@ void queue_io_piece(struct thread_data *td, struct io_piece *ipo) td->total_io_size += ipo->len; } -void log_io_u(struct thread_data *td, struct io_u *io_u) +void log_io_u(const struct thread_data *td, const struct io_u *io_u) { - const char *act[] = { "read", "write", "sync", "datasync", - "sync_file_range", "wait", "trim" }; - - assert(io_u->ddir <= 6); - if (!td->o.write_iolog_file) return; fprintf(td->iolog_f, "%s %s %llu %lu\n", io_u->file->file_name, - act[io_u->ddir], io_u->offset, - io_u->buflen); + io_ddir_name(io_u->ddir), + io_u->offset, io_u->buflen); } void log_file(struct thread_data *td, struct fio_file *f, @@ -73,12 +68,6 @@ static void iolog_delay(struct thread_data *td, unsigned long delay) delay -= usec; - /* - * less than 100 usec delay, just regard it as noise - */ - if (delay < 100) - return; - while (delay && !td->terminate) { this_delay = delay; if (this_delay > 500000) @@ -113,7 +102,7 @@ static int ipo_special(struct thread_data *td, struct io_piece *ipo) td_io_close_file(td, f); break; case FIO_LOG_UNLINK_FILE: - unlink(f->file_name); + td_io_unlink_file(td, f); break; default: log_err("fio: bad file action %d\n", ipo->file_action); @@ -293,7 +282,7 @@ void unlog_io_piece(struct thread_data *td, struct io_u *io_u) td->io_hist_len--; } -void trim_io_piece(struct thread_data *td, struct io_u *io_u) +void trim_io_piece(struct thread_data *td, const struct io_u *io_u) { struct io_piece *ipo = io_u->ipo; @@ -550,9 +539,9 @@ int init_iolog(struct thread_data *td) void setup_log(struct io_log **log, struct log_params *p, const char *filename) { - struct io_log *l = malloc(sizeof(*l)); + struct io_log *l; - memset(l, 0, sizeof(*l)); + l = calloc(1, sizeof(*l)); l->nr_samples = 0; l->max_samples = 1024; l->log_type = p->log_type;