return '' if (&IsParam("noSHM"));
if (shmread($key,$retval,$position,$size)) {
+ &DEBUG("shmRead($key): $retval");
return $retval;
} else {
&ERROR("shmRead: failed: $!");
$str = $read ."||". $str;
}
- if (!shmwrite($key, '', $position, $size)) {
+ if (!shmwrite($key, $str, $position, $size)) {
+ &DEBUG("shmWrite($key, $str)");
&ERROR("shmWrite: failed: $!");
}
}
if ($count > 3) { # 3 seconds.
my $list = join(', ', keys %forked);
if (defined $who) {
- &msg($who, "exceeded allowed forked count: $list");
+ &msg($who, "exceeded allowed forked count (shm $shm): $list");
} else {
- &status("Fork: I ran too many forked processes :) Giving up $name.");
+ &status("Fork: I ran too many forked processes :) Giving up $name. Shm: $shm");
}
return 0;
my $time;
my $shmmsg = &shmRead($shm);
- $shmmsg =~ s/\0//g; # remove padded \0's.
+ # remove padded \0's.
+ $shmmsg =~ s/\0//g;
return if (length($shmmsg) == 0);
if ($shmmsg =~ s/^(\S+):(\d+):(\d+): //) {
my $n = $1;