Searched refs:IOJob_t (Results 1 – 3 of 3) sorted by relevance
146 static IOJob_t *AIO_IOPool_createIoJob(IOPoolCtx_t *ctx, size_t bufferSize) { in AIO_IOPool_createIoJob()147 IOJob_t* const job = (IOJob_t*) malloc(sizeof(IOJob_t)); in AIO_IOPool_createIoJob()221 static void AIO_IOPool_releaseIoJob(IOJob_t* job) { in AIO_IOPool_releaseIoJob()262 IOJob_t* job = (IOJob_t*) ctx->availableJobs[i]; in AIO_IOPool_destroy()270 static IOJob_t* AIO_IOPool_acquireJob(IOPoolCtx_t* ctx) { in AIO_IOPool_acquireJob()271 IOJob_t* job; in AIO_IOPool_acquireJob()275 job = (IOJob_t*) ctx->availableJobs[--ctx->availableJobsCount]; in AIO_IOPool_acquireJob()301 static void AIO_IOPool_enqueueJob(IOJob_t* job) { in AIO_IOPool_enqueueJob()315 IOJob_t* AIO_WritePool_acquireJob(WritePoolCtx_t* ctx) { in AIO_WritePool_acquireJob()324 void AIO_WritePool_enqueueAndReacquireWriteJob(IOJob_t **job) { in AIO_WritePool_enqueueAndReacquireWriteJob()[all …]
96 } IOJob_t; typedef105 void AIO_WritePool_releaseIoJob(IOJob_t *job);109 IOJob_t* AIO_WritePool_acquireJob(WritePoolCtx_t *ctx);116 void AIO_WritePool_enqueueAndReacquireWriteJob(IOJob_t **job);
1220 IOJob_t *writeJob = NULL; in FIO_compressGzFrame()1317 IOJob_t *writeJob = NULL; in FIO_compressLzmaFrame()1409 IOJob_t* writeJob = AIO_WritePool_acquireJob(ress->writeCtx); in FIO_compressLz4Frame()1498 IOJob_t* writeJob = AIO_WritePool_acquireJob(ressPtr->writeCtx); in FIO_compressZstdFrame()2378 IOJob_t *writeJob = AIO_WritePool_acquireJob(ress->writeCtx); in FIO_passThrough()2442 IOJob_t* writeJob = AIO_WritePool_acquireJob(ress->writeCtx); in FIO_decompressZstdFrame()2514 IOJob_t *writeJob = NULL; in FIO_decompressGzFrame()2583 IOJob_t *writeJob = NULL; in FIO_decompressLzmaFrame()2653 IOJob_t *writeJob = NULL; in FIO_decompressLz4Frame()