connection 506 opal/mca/event/libevent2022/libevent/evrpc.c static int evrpc_schedule_request(struct evhttp_connection *connection, connection 542 opal/mca/event/libevent2022/libevent/evrpc.c struct evhttp_connection *connection; connection 558 opal/mca/event/libevent2022/libevent/evrpc.c while ((connection = TAILQ_FIRST(&pool->connections)) != NULL) { connection 559 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_REMOVE(&pool->connections, connection, next); connection 560 opal/mca/event/libevent2022/libevent/evrpc.c evhttp_connection_free(connection); connection 583 opal/mca/event/libevent2022/libevent/evrpc.c struct evhttp_connection *connection) connection 585 opal/mca/event/libevent2022/libevent/evrpc.c EVUTIL_ASSERT(connection->http_server == NULL); connection 586 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_INSERT_TAIL(&pool->connections, connection, next); connection 592 opal/mca/event/libevent2022/libevent/evrpc.c evhttp_connection_set_base(connection, pool->base); connection 598 opal/mca/event/libevent2022/libevent/evrpc.c if (connection->timeout == -1) connection 599 opal/mca/event/libevent2022/libevent/evrpc.c connection->timeout = pool->timeout; connection 610 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_schedule_request(connection, request); connection 616 opal/mca/event/libevent2022/libevent/evrpc.c struct evhttp_connection *connection) connection 618 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_REMOVE(&pool->connections, connection, next); connection 642 opal/mca/event/libevent2022/libevent/evrpc.c struct evhttp_connection *connection; connection 643 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_FOREACH(connection, &pool->connections, next) { connection 644 opal/mca/event/libevent2022/libevent/evrpc.c if (TAILQ_FIRST(&connection->requests) == NULL) connection 645 opal/mca/event/libevent2022/libevent/evrpc.c return (connection); connection 661 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_schedule_request(struct evhttp_connection *connection, connection 675 opal/mca/event/libevent2022/libevent/evrpc.c ctx->evcon = connection; connection 683 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_hook_associate_meta(&ctx->hook_meta, connection); connection 723 opal/mca/event/libevent2022/libevent/evrpc.c struct evhttp_connection *connection = ctx->evcon; connection 748 opal/mca/event/libevent2022/libevent/evrpc.c res = evhttp_make_request(connection, req, EVHTTP_REQ_POST, uri); connection 476 opal/mca/event/libevent2022/libevent/http.c const char *connection = evhttp_find_header(headers, "Proxy-Connection"); connection 477 opal/mca/event/libevent2022/libevent/http.c return (connection == NULL || evutil_ascii_strcasecmp(connection, "keep-alive") != 0); connection 479 opal/mca/event/libevent2022/libevent/http.c const char *connection = evhttp_find_header(headers, "Connection"); connection 480 opal/mca/event/libevent2022/libevent/http.c return (connection != NULL && evutil_ascii_strcasecmp(connection, "close") == 0); connection 488 opal/mca/event/libevent2022/libevent/http.c const char *connection = evhttp_find_header(headers, "Connection"); connection 489 opal/mca/event/libevent2022/libevent/http.c return (connection != NULL connection 490 opal/mca/event/libevent2022/libevent/http.c && evutil_ascii_strncasecmp(connection, "keep-alive", 10) == 0); connection 1853 opal/mca/event/libevent2022/libevent/http.c const char *connection; connection 1856 opal/mca/event/libevent2022/libevent/http.c connection = evhttp_find_header(headers, "Connection"); connection 1858 opal/mca/event/libevent2022/libevent/http.c if (content_length == NULL && connection == NULL) connection 1861 opal/mca/event/libevent2022/libevent/http.c evutil_ascii_strcasecmp(connection, "Close") != 0) { connection 1865 opal/mca/event/libevent2022/libevent/http.c __func__, connection); connection 3599 opal/mca/event/libevent2022/libevent/test/regress_http.c HTTP(connection), connection 862 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c memset(&mca_ptl_tcp_component.connection, 0, sizeof(struct sockaddr_storage)); connection 882 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c in = (struct sockaddr_in*)&mca_ptl_tcp_component.connection; connection 916 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c in6 = (struct sockaddr_in6*)&mca_ptl_tcp_component.connection; connection 931 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_connect(&mca_ptl_tcp_component.connection, len, sd))) { connection 48 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.h struct sockaddr_storage connection; connection 251 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c memset(&mca_ptl_tcp_component.connection, 0, sizeof(mca_ptl_tcp_component.connection)); connection 537 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c (struct sockaddr*)&mca_ptl_tcp_component.connection, connection 545 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (AF_INET == mca_ptl_tcp_component.connection.ss_family) { connection 546 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c ((struct sockaddr_in*) &mca_ptl_tcp_component.connection)->sin_port = htons(mca_ptl_tcp_component.ipv4_port); connection 550 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c } else if (AF_INET6 == mca_ptl_tcp_component.connection.ss_family) { connection 551 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c ((struct sockaddr_in6*) &mca_ptl_tcp_component.connection)->sin6_port = htons(mca_ptl_tcp_component.ipv6_port); connection 565 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c lt->socket = socket(mca_ptl_tcp_component.connection.ss_family, SOCK_STREAM, 0); connection 587 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (bind(lt->socket, (struct sockaddr*)&mca_ptl_tcp_component.connection, sizeof(struct sockaddr)) < 0) { connection 594 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (getsockname(lt->socket, (struct sockaddr*)&mca_ptl_tcp_component.connection, &addrlen) < 0) { connection 622 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (AF_INET == mca_ptl_tcp_component.connection.ss_family) { connection 624 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c myport = ntohs(((struct sockaddr_in*) &mca_ptl_tcp_component.connection)->sin_port); connection 625 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c inet_ntop(AF_INET, &((struct sockaddr_in*) &mca_ptl_tcp_component.connection)->sin_addr, connection 627 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c } else if (AF_INET6 == mca_ptl_tcp_component.connection.ss_family) { connection 629 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c myport = ntohs(((struct sockaddr_in6*) &mca_ptl_tcp_component.connection)->sin6_port); connection 630 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c inet_ntop(AF_INET6, &((struct sockaddr_in6*) &mca_ptl_tcp_component.connection)->sin6_addr, connection 164 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c memset(&mca_ptl_usock_component.connection, 0, sizeof(struct sockaddr_storage)); connection 165 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c address = (struct sockaddr_un*)&mca_ptl_usock_component.connection; connection 179 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_connect(&mca_ptl_usock_component.connection, len, &sd))) { connection 30 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.h struct sockaddr_storage connection; connection 113 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c memset(&mca_ptl_usock_component.connection, 0, sizeof(mca_ptl_usock_component.connection)); connection 208 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c address = (struct sockaddr_un*)&mca_ptl_usock_component.connection;