package lvm; # $Id$

use diagnostics;
use strict;

#-######################################################################################
#- misc imports
#-######################################################################################
use common;
use modules;
use devices;
use fs::type;
use run_program;

#- for partition_table_xxx emulation
sub new {
    my ($class, $name) = @_;
    $name =~ s/\W/_/g;
    $name = substr($name, 0, 63); # max length must be < NAME_LEN / 2  where NAME_LEN is 128
    bless { disks => [], VG_name => $name }, $class;
}
sub hasExtended { 0 }
sub adjustStart {}
sub adjustEnd {}
sub write {}
sub cylinder_size { 
    my ($hd) = @_;
    $hd->{extent_size};
}

init() or log::l("lvm::init failed");

sub init() {
    devices::init_device_mapper();
    if ($::isInstall) {
	run_program::run('lvm2', 'vgscan');
	run_program::run('lvm2', 'vgchange', '-a', 'y');
    }
    1;
}

sub lvm_cmd {
    if (my $r = run_program::run('lvm2', @_)) {
	$r;
    } else {
	$? >> 8 == 98 or return;

	#- sometimes, it needs running vgscan again, doing so:
	run_program::run('lvm2', 'vgscan');
	run_program::run('lvm2', @_);
    }
}
sub lvm_cmd_or_die {
    my ($prog, @para) = @_;
    lvm_cmd($prog, @para) or die "$prog failed\n";
}

sub check {
    my ($in) = @_;

    $in->do_pkgs->ensure_binary_is_installed('lvm2', 'lvm2') or return;
    init();
    1;
}

sub get_vg {
    my ($part) = @_;
    my $dev = expand_symlinks(devices::make($part->{device}));
    run_program::get_stdout('lvm2', 'pvs', '--noheadings', '-o', 'vg_name', $dev) =~ /(\S+)/ && $1;
}

sub update_size {
    my ($lvm) = @_;
    $lvm->{extent_size} = to_int(run_program::get_stdout('lvm2', 'vgs', '--noheadings', '--nosuffix', '--units', 's', '-o', 'vg_extent_size', $lvm->{VG_name}));
    $lvm->{totalsectors} = to_int(run_program::get_stdout('lvm2', 'vgs', '--noheadings', '--nosuffix', '--units', 's', '-o', 'vg_size', $lvm->{VG_name}));
}

sub get_lv_size {
    my ($lvm_device) = @_;
    to_int(run_program::get_stdout('lvm2', 'lvs', '--noheadings', '--nosuffix', '--units', 's', '-o', 'lv_size', "/dev/$lvm_device"));
}

sub get_lvs {
    my ($lvm) = @_;
    my @l = run_program::get_stdout('lvm2', 'lvs', '--noheadings', '--nosuffix', '--units', 's', '-o', 'lv_name', $lvm->{VG_name}) =~ /(\S+)/g;
    $lvm->{primary}{normal} = 
      [
       map {
	   my $device = "$lvm->{VG_name}/$_";
	   my $fs_type = -e "/dev/$device" && fs::type::fs_type_from_magic({ device => $device });

	   { device => $device, 
	     lv_name => $_,
	     fs_type => $fs_type || 'ext2',
	     size => get_lv_size($device) };
       } @l
      ];
}

sub vg_add {
    my ($part) = @_;
    my $dev = expand_symlinks(devices::make($part->{device}));
    lvm_cmd_or_die('pvcreate', '-y', '-ff', $dev);
    my $prog = lvm_cmd('vgs', $part->{lvm}) ? 'vgextend' : 'vgcreate';
    lvm_cmd_or_die($prog, $part->{lvm}, $dev);
}

sub vg_destroy {
    my ($lvm) = @_;

    is_empty_array_ref($lvm->{primary}{normal}) or die N("Remove the logical volumes first\n");
    lvm_cmd('vgchange', '-a', 'n', $lvm->{VG_name});
    lvm_cmd_or_die('vgremove', $lvm->{VG_name});
    foreach (@{$lvm->{disks}}) {
	lvm_cmd_or_die('pvremove', devices::make($_->{device}));
	delete $_->{lvm};
	set_isFormatted($_, 0);
    }
}

sub lv_delete {
    my ($lvm, $lv) = @_;

    lvm_cmd_or_die('lvremove', '-f', "/dev/$lv->{device}");

    my $list = $lvm->{primary}{normal};
    @$list = grep { $_ != $lv } @$list;
}

sub lv_create {
    my ($lvm, $lv) = @_;
    my $list = $lvm->{primary}{normal} ||= [];
    $lv->{lv_name} ||= 1 + max(map { if_($_->{device} =~ /(\d+)$/, $1) } @$list);
    $lv->{device} = "$lvm->{VG_name}/$lv->{lv_name}";
    lvm_cmd_or_die('lvcreate', '--size', int($lv->{size} / 2) . 'k', '-n', $lv->{lv_name}, $lvm->{VG_name});
    $lv->{size} = get_lv_size($lv->{device}); #- the created size is smaller than asked size
    set_isFormatted($lv, 0);
    push @$list, $lv;
}

sub lv_resize {
    my ($lv, $oldsize) = @_;
    lvm_cmd_or_die($oldsize > $lv->{size} ? ('lvreduce', '-f') : 'lvextend', 
		   '--size', int($lv->{size} / 2) . 'k', "/dev/$lv->{device}");
    $lv->{size} = get_lv_size($lv->{device}); #- the resized partition may not be the exact asked size
}

1;
' onchange='this.form.submit();'><option value='0' selected='selected'>unified</option><option value='1'>ssdiff</option><option value='2'>stat only</option></select></td></tr><tr><td/><td class='ctrl'><noscript><input type='submit' value='reload'/></noscript></td></tr></table></form></div><table summary='commit info' class='commit-info'>
<tr><th>author</th><td>Albert Astals Cid &lt;tsdgeos@mandriva.com&gt;</td><td class='right'>2004-09-24 15:20:02 +0000</td></tr>
<tr><th>committer</th><td>Albert Astals Cid &lt;tsdgeos@mandriva.com&gt;</td><td class='right'>2004-09-24 15:20:02 +0000</td></tr>
<tr><th>commit</th><td colspan='2' class='sha1'><a href='/software/control-center/commit/?h=12.59&amp;id=72e5c658259d0fa0c3914745d2d4ae45e7c755ba'>72e5c658259d0fa0c3914745d2d4ae45e7c755ba</a> (<a href='/software/control-center/patch/?id=72e5c658259d0fa0c3914745d2d4ae45e7c755ba'>patch</a>)</td></tr>
<tr><th>tree</th><td colspan='2' class='sha1'><a href='/software/control-center/tree/?h=12.59&amp;id=72e5c658259d0fa0c3914745d2d4ae45e7c755ba'>76812d48dec84a0a47076ade2b976cf748476ea0</a></td></tr>
<tr><th>parent</th><td colspan='2' class='sha1'><a href='/software/control-center/commit/?h=12.59&amp;id=ca2ede61614900824b9ec7e3316995149ee330ec'>ca2ede61614900824b9ec7e3316995149ee330ec</a> (<a href='/software/control-center/diff/?h=12.59&amp;id=72e5c658259d0fa0c3914745d2d4ae45e7c755ba&amp;id2=ca2ede61614900824b9ec7e3316995149ee330ec'>diff</a>)</td></tr><tr><th>download</th><td colspan='2' class='sha1'><a href='/software/control-center/snapshot/control-center-72e5c658259d0fa0c3914745d2d4ae45e7c755ba.tar'>control-center-72e5c658259d0fa0c3914745d2d4ae45e7c755ba.tar</a><br/><a href='/software/control-center/snapshot/control-center-72e5c658259d0fa0c3914745d2d4ae45e7c755ba.tar.gz'>control-center-72e5c658259d0fa0c3914745d2d4ae45e7c755ba.tar.gz</a><br/><a href='/software/control-center/snapshot/control-center-72e5c658259d0fa0c3914745d2d4ae45e7c755ba.tar.bz2'>control-center-72e5c658259d0fa0c3914745d2d4ae45e7c755ba.tar.bz2</a><br/><a href='/software/control-center/snapshot/control-center-72e5c658259d0fa0c3914745d2d4ae45e7c755ba.tar.xz'>control-center-72e5c658259d0fa0c3914745d2d4ae45e7c755ba.tar.xz</a><br/><a href='/software/control-center/snapshot/control-center-72e5c658259d0fa0c3914745d2d4ae45e7c755ba.zip'>control-center-72e5c658259d0fa0c3914745d2d4ae45e7c755ba.zip</a><br/></td></tr></table>
<div class='commit-subject'>