/[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 192 by dpavlin, Thu Oct 13 15:09:55 2005 UTC revision 194 by dpavlin, Thu Oct 13 17:11:59 2005 UTC
# Line 84  my $sth_inc_deleted = $dbh->prepare(qq{ Line 84  my $sth_inc_deleted = $dbh->prepare(qq{
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    
87          my $size = -1;          # this will return -1 if file doesn't exist
88          $size = (stat( "$tar_dir/$tar_file" ))[7] if (-e "$tar_dir/$tar_file");          my $size = BackupPC::SearchLib::get_tgz_size_by_name($tar_file);
   
         next if ($row->{'inc_size'} != -1 && $size != -1 && $row->{'inc_size'} == $size);  
89    
90          print curr_time, " ", $row->{'host'}, ":", $row->{'share'}, " #", $row->{'num'}, " -> $tar_file";          print curr_time, " ", $row->{'host'}, ":", $row->{'share'}, " #", $row->{'num'}, " -> $tar_file";
91    
92          my $t = time();          my $t = time();
93    
94          my $cmd = qq{$tarIncCreate -h "$row->{'host'}" -s "$row->{'share'}" -n $row->{'num'} | gzip -9 > $tar_dir/$tar_file};          # re-create archive?
95          print STDERR "## $cmd\n" if ($debug);          if ($row->{'inc_size'} == -1 || $size == -1 || $row->{'inc_size'} != $size) {
96                    my $cmd = qq{$tarIncCreate -h "$row->{'host'}" -s "$row->{'share'}" -n $row->{'num'} | gzip -9 > $tar_dir/$tar_file};
97                    print STDERR "## $cmd\n" if ($debug);
98    
99                    system($cmd) == 0 or die "failed: $?";
100            
101                    $size = (stat( "$tar_dir/$tar_file" ))[7];
102            }
103    
104          system($cmd) == 0 or die "failed: $?";          if ($size > 45) {
105    
106          my $size = (stat( "$tar_dir/$tar_file" ))[7];                  my $max_size = $Conf{'MaxArchiveSize'} || die "problem with MaxArchieSize parametar";
107    
108          printf(" %1.2f MB, dur: %s", ($size / 1024 / 1024), fmt_time(time() - $t));                  if ($size > $max_size && ! -d "$tar_dir/$tar_file") {
109                            print " split";
110                            my $in = my $out = "$tar_dir/$tar_file";
111                            $out .= '.tmp';
112                            rename $in, $out || die "can't rename $in: $!";
113                            mkdir $in || die "can't mkdir $in: $!";
114                            system("split -d -b $max_size $out $in/part") == 0 or die "can't split $out: $!";
115                            unlink $out || die "can't unlink $out: $!";
116                    }
117    
         if ($size > 45) {  
118                  $sth_inc_size->execute($size, $row->{'backup_id'});                  $sth_inc_size->execute($size, $row->{'backup_id'});
119                  $sth_inc_deleted->execute(0, $row->{'backup_id'});                  $sth_inc_deleted->execute(0, $row->{'backup_id'});
120    
121                    printf(" %1.2f MB", ($size / 1024 / 1024));
122    
123          } else {          } else {
124                  $sth_inc_deleted->execute(1, $row->{'backup_id'});                  $sth_inc_deleted->execute(1, $row->{'backup_id'});
125                  unlink "$tar_dir/$tar_file" || die "can't delete $tar_dir/$tar_file: $!\n";                  unlink "$tar_dir/$tar_file" || die "can't delete $tar_dir/$tar_file: $!\n";
126                  print " EMPTY";                  print " EMPTY";
127          }          }
128          print "\n";          print ", dur: ",fmt_time(time() - $t), "\n";
129    
130          $dbh->commit;          $dbh->commit;
131    
Legend:
Removed from v.192  
changed lines
  Added in v.194
  ViewVC Help
Powered by ViewVC 1.1.26