Lines Matching refs:iocb
274 mIobuf[i].iocb.resize(AIO_BUFS_MAX); in start()
279 mIobuf[i].iocb[j] = &mIobuf[i].iocbs[j]; in start()
372 int MtpFfsHandle::cancelEvents(struct iocb **iocb, struct io_event *events, unsigned start, in cancelEvents() argument
384 if (io_cancel(mCtx, iocb[j], nullptr) != -1 || errno != EINPROGRESS) { in cancelEvents()
416 io_prep(buf->iocb[j], fd, buf->buf[j], rq_length, 0, read); in iobufSubmit()
417 buf->iocb[j]->aio_flags |= IOCB_FLAG_RESFD; in iobufSubmit()
418 buf->iocb[j]->aio_resfd = mEventFd; in iobufSubmit()
427 ret = io_submit(mCtx, buf->actual, buf->iocb.data()); in iobufSubmit()
498 cancelEvents(mIobuf[i].iocb.data(), ioevs, num_events, mIobuf[i].actual); in receiveFile()
505 reinterpret_cast<struct iocb*>(ioevs[j].obj)->aio_nbytes) { in receiveFile()
509 / sizeof(struct iocb) + 1; in receiveFile()
515 if (cancelEvents(mIobuf[i].iocb.data(), ioevs, short_i, mIobuf[i].actual)) { in receiveFile()
615 cancelEvents(mIobuf[(i-1)%NUM_IO_BUFS].iocb.data(), ioevs, num_events, in sendFile()