Lines Matching refs:req
132 static int do_not_aio(struct aio_thread_req *req) in do_not_aio() argument
138 actual = lseek64(req->io_fd, req->offset, SEEK_SET); in do_not_aio()
139 if (actual != req->offset) in do_not_aio()
142 switch (req->type) { in do_not_aio()
144 n = read(req->io_fd, req->buf, req->len); in do_not_aio()
147 n = write(req->io_fd, req->buf, req->len); in do_not_aio()
150 n = read(req->io_fd, &c, sizeof(c)); in do_not_aio()
154 req->type); in do_not_aio()
171 struct aio_thread_req req; in not_aio_thread() local
177 err = read(aio_req_fd_r, &req, sizeof(req)); in not_aio_thread()
178 if (err != sizeof(req)) { in not_aio_thread()
191 err = do_not_aio(&req); in not_aio_thread()
192 reply = ((struct aio_thread_reply) { .data = req.aio, in not_aio_thread()
194 err = write(req.aio->reply_fd, &reply, sizeof(reply)); in not_aio_thread()
197 "fd = %d, err = %d\n", req.aio->reply_fd, errno); in not_aio_thread()
364 struct aio_thread_req req = { .type = type, in submit_aio_24() local
373 err = write(aio_req_fd_w, &req, sizeof(req)); in submit_aio_24()
374 if (err == sizeof(req)) in submit_aio_24()