WebSVN – zfs_utils – Diff – /trunk/replication/sync.sample

    use lib dirname( abs_path( __FILE__ ) );
+}
 use YAML::Tiny; # pkg install p5-YAML-Tiny-1.74
 use Data::Dumper;
-use Email::Simple; # cpan install Email::Simple
+#use Email::Simple; # cpan install Email::Simple
 my $cwd = $FindBin::RealBin;
 my $configFileName = $cwd . '/sync.yaml';
 my $replicateScript = $cwd . '/replicate';
       $yaml = YAML::Tiny->read( $filename );
+   }
    return $yaml->[0];
+}
+sub logit {
+   open LOG, ">>/tmp/replicate.log" or die "Could not open replicate.log: $!\n";
+   print LOG join( "\n", @_ ) . "\n";
+   close LOG;
+}
 # this calls gshred which will overwrite the file 3 times, then
 # remove it.
 # NOTE: this will not work on ZFS, since ZFS is CopyOnWrite (COW)
 # runs a command, redirecting stderr to stdout (which it ignores)
 # then returns 0 on success.
 # if error, returns string describing error
 sub runCommand {
    my $command = shift;
+   #logit( $command );
    my $output = qx/$command 2>&1/;
    if ($? == -1) {
       return (-1, "failed to execute: $!" );
    } elsif ($? & 127) {
       return (-1,sprintf "child died with signal %d, %s coredump",
    # if we succeeded, we want to shred the keyfile
    &shredFile( $configuration->{localMachine}->{encryptionKeyPath} ) if -f $configuration->{localMachine}->{encryptionKeyPath};
    return $error;
+}
-# a very simple mailer, using Email::Simple to just get status messages out
+# a very simple mailer, just send information to sendmail
 sub sendMail {
    my ($message, $configuration, $subject ) = @_;
+   if ( $message ) {
-   $configuration->{'email'}->{'notify'} = 'root' unless $configuration->{'email'}->{'notify'};
+      open MAIL,"|sendmail -t" or die "Could not open sendmail: $!\n";
-   die "No message in outgoing message\n" unless $message;
+      print MAIL "To: $configuration->{email}->{notify}\n";
-   my $email = Email::Simple->create(
+      print MAIL "From: $configuration->{email}->{from}\n";
-      header => [
+      print MAIL "Subject: " .
-         To     => $configuration->{'email'}->{'notify'},
-         Subject=> $configuration->{'email'}->{'subject'} . ( $subject ? " - $subject" : '' ),
+                 ($configuration->{'email'}->{'subject'} . ( $subject ? " - $subject" : '' ) ) .
-         From   => $configuration->{'email'}->{'from'}
+                 "\n\n";
-      ],
-      body => $message
+      print MAIL $message;
-   );
-   $message = $email->as_string;
-   if ( $configuration->{'testing'} > 1 ) {
-      print "$message\n";
+      close MAIL;
    } else {
-      `echo '$message' | sendmail $configuration->{'email'}->{'notify'}`;
+      warn "no message in outgoing email\n";
+   }
+#   $message =~ s/\(/\\(/g;
+#   $message =~ s/\)/\\)/g;
+#   $configuration->{'email'}->{'notify'} = 'root' unless $configuration->{'email'}->{'notify'};
+#   die "No message in outgoing message\n" unless $message;
+#   my $email = Email::Simple->create(
+#      header => [
+#         To     => $configuration->{'email'}->{'notify'},
+#         Subject=> $configuration->{'email'}->{'subject'} . ( $subject ? " - $subject" : '' ),
+#         From   => $configuration->{'email'}->{'from'}
+#      ],
+#      body => $message
+#   );
+#   $message = $email->as_string;
+#   #warn "Message is\n$message\n\n";
+#   if ( $configuration->{'testing'} > 1 ) {
+#      print "$message\n";
+#   } else {
+#      `echo '$message' | sendmail $configuration->{'email'}->{'notify'}`;
+#   }
+}
 # checks to see if we should be in maintenance mode
 # if $remoteMachine->{'maintenanceMode'} exists, set mode
 # otherwise, wait localMachine->{'waittime'} minutes, then check
    return 0;
+}
 sub shutdownMachine {
    my $configuration = shift;
-   my $subject = shift;
-   push @_, "Shutting down" if $configuration->{'shutdown'};
-   &sendMail( join( "\n", @_), $configuration, $subject );
-   # do not actually shut down the server unless we are told to
    exit unless $configuration->{'shutdown'};
-   die "Shutting down machine now\n";
+   # do not actually shut down the server unless we are told to
    &runCommand( "poweroff" ) unless $configuration->{'testing'};
+}
 # returns the current time as a string
 sub currentTime {
 # see if remote machine is up by sending one ping. Expect response in 5 seconds
 ( $error,$output) = &checkRemoteUp( $configuration );
 $configuration->{'up'} = ! $error;
 push @status, "remote machine is " . ( $configuration->{'up'} ? 'Up' : 'Down' ) . "\n";
+if ( ! $configuration->{'up'} ) {
-# we can not connect to the remote server, so just shut down
+   # we can not connect to the remote server, so just shut down
-&shutdownMachine( $configuration, "No connection to remote machine", @status ) unless $configuration->{'up'};
+   sendMail( join( "\n", @status ), $configuration, "No connection to remote machine" );
+   &shutdownMachine( $configuration );
+}
 # check for maintenance flags, exit if we should go into mainteance mode
 if ( my $result = &checkMaintenance( $configuration ) ) {
    push @status,$result;
    &sendMail( join( "\n", @status), $configuration, "Maintenance Mode" );
+}
 # try to mount the datasets if they are encrypted
 ($error,$output) = &mountDrives( $configuration );
 if ( $error ) { # could not mount datasets
-   push @status, $error;
+   push @status, $output;
-   &shutdownMachine( $configuration, "Mount Drive Error: [$output]", @status );
+   &sendMail( join( "\n", @status ), $configuration, "Mount Drive Error: [$output]" );
+   &shutdownMachine( $configuration );
+}
-&sendMail( "Backup has been started at " . &currentTime(), $configuration, "Backup Starting" );
+#&sendMail( "Backup has been started at " . &currentTime(), $configuration, "Backup Starting" );
 push @status, &currentTime() . ' Backup started';
 $configuration->{'source'}->{'server'} = $configuration->{'source'}->{'server'} ? $configuration->{'source'}->{'server'} . ':' : '';
 $configuration->{'target'}->{'server'} = $configuration->{'target'}->{'server'} ? $configuration->{'target'}->{'server'} . ':' : '';
 my @flags;
 push @flags, '--dryrun' if $configuration->{'dryrun'};
 push @flags, '--recurse' if $configuration->{'recurse'};
 push @flags, '--verbose' if $configuration->{'verbose'};
 push @flags, '--verbose' if $configuration->{'verbose'} > 1;
-push @flags, "--bwlimit=$configuration->{bandwidth}" if $configuration->{'bandwidt'};
+push @flags, "--bwlimit=$configuration->{bandwidth}" if $configuration->{'bandwidth'};
 push @flags, "--filter='$configuration->{filter}'" if $configuration->{'filter'};
 # For each dataset, let's find the snapshots we need
 foreach my $sourceDir ( keys %{$configuration->{'source'}->{'dataset'}} ) {
+   #print "Working on $sourceDir\n";
    print "Looking for $sourceDir\n" if $configuration->{'testing'} > 2;
    print "syncing to $configuration->{target}->{dataset}\n" if $configuration->{'testing'} > 2;
    my $command = $replicateScript . ' ' . join( ' ', @flags ) . ' ' .
                  '--source=' .
                  $configuration->{'source'}->{'server'} .
                  $configuration->{'source'}->{'dataset'}->{$sourceDir} . '/' . $sourceDir . ' ' .
                  '--target=' .
                  $configuration->{'target'}->{'server'} .
                  $configuration->{'target'}->{'dataset'} . '/' . $sourceDir;
+   #print "Command is $command\n";
    push @status, &currentTime() . " Running $command";
    if ( ! $configuration->{'testing'} ) {
       ($error, $output) = &runCommand( $command );
       push @status, $output;
+   }
    push @status, &currentTime() . " Completed command, with status $error";
+}
+#print "Finished processing\n";
+#print "testing is " . $configuration->{'testing'} . "\n";
 push @status, &currentTime() . ' Backup finished';
 if ($configuration->{'testing'}) {
    print join( "\n", @status ) . "\n";
 } else {
+   #print "Sending final email\n";
+   &sendMail( join( "\n", @status ), $configuration, "Backup Complete" );
+   #print "Running shutdown\n";
-   &shutdownMachine( $configuration, "Backup Complete", @status );
+   &shutdownMachine( $configuration ) if $configuration->{'shutdown'};
+}
 ;

Subversion Repositories zfs_utils

(root)/trunk/replication/sync.sample – Rev 7 → 10