File Coverage

blib/lib/MMM/Sync/Rsync.pm

Criterion	Covered	Total	%
statement	22	41	53.6
branch	7	24	29.1
condition	1	8	12.5
subroutine	3	5	60.0
pod	1	1	100.0
total	34	79	43.0

package MMM::Sync::Rsync;

use strict;
use warnings;
our @ISA = qw(MMM::Sync);

=head1 NAME

MMM::Sync::Rsync

=cut

sub buildcmd {
    my ($self) = @_;

    my @command = ('rsync');

    if ($self->{options}{rsync_defaults}) {
        push(@command, split(/ +/, $self->{options}{rsync_defaults}));
    } else { push(@command, '-aH'); }

    if ($self->{options}{rsync_opts}) {
        push(@command, split(/ +/, $self->{options}{rsync_opts}));
    }

    if ($self->{options}{exclude}) {
        foreach ( map { split( m/ /, $_ ) } $self->{options}{exclude} ) {
            push( @command, '--exclude', $_ );
        }
    }

    my %mo = (
        partialdir => 'partial-dir',
        tempdir => 'temp-dir',
    );
    push(@command, map {
        $self->{options}{$_}
            ? '--' . ($mo{$_} || $_)
            : ()
        } (qw(delete-after delete delete-excluded)));
    push(@command, map {
        $self->{options}{$_}
            ? ('--' . ($mo{$_} || $_), $self->{options}{$_})
            : ()
        } (qw(partialdir tempdir))
    );
    push(@command, '--partial') if ($self->{options}{partialdir});

    push(@command, '-e', 'ssh') if ($self->{options}{use_ssh});

    push( @command,
        $self->{source},
        $self->{dest}
    );

    $ENV{RSYNC_PASSWORD} = $self->{options}{password} || '-'; # Avoid passwd prompt

    return @command;
}

sub _analyze_output {
    my ($self, $src, $line) = @_;
    if ($src eq 'STDERR') {
        return $line;
    } elsif ($line =~ /vanished|error|permission denied/i) {
        return $line
    } else {
        return;
    }
}

sub _exitcode {
    my ($self, $exitstatus) = @_;

    return 0 if (! $exitstatus);
    # Handle system exit code
    # if (grep { ($? & 127) == $_ } ()) {
    # }

    # Rsync exit code - no way to retry
    if (
        grep { ( $exitstatus ) == $_ } (
            1,    # Syntax or usage error
            2,    # Protocol incompatibility
            20,    # SIGUSR1 ou SIGINT reçu
        )
      )
    {
        return ( 2 );
    }

    # This is not a failure, but normal state
    if (
        grep { ( $exitstatus ) == $_ } (
            25,    # The --max-delete limit stopped deletions
        )
      )
    {
        return ( 0 );
    }
    return ( 1 );
}

1;

__END__