mirror of
https://github.com/kolesa-team/pve-purestorage-plugin.git
synced 2026-08-12 21:53:06 -06:00
Correct formatting (perltidy)
This commit is contained in:
+29
-30
@@ -38,9 +38,9 @@ my $default_hgsuffix = "";
|
|||||||
my $DEBUG = 0;
|
my $DEBUG = 0;
|
||||||
|
|
||||||
my $cmd = {
|
my $cmd = {
|
||||||
iscsiadm => '/usr/bin/iscsiadm',
|
iscsiadm => '/usr/bin/iscsiadm',
|
||||||
multipath => '/sbin/multipath',
|
multipath => '/sbin/multipath',
|
||||||
blockdev => '/usr/sbin/blockdev'
|
blockdev => '/usr/sbin/blockdev'
|
||||||
};
|
};
|
||||||
|
|
||||||
### BLOCK: Configuration
|
### BLOCK: Configuration
|
||||||
@@ -145,18 +145,18 @@ sub exec_command {
|
|||||||
|
|
||||||
sub scsi_scan_new {
|
sub scsi_scan_new {
|
||||||
print "Debug :: PVE::Storage::Custom::PureStoragePlugin::sub::scsi_scan_new\n" if $DEBUG;
|
print "Debug :: PVE::Storage::Custom::PureStoragePlugin::sub::scsi_scan_new\n" if $DEBUG;
|
||||||
my $fc_base = '/sys/class/fc_host';
|
my $fc_base = '/sys/class/fc_host';
|
||||||
my @fc_hosts = glob("$fc_base/*");
|
my @fc_hosts = glob( "$fc_base/*" );
|
||||||
|
|
||||||
die "Error :: sub::scsi_scan_new did not find fibre channel hosts.\n" unless @fc_hosts;
|
die "Error :: sub::scsi_scan_new did not find fibre channel hosts.\n" unless @fc_hosts;
|
||||||
|
|
||||||
foreach my $fc_host (@fc_hosts) {
|
foreach my $fc_host ( @fc_hosts ) {
|
||||||
next unless ($fc_host =~ m/^(\/sys\/class\/fc_host\/\w+)$/);
|
next unless ( $fc_host =~ m/^(\/sys\/class\/fc_host\/\w+)$/ );
|
||||||
my $adapter = basename($1);
|
my $adapter = basename( $1 );
|
||||||
my $scsi_host = File::Spec->catfile("/sys/class/scsi_host/", $adapter);
|
my $scsi_host = File::Spec->catfile( "/sys/class/scsi_host/", $adapter );
|
||||||
|
|
||||||
if(-d $scsi_host) {
|
if ( -d $scsi_host ) {
|
||||||
open my $fh, '>', File::Spec->catfile($scsi_host, "scan") or die "Error :: Cannot open file: $!";
|
open my $fh, '>', File::Spec->catfile( $scsi_host, "scan" ) or die "Error :: Cannot open file: $!";
|
||||||
print $fh "- - -\n";
|
print $fh "- - -\n";
|
||||||
close $fh;
|
close $fh;
|
||||||
} else {
|
} else {
|
||||||
@@ -166,27 +166,27 @@ sub scsi_scan_new {
|
|||||||
}
|
}
|
||||||
|
|
||||||
sub scsi_rescan_device {
|
sub scsi_rescan_device {
|
||||||
my ($wwid) = @_;
|
my ( $wwid ) = @_;
|
||||||
print "Debug :: PVE::Storage::Custom::PureStoragePlugin::sub::scsi_rescan_device\n" if $DEBUG;
|
print "Debug :: PVE::Storage::Custom::PureStoragePlugin::sub::scsi_rescan_device\n" if $DEBUG;
|
||||||
die "Error :: sub::scsi_rescan_device did not recive a wwid.\n" unless $wwid;
|
die "Error :: sub::scsi_rescan_device did not recive a wwid.\n" unless $wwid;
|
||||||
|
|
||||||
foreach my $device (glob('/sys/class/scsi_device/*')) {
|
foreach my $device ( glob( '/sys/class/scsi_device/*' ) ) {
|
||||||
next unless ($device =~ m/^(\/sys\/class\/scsi_device\/[\d\:\\]+)$/);
|
next unless ( $device =~ m/^(\/sys\/class\/scsi_device\/[\d\:\\]+)$/ );
|
||||||
my $tmppath = $1;
|
my $tmppath = $1;
|
||||||
|
|
||||||
my $wwid_file = File::Spec->catfile($tmppath, "device/wwid");
|
my $wwid_file = File::Spec->catfile( $tmppath, "device/wwid" );
|
||||||
next unless -f $wwid_file;
|
next unless -f $wwid_file;
|
||||||
|
|
||||||
open(my $wwid_fh, '<', $wwid_file) or die "Error :: Cannot open file: $!";
|
open( my $wwid_fh, '<', $wwid_file ) or die "Error :: Cannot open file: $!";
|
||||||
my $tmpwwid = <$wwid_fh>;
|
my $tmpwwid = <$wwid_fh>;
|
||||||
close($wwid_fh);
|
close( $wwid_fh );
|
||||||
|
|
||||||
$tmpwwid =~ s/^naa\.//;
|
$tmpwwid =~ s/^naa\.//;
|
||||||
$tmpwwid = "3" . lc($tmpwwid);
|
$tmpwwid = "3" . lc( $tmpwwid );
|
||||||
chomp($tmpwwid);
|
chomp( $tmpwwid );
|
||||||
|
|
||||||
if ($tmpwwid eq $wwid) {
|
if ( $tmpwwid eq $wwid ) {
|
||||||
open my $rescan, '>', File::Spec->catfile($tmppath, "device/rescan") or die "Error :: Cannot open file: $!";
|
open my $rescan, '>', File::Spec->catfile( $tmppath, "device/rescan" ) or die "Error :: Cannot open file: $!";
|
||||||
print $rescan "1\n";
|
print $rescan "1\n";
|
||||||
close $rescan;
|
close $rescan;
|
||||||
}
|
}
|
||||||
@@ -643,16 +643,15 @@ sub purestorage_resize_volume {
|
|||||||
my ( $path, $wwid ) = $class->purestorage_get_wwn( $scfg, $volname );
|
my ( $path, $wwid ) = $class->purestorage_get_wwn( $scfg, $volname );
|
||||||
|
|
||||||
my $protocol = $scfg->{ protocol };
|
my $protocol = $scfg->{ protocol };
|
||||||
if ($protocol == 1) {
|
if ( $protocol == 1 ) {
|
||||||
exec_command( [ $cmd->{ iscsiadm }, '--mode', 'node', '--rescan' ], 1 );
|
exec_command( [ $cmd->{ iscsiadm }, '--mode', 'node', '--rescan' ], 1 );
|
||||||
} elsif ($protocol == 2) {
|
} elsif ( $protocol == 2 ) {
|
||||||
scsi_rescan_device($wwid);
|
scsi_rescan_device( $wwid );
|
||||||
} elsif ($protocol == 3) {
|
} elsif ( $protocol == 3 ) {
|
||||||
die qq{"Error :: Protocol: "$protocol" isn't implemented yet.\n};
|
die qq{"Error :: Protocol: "$protocol" isn't implemented yet.\n};
|
||||||
} else {
|
} else {
|
||||||
die qq{Error :: Protocol: "$protocol" isn't a valid protocol.\n};
|
die qq{Error :: Protocol: "$protocol" isn't a valid protocol.\n};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
# FIXME: wwid is probably ignored
|
# FIXME: wwid is probably ignored
|
||||||
exec_command( [ $cmd->{ multipath }, '-r', $wwid ], 1 );
|
exec_command( [ $cmd->{ multipath }, '-r', $wwid ], 1 );
|
||||||
@@ -977,11 +976,11 @@ sub map_volume {
|
|||||||
exec_command( [ $cmd->{ multipath }, '-a', $wwid ], 1 );
|
exec_command( [ $cmd->{ multipath }, '-a', $wwid ], 1 );
|
||||||
|
|
||||||
my $protocol = $scfg->{ protocol };
|
my $protocol = $scfg->{ protocol };
|
||||||
if ($protocol == 1) {
|
if ( $protocol == 1 ) {
|
||||||
exec_command( [ $cmd->{ iscsiadm }, '--mode', 'session', '--rescan' ], 1 );
|
exec_command( [ $cmd->{ iscsiadm }, '--mode', 'session', '--rescan' ], 1 );
|
||||||
} elsif ($protocol == 2) {
|
} elsif ( $protocol == 2 ) {
|
||||||
scsi_scan_new();
|
scsi_scan_new();
|
||||||
} elsif ($protocol == 3) {
|
} elsif ( $protocol == 3 ) {
|
||||||
die qq{"Error :: Protocol: "$protocol" isn't implemented yet.\n};
|
die qq{"Error :: Protocol: "$protocol" isn't implemented yet.\n};
|
||||||
} else {
|
} else {
|
||||||
die qq{Error :: Protocol: "$protocol" isn't a valid protocol.\n};
|
die qq{Error :: Protocol: "$protocol" isn't a valid protocol.\n};
|
||||||
|
|||||||
Reference in New Issue
Block a user