package raid; # $Id$ use diagnostics; use strict; #-###################################################################################### #- misc imports #-###################################################################################### use common; use partition_table qw(:types); use run_program; use devices; use modules; use fs; sub max_nb { 31 } sub nb { my ($nb) = @_; first((ref($nb) ? $nb->{device} : $nb) =~ /(\d+)/); } sub new { my ($raids, @parts) = @_; my $nb = @$raids; $raids->[$nb] = { 'chunk-size' => "64k", type => 0x483, disks => [ @parts ], device => "md$nb", notFormatted => 1, level => 1 }; foreach my $part (@parts) { $part->{raid} = $nb; delete $part->{mntpoint}; } update($raids->[$nb]); $nb; } sub add { my ($raids, $part, $nb) = @_; $nb = nb($nb); $raids->[$nb]{isMounted} and die \N("Can't add a partition to _formatted_ RAID md%d", $nb); inactivate_and_dirty($raids->[$nb]); $part->{notFormatted} = 1; $part->{isFormatted} = 0; $part->{raid} = $nb; delete $part->{mntpoint}; push @{$raids->[$nb]{disks}}, $part; update($raids->[$nb]); } sub delete { my ($raids, $nb) = @_; $nb = nb($nb); inactivate_and_dirty($raids->[$nb]); delete $_->{raid} foreach @{$raids->[$nb]{disks}}; undef $raids->[$nb]; } sub changeNb { my ($raids, $oldnb, $newnb) = @_; if ($oldnb != $newnb) { inactivate_and_dirty($raids->[$_]) foreach $oldnb, $newnb; ($raids->[$newnb], $raids->[$oldnb]) = ($raids->[$oldnb], undef); $raids->[$newnb]{device} = "md$newnb"; $_->{raid} = $newnb foreach @{$raids->[$newnb]{disks}}; } $newnb; } sub removeDisk { my ($raids, $part) = @_; my $nb = nb($part->{raid}); inactivate_and_dirty($raids->[$nb]); delete $part->{raid}; my $disks = $raids->[$nb]{disks}; @$disks = grep { $_ != $part } @$disks; if (@$disks) { update($raids->[$nb]); } else { undef $raids->[$nb]; } } sub updateSize { my ($part) = @_; local $_ = $part->{level}; my @l = map { $_->{size} } @{$part->{disks}}; $part->{size} = do { if (/0|linear/) { sum @l } elsif (/1/) { min @l } elsif (/4|5/) { min(@l) * $#l } }; } sub module { my ($part) = @_; my $mod = $part->{level}; $mod = 5 if $mod eq "4"; $mod = "raid$mod" if $mod =~ /^\d+$/; $mod; } sub update { updateSize($_) foreach @_; } sub write { my ($raids, $file) = @_; return if $::testing; output($file, map { my $s = sprintf(<<EOF, devices::make($_->{device}), $_->{level}, $_->{'chunk-size'}, int @{$_->{disks}}); raiddev %s raid-level %s chunk-size %s persistent-superblock 1 nr-raid-disks %d EOF my @devs = map_index { " device " . devices::make($_->{device}) . "\n raid-disk $::i\n"; } @{$_->{disks}}; $s, @devs } grep { $_ } @$raids); } sub make { my ($raids, $part) = @_; return if is_active($part->{device}); inactivate_and_dirty($part); isRAID($_) and make($raids, $_) foreach @{$part->{disks}}; my $dev = devices::make($part->{device}); eval { modules::load(module($part)) }; &write($raids, "/etc/raidtab"); run_program::run("mkraid", "--really-force", $dev) or die $::isStandalone ? N("mkraid failed (maybe raidtools are missing?)") : N("mkraid failed"); } sub format_part { my ($raids, $part) = @_; $part->{isFormatted} and return; make($raids, $part); fs::real_format_part($part); $_->{isFormatted} = 1 foreach @{$part->{disks}}; } sub verify { my ($raids) = @_; $raids or return; foreach (grep { $_ } @$raids) { @{$_->{disks}} >= ($_->{level} =~ /4|5/ ? 3 : 2) or die \N("Not enough partitions for RAID level %d\n", $_->{level}); } } sub prepare_prefixed { my ($raids, $prefix) = @_; $raids or return; &write($raids, "/etc/raidtab") if ! -e "/etc/raidtab"; eval { cp_af("/etc/raidtab", "$prefix/etc/raidtab") }; foreach (grep { $_ } @$raids) { devices::make("$prefix/dev/$_->{device}") foreach @{$_->{disks}}; } } sub inactivate_and_dirty { my ($part) = @_; run_program::run("raidstop", devices::make($part->{device})); $part->{notFormatted} = 1; $part->{isFormatted} = 0; } sub active_mds { map { if_(/^(md\d+) /, $1) } cat_("/proc/mdstat"); } sub is_active { my ($dev) = @_; member($dev, active_mds()); } sub inactivate_all() { run_program::run("raidstop", devices::make($_)) foreach active_mds() } 1;