public function reaper($pid = null, $status = null)
    {
        if ($pid === null) {
            $pid = pcntl_waitpid(-1, $status, WNOHANG);
        }

        while ($pid > 0) {
            if (isset($this->workers[$pid])) {
                // @todo does the socket really need to be closed?
                //@socket_close($this->workers[$pid]['socket']);
                unset($this->workers[$pid]);
            } else {
                // the child died before the parent could initialize the $worker
                // queue. So we track it temporarily so we can handle it in
                // self::create().
                $this->caught[$pid] = $status;
            }
            $pid = pcntl_waitpid(-1, $status, WNOHANG);
        }
    }
public function reaper($pid = null, $status = null)
    {
        if ($pid === null) {
            $pid = pcntl_waitpid(-1, $status, WNOHANG);
        }

        while ($pid > 0) {
            if (isset($this->workers[$pid])) {
                // @todo does the socket really need to be closed?
                //@socket_close($this->workers[$pid]['socket']);
                unset($this->workers[$pid]);
            } else {
                // the child died before the parent could initialize the $worker
                // queue. So we track it temporarily so we can handle it in
                // self::create().
                $this->caught[$pid] = $status;
            }
            $pid = pcntl_waitpid(-1, $status, WNOHANG);
        }
    }
public function reaper ( $ pid = null , $ status = null ) { if ( $ pid === null ) { $ pid = pcntl_waitpid ( - 1 , $ status , WNOHANG ) ; } while ( $ pid > 0 ) { if ( isset ( $ this -> workers [ $ pid ] ) ) { // @todo does the socket really need to be closed? //@socket_close($this->workers[$pid]['socket']); unset ( $ this -> workers [ $ pid ] ) ; } else { // the child died before the parent could initialize the $worker // queue. So we track it temporarily so we can handle it in // self::create(). $ this -> caught [ $ pid ] = $ status ; } $ pid = pcntl_waitpid ( - 1 , $ status , WNOHANG ) ; } }
Reap any dead children
Reap any dead children