projects
/
brisk.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
not guaranteed users silenced on chat room
[brisk.git]
/
web
/
Obj
/
sac-a-push.phh
diff --git
a/web/Obj/sac-a-push.phh
b/web/Obj/sac-a-push.phh
index
91012a8
..
6d75492
100644
(file)
--- a/
web/Obj/sac-a-push.phh
+++ b/
web/Obj/sac-a-push.phh
@@
-156,6
+156,8
@@
function spu_process_info($stream_info, &$method, &$header, &$get, &$post, &$coo
printf("A COUNT: [%s] %d\n", $a[0], count($a));
for ($i = 0 ; $i < count($a) ; $i++) {
$b = explode('=', $a[$i]);
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]);
}
}
$get[$b[0]] = urldecode($b[1]);
}
}
@@
-603,7
+605,7
@@
class Sac_a_push {
foreach ($this->socks as $k => $sock) {
$id = intval($sock);
if (isset($this->s2u[$id])) {
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);
}
if ($this->s2u[$id]->rd_socket_get() != NULL) {
$this->s2u[$id]->rd_socket_set(NULL);
}
@@
-614,6
+616,7
@@
class Sac_a_push {
}
}
}
}
}
}
+ $this->app->users_cleanup();
}
function run()
}
function run()
@@
-796,7
+799,7
@@
class Sac_a_push {
$line = trim($buf);
if ($line == "reload") {
require("$DOCUMENT_ROOT/Etc/".BRISK_CONF);
$line = trim($buf);
if ($line == "reload") {
require("$DOCUMENT_ROOT/Etc/".BRISK_CONF);
- $this->app->reload($G_ban_list, $G_black_list);
+ $this->app->reload(
FALSE,
$G_ban_list, $G_black_list);
global_dump();
}
else if ($line == "shutdown" || $line == "sd") {
global_dump();
}
else if ($line == "shutdown" || $line == "sd") {
@@
-941,6
+944,9
@@
class Sac_a_push {
} // if (isset($this->s2u[$id]...
} // foreach ($this->socks...
printf("\n");
} // if (isset($this->s2u[$id]...
} // foreach ($this->socks...
printf("\n");
+ if (defined('CURL_DE_SAC_VERS')) {
+ $this->app->cds->process();
+ }
} // while (...
} // function run(...
} // while (...
} // function run(...