tange/parallel
1
0
Fork 0
mirror of https://git.savannah.gnu.org/git/parallel.git synced 2024-11-22 14:07:55 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

parallel: test distribute jobs round robin between --sshlogins.

Browse source
This commit is contained in:
Ole Tange 2013-05-07 01:37:05 +02:00
parent ee30290b9a
commit 2b48812915
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/parallel
View file

@ -1289,6 +1289,7 @@ sub start_more_jobs {
# Returns: # Returns:
# number of jobs started # number of jobs started
my $jobs_started = 0; my $jobs_started = 0;
my $jobs_started_this_round = 0;
if($Global::start_no_new_jobs) { if($Global::start_no_new_jobs) {
return $jobs_started; return $jobs_started;
} }
@ -1301,18 +1302,17 @@ sub start_more_jobs {
} }
} }
} }
my $sleep = 0.0001; # 0.01 ms - better performance on highend do {
$jobs_started_this_round = 0;
for my $sshlogin (values %Global::host) { for my $sshlogin (values %Global::host) {
debug("Running jobs before on ".$sshlogin->string().": ".$sshlogin->jobs_running()."\n"); debug("Running jobs before on ".$sshlogin->string().": ".$sshlogin->jobs_running()."\n");
while ($sshlogin->jobs_running() < $sshlogin->max_jobs_running()) { if ($sshlogin->jobs_running() < $sshlogin->max_jobs_running()) {
if($opt::load and $sshlogin->loadavg_too_high()) { if($opt::load and $sshlogin->loadavg_too_high()) {
# The load is too high or unknown # The load is too high or unknown
$sleep = ::reap_usleep($sleep);
next; next;
} }
if($opt::noswap and $sshlogin->swapping()) { if($opt::noswap and $sshlogin->swapping()) {
# The server is swapping # The server is swapping
$sleep = ::reap_usleep($sleep);
next; next;
} }
if($sshlogin->too_fast_remote_login()) { if($sshlogin->too_fast_remote_login()) {
@ -1333,10 +1333,13 @@ sub start_more_jobs {
$sshlogin->inc_jobs_running(); $sshlogin->inc_jobs_running();
$sshlogin->set_last_login_at(::now()); $sshlogin->set_last_login_at(::now());
$jobs_started++; $jobs_started++;
$jobs_started_this_round++;
} }
debug("Running jobs after on ".$sshlogin->string().": ".$sshlogin->jobs_running() debug("Running jobs after on ".$sshlogin->string().": ".$sshlogin->jobs_running()
." of ".$sshlogin->max_jobs_running() ."\n"); ." of ".$sshlogin->max_jobs_running() ."\n");
} }
} while($jobs_started_this_round);
return $jobs_started; return $jobs_started;
} }