fix: io_uring sqpoll issue_time empty when kernel not yet read sq

[fio.git] / engines / libhdfs.c

diff --git a/engines/libhdfs.c b/engines/libhdfs.c
index 9ca82f78cb067469190b2e393f7bc0dd7215df7c..d0a268408435418f261616a734f335b03aa91286 100644 (file)
--- a/engines/libhdfs.c
+++ b/engines/libhdfs.c
@@ -27,7 +27,7 @@ struct hdfsio_data {
 };
 
 struct hdfsio_options {
-       void *pad;                      /* needed because offset can't be 0 for a option defined used offsetof */
+       void *pad;                      /* needed because offset can't be 0 for an option defined used offsetof */
        char *host;
        char *directory;
        unsigned int port;
@@ -240,7 +240,7 @@ int fio_hdfsio_close_file(struct thread_data *td, struct fio_file *f)
        return 0;
 }
 
-static int fio_hdfsio_init(struct thread_data *td)
+static int fio_hdfsio_io_u_init(struct thread_data *td, struct io_u *io_u)
 {
        struct hdfsio_options *options = td->eo;
        struct hdfsio_data *hd = td->io_ops_data;
@@ -315,8 +315,7 @@ static int fio_hdfsio_setup(struct thread_data *td)
        uint64_t file_size, total_file_size;
 
        if (!td->io_ops_data) {
-               hd = malloc(sizeof(*hd));
-               memset(hd, 0, sizeof(*hd));
+               hd = calloc(1, sizeof(*hd));
                
                hd->curr_file_id = -1;
 
@@ -349,7 +348,7 @@ static int fio_hdfsio_setup(struct thread_data *td)
        return 0;
 }
 
-static int fio_hdfsio_io_u_init(struct thread_data *td, struct io_u *io_u)
+static int fio_hdfsio_init(struct thread_data *td)
 {
        struct hdfsio_data *hd = td->io_ops_data;
        struct hdfsio_options *options = td->eo;