146 static IOJob_t *AIO_IOPool_createIoJob(IOPoolCtx_t *ctx, size_t bufferSize) {  in AIO_IOPool_createIoJob()
164 static void AIO_IOPool_createThreadPool(IOPoolCtx_t* ctx, const FIO_prefs_t* prefs) {  in AIO_IOPool_createThreadPool()
182 static void AIO_IOPool_init(IOPoolCtx_t* ctx, const FIO_prefs_t* prefs, POOL_function poolFunction,…  in AIO_IOPool_init()
200 static int AIO_IOPool_threadPoolActive(IOPoolCtx_t* ctx) {  in AIO_IOPool_threadPoolActive()
207 static void AIO_IOPool_lockJobsMutex(IOPoolCtx_t* ctx) {  in AIO_IOPool_lockJobsMutex()
214 static void AIO_IOPool_unlockJobsMutex(IOPoolCtx_t* ctx) {  in AIO_IOPool_unlockJobsMutex()
222     IOPoolCtx_t* const ctx = (IOPoolCtx_t *) job->ctx;  in AIO_IOPool_releaseIoJob()  local
231 static void AIO_IOPool_join(IOPoolCtx_t* ctx) {  in AIO_IOPool_join()
239 static void AIO_IOPool_setThreaded(IOPoolCtx_t* ctx, int threaded) {  in AIO_IOPool_setThreaded()
250 static void AIO_IOPool_destroy(IOPoolCtx_t* ctx) {  in AIO_IOPool_destroy()
270 static IOJob_t* AIO_IOPool_acquireJob(IOPoolCtx_t* ctx) {  in AIO_IOPool_acquireJob()
287 static void AIO_IOPool_setFile(IOPoolCtx_t* ctx, FILE* file) {  in AIO_IOPool_setFile()
294 static FILE* AIO_IOPool_getFile(const IOPoolCtx_t* ctx) {  in AIO_IOPool_getFile()
302     IOPoolCtx_t* const ctx = (IOPoolCtx_t *)job->ctx;  in AIO_IOPool_enqueueJob()  local
315 IOJob_t* AIO_WritePool_acquireJob(WritePoolCtx_t* ctx) {  in AIO_WritePool_acquireJob()
332 void AIO_WritePool_sparseWriteEnd(WritePoolCtx_t* ctx) {  in AIO_WritePool_sparseWriteEnd()
343 void AIO_WritePool_setFile(WritePoolCtx_t* ctx, FILE* file) {  in AIO_WritePool_setFile()
350 FILE* AIO_WritePool_getFile(const WritePoolCtx_t* ctx) {  in AIO_WritePool_getFile()
363 int AIO_WritePool_closeFile(WritePoolCtx_t* ctx) {  in AIO_WritePool_closeFile()
375     WritePoolCtx_t* const ctx = (WritePoolCtx_t*) job->ctx;  in AIO_WritePool_executeWriteJob()  local
383     WritePoolCtx_t* const ctx = (WritePoolCtx_t*) malloc(sizeof(WritePoolCtx_t));  in AIO_WritePool_create()  local
392 void AIO_WritePool_free(WritePoolCtx_t* ctx) {  in AIO_WritePool_free()
404 void AIO_WritePool_setAsync(WritePoolCtx_t* ctx, int async) {  in AIO_WritePool_setAsync()
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()  local
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()  local
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()
548     ReadPoolCtx_t* const ctx = (ReadPoolCtx_t*) malloc(sizeof(ReadPoolCtx_t));  in AIO_ReadPool_create()  local
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()