zpool: cleanup zfs_request command a bit
Signed-off-by: Thomas Lamprecht <t.lamprecht@proxmox.com>
This commit is contained in:
@ -167,8 +167,6 @@ sub path {
|
|||||||
sub zfs_request {
|
sub zfs_request {
|
||||||
my ($class, $scfg, $timeout, $method, @params) = @_;
|
my ($class, $scfg, $timeout, $method, @params) = @_;
|
||||||
|
|
||||||
my $default_timeout = PVE::RPCEnvironment->is_worker() ? 60*60 : 5;
|
|
||||||
|
|
||||||
my $cmd = [];
|
my $cmd = [];
|
||||||
|
|
||||||
if ($method eq 'zpool_list') {
|
if ($method eq 'zpool_list') {
|
||||||
@ -179,17 +177,12 @@ sub zfs_request {
|
|||||||
} else {
|
} else {
|
||||||
push @$cmd, 'zfs', $method;
|
push @$cmd, 'zfs', $method;
|
||||||
}
|
}
|
||||||
|
|
||||||
push @$cmd, @params;
|
push @$cmd, @params;
|
||||||
|
|
||||||
my $msg = '';
|
my $msg = '';
|
||||||
|
my $output = sub { $msg .= "$_[0]\n" };
|
||||||
|
|
||||||
my $output = sub {
|
$timeout = PVE::RPCEnvironment->is_worker() ? 60*60 : 5 if !$timeout;
|
||||||
my $line = shift;
|
|
||||||
$msg .= "$line\n";
|
|
||||||
};
|
|
||||||
|
|
||||||
$timeout = $default_timeout if !$timeout;
|
|
||||||
|
|
||||||
run_command($cmd, errmsg => "zfs error", outfunc => $output, timeout => $timeout);
|
run_command($cmd, errmsg => "zfs error", outfunc => $output, timeout => $timeout);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user