Merge branch 'master' of https://github.com/jimsalterjrs/sanoid
This commit is contained in:
commit
df69c033d2
26
README.md
26
README.md
|
@ -122,6 +122,32 @@ If ZFS supports resumeable send/receive streams on both the source and target th
|
||||||
|
|
||||||
As of 1.4.18, syncoid also automatically supports and enables resume of interrupted replication when both source and target support this feature.
|
As of 1.4.18, syncoid also automatically supports and enables resume of interrupted replication when both source and target support this feature.
|
||||||
|
|
||||||
|
##### Syncoid Dataset Properties
|
||||||
|
|
||||||
|
+ syncoid:sync
|
||||||
|
|
||||||
|
Available values:
|
||||||
|
|
||||||
|
+ `true` (default if unset)
|
||||||
|
|
||||||
|
This dataset will be synchronised to all hosts.
|
||||||
|
|
||||||
|
+ `false`
|
||||||
|
|
||||||
|
This dataset will not be synchronised to any hosts - it will be skipped. This can be useful for preventing certain datasets from being transferred when recursively handling a tree.
|
||||||
|
|
||||||
|
+ `host1,host2,...`
|
||||||
|
|
||||||
|
A comma separated list of hosts. This dataset will only be synchronised by hosts listed in the property.
|
||||||
|
|
||||||
|
_Note_: this check is performed by the host running `syncoid`, thus the local hostname must be present for inclusion during a push operation // the remote hostname must be present for a pull.
|
||||||
|
|
||||||
|
_Note_: this will also prevent syncoid from handling the dataset if given explicitly on the command line.
|
||||||
|
|
||||||
|
_Note_: syncing a child of a no-sync dataset will currently result in a critical error.
|
||||||
|
|
||||||
|
_Note_: empty properties will be handled as if they were unset.
|
||||||
|
|
||||||
##### Syncoid Command Line Options
|
##### Syncoid Command Line Options
|
||||||
|
|
||||||
+ [source]
|
+ [source]
|
||||||
|
|
88
syncoid
88
syncoid
|
@ -97,6 +97,7 @@ my $targetsudocmd = $targetisroot ? '' : $sudocmd;
|
||||||
my %avail = checkcommands();
|
my %avail = checkcommands();
|
||||||
|
|
||||||
my %snaps;
|
my %snaps;
|
||||||
|
my $exitcode = 0;
|
||||||
|
|
||||||
## break here to call replication individually so that we ##
|
## break here to call replication individually so that we ##
|
||||||
## can loop across children separately, for recursive ##
|
## can loop across children separately, for recursive ##
|
||||||
|
@ -127,7 +128,7 @@ if ($targethost ne '') {
|
||||||
close FH;
|
close FH;
|
||||||
}
|
}
|
||||||
|
|
||||||
exit 0;
|
exit $exitcode;
|
||||||
|
|
||||||
##############################################################################
|
##############################################################################
|
||||||
##############################################################################
|
##############################################################################
|
||||||
|
@ -189,9 +190,27 @@ sub syncdataset {
|
||||||
|
|
||||||
if ($debug) { print "DEBUG: syncing source $sourcefs to target $targetfs.\n"; }
|
if ($debug) { print "DEBUG: syncing source $sourcefs to target $targetfs.\n"; }
|
||||||
|
|
||||||
|
my $sync = getzfsvalue($sourcehost,$sourcefs,$sourceisroot,'syncoid:sync');
|
||||||
|
|
||||||
|
if ($sync eq 'true' || $sync eq '-' || $sync eq '') {
|
||||||
|
# empty is handled the same as unset (aka: '-')
|
||||||
|
# definitely sync this dataset - if a host is called 'true' or '-', then you're special
|
||||||
|
} elsif ($sync eq 'false') {
|
||||||
|
if (!$quiet) { print "INFO: Skipping dataset (syncoid:sync=false): $sourcefs...\n"; }
|
||||||
|
return 0;
|
||||||
|
} else {
|
||||||
|
my $hostid = hostname();
|
||||||
|
my @hosts = split(/,/,$sync);
|
||||||
|
if (!(grep $hostid eq $_, @hosts)) {
|
||||||
|
if (!$quiet) { print "INFO: Skipping dataset (syncoid:sync doesn't include $hostid): $sourcefs...\n"; }
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
# make sure target is not currently in receive.
|
# make sure target is not currently in receive.
|
||||||
if (iszfsbusy($targethost,$targetfs,$targetisroot)) {
|
if (iszfsbusy($targethost,$targetfs,$targetisroot)) {
|
||||||
warn "Cannot sync now: $targetfs is already target of a zfs receive process.\n";
|
warn "Cannot sync now: $targetfs is already target of a zfs receive process.\n";
|
||||||
|
if ($exitcode < 1) { $exitcode = 1; }
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -237,11 +256,16 @@ sub syncdataset {
|
||||||
if (!defined $args{'no-sync-snap'}) {
|
if (!defined $args{'no-sync-snap'}) {
|
||||||
# create a new syncoid snapshot on the source filesystem.
|
# create a new syncoid snapshot on the source filesystem.
|
||||||
$newsyncsnap = newsyncsnap($sourcehost,$sourcefs,$sourceisroot);
|
$newsyncsnap = newsyncsnap($sourcehost,$sourcefs,$sourceisroot);
|
||||||
|
if (!$newsyncsnap) {
|
||||||
|
# we already whined about the error
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
# we don't want sync snapshots created, so use the newest snapshot we can find.
|
# we don't want sync snapshots created, so use the newest snapshot we can find.
|
||||||
$newsyncsnap = getnewestsnapshot($sourcehost,$sourcefs,$sourceisroot);
|
$newsyncsnap = getnewestsnapshot($sourcehost,$sourcefs,$sourceisroot);
|
||||||
if ($newsyncsnap eq 0) {
|
if ($newsyncsnap eq 0) {
|
||||||
warn "CRITICAL: no snapshots exist on source $sourcefs, and you asked for --no-sync-snap.\n";
|
warn "CRITICAL: no snapshots exist on source $sourcefs, and you asked for --no-sync-snap.\n";
|
||||||
|
if ($exitcode < 1) { $exitcode = 1; }
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -270,6 +294,11 @@ sub syncdataset {
|
||||||
}
|
}
|
||||||
my $oldestsnap = getoldestsnapshot(\%snaps);
|
my $oldestsnap = getoldestsnapshot(\%snaps);
|
||||||
if (! $oldestsnap) {
|
if (! $oldestsnap) {
|
||||||
|
if (defined ($args{'no-sync-snap'}) ) {
|
||||||
|
# we already whined about the missing snapshots
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
# getoldestsnapshot() returned false, so use new sync snapshot
|
# getoldestsnapshot() returned false, so use new sync snapshot
|
||||||
if ($debug) { print "DEBUG: getoldestsnapshot() returned false, so using $newsyncsnap.\n"; }
|
if ($debug) { print "DEBUG: getoldestsnapshot() returned false, so using $newsyncsnap.\n"; }
|
||||||
$oldestsnap = $newsyncsnap;
|
$oldestsnap = $newsyncsnap;
|
||||||
|
@ -298,10 +327,14 @@ sub syncdataset {
|
||||||
# make sure target is (still) not currently in receive.
|
# make sure target is (still) not currently in receive.
|
||||||
if (iszfsbusy($targethost,$targetfs,$targetisroot)) {
|
if (iszfsbusy($targethost,$targetfs,$targetisroot)) {
|
||||||
warn "Cannot sync now: $targetfs is already target of a zfs receive process.\n";
|
warn "Cannot sync now: $targetfs is already target of a zfs receive process.\n";
|
||||||
|
if ($exitcode < 1) { $exitcode = 1; }
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
system($synccmd) == 0
|
system($synccmd) == 0 or do {
|
||||||
or die "CRITICAL ERROR: $synccmd failed: $?";
|
warn "CRITICAL ERROR: $synccmd failed: $?";
|
||||||
|
if ($exitcode < 2) { $exitcode = 2; }
|
||||||
|
return 0;
|
||||||
|
};
|
||||||
|
|
||||||
# now do an -I to the new sync snapshot, assuming there were any snapshots
|
# now do an -I to the new sync snapshot, assuming there were any snapshots
|
||||||
# other than the new sync snapshot to begin with, of course - and that we
|
# other than the new sync snapshot to begin with, of course - and that we
|
||||||
|
@ -324,6 +357,7 @@ sub syncdataset {
|
||||||
# make sure target is (still) not currently in receive.
|
# make sure target is (still) not currently in receive.
|
||||||
if (iszfsbusy($targethost,$targetfs,$targetisroot)) {
|
if (iszfsbusy($targethost,$targetfs,$targetisroot)) {
|
||||||
warn "Cannot sync now: $targetfs is already target of a zfs receive process.\n";
|
warn "Cannot sync now: $targetfs is already target of a zfs receive process.\n";
|
||||||
|
if ($exitcode < 1) { $exitcode = 1; }
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -331,9 +365,12 @@ sub syncdataset {
|
||||||
if ($debug) { print "DEBUG: $synccmd\n"; }
|
if ($debug) { print "DEBUG: $synccmd\n"; }
|
||||||
|
|
||||||
if ($oldestsnap ne $newsyncsnap) {
|
if ($oldestsnap ne $newsyncsnap) {
|
||||||
system($synccmd) == 0
|
my $ret = system($synccmd);
|
||||||
or warn "CRITICAL ERROR: $synccmd failed: $?";
|
if ($ret != 0) {
|
||||||
|
warn "CRITICAL ERROR: $synccmd failed: $?";
|
||||||
|
if ($exitcode < 1) { $exitcode = 1; }
|
||||||
return 0;
|
return 0;
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
if (!$quiet) { print "INFO: no incremental sync needed; $oldestsnap is already the newest available snapshot.\n"; }
|
if (!$quiet) { print "INFO: no incremental sync needed; $oldestsnap is already the newest available snapshot.\n"; }
|
||||||
}
|
}
|
||||||
|
@ -357,8 +394,11 @@ sub syncdataset {
|
||||||
|
|
||||||
if (!$quiet) { print "Resuming interrupted zfs send/receive from $sourcefs to $targetfs (~ $disp_pvsize remaining):\n"; }
|
if (!$quiet) { print "Resuming interrupted zfs send/receive from $sourcefs to $targetfs (~ $disp_pvsize remaining):\n"; }
|
||||||
if ($debug) { print "DEBUG: $synccmd\n"; }
|
if ($debug) { print "DEBUG: $synccmd\n"; }
|
||||||
system("$synccmd") == 0
|
system("$synccmd") == 0 or do {
|
||||||
or die "CRITICAL ERROR: $synccmd failed: $?";
|
warn "CRITICAL ERROR: $synccmd failed: $?";
|
||||||
|
if ($exitcode < 2) { $exitcode = 2; }
|
||||||
|
return 0;
|
||||||
|
};
|
||||||
|
|
||||||
# a resumed transfer will only be done to the next snapshot,
|
# a resumed transfer will only be done to the next snapshot,
|
||||||
# so do an normal sync cycle
|
# so do an normal sync cycle
|
||||||
|
@ -386,6 +426,7 @@ sub syncdataset {
|
||||||
# make sure target is (still) not currently in receive.
|
# make sure target is (still) not currently in receive.
|
||||||
if (iszfsbusy($targethost,$targetfs,$targetisroot)) {
|
if (iszfsbusy($targethost,$targetfs,$targetisroot)) {
|
||||||
warn "Cannot sync now: $targetfs is already target of a zfs receive process.\n";
|
warn "Cannot sync now: $targetfs is already target of a zfs receive process.\n";
|
||||||
|
if ($exitcode < 1) { $exitcode = 1; }
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -418,8 +459,11 @@ sub syncdataset {
|
||||||
|
|
||||||
if (!$quiet) { print "Sending incremental $sourcefs\@$matchingsnap ... $newsyncsnap (~ $disp_pvsize):\n"; }
|
if (!$quiet) { print "Sending incremental $sourcefs\@$matchingsnap ... $newsyncsnap (~ $disp_pvsize):\n"; }
|
||||||
if ($debug) { print "DEBUG: $synccmd\n"; }
|
if ($debug) { print "DEBUG: $synccmd\n"; }
|
||||||
system("$synccmd") == 0
|
system("$synccmd") == 0 or do {
|
||||||
or die "CRITICAL ERROR: $synccmd failed: $?";
|
warn "CRITICAL ERROR: $synccmd failed: $?";
|
||||||
|
if ($exitcode < 2) { $exitcode = 2; }
|
||||||
|
return 0;
|
||||||
|
};
|
||||||
|
|
||||||
# restore original readonly value to target after sync complete
|
# restore original readonly value to target after sync complete
|
||||||
# dyking this functionality out for the time being due to buggy mount/unmount behavior
|
# dyking this functionality out for the time being due to buggy mount/unmount behavior
|
||||||
|
@ -589,7 +633,7 @@ sub checkcommands {
|
||||||
if ($debug) { print "DEBUG: checking availability of $mbuffercmd on source...\n"; }
|
if ($debug) { print "DEBUG: checking availability of $mbuffercmd on source...\n"; }
|
||||||
$avail{'sourcembuffer'} = `$sourcessh $lscmd $mbuffercmd 2>/dev/null`;
|
$avail{'sourcembuffer'} = `$sourcessh $lscmd $mbuffercmd 2>/dev/null`;
|
||||||
if ($avail{'sourcembuffer'} eq '') {
|
if ($avail{'sourcembuffer'} eq '') {
|
||||||
print "WARN: $mbuffercmd not available on source $s - sync will continue without source buffering.\n";
|
if (!$quiet) { print "WARN: $mbuffercmd not available on source $s - sync will continue without source buffering.\n"; }
|
||||||
$avail{'sourcembuffer'} = 0;
|
$avail{'sourcembuffer'} = 0;
|
||||||
} else {
|
} else {
|
||||||
$avail{'sourcembuffer'} = 1;
|
$avail{'sourcembuffer'} = 1;
|
||||||
|
@ -598,7 +642,7 @@ sub checkcommands {
|
||||||
if ($debug) { print "DEBUG: checking availability of $mbuffercmd on target...\n"; }
|
if ($debug) { print "DEBUG: checking availability of $mbuffercmd on target...\n"; }
|
||||||
$avail{'targetmbuffer'} = `$targetssh $lscmd $mbuffercmd 2>/dev/null`;
|
$avail{'targetmbuffer'} = `$targetssh $lscmd $mbuffercmd 2>/dev/null`;
|
||||||
if ($avail{'targetmbuffer'} eq '') {
|
if ($avail{'targetmbuffer'} eq '') {
|
||||||
print "WARN: $mbuffercmd not available on target $t - sync will continue without target buffering.\n";
|
if (!$quiet) { print "WARN: $mbuffercmd not available on target $t - sync will continue without target buffering.\n"; }
|
||||||
$avail{'targetmbuffer'} = 0;
|
$avail{'targetmbuffer'} = 0;
|
||||||
} else {
|
} else {
|
||||||
$avail{'targetmbuffer'} = 1;
|
$avail{'targetmbuffer'} = 1;
|
||||||
|
@ -610,14 +654,14 @@ sub checkcommands {
|
||||||
$avail{'localmbuffer'} = `$lscmd $mbuffercmd 2>/dev/null`;
|
$avail{'localmbuffer'} = `$lscmd $mbuffercmd 2>/dev/null`;
|
||||||
if ($avail{'localmbuffer'} eq '') {
|
if ($avail{'localmbuffer'} eq '') {
|
||||||
$avail{'localmbuffer'} = 0;
|
$avail{'localmbuffer'} = 0;
|
||||||
print "WARN: $mbuffercmd not available on local machine - sync will continue without local buffering.\n";
|
if (!$quiet) { print "WARN: $mbuffercmd not available on local machine - sync will continue without local buffering.\n"; }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if ($debug) { print "DEBUG: checking availability of $pvcmd on local machine...\n"; }
|
if ($debug) { print "DEBUG: checking availability of $pvcmd on local machine...\n"; }
|
||||||
$avail{'localpv'} = `$lscmd $pvcmd 2>/dev/null`;
|
$avail{'localpv'} = `$lscmd $pvcmd 2>/dev/null`;
|
||||||
if ($avail{'localpv'} eq '') {
|
if ($avail{'localpv'} eq '') {
|
||||||
print "WARN: $pvcmd not available on local machine - sync will continue without progress bar.\n";
|
if (!$quiet) { print "WARN: $pvcmd not available on local machine - sync will continue without progress bar.\n"; }
|
||||||
$avail{'localpv'} = 0;
|
$avail{'localpv'} = 0;
|
||||||
} else {
|
} else {
|
||||||
$avail{'localpv'} = 1;
|
$avail{'localpv'} = 1;
|
||||||
|
@ -745,7 +789,7 @@ sub getoldestsnapshot {
|
||||||
# must not have had any snapshots on source - luckily, we already made one, amirite?
|
# must not have had any snapshots on source - luckily, we already made one, amirite?
|
||||||
if (defined ($args{'no-sync-snap'}) ) {
|
if (defined ($args{'no-sync-snap'}) ) {
|
||||||
# well, actually we set --no-sync-snap, so no we *didn't* already make one. Whoops.
|
# well, actually we set --no-sync-snap, so no we *didn't* already make one. Whoops.
|
||||||
die "CRIT: --no-sync-snap is set, and getoldestsnapshot() could not find any snapshots on source!\n";
|
warn "CRIT: --no-sync-snap is set, and getoldestsnapshot() could not find any snapshots on source!\n";
|
||||||
}
|
}
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
@ -754,7 +798,7 @@ sub getnewestsnapshot {
|
||||||
my $snaps = shift;
|
my $snaps = shift;
|
||||||
foreach my $snap ( sort { $snaps{'source'}{$b}{'creation'}<=>$snaps{'source'}{$a}{'creation'} } keys %{ $snaps{'source'} }) {
|
foreach my $snap ( sort { $snaps{'source'}{$b}{'creation'}<=>$snaps{'source'}{$a}{'creation'} } keys %{ $snaps{'source'} }) {
|
||||||
# return on first snap found - it's the newest
|
# return on first snap found - it's the newest
|
||||||
print "NEWEST SNAPSHOT: $snap\n";
|
if (!$quiet) { print "NEWEST SNAPSHOT: $snap\n"; }
|
||||||
return $snap;
|
return $snap;
|
||||||
}
|
}
|
||||||
# must not have had any snapshots on source - looks like we'd better create one!
|
# must not have had any snapshots on source - looks like we'd better create one!
|
||||||
|
@ -767,6 +811,7 @@ sub getnewestsnapshot {
|
||||||
# we also probably need an argument to mute this WARN, for people who deliberately exclude
|
# we also probably need an argument to mute this WARN, for people who deliberately exclude
|
||||||
# datasets from recursive replication this way.
|
# datasets from recursive replication this way.
|
||||||
warn "WARN: --no-sync-snap is set, and getnewestsnapshot() could not find any snapshots on source for current dataset. Continuing.\n";
|
warn "WARN: --no-sync-snap is set, and getnewestsnapshot() could not find any snapshots on source for current dataset. Continuing.\n";
|
||||||
|
if ($exitcode < 2) { $exitcode = 2; }
|
||||||
}
|
}
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
@ -784,7 +829,7 @@ sub buildsynccmd {
|
||||||
$synccmd = "$sendcmd |";
|
$synccmd = "$sendcmd |";
|
||||||
# avoid confusion - accept either source-bwlimit or target-bwlimit as the bandwidth limiting option here
|
# avoid confusion - accept either source-bwlimit or target-bwlimit as the bandwidth limiting option here
|
||||||
my $bwlimit = '';
|
my $bwlimit = '';
|
||||||
if (length $args{'bwlimit'}) {
|
if (length $args{'source-bwlimit'}) {
|
||||||
$bwlimit = $args{'source-bwlimit'};
|
$bwlimit = $args{'source-bwlimit'};
|
||||||
} elsif (length $args{'target-bwlimit'}) {
|
} elsif (length $args{'target-bwlimit'}) {
|
||||||
$bwlimit = $args{'target-bwlimit'};
|
$bwlimit = $args{'target-bwlimit'};
|
||||||
|
@ -890,7 +935,7 @@ sub pruneoldsyncsnaps {
|
||||||
$prunecmd = escapeshellparam($prunecmd);
|
$prunecmd = escapeshellparam($prunecmd);
|
||||||
}
|
}
|
||||||
system("$rhost $prunecmd") == 0
|
system("$rhost $prunecmd") == 0
|
||||||
or warn "CRITICAL ERROR: $rhost $prunecmd failed: $?";
|
or warn "WARNING: $rhost $prunecmd failed: $?";
|
||||||
$prunecmd = '';
|
$prunecmd = '';
|
||||||
$counter = 0;
|
$counter = 0;
|
||||||
}
|
}
|
||||||
|
@ -921,6 +966,7 @@ sub getmatchingsnapshot {
|
||||||
}
|
}
|
||||||
|
|
||||||
# if we got this far, we failed to find a matching snapshot.
|
# if we got this far, we failed to find a matching snapshot.
|
||||||
|
if ($exitcode < 2) { $exitcode = 2; }
|
||||||
|
|
||||||
print "\n";
|
print "\n";
|
||||||
print "CRITICAL ERROR: Target $targetfs exists but has no snapshots matching with $sourcefs!\n";
|
print "CRITICAL ERROR: Target $targetfs exists but has no snapshots matching with $sourcefs!\n";
|
||||||
|
@ -953,8 +999,12 @@ sub newsyncsnap {
|
||||||
my %date = getdate();
|
my %date = getdate();
|
||||||
my $snapname = "syncoid\_$identifier$hostid\_$date{'stamp'}";
|
my $snapname = "syncoid\_$identifier$hostid\_$date{'stamp'}";
|
||||||
my $snapcmd = "$rhost $mysudocmd $zfscmd snapshot $fsescaped\@$snapname\n";
|
my $snapcmd = "$rhost $mysudocmd $zfscmd snapshot $fsescaped\@$snapname\n";
|
||||||
system($snapcmd) == 0
|
system($snapcmd) == 0 or do {
|
||||||
or die "CRITICAL ERROR: $snapcmd failed: $?";
|
warn "CRITICAL ERROR: $snapcmd failed: $?";
|
||||||
|
if ($exitcode < 2) { $exitcode = 2; }
|
||||||
|
return 0;
|
||||||
|
};
|
||||||
|
|
||||||
return $snapname;
|
return $snapname;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue