Home | History | Annotate | Download | only in programs

Lines Matching refs:IOJob_t

146 static IOJob_t *AIO_IOPool_createIoJob(IOPoolCtx_t *ctx, size_t bufferSize) {
147     IOJob_t* const job  = (IOJob_t*) malloc(sizeof(IOJob_t));
221 static void AIO_IOPool_releaseIoJob(IOJob_t* job) {
262         IOJob_t* job = (IOJob_t*) ctx->availableJobs[i];
270 static IOJob_t* AIO_IOPool_acquireJob(IOPoolCtx_t* ctx) {
271     IOJob_t* job;
275     job = (IOJob_t*) ctx->availableJobs[--ctx->availableJobsCount];
301 static void AIO_IOPool_enqueueJob(IOJob_t* job) {
315 IOJob_t* AIO_WritePool_acquireJob(WritePoolCtx_t* ctx) {
324 void AIO_WritePool_enqueueAndReacquireWriteJob(IOJob_t **job) {
356 void AIO_WritePool_releaseIoJob(IOJob_t* job) {
374     IOJob_t* const job = (IOJob_t*) opaque;
415         IOJob_t* job = (IOJob_t*) ctx->completedJobs[i];
421 static void AIO_ReadPool_addJobToCompleted(IOJob_t* job) {
436 static IOJob_t* AIO_ReadPool_findNextWaitingOffsetCompletedJob_locked(ReadPoolCtx_t* ctx) {
437     IOJob_t *job = NULL;
444         job = (IOJob_t *) ctx->completedJobs[i];
461  * Returns a completed IOJob_t for the next read in line based on waitingOnOffset and advances waitingOnOffset.
463 static IOJob_t* AIO_ReadPool_getNextCompletedJob(ReadPoolCtx_t* ctx) {
464     IOJob_t *job = NULL;
489     IOJob_t* const job = (IOJob_t*) opaque;
510     IOJob_t* const job = AIO_IOPool_acquireJob(&ctx->base);
530         AIO_IOPool_releaseIoJob((IOJob_t *)ctx->currentJobHeld);
588 static IOJob_t* AIO_ReadPool_releaseCurrentHeldAndGetNext(ReadPoolCtx_t* ctx) {
590         AIO_IOPool_releaseIoJob((IOJob_t *)ctx->currentJobHeld);
595     return (IOJob_t*) ctx->currentJobHeld;
604     IOJob_t *job;