58 static int fio_hdfsio_prep(struct thread_data *td, struct io_u *io_u)  in fio_hdfsio_prep()  argument
74 	f_id = (io_u->offset / hd->fsbs) + hd->fid_correction;  in fio_hdfsio_prep()
85 	if (io_u->ddir == DDIR_READ) {  in fio_hdfsio_prep()
87 	} else if (io_u->ddir == DDIR_WRITE) {  in fio_hdfsio_prep()
97 		if (fi->mSize >= hd->fsbs || io_u->ddir == DDIR_WRITE) {  in fio_hdfsio_prep()
113 static int fio_io_end(struct thread_data *td, struct io_u *io_u, int ret)  in fio_io_end()  argument
115 	if (ret != (int)io_u->xfer_buflen) {  in fio_io_end()
117 			io_u->resid = io_u->xfer_buflen - ret;  in fio_io_end()
118 			io_u->error = 0;  in fio_io_end()
121 			io_u->error = errno;  in fio_io_end()
124 	if (io_u->error)  in fio_io_end()
125 		td_verror(td, io_u->error, "xfer");  in fio_io_end()
130 static int fio_hdfsio_queue(struct thread_data *td, struct io_u *io_u)  in fio_hdfsio_queue()  argument
137 	if (io_u->ddir == DDIR_READ) {  in fio_hdfsio_queue()
139 		    hdfsRead(hd->fs, hd->fp, io_u->xfer_buf, io_u->xfer_buflen);  in fio_hdfsio_queue()
140 	} else if (io_u->ddir == DDIR_WRITE) {  in fio_hdfsio_queue()
142 		    hdfsWrite(hd->fs, hd->fp, io_u->xfer_buf,  in fio_hdfsio_queue()
143 			      io_u->xfer_buflen);  in fio_hdfsio_queue()
148 	return fio_io_end(td, io_u, ret);  in fio_hdfsio_queue()