Lines Matching refs:connection

504 static int evrpc_schedule_request(struct evhttp_connection *connection,
540 struct evhttp_connection *connection; in evrpc_pool_free() local
556 while ((connection = TAILQ_FIRST(&pool->connections)) != NULL) { in evrpc_pool_free()
557 TAILQ_REMOVE(&pool->connections, connection, next); in evrpc_pool_free()
558 evhttp_connection_free(connection); in evrpc_pool_free()
581 struct evhttp_connection *connection) in evrpc_pool_add_connection() argument
583 EVUTIL_ASSERT(connection->http_server == NULL); in evrpc_pool_add_connection()
584 TAILQ_INSERT_TAIL(&pool->connections, connection, next); in evrpc_pool_add_connection()
590 evhttp_connection_set_base(connection, pool->base); in evrpc_pool_add_connection()
596 if (!evutil_timerisset(&connection->timeout)) in evrpc_pool_add_connection()
597 evhttp_connection_set_timeout(connection, pool->timeout); in evrpc_pool_add_connection()
608 evrpc_schedule_request(connection, request); in evrpc_pool_add_connection()
614 struct evhttp_connection *connection) in evrpc_pool_remove_connection() argument
616 TAILQ_REMOVE(&pool->connections, connection, next); in evrpc_pool_remove_connection()
640 struct evhttp_connection *connection; in evrpc_pool_find_connection() local
641 TAILQ_FOREACH(connection, &pool->connections, next) { in evrpc_pool_find_connection()
642 if (TAILQ_FIRST(&connection->requests) == NULL) in evrpc_pool_find_connection()
643 return (connection); in evrpc_pool_find_connection()
659 evrpc_schedule_request(struct evhttp_connection *connection, in evrpc_schedule_request() argument
673 ctx->evcon = connection; in evrpc_schedule_request()
681 evrpc_hook_associate_meta_(&ctx->hook_meta, connection); in evrpc_schedule_request()
721 struct evhttp_connection *connection = ctx->evcon; in evrpc_schedule_request_closure() local
746 res = evhttp_make_request(connection, req, EVHTTP_REQ_POST, uri); in evrpc_schedule_request_closure()