}
for (@res) {
if (ref $chan) {
- dbg("send: $_");
$chan->send($_);
} elsif (isdbg('cron')) {
dbg("$pkg::spawn_cmd: $_");
diffms($pkg, "::spawn_cmd", $line, $t0, scalar @res) if isdbg('progress');
}
);
+ return ();
}
# do an rcmd to another cluster from the crontab
# $ifh is "global" and should not be closed
- dbg("DXUser::readinjson $count record headers read from $fn in ". _diffms($ta) . " mS");
+ LogDbg('DXUser',"DXUser::readinjson $count record headers read from $fn in ". _diffms($ta) . " mS");
return $totusers = $count;
}
}
$ofh->close;
- dbg("DXUser::writeoutjson $count records written to $ofn in ". _diffms($ta) . " mS");
+ LogDbg('DXUser',"DXUser::writeoutjson $count records written to $ofn in ". _diffms($ta) . " mS");
return $count;
}
1;