Lines Matching refs:sshlogin
105 if($opt::filter_hosts and (@opt::sshlogin or @opt::sshloginfile)) {
132 for my $sshlogin (values %Global::host) {
133 $sshlogin->max_jobs_running();
651 "sshlogin|S=s" => \@opt::sshlogin,
898 if(@opt::sshlogin) { @Global::sshlogin = @opt::sshlogin; }
1679 for my $sshlogin (values %Global::host) {
1680 $sshlogin->set_max_jobs_running(undef);
1695 @Global::sshlogin = ();
1715 for my $sshlogin (values %Global::host) {
1720 debug("run", "Running jobs before on ", $sshlogin->string(), ": ",
1721 $sshlogin->jobs_running(), "\n");
1722 if ($sshlogin->jobs_running() < $sshlogin->max_jobs_running()) {
1723 if($opt::load and $sshlogin->loadavg_too_high()) {
1727 if($opt::noswap and $sshlogin->swapping()) {
1731 if($sshlogin->too_fast_remote_login()) {
1739 debug("run", $sshlogin->string(), " has ", $sshlogin->jobs_running(),
1740 " out of ", $sshlogin->max_jobs_running(),
1742 if(start_another_job($sshlogin) == 0) {
1744 debug("run","No jobs started on ", $sshlogin->string(), "\n");
1747 $sshlogin->inc_jobs_running();
1748 $sshlogin->set_last_login_at(::now());
1752 debug("run","Running jobs after on ", $sshlogin->string(), ": ",
1753 $sshlogin->jobs_running(), " of ",
1754 $sshlogin->max_jobs_running(), "\n");
1783 my $sshlogin = shift;
1795 $job = get_job_with_sshlogin($sshlogin);
1799 $sshlogin->string(), "\n");
1805 debug("start", "Command to run on '", $job->sshlogin()->string(), "': '",
1819 my $max = $sshlogin->max_jobs_running();
1824 $sshlogin->set_max_jobs_running($max);
1964 my %sshlogin = map { $_ eq ":" ? ($_=>"local") : ($_=>$_) } @workers;
1970 $workerno{$w}.":".$sshlogin{$w} ." / ".
1986 $sshlogin{$_}, $running, $completed,
2013 $sshlogin{$_},
2041 $sshlogin{$_}, $Global::host{$_}->jobs_running(),
2051 $sshlogin{$_}, $Global::host{$_}->jobs_running(),
2071 $sshlogin{$_},
2175 my $sshlogin = shift;
2182 if($sshlogin->in_hostgroups($job->hostgroups())) {
2208 return get_job_with_sshlogin($sshlogin);
2213 $job->set_sshlogin($sshlogin);
2230 $nextjob = get_job_with_sshlogin($sshlogin);
2289 push @Global::sshlogin, $_;
2299 if(not @Global::sshlogin) { @Global::sshlogin = (":"); }
2300 for my $sshlogin (@Global::sshlogin) {
2302 for my $s (split /,/, $sshlogin) {
2314 my $sshlogin = SSHLogin->new($ncpu_sshlogin_string);
2315 my $sshlogin_string = $sshlogin->string();
2318 push @allowed_hostgroups, $sshlogin->hostgroups();
2326 if($sshlogin->{'ncpus'}) {
2328 $Global::host{$sshlogin_string}->set_ncpus($sshlogin->ncpus());
2334 $sshlogin->set_maxlength(Limits::Command::max_length());
2337 $sshlogin->set_maxlength(int(Limits::Command::max_length()/2));
2340 ::min($Global::minimal_command_line_length, $sshlogin->maxlength());
2341 $Global::host{$sshlogin_string} = $sshlogin;
2345 while (my ($string, $sshlogin) = each %Global::host) {
2346 if(not $sshlogin->in_hostgroups(@allowed_hostgroups)) {
2385 for my $sshlogin (values %Global::host) {
2386 if($sshlogin->string() eq ":") { next }
2393 $cmd .= $sshlogin->rsync_transfer_cmd($file,$workdir) . "&";
2406 for my $sshlogin (values %Global::host) {
2407 if($sshlogin->string() eq ":") { next }
2409 $cmd .= $sshlogin->cleanup_cmd($file,$workdir)."&";
2420 while (my ($host, $sshlogin) = each %Global::host) {
2423 my $sshcmd = "true $host;" . $sshlogin->sshcommand()." ".$sshlogin->serverlogin();
2525 while (my ($sshlogin, $obj) = each %Global::host) {
2526 if($sshlogin eq ":") { next }
2527 $ncpus{$sshlogin} or ::die_bug("ncpus missing: ".$obj->serverlogin());
2528 $ncores{$sshlogin} or ::die_bug("ncores missing: ".$obj->serverlogin());
2529 $time_to_login{$sshlogin} or ::die_bug("time_to_login missing: ".$obj->serverlogin());
2530 $maxlen{$sshlogin} or ::die_bug("maxlen missing: ".$obj->serverlogin());
2532 $obj->set_ncpus($ncpus{$sshlogin});
2534 $obj->set_ncpus($ncores{$sshlogin});
2536 $obj->set_time_to_login($time_to_login{$sshlogin});
2537 $obj->set_maxlength($maxlen{$sshlogin});
2540 int($maxlen{$sshlogin}/2));
2541 ::debug("init", "Timing from -S:$sshlogin ncpus:",$ncpus{$sshlogin},
2542 " ncores:", $ncores{$sshlogin},
2543 " time_to_login:", $time_to_login{$sshlogin},
2544 " maxlen:", $maxlen{$sshlogin},
2612 my $sshlogin = $Global::host{$host};
2621 "--tagstring ".shell_quote_scalar($sshlogin->string()) : ""),
2622 " -S ", shell_quote_scalar($sshlogin->string())," ",
2626 "--tagstring ".shell_quote_scalar($sshlogin->string()) : ""),
2627 " -S ", shell_quote_scalar($sshlogin->string())," ",
2726 my $sshlogin = $job->sshlogin();
2727 $sshlogin->dec_jobs_running();
2728 $sshlogin->inc_jobs_completed();
3791 for my $sshlogin (values %Global::host) {
3792 $sshlogin->set_max_loadavg(undef);
5365 my $sshlogin = shift;
5366 return $self->{'failed'}{$sshlogin};
5374 return $self->{'failed'}{$self->sshlogin()};
5380 my $sshlogin = shift;
5381 $self->{'failed'}{$sshlogin}++;
5387 $self->{'failed'}{$self->sshlogin()}++;
5393 my $sshlogin = shift;
5394 delete $self->{'failed'}{$sshlogin};
5400 delete $self->{'failed'}{$self->sshlogin()};
5518 my $sshlogin = shift;
5519 $self->{'sshlogin'} = $sshlogin;
5524 sub sshlogin { subroutine
5536 my $sshlogin = $self->sshlogin();
5537 my $sshcmd = $sshlogin->sshcommand();
5538 my $serverlogin = $sshlogin->serverlogin();
5658 my $sshlogin = $self->sshlogin();
5661 push @pre, $sshlogin->rsync_transfer_cmd($file,$workdir).";";
5693 my $sshlogin = $self->sshlogin();
5694 my $sshcmd = $sshlogin->sshcommand();
5695 my $serverlogin = $sshlogin->serverlogin();
5723 $pre .= "mkdir -p $basedir$cd; ".$sshlogin->rsync()." $rsync_cd $rsync_opt $serverlogin:".
5734 my $sshlogin = $self->sshlogin();
5735 my $sshcmd = $sshlogin->sshcommand();
5736 my $serverlogin = $sshlogin->serverlogin();
5742 $cleancmd .= $sshlogin->cleanup_cmd($file,$workdir).";";
5885 and $job->sshlogin()->string() eq ":") {
6221 join("\t", $self->seq(), $self->sshlogin()->string(),