If "Fork and Zombies" was a diner... I would totally eat there.
On Tue, Mar 17, 2009 at 5:00 PM, Jochem Maas <jochem@xxxxxxxxxxxxx> wrote:
> Per Jessen schreef:
> > Waynn Lue wrote:
> >
> >> (Apologies for topposting, I'm on my blackberry). Hm, so you think
> >> exiting from the child thread causes the db resource to get reclaimed?
> >>
> >
> > Yeah, something like that. The connection is definitely closed when the
> > child exits.
> >
>
> I can confirm this. you definitely need to open a connection for each child
> process.
> if you require a db connection in the parent process, you should close
> it before forking (and then reopen it afterwards if you still need it).
>
> at least that's what I found I had to do when I ran into this.
> incidently my forking loop looks like this, very interested to know if
> Per can spot any obvious stupidity:
>
> $childProcs = array();
> do {
> if (count($childProcs) <= $maxChildProcs) {
> $site = array_shift($sites);
> $pid = pcntl_fork();
> } else {
> // stay as parent, no fork, try to reduce number of child processes
> $site = null;
> $pid = null;
> }
>
> switch (true) {
> case ($pid === -1):
> cronLog("error: (in {$thisScript}), cannot initialize worker
> process in order to run {$script} for {$site['name']}");
> break;
>
> case ($pid === 0):
> // we are child
>
> $exit = 0;
> $output = array();
>
> // do we want to exec? or maybe include?
> if ($doExec) {
> exec($script.' '.$site['id'], $output, $exit);
> } else {
> $output = inc($script);
> $output = explode("\n", $output);
> }
>
> if ($exit != 0)
> cronLog("error: (in {$thisScript}), {$script} reported an
> error ($exit) whilst processing for {$site['name']}",);
>
> foreach ($output as $line)
> cronLog($line);
>
> exit($exit);
> break;
>
> default:
> // we are parent
> $childProcs[] = $pid;
>
> do {
> $status = null;
> while (pcntl_wait($status, WNOHANG | WUNTRACED) < 1)
> usleep(50000);
>
> foreach ($childProcs as $k => $v)
> if (!posix_kill($v, 0)) // send signal 'zero' to check
> whether process is still 'up'
> unset($childProcs[ $k ]);
>
> $childProcs = array_values($childProcs);
>
> if (count($sites))
> break; // more sites to run the given script for
> if (!count($childProcs))
> break; // no more sites to run the given script for and
> all children are complete/dead
>
> } while (true);
> break;
> }
>
>
> if (!count($sites))
> break; // nothing more to do
>
> usleep(50000);
> } while (true);
>
>
> >
> > /Per
> >
>
>
> --
> PHP General Mailing List (http://www.php.net/)
> To unsubscribe, visit: http://www.php.net/unsub.php
>
>
