viewvc.cgi/cricket/parse_maillog.pl

#!/usr/bin/perl -wT

# this script can be run periodicly on log mail.log file to report
# change since last run.
#
# Dobrica Pavlinusic <dpavlin@rot13.org>

use strict;

my $log="/var/adm/syslog.dated/current/mail.log";

# edit this to your configuration!

my $domain='@pliva.hr';
my $delta="/var/tmp/";

my $debug=1;

# counters
my ($mail_int, $mail_ext) = (0,0,0,0);
# size
my ($size_int, $size_ext) = (0,0,0,0);

open(LOG,$log) || die "can't open log";

my $tmp_log=$log;
$tmp_log=~s/\W/_/g;
$delta.=$tmp_log.".offset";

if (-e $delta) {
        open(D,$delta) || die "can't open delta file '$delta' for log '$log'";
        my $offset=<D>;
        chomp $offset;
        close(D);
        my $log_size = -s $log;
        print "log size: $log_size\n" if ($debug);
        if ($offset <= $log_size) {
                seek(LOG,$offset,0);
                print STDERR "skipping to position: $offset\n" if ($debug);
        } else {
                print STDERR "reset position to begin\n" if ($debug);
        }
}

my $lines=0;

while(<LOG>) {
        chomp;
        if (m/from=[^\@]+\@[^\@]+$domain[>,]+\s+.*size=(\d+)/ || m/from=[^\@]+[,\s]+.*size=(\d+)/ ) {
                $mail_int++;
                $size_int+=$1;
        } elsif (m/from=.*size=(\d+)/) {
                $mail_ext++;
                $size_ext+=$1;
        }
        $lines++;
}

print STDERR "processed $lines lines...\n" if ($debug);

open(D,"> $delta") || die "can't open delta file '$delta' for log '$log'";
print D tell(LOG);
close(D);

print STDERR "last position in log: ".tell(LOG)."\n" if ($debug);

print "$mail_int
$size_int
$mail_ext
$size_ext
";
1	dpavlin	1.1	#!/usr/bin/perl -wT
2
3			# this script can be run periodicly on log mail.log file to report
4			# change since last run.
5			#
6			# Dobrica Pavlinusic <dpavlin@rot13.org>
7
8			use strict;
9
10			my $log="/var/adm/syslog.dated/current/mail.log";
11
12			# edit this to your configuration!
13
14			my $domain='@pliva.hr';
15			my $delta="/var/tmp/";
16
17			my $debug=1;
18
19			# counters
20			my ($mail_int, $mail_ext) = (0,0,0,0);
21			# size
22			my ($size_int, $size_ext) = (0,0,0,0);
23
24			open(LOG,$log) \|\| die "can't open log";
25
26			my $tmp_log=$log;
27			$tmp_log=~s/\W/_/g;
28			$delta.=$tmp_log.".offset";
29
30			if (-e $delta) {
31			open(D,$delta) \|\| die "can't open delta file '$delta' for log '$log'";
32			my $offset=<D>;
33			chomp $offset;
34			close(D);
35			my $log_size = -s $log;
36			print "log size: $log_size\n" if ($debug);
37			if ($offset <= $log_size) {
38			seek(LOG,$offset,0);
39			print STDERR "skipping to position: $offset\n" if ($debug);
40			} else {
41			print STDERR "reset position to begin\n" if ($debug);
42			}
43			}
44
45			my $lines=0;
46
47			while(<LOG>) {
48			chomp;
49			if (m/from=[^\@]+\@[^\@]+$domain[>,]+\s+.size=(\d+)/ \|\| m/from=[^\@]+[,\s]+.size=(\d+)/ ) {
50			$mail_int++;
51			$size_int+=$1;
52			} elsif (m/from=.*size=(\d+)/) {
53			$mail_ext++;
54			$size_ext+=$1;
55			}
56			$lines++;
57			}
58
59			print STDERR "processed $lines lines...\n" if ($debug);
60
61			open(D,"> $delta") \|\| die "can't open delta file '$delta' for log '$log'";
62			print D tell(LOG);
63			close(D);
64
65			print STDERR "last position in log: ".tell(LOG)."\n" if ($debug);
66
67			print "$mail_int
68			$size_int
69			$mail_ext
70			$size_ext
71			";