Lines Matching refs:pause
99 struct evrpc_hook_ctx *pause; in evrpc_free() local
106 while ((pause = TAILQ_FIRST(&base->paused_requests)) != NULL) { in evrpc_free()
107 TAILQ_REMOVE(&base->paused_requests, pause, next); in evrpc_free()
108 mm_free(pause); in evrpc_free()
543 struct evrpc_hook_ctx *pause; in evrpc_pool_free() local
552 while ((pause = TAILQ_FIRST(&pool->paused_requests)) != NULL) { in evrpc_pool_free()
553 TAILQ_REMOVE(&pool->paused_requests, pause, next); in evrpc_pool_free()
554 mm_free(pause); in evrpc_pool_free()
768 struct evrpc_hook_ctx *pause = mm_malloc(sizeof(*pause)); in evrpc_pause_request() local
769 if (pause == NULL) in evrpc_pause_request()
772 pause->ctx = ctx; in evrpc_pause_request()
773 pause->cb = cb; in evrpc_pause_request()
775 TAILQ_INSERT_TAIL(&base->pause_requests, pause, next); in evrpc_pause_request()
784 struct evrpc_hook_ctx *pause; in evrpc_resume_request() local
786 TAILQ_FOREACH(pause, head, next) { in evrpc_resume_request()
787 if (pause->ctx == ctx) in evrpc_resume_request()
791 if (pause == NULL) in evrpc_resume_request()
794 (*pause->cb)(pause->ctx, res); in evrpc_resume_request()
795 TAILQ_REMOVE(head, pause, next); in evrpc_resume_request()
796 mm_free(pause); in evrpc_resume_request()