X-Git-Url: http://mop.ddnsfree.com/gitweb/?p=brisk.git;a=blobdiff_plain;f=web%2FObj%2Fsac-a-push.phh;h=cb106439b2d950cdfc0c4c311c15057aab5d0d9f;hp=7292a7bbf934e498fba28839217482c3855d22dc;hb=5397b38d036459e80f0e5ce4c2f53bd8263007cc;hpb=4bc572b7ad20f01404dd133246437a8f67807eeb diff --git a/web/Obj/sac-a-push.phh b/web/Obj/sac-a-push.phh index 7292a7b..cb10643 100644 --- a/web/Obj/sac-a-push.phh +++ b/web/Obj/sac-a-push.phh @@ -404,6 +404,7 @@ class Sac_a_push { var $s2u; // user associated with input socket var $s2p; // pending page associated with input socket var $pending_pages; + var $is_daemon; var $list; var $in; @@ -446,7 +447,7 @@ class Sac_a_push { } } - static function create(&$app, $sockname, $debug, $blocking_mode) + static function create(&$app, $sockname, $debug, $blocking_mode, $argv) { $thiz = new Sac_a_push(); @@ -458,6 +459,11 @@ class Sac_a_push { $thiz->s2u = array(); $thiz->s2p = array(); $thiz->pending_pages = array(); + $thiz->is_daemon = FALSE; + + if (array_search("-d", $argv) !== FALSE || array_search("--daemon", $argv) !== FALSE) { + $thiz->is_daemon = TRUE; + } // create a couple of sockets for control management if (($sockpair = stream_socket_pair(STREAM_PF_UNIX, STREAM_SOCK_STREAM, @@ -628,9 +634,15 @@ class Sac_a_push { /* if ($shutdown) */ /* $read = array_merge(array("$in" => $in), $socks); */ /* else */ - $read = array_merge(array(intval($this->list) => $this->list, intval($this->in) => $this->in, - intval(static::$cnt_slave) => static::$cnt_slave), - $this->socks); + $pre_read = array_merge(array(intval($this->list) => $this->list, + intval(static::$cnt_slave) => static::$cnt_slave), + $this->socks); + if ($this->is_daemon == FALSE) { + $read = array_merge($pre_read, array(intval($this->in) => $this->in)); + } + else { + $read = $pre_read; + } if ($this->debug > 1) { printf("PRE_SELECT\n");