Lines Matching refs:availableJobsCount
188 ctx->availableJobsCount = ctx->totalIoJobs; in AIO_IOPool_init()
189 for(i=0; i < ctx->availableJobsCount; i++) { in AIO_IOPool_init()
224 assert(ctx->availableJobsCount < ctx->totalIoJobs); in AIO_IOPool_releaseIoJob()
225 ctx->availableJobs[ctx->availableJobsCount++] = job; in AIO_IOPool_releaseIoJob()
256 assert(ctx->availableJobsCount == ctx->totalIoJobs); in AIO_IOPool_destroy()
261 for(i=0; i<ctx->availableJobsCount; i++) { in AIO_IOPool_destroy()
274 assert(ctx->availableJobsCount > 0); in AIO_IOPool_acquireJob()
275 job = (IOJob_t*) ctx->availableJobs[--ctx->availableJobsCount]; in AIO_IOPool_acquireJob()
290 assert(ctx->availableJobsCount == ctx->totalIoJobs); in AIO_IOPool_setFile()
457 …return (size_t)(ctx->base.totalIoJobs - (ctx->base.availableJobsCount + ctx->completedJobsCount + … in AIO_ReadPool_numReadsInFlight()
517 while(ctx->base.availableJobsCount) { in AIO_ReadPool_startReading()