Lines Matching defs:ld
53 struct guasi_data *ld = td->io_ops_data;
58 if (guasi_req_info(ld->reqs[event], &rinf) < 0) {
85 struct guasi_data *ld = td->io_ops_data;
90 if (min > ld->max_reqs)
91 min = ld->max_reqs;
92 if (max > ld->max_reqs)
93 max = ld->max_reqs;
96 for (n = 0; n < ld->reqs_nr; n++)
97 guasi_req_free(ld->reqs[n]);
100 r = guasi_fetch(ld->hctx, ld->reqs + n, min - n,
110 ld->reqs_nr = n;
118 struct guasi_data *ld = td->io_ops_data;
123 if (ld->queued_nr == (int) td->o.iodepth)
126 ld->io_us[ld->queued_nr] = io_u;
127 ld->queued_nr++;
151 struct guasi_data *ld = td->io_ops_data;
156 GDBG_PRINT(("fio_guasi_commit(%d)\n", ld->queued_nr));
157 for (i = 0; i < ld->queued_nr; i++) {
158 io_u = ld->io_us[i];
163 io_u->greq = guasi__pread(ld->hctx, ld, io_u, 0,
167 io_u->greq = guasi__pwrite(ld->hctx, ld, io_u, 0,
171 io_u->greq = guasi__fsync(ld->hctx, ld, io_u, 0, f->fd);
182 fio_guasi_queued(td, ld->io_us, i);
183 ld->queued_nr = 0;
201 struct guasi_data *ld = td->io_ops_data;
204 GDBG_PRINT(("fio_guasi_cleanup(%p)\n", ld));
205 if (ld) {
206 for (n = 0; n < ld->reqs_nr; n++)
207 guasi_req_free(ld->reqs[n]);
208 guasi_free(ld->hctx);
209 free(ld->reqs);
210 free(ld->io_us);
211 free(ld);
213 GDBG_PRINT(("fio_guasi_cleanup(%p) DONE\n", ld));
219 struct guasi_data *ld = malloc(sizeof(*ld));
222 memset(ld, 0, sizeof(*ld));
226 if ((ld->hctx = guasi_create(GFIO_MIN_THREADS, maxthr, 1)) == NULL) {
228 free(ld);
231 ld->max_reqs = td->o.iodepth;
232 ld->reqs = malloc(ld->max_reqs * sizeof(guasi_req_t));
233 ld->io_us = malloc(ld->max_reqs * sizeof(struct io_u *));
234 memset(ld->io_us, 0, ld->max_reqs * sizeof(struct io_u *));
235 ld->queued_nr = 0;
236 ld->reqs_nr = 0;
238 td->io_ops_data = ld;
239 GDBG_PRINT(("fio_guasi_init(): depth=%d -> %p\n", td->o.iodepth, ld));
