Lines Matching refs:pause
101 struct evrpc_hook_ctx *pause; in evrpc_free() local
108 while ((pause = TAILQ_FIRST(&base->paused_requests)) != NULL) { in evrpc_free()
109 TAILQ_REMOVE(&base->paused_requests, pause, next); in evrpc_free()
110 mm_free(pause); in evrpc_free()
546 struct evrpc_hook_ctx *pause; in evrpc_pool_free() local
555 while ((pause = TAILQ_FIRST(&pool->paused_requests)) != NULL) { in evrpc_pool_free()
556 TAILQ_REMOVE(&pool->paused_requests, pause, next); in evrpc_pool_free()
557 mm_free(pause); in evrpc_pool_free()
771 struct evrpc_hook_ctx *pause = mm_malloc(sizeof(*pause)); in evrpc_pause_request() local
772 if (pause == NULL) in evrpc_pause_request()
775 pause->ctx = ctx; in evrpc_pause_request()
776 pause->cb = cb; in evrpc_pause_request()
778 TAILQ_INSERT_TAIL(&base->pause_requests, pause, next); in evrpc_pause_request()
787 struct evrpc_hook_ctx *pause; in evrpc_resume_request() local
789 TAILQ_FOREACH(pause, head, next) { in evrpc_resume_request()
790 if (pause->ctx == ctx) in evrpc_resume_request()
794 if (pause == NULL) in evrpc_resume_request()
797 (*pause->cb)(pause->ctx, res); in evrpc_resume_request()
798 TAILQ_REMOVE(head, pause, next); in evrpc_resume_request()
799 mm_free(pause); in evrpc_resume_request()