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);