Lines Matching refs:srv
372 static handler_t fcgi_handle_fdevent(server *srv, void *ctx, int revents);
398 static void fcgi_proc_load_inc(server *srv, handler_ctx *hctx) { in fcgi_proc_load_inc() argument
402 status_counter_inc(srv, CONST_STR_LEN("fastcgi.active-requests")); in fcgi_proc_load_inc()
407 status_counter_set(srv, CONST_BUF_LEN(p->statuskey), hctx->proc->load); in fcgi_proc_load_inc()
410 static void fcgi_proc_load_dec(server *srv, handler_ctx *hctx) { in fcgi_proc_load_dec() argument
414 status_counter_dec(srv, CONST_STR_LEN("fastcgi.active-requests")); in fcgi_proc_load_dec()
419 status_counter_set(srv, CONST_BUF_LEN(p->statuskey), hctx->proc->load); in fcgi_proc_load_dec()
422 static void fcgi_host_assign(server *srv, handler_ctx *hctx, fcgi_extension_host *host) { in fcgi_host_assign() argument
430 status_counter_set(srv, CONST_BUF_LEN(p->statuskey), hctx->host->load); in fcgi_host_assign()
433 static void fcgi_host_reset(server *srv, handler_ctx *hctx) { in fcgi_host_reset() argument
440 status_counter_set(srv, CONST_BUF_LEN(p->statuskey), hctx->host->load); in fcgi_host_reset()
445 static void fcgi_host_disable(server *srv, handler_ctx *hctx) { in fcgi_host_disable() argument
450 hctx->proc->disabled_until = srv->cur_ts + hctx->host->disable_time; in fcgi_host_disable()
454 log_error_write(srv, __FILE__, __LINE__, "sds", in fcgi_host_disable()
460 static int fastcgi_status_init(server *srv, buffer *b, fcgi_extension_host *host, fcgi_proc *proc) { in fastcgi_status_init() argument
464 status_counter_set(srv, CONST_BUF_LEN(b), 0); in fastcgi_status_init()
477 status_counter_set(srv, CONST_BUF_LEN(b), 0); in fastcgi_status_init()
511 static void handler_ctx_free(server *srv, handler_ctx *hctx) { in handler_ctx_free() argument
513 fcgi_host_reset(srv, hctx); in handler_ctx_free()
693 UNUSED(srv); in FREE_FUNC()
702 for (i = 0; i < srv->config_context->used; i++) { in FREE_FUNC()
847 static int fcgi_spawn_connection(server *srv, in fcgi_spawn_connection() argument
867 log_error_write(srv, __FILE__, __LINE__, "sdb", in fcgi_spawn_connection()
891 log_error_write(srv, __FILE__, __LINE__, "s", in fcgi_spawn_connection()
908 log_error_write(srv, __FILE__, __LINE__, in fcgi_spawn_connection()
915 log_error_write(srv, __FILE__, __LINE__, "sd", "addr-type != AF_INET: ", he->h_addrtype); in fcgi_spawn_connection()
920 … log_error_write(srv, __FILE__, __LINE__, "sd", "addr-length != sizeof(in_addr): ", he->h_length); in fcgi_spawn_connection()
944 log_error_write(srv, __FILE__, __LINE__, "ss", in fcgi_spawn_connection()
963 log_error_write(srv, __FILE__, __LINE__, "ss", in fcgi_spawn_connection()
970 log_error_write(srv, __FILE__, __LINE__, "ss", in fcgi_spawn_connection()
977 log_error_write(srv, __FILE__, __LINE__, "sbs", in fcgi_spawn_connection()
985 log_error_write(srv, __FILE__, __LINE__, "ss", in fcgi_spawn_connection()
1067 log_error_write(srv, __FILE__, __LINE__, "sss", "chdir failed:", strerror(errno), arg.ptr[0]); in fcgi_spawn_connection()
1099 log_error_write(srv, __FILE__, __LINE__, "ss", in fcgi_spawn_connection()
1103 log_error_write(srv, __FILE__, __LINE__, "sbs", in fcgi_spawn_connection()
1107 log_error_write(srv, __FILE__, __LINE__, "sdb", in fcgi_spawn_connection()
1110 log_error_write(srv, __FILE__, __LINE__, "s", in fcgi_spawn_connection()
1114 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_spawn_connection()
1119 log_error_write(srv, __FILE__, __LINE__, "s", in fcgi_spawn_connection()
1121 log_error_write(srv, __FILE__, __LINE__, "s", in fcgi_spawn_connection()
1125 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_spawn_connection()
1144 log_error_write(srv, __FILE__, __LINE__, "sb", in fcgi_spawn_connection()
1172 p->config_storage = calloc(1, srv->config_context->used * sizeof(specific_config *)); in SETDEFAULTS_FUNC()
1174 for (i = 0; i < srv->config_context->used; i++) { in SETDEFAULTS_FUNC()
1188 ca = ((data_config *)srv->config_context->data[i])->value; in SETDEFAULTS_FUNC()
1190 if (0 != config_insert_values_global(srv, ca, cv)) { in SETDEFAULTS_FUNC()
1203 log_error_write(srv, __FILE__, __LINE__, "sss", in SETDEFAULTS_FUNC()
1220 log_error_write(srv, __FILE__, __LINE__, "sssbs", in SETDEFAULTS_FUNC()
1269 log_error_write(srv, __FILE__, __LINE__, "ssSBS", in SETDEFAULTS_FUNC()
1309 if (0 != config_insert_values_internal(srv, da_host->value, fcv)) { in SETDEFAULTS_FUNC()
1315 log_error_write(srv, __FILE__, __LINE__, "sbsbsbs", in SETDEFAULTS_FUNC()
1329 log_error_write(srv, __FILE__, __LINE__, "sbsbsbs", in SETDEFAULTS_FUNC()
1342 log_error_write(srv, __FILE__, __LINE__, "sbsbsbs", in SETDEFAULTS_FUNC()
1350 log_error_write(srv, __FILE__, __LINE__, "sbsbsbs", in SETDEFAULTS_FUNC()
1365 log_error_write(srv, __FILE__, __LINE__, "ssbsdsbsd", in SETDEFAULTS_FUNC()
1389 log_error_write(srv, __FILE__, __LINE__, "ssdsbsdsd", in SETDEFAULTS_FUNC()
1396 if (fcgi_spawn_connection(srv, p, host, proc)) { in SETDEFAULTS_FUNC()
1397 log_error_write(srv, __FILE__, __LINE__, "s", in SETDEFAULTS_FUNC()
1402 fastcgi_status_init(srv, p->statuskey, host, proc); in SETDEFAULTS_FUNC()
1424 fastcgi_status_init(srv, p->statuskey, host, proc); in SETDEFAULTS_FUNC()
1437 log_error_write(srv, __FILE__, __LINE__, "s", in SETDEFAULTS_FUNC()
1442 log_error_write(srv, __FILE__, __LINE__, "sbs", in SETDEFAULTS_FUNC()
1460 static int fcgi_set_state(server *srv, handler_ctx *hctx, fcgi_connection_state_t state) { in fcgi_set_state() argument
1462 hctx->state_timestamp = srv->cur_ts; in fcgi_set_state()
1468 static void fcgi_connection_close(server *srv, handler_ctx *hctx) { in fcgi_connection_close() argument
1478 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in fcgi_connection_close()
1479 fdevent_unregister(srv->ev, hctx->fd); in fcgi_connection_close()
1481 srv->cur_fds--; in fcgi_connection_close()
1487 fcgi_proc_load_dec(srv, hctx); in fcgi_connection_close()
1490 log_error_write(srv, __FILE__, __LINE__, "ssdsbsd", in fcgi_connection_close()
1500 handler_ctx_free(srv, hctx); in fcgi_connection_close()
1504 static int fcgi_reconnect(server *srv, handler_ctx *hctx) { in fcgi_reconnect() argument
1527 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in fcgi_reconnect()
1528 fdevent_unregister(srv->ev, hctx->fd); in fcgi_reconnect()
1530 srv->cur_fds--; in fcgi_reconnect()
1534 fcgi_set_state(srv, hctx, FCGI_STATE_INIT); in fcgi_reconnect()
1541 log_error_write(srv, __FILE__, __LINE__, "sdb", in fcgi_reconnect()
1545 log_error_write(srv, __FILE__, __LINE__, "sb", in fcgi_reconnect()
1552 fcgi_proc_load_dec(srv, hctx); in fcgi_reconnect()
1556 fcgi_host_reset(srv, hctx); in fcgi_reconnect()
1562 static handler_t fcgi_connection_reset(server *srv, connection *con, void *p_d) { in fcgi_connection_reset() argument
1565 fcgi_connection_close(srv, con->plugin_ctx[p->id]); in fcgi_connection_reset()
1646 static connection_result_t fcgi_establish_connection(server *srv, handler_ctx *hctx) { in fcgi_establish_connection() argument
1685 log_error_write(srv, __FILE__, __LINE__, "sbs", in fcgi_establish_connection()
1717 log_error_write(srv, __FILE__, __LINE__, "sb", in fcgi_establish_connection()
1724 log_error_write(srv, __FILE__, __LINE__, "sbsd", in fcgi_establish_connection()
1732 log_error_write(srv, __FILE__, __LINE__, "sssb", in fcgi_establish_connection()
1743 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_establish_connection()
1750 static int fcgi_env_add_request_headers(server *srv, connection *con, plugin_data *p) { in fcgi_env_add_request_headers() argument
1760 buffer_reset(srv->tmp_buf); in fcgi_env_add_request_headers()
1763 buffer_copy_string_len(srv->tmp_buf, CONST_STR_LEN("HTTP_")); in fcgi_env_add_request_headers()
1764 srv->tmp_buf->used--; in fcgi_env_add_request_headers()
1767 buffer_prepare_append(srv->tmp_buf, ds->key->used + 2); in fcgi_env_add_request_headers()
1777 srv->tmp_buf->ptr[srv->tmp_buf->used++] = c; in fcgi_env_add_request_headers()
1779 srv->tmp_buf->ptr[srv->tmp_buf->used++] = '\0'; in fcgi_env_add_request_headers()
1781 …FCGI_ENV_ADD_CHECK(fcgi_env_add(p->fcgi_env, CONST_BUF_LEN(srv->tmp_buf), CONST_BUF_LEN(ds->value)… in fcgi_env_add_request_headers()
1792 buffer_reset(srv->tmp_buf); in fcgi_env_add_request_headers()
1794 buffer_prepare_append(srv->tmp_buf, ds->key->used + 2); in fcgi_env_add_request_headers()
1804 srv->tmp_buf->ptr[srv->tmp_buf->used++] = c; in fcgi_env_add_request_headers()
1806 srv->tmp_buf->ptr[srv->tmp_buf->used++] = '\0'; in fcgi_env_add_request_headers()
1808 …FCGI_ENV_ADD_CHECK(fcgi_env_add(p->fcgi_env, CONST_BUF_LEN(srv->tmp_buf), CONST_BUF_LEN(ds->value)… in fcgi_env_add_request_headers()
1816 static int fcgi_create_env(server *srv, handler_ctx *hctx, size_t request_id) { in fcgi_create_env() argument
1899 s = inet_ntop_cache_get_ip(srv, &(srv_sock->addr)); in fcgi_create_env()
1901 s = inet_ntop_cache_get_ip(srv, &(our_addr)); in fcgi_create_env()
1915 s = inet_ntop_cache_get_ip(srv, &(con->dst_addr)); in fcgi_create_env()
2038 FCGI_ENV_ADD_CHECK(fcgi_env_add_request_headers(srv, con, p), con); in fcgi_create_env()
2071 log_error_write(srv, __FILE__, __LINE__, "soso", "tosend:", offset, "/", req_cq->bytes_in); in fcgi_create_env()
2076 log_error_write(srv, __FILE__, __LINE__, "soso", "chunk:", written, "/", weWant); in fcgi_create_env()
2086 log_error_write(srv, __FILE__, __LINE__, "soSosOsb", in fcgi_create_env()
2118 log_error_write(srv, __FILE__, __LINE__, "s", "next chunk"); in fcgi_create_env()
2176 static int fcgi_response_parse(server *srv, connection *con, plugin_data *p, buffer *in) { in fcgi_response_parse() argument
2184 UNUSED(srv); in fcgi_response_parse()
2272 … log_error_write(srv, __FILE__, __LINE__, "ss", "Couldn't find range after filename:", filename); in fcgi_response_parse()
2276 buffer_copy_string_len(srv->tmp_buf, filename, range - filename); in fcgi_response_parse()
2281 buffer_urldecode_path(srv->tmp_buf); in fcgi_response_parse()
2282 if (HANDLER_ERROR == stat_cache_get_entry(srv, con, srv->tmp_buf, &sce)) { in fcgi_response_parse()
2284 log_error_write(srv, __FILE__, __LINE__, "sb", in fcgi_response_parse()
2286 srv->tmp_buf); in fcgi_response_parse()
2291 log_error_write(srv, __FILE__, __LINE__, "sb", in fcgi_response_parse()
2293 srv->tmp_buf); in fcgi_response_parse()
2318 … log_error_write(srv, __FILE__, __LINE__, "ss", "Couldn't decode range after filename:", filename); in fcgi_response_parse()
2333 http_chunk_append_file(srv, con, srv->tmp_buf, begin_range, range_len); in fcgi_response_parse()
2358 joblist_append(srv, con); in fcgi_response_parse()
2391 static int fastcgi_get_packet(server *srv, handler_ctx *hctx, fastcgi_response_packet *packet) { in fastcgi_get_packet() argument
2429 …log_error_write(srv, __FILE__, __LINE__, "sdsds", "FastCGI: header too small:", packet->b->used, "… in fastcgi_get_packet()
2488 static int fcgi_demux_response(server *srv, handler_ctx *hctx) { in fcgi_demux_response() argument
2504 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_demux_response()
2531 log_error_write(srv, __FILE__, __LINE__, "sds", in fcgi_demux_response()
2543 log_error_write(srv, __FILE__, __LINE__, "ssdsb", in fcgi_demux_response()
2559 if (0 != fastcgi_get_packet(srv, hctx, &packet)) { in fcgi_demux_response()
2602 if (fcgi_response_parse(srv, con, p, hctx->response_header)) { in fcgi_demux_response()
2623 if (HANDLER_ERROR != stat_cache_get_entry(srv, con, ds->value, &sce)) { in fcgi_demux_response()
2629 http_chunk_append_file(srv, con, ds->value, 0, sce->st.st_size); in fcgi_demux_response()
2631 joblist_append(srv, con); in fcgi_demux_response()
2641 log_error_write(srv, __FILE__, __LINE__, "sb", in fcgi_demux_response()
2659 http_chunk_append_mem(srv, con, c, blen); in fcgi_demux_response()
2660 joblist_append(srv, con); in fcgi_demux_response()
2669 http_chunk_append_mem(srv, con, packet.b->ptr, packet.b->used); in fcgi_demux_response()
2670 joblist_append(srv, con); in fcgi_demux_response()
2676 log_error_write(srv, __FILE__, __LINE__, "sb", in fcgi_demux_response()
2687 http_chunk_append_mem(srv, con, NULL, 0); in fcgi_demux_response()
2688 joblist_append(srv, con); in fcgi_demux_response()
2694 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_demux_response()
2704 static int fcgi_restart_dead_procs(server *srv, plugin_data *p, fcgi_extension_host *host) { in fcgi_restart_dead_procs() argument
2711 log_error_write(srv, __FILE__, __LINE__, "sbdddd", in fcgi_restart_dead_procs()
2734 if (srv->cur_ts <= proc->disabled_until) break; in fcgi_restart_dead_procs()
2739 log_error_write(srv, __FILE__, __LINE__, "sbdb", in fcgi_restart_dead_procs()
2755 if (srv->cur_ts <= proc->disabled_until) break; in fcgi_restart_dead_procs()
2760 log_error_write(srv, __FILE__, __LINE__, "sbdb", in fcgi_restart_dead_procs()
2768 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_restart_dead_procs()
2776 log_error_write(srv, __FILE__, __LINE__, "sdsd", in fcgi_restart_dead_procs()
2781 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_restart_dead_procs()
2785 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_restart_dead_procs()
2812 log_error_write(srv, __FILE__, __LINE__, "ssbsdsd", in fcgi_restart_dead_procs()
2818 if (fcgi_spawn_connection(srv, p, host, proc)) { in fcgi_restart_dead_procs()
2819 log_error_write(srv, __FILE__, __LINE__, "s", in fcgi_restart_dead_procs()
2824 if (srv->cur_ts <= proc->disabled_until) break; in fcgi_restart_dead_procs()
2829 log_error_write(srv, __FILE__, __LINE__, "sb", in fcgi_restart_dead_procs()
2840 static handler_t fcgi_write_request(server *srv, handler_ctx *hctx) { in fcgi_write_request() argument
2855 log_error_write(srv, __FILE__, __LINE__, "s", "fatal error: host = NULL"); in fcgi_write_request()
2859 …log_error_write(srv, __FILE__, __LINE__, "s", "fatal error: neither host->port nor host->unixsocke… in fcgi_write_request()
2870 log_error_write(srv, __FILE__, __LINE__, "ss", in fcgi_write_request()
2873 fcgi_host_disable(srv, hctx); in fcgi_write_request()
2881 log_error_write(srv, __FILE__, __LINE__, "sssb", in fcgi_write_request()
2886 fcgi_host_disable(srv, hctx); in fcgi_write_request()
2887 log_error_write(srv, __FILE__, __LINE__, "sdssdsd", in fcgi_write_request()
2895 status_counter_inc(srv, CONST_BUF_LEN(p->statuskey)); in fcgi_write_request()
2936 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_write_request()
2942 log_error_write(srv, __FILE__, __LINE__, "ssdd", in fcgi_write_request()
2943 "socket failed:", strerror(errno), srv->cur_fds, srv->max_fds); in fcgi_write_request()
2948 srv->cur_fds++; in fcgi_write_request()
2950 fdevent_register(srv->ev, hctx->fd, fcgi_handle_fdevent, hctx); in fcgi_write_request()
2952 if (-1 == fdevent_fcntl_set(srv->ev, hctx->fd)) { in fcgi_write_request()
2953 log_error_write(srv, __FILE__, __LINE__, "ss", in fcgi_write_request()
2963 switch (fcgi_establish_connection(srv, hctx)) { in fcgi_write_request()
2967 fdevent_event_set(srv->ev, &(hctx->fde_ndx), hctx->fd, FDEVENT_OUT); in fcgi_write_request()
2969 fcgi_set_state(srv, hctx, FCGI_STATE_CONNECT_DELAYED); in fcgi_write_request()
2976 log_error_write(srv, __FILE__, __LINE__, "sdssdsd", in fcgi_write_request()
2981 hctx->proc->disabled_until = srv->cur_ts + hctx->host->disable_time; in fcgi_write_request()
2989 status_counter_inc(srv, CONST_BUF_LEN(p->statuskey)); in fcgi_write_request()
3000 fcgi_host_disable(srv, hctx); in fcgi_write_request()
3002 log_error_write(srv, __FILE__, __LINE__, "sdssdsd", in fcgi_write_request()
3010 status_counter_inc(srv, CONST_BUF_LEN(p->statuskey)); in fcgi_write_request()
3016 fcgi_set_state(srv, hctx, FCGI_STATE_PREPARE_WRITE); in fcgi_write_request()
3024 fcgi_proc_load_inc(srv, hctx); in fcgi_write_request()
3027 status_counter_inc(srv, CONST_STR_LEN("fastcgi.requests")); in fcgi_write_request()
3032 status_counter_inc(srv, CONST_BUF_LEN(p->statuskey)); in fcgi_write_request()
3035 log_error_write(srv, __FILE__, __LINE__, "ssdsbsd", in fcgi_write_request()
3046 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_write_request()
3051 if (-1 == fcgi_create_env(srv, hctx, hctx->request_id)) return HANDLER_ERROR; in fcgi_write_request()
3052 fcgi_set_state(srv, hctx, FCGI_STATE_WRITE); in fcgi_write_request()
3055 ret = srv->network_backend_write(srv, con, hctx->fd, hctx->wb, MAX_WRITE_LIMIT); in fcgi_write_request()
3068 log_error_write(srv, __FILE__, __LINE__, "ssosb", in fcgi_write_request()
3075 log_error_write(srv, __FILE__, __LINE__, "ssd", in fcgi_write_request()
3084 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in fcgi_write_request()
3085 fdevent_event_set(srv->ev, &(hctx->fde_ndx), hctx->fd, FDEVENT_IN); in fcgi_write_request()
3086 fcgi_set_state(srv, hctx, FCGI_STATE_READ); in fcgi_write_request()
3088 fdevent_event_set(srv->ev, &(hctx->fde_ndx), hctx->fd, FDEVENT_OUT); in fcgi_write_request()
3098 log_error_write(srv, __FILE__, __LINE__, "s", "(debug) unknown state"); in fcgi_write_request()
3150 fcgi_connection_close(srv, hctx); in SUBREQUEST_FUNC()
3171 fcgi_host_assign(srv, hctx, host); in SUBREQUEST_FUNC()
3178 switch(fcgi_write_request(srv, hctx)) { in SUBREQUEST_FUNC()
3184 fcgi_restart_dead_procs(srv, p, host); in SUBREQUEST_FUNC()
3188 fcgi_reconnect(srv, hctx); in SUBREQUEST_FUNC()
3189 joblist_append(srv, con); /* in case we come from the event-handler */ in SUBREQUEST_FUNC()
3193 fcgi_connection_close(srv, hctx); in SUBREQUEST_FUNC()
3198 joblist_append(srv, con); /* in case we come from the event-handler */ in SUBREQUEST_FUNC()
3203 fcgi_connection_close(srv, hctx); in SUBREQUEST_FUNC()
3208 joblist_append(srv, con); /* really ? */ in SUBREQUEST_FUNC()
3221 log_error_write(srv, __FILE__, __LINE__, "s", "subrequest write-req default"); in SUBREQUEST_FUNC()
3226 static handler_t fcgi_handle_fdevent(server *srv, void *ctx, int revents) { in fcgi_handle_fdevent() argument
3236 switch (fcgi_demux_response(srv, hctx)) { in fcgi_handle_fdevent()
3255 fcgi_connection_close(srv, hctx); in fcgi_handle_fdevent()
3262 fcgi_connection_close(srv, hctx); in fcgi_handle_fdevent()
3265 joblist_append(srv, con); in fcgi_handle_fdevent()
3282 log_error_write(srv, __FILE__, __LINE__, "sdsd", in fcgi_handle_fdevent()
3286 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_handle_fdevent()
3290 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_handle_fdevent()
3296 log_error_write(srv, __FILE__, __LINE__, "ssbsdsd", in fcgi_handle_fdevent()
3302 if (fcgi_spawn_connection(srv, p, host, proc)) { in fcgi_handle_fdevent()
3306 log_error_write(srv, __FILE__, __LINE__, "s", in fcgi_handle_fdevent()
3319 fcgi_reconnect(srv, hctx); in fcgi_handle_fdevent()
3321 log_error_write(srv, __FILE__, __LINE__, "ssbsBSBs", in fcgi_handle_fdevent()
3329 log_error_write(srv, __FILE__, __LINE__, "sosbsBSBs", in fcgi_handle_fdevent()
3334 fcgi_connection_close(srv, hctx); in fcgi_handle_fdevent()
3336 connection_set_state(srv, con, CON_STATE_HANDLE_REQUEST); in fcgi_handle_fdevent()
3342 fcgi_connection_close(srv, hctx); in fcgi_handle_fdevent()
3344 log_error_write(srv, __FILE__, __LINE__, "ssbsBSBs", in fcgi_handle_fdevent()
3349 connection_set_state(srv, con, CON_STATE_ERROR); in fcgi_handle_fdevent()
3355 joblist_append(srv, con); in fcgi_handle_fdevent()
3368 return mod_fastcgi_handle_subrequest(srv, con, p); in fcgi_handle_fdevent()
3370 log_error_write(srv, __FILE__, __LINE__, "sd", in fcgi_handle_fdevent()
3388 return mod_fastcgi_handle_subrequest(srv, con, p); in fcgi_handle_fdevent()
3397 log_error_write(srv, __FILE__, __LINE__, "sBSbsbsd", in fcgi_handle_fdevent()
3403 connection_set_state(srv, con, CON_STATE_ERROR); in fcgi_handle_fdevent()
3404 fcgi_connection_close(srv, hctx); in fcgi_handle_fdevent()
3405 joblist_append(srv, con); in fcgi_handle_fdevent()
3408 log_error_write(srv, __FILE__, __LINE__, "s", in fcgi_handle_fdevent()
3413 connection_set_state(srv, con, CON_STATE_ERROR); in fcgi_handle_fdevent()
3414 fcgi_connection_close(srv, hctx); in fcgi_handle_fdevent()
3415 joblist_append(srv, con); in fcgi_handle_fdevent()
3422 static int fcgi_patch_connection(server *srv, connection *con, plugin_data *p) { in fcgi_patch_connection() argument
3431 for (i = 1; i < srv->config_context->used; i++) { in fcgi_patch_connection()
3432 data_config *dc = (data_config *)srv->config_context->data[i]; in fcgi_patch_connection()
3436 if (!config_check_cond(srv, con, dc)) continue; in fcgi_patch_connection()
3457 static handler_t fcgi_check_extension(server *srv, connection *con, void *p_d, int uri_path_handler… in fcgi_check_extension() argument
3476 fcgi_patch_connection(srv, con, p); in fcgi_check_extension()
3570 log_error_write(srv, __FILE__, __LINE__, "sBSbsbs", in fcgi_check_extension()
3609 log_error_write(srv, __FILE__, __LINE__, "s", in fcgi_check_extension()
3676 log_error_write(srv, __FILE__, __LINE__, "s", "handling it in mod_fastcgi"); in fcgi_check_extension()
3684 static handler_t fcgi_check_extension_1(server *srv, connection *con, void *p_d) { in fcgi_check_extension_1() argument
3685 return fcgi_check_extension(srv, con, p_d, 1); in fcgi_check_extension_1()
3689 static handler_t fcgi_check_extension_2(server *srv, connection *con, void *p_d) { in fcgi_check_extension_2() argument
3690 return fcgi_check_extension(srv, con, p_d, 0); in fcgi_check_extension_2()
3702 fdevent_event_set(srv->ev, &(hctx->fde_ndx), hctx->fd, FDEVENT_IN); in JOBLIST_FUNC()
3707 fdevent_event_set(srv->ev, &(hctx->fde_ndx), hctx->fd, FDEVENT_OUT); in JOBLIST_FUNC()
3714 log_error_write(srv, __FILE__, __LINE__, "sd", "unhandled fcgi.state", hctx->state); in JOBLIST_FUNC()
3723 static handler_t fcgi_connection_close_callback(server *srv, connection *con, void *p_d) { in fcgi_connection_close_callback() argument
3726 fcgi_connection_close(srv, con->plugin_ctx[p->id]); in fcgi_connection_close_callback()
3746 for (i = 0; i < srv->config_context->used; i++) { in TRIGGER_FUNC()
3766 fcgi_restart_dead_procs(srv, p, host); in TRIGGER_FUNC()
3780 log_error_write(srv, __FILE__, __LINE__, "sddss", in TRIGGER_FUNC()
3797 log_error_write(srv, __FILE__, __LINE__, "sdb", in TRIGGER_FUNC()
3803 log_error_write(srv, __FILE__, __LINE__, "sd", in TRIGGER_FUNC()
3808 log_error_write(srv, __FILE__, __LINE__, "sd", in TRIGGER_FUNC()