Lines Matching refs:ReadPoolCtx_t
412 static void AIO_ReadPool_releaseAllCompletedJobs(ReadPoolCtx_t* ctx) { in AIO_ReadPool_releaseAllCompletedJobs()
422 ReadPoolCtx_t* const ctx = (ReadPoolCtx_t *)job->ctx; in AIO_ReadPool_addJobToCompleted()
436 static IOJob_t* AIO_ReadPool_findNextWaitingOffsetCompletedJob_locked(ReadPoolCtx_t* ctx) { in AIO_ReadPool_findNextWaitingOffsetCompletedJob_locked()
455 static size_t AIO_ReadPool_numReadsInFlight(ReadPoolCtx_t* ctx) { in AIO_ReadPool_numReadsInFlight()
463 static IOJob_t* AIO_ReadPool_getNextCompletedJob(ReadPoolCtx_t* ctx) { in AIO_ReadPool_getNextCompletedJob()
490 ReadPoolCtx_t* const ctx = (ReadPoolCtx_t *)job->ctx; in AIO_ReadPool_executeReadJob()
509 static void AIO_ReadPool_enqueueRead(ReadPoolCtx_t* ctx) { in AIO_ReadPool_enqueueRead()
516 static void AIO_ReadPool_startReading(ReadPoolCtx_t* ctx) { in AIO_ReadPool_startReading()
525 void AIO_ReadPool_setFile(ReadPoolCtx_t* ctx, FILE* file) { in AIO_ReadPool_setFile()
547 ReadPoolCtx_t* AIO_ReadPool_create(const FIO_prefs_t* prefs, size_t bufferSize) { in AIO_ReadPool_create()
548 ReadPoolCtx_t* const ctx = (ReadPoolCtx_t*) malloc(sizeof(ReadPoolCtx_t)); in AIO_ReadPool_create()
568 void AIO_ReadPool_free(ReadPoolCtx_t* ctx) { in AIO_ReadPool_free()
580 void AIO_ReadPool_consumeBytes(ReadPoolCtx_t* ctx, size_t n) { in AIO_ReadPool_consumeBytes()
588 static IOJob_t* AIO_ReadPool_releaseCurrentHeldAndGetNext(ReadPoolCtx_t* ctx) { in AIO_ReadPool_releaseCurrentHeldAndGetNext()
603 size_t AIO_ReadPool_fillBuffer(ReadPoolCtx_t* ctx, size_t n) { in AIO_ReadPool_fillBuffer()
639 size_t AIO_ReadPool_consumeAndRefill(ReadPoolCtx_t* ctx) { in AIO_ReadPool_consumeAndRefill()
646 FILE* AIO_ReadPool_getFile(const ReadPoolCtx_t* ctx) { in AIO_ReadPool_getFile()
652 int AIO_ReadPool_closeFile(ReadPoolCtx_t* ctx) { in AIO_ReadPool_closeFile()
661 void AIO_ReadPool_setAsync(ReadPoolCtx_t* ctx, int async) { in AIO_ReadPool_setAsync()