/httpd/modules/proxy/ |
H A D | ajp_link.c | 21 apr_status_t ajp_ilink_send(apr_socket_t *sock, ajp_msg_t *msg) argument 35 status = apr_socket_send(sock, buf, &written); 49 static apr_status_t ilink_read(apr_socket_t *sock, apr_byte_t *buf, argument 58 status = apr_socket_recv(sock, (char *)(buf + rdlen), &length); 74 apr_status_t ajp_ilink_receive(apr_socket_t *sock, ajp_msg_t *msg) argument 82 status = ilink_read(sock, msg->buf, hlen); 98 status = ilink_read(sock, msg->buf + hlen, blen);
|
H A D | ajp_utils.c | 24 apr_status_t ajp_handle_cping_cpong(apr_socket_t *sock, argument 50 rc = ajp_ilink_send(sock, msg); 58 rc = apr_socket_timeout_get(sock, &org); 66 rc = apr_socket_timeout_set(sock, timeout); 75 rv = ajp_ilink_receive(sock, msg); 99 rc = apr_socket_timeout_set(sock, org);
|
H A D | ajp.h | 394 * @param sock backend socket 398 apr_status_t ajp_ilink_send(apr_socket_t *sock, ajp_msg_t *msg); 403 * @param sock backend socket 407 apr_status_t ajp_ilink_receive(apr_socket_t *sock, ajp_msg_t *msg); 411 * @param sock backend socket 417 apr_status_t ajp_send_header(apr_socket_t *sock, request_rec *r, 423 * @param sock backend socket 429 apr_status_t ajp_read_header(apr_socket_t *sock, 447 * @param sock backend socket 452 apr_status_t ajp_send_data_msg(apr_socket_t *sock, [all...] |
H A D | mod_proxy_connect.c | 203 apr_socket_t *sock; local 297 failed = ap_proxy_connect_to_backend(&sock, "CONNECT", nexthop, 314 apr_socket_close(sock); 329 pollfd.desc.s = sock; 338 backconn = ap_run_create_connection(c->pool, r->server, sock, 345 apr_socket_close(sock); 349 rc = ap_run_pre_connection(backconn, sock); 423 apr_socket_close(sock); 435 if (cur->desc.s == sock) { 440 "sock wa [all...] |
H A D | mod_proxy_wstunnel.c | 49 apr_socket_t *sock = conn->sock; local 87 if (cur->desc.s == sock) { 91 "sock was readable"); 92 done |= proxy_wstunnel_transfer(r, backconn, c, bb, "sock", 341 apr_socket_t *sock = conn->sock; local 384 apr_socket_opt_set(sock, APR_SO_NONBLOCK, 1); 385 apr_socket_opt_set(sock, APR_SO_KEEPALIVE, 1); 393 pollfd.desc.s = sock; [all...] |
H A D | mod_proxy_ajp.c | 210 status = ajp_send_header(conn->sock, r, maxsize, uri); 289 status = ajp_send_data_msg(conn->sock, msg, bufsiz); 329 status = ajp_read_header(conn->sock, r, maxsize, 373 conn_poll->desc.s = conn->sock; 418 status = ajp_send_data_msg(conn->sock, msg, bufsiz); 590 status = ajp_read_header(conn->sock, r, maxsize, 790 if (!ap_proxy_is_socket_connected(backend->sock)) { 801 status = ajp_handle_cping_cpong(backend->sock, r,
|
H A D | mod_proxy_fdpass.c | 132 apr_socket_t *sock; local 142 rv = get_socket_from_path(r->pool, url, &sock); 172 rv = send_socket(r->pool, sock, clientsock);
|
H A D | ajp_header.c | 668 apr_status_t ajp_send_header(apr_socket_t *sock, argument 690 rc = ajp_ilink_send(sock, msg); 704 apr_status_t ajp_read_header(apr_socket_t *sock, argument 729 rc = ajp_ilink_receive(sock, *msg); 871 apr_status_t ajp_send_data_msg(apr_socket_t *sock, argument 880 return ajp_ilink_send(sock, msg);
|
H A D | mod_proxy_scgi.c | 85 apr_socket_t *sock; member in struct:__anon301 98 apr_socket_t *p = data->sock; 236 if ((rv = apr_socket_send(conn->sock, buf, &written)) != APR_SUCCESS) { 371 sock_data->sock = conn->sock;
|
H A D | proxy_util.c | 1407 conn->sock = NULL; 1427 if (conn->sock && conn->connection) { 1666 * require format: unix:/path/foo/bar.sock|http://ignored/path2/ 1667 * This results in talking http to the socket at /path/foo/bar.sock 2466 (!conn->ssl_hostname && ssl_hostname && conn->sock)) { 2532 apr_socket_timeout_get(sock, ¤t_timeout); 2534 apr_socket_timeout_set(sock, 0); 2535 socket_status = apr_socket_recv(sock, test_buffer, &buffer_len); 2537 apr_socket_timeout_set(sock, current_timeout); 2586 apr_socket_send(backend->sock, buffe [all...] |
H A D | mod_proxy_fcgi.c | 145 apr_socket_t *s = conn->sock; 186 apr_status_t rv = apr_socket_recv(conn->sock, buffer, buflen); 454 pfd.desc.s = conn->sock; 468 apr_socket_timeout_get(conn->sock, &timeout);
|
H A D | mod_proxy.h | 246 apr_socket_t *sock; /* Connection socket */ member in struct:__anon281 907 * @param sock UDS to connect 909 * @param p pool to make the sock addr 912 PROXY_DECLARE(apr_status_t) ap_proxy_connect_uds(apr_socket_t *sock,
|
/httpd/server/mpm/simple/ |
H A D | simple_event.h | 45 apr_socket_t * sock,
|
H A D | simple_types.h | 46 typedef void (*simple_io_sock_cb) (simple_core_t * sc, apr_socket_t * sock, 48 typedef void (*simple_io_file_cb) (simple_core_t * sc, apr_socket_t * sock, 122 apr_socket_t *sock; member in struct:simple_conn_t
|
H A D | simple_io.c | 216 scon->c = ap_run_create_connection(scon->pool, ap_server_conf, scon->sock, 227 scon->pfd.desc.s = scon->sock; 236 rv = ap_run_pre_connection(scon->c, scon->sock); 284 scon->sock = socket;
|
/httpd/modules/cluster/ |
H A D | mod_heartbeat.c | 48 apr_socket_t *sock = NULL; local 85 rv = apr_socket_create(&sock, ctx->mcast_addr->family, 93 rv = apr_mcast_loopback(sock, 1); 100 rv = apr_socket_sendto(sock, ctx->mcast_addr, 0, buf, &len); 108 if (sock) { 109 apr_socket_close(sock);
|
H A D | mod_heartmonitor.c | 64 apr_socket_t *sock; member in struct:hm_ctx_t 80 rv = apr_socket_create(&ctx->sock, ctx->mcast_addr->family, 89 rv = apr_socket_opt_set(ctx->sock, APR_SO_REUSEADDR, 1); 97 rv = apr_socket_opt_set(ctx->sock, APR_SO_NONBLOCK, 1); 104 rv = apr_socket_bind(ctx->sock, ctx->mcast_addr); 111 rv = apr_mcast_join(ctx->sock, ctx->mcast_addr, NULL, NULL); 119 rv = apr_mcast_loopback(ctx->sock, 1); 570 rv = apr_socket_recvfrom(&from, ctx->sock, 0, buf, &len); 629 pfd.desc.s = ctx->sock; 654 if (ctx->sock) { [all...] |
/httpd/server/mpm/motorz/ |
H A D | motorz.h | 158 typedef void (*motorz_io_sock_cb) (motorz_core_t *mz, apr_socket_t *sock, 160 typedef void (*motorz_io_file_cb) (motorz_core_t *mz, apr_socket_t *sock, 179 apr_socket_t *sock; member in struct:motorz_conn_t
|
H A D | motorz.c | 145 scon->c = ap_run_create_connection(scon->pool, ap_server_conf, scon->sock, 156 scon->pfd.desc.s = scon->sock; 165 status = ap_run_pre_connection(scon->c, scon->sock); 210 scon->sock = socket;
|
/httpd/modules/metadata/ |
H A D | mod_ident.c | 158 static apr_status_t rfc1413_query(apr_socket_t *sock, conn_rec *conn, argument 182 status = apr_socket_send(sock, buffer+i, &j); 208 status = apr_socket_recv(sock, buffer+i, &j); 306 apr_socket_t *sock; local 318 rv = rfc1413_connect(&sock, conn, srv, conf->timeout); 320 rv = rfc1413_query(sock, conn, srv); 321 apr_socket_close(sock);
|
/httpd/server/ |
H A D | mpm_unix.c | 614 apr_socket_t *sock; local 637 rv = apr_socket_create(&sock, lp->bind_addr->family, SOCK_STREAM, 0, p); 651 rv = apr_socket_timeout_set(sock, apr_time_from_sec(3)); 655 apr_socket_close(sock); 660 rv = apr_socket_connect(sock, lp->bind_addr); 708 apr_socket_send(sock, data, &len); 709 apr_socket_close(sock);
|
H A D | listen.c | 940 apr_socket_t *sock; local 941 if (apr_socket_create(&sock, APR_UNSPEC, SOCK_STREAM, 0, 944 apr_os_sock_get(&thesock, sock); 948 apr_socket_close(sock);
|
/httpd/modules/lua/ |
H A D | lua_request.c | 2228 apr_socket_t *sock; local 2246 sock = ap_get_conn_socket(r->connection); 2252 rv = apr_socket_recv(sock, &byte, &len); 2267 rv = apr_socket_recv(sock, &byte, &len); 2285 rv = apr_socket_recv(sock, (char*) &payload_short, &len); 2304 rv = apr_socket_recv(sock, (char*) &payload_long, &len); 2326 rv = apr_socket_recv(sock, (char*) mask_bytes, &len); 2346 rv = apr_socket_recv(sock, buffer+at, &received); 2382 apr_socket_send(sock, frame, &plen); /* Pong! */ 2446 apr_socket_t *sock; local 2466 apr_socket_t *sock; local [all...] |
/httpd/server/mpm/winnt/ |
H A D | child.c | 92 apr_socket_t *sock; member in struct:winnt_conn_ctx_t_s 717 apr_os_sock_make(&context->sock, &sockinfo, context->ptrans); 850 context->sock, thread_num, sbh, 866 /* follow ap_process_connection(c, context->sock) logic 871 rc = ap_run_pre_connection(c, context->sock); 887 apr_socket_opt_get(context->sock, APR_SO_DISCONNECTED, &disconnected);
|
/httpd/modules/arch/netware/ |
H A D | mod_nw_ssl.c | 336 SOCKET sock; local 339 apr_os_sock_get(&sock, csd); 347 rcode = WSAIoctl(sock, SO_TLS_SET_FLAGS, &ulFlags, sizeof(unsigned long), 357 WSAIoctl(sock, SO_TLS_SET_FLAGS, &ulFlags, sizeof(unsigned long), 380 rcode = WSAIoctl(sock, SO_TLS_SET_CLIENT, &sWS2Opts,
|