Perl ForkManager module not working

Question

My error is as follows

You cannot start another process while you are in a child process, on the page / usr / lib / perl 5 / site_perl / 5.8.6 / Parallel / ForkManager.pm, line 463.

The part of my code that is having problems is below, below my code there is a routine that does not work in forkmanager, I can’t understand why. Without forkmanager, I can work fine.

my $pm = new Parallel::ForkManager($MAX_PROCESSES); for (0..$SCOUNT) { my $pid = $pm->start and next; my %shash = (); %shash = ( ID => "$SREF->[$_]->[0]", typeID => "$SREF->[$_]->[1]", extIP => "$SREF->[$_]->[2]", intIP => "$SREF->[$_]->[3]", NAME => "$SREF->[$_]->[4]", buTYPE => "NULL" ); if ($shash{typeID} =~ /^(4|16|17|25|27|28|42|49|50|51|54|58|60|63|19)$/){$shash{buTYPE} = 'LINUX DEDICATED';} if ($shash{typeID} =~ /^(11|14|22|32|34|36|37|46)$/) {$shash{buTYPE} = 'LINUX FULL';} if ($shash{typeID} =~ /^(44)$/) {$shash{buTYPE} = 'EMAIL MARKETER';} if ($shash{typeID} =~ /^(43)$/) {$shash{buTYPE} = 'TYip1';} if ($shash{typeID} =~ /^(45)$/) {$shash{buTYPE} = 'DDDOMAINS';} if ($shash{typeID} =~ /^(56)$/) {$shash{buTYPE} = 'AT MAIL';} if ($shash{typeID} =~ /^(65|66)$/) {$shash{buTYPE} = 'ENT MAIL';} if ($shash{typeID} =~ /^(1|3)$/) {$shash{buTYPE} = 'LINUX PROD';} if ($shash{buTYPE} eq 'LINUX DEDICATED' || $shash{buTYPE} eq 'LINUX FULL') #if ($shash{buTYPE} eq 'LINUX FULL') { next if (`grep $shash{NAME} $excludes`); my $ip; my $ipchoice=0; print "Doing $shash{NAME}.\n"; my $testport = testport("$shash{intIP}",'1500'); if(!$testport) { $ipchoice=1; $testport = testport("$shash{extIP}",'1500'); } unless ($testport) { log_event("$log/rsync_error.$date_string","Port 1500 closed for $shash{NAME}\n"); next; } if ($ipchoice==0) { $ip = $shash{intIP}; }else{ $ip = $shash{extIP}; } # send_file("$repo/rsyncd.conf","$shash{intIP}","/etc/rsyncd.conf"); check_rsync($shash{NAME},$ip); # do_backup($shash{NAME},$ip,$shash{buTYPE}); } $pm->finish; } $pm->wait_all_children; 

Encoding ForkManager.pm.

 sub start { my ($s,$identification) =@ _; die "Cannot start another process while you are in the child process" if $s->{in_child}; while ($s->{max_proc} && ( keys %{ $s->{processes} } ) >= $s->{max_proc}) { $s->on_wait; $s->wait_one_child(defined $s->{on_wait_period} ? &WNOHANG : undef); }; $s->wait_children; if ($s->{max_proc}) { my $pid=fork(); die "Cannot fork: $!" if !defined $pid; if ($pid) { $s->{processes}->{$pid}=$identification; $s->on_start($pid,$identification); } else { $s->{in_child}=1 if !$pid; } return $pid; } else { $s->{processes}->{$$}=$identification; $s->on_start($$,$identification); return 0; # Simulating the child which returns 0 } } 

Answer 1

You call next inside the child process code. This tries the next iteration for(0..$COUNT) , which then tries fork again, which is not what you want.

You might want to change

  next if (`grep $shash{NAME} $excludes`); 

to

  $pm->finish if (`grep $shash{NAME} $excludes`);