Lines Matching refs:conf
263 log_error(r->conf.errh, __FILE__, __LINE__, in gw_proc_connect_success()
272 log_error_st * const errh = r->conf.errh; in gw_proc_connect_error()
737 gw_plugin_config *conf = NULL; in unixsocket_is_dup() local
741 if (cpv->vtype == T_CONFIG_LOCAL) conf = cpv->v.v; in unixsocket_is_dup()
748 if (NULL == conf || NULL == conf->exts) continue; in unixsocket_is_dup()
750 gw_exts *exts = conf->exts; in unixsocket_is_dup()
835 log_error(r->conf.errh, __FILE__, __LINE__, in gw_host_get()
904 log_error(r->conf.errh, __FILE__, __LINE__, in gw_host_get()
923 log_error(r->conf.errh, __FILE__, __LINE__, in gw_host_get()
934 log_error(r->conf.errh, __FILE__, __LINE__, in gw_host_get()
960 log_error(r->conf.errh, __FILE__, __LINE__, in gw_host_get()
975 log_error(r->conf.errh, __FILE__, __LINE__, in gw_establish_connection()
988 log_error(r->conf.errh, __FILE__, __LINE__, in gw_establish_connection()
1812 gw_proc_release(hctx->host, hctx->proc, hctx->conf.debug, in gw_backend_close()
1813 r->conf.errh); in gw_backend_close()
1837 hctx->host = gw_host_get(r,hctx->ext,hctx->conf.balance,hctx->conf.debug); in gw_reconnect()
1864 if (r->conf.stream_request_body & FDEVENT_STREAM_REQUEST_BACKEND_SHUT_WR) in gw_conditional_tcp_fin()
1868 r->conf.stream_request_body |= FDEVENT_STREAM_REQUEST_BACKEND_SHUT_WR; in gw_conditional_tcp_fin()
1869 r->conf.stream_request_body &= ~FDEVENT_STREAM_REQUEST_POLLIN; in gw_conditional_tcp_fin()
1896 &r->reqbody_queue, qlen, r->conf.errh)) in gw_write_refill_wb()
1933 log_perror(r->conf.errh, __FILE__, __LINE__, in gw_write_request()
1950 hctx->fd, hctx->conf.debug)) { in gw_write_request()
1969 socket_error, hctx->conf.debug); in gw_write_request()
1976 gw_proc_connect_success(hctx->host, hctx->proc, hctx->conf.debug, r); in gw_write_request()
2007 log_error_st * const errh = r->conf.errh; in gw_write_request()
2009 if (hctx->conf.debug > 1) { in gw_write_request()
2053 if (!(r->conf.stream_request_body in gw_write_request()
2055 r->conf.stream_request_body |= in gw_write_request()
2069 if (r->conf.stream_request_body in gw_write_request()
2078 log_error(r->conf.errh, __FILE__, __LINE__, in gw_write_request()
2110 gw_restart_dead_procs(hctx->host,srv->errh,hctx->conf.debug,0); in gw_write_error()
2159 if ((r->conf.stream_response_body & FDEVENT_STREAM_RESPONSE_BUFMIN) in gw_handle_subrequest()
2192 && (r->conf.stream_request_body & FDEVENT_STREAM_REQUEST_BUFMIN)) { in gw_handle_subrequest()
2193 r->conf.stream_request_body &= ~FDEVENT_STREAM_REQUEST_POLLIN; in gw_handle_subrequest()
2204 && ((r->conf.stream_request_body & FDEVENT_STREAM_REQUEST) in gw_handle_subrequest()
2215 return (r->conf.stream_request_body & FDEVENT_STREAM_REQUEST) in gw_handle_subrequest()
2250 if (r->conf.stream_request_body & FDEVENT_STREAM_REQUEST_TCP_FIN) in gw_handle_subrequest()
2276 r->conf.stream_response_body |= (hctx->opts.authorizer >> 1); in gw_authorizer_ok()
2283 log_error(r->conf.errh, __FILE__, __LINE__, in gw_authorizer_ok()
2363 if (hctx->conf.debug) { in gw_recv_response_error()
2369 if (gw_spawn_connection(host, proc, errh, hctx->conf.debug)) { in gw_recv_response_error()
2380 log_error(r->conf.errh, __FILE__, __LINE__, in gw_recv_response_error()
2389 log_error(r->conf.errh, __FILE__, __LINE__, in gw_recv_response_error()
2396 log_error(r->conf.errh, __FILE__, __LINE__, in gw_recv_response_error()
2435 const unsigned short flags = r->conf.stream_response_body; in gw_process_fdevent()
2436 r->conf.stream_response_body &= ~FDEVENT_STREAM_RESPONSE_BUFMIN; in gw_process_fdevent()
2437 r->conf.stream_response_body |= FDEVENT_STREAM_RESPONSE_POLLRDHUP; in gw_process_fdevent()
2441 r->conf.stream_response_body = flags; in gw_process_fdevent()
2445 log_error(r->conf.errh, __FILE__, __LINE__, in gw_process_fdevent()
2455 log_error(r->conf.errh, __FILE__, __LINE__, in gw_process_fdevent()
2467 if (NULL == p->conf.exts) return HANDLER_GO_ON; in gw_check_extension()
2493 exts = p->conf.exts_auth; in gw_check_extension()
2496 exts = p->conf.exts_resp; in gw_check_extension()
2510 if (p->conf.ext_mapping) { in gw_check_extension()
2512 (data_string *)array_match_key_suffix(p->conf.ext_mapping, fn); in gw_check_extension()
2568 host = gw_host_get(r, extension, p->conf.balance, p->conf.debug); in gw_check_extension()
2652 hctx->conf.balance = p->conf.balance; in gw_check_extension()
2653 hctx->conf.proto = p->conf.proto; in gw_check_extension()
2654 hctx->conf.debug = p->conf.debug; in gw_check_extension()
2657 !(r->conf.stream_response_body /*(if not streaming response body)*/ in gw_check_extension()
2660 : (r->conf.stream_response_body & FDEVENT_STREAM_RESPONSE_BUFMIN) in gw_check_extension()
2673 if (r->conf.log_request_handling) { in gw_check_extension()
2674 log_error(r->conf.errh, __FILE__, __LINE__, in gw_check_extension()
2691 ETIMEDOUT, hctx->conf.debug); in gw_handle_trigger_hctx_timeout()
2708 log_error(r->conf.errh, __FILE__, __LINE__, in gw_handle_trigger_hctx_timeout()
2857 gw_plugin_config *conf = NULL; in gw_handle_trigger() local
2862 if (cpv->vtype == T_CONFIG_LOCAL) conf = cpv->v.v; in gw_handle_trigger()
2872 if (NULL == conf || NULL == conf->exts) continue; in gw_handle_trigger()
2879 ? gw_handle_trigger_exts_wkr(conf->exts, errh) in gw_handle_trigger()
2880 : gw_handle_trigger_exts(conf->exts, errh, debug); in gw_handle_trigger()
2897 gw_plugin_config *conf = NULL; in gw_handle_waitpid_cb() local
2902 if (cpv->vtype == T_CONFIG_LOCAL) conf = cpv->v.v; in gw_handle_waitpid_cb()
2912 if (NULL == conf || NULL == conf->exts) continue; in gw_handle_waitpid_cb()
2919 gw_exts *exts = conf->exts; in gw_handle_waitpid_cb()