Searched refs:ReadPoolCtx_t (Results 1 – 3 of 3) sorted by relevance
78 } ReadPoolCtx_t; typedef156 ReadPoolCtx_t* AIO_ReadPool_create(const FIO_prefs_t* prefs, size_t bufferSize);160 void AIO_ReadPool_free(ReadPoolCtx_t* ctx);165 void AIO_ReadPool_setAsync(ReadPoolCtx_t* ctx, int async);169 void AIO_ReadPool_consumeBytes(ReadPoolCtx_t *ctx, size_t n);176 size_t AIO_ReadPool_fillBuffer(ReadPoolCtx_t *ctx, size_t n);180 size_t AIO_ReadPool_consumeAndRefill(ReadPoolCtx_t *ctx);185 void AIO_ReadPool_setFile(ReadPoolCtx_t *ctx, FILE* file);189 FILE* AIO_ReadPool_getFile(const ReadPoolCtx_t *ctx);193 int AIO_ReadPool_closeFile(ReadPoolCtx_t *ctx);
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()[all …]
1073 ReadPoolCtx_t *readCtx;2319 ReadPoolCtx_t *readCtx;