evcon             116 opal/mca/event/libevent2022/libevent/evrpc-internal.h 	struct evhttp_connection *evcon;
evcon             121 opal/mca/event/libevent2022/libevent/evrpc-internal.h     struct evhttp_connection *evcon);
evcon             176 opal/mca/event/libevent2022/libevent/evrpc-internal.h 	struct evhttp_connection *evcon;
evcon             304 opal/mca/event/libevent2022/libevent/evrpc.c 		evrpc_hook_associate_meta(&rpc_state->hook_meta, req->evcon);
evcon             430 opal/mca/event/libevent2022/libevent/evrpc.c 		evrpc_hook_associate_meta(&rpc_state->hook_meta, req->evcon);
evcon             624 opal/mca/event/libevent2022/libevent/evrpc.c 	struct evhttp_connection *evcon;
evcon             625 opal/mca/event/libevent2022/libevent/evrpc.c 	TAILQ_FOREACH(evcon, &pool->connections, next) {
evcon             626 opal/mca/event/libevent2022/libevent/evrpc.c 		evcon->timeout = timeout_in_secs;
evcon             675 opal/mca/event/libevent2022/libevent/evrpc.c 	ctx->evcon = connection;
evcon             723 opal/mca/event/libevent2022/libevent/evrpc.c 	struct evhttp_connection *connection = ctx->evcon;
evcon             841 opal/mca/event/libevent2022/libevent/evrpc.c 	ctx->evcon = NULL;
evcon             880 opal/mca/event/libevent2022/libevent/evrpc.c 		evrpc_hook_associate_meta(&ctx->hook_meta, ctx->evcon);
evcon             960 opal/mca/event/libevent2022/libevent/evrpc.c 	struct evhttp_connection *evcon;
evcon             966 opal/mca/event/libevent2022/libevent/evrpc.c 	if ((evcon = evrpc_pool_find_connection(pool)) != NULL) {
evcon             968 opal/mca/event/libevent2022/libevent/evrpc.c 		evrpc_schedule_request(evcon, ctx);
evcon             976 opal/mca/event/libevent2022/libevent/evrpc.c 	struct evhttp_connection *evcon = ctx->evcon;
evcon             977 opal/mca/event/libevent2022/libevent/evrpc.c 	EVUTIL_ASSERT(evcon != NULL);
evcon             979 opal/mca/event/libevent2022/libevent/evrpc.c 	evhttp_connection_fail(evcon, EVCON_HTTP_TIMEOUT);
evcon            1008 opal/mca/event/libevent2022/libevent/evrpc.c 	ctx->evcon = NULL;
evcon            1015 opal/mca/event/libevent2022/libevent/evrpc.c     struct evhttp_connection *evcon)
evcon            1020 opal/mca/event/libevent2022/libevent/evrpc.c 	ctx->evcon = evcon;
evcon            1078 opal/mca/event/libevent2022/libevent/evrpc.c 	return (req->hook_meta != NULL ? req->hook_meta->evcon : NULL);
evcon             174 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon);
evcon             176 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon);
evcon             178 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon);
evcon             179 opal/mca/event/libevent2022/libevent/http.c static void evhttp_request_dispatch(struct evhttp_connection* evcon);
evcon             180 opal/mca/event/libevent2022/libevent/http.c static void evhttp_read_firstline(struct evhttp_connection *evcon,
evcon             182 opal/mca/event/libevent2022/libevent/http.c static void evhttp_read_header(struct evhttp_connection *evcon,
evcon             377 opal/mca/event/libevent2022/libevent/http.c evhttp_write_buffer(struct evhttp_connection *evcon,
evcon             383 opal/mca/event/libevent2022/libevent/http.c 	evcon->cb = cb;
evcon             384 opal/mca/event/libevent2022/libevent/http.c 	evcon->cb_arg = arg;
evcon             389 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_setcb(evcon->bufev,
evcon             393 opal/mca/event/libevent2022/libevent/http.c 	    evcon);
evcon             395 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_enable(evcon->bufev, EV_WRITE);
evcon             399 opal/mca/event/libevent2022/libevent/http.c evhttp_send_continue_done(struct evhttp_connection *evcon, void *arg)
evcon             401 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_disable(evcon->bufev, EV_WRITE);
evcon             405 opal/mca/event/libevent2022/libevent/http.c evhttp_send_continue(struct evhttp_connection *evcon,
evcon             408 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_enable(evcon->bufev, EV_WRITE);
evcon             409 opal/mca/event/libevent2022/libevent/http.c 	evbuffer_add_printf(bufferevent_get_output(evcon->bufev),
evcon             412 opal/mca/event/libevent2022/libevent/http.c 	evcon->cb = evhttp_send_continue_done;
evcon             413 opal/mca/event/libevent2022/libevent/http.c 	evcon->cb_arg = NULL;
evcon             414 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_setcb(evcon->bufev,
evcon             418 opal/mca/event/libevent2022/libevent/http.c 	    evcon);
evcon             423 opal/mca/event/libevent2022/libevent/http.c evhttp_connected(struct evhttp_connection *evcon)
evcon             425 opal/mca/event/libevent2022/libevent/http.c 	switch (evcon->state) {
evcon             445 opal/mca/event/libevent2022/libevent/http.c evhttp_make_header_request(struct evhttp_connection *evcon,
evcon             454 opal/mca/event/libevent2022/libevent/http.c 	evbuffer_add_printf(bufferevent_get_output(evcon->bufev),
evcon             537 opal/mca/event/libevent2022/libevent/http.c evhttp_make_header_response(struct evhttp_connection *evcon,
evcon             541 opal/mca/event/libevent2022/libevent/http.c 	evbuffer_add_printf(bufferevent_get_output(evcon->bufev),
evcon             593 opal/mca/event/libevent2022/libevent/http.c evhttp_make_header(struct evhttp_connection *evcon, struct evhttp_request *req)
evcon             596 opal/mca/event/libevent2022/libevent/http.c 	struct evbuffer *output = bufferevent_get_output(evcon->bufev);
evcon             603 opal/mca/event/libevent2022/libevent/http.c 		evhttp_make_header_request(evcon, req);
evcon             605 opal/mca/event/libevent2022/libevent/http.c 		evhttp_make_header_response(evcon, req);
evcon             627 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_set_max_headers_size(struct evhttp_connection *evcon,
evcon             631 opal/mca/event/libevent2022/libevent/http.c 		evcon->max_headers_size = EV_SIZE_MAX;
evcon             633 opal/mca/event/libevent2022/libevent/http.c 		evcon->max_headers_size = new_max_headers_size;
evcon             636 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_set_max_body_size(struct evhttp_connection* evcon,
evcon             640 opal/mca/event/libevent2022/libevent/http.c 		evcon->max_body_size = EV_UINT64_MAX;
evcon             642 opal/mca/event/libevent2022/libevent/http.c 		evcon->max_body_size = new_max_body_size;
evcon             662 opal/mca/event/libevent2022/libevent/http.c 			TAILQ_REMOVE(&req->evcon->requests, req, next);
evcon             666 opal/mca/event/libevent2022/libevent/http.c 			req->evcon = NULL;
evcon             698 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_fail(struct evhttp_connection *evcon,
evcon             701 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_request* req = TAILQ_FIRST(&evcon->requests);
evcon             706 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_disable(evcon->bufev, EV_READ|EV_WRITE);
evcon             708 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->flags & EVHTTP_CON_INCOMING) {
evcon             718 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_free(evcon);
evcon             736 opal/mca/event/libevent2022/libevent/http.c 	TAILQ_REMOVE(&evcon->requests, req, next);
evcon             740 opal/mca/event/libevent2022/libevent/http.c 	evhttp_connection_reset(evcon);
evcon             743 opal/mca/event/libevent2022/libevent/http.c 	if (TAILQ_FIRST(&evcon->requests) != NULL)
evcon             744 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_connect(evcon);
evcon             756 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon = arg;
evcon             759 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->cb != NULL)
evcon             760 opal/mca/event/libevent2022/libevent/http.c 		(*evcon->cb)(evcon, evcon->cb_arg);
evcon             771 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_done(struct evhttp_connection *evcon)
evcon             773 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_request *req = TAILQ_FIRST(&evcon->requests);
evcon             774 opal/mca/event/libevent2022/libevent/http.c 	int con_outgoing = evcon->flags & EVHTTP_CON_OUTGOING;
evcon             779 opal/mca/event/libevent2022/libevent/http.c 		TAILQ_REMOVE(&evcon->requests, req, next);
evcon             780 opal/mca/event/libevent2022/libevent/http.c 		req->evcon = NULL;
evcon             782 opal/mca/event/libevent2022/libevent/http.c 		evcon->state = EVCON_IDLE;
evcon             790 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_reset(evcon);
evcon             792 opal/mca/event/libevent2022/libevent/http.c 		if (TAILQ_FIRST(&evcon->requests) != NULL) {
evcon             797 opal/mca/event/libevent2022/libevent/http.c 			if (!evhttp_connected(evcon))
evcon             798 opal/mca/event/libevent2022/libevent/http.c 				evhttp_connection_connect(evcon);
evcon             800 opal/mca/event/libevent2022/libevent/http.c 				evhttp_request_dispatch(evcon);
evcon             806 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_start_detectclose(evcon);
evcon             813 opal/mca/event/libevent2022/libevent/http.c 		evcon->state = EVCON_WRITING;
evcon             889 opal/mca/event/libevent2022/libevent/http.c 			if (req->body_size + (size_t)ntoread > req->evcon->max_body_size) {
evcon             933 opal/mca/event/libevent2022/libevent/http.c evhttp_read_trailer(struct evhttp_connection *evcon, struct evhttp_request *req)
evcon             935 opal/mca/event/libevent2022/libevent/http.c 	struct evbuffer *buf = bufferevent_get_input(evcon->bufev);
evcon             940 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_fail(evcon, EVCON_HTTP_INVALID_HEADER);
evcon             943 opal/mca/event/libevent2022/libevent/http.c 		bufferevent_disable(evcon->bufev, EV_READ);
evcon             944 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_done(evcon);
evcon             949 opal/mca/event/libevent2022/libevent/http.c 		bufferevent_enable(evcon->bufev, EV_READ);
evcon             955 opal/mca/event/libevent2022/libevent/http.c evhttp_read_body(struct evhttp_connection *evcon, struct evhttp_request *req)
evcon             957 opal/mca/event/libevent2022/libevent/http.c 	struct evbuffer *buf = bufferevent_get_input(evcon->bufev);
evcon             963 opal/mca/event/libevent2022/libevent/http.c 			evcon->state = EVCON_READING_TRAILER;
evcon             964 opal/mca/event/libevent2022/libevent/http.c 			evhttp_read_trailer(evcon, req);
evcon             969 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_fail(evcon,
evcon             983 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_fail(evcon, EVCON_HTTP_INVALID_HEADER);
evcon            1002 opal/mca/event/libevent2022/libevent/http.c 	if (req->body_size > req->evcon->max_body_size ||
evcon            1004 opal/mca/event/libevent2022/libevent/http.c 		(size_t)req->ntoread > req->evcon->max_body_size)) {
evcon            1008 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_fail(evcon,
evcon            1026 opal/mca/event/libevent2022/libevent/http.c 		bufferevent_disable(evcon->bufev, EV_READ);
evcon            1028 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_done(evcon);
evcon            1033 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_enable(evcon->bufev, EV_READ);
evcon            1036 opal/mca/event/libevent2022/libevent/http.c #define get_deferred_queue(evcon)		\
evcon            1037 opal/mca/event/libevent2022/libevent/http.c 	(event_base_get_deferred_cb_queue((evcon)->base))
evcon            1046 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon = arg;
evcon            1047 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_request *req = TAILQ_FIRST(&evcon->requests);
evcon            1050 opal/mca/event/libevent2022/libevent/http.c 	event_deferred_cb_cancel(get_deferred_queue(evcon),
evcon            1051 opal/mca/event/libevent2022/libevent/http.c 	    &evcon->read_more_deferred_cb);
evcon            1053 opal/mca/event/libevent2022/libevent/http.c 	switch (evcon->state) {
evcon            1055 opal/mca/event/libevent2022/libevent/http.c 		evhttp_read_firstline(evcon, req);
evcon            1060 opal/mca/event/libevent2022/libevent/http.c 		evhttp_read_header(evcon, req);
evcon            1065 opal/mca/event/libevent2022/libevent/http.c 		evhttp_read_body(evcon, req);
evcon            1070 opal/mca/event/libevent2022/libevent/http.c 		evhttp_read_trailer(evcon, req);
evcon            1078 opal/mca/event/libevent2022/libevent/http.c 			input = bufferevent_get_input(evcon->bufev);
evcon            1086 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_reset(evcon);
evcon            1094 opal/mca/event/libevent2022/libevent/http.c 			   __func__, evcon->state);
evcon            1101 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon = data;
evcon            1102 opal/mca/event/libevent2022/libevent/http.c 	evhttp_read_cb(evcon->bufev, evcon);
evcon            1106 opal/mca/event/libevent2022/libevent/http.c evhttp_write_connectioncb(struct evhttp_connection *evcon, void *arg)
evcon            1109 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_request *req = TAILQ_FIRST(&evcon->requests);
evcon            1112 opal/mca/event/libevent2022/libevent/http.c 	EVUTIL_ASSERT(evcon->state == EVCON_WRITING);
evcon            1117 opal/mca/event/libevent2022/libevent/http.c 	evhttp_start_read(evcon);
evcon            1125 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_free(struct evhttp_connection *evcon)
evcon            1130 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->fd != -1) {
evcon            1131 opal/mca/event/libevent2022/libevent/http.c 		if (evhttp_connected(evcon) && evcon->closecb != NULL)
evcon            1132 opal/mca/event/libevent2022/libevent/http.c 			(*evcon->closecb)(evcon, evcon->closecb_arg);
evcon            1140 opal/mca/event/libevent2022/libevent/http.c 	while ((req = TAILQ_FIRST(&evcon->requests)) != NULL) {
evcon            1141 opal/mca/event/libevent2022/libevent/http.c 		TAILQ_REMOVE(&evcon->requests, req, next);
evcon            1145 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->http_server != NULL) {
evcon            1146 opal/mca/event/libevent2022/libevent/http.c 		struct evhttp *http = evcon->http_server;
evcon            1147 opal/mca/event/libevent2022/libevent/http.c 		TAILQ_REMOVE(&http->connections, evcon, next);
evcon            1150 opal/mca/event/libevent2022/libevent/http.c 	if (event_initialized(&evcon->retry_ev)) {
evcon            1151 opal/mca/event/libevent2022/libevent/http.c 		event_del(&evcon->retry_ev);
evcon            1152 opal/mca/event/libevent2022/libevent/http.c 		event_debug_unassign(&evcon->retry_ev);
evcon            1155 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->bufev != NULL)
evcon            1156 opal/mca/event/libevent2022/libevent/http.c 		bufferevent_free(evcon->bufev);
evcon            1158 opal/mca/event/libevent2022/libevent/http.c 	event_deferred_cb_cancel(get_deferred_queue(evcon),
evcon            1159 opal/mca/event/libevent2022/libevent/http.c 	    &evcon->read_more_deferred_cb);
evcon            1161 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->fd != -1) {
evcon            1162 opal/mca/event/libevent2022/libevent/http.c 		shutdown(evcon->fd, EVUTIL_SHUT_WR);
evcon            1163 opal/mca/event/libevent2022/libevent/http.c 		evutil_closesocket(evcon->fd);
evcon            1166 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->bind_address != NULL)
evcon            1167 opal/mca/event/libevent2022/libevent/http.c 		mm_free(evcon->bind_address);
evcon            1169 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->address != NULL)
evcon            1170 opal/mca/event/libevent2022/libevent/http.c 		mm_free(evcon->address);
evcon            1172 opal/mca/event/libevent2022/libevent/http.c 	mm_free(evcon);
evcon            1176 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_set_local_address(struct evhttp_connection *evcon,
evcon            1179 opal/mca/event/libevent2022/libevent/http.c 	EVUTIL_ASSERT(evcon->state == EVCON_DISCONNECTED);
evcon            1180 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->bind_address)
evcon            1181 opal/mca/event/libevent2022/libevent/http.c 		mm_free(evcon->bind_address);
evcon            1182 opal/mca/event/libevent2022/libevent/http.c 	if ((evcon->bind_address = mm_strdup(address)) == NULL)
evcon            1187 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_set_local_port(struct evhttp_connection *evcon,
evcon            1190 opal/mca/event/libevent2022/libevent/http.c 	EVUTIL_ASSERT(evcon->state == EVCON_DISCONNECTED);
evcon            1191 opal/mca/event/libevent2022/libevent/http.c 	evcon->bind_port = port;
evcon            1195 opal/mca/event/libevent2022/libevent/http.c evhttp_request_dispatch(struct evhttp_connection* evcon)
evcon            1197 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_request *req = TAILQ_FIRST(&evcon->requests);
evcon            1204 opal/mca/event/libevent2022/libevent/http.c 	evhttp_connection_stop_detectclose(evcon);
evcon            1207 opal/mca/event/libevent2022/libevent/http.c 	EVUTIL_ASSERT(evcon->state == EVCON_IDLE);
evcon            1209 opal/mca/event/libevent2022/libevent/http.c 	evcon->state = EVCON_WRITING;
evcon            1212 opal/mca/event/libevent2022/libevent/http.c 	evhttp_make_header(evcon, req);
evcon            1214 opal/mca/event/libevent2022/libevent/http.c 	evhttp_write_buffer(evcon, evhttp_write_connectioncb, NULL);
evcon            1220 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_reset(struct evhttp_connection *evcon)
evcon            1235 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_disable_hard(evcon->bufev, EV_READ|EV_WRITE);
evcon            1237 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->fd != -1) {
evcon            1239 opal/mca/event/libevent2022/libevent/http.c 		if (evhttp_connected(evcon) && evcon->closecb != NULL)
evcon            1240 opal/mca/event/libevent2022/libevent/http.c 			(*evcon->closecb)(evcon, evcon->closecb_arg);
evcon            1242 opal/mca/event/libevent2022/libevent/http.c 		shutdown(evcon->fd, EVUTIL_SHUT_WR);
evcon            1243 opal/mca/event/libevent2022/libevent/http.c 		evutil_closesocket(evcon->fd);
evcon            1244 opal/mca/event/libevent2022/libevent/http.c 		evcon->fd = -1;
evcon            1248 opal/mca/event/libevent2022/libevent/http.c 	tmp = bufferevent_get_output(evcon->bufev);
evcon            1250 opal/mca/event/libevent2022/libevent/http.c 	tmp = bufferevent_get_input(evcon->bufev);
evcon            1253 opal/mca/event/libevent2022/libevent/http.c 	evcon->state = EVCON_DISCONNECTED;
evcon            1257 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_start_detectclose(struct evhttp_connection *evcon)
evcon            1259 opal/mca/event/libevent2022/libevent/http.c 	evcon->flags |= EVHTTP_CON_CLOSEDETECT;
evcon            1261 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_enable(evcon->bufev, EV_READ);
evcon            1265 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_stop_detectclose(struct evhttp_connection *evcon)
evcon            1267 opal/mca/event/libevent2022/libevent/http.c 	evcon->flags &= ~EVHTTP_CON_CLOSEDETECT;
evcon            1269 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_disable(evcon->bufev, EV_READ);
evcon            1275 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon = arg;
evcon            1277 opal/mca/event/libevent2022/libevent/http.c 	evcon->state = EVCON_DISCONNECTED;
evcon            1278 opal/mca/event/libevent2022/libevent/http.c 	evhttp_connection_connect(evcon);
evcon            1282 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_cb_cleanup(struct evhttp_connection *evcon)
evcon            1286 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->retry_max < 0 || evcon->retry_cnt < evcon->retry_max) {
evcon            1287 opal/mca/event/libevent2022/libevent/http.c 		evtimer_assign(&evcon->retry_ev, evcon->base, evhttp_connection_retry, evcon);
evcon            1289 opal/mca/event/libevent2022/libevent/http.c 		evhttp_add_event(&evcon->retry_ev,
evcon            1290 opal/mca/event/libevent2022/libevent/http.c 		    MIN(3600, 2 << evcon->retry_cnt),
evcon            1292 opal/mca/event/libevent2022/libevent/http.c 		evcon->retry_cnt++;
evcon            1295 opal/mca/event/libevent2022/libevent/http.c 	evhttp_connection_reset(evcon);
evcon            1304 opal/mca/event/libevent2022/libevent/http.c 	while (TAILQ_FIRST(&evcon->requests) != NULL) {
evcon            1305 opal/mca/event/libevent2022/libevent/http.c 		struct evhttp_request *request = TAILQ_FIRST(&evcon->requests);
evcon            1306 opal/mca/event/libevent2022/libevent/http.c 		TAILQ_REMOVE(&evcon->requests, request, next);
evcon            1314 opal/mca/event/libevent2022/libevent/http.c 		request->evcon = NULL;
evcon            1325 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon = arg;
evcon            1326 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_request *req = TAILQ_FIRST(&evcon->requests);
evcon            1328 opal/mca/event/libevent2022/libevent/http.c 	switch (evcon->state) {
evcon            1333 opal/mca/event/libevent2022/libevent/http.c 				__func__, evcon->address, evcon->port,
evcon            1334 opal/mca/event/libevent2022/libevent/http.c 				EV_SOCK_ARG(evcon->fd)));
evcon            1335 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_cb_cleanup(evcon);
evcon            1344 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_done(evcon);
evcon            1362 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->flags & EVHTTP_CON_CLOSEDETECT) {
evcon            1363 opal/mca/event/libevent2022/libevent/http.c 		evcon->flags &= ~EVHTTP_CON_CLOSEDETECT;
evcon            1364 opal/mca/event/libevent2022/libevent/http.c 		EVUTIL_ASSERT(evcon->http_server == NULL);
evcon            1369 opal/mca/event/libevent2022/libevent/http.c 		EVUTIL_ASSERT(evcon->state == EVCON_IDLE);
evcon            1370 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_reset(evcon);
evcon            1375 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_fail(evcon, EVCON_HTTP_TIMEOUT);
evcon            1377 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_fail(evcon, EVCON_HTTP_EOF);
evcon            1379 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_fail(evcon, EVCON_HTTP_BUFFER_ERROR);
evcon            1389 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon = arg;
evcon            1407 opal/mca/event/libevent2022/libevent/http.c 	if (getsockopt(evcon->fd, SOL_SOCKET, SO_ERROR, (void*)&error,
evcon            1410 opal/mca/event/libevent2022/libevent/http.c 			__func__, evcon->address, evcon->port,
evcon            1411 opal/mca/event/libevent2022/libevent/http.c 			EV_SOCK_ARG(evcon->fd)));
evcon            1418 opal/mca/event/libevent2022/libevent/http.c 			__func__, evcon->address, evcon->port,
evcon            1419 opal/mca/event/libevent2022/libevent/http.c 			EV_SOCK_ARG(evcon->fd),
evcon            1426 opal/mca/event/libevent2022/libevent/http.c 			__func__, evcon->address, evcon->port,
evcon            1427 opal/mca/event/libevent2022/libevent/http.c 			EV_SOCK_ARG(evcon->fd)));
evcon            1430 opal/mca/event/libevent2022/libevent/http.c 	evcon->retry_cnt = 0;
evcon            1431 opal/mca/event/libevent2022/libevent/http.c 	evcon->state = EVCON_IDLE;
evcon            1434 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_setcb(evcon->bufev,
evcon            1438 opal/mca/event/libevent2022/libevent/http.c 	    evcon);
evcon            1440 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->timeout == -1)
evcon            1441 opal/mca/event/libevent2022/libevent/http.c 		bufferevent_settimeout(evcon->bufev,
evcon            1445 opal/mca/event/libevent2022/libevent/http.c 		tv.tv_sec = evcon->timeout;
evcon            1447 opal/mca/event/libevent2022/libevent/http.c 		bufferevent_set_timeouts(evcon->bufev, &tv, &tv);
evcon            1451 opal/mca/event/libevent2022/libevent/http.c 	evhttp_request_dispatch(evcon);
evcon            1455 opal/mca/event/libevent2022/libevent/http.c 	evhttp_connection_cb_cleanup(evcon);
evcon            1589 opal/mca/event/libevent2022/libevent/http.c 	    !evhttp_find_vhost(req->evcon->http_server, NULL, hostname))
evcon            1731 opal/mca/event/libevent2022/libevent/http.c 		if (req->evcon != NULL &&
evcon            1732 opal/mca/event/libevent2022/libevent/http.c 		    evbuffer_get_length(buffer) > req->evcon->max_headers_size)
evcon            1738 opal/mca/event/libevent2022/libevent/http.c 	if (req->evcon != NULL &&
evcon            1739 opal/mca/event/libevent2022/libevent/http.c 	    line_length > req->evcon->max_headers_size) {
evcon            1801 opal/mca/event/libevent2022/libevent/http.c 		if (req->evcon != NULL &&
evcon            1802 opal/mca/event/libevent2022/libevent/http.c 		    req->headers_size > req->evcon->max_headers_size) {
evcon            1836 opal/mca/event/libevent2022/libevent/http.c 		if (req->evcon != NULL &&
evcon            1837 opal/mca/event/libevent2022/libevent/http.c 		req->headers_size + evbuffer_get_length(buffer) > req->evcon->max_headers_size)
evcon            1882 opal/mca/event/libevent2022/libevent/http.c 		EV_SIZE_ARG(evbuffer_get_length(bufferevent_get_input(req->evcon->bufev)))));
evcon            1910 opal/mca/event/libevent2022/libevent/http.c evhttp_get_body(struct evhttp_connection *evcon, struct evhttp_request *req)
evcon            1917 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_done(evcon);
evcon            1920 opal/mca/event/libevent2022/libevent/http.c 	evcon->state = EVCON_READING_BODY;
evcon            1927 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_fail(evcon,
evcon            1934 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_done(evcon);
evcon            1954 opal/mca/event/libevent2022/libevent/http.c 					if ((req->evcon->max_body_size <= EV_INT64_MAX) && (ev_uint64_t)req->ntoread > req->evcon->max_body_size) {
evcon            1959 opal/mca/event/libevent2022/libevent/http.c 				if (!evbuffer_get_length(bufferevent_get_input(evcon->bufev)))
evcon            1960 opal/mca/event/libevent2022/libevent/http.c 					evhttp_send_continue(evcon, req);
evcon            1969 opal/mca/event/libevent2022/libevent/http.c 	evhttp_read_body(evcon, req);
evcon            1974 opal/mca/event/libevent2022/libevent/http.c evhttp_read_firstline(struct evhttp_connection *evcon,
evcon            1979 opal/mca/event/libevent2022/libevent/http.c 	res = evhttp_parse_firstline(req, bufferevent_get_input(evcon->bufev));
evcon            1983 opal/mca/event/libevent2022/libevent/http.c 			__func__, EV_SOCK_ARG(evcon->fd)));
evcon            1984 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_fail(evcon, EVCON_HTTP_INVALID_HEADER);
evcon            1991 opal/mca/event/libevent2022/libevent/http.c 	evcon->state = EVCON_READING_HEADERS;
evcon            1992 opal/mca/event/libevent2022/libevent/http.c 	evhttp_read_header(evcon, req);
evcon            1996 opal/mca/event/libevent2022/libevent/http.c evhttp_read_header(struct evhttp_connection *evcon,
evcon            2000 opal/mca/event/libevent2022/libevent/http.c 	evutil_socket_t fd = evcon->fd;
evcon            2002 opal/mca/event/libevent2022/libevent/http.c 	res = evhttp_parse_headers(req, bufferevent_get_input(evcon->bufev));
evcon            2007 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_fail(evcon, EVCON_HTTP_INVALID_HEADER);
evcon            2015 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_disable(evcon->bufev, EV_READ);
evcon            2022 opal/mca/event/libevent2022/libevent/http.c 		evhttp_get_body(evcon, req);
evcon            2029 opal/mca/event/libevent2022/libevent/http.c 			evhttp_start_read(evcon);
evcon            2035 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_done(evcon);
evcon            2040 opal/mca/event/libevent2022/libevent/http.c 			evhttp_get_body(evcon, req);
evcon            2049 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_fail(evcon, EVCON_HTTP_INVALID_HEADER);
evcon            2075 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon = NULL;
evcon            2079 opal/mca/event/libevent2022/libevent/http.c 	if ((evcon = mm_calloc(1, sizeof(struct evhttp_connection))) == NULL) {
evcon            2084 opal/mca/event/libevent2022/libevent/http.c 	evcon->fd = -1;
evcon            2085 opal/mca/event/libevent2022/libevent/http.c 	evcon->port = port;
evcon            2087 opal/mca/event/libevent2022/libevent/http.c 	evcon->max_headers_size = EV_SIZE_MAX;
evcon            2088 opal/mca/event/libevent2022/libevent/http.c 	evcon->max_body_size = EV_SIZE_MAX;
evcon            2090 opal/mca/event/libevent2022/libevent/http.c 	evcon->timeout = -1;
evcon            2091 opal/mca/event/libevent2022/libevent/http.c 	evcon->retry_cnt = evcon->retry_max = 0;
evcon            2093 opal/mca/event/libevent2022/libevent/http.c 	if ((evcon->address = mm_strdup(address)) == NULL) {
evcon            2098 opal/mca/event/libevent2022/libevent/http.c 	if ((evcon->bufev = bufferevent_new(-1,
evcon            2101 opal/mca/event/libevent2022/libevent/http.c 		    evhttp_error_cb, evcon)) == NULL) {
evcon            2106 opal/mca/event/libevent2022/libevent/http.c 	evcon->state = EVCON_DISCONNECTED;
evcon            2107 opal/mca/event/libevent2022/libevent/http.c 	TAILQ_INIT(&evcon->requests);
evcon            2110 opal/mca/event/libevent2022/libevent/http.c 		evcon->base = base;
evcon            2111 opal/mca/event/libevent2022/libevent/http.c 		bufferevent_base_set(base, evcon->bufev);
evcon            2115 opal/mca/event/libevent2022/libevent/http.c 	event_deferred_cb_init(&evcon->read_more_deferred_cb,
evcon            2116 opal/mca/event/libevent2022/libevent/http.c 	    evhttp_deferred_read_cb, evcon);
evcon            2118 opal/mca/event/libevent2022/libevent/http.c 	evcon->dns_base = dnsbase;
evcon            2120 opal/mca/event/libevent2022/libevent/http.c 	return (evcon);
evcon            2123 opal/mca/event/libevent2022/libevent/http.c 	if (evcon != NULL)
evcon            2124 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_free(evcon);
evcon            2129 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_get_bufferevent(struct evhttp_connection *evcon)
evcon            2131 opal/mca/event/libevent2022/libevent/http.c 	return evcon->bufev;
evcon            2135 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_set_base(struct evhttp_connection *evcon,
evcon            2138 opal/mca/event/libevent2022/libevent/http.c 	EVUTIL_ASSERT(evcon->base == NULL);
evcon            2139 opal/mca/event/libevent2022/libevent/http.c 	EVUTIL_ASSERT(evcon->state == EVCON_DISCONNECTED);
evcon            2140 opal/mca/event/libevent2022/libevent/http.c 	evcon->base = base;
evcon            2141 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_base_set(base, evcon->bufev);
evcon            2145 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_set_timeout(struct evhttp_connection *evcon,
evcon            2148 opal/mca/event/libevent2022/libevent/http.c 	evcon->timeout = timeout_in_secs;
evcon            2150 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->timeout == -1)
evcon            2151 opal/mca/event/libevent2022/libevent/http.c 		bufferevent_settimeout(evcon->bufev,
evcon            2154 opal/mca/event/libevent2022/libevent/http.c 		bufferevent_settimeout(evcon->bufev,
evcon            2155 opal/mca/event/libevent2022/libevent/http.c 		    evcon->timeout, evcon->timeout);
evcon            2159 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_set_retries(struct evhttp_connection *evcon,
evcon            2162 opal/mca/event/libevent2022/libevent/http.c 	evcon->retry_max = retry_max;
evcon            2166 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_set_closecb(struct evhttp_connection *evcon,
evcon            2169 opal/mca/event/libevent2022/libevent/http.c 	evcon->closecb = cb;
evcon            2170 opal/mca/event/libevent2022/libevent/http.c 	evcon->closecb_arg = cbarg;
evcon            2174 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_get_peer(struct evhttp_connection *evcon,
evcon            2177 opal/mca/event/libevent2022/libevent/http.c 	*address = evcon->address;
evcon            2178 opal/mca/event/libevent2022/libevent/http.c 	*port = evcon->port;
evcon            2182 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_connect(struct evhttp_connection *evcon)
evcon            2184 opal/mca/event/libevent2022/libevent/http.c 	int old_state = evcon->state;
evcon            2186 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->state == EVCON_CONNECTING)
evcon            2189 opal/mca/event/libevent2022/libevent/http.c 	evhttp_connection_reset(evcon);
evcon            2191 opal/mca/event/libevent2022/libevent/http.c 	EVUTIL_ASSERT(!(evcon->flags & EVHTTP_CON_INCOMING));
evcon            2192 opal/mca/event/libevent2022/libevent/http.c 	evcon->flags |= EVHTTP_CON_OUTGOING;
evcon            2194 opal/mca/event/libevent2022/libevent/http.c 	evcon->fd = bind_socket(
evcon            2195 opal/mca/event/libevent2022/libevent/http.c 		evcon->bind_address, evcon->bind_port, 0 /*reuse*/);
evcon            2196 opal/mca/event/libevent2022/libevent/http.c 	if (evcon->fd == -1) {
evcon            2198 opal/mca/event/libevent2022/libevent/http.c 			__func__, evcon->bind_address));
evcon            2203 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_setfd(evcon->bufev, evcon->fd);
evcon            2204 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_setcb(evcon->bufev,
evcon            2208 opal/mca/event/libevent2022/libevent/http.c 	    evcon);
evcon            2209 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_settimeout(evcon->bufev, 0,
evcon            2210 opal/mca/event/libevent2022/libevent/http.c 	    evcon->timeout != -1 ? evcon->timeout : HTTP_CONNECT_TIMEOUT);
evcon            2212 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_enable(evcon->bufev, EV_WRITE);
evcon            2214 opal/mca/event/libevent2022/libevent/http.c 	evcon->state = EVCON_CONNECTING;
evcon            2216 opal/mca/event/libevent2022/libevent/http.c 	if (bufferevent_socket_connect_hostname(evcon->bufev, evcon->dns_base,
evcon            2217 opal/mca/event/libevent2022/libevent/http.c 		AF_UNSPEC, evcon->address, evcon->port) < 0) {
evcon            2218 opal/mca/event/libevent2022/libevent/http.c 		evcon->state = old_state;
evcon            2219 opal/mca/event/libevent2022/libevent/http.c 		event_sock_warn(evcon->fd, "%s: connection to \"%s\" failed",
evcon            2220 opal/mca/event/libevent2022/libevent/http.c 		    __func__, evcon->address);
evcon            2225 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_cb_cleanup(evcon);
evcon            2239 opal/mca/event/libevent2022/libevent/http.c evhttp_make_request(struct evhttp_connection *evcon,
evcon            2260 opal/mca/event/libevent2022/libevent/http.c 	EVUTIL_ASSERT(req->evcon == NULL);
evcon            2261 opal/mca/event/libevent2022/libevent/http.c 	req->evcon = evcon;
evcon            2264 opal/mca/event/libevent2022/libevent/http.c        TAILQ_INSERT_TAIL(&evcon->requests, req, next);
evcon            2267 opal/mca/event/libevent2022/libevent/http.c 	if (!evhttp_connected(evcon)) {
evcon            2268 opal/mca/event/libevent2022/libevent/http.c 		int res = evhttp_connection_connect(evcon);
evcon            2274 opal/mca/event/libevent2022/libevent/http.c 		       TAILQ_REMOVE(&evcon->requests, req, next);
evcon            2284 opal/mca/event/libevent2022/libevent/http.c 	if (TAILQ_FIRST(&evcon->requests) == req)
evcon            2285 opal/mca/event/libevent2022/libevent/http.c 		evhttp_request_dispatch(evcon);
evcon            2293 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon = req->evcon;
evcon            2294 opal/mca/event/libevent2022/libevent/http.c 	if (evcon != NULL) {
evcon            2296 opal/mca/event/libevent2022/libevent/http.c 		if (TAILQ_FIRST(&evcon->requests) == req) {
evcon            2300 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_fail(evcon,
evcon            2309 opal/mca/event/libevent2022/libevent/http.c 			TAILQ_REMOVE(&evcon->requests, req, next);
evcon            2322 opal/mca/event/libevent2022/libevent/http.c evhttp_start_read(struct evhttp_connection *evcon)
evcon            2325 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_disable(evcon->bufev, EV_WRITE);
evcon            2326 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_enable(evcon->bufev, EV_READ);
evcon            2327 opal/mca/event/libevent2022/libevent/http.c 	evcon->state = EVCON_READING_FIRSTLINE;
evcon            2329 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_setcb(evcon->bufev,
evcon            2333 opal/mca/event/libevent2022/libevent/http.c 	    evcon);
evcon            2337 opal/mca/event/libevent2022/libevent/http.c 	if (evbuffer_get_length(bufferevent_get_input(evcon->bufev))) {
evcon            2338 opal/mca/event/libevent2022/libevent/http.c 		event_deferred_cb_schedule(get_deferred_queue(evcon),
evcon            2339 opal/mca/event/libevent2022/libevent/http.c 		    &evcon->read_more_deferred_cb);
evcon            2344 opal/mca/event/libevent2022/libevent/http.c evhttp_send_done(struct evhttp_connection *evcon, void *arg)
evcon            2347 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_request *req = TAILQ_FIRST(&evcon->requests);
evcon            2348 opal/mca/event/libevent2022/libevent/http.c 	TAILQ_REMOVE(&evcon->requests, req, next);
evcon            2360 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_free(evcon);
evcon            2365 opal/mca/event/libevent2022/libevent/http.c 	if (evhttp_associate_new_request_with_connection(evcon) == -1) {
evcon            2366 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_free(evcon);
evcon            2387 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_free(req->evcon);
evcon            2409 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon = req->evcon;
evcon            2411 opal/mca/event/libevent2022/libevent/http.c 	if (evcon == NULL) {
evcon            2416 opal/mca/event/libevent2022/libevent/http.c 	EVUTIL_ASSERT(TAILQ_FIRST(&evcon->requests) == req);
evcon            2426 opal/mca/event/libevent2022/libevent/http.c 	evhttp_make_header(evcon, req);
evcon            2428 opal/mca/event/libevent2022/libevent/http.c 	evhttp_write_buffer(evcon, evhttp_send_done, NULL);
evcon            2459 opal/mca/event/libevent2022/libevent/http.c 	evhttp_make_header(req->evcon, req);
evcon            2460 opal/mca/event/libevent2022/libevent/http.c 	evhttp_write_buffer(req->evcon, NULL, NULL);
evcon            2466 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon = req->evcon;
evcon            2469 opal/mca/event/libevent2022/libevent/http.c 	if (evcon == NULL)
evcon            2472 opal/mca/event/libevent2022/libevent/http.c 	output = bufferevent_get_output(evcon->bufev);
evcon            2486 opal/mca/event/libevent2022/libevent/http.c 	evhttp_write_buffer(evcon, NULL, NULL);
evcon            2492 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon = req->evcon;
evcon            2495 opal/mca/event/libevent2022/libevent/http.c 	if (evcon == NULL) {
evcon            2500 opal/mca/event/libevent2022/libevent/http.c 	output = bufferevent_get_output(evcon->bufev);
evcon            2507 opal/mca/event/libevent2022/libevent/http.c 		evhttp_write_buffer(req->evcon, evhttp_send_done, NULL);
evcon            2511 opal/mca/event/libevent2022/libevent/http.c 		evhttp_send_done(evcon, NULL);
evcon            2514 opal/mca/event/libevent2022/libevent/http.c 		evcon->cb = evhttp_send_done;
evcon            2515 opal/mca/event/libevent2022/libevent/http.c 		evcon->cb_arg = NULL;
evcon            3054 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_free(req->evcon);
evcon            3060 opal/mca/event/libevent2022/libevent/http.c 			evhttp_connection_free(req->evcon);
evcon            3258 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon;
evcon            3272 opal/mca/event/libevent2022/libevent/http.c 	while ((evcon = TAILQ_FIRST(&http->connections)) != NULL) {
evcon            3274 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_free(evcon);
evcon            3560 opal/mca/event/libevent2022/libevent/http.c 	return req->evcon;
evcon            3679 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon;
evcon            3693 opal/mca/event/libevent2022/libevent/http.c 	evcon = evhttp_connection_base_new(
evcon            3697 opal/mca/event/libevent2022/libevent/http.c 	if (evcon == NULL)
evcon            3700 opal/mca/event/libevent2022/libevent/http.c 	evcon->max_headers_size = http->default_max_headers_size;
evcon            3701 opal/mca/event/libevent2022/libevent/http.c 	evcon->max_body_size = http->default_max_body_size;
evcon            3703 opal/mca/event/libevent2022/libevent/http.c 	evcon->flags |= EVHTTP_CON_INCOMING;
evcon            3704 opal/mca/event/libevent2022/libevent/http.c 	evcon->state = EVCON_READING_FIRSTLINE;
evcon            3706 opal/mca/event/libevent2022/libevent/http.c 	evcon->fd = fd;
evcon            3708 opal/mca/event/libevent2022/libevent/http.c 	bufferevent_setfd(evcon->bufev, fd);
evcon            3710 opal/mca/event/libevent2022/libevent/http.c 	return (evcon);
evcon            3714 opal/mca/event/libevent2022/libevent/http.c evhttp_associate_new_request_with_connection(struct evhttp_connection *evcon)
evcon            3716 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp *http = evcon->http_server;
evcon            3721 opal/mca/event/libevent2022/libevent/http.c 	if ((req->remote_host = mm_strdup(evcon->address)) == NULL) {
evcon            3726 opal/mca/event/libevent2022/libevent/http.c 	req->remote_port = evcon->port;
evcon            3728 opal/mca/event/libevent2022/libevent/http.c 	req->evcon = evcon;	/* the request ends up owning the connection */
evcon            3738 opal/mca/event/libevent2022/libevent/http.c 	TAILQ_INSERT_TAIL(&evcon->requests, req, next);
evcon            3743 opal/mca/event/libevent2022/libevent/http.c 	evhttp_start_read(evcon);
evcon            3752 opal/mca/event/libevent2022/libevent/http.c 	struct evhttp_connection *evcon;
evcon            3754 opal/mca/event/libevent2022/libevent/http.c 	evcon = evhttp_get_request_connection(http, fd, sa, salen);
evcon            3755 opal/mca/event/libevent2022/libevent/http.c 	if (evcon == NULL) {
evcon            3764 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_set_timeout(evcon, http->timeout);
evcon            3770 opal/mca/event/libevent2022/libevent/http.c 	evcon->http_server = http;
evcon            3771 opal/mca/event/libevent2022/libevent/http.c 	TAILQ_INSERT_TAIL(&http->connections, evcon, next);
evcon            3773 opal/mca/event/libevent2022/libevent/http.c 	if (evhttp_associate_new_request_with_connection(evcon) == -1)
evcon            3774 opal/mca/event/libevent2022/libevent/http.c 		evhttp_connection_free(evcon);
evcon             435 opal/mca/event/libevent2022/libevent/include/event2/http.h 	struct evhttp_connection *evcon);
evcon             460 opal/mca/event/libevent2022/libevent/include/event2/http.h void evhttp_connection_set_max_headers_size(struct evhttp_connection *evcon,
evcon             463 opal/mca/event/libevent2022/libevent/include/event2/http.h void evhttp_connection_set_max_body_size(struct evhttp_connection* evcon,
evcon             467 opal/mca/event/libevent2022/libevent/include/event2/http.h void evhttp_connection_free(struct evhttp_connection *evcon);
evcon             470 opal/mca/event/libevent2022/libevent/include/event2/http.h void evhttp_connection_set_local_address(struct evhttp_connection *evcon,
evcon             474 opal/mca/event/libevent2022/libevent/include/event2/http.h void evhttp_connection_set_local_port(struct evhttp_connection *evcon,
evcon             478 opal/mca/event/libevent2022/libevent/include/event2/http.h void evhttp_connection_set_timeout(struct evhttp_connection *evcon,
evcon             482 opal/mca/event/libevent2022/libevent/include/event2/http.h void evhttp_connection_set_retries(struct evhttp_connection *evcon,
evcon             486 opal/mca/event/libevent2022/libevent/include/event2/http.h void evhttp_connection_set_closecb(struct evhttp_connection *evcon,
evcon             490 opal/mca/event/libevent2022/libevent/include/event2/http.h void evhttp_connection_get_peer(struct evhttp_connection *evcon,
evcon             506 opal/mca/event/libevent2022/libevent/include/event2/http.h int evhttp_make_request(struct evhttp_connection *evcon,
evcon              79 opal/mca/event/libevent2022/libevent/include/event2/http_compat.h void evhttp_connection_set_base(struct evhttp_connection *evcon,
evcon              68 opal/mca/event/libevent2022/libevent/include/event2/http_struct.h 	struct evhttp_connection *evcon;
evcon             417 opal/mca/event/libevent2022/libevent/include/event2/rpc.h     struct evhttp_connection *evcon);
evcon             428 opal/mca/event/libevent2022/libevent/include/event2/rpc.h     struct evhttp_connection *evcon);
evcon             829 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon             836 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL, "127.0.0.1", port);
evcon             837 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon             839 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evhttp_connection_get_base(evcon) == data->base);
evcon             853 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) {
evcon             878 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) {
evcon             893 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) {
evcon             900 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evcon)
evcon             901 opal/mca/event/libevent2022/libevent/test/regress_http.c 		evhttp_connection_free(evcon);
evcon             927 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon             948 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, dns_base, "127.0.0.1", port);
evcon             949 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon             962 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) {
evcon             986 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) {
evcon            1001 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) {
evcon            1008 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evcon)
evcon            1009 opal/mca/event/libevent2022/libevent/test/regress_http.c 		evhttp_connection_free(evcon);
evcon            1047 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon            1057 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL, "127.0.0.1", port);
evcon            1058 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            1071 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_int_op(evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/delay"),
evcon            1093 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_int_op(evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test"),
evcon            1107 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_int_op(evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test"),
evcon            1113 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evcon)
evcon            1114 opal/mca/event/libevent2022/libevent/test/regress_http.c 		evhttp_connection_free(evcon);
evcon            1168 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon            1197 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL, "127.0.0.1", port);
evcon            1198 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            1207 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET,
evcon            1225 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET,
evcon            1244 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET,
evcon            1262 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET,
evcon            1280 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET,
evcon            1316 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evcon)
evcon            1317 opal/mca/event/libevent2022/libevent/test/regress_http.c 		evhttp_connection_free(evcon);
evcon            1413 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon            1420 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL, "127.0.0.1", port);
evcon            1421 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            1424 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evhttp_connection_set_local_address(evcon, "127.0.0.1");
evcon            1437 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/?arg=val") == -1) {
evcon            1444 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evcon)
evcon            1445 opal/mca/event/libevent2022/libevent/test/regress_http.c 		evhttp_connection_free(evcon);
evcon            1463 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon            1470 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL, "127.0.0.1", port);
evcon            1471 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            1485 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_POST, "/postit") == -1) {
evcon            1505 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_POST, "/postit") == -1) {
evcon            1513 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evhttp_connection_free(evcon);
evcon            1603 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon            1610 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL, "127.0.0.1", port);
evcon            1611 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            1624 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_PUT, "/putit") == -1) {
evcon            1630 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evhttp_connection_free(evcon);
evcon            1777 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = arg;
evcon            1778 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct event_base *base = evhttp_connection_get_base(evcon);
evcon            1787 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) {
evcon            1795 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = arg;
evcon            1796 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct event_base *base = evhttp_connection_get_base(evcon);
evcon            1807 opal/mca/event/libevent2022/libevent/test/regress_http.c 	event_base_once(base, -1, EV_TIMEOUT, close_detect_launch, evcon, &tv);
evcon            1817 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon            1826 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL,
evcon            1828 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            1829 opal/mca/event/libevent2022/libevent/test/regress_http.c 	delayed_client = evcon;
evcon            1836 opal/mca/event/libevent2022/libevent/test/regress_http.c 	req = evhttp_request_new(close_detect_cb, evcon);
evcon            1842 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon,
evcon            1853 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evcon)
evcon            1854 opal/mca/event/libevent2022/libevent/test/regress_http.c 		evhttp_connection_free(evcon);
evcon            2773 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon            2812 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL, "127.0.0.1", port);
evcon            2813 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            2824 opal/mca/event/libevent2022/libevent/test/regress_http.c 		if (evhttp_make_request(evcon, req,
evcon            2835 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evcon)
evcon            2836 opal/mca/event/libevent2022/libevent/test/regress_http.c 		evhttp_connection_free(evcon);
evcon            2846 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon            2854 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL, "127.0.0.1", port);
evcon            2855 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            2869 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/streamed")
evcon            2877 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evcon)
evcon            2878 opal/mca/event/libevent2022/libevent/test/regress_http.c 		evhttp_connection_free(evcon);
evcon            2914 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon;
evcon            2922 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL,"127.0.0.1", port);
evcon            2923 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            2929 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, url) == -1) {
evcon            2950 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evcon)
evcon            2951 opal/mca/event/libevent2022/libevent/test/regress_http.c 		evhttp_connection_free(evcon);
evcon            2987 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon;
evcon            2993 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL, "127.0.0.1", port);
evcon            2994 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            3000 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/chunked") == -1) {
evcon            3008 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evhttp_connection_free(evcon);
evcon            3016 opal/mca/event/libevent2022/libevent/test/regress_http.c        struct evhttp_connection *evcon = arg;
evcon            3017 opal/mca/event/libevent2022/libevent/test/regress_http.c        struct event_base *base = evhttp_connection_get_base(evcon);
evcon            3025 opal/mca/event/libevent2022/libevent/test/regress_http.c        evhttp_connection_free(evcon);
evcon            3040 opal/mca/event/libevent2022/libevent/test/regress_http.c        struct evhttp_connection *evcon = NULL;
evcon            3053 opal/mca/event/libevent2022/libevent/test/regress_http.c        evcon = evhttp_connection_base_new(data->base, NULL, "239.10.20.30", 80);
evcon            3054 opal/mca/event/libevent2022/libevent/test/regress_http.c        tt_assert(evcon);
evcon            3061 opal/mca/event/libevent2022/libevent/test/regress_http.c        req = evhttp_request_new(http_connection_fail_done, evcon);
evcon            3064 opal/mca/event/libevent2022/libevent/test/regress_http.c        if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/") == -1) {
evcon            3105 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon            3117 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL, "127.0.0.1", port);
evcon            3118 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            3120 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evhttp_connection_set_timeout(evcon, 1);
evcon            3122 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evhttp_connection_set_local_address(evcon, "127.0.0.1");
evcon            3135 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET,
evcon            3153 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evhttp_connection_set_timeout(evcon, 1);
evcon            3154 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evhttp_connection_set_retries(evcon, 1);
evcon            3162 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET,
evcon            3182 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evhttp_connection_set_timeout(evcon, 1);
evcon            3183 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evhttp_connection_set_retries(evcon, 3);
evcon            3191 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET,
evcon            3216 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evcon)
evcon            3217 opal/mca/event/libevent2022/libevent/test/regress_http.c 		evhttp_connection_free(evcon);
evcon            3313 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon            3320 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL, "127.0.0.1", port);
evcon            3321 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            3334 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) {
evcon            3341 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evcon)
evcon            3342 opal/mca/event/libevent2022/libevent/test/regress_http.c 		evhttp_connection_free(evcon);
evcon            3371 opal/mca/event/libevent2022/libevent/test/regress_http.c 	struct evhttp_connection *evcon = NULL;
evcon            3379 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evcon = evhttp_connection_base_new(data->base, NULL, "127.0.0.1", port);
evcon            3380 opal/mca/event/libevent2022/libevent/test/regress_http.c 	tt_assert(evcon);
evcon            3383 opal/mca/event/libevent2022/libevent/test/regress_http.c 	evhttp_connection_set_local_address(evcon, "127.0.0.1");
evcon            3400 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/?arg=val") == -1) {
evcon            3410 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, long_str) == -1) {
evcon            3419 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_POST, "/") == -1) {
evcon            3428 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evhttp_make_request(evcon, req, EVHTTP_REQ_POST, "/") == -1) {
evcon            3435 opal/mca/event/libevent2022/libevent/test/regress_http.c 	if (evcon)
evcon            3436 opal/mca/event/libevent2022/libevent/test/regress_http.c 		evhttp_connection_free(evcon);
evcon            3480 opal/mca/event/libevent2022/libevent/test/regress_http.c terminate_chunked_close_cb(struct evhttp_connection *evcon, void *arg)
evcon             190 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	struct evhttp_connection *evcon = NULL;
evcon             195 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	evcon = evhttp_connection_new("127.0.0.1", port);
evcon             196 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	tt_assert(evcon);
evcon             210 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	if (evhttp_make_request(evcon, req,
evcon             220 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	evhttp_connection_free(evcon);
evcon             259 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	struct evhttp_connection *evcon = NULL;
evcon             265 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	evcon = evhttp_connection_new("127.0.0.1", port);
evcon             266 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	tt_assert(evcon);
evcon             289 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	if (evhttp_make_request(evcon, req,
evcon             300 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	evhttp_connection_free(evcon);
evcon             311 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	struct evhttp_connection *evcon;
evcon             317 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	evcon = evhttp_connection_new("127.0.0.1", port);
evcon             318 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	assert(evcon != NULL);
evcon             320 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	evrpc_pool_add_connection(pool, evcon);
evcon            1424 opal/mca/pmix/ext2x/ext2x.c                    evcon, evdes);
evcon            1743 opal/mca/pmix/ext3x/ext3x.c                    evcon, evdes);
evcon            1411 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c                     evcon, evdes);
evcon            1730 opal/mca/pmix/pmix4x/pmix4x.c                    evcon, evdes);