Lines Matching refs:td
123 static int fio_hdfsio_prep(struct thread_data *td, struct io_u *io_u)
125 struct hdfsio_options *options = td->eo;
126 struct hdfsio_data *hd = td->io_ops_data;
168 static int fio_hdfsio_queue(struct thread_data *td, struct io_u *io_u)
170 struct hdfsio_data *hd = td->io_ops_data;
171 struct hdfsio_options *options = td->eo;
213 td_verror(td, io_u->error, "xfer");
218 int fio_hdfsio_open_file(struct thread_data *td, struct fio_file *f)
220 if (td->o.odirect) {
221 td->error = EINVAL;
228 int fio_hdfsio_close_file(struct thread_data *td, struct fio_file *f)
230 struct hdfsio_data *hd = td->io_ops_data;
242 static int fio_hdfsio_init(struct thread_data *td)
244 struct hdfsio_options *options = td->eo;
245 struct hdfsio_data *hd = td->io_ops_data;
256 for_each_file(td, f, i) {
309 static int fio_hdfsio_setup(struct thread_data *td)
316 if (!td->io_ops_data) {
322 td->io_ops_data = hd;
328 for_each_file(td, f, i) {
329 if(!td->o.file_size_low) {
330 file_size = floor(td->o.size / td->o.nr_files);
333 else if (td->o.file_size_low == td->o.file_size_high)
334 file_size = td->o.file_size_low;
336 file_size = get_rand_file_size(td);
344 if (!td->o.file_size_low && total_file_size < td->o.size) {
345 f->real_file_size += (td->o.size - total_file_size);
351 static int fio_hdfsio_io_u_init(struct thread_data *td, struct io_u *io_u)
353 struct hdfsio_data *hd = td->io_ops_data;
354 struct hdfsio_options *options = td->eo;
386 static void fio_hdfsio_io_u_free(struct thread_data *td, struct io_u *io_u)
388 struct hdfsio_data *hd = td->io_ops_data;
