/[smeserver]/rpms/smeserver-qpsmtpd/sme8/smeserver-qpsmtpd-1.2.1-logterse_stats.patch
ViewVC logotype

Contents of /rpms/smeserver-qpsmtpd/sme8/smeserver-qpsmtpd-1.2.1-logterse_stats.patch

Parent Directory Parent Directory | Revision Log Revision Log | View Revision Graph Revision Graph


Revision 1.1 - (show annotations) (download)
Tue Jun 12 21:05:55 2007 UTC (17 years, 4 months ago) by slords
Branch: MAIN
CVS Tags: smeserver-qpsmtpd-1_2_1-42_el5_sme, smeserver-qpsmtpd-1_2_1-39_el5_sme, smeserver-qpsmtpd-1_2_1-45_el5_sme, smeserver-qpsmtpd-1_2_1-51_el5_sme, smeserver-qpsmtpd-1_2_1-52_el5_sme, smeserver-qpsmtpd-1_2_1-40_el5_sme, smeserver-qpsmtpd-1_2_1-47_el5_sme, smeserver-qpsmtpd-1_2_1-49_el5_sme, smeserver-qpsmtpd-1_2_1-57_el5_sme, smeserver-qpsmtpd-1_2_1-44_el5_sme, smeserver-qpsmtpd-1_2_1-55_el5_sme, smeserver-qpsmtpd-1_2_1-56_el5_sme, smeserver-qpsmtpd-1_2_1-53_el5_sme, smeserver-qpsmtpd-1_2_1-54_el5_sme, smeserver-qpsmtpd-1_2_1-41_el5_sme, smeserver-qpsmtpd-1_2_1-50_el5_sme, smeserver-qpsmtpd-1_2_1-43_el5_sme, smeserver-qpsmtpd-1_2_1-46_el5_sme
Import on branch sme8 of package smeserver-qpsmtpd-1.2.1-39.el5.sme.src.rpm

1 diff -Nur -x '*.orig' -x '*.rej' smeserver-qpsmtpd-1.2.1/root/var/service/qpsmtpd/log/run mezzanine_patched_smeserver-qpsmtpd-1.2.1/root/var/service/qpsmtpd/log/run
2 --- smeserver-qpsmtpd-1.2.1/root/var/service/qpsmtpd/log/run 2005-04-20 22:35:31.000000000 -0600
3 +++ mezzanine_patched_smeserver-qpsmtpd-1.2.1/root/var/service/qpsmtpd/log/run 2007-06-07 09:41:00.000000000 -0600
4 @@ -24,4 +24,4 @@
5 exec \
6 /usr/local/bin/setuidgid smelog \
7 /usr/local/bin/multilog t s5000000 \
8 - /var/log/qpsmtpd
9 + !/usr/local/bin/qplogsumm.pl /var/log/qpsmtpd
10 diff -Nur -x '*.orig' -x '*.rej' usr/local/bin/qplogsumm.pl mezzanine_patched_usr/local/bin/qplogsumm.pl
11 --- usr/local/bin/qplogsumm.pl 1969-12-31 17:00:00.000000000 -0700
12 +++ mezzanine_patched_usr/local/bin/qplogsumm.pl 2007-06-07 09:37:09.000000000 -0600
13 @@ -0,0 +1,272 @@
14 +#!/usr/bin/perl
15 +#
16 +
17 +=pod
18 +
19 +=head1 SUMMARY
20 +
21 +Works with multilog to analyse and summarise log entries generated by the logterse plugin. It is designed
22 +to be invoked by multilog at log-rotation time. This is specified by an argument to multilog similar to:
23 +
24 +=over 4
25 +
26 +multilog t !/path/to/qplogsumm ./main
27 +
28 +=back
29 +
30 +When qplogsumm is invoked, each line will be echoed, meaning the stored log is unchanged, but summary
31 +information will be written to fd 5 and so stored in the 'state' file by multilog.
32 +
33 +This file is fed in on fd 4 at the beginning of the next log rotation, so running totals, etc can be maintained.
34 +
35 +=head1 State file format:
36 +
37 +One entry per line containing three fields separated by whitespace:
38 +
39 +=over 4
40 +
41 +=item 1. Disposition (plugin) name.
42 +
43 +=item 2. tai64n timestamp recording the first time it was seen in a log.
44 +
45 +=item 3. long-term running total.
46 +
47 +=back
48 +
49 +A disposition is effectively the plugin name that called DENY or the string 'queued' for
50 +messages that made it through.
51 +
52 +A line containing a disposition name of LOGFILE_EPOCH and a timestamp for the earliest known log entry.
53 +
54 +Other derived data, such as percentages etc. can also appear in the file, commented
55 +by a # character. This will be ignored on the next intake.
56 +
57 +=head1 AUTHOR
58 +
59 +Charles Butcher
60 +
61 +=head1 VERSION
62 +
63 +This is release 1.0
64 +
65 +=cut
66 +
67 +use strict;
68 +use POSIX qw(strftime);
69 +
70 +
71 +my $FS = "\t"; # field separator used by logterse plugin
72 +my %disp; # hash of dispositions
73 +
74 +if (open PREVIOUS, "<&4")
75 +{
76 + while (<PREVIOUS>)
77 + {
78 + chomp();
79 + next if m/^#/;
80 + next if m/^\s*$/;
81 + my ($plug_name, $plug_epoch, $plug_cumulative) = split /\s/;
82 + my $c = { epoch => $plug_epoch, cum => $plug_cumulative, curr => 0 };
83 + $disp{$plug_name} = $c;
84 + }
85 +
86 + close PREVIOUS;
87 +}
88 +
89 +my $first_timestamp = 0;
90 +my $last_timestamp = 0;
91 +
92 +
93 +while (<>)
94 +{
95 + print;
96 + chomp;
97 + next unless m/terse plugin/;
98 +
99 + my ($timestamp_part, $log_part) = split '`';
100 + my ($current_timestamp) = split /\s/, $timestamp_part;
101 + $first_timestamp = $current_timestamp unless $first_timestamp;
102 + $last_timestamp = $current_timestamp;
103 +
104 + my (@log_items) = split $FS, $log_part;
105 + my $disposition = $log_items[5];
106 + next unless defined $disposition;
107 +
108 + if ($disp{$disposition})
109 + {
110 + $disp{$disposition}->{curr} = 1;
111 + }
112 + else # a new plugin -- make a note of when it first appeared
113 + {
114 + my $c = { epoch => $current_timestamp, cum => 0, curr => 1 };
115 + $disp{$disposition} = $c;
116 + }
117 +}
118 +
119 +
120 +#
121 +# Set overall epoch
122 +#
123 +if (!exists $disp{'LOGFILE_EPOCH'})
124 +{
125 + my $c = { epoch => $first_timestamp, cum => 0, curr => 0};
126 + $disp{'LOGFILE_EPOCH'} = $c;
127 +}
128 +
129 +my $current_total = 0;
130 +my $cumulative_total = 0;
131 +
132 +open HOLDOVER, ">&5" and select HOLDOVER;
133 +
134 +#
135 +# Output cumulative values for intake the next time a log is processed
136 +#
137 +for my $c (keys %disp)
138 +{
139 + $disp{$c}->{cum} = $disp{$c}->{curr};
140 + $current_total = $disp{$c}->{curr};
141 + $cumulative_total = $disp{$c}->{cum};
142 +
143 + printf "%-30.30s %s %12d\n", $c, $disp{$c}->{epoch}, $disp{$c}->{cum};
144 +}
145 +
146 +#
147 +# Output current logfile stats
148 +#
149 +
150 +my $current_elapsed = tai64diff($last_timestamp, $first_timestamp);
151 +
152 +printf "#
153 +# Most recent logfile
154 +# -------------------
155 +#
156 +# Start : %s
157 +# Finish : %s
158 +# Elapsed: %s
159 +#
160 +# Total transactions : %9d
161 +# Average tx per hour: %9d
162 +",
163 + tai64utc($first_timestamp),
164 + tai64utc($last_timestamp),
165 + seconds_to_days($current_elapsed),
166 + $current_total,
167 + $current_total / ($current_elapsed / 3600),
168 + ;
169 +
170 +#
171 +# Output cumulative log stats
172 +#
173 +my $cumulative_elapsed = tai64diff($last_timestamp, $disp{'LOGFILE_EPOCH'}->{epoch});
174 +
175 +printf "#
176 +# Cumulative Totals
177 +# -----------------
178 +#
179 +# Start : %s
180 +# Finish : %s
181 +# Elapsed: %s
182 +#
183 +# Total transactions : %12d
184 +# Average tx per hour: %12d
185 +",
186 + tai64utc($disp{'LOGFILE_EPOCH'}->{epoch}),
187 + tai64utc($last_timestamp),
188 + seconds_to_days($cumulative_elapsed),
189 + $cumulative_total,
190 + $cumulative_total / ($cumulative_elapsed / 3600),
191 + ;
192 +
193 +
194 +#
195 +# Output per-plugin stats
196 +#
197 +
198 +print "#
199 +# Most Recent Logfile Cumulative Totals
200 +# Disposition (plugin) Total Avg/Day Total Avg/Day
201 +# ----------------------------------------------------------------------------\n";
202 +
203 +my $printf_format = "# %-30.30s %6d %3d%% %8d %10d %3d%% %8d\n";
204 +
205 +foreach my $c (sort { $disp{$b}->{curr} <=> $disp{$a}->{curr} } keys %disp)
206 +{
207 + next if ($c eq 'LOGFILE_EPOCH');
208 +
209 + printf $printf_format,
210 + $c,
211 + $disp{$c}->{curr},
212 + $disp{$c}->{curr} / $current_total * 100,
213 + $disp{$c}->{curr} / ($current_elapsed / 86400),
214 + $disp{$c}->{cum},
215 + $disp{$c}->{cum} / $cumulative_total * 100,
216 + $disp{$c}->{cum} / (tai64diff($last_timestamp, $disp{$c}->{epoch}) / 86400),
217 + ;
218 +}
219 +
220 +print "# ----------------------------------------------------------------------------\n";
221 +printf $printf_format,
222 + 'TOTALS',
223 + $current_total,
224 + 100,
225 + $current_total / ($current_elapsed / 86400),
226 + $cumulative_total,
227 + 100,
228 + $cumulative_total / ($cumulative_elapsed / 86400),
229 + ;
230 +
231 +exit 0;
232 +
233 +
234 +sub tai64utc {
235 + my ($s) = @_;
236 +
237 + # @400000003f6c7bc5253bf98c
238 + # 0123456789012345678901234
239 + # 0 1 2
240 + # |-------------||------|
241 + if (substr($s, 0, 2) eq '@4') {
242 + my $ts = hex(substr($s, 2, 15));
243 + $s = strftime('%Y-%m-%d %H:%M:%S', gmtime($ts));
244 + }
245 + return $s;
246 +}
247 +
248 +#
249 +# Return difference in seconds
250 +#
251 +sub tai64diff
252 +{
253 + my ($s1, $s2) = @_;
254 +
255 + # @400000003f6c7bc5253bf98c
256 + # 0123456789012345678901234
257 + # 0 1 2
258 + # |-------------||------|
259 + if (substr($s1, 0, 2) eq '@4' and substr($s2, 0, 2) eq '@4')
260 + {
261 + my $ts1 = hex(substr($s1, 2, 15));
262 + my $ts2 = hex(substr($s2, 2, 15));
263 + return $ts1 - $ts2;
264 + }
265 + else
266 + {
267 + return 0;
268 + }
269 +}
270 +
271 +
272 +#
273 +# Return an english phrase representing a number of seconds
274 +#
275 +sub seconds_to_days
276 +{
277 + my ($secs) = @_;
278 +
279 + my $phrase = sprintf "%d days, ", ($secs / 86400);
280 + $secs %= 86400;
281 + $phrase .= sprintf "%d hours, ", ($secs / 3600);
282 + $secs %= 3600;
283 + $phrase .= sprintf "%d mins, %d secs", ($secs / 60), ($secs % 60);
284 +}
285 +

admin@koozali.org
ViewVC Help
Powered by ViewVC 1.2.1 RSS 2.0 feed