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

marsadm: new command shutdown

This commit is contained in:
Thomas Schoebel-Theuer 2020-05-27 11:29:59 +02:00
parent ae686076fc
commit 394459083d
1 changed files with 44 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
userspace/marsadm
View File

@ -32,6 +32,7 @@ umask 0077;
# global constants
my $gate_code = "0x8";
my $gate_fail = "-108"; # -ESHUTDOWN
##################################################################
@ -7216,7 +7217,7 @@ sub prosumer_phase2 {
foreach my $peer (split("\\+", $minus_prosumers)) {
lprint "Killing prosumer at '$peer'\n";
my $lnk = "$mars/resource-$res/todo-$peer/gate-mask";
set_link("-1", $lnk);
set_link($gate_fail, $lnk);
$lnk = "$mars/resource-$res/todo-$peer/kill-device";
set_link("1", $lnk);
}
@ -7318,6 +7319,38 @@ sub prosumer_phase6 {
return $fail;
}
sub prosumer_shutdown {
my ($cmd, $res) = @_;
my $old_prosumers = _get_prosumer(@_);
my $new_prosumers = $old_prosumers;
if ($cmd_suffix{$cmd}) {
$new_prosumers = parse_list_spec($cmd_suffix{$cmd}, $old_prosumers, $host);
}
if ($new_prosumers eq "(none)") {
lprint "Nothing to do for prosumer $new_prosumers.\n";
return;
}
if ($new_prosumers eq "(local)") {
ldie "Cannot shutdown local devices\n" if !$force;
$new_prosumers = $host;
lwarn "TRYING to shutdown local device on '$host'\n";
}
if ($new_prosumers =~ m/[+]/) {
lwarn "EXPERIMENTAL feature: multiple prosumers separated by '+' are not officially supported\n";
lwarn "EXPERIMENTAL feature: this is KNOWN to cause DATA CORRUPTION under certain circumstances.\n";
lwarn "EXPERIMENTAL feature: do not use this in production!\n";
}
foreach my $peer (split("\\+", $new_prosumers)) {
lprint "Killing prosumer at '$peer'\n";
my $lnk = "$mars/resource-$res/todo-$peer/gate-mask";
set_link($gate_fail, $lnk);
$lnk = "$mars/resource-$res/todo-$peer/kill-device";
set_link("1", $lnk);
}
finish_links();
_trigger(3);
}
sub wait_umount_res {
my ($cmd, $res) = @_;
my $path = "$mars/resource-$res/actual-$host/open-count";
@ -10713,6 +10746,16 @@ my %cmd_table =
\&prosumer_phase6,
"wait for device",
],
"shutdown"
=> [
"usage: shutdown[=<host_list>] <resource_name>",
" where <host_list> is '+'-separated.",
" Operators += and -= are also allowed in place of = .",
"Let any pending IO requests on a prosumer device fail.",
"This is useful when the network is down for a longer time,",
"or when a storage host has failed permanently.",
\&prosumer_shutdown,
],
"invalidate"
=> [
"Only useful on a secondary node.",