Lines Matching refs:aio
360 struct aiocb **aiocb = md->aio.aiocb; in record__aio_sync()
361 struct aiocb *cblocks = md->aio.cblocks; in record__aio_sync()
367 for (i = 0; i < md->aio.nr_cblocks; ++i) { in record__aio_sync()
386 while (aio_suspend((const struct aiocb **)aiocb, md->aio.nr_cblocks, &timeout)) { in record__aio_sync()
401 struct record_aio *aio = to; in record__aio_pushfn() local
417 if (record__comp_enabled(aio->rec)) { in record__aio_pushfn()
418 ssize_t compressed = zstd_compress(aio->rec->session, NULL, aio->data + aio->size, in record__aio_pushfn()
419 mmap__mmap_len(map) - aio->size, in record__aio_pushfn()
426 memcpy(aio->data + aio->size, buf, size); in record__aio_pushfn()
429 if (!aio->size) { in record__aio_pushfn()
443 aio->size += size; in record__aio_pushfn()
452 struct record_aio aio = { .rec = rec, .size = 0 }; in record__aio_push() local
460 aio.data = map->aio.data[idx]; in record__aio_push()
461 ret = perf_mmap__push(map, &aio, record__aio_pushfn); in record__aio_push()
466 ret = record__aio_write(&(map->aio.cblocks[idx]), trace_fd, aio.data, aio.size, *off); in record__aio_push()
468 *off += aio.size; in record__aio_push()
469 rec->bytes_written += aio.size; in record__aio_push()