File Coverage

blib/lib/Parallel/Workers/Backend/SSH.pm

Criterion	Covered	Total	%
statement	10	12	83.3
branch			n/a
condition			n/a
subroutine	4	4	100.0
pod			n/a
total	14	16	87.5

package Parallel::Workers::Backend::SSH;

use warnings;
use strict;
use Carp;
use Net::SSH::Perl;
use Data::Dumper;

our (@ISA, @EXPORT, @EXPORT_OK);
@ISA = qw(Exporter);

@EXPORT = ();
@EXPORT_OK = ();

#
sub new {
  my $class = shift;
  my %parms = @_;

  my $self = {user => $parms{user},password=>$parms{pass}, ssh => undef};
  bless $self, $class;
  return $self;
}

sub _open{
  my ($user,$password,$host) = @_;
  my $ssh = Net::SSH::Perl->new($host, {protocol=>'2,1',privileged => 0,compression=>1, options => [
        "BatchMode yes", "RhostsAuthentication no" ]});
  $ssh->login("$user", "$password");
  return $ssh;
}

sub pre {
  my ($this, $id, $host, $cmd ,$params)=@_;
  my $ssh=_open($this->{user},$this->{password},$host);
  my($stdout, $stderr, $exit) = $ssh->cmd($cmd);
  return $stdout;
}

sub do {
  my ($this, $id, $host, $cmd ,$params)=@_;
  print "ssh command ($cmd) open\n" if $Parallel::Workers::WARN;
  my $ssh=_open($this->{user},$this->{password},$host);
  print "ssh command ($cmd) start\n" if $Parallel::Workers::WARN;
  my($stdout, $stderr, $exit) = $ssh->cmd($cmd);
  print "ssh command ($cmd) done\n" if $Parallel::Workers::WARN;
  return $stdout;
}

sub post {
  my ($this, $id, $host, $cmd ,$params)=@_;
  my $ssh=_open( $this->{user},$this->{password},$host);
  my($stdout, $stderr, $exit) = $ssh->cmd($cmd);
  return $stdout;
}

1; # Magic true value required at end of module
__END__