Lines Matching refs:bd
35 static void binject_buc_init(struct binject_data *bd, struct io_u *io_u)
97 struct binject_data *bd = td->io_ops->data;
99 void *buf = bd->cmds;
113 bd->fd_flags[i] = fio_set_fd_nonblocking(bf->fd, "binject");
115 bd->fd_flags[i] = -1;
117 bd->pfds[i].fd = bf->fd;
118 bd->pfds[i].events = POLLIN;
123 ret = poll(bd->pfds, td->o.nr_files, -1);
132 if (pollin_events(bd->pfds, td->o.nr_files))
150 bd->events[ev_index] = (struct io_u *) (unsigned long) buc->usr_ptr;
159 if (bd->fd_flags[i] == -1)
162 if (fcntl(bf->fd, F_SETFL, bd->fd_flags[i]) < 0)
188 struct binject_data *bd = td->io_ops->data;
198 binject_buc_init(bd, io_u);
201 binject_buc_init(bd, io_u);
207 binject_buc_init(bd, io_u);
237 struct binject_data *bd = td->io_ops->data;
239 return bd->events[event];
379 struct binject_data *bd = td->io_ops->data;
381 if (bd) {
382 free(bd->events);
383 free(bd->cmds);
384 free(bd->fd_flags);
385 free(bd->pfds);
386 free(bd);
392 struct binject_data *bd;
394 bd = malloc(sizeof(*bd));
395 memset(bd, 0, sizeof(*bd));
397 bd->cmds = malloc(td->o.iodepth * sizeof(struct b_user_cmd));
398 memset(bd->cmds, 0, td->o.iodepth * sizeof(struct b_user_cmd));
400 bd->events = malloc(td->o.iodepth * sizeof(struct io_u *));
401 memset(bd->events, 0, td->o.iodepth * sizeof(struct io_u *));
403 bd->pfds = malloc(sizeof(struct pollfd) * td->o.nr_files);
404 memset(bd->pfds, 0, sizeof(struct pollfd) * td->o.nr_files);
406 bd->fd_flags = malloc(sizeof(int) * td->o.nr_files);
407 memset(bd->fd_flags, 0, sizeof(int) * td->o.nr_files);
409 td->io_ops->data = bd;