/[42-fs]/42.pl
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /42.pl

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1 by dpavlin, Sat Jul 18 17:31:53 2009 UTC revision 5 by dpavlin, Sun Jul 19 13:33:51 2009 UTC
# Line 6  use strict; Line 6  use strict;
6  use File::Slurp;  use File::Slurp;
7  use File::Path;  use File::Path;
8  use Getopt::Long;  use Getopt::Long;
9    use Data::Dump qw/dump/;
10    
11  my $dev = '/dev/sdb2';  my $dev = '/dev/sdb';
12  my $mnt = '/mnt/42';  my $mnt = '/mnt/42';
13    
14  my ( $rollback, $commit );  my ( $verbose, $skip, $init, $debug ) = ( 0, 1 );
15    
16  GetOptions(  GetOptions(
17          'rollback!' => \$rollback,          'verbose!' => \$verbose,
18          'commit!'   => \$commit,          'skip!'    => \$skip,
19            'init!'    => \$init,
20            'debug!'   => \$debug,
21  ) or die "unknown options: $!";  ) or die "unknown options: $!";
22    
 map { mkdir $_ unless -e $_ } map { "$mnt/$_" } ( 'log', 'ps' );  
23    
24  my $path = shift @ARGV;  sub size {
25            my $size = shift;
26            $size =~ s{MB}{};
27            $size;
28    }
29    
30  my ($dir,$file) = ($1,$2) if $path =~ m{^(?:(.+)/)?([^/]+)};  my @part;
31    
32  my $seq;  sub partitions {
33  my $opos = 0;          @part = ();
34            open(my $parted, '-|', "parted -s $dev unit mb print free") || die "parted: $!";
35            while(<$parted>) {
36                    chomp;
37                    s{^\s+}{};
38                    next unless $_;
39                    my @p = map { size($_) } split(/\s+/, $_ );
40                    warn "## $_ ",dump( @p ) if $debug;
41                    if ( $p[3] && $p[3] eq 'Free' ) {
42                            $part[0] = [ @p ];
43                    } elsif ( $p[0] =~ m{^\d+$} ) {
44                            my $nr = shift @p;
45                            $part[$nr] = [ @p ];
46                    } else {
47                            warn "SKIP ",dump( @p ) if $debug;
48                    }
49            }
50            warn "# part = ",dump( @part ) if $verbose;
51            return @part;
52    }
53    
54  if ( -e "$mnt/last" ) {  sub mount_42 {
55          my $log = read_file("$mnt/last");          my $node = $dev . '1';
56          $seq = readlink("$mnt/last");          if ( ! -e $node ) {
57          $seq =~ s{^.+/(\d+)$}{$1} || die "can't parse sequence: $seq";                  print STDERR "wait for $node";
58          $seq++;                  sleep 1;
59          $opos = $1 if $log =~ m{opos:\s+(\d+\.\d[k])};                  while ( ! -e $node ) {
60          die "can't decode opos" unless $opos;                          print STDERR ".";
61          warn "# seq: $seq start: $opos\n";                          sleep 1;
62                    }
63  } else {          }
64          $seq = scalar(glob("$mnt/log/*"));          warn " ready\n+ mount $node $mnt\n";
65          warn "# $mnt/last not found, recover seq: $seq\n";          system("mount $node $mnt") == 0 or die "can't mount: $!";
66  }  }
67    
68    my $remount_on = qr/(mkpart|rm)/;
69    
70  my $log = "$mnt/log/$seq";  sub parted {
71            my $command = shift;
72  if ( -e $log ) {          my @before = partitions();
73          print "ERROR $log exists!\n",read_file($log);  
74          if ( $rollback ) {          system "umount $mnt" if $command =~ $remount_on;
75                  unlink $log || die "can't rollback $log: $!";  
76                  die "RECOVERY removed $log\n";          warn "+ $command\n";
77          } elsif ( $commit ) {          system("parted -s $dev unit mb $command") == 0 or die "parted: $?";
78                  unlink "$mnt/last" || die "can't remove $mnt/last: $!";          if ( $command =~ $remount_on ) {
79                  symlink $log,"$mnt/last" || die "can't commit $log: $!";                  my @part = partitions();
80                  die "ERROR: can't update $mnt/last -> $log" unless $log eq readlink "$mnt/last";                  while ( $#before == $#part ) {
81                  die "RECOVERY updated $mnt/last -> $log\n";                          warn "re-read partition table\n";
82          } else {                          sleep 1;
83                  die "$log exists, re-run with --commit or --rollback";                          @part = partitions();
84                    }
85            mount_42 if $part[1];
86          }          }
87  }  }
88    
89  my $cmd = "dd_rescue -l $log -S $opos $path $dev && ln -s $log $mnt/last";  partitions();
90  print "+ $cmd\n";  
91  system($cmd) == 0 or die $?;  if ( $init ) {
92            parted("rm $_") foreach grep { defined $part[$_] } map { $#part - $_ + 1 } ( 1 .. $#part );
93            parted("mkpartfs primary ext2 0 42MB");
94            parted("mkpart extended 42MB " . $part[0]->[1] . 'MB');
95            my $cmd = read_file($0);
96            write_file( "$mnt/42.pl", $cmd );
97            chmod 0755, "$mnt/42.pl";
98            exit;
99    }
100    
101    map { mkdir $_ unless -e $_ } map { "$mnt/$_" } ( 'log', 'fs', 'stat' );
102    
103    my $path = shift @ARGV || die "usage: $0 /path/to/file\n";
104    
105    my ($dir,$file) = ($1,$2) if $path =~ m{^(?:(.+)/)?([^/]+)};
106    
107  my $fs = "$mnt/fs/$dir";  my $fs = "$mnt/fs/$dir";
108  mkdir $fs unless -e $fs;  mkpath $fs unless -e $fs;
109    
110  $fs .= '/' . $file;  $fs .= '/' . $file;
111  symlink $fs,$log || die "can't create $fs: $!";  if ( -e $fs ) {
112            if ( $skip ) {
113                    warn "SKIP $fs\n";
114                    exit 0;
115            } else {
116                    die "$fs exists! re-run with --skip\n";
117            }
118    }
119    
120    my @stat = stat($path);
121    die "can't stat $path: $!" unless @stat;
122    warn "# $path ",$stat[7],$/;
123    
124    my $size_mb = $stat[7] / 1000 / 1000; # FIXME correctly round to something?
125    my ( $free_start, undef, $free_size ) = @{$part[0]};
126    
127    my $part_end = int( $free_start + $size_mb + 1 );
128    
129    my $last_part = $#part;
130    
131    parted("mkpart logical ${free_start}MB ${part_end}MB ");
132    
133    my $part_size = $part[$#part]->[2] || die "can't get size of new partition";
134    
135    die "not enough space on $dev $size_mb > $part_size" if $size_mb > $part_size;
136    
137    my $part_nr = $#part;
138    
139    write_file( "$mnt/stat/$part_nr", join("\n",@stat) );
140    
141    my $log = "$mnt/log/$part_nr";
142    
143    my $to_dev = $dev . $part_nr;
144    
145    symlink( $to_dev ,$fs) || die "can't create $fs: $!";
146    
147    my $cmd = "dd_rescue -w -l $log $path $to_dev";
148    print "+ $cmd\n";
149    exec $cmd;

Legend:
Removed from v.1  
changed lines
  Added in v.5

  ViewVC Help
Powered by ViewVC 1.1.26