Subversion Repositories zfs_utils

}

}

# grabs the encryption key from the remote server, and uses it to unlock the 

# grabs the encryption key from the remote server, and uses it to unlock the 

# datasets, then mount the drives.

# datasets, then mount the drives.

# a return of '' is success, anything else is an error

# a return of '' is success, anything else is an error

sub mountDrives {

sub mountDrives {

   my $configuration = shift;

   my $configuration = shift;

   return (0, 'No encrypted target found' ) unless defined( $configuration->{'target'}->{'encryptionKeyPath'} ) && $configuration->{'target'}->{'encryptionKeyPath'};

   return (0, 'No encrypted target found' ) unless defined( $configuration->{'target'}->{'encryptionKeyPath'} ) && $configuration->{'target'}->{'encryptionKeyPath'};

   # try to grab the file from the remote machine

   # try to grab the file from the remote machine

   &runCommand( "scp $configuration->{remoteMachine}->{ip}:$configuration->{remoteMachine}->{encryptionKeyPath} $configuration->{localMachine}->{encryptionKeyPath}" );

   &runCommand( "scp $configuration->{remoteMachine}->{ip}:$configuration->{remoteMachine}->{encryptionKeyPath} $configuration->{localMachine}->{encryptionKeyPath}" );

# checks to see if we should be in maintenance mode

# checks to see if we should be in maintenance mode

# if $remoteMachine->{'maintenanceMode'} exists, set mode

# if $remoteMachine->{'maintenanceMode'} exists, set mode

# otherwise, wait localMachine->{'waittime'} minutes, then check

# otherwise, wait localMachine->{'waittime'} minutes, then check

# $localMachine->{'maintenanceMode'}.

# $localMachine->{'maintenanceMode'}.

# if neither exists, begin sync

# if neither exists, begin sync

sub checkMaintenance {

sub checkMaintenance {

   my $configuration = shift;

   my $configuration = shift;

   return 0 unless # exit if maintenanceFlag has not been set at all

   return 0 unless # exit if maintenanceFlag has not been set at all

     ( defined( $configuration->{'target'}->{'maintenanceFlag'} ) && $configuration->{'target'}->{'maintenanceFlag'} ) ||

     ( defined( $configuration->{'target'}->{'maintenanceFlag'} ) && $configuration->{'target'}->{'maintenanceFlag'} ) ||

     ( defined( $configuration->{'source'}->{'maintenanceFlag'} ) && $configuration->{'source'}->{'maintenanceFlag'} );

     ( defined( $configuration->{'source'}->{'maintenanceFlag'} ) && $configuration->{'source'}->{'maintenanceFlag'} );

# returns the current time as a string

# returns the current time as a string

sub currentTime {

sub currentTime {

   my $format = shift;

   my $format = shift;

   # default to YY-MM-DD HH-MM-SS

   # default to YY-MM-DD HH-MM-SS

   use POSIX;

   use POSIX;

   return POSIX::strftime( $format, localtime() );

   return POSIX::strftime( $format, localtime() );

}

}

# verify a remote machine is up and running

# verify a remote machine is up and running

   my ( $label, $filename, $output ) = @_;

   my ( $label, $filename, $output ) = @_;

   if ( $output =~ m/bytes\t(\d+).*seconds\t(\d+)/gms ) { # global, multiline, . matches newlines

   if ( $output =~ m/bytes\t(\d+).*seconds\t(\d+)/gms ) { # global, multiline, . matches newlines

      my $seconds = $2;

      my $seconds = $2;

      my $bytes = $1;

      my $bytes = $1;

      open STATS,">>$filename" or warn "Could not create file $filename: $!\n";

      open STATS,">>$filename" or warn "Could not create file $filename: $!\n";

      close STATS

      close STATS

   } else {

   } else {

      warn "updateStats called with invalid report\n";

      warn "updateStats called with invalid report\n";

   }

   }

}

}

$configuration->{'target'}->{'server'} = $configuration->{'target'}->{'server'} ? $configuration->{'target'}->{'server'} . ':' : '';

$configuration->{'target'}->{'server'} = $configuration->{'target'}->{'server'} ? $configuration->{'target'}->{'server'} . ':' : '';

my @flags;

my @flags;

push @flags, '--dryrun' if $configuration->{'dryrun'};

push @flags, '--dryrun' if $configuration->{'dryrun'};

push @flags, '--recurse' if $configuration->{'recurse'};

push @flags, '--recurse' if $configuration->{'recurse'};

push @flags, "--bwlimit=$configuration->{bandwidth}" if $configuration->{'bandwidth'};

push @flags, "--bwlimit=$configuration->{bandwidth}" if $configuration->{'bandwidth'};

push @flags, "--filter='$configuration->{filter}'" if $configuration->{'filter'};

push @flags, "--filter='$configuration->{filter}'" if $configuration->{'filter'};

# prepend the current working directory to stats if it does not have a path

# prepend the current working directory to stats if it does not have a path

$configuration->{'stats'} = $cwd . "/" . $configuration->{'stats'}

$configuration->{'stats'} = $cwd . "/" . $configuration->{'stats'}

   if $configuration->{'stats'} && $configuration->{'stats'} !~ m/\//;

   if $configuration->{'stats'} && $configuration->{'stats'} !~ m/\//;

# For each dataset, let's find the snapshots we need

# For each dataset, let's find the snapshots we need

                 $configuration->{'target'}->{'dataset'} . '/' . $sourceDir;

                 $configuration->{'target'}->{'dataset'} . '/' . $sourceDir;

   #print "Command is $command\n";

   #print "Command is $command\n";

   push @status, &currentTime() . " Running $command";

   push @status, &currentTime() . " Running $command";

   if ( ! $configuration->{'testing'} ) {

   if ( ! $configuration->{'testing'} ) {

      ($error, $output) = &runCommand( $command );

      ($error, $output) = &runCommand( $command );

      # update stats file if they have requested it

      # update stats file if they have requested it

      &updateStats( $sourceDir, $configuration->{'stats'}, $output ) if $configuration->{'stats'};

      &updateStats( $sourceDir, $configuration->{'stats'}, $output ) if $configuration->{'stats'};

   }

   }

   push @status, &currentTime() . " Completed command, with status $error";

   push @status, &currentTime() . " Completed command, with status $error";

}

}