Lines Matching defs:io_u
182 struct io_u **io_us_queued;
184 struct io_u **io_us_flight;
186 struct io_u **io_us_completed;
562 static int fio_rdmaio_prep(struct thread_data *td, struct io_u *io_u)
567 r_io_u_d = io_u->engine_data;
572 r_io_u_d->rdma_sgl.addr = (uint64_t) (unsigned long)io_u->buf;
573 r_io_u_d->rdma_sgl.lkey = io_u->mr->lkey;
580 r_io_u_d->rdma_sgl.addr = (uint64_t) (unsigned long)io_u->buf;
581 r_io_u_d->rdma_sgl.lkey = io_u->mr->lkey;
582 r_io_u_d->rdma_sgl.length = io_u->buflen;
590 r_io_u_d->rdma_sgl.addr = (uint64_t) (unsigned long)io_u->buf;
591 r_io_u_d->rdma_sgl.lkey = io_u->mr->lkey;
592 r_io_u_d->rdma_sgl.length = io_u->buflen;
605 static struct io_u *fio_rdmaio_event(struct thread_data *td, int event)
608 struct io_u *io_u;
611 io_u = rd->io_us_completed[0];
617 dprint_io_u(io_u, "fio_rdmaio_event");
619 return io_u;
684 static int fio_rdmaio_send(struct thread_data *td, struct io_u **io_us,
747 static int fio_rdmaio_recv(struct thread_data *td, struct io_u **io_us,
757 /* post io_u into recv queue */
784 static int fio_rdmaio_queue(struct thread_data *td, struct io_u *io_u)
788 fio_ro_check(td, io_u);
793 rd->io_us_queued[rd->io_u_queued_nr] = io_u;
796 dprint_io_u(io_u, "fio_rdmaio_queue");
801 static void fio_rdmaio_queued(struct thread_data *td, struct io_u **io_us,
814 struct io_u *io_u = io_us[i];
817 rd->io_us_flight[rd->io_u_flight_nr] = io_u;
820 memcpy(&io_u->issue_time, &now, sizeof(now));
821 io_u_queued(td, io_u);
828 struct io_u **io_us;
1260 rd->io_us_queued = malloc(td->o.iodepth * sizeof(struct io_u *));
1261 memset(rd->io_us_queued, 0, td->o.iodepth * sizeof(struct io_u *));
1264 rd->io_us_flight = malloc(td->o.iodepth * sizeof(struct io_u *));
1265 memset(rd->io_us_flight, 0, td->o.iodepth * sizeof(struct io_u *));
1268 rd->io_us_completed = malloc(td->o.iodepth * sizeof(struct io_u *));
1269 memset(rd->io_us_completed, 0, td->o.iodepth * sizeof(struct io_u *));
1285 /* register each io_u in the free list */
1287 struct io_u *io_u = td->io_u_freelist.io_us[i];
1289 io_u->engine_data = malloc(sizeof(struct rdma_io_u_data));
1290 memset(io_u->engine_data, 0, sizeof(struct rdma_io_u_data));
1291 ((struct rdma_io_u_data *)io_u->engine_data)->wr_id = i;
1293 io_u->mr = ibv_reg_mr(rd->pd, io_u->buf, max_bs,
1297 if (io_u->mr == NULL) {
1298 log_err("fio: ibv_reg_mr io_u failed: %m\n");
1303 htonll((uint64_t) (unsigned long)io_u->buf);
1304 rd->send_buf.rmt_us[i].rkey = htonl(io_u->mr->rkey);
1308 log_info("fio: Send rkey %x addr %" PRIx64 " len %d to client\n", io_u->mr->rkey, io_u->buf, max_bs); */
