116         if (posix_madvise(mIobuf[i].bufs.data(), MAX_FILE_CHUNK_SIZE,  in advise()
141             mIobuf[0].buf[i] = reinterpret_cast<unsigned char*>(data) + total + i * AIO_BUF_LEN;  in doAsync()
143         int ret = iobufSubmit(&mIobuf[0], read ? mBulkOut : mBulkIn, this_len, read);  in doAsync()
145         ret = waitEvents(&mIobuf[0], ret, ioevs, nullptr);  in doAsync()
153         int ret = iobufSubmit(&mIobuf[0], read ? mBulkOut : mBulkIn, 0, read);  in doAsync()
155         ret = waitEvents(&mIobuf[0], ret, ioevs, nullptr);  in doAsync()
160         mIobuf[0].buf[i] = mIobuf[0].bufs.data() + i * AIO_BUF_LEN;  in doAsync()
273         mIobuf[i].bufs.resize(MAX_FILE_CHUNK_SIZE);  in start()
274         mIobuf[i].iocb.resize(AIO_BUFS_MAX);  in start()
275         mIobuf[i].iocbs.resize(AIO_BUFS_MAX);  in start()
276         mIobuf[i].buf.resize(AIO_BUFS_MAX);  in start()
278             mIobuf[i].buf[j] = mIobuf[i].bufs.data() + j * AIO_BUF_LEN;  in start()
279             mIobuf[i].iocb[j] = &mIobuf[i].iocbs[j];  in start()
465             if (iobufSubmit(&mIobuf[i], mBulkOut, length, true) == -1)  in receiveFile()
489             unsigned short_i = mIobuf[i].actual;  in receiveFile()
494                 int event_ret = waitEvents(&mIobuf[i], 1, ioevs, &this_events);  in receiveFile()
498                     cancelEvents(mIobuf[i].iocb.data(), ioevs, num_events, mIobuf[i].actual);  in receiveFile()
508 …                      short_i = (ioevs[j].obj - reinterpret_cast<uint64_t>(mIobuf[i].iocbs.data()))  in receiveFile()
515                 if (cancelEvents(mIobuf[i].iocb.data(), ioevs, short_i, mIobuf[i].actual)) {  in receiveFile()
539             aio_prepare(&aio, mIobuf[i].bufs.data(), ret, offset);  in receiveFile()
550         if (read(mIobuf[0].bufs.data(), packet_size) != 0) {  in receiveFile()
582     mtp_data_header *header = reinterpret_cast<mtp_data_header*>(mIobuf[0].bufs.data());  in sendFile()
590     if (TEMP_FAILURE_RETRY(pread(mfr.fd, mIobuf[0].bufs.data() +  in sendFile()
593     if (doAsync(mIobuf[0].bufs.data(), sizeof(mtp_data_header) + init_read_len,  in sendFile()
605             aio_prepare(&aio, mIobuf[i].bufs.data(), length, offset);  in sendFile()
612             if (waitEvents(&mIobuf[(i-1)%NUM_IO_BUFS], mIobuf[(i-1)%NUM_IO_BUFS].actual, ioevs,  in sendFile()
615                 cancelEvents(mIobuf[(i-1)%NUM_IO_BUFS].iocb.data(), ioevs, num_events,  in sendFile()
616                         mIobuf[(i-1)%NUM_IO_BUFS].actual);  in sendFile()
640             if (iobufSubmit(&mIobuf[i], mBulkIn, num_read, false) == -1) {  in sendFile()
652         if (write(mIobuf[0].bufs.data(), 0) != 0) {  in sendFile()