define('SITE_PREFIX_LEN', 7);
define('DIRECT_ST_READ', 1);
define('SITE_PREFIX_LEN', 7);
define('DIRECT_ST_READ', 1);
'G_admin_mail', 'G_alarm_passwd', 'G_all_points', 'G_ban_list', 'G_base',
'G_black_list', 'G_brisk_version', 'G_btrace_pref_sub', 'G_cloud_smasher',
'G_crypt_key', 'G_dbasetype', 'G_dbauth', 'G_dbpfx', 'G_doc_path',
'G_admin_mail', 'G_alarm_passwd', 'G_all_points', 'G_ban_list', 'G_base',
'G_black_list', 'G_brisk_version', 'G_btrace_pref_sub', 'G_cloud_smasher',
'G_crypt_key', 'G_dbasetype', 'G_dbauth', 'G_dbpfx', 'G_doc_path',
-'G_domain', 'G_donors_all', 'G_donors_cur', 'G_is_local', 'G_lang', 'G_lng',
+'G_proto', 'G_domain', 'G_donors_all', 'G_donors_cur', 'G_is_local', 'G_lang', 'G_lng',
'G_mail_seed', 'G_notguar_code', 'G_PG_cons', 'G_PG_cons_n', 'G_PG_vow',
'G_PG_vow_n', 'G_poll_entries', 'G_poll_name', 'G_poll_title',
'G_provider_proxy', 'G_proxy_white_list', 'G_room_about', 'G_room_help',
'G_mail_seed', 'G_notguar_code', 'G_PG_cons', 'G_PG_cons_n', 'G_PG_vow',
'G_PG_vow_n', 'G_poll_entries', 'G_poll_name', 'G_poll_title',
'G_provider_proxy', 'G_proxy_white_list', 'G_room_about', 'G_room_help',
$path = $get_vars[0];
if (count($get_vars) > 1) {
$a = explode('&', $get_vars[1]);
$path = $get_vars[0];
if (count($get_vars) > 1) {
$a = explode('&', $get_vars[1]);
for ($i = 0 ; $i < count($a) ; $i++) {
$b = explode('=', $a[$i]);
if ($b[0] == "")
for ($i = 0 ; $i < count($a) ; $i++) {
$b = explode('=', $a[$i]);
if ($b[0] == "")
- if ($this->s2u[$id]->the_end) {
- if ($this->s2u[$id]->rd_socket_get() != NULL) {
- $this->s2u[$id]->rd_socket_set(NULL);
+ $user = $this->s2u[$id];
+ if ($user->the_end) {
+ if (($user->rd_toflush == FALSE && $user->rd_step == $user->step)
+ || $user->rd_endtime_is_expired($this->curtime)) {
+ if ($user->rd_socket_get() != NULL) {
+ $user->rd_socket_set(NULL);
+ }
+ unset($this->socks[$id]);
+ unset($this->s2u[$id]);
+ fclose($sock);
+ // printf("CLOSE ON GARBAGE MANAGER\n");
- fprintf(STDERR, "IN LOOP: Current opened: %d pending_pages: %d\n", count($this->socks), count($this->pending_pages));
+ if ($lastime != ($this->curtime >> 2)) {
+ fprintf(STDERR, "\nIN LOOP: Current opened: %d pending_pages: %d\n", count($this->socks), count($this->pending_pages));
+ }
$num_changed_sockets = @stream_select($read, $write, $except, 0, 500000);
if ($num_changed_sockets == 0) {
$num_changed_sockets = @stream_select($read, $write, $except, 0, 500000);
if ($num_changed_sockets == 0) {
- printf("num sock %d num_of_socket: %d\n", $num_changed_sockets, count($read));
+ if ($lastime != ($this->curtime >> 2)) {
+ printf("num sock %d num_of_socket: %d\n", $num_changed_sockets, count($read));
+ }
if (($new_unix = stream_socket_accept($this->list_web)) == FALSE) {
printf("SOCKET_ACCEPT FAILED\n");
continue;
if (($new_unix = stream_socket_accept($this->list_web)) == FALSE) {
printf("SOCKET_ACCEPT FAILED\n");
continue;
if (($path = spu_process_info($stream_info, $method, $header,
$get, $post, $cookie, $rest, $cont))
== FALSE) {
fprintf(STDERR, "TODO: fix wrong header management\n");
}
if (($path = spu_process_info($stream_info, $method, $header,
$get, $post, $cookie, $rest, $cont))
== FALSE) {
fprintf(STDERR, "TODO: fix wrong header management\n");
}
- $addr_full = stream_socket_get_name($new_socket, TRUE);
+
+ // We try to get real IP from header (passed by proxy) and then fallback to direct connection IP
+ // error_log(sprintf("addr: [%s]", $addr));
+ // error_log(sprintf("X-Real-Ip: [%s]", array_key_exists('X-Real-Ip', $header) ? $header['X-Real-Ip'] : "Not exists"));
+ if (array_key_exists('X-Real-Ip', $header)) {
+ $addr = $header['X-Real-Ip'];
+ }
+ else {
+ $addr = addrtoipv4(stream_socket_get_name($new_socket, TRUE));
+ }
+
- printf("PATH: [%s] [%s]\n", $path, print_r($header, TRUE));
+ // printf("PATH: [%s] [%s]\n", $path, print_r($header, TRUE));
if ($method == "POST" && $rest > 0) {
if (isset($header['Expect']) && $header['Expect'] == '100-continue') {
if ($method == "POST" && $rest > 0) {
if (isset($header['Expect']) && $header['Expect'] == '100-continue') {
$this->pendpage_try_addcont($new_socket, 20,
$method, $header, $get, $post, $cookie,
$path, $addr, $rest, $cont);
$this->pendpage_try_addcont($new_socket, 20,
$method, $header, $get, $post, $cookie,
$path, $addr, $rest, $cont);
if (($new_unix = stream_socket_accept($this->list_cmd)) == FALSE) {
printf("SOCKET_ACCEPT FAILED\n");
continue;
if (($new_unix = stream_socket_accept($this->list_cmd)) == FALSE) {
printf("SOCKET_ACCEPT FAILED\n");
continue;
}
else { // data arrived from not special socket
$key = array_search("$sock", $this->socks);
}
else { // data arrived from not special socket
$key = array_search("$sock", $this->socks);
- fprintf(STDERR, "Arrivati %d bytes dalla socket n. %d\n", mb_strlen($buf, "ASCII"), $key);
+ // fprintf(STDERR, "Arrivati %d bytes dalla socket n. %d\n", mb_strlen($buf, "ASCII"), $key);
if (isset($this->s2p[$id])) {
$this->s2p[$id]->rest -= mb_strlen($buf, "ASCII");
$this->s2p[$id]->cont .= $buf;
if (isset($this->s2p[$id])) {
$this->s2p[$id]->rest -= mb_strlen($buf, "ASCII");
$this->s2p[$id]->cont .= $buf;
if ($response == "") {
$content = "";
$user->stream_main($content, $get, $post, $cookie);
if ($response == "") {
$content = "";
$user->stream_main($content, $get, $post, $cookie);
- printf("[%s] [%d] [%d]\n", $user->name, $user->lacc, $this->curtime);
+ if ($dump_users) {
+ printf("[%s] [%d] [%d]\n", $user->name, $user->lacc, $this->curtime);
+ }
$clo_l = mb_strlen($clo, "ASCII");
@fwrite($sock, $clo, $clo_l);
fclose($sock);
$clo_l = mb_strlen($clo, "ASCII");
@fwrite($sock, $clo, $clo_l);
fclose($sock);