From: Frank Brehm <frank@brehm-online.com>
Date: Fri, 31 Mar 2006 13:24:34 +0000 (+0000)
Subject: Komprimierung dazu
X-Git-Url: https://git.uhu-banane.org/?a=commitdiff_plain;h=b87bd8a0c91bf2714549059d5d1ac2cad67a6f2c;p=scripts%2Fsolaris.git

Komprimierung dazu
---

diff --git a/LogRotate.pm b/LogRotate.pm
index 1f8edcb..638a161 100644
--- a/LogRotate.pm
+++ b/LogRotate.pm
@@ -519,6 +519,333 @@ sub collect_old_logfiles($$) {
 
 #------------------------------------------------------------------------------------
 
+=head2 compress( )
+
+Komprimiert alle alten Logdateien, die in $self->{'files_compress'} erfasst worden sind.
+
+=cut
+
+sub compress($) {
+
+  my $self = shift;
+  my $p = verbose() ? __PACKAGE__ . "::compress(): " : "";
+
+  print $p . "Komprimiere alte Logdateien ...\n" if verbose();
+
+  unless ( $self->{'files_compress'} and scalar( keys %{$self->{'files_compress'}} ) ) {
+    print $p . "Keine alten Logdateien zum Komprimieren gefunden.\n";
+    return 1;
+  }
+
+  my ( $file );
+  my $cmd = $self->{'c'}{'compress_cmd'};
+
+  unless ( $cmd ) {
+    warn $p . "Kein gueltiges Kompressionsprogramm gegeben oder gefunden.\n";
+    return 1;
+  }
+
+  my $method = ( $cmd eq 'Compress::Zlib'  or $cmd eq '1' ) ? \&compress_file_zlib  :
+               ( $cmd eq 'Compress::Bzip2' or $cmd eq '2' ) ? \&compress_file_bzip2 :
+                                                              \&compress_external;
+
+  for $file ( keys %{$self->{'files_compress'}} ) {
+
+    unless ( $self->$method($file) ) {
+      warn $p . "Komprimieren von '$file' ging gewaltig schief.\n";
+      return undef;
+    }
+
+  }
+
+  return 1;
+
+}
+
+#------------------------------------------------------------------------------------
+
+=head2 compress_external( $file )
+
+Komprimiert die uebergebene Datei mittels eines externen Programms.
+
+=cut
+
+sub compress_external($$) {
+
+  my $self = shift;
+  my $file = shift;
+  my $p = verbose() ? __PACKAGE__ . "::compress_external(): " : "";
+
+  my $cmd = $self->{'c'}{'compress_cmd'};
+
+  unless ( $file ) {
+    carp( $p . "Keine Datei uebergeben!\n" );
+    return undef;
+  }
+  print $p . "Komprimiere Datei '$file'" . ( verbose() ? " mittels '$cmd'" : "" ) . " ...\n";
+
+  # Gucken, ob Datei ueberhaupt da ist
+  unless ( -f $file ) {
+    warn $p . "Datei '$file' existiert nicht!\n";
+    return 1;
+  }
+
+  # Weiter, wenn Dateigroesse == 0
+  my $size = ( -s $file );
+  unless ( $size ) {
+    print $p . "Datei '$file' hat Groesse 0, wird nicht komprimiert.\n";
+    return 1;
+  }
+
+  $cmd .= " " . ( $self->{'compressoptions'} || "" ) . " " . $file;
+  print "   -> $cmd\n";
+
+  # Weiter, wenn Testmodus
+  return 1 if $self->{'test'};
+
+  system $cmd;
+
+  if ( $? ) {
+    if ($? == -1) {
+      warn $p . "Konnte Kompressions-Kommando nicht ausfuehren: $!\n";
+      return undef;
+    } elsif ($? & 127) {
+      warn( $p . printf "Das Kommando starb mit Signal %d, %s Coredump\n", ($? & 127),  ($? & 128) ? 'mit' : 'ohne');
+      return undef;
+    } else {
+      printf $p . "Das Kommando wurde mit dem Wert %d beendet.\n", $? >> 8;
+    }
+  }
+
+  return 1;
+
+}
+
+#------------------------------------------------------------------------------------
+
+=head2 compress_file_bzip2( $file )
+
+Komprimiert die uebergebene Datei mittels der I<Compress::Bzip2>-Bibliothek.
+
+Voraussetzung fuer den Einsatz dieser Funktion ist, dass I<Compress::Bzip2>
+bereits geladen ist.
+
+=cut
+
+sub compress_file_bzip2($$) {
+
+  my $self = shift;
+  my $file = shift;
+  my $p = verbose() ? __PACKAGE__ . "::compress_file_bzip2(): " : "";
+
+  my ( $size );
+
+  unless ( $file ) {
+    carp( $p . "Keine Datei uebergeben!\n" );
+    return undef;
+  }
+  print $p . "Komprimiere Datei '$file'" . ( verbose() ? " mittels Compress::Bzip2" : "" ) . " ...\n";
+
+  # Endung der komprimierten Datei ermitteln
+  my $ce = $self->{'c'}->compressext();
+  if ( not defined($ce) or $ce =~ /^\s*$/ ) {
+    $ce = ".gz";
+  }
+  $ce = "." . $ce if $ce ne "" and $ce !~ /^\./;
+
+  # Gucken, ob Datei ueberhaupt da ist
+  unless ( -f $file ) {
+    warn $p . "Datei '$file' existiert nicht!\n";
+    return 1;
+  }
+
+  # Weiter, wenn Dateigroesse == 0
+  $size = ( -s $file );
+  unless ( $size ) {
+    print $p . "Datei '$file' hat Groesse 0, wird nicht komprimiert.\n";
+    return 1;
+  }
+
+  # Weiter, wenn Testmodus
+  return 1 if $self->{'test'};
+
+  my $target = $file . $ce;
+  my ( $bz, $buffer );
+  my ( @Stat );
+  my %BzParams = ();
+  $BzParams{'-verbosity'} = verbose() > 7 ? 4 : int((verbose()+1) / 2) ;
+
+  unless ( open LOG, "<", "$file" ) {
+    warn $p . "Problem beim Oeffnen der Logdatei '$file' zum Lesen: $!\n";
+    return undef;
+  }
+
+  unless ( $bz = eval " bzopen( '$target', 'w' )" ) {
+    warn $p . "Kann komprimierte Datei '$target'  nicht schreiben: $!.\n";
+    close LOG;
+    return undef;
+  }
+
+  print "   ";
+  $bz->bzsetparams( %BzParams );
+  while ( read LOG, $buffer, default_buffer_size ) {
+    $bz->bzwrite( $buffer );
+  }
+  $bz->bzclose();
+
+  close LOG;
+  print "\n" if verbose();
+
+  @Stat = stat $file;
+  my ( $mode, $uid, $gid, $mtime ) = @Stat[ 2, 4, 5, 9 ];
+  $mode &= 0777;
+
+  print $p . "Setze Permissions von '$target'.\n" if verbose();
+  unless ( chmod $mode, $target ) {
+    warn $p . "Problem beim Setzen der Permissions von '$target': $!\n";
+  }
+
+  print $p . "Setze Mtime von '$target'.\n" if verbose();
+  unless ( utime $mtime, $mtime, $target ) {
+    warn $p . "Problem beim Setzen der Mtime von '$target': $!\n";
+  }
+
+  print $p . "Setze Besitzerschaft von '$target'.\n" if verbose();
+  unless ( chown $uid, $gid, $target ) {
+    warn $p . "Problem beim Setzen der Besitzerschaft von '$target': $!\n";
+  }
+
+  print $p . "Loesche Original-Datei '$file' ...\n" if verbose();
+  unless ( unlink $file ) {
+    warn $p . "Problem beim Loeschen von '$file': $!\n";
+    return undef;
+  }
+
+  return 1;
+
+}
+
+#------------------------------------------------------------------------------------
+
+=head2 compress_file_zlib( $file )
+
+Komprimiert die uebergebene Datei mittels der I<Compress::Zlib>-Bibliothek.
+
+Voraussetzung fuer den Einsatz dieser Funktion ist, dass I<Compress::Zlib>
+bereits geladen ist.
+
+=cut
+
+sub compress_file_zlib($$) {
+
+  my $self = shift;
+  my $file = shift;
+  my $p = verbose() ? __PACKAGE__ . "::compress_file_zlib(): " : "";
+
+  my ( $size );
+
+  unless ( $file ) {
+    carp( $p . "Keine Datei uebergeben!\n" );
+    return undef;
+  }
+  print $p . "Komprimiere Datei '$file'" . ( verbose() ? " mittels Compress::Zlib" : "" ) . " ...\n";
+
+  # Endung der komprimierten Datei ermitteln
+  my $ce = $self->{'c'}->compressext();
+  if ( not defined($ce) or $ce =~ /^\s*$/ ) {
+    $ce = ".gz";
+  }
+  $ce = "." . $ce if $ce ne "" and $ce !~ /^\./;
+
+  # Gucken, ob Datei ueberhaupt da ist
+  unless ( -f $file ) {
+    warn $p . "Datei '$file' existiert nicht!\n";
+    return 1;
+  }
+
+  # Weiter, wenn Dateigroesse == 0
+  $size = ( -s $file );
+  unless ( $size ) {
+    print $p . "Datei '$file' hat Groesse 0, wird nicht komprimiert.\n";
+    return 1;
+  }
+
+  # Ermittlung Compress-Level
+  my $level = 5;
+  if ( $self->{'c'}{'compressoptions'} and $self->{'c'}{'compressoptions'} =~ /^[^\d-]*-(\d)/ ) {
+    $level = $1;
+  }
+  print $p . "Gewuenschtes Kompressions-Level: $level\n" if verbose() > 1;
+  unless ( $level ) {
+    warn $p . "Kompressions-Level '0' eingestellt, keine Kompression.\n";
+    return 1;
+  }
+
+  # Weiter, wenn Testmodus
+  return 1 if $self->{'test'};
+
+  my $blocks = int( $size / default_buffer_size );
+  my $every = $blocks > 70 ? int( $blocks / 70 ) + 1 : 1;
+  my $i = 0;
+  my $target = $file . $ce;
+  my $strategy = eval "Z_DEFAULT_STRATEGY";
+  my ( $gz, $buffer );
+  my ( @Stat );
+
+  unless ( open LOG, "<", "$file" ) {
+    warn $p . "Problem beim Oeffnen der Logdatei '$file' zum Lesen: $!\n";
+    return undef;
+  }
+
+  unless ( $gz = eval " gzopen( '$target', 'wb' )" ) {
+    warn $p . "Kann komprimierte Datei '$target'  nicht schreiben: $!.\n";
+    close LOG;
+    return undef;
+  }
+
+  print "   ";
+  $gz->gzsetparams( $level, $strategy );
+  while ( read LOG, $buffer, default_buffer_size ) {
+    $i++;
+    $gz->gzwrite( $buffer );
+    print "." if verbose() and ( $i % $every == 0 );
+  }
+  $gz->gzclose();
+
+  close LOG;
+  print "\n" if verbose();
+
+  @Stat = stat $file;
+  my ( $mode, $uid, $gid, $mtime ) = @Stat[ 2, 4, 5, 9 ];
+  $mode &= 0777;
+
+  print $p . "Setze Permissions von '$target'.\n" if verbose();
+  unless ( chmod $mode, $target ) {
+    warn $p . "Problem beim Setzen der Permissions von '$target': $!\n";
+  }
+
+  print $p . "Setze Mtime von '$target'.\n" if verbose();
+  unless ( utime $mtime, $mtime, $target ) {
+    warn $p . "Problem beim Setzen der Mtime von '$target': $!\n";
+  }
+
+  print $p . "Setze Besitzerschaft von '$target'.\n" if verbose();
+  unless ( chown $uid, $gid, $target ) {
+    warn $p . "Problem beim Setzen der Besitzerschaft von '$target': $!\n";
+  }
+
+  print $p . "Loesche Original-Datei '$file' ...\n" if verbose();
+  unless ( unlink $file ) {
+    warn $p . "Problem beim Loeschen von '$file': $!\n";
+    return undef;
+  }
+
+  return 1;
+
+}
+
+#------------------------------------------------------------------------------------
+
 =head2 create_olddir ( $logfile )
 
 Checkt das Vorhandensein von $self-E<gt>{'c'}{'logfiles'}{$logfile}{'olddir'}, vorher werden aber die
@@ -671,6 +998,42 @@ sub create_olddir($$) {
 
 #------------------------------------------------------------------------------------
 
+=head2 delete_oldfiles( )
+
+Loescht alle alten Logdateien, die in $self->{'files_delete'} erfasst worden sind.
+
+=cut
+
+sub delete_oldfiles($) {
+
+  my $self = shift;
+  my $p = verbose() ? __PACKAGE__ . "::delete_oldfiles(): " : "";
+
+  print $p . "Loesche alte Logdateien ...\n" if verbose();
+
+  unless ( $self->{'files_delete'} and scalar( keys %{$self->{'files_delete'}} ) ) {
+    print $p . "Keine alten Logdateien zum Loeschen gefunden.\n";
+    return 1;
+  }
+
+  my ( $file );
+
+  for $file ( sort keys %{$self->{'files_delete'}} ) {
+    print $p . "Loesche alte Logdatei '$file' ...\n";
+    unless ( $self->{'test'} ) {
+      unless ( unlink($file) ) {
+        warn $p . "Konnte alte Logdatei '$file' nicht loeschen: $!\n";
+        return undef;
+      }
+    }
+  }
+
+  return 1;
+
+}
+
+#------------------------------------------------------------------------------------
+
 =head2 find_rotatings( $file, $target )
 
 Findet an Hand des uebergebenen Logdatei-Namens und des Dateinamens der rotierten Datei
@@ -1026,6 +1389,8 @@ sub rotate_file($$) {
     carp( $p . "Keine Logdatei uebergeben!\n" );
     return undef;
   }
+  print "\n";
+  print( ("-" x 20) . "\n\n") if verbose() > 1;
   print $p . "Rotiere Logdatei '$file'.\n" if verbose();
   my $f = $self->{'c'}{'logfiles'}{$file};
 
@@ -1176,8 +1541,10 @@ sub rotate_file($$) {
 
   }
 
-  # Ermittlung aller bisherigen Logfiles ...
-  my $old_logfiles = $self->collect_old_logfiles( $file );
+  my ( $old_logfiles, $files_delete, $files_compress );
+
+  # Ermittlung aller bisherigen Logdateien ...
+  $old_logfiles = $self->collect_old_logfiles( $file );
   unless ( $old_logfiles ) {
     warn $p . "Fehler beim Ermitteln der bisher rotierten Logdateien.\n";
     return undef;
@@ -1186,8 +1553,9 @@ sub rotate_file($$) {
   print $p . "Liste aller bisher rotierten Logdateien: " . Dumper($old_logfiles) if verbose() > 2;
   $f->{'oldfiles'} = $old_logfiles;
 
+  # Ermittlung der alten Logdateien, die zu loeschen sind ...
   if ( scalar( keys %$old_logfiles ) ) {
-    my $files_delete = $self->collect_files_delete($file);
+    $files_delete = $self->collect_files_delete($file);
     unless ( $files_delete ) {
       warn $p . "Fehler beim Ermitteln der bisher zu loeschenden alten Logdateien.\n";
       return undef;
@@ -1201,7 +1569,7 @@ sub rotate_file($$) {
 
   # Ermittlung der zu komprimierenden Logdateien ...
   if ( $f->{'compress'} and scalar( keys %$old_logfiles ) ) {
-    my $files_compress = $self->collect_compress_logfiles($file);
+    $files_compress = $self->collect_compress_logfiles($file);
     unless ( $files_compress ) {
       warn $p . "Fehler beim Ermitteln der zu komprimierenden Logdateien.\n";
       return undef;
@@ -1214,6 +1582,18 @@ sub rotate_file($$) {
     }
   }
 
+  # Und Muell wegraeumen ...
+  delete $f->{'oldfiles'};
+  $old_logfiles   = undef;
+  $files_delete   = undef;
+  $files_compress = undef;
+
+  # und schliesslich noch das Rueckschreiben des Rotierens in die Statusdatei ...
+  unless ( $self->{'state_file'}->write_logfile($file) ) {
+    die $p . "Fehler beim Schreiben der Statusdatei.\n";
+    return undef;
+  }
+
   return 1;
 
 }
diff --git a/logrotate.pl b/logrotate.pl
index 7f83761..421da8f 100755
--- a/logrotate.pl
+++ b/logrotate.pl
@@ -249,8 +249,17 @@ print "Phase 2: Eigentliches Rotieren ...\n\n";
 
 $lr->rotate();
 
+print "\n";
+print( ("-" x 80) . "\n\n") if $verbose > 1;
+print "Phase 3: Loeschen der alten Logdateien ...\n\n";
+
+$lr->delete_oldfiles();
 
+print "\n";
+print( ("-" x 80) . "\n\n") if $verbose > 1;
+print "Phase 4: Komprimieren der alten Logdateien ...\n\n";
 
+$lr->compress();
 
 $lr = undef;