90 |
fdset_update( params); |
fdset_update( params); |
91 |
|
|
92 |
/* any blocked req's move from request_ready to request_block */ |
/* any blocked req's move from request_ready to request_block */ |
93 |
if (params->server_s[0].socket != -1) process_requests(params, params->server_s[0]); |
if (params->server_s[0].socket != -1) process_requests(params, ¶ms->server_s[0]); |
94 |
if (params->server_s[1].socket != -1) process_requests(params, params->server_s[1]); |
#ifdef ENABLE_SSL |
95 |
|
if (params->server_s[1].socket != -1) process_requests(params, ¶ms->server_s[1]); |
96 |
|
#endif |
97 |
|
|
98 |
if (!params->sigterm_flag && params->total_connections < (max_connections - 10)) { |
if (!params->sigterm_flag && params->total_connections < (max_connections - 10)) { |
99 |
if (params->server_s[0].socket != -1) BOA_FD_SET(params->server_s[0].socket, ¶ms->block_read_fdset); /* server always set */ |
if (params->server_s[0].socket != -1) BOA_FD_SET(params->server_s[0].socket, ¶ms->block_read_fdset); /* server always set */ |
100 |
|
#ifdef ENABLE_SSL |
101 |
if (params->server_s[1].socket != -1) BOA_FD_SET(params->server_s[1].socket, ¶ms->block_read_fdset); /* server always set */ |
if (params->server_s[1].socket != -1) BOA_FD_SET(params->server_s[1].socket, ¶ms->block_read_fdset); /* server always set */ |
102 |
|
#endif |
103 |
} |
} |
104 |
|
|
105 |
params->req_timeout.tv_sec = ((params->request_ready) ? 0 : |
params->req_timeout.tv_sec = ((params->request_ready) ? 0 : |
120 |
time(¤t_time); |
time(¤t_time); |
121 |
if (params->server_s[0].socket != -1 && FD_ISSET(params->server_s[0].socket, ¶ms->block_read_fdset)) |
if (params->server_s[0].socket != -1 && FD_ISSET(params->server_s[0].socket, ¶ms->block_read_fdset)) |
122 |
params->server_s[0].pending_requests = 1; |
params->server_s[0].pending_requests = 1; |
123 |
|
#ifdef ENABLE_SSL |
124 |
if (params->server_s[1].socket != -1 && FD_ISSET(params->server_s[1].socket, ¶ms->block_read_fdset)) |
if (params->server_s[1].socket != -1 && FD_ISSET(params->server_s[1].socket, ¶ms->block_read_fdset)) |
125 |
params->server_s[1].pending_requests = 1; |
params->server_s[1].pending_requests = 1; |
126 |
|
#endif |
127 |
} |
} |
128 |
|
|
129 |
return NULL; |
return NULL; |