printf("A COUNT: [%s] %d\n", $a[0], count($a));
for ($i = 0 ; $i < count($a) ; $i++) {
$b = explode('=', $a[$i]);
+ if ($b[0] == "")
+ continue;
$get[$b[0]] = urldecode($b[1]);
}
}
static $fixed_fd = 3;
static $cnt_master = NULL;
static $cnt_slave = NULL;
+
+ var $provider_proxy; // list of provider/browser that offer proxy service
var $file_socket;
var $unix_socket;
}
}
- static function create(&$app, $sockname, $debug, $blocking_mode, $argv)
+ static function create(&$app, $sockname, $debug, $blocking_mode, $provider_proxy, $argv)
{
$thiz = new Sac_a_push();
$thiz->app = $app;
+
+ $thiz->provider_proxy = ProviderProxy::create();
+
$thiz->file_socket = $sockname;
$thiz->unix_socket = "unix://$sockname";
$thiz->direct_socket = "unix://${sockname}2";
}
$thiz->main_loop = FALSE;
+ $thiz->reload(TRUE, $provider_proxy);
return ($thiz);
}
foreach ($this->socks as $k => $sock) {
$id = intval($sock);
if (isset($this->s2u[$id])) {
- if ($this->s2u[$id]->sess == '') {
+ if ($this->s2u[$id]->the_end) {
if ($this->s2u[$id]->rd_socket_get() != NULL) {
$this->s2u[$id]->rd_socket_set(NULL);
}
}
}
}
+ $this->app->users_cleanup();
}
function run()
{
GLOBAL $DOCUMENT_ROOT, $HTTP_HOST;
- GLOBAL $G_alarm_passwd, $G_ban_list, $G_black_list, $G_btrace_pref_sub, $G_dbauth;
+ GLOBAL $G_alarm_passwd, $G_ban_list, $G_black_list, $G_cloud_smasher, $G_provider_proxy;
+ GLOBAL $G_btrace_pref_sub, $G_dbauth;
GLOBAL $G_dbpfx, $G_donors_all, $G_donors_cur, $G_is_local, $G_lang;
GLOBAL $G_poll_entries, $G_poll_name, $G_poll_title, $G_proxy_white_list;
GLOBAL $G_room_roadmap, $G_shutdown;
== FALSE) {
fprintf(STDERR, "TODO: fix wrong header management\n");
}
- $addr = stream_socket_get_name($new_socket, TRUE);
+ $addr_full = stream_socket_get_name($new_socket, TRUE);
+ // FOR TEST $header['X-Forwarded-For'] = '154.155.22.33';
+ $addr = $this->pproxy_realip($header, addrtoipv4($addr_full));
+
printf("PATH: [%s]\n", $path);
if ($method == "POST" && $rest > 0) {
if (isset($header['Expect']) && $header['Expect'] == '100-continue') {
$line = trim($buf);
if ($line == "reload") {
require("$DOCUMENT_ROOT/Etc/".BRISK_CONF);
- $this->app->reload(FALSE, $G_ban_list, $G_black_list);
+ $this->reload(FALSE, $G_provider_proxy);
+ $this->app->reload(FALSE, $G_ban_list, $G_black_list,
+ $G_cloud_smasher);
global_dump();
}
else if ($line == "shutdown" || $line == "sd") {
if ($rret == FALSE) {
// FIXME: manage 404 !!!
printf("TODO: fix unknown page\n");
+ fclose($new_socket);
}
}
}
} // while (...
} // function run(...
+ function pproxy_realip($header, $ip_str)
+ {
+ return ($this->provider_proxy->realip($header, $ip_str));
+ }
+
+ function reload($is_first, $prov_proxy)
+ {
+ fprintf(STDERR, "SAP RELOAD STUFF (%d)\n", count($prov_proxy));
+
+ $this->provider_proxy->update($prov_proxy);
+ }
+
function direct_command($cmdstr)
{
GLOBAL $G_alarm_passwd;