Lines Matching refs:pause
97 struct evrpc_hook_ctx *pause; in evrpc_free() local
104 while ((pause = TAILQ_FIRST(&base->paused_requests)) != NULL) { in evrpc_free()
105 TAILQ_REMOVE(&base->paused_requests, pause, next); in evrpc_free()
106 mm_free(pause); in evrpc_free()
541 struct evrpc_hook_ctx *pause; in evrpc_pool_free() local
550 while ((pause = TAILQ_FIRST(&pool->paused_requests)) != NULL) { in evrpc_pool_free()
551 TAILQ_REMOVE(&pool->paused_requests, pause, next); in evrpc_pool_free()
552 mm_free(pause); in evrpc_pool_free()
766 struct evrpc_hook_ctx *pause = mm_malloc(sizeof(*pause)); in evrpc_pause_request() local
767 if (pause == NULL) in evrpc_pause_request()
770 pause->ctx = ctx; in evrpc_pause_request()
771 pause->cb = cb; in evrpc_pause_request()
773 TAILQ_INSERT_TAIL(&base->pause_requests, pause, next); in evrpc_pause_request()
782 struct evrpc_hook_ctx *pause; in evrpc_resume_request() local
784 TAILQ_FOREACH(pause, head, next) { in evrpc_resume_request()
785 if (pause->ctx == ctx) in evrpc_resume_request()
789 if (pause == NULL) in evrpc_resume_request()
792 (*pause->cb)(pause->ctx, res); in evrpc_resume_request()
793 TAILQ_REMOVE(head, pause, next); in evrpc_resume_request()
794 mm_free(pause); in evrpc_resume_request()