Lines Matching refs:conn
137 static apr_status_t send_data(proxy_conn_rec *conn,
145 apr_socket_t *s = conn->sock;
175 conn->worker->s->transferred += written;
182 static apr_status_t get_data(proxy_conn_rec *conn,
186 apr_status_t rv = apr_socket_recv(conn->sock, buffer, buflen);
189 conn->worker->s->read += *buflen;
195 static apr_status_t get_data_full(proxy_conn_rec *conn,
205 rv = get_data(conn, buffer + cumulative_len, &readlen);
215 static apr_status_t send_begin_request(proxy_conn_rec *conn,
229 ap_proxy_connection_reusable(conn)
240 return send_data(conn, vec, 2, &len);
243 static apr_status_t send_environment(proxy_conn_rec *conn, request_rec *r,
342 rv = send_data(conn, vec, 2, &len);
357 return send_data(conn, vec, 1, &len);
428 static apr_status_t dispatch(proxy_conn_rec *conn, proxy_dir_conf *conf,
448 if (conn->worker->s->io_buffer_size_set) {
449 iobuf_size = conn->worker->s->io_buffer_size;
454 pfd.desc.s = conn->sock;
468 apr_socket_timeout_get(conn->sock, &timeout);
530 rv = send_data(conn, vec, nvec, &len);
554 rv = send_data(conn, vec, 1, &len);
570 rv = get_data_full(conn, (char *) farray, AP_FCGI_HEADER_LEN);
609 rv = get_data(conn, iobuf, &readbuflen);
769 rv = get_data_full(conn, iobuf, plen);
794 proxy_conn_rec *conn,
813 rv = send_begin_request(conn, request_id);
817 conn->close = 1;
824 rv = send_environment(conn, r, temp_pool, request_id);
828 conn->close = 1;
833 rv = dispatch(conn, conf, r, temp_pool, request_id,
842 conn->close = 1;