/[BackupPC]/trunk/bin/BackupPC_incPartsUpdate
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 /trunk/bin/BackupPC_incPartsUpdate

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

revision 157 by dpavlin, Mon Oct 10 13:04:51 2005 UTC revision 192 by dpavlin, Thu Oct 13 15:09:55 2005 UTC
# Line 8  use BackupPC::Lib; Line 8  use BackupPC::Lib;
8  use BackupPC::View;  use BackupPC::View;
9  use Data::Dumper;  use Data::Dumper;
10  use Time::HiRes qw/time/;  use Time::HiRes qw/time/;
 use File::Pid;  
11  use POSIX qw/strftime/;  use POSIX qw/strftime/;
12  use BackupPC::SearchLib;  use BackupPC::SearchLib;
13  use Cwd qw/abs_path/;  use Cwd qw/abs_path/;
# Line 19  my $tarIncCreate = $path .= 'BackupPC_ta Line 18  my $tarIncCreate = $path .= 'BackupPC_ta
18    
19  die "can't find $tarIncCreate: $!\n" unless (-x $tarIncCreate);  die "can't find $tarIncCreate: $!\n" unless (-x $tarIncCreate);
20    
21  my $debug = 1;  my $debug = 0;
22  $|=1;  $|=1;
23    
24  my $start_t = time();  my $start_t = time();
# Line 61  sub curr_time { Line 60  sub curr_time {
60  my $sth = $dbh->prepare( qq{  my $sth = $dbh->prepare( qq{
61                    
62  select  select
63            backups.id as backup_id,
64          hosts.name as host,          hosts.name as host,
65          shares.name as share,          shares.name as share,
66          num as num          backups.num as num,
67            inc_size
68  from backups  from backups
69          join shares on backups.hostid = shares.hostid          join shares on backups.hostid = shares.hostid
70                  and shares.id = backups.shareid                  and shares.id = backups.shareid
71          join hosts on shares.hostid = hosts.id          join hosts on shares.hostid = hosts.id
72  where inc_size < 0 and not inc_deleted  where not inc_deleted
73  order by backups.date  order by backups.date
74    
75  } );  } );
76    
77  $sth->execute();  $sth->execute();
78    
79    my $sth_inc_size = $dbh->prepare(qq{ update backups set inc_size = ? where id = ? });
80    my $sth_inc_deleted = $dbh->prepare(qq{ update backups set inc_deleted = ? where id = ? });
81    
82  %BackupPC::SearchLib::Conf = %Conf;  %BackupPC::SearchLib::Conf = %Conf;
83    
84  while (my $row = $sth->fetchrow_hashref) {  while (my $row = $sth->fetchrow_hashref) {
85          my $tar_file = BackupPC::SearchLib::getGzipName($row->{'host'}, $row->{'share'}, $row->{'num'});          my $tar_file = BackupPC::SearchLib::getGzipName($row->{'host'}, $row->{'share'}, $row->{'num'});
86          print curr_time, sprintf(" %s:%s %-3d ", $row->{'host'}, $row->{'share'}, $row->{'num'}), " -> $tar_file ";  
87            my $size = -1;
88            $size = (stat( "$tar_dir/$tar_file" ))[7] if (-e "$tar_dir/$tar_file");
89    
90            next if ($row->{'inc_size'} != -1 && $size != -1 && $row->{'inc_size'} == $size);
91    
92            print curr_time, " ", $row->{'host'}, ":", $row->{'share'}, " #", $row->{'num'}, " -> $tar_file";
93    
94          my $t = time();          my $t = time();
95    
# Line 88  while (my $row = $sth->fetchrow_hashref) Line 98  while (my $row = $sth->fetchrow_hashref)
98    
99          system($cmd) == 0 or die "failed: $?";          system($cmd) == 0 or die "failed: $?";
100    
101          print fmt_time(time() - $t),"\n";          my $size = (stat( "$tar_dir/$tar_file" ))[7];
102    
103            printf(" %1.2f MB, dur: %s", ($size / 1024 / 1024), fmt_time(time() - $t));
104    
105            if ($size > 45) {
106                    $sth_inc_size->execute($size, $row->{'backup_id'});
107                    $sth_inc_deleted->execute(0, $row->{'backup_id'});
108            } else {
109                    $sth_inc_deleted->execute(1, $row->{'backup_id'});
110                    unlink "$tar_dir/$tar_file" || die "can't delete $tar_dir/$tar_file: $!\n";
111                    print " EMPTY";
112            }
113            print "\n";
114    
115            $dbh->commit;
116    
117  }  }
118    
Legend:
Removed from v.157  
changed lines
  Added in v.192
  ViewVC Help
Powered by ViewVC 1.1.26