RepoMirrors
/
mars
mirror of https://github.com/schoebel/mars
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

marsadm: workaround split brain detection races

This commit is contained in:
Thomas Schoebel-Theuer 2018-09-11 08:27:18 +02:00
parent 1616b620c7
commit 6c0aa577ee
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
userspace/marsadm
View File

@ -1434,14 +1434,22 @@ sub detect_splitbrain {
# dynamic programming # dynamic programming
return $detected_splits{$res} if defined($detected_splits{$res}); return $detected_splits{$res} if defined($detected_splits{$res});
my $basedir = "$mars/resource-$res"; my $basedir = "$mars/resource-$res";
my $retry = 2;
my $ok = 1; my $ok = 1;
my @list = glob("$mars/resource-$res/replay-*"); my @list = glob("$mars/resource-$res/replay-*");
my @hosts = map { $_ =~ s:.*/replay-::; $_ } @list; my @hosts = map { $_ =~ s:.*/replay-::; $_ } @list;
AGAIN:
foreach my $host1 (@hosts) { foreach my $host1 (@hosts) {
foreach my $host2 (@hosts) { foreach my $host2 (@hosts) {
next if $host1 ge $host2; next if $host1 ge $host2;
my ($point, $split, $size1, $size2) = get_common_ancestor($basedir, $host1, $host2); my ($point, $split, $size1, $size2) = get_common_ancestor($basedir, $host1, $host2);
if ($split) { if ($split) {
# Workaround races.
if ($retry > 0) {
$retry--;
sleep(2);
next AGAIN;
}
$ok = 0; $ok = 0;
if ($do_report) { if ($do_report) {
my $age = ""; my $age = "";