Lines Matching refs:IOJob_t
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()
356 void AIO_WritePool_releaseIoJob(IOJob_t* job) { in AIO_WritePool_releaseIoJob()
374 IOJob_t* const job = (IOJob_t*) opaque; in AIO_WritePool_executeWriteJob()
415 IOJob_t* job = (IOJob_t*) ctx->completedJobs[i]; in AIO_ReadPool_releaseAllCompletedJobs()
421 static void AIO_ReadPool_addJobToCompleted(IOJob_t* job) { in AIO_ReadPool_addJobToCompleted()
436 static IOJob_t* AIO_ReadPool_findNextWaitingOffsetCompletedJob_locked(ReadPoolCtx_t* ctx) { in AIO_ReadPool_findNextWaitingOffsetCompletedJob_locked()
437 IOJob_t *job = NULL; in AIO_ReadPool_findNextWaitingOffsetCompletedJob_locked()
444 job = (IOJob_t *) ctx->completedJobs[i]; in AIO_ReadPool_findNextWaitingOffsetCompletedJob_locked()
463 static IOJob_t* AIO_ReadPool_getNextCompletedJob(ReadPoolCtx_t* ctx) { in AIO_ReadPool_getNextCompletedJob()
464 IOJob_t *job = NULL; in AIO_ReadPool_getNextCompletedJob()
489 IOJob_t* const job = (IOJob_t*) opaque; in AIO_ReadPool_executeReadJob()
510 IOJob_t* const job = AIO_IOPool_acquireJob(&ctx->base); in AIO_ReadPool_enqueueRead()
530 AIO_IOPool_releaseIoJob((IOJob_t *)ctx->currentJobHeld); in AIO_ReadPool_setFile()
588 static IOJob_t* AIO_ReadPool_releaseCurrentHeldAndGetNext(ReadPoolCtx_t* ctx) { in AIO_ReadPool_releaseCurrentHeldAndGetNext()
590 AIO_IOPool_releaseIoJob((IOJob_t *)ctx->currentJobHeld); in AIO_ReadPool_releaseCurrentHeldAndGetNext()
595 return (IOJob_t*) ctx->currentJobHeld; in AIO_ReadPool_releaseCurrentHeldAndGetNext()
604 IOJob_t *job; in AIO_ReadPool_fillBuffer()