1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
|
#!/usr/bin/perl
#
# re-mqueue -- requeue messages from queueA to queueB based on age.
#
# Contributed by Paul Pomes <ppomes@Qualcomm.COM>.
# http://www.qualcomm.com/~ppomes/
#
# Usage: re-mqueue [-d] queueA queueB seconds
#
# -d enable debugging
# queueA source directory
# queueB destination directory
# seconds select files older than this number of seconds
#
# Example: re-mqueue /var/spool/mqueue /var/spool/mqueue2 2700
#
# Moves the qf* and df* files for a message from /var/spool/mqueue to
# /var/spool/mqueue2 if the df* file is over 2700 seconds old.
#
# The qf* file can't be used for age checking as it's partially re-written
# with the results of the last queue run.
#
# Rationale: With a limited number of sendmail processes allowed to run,
# messages that can't be delivered immediately slow down the ones that can.
# This becomes especially important when messages are being queued instead
# of delivered right away, or when the queue becomes excessively deep.
# By putting messages that have already failed one or more delivery attempts
# into another queue, the primary queue can be kept small and fast.
#
# On postoffice.cso.uiuc.edu, the primary sendmail daemon runs the queue
# every thirty minutes. Messages over 45 minutues old are moved to
# /var/spool/mqueue2 where sendmail runs every hour. Messages more than
# 3.25 hours old are moved to /var/spool/mqueue3 where sendmail runs every
# four hours. Messages more than a day old are moved to /var/spool/mqueue4
# where sendmail runs three times a day. The idea is that a message is
# tried at least twice in the first three queues before being moved to the
# old-age ghetto.
#
# (Each must be re-formed into a single line before using in crontab)
#
# 08 * * * * /usr/local/libexec/re-mqueue /var/spool/mqueue ## /var/spool/mqueue2 2700
# 11 * * * * /usr/lib/sendmail -oQ/var/spool/mqueue2 -q > ## > /var/log/mqueue2 2>&1
# 38 * * * * /usr/local/libexec/re-mqueue /var/spool/mqueue2
# /var/spool/mqueue3 11700
# 41 1,5,9,13,17,21 * * * /usr/lib/sendmail -oQ/var/spool/mqueue3 -q ## > /var/log/mqueue3 2>&1
# 48 * * * * /usr/local/libexec/re-mqueue /var/spool/mqueue3
# /var/spool/mqueue4 100000
#53 3,11,19 * * * /usr/lib/sendmail -oQ/var/spool/mqueue4 -q > ## > /var/log/mqueue4 2>&1
#
#
# N.B., the moves are done with link(). This has two effects: 1) the mqueue*
# directories must all be on the same filesystem, and 2) the file modification
# times are not changed. All times must be cumulative from when the df*
# file was created.
#
# Copyright (c) 1995 University of Illinois Board of Trustees and Paul Pomes
# All rights reserved.
#
# Redistribution and use in source and binary forms, with or without
# modification, are permitted provided that the following conditions
# are met:
# 1. Redistributions of source code must retain the above copyright
# notice, this list of conditions and the following disclaimer.
# 2. Redistributions in binary form must reproduce the above copyright
# notice, this list of conditions and the following disclaimer in the
# documentation and/or other materials provided with the distribution.
# 3. All advertising materials mentioning features or use of this software
# must display the following acknowledgement:
# This product includes software developed by the University of
# Illinois at Urbana and their contributors.
# 4. Neither the name of the University nor the names of their contributors
# may be used to endorse or promote products derived from this software
# without specific prior written permission.
#
# THIS SOFTWARE IS PROVIDED BY THE TRUSTEES AND CONTRIBUTORS ``AS IS'' AND
# ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
# ARE DISCLAIMED. IN NO EVENT SHALL THE TRUSTEES OR CONTRIBUTORS BE LIABLE
# FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
# DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
# OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
# HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
# OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
# SUCH DAMAGE.
#
# @(#)$FreeBSD$
require "syslog.pl";
$LOCK_EX = 2;
$LOCK_NB = 4;
$LOCK_UN = 8;
# Count arguments, exit if wrong in any way.
die "Usage: $0 [-d] queueA queueB seconds\n" if ($#ARGV < 2);
while ($_ = $ARGV[0], /^-/) {
shift;
last if /^--$/;
/^-d/ && $debug++;
}
$queueA = shift;
$queueB = shift;
$age = shift;
die "$0: $queueA not a directory\n" if (! -d $queueA);
die "$0: $queueB not a directory\n" if (! -d $queueB);
die "$0: $age isn't a valid number of seconds for age\n" if ($age =~ /\D/);
# chdir to $queueA and read the directory. When a df* file is found, stat it.
# If it's older than $age, lock the corresponding qf* file. If the lock
# fails, give up and move on. Once the lock is obtained, verify that files
# of the same name *don't* already exist in $queueB and move on if they do.
# Otherwise re-link the qf* and df* files into $queueB then release the lock.
chdir "$queueA" || die "$0: can't cd to $queueA: $!\n";
opendir (QA, ".") || die "$0: can't open directory $queueA for reading: $!\n";
@dfiles = grep(/^df/, readdir(QA));
$now = time();
($program = $0) =~ s,.*/,,;
&openlog($program, 'pid', 'mail');
# Loop through the dfiles
while ($dfile = pop(@dfiles)) {
print "Checking $dfile\n" if ($debug);
($qfile = $dfile) =~ s/^d/q/;
($mfile = $dfile) =~ s/^df//;
if (! -e $dfile || -z $dfile) {
print "$dfile is gone or zero bytes - skipping\n" if ($debug);
next;
}
if (! -e $qfile || -z $qfile) {
print "$qfile is gone or zero bytes - skipping\n" if ($debug);
next;
}
$mtime = $now;
($dev,$ino,$mode,$nlink,$uid,$gid,$rdev,$size,
$atime,$mtime,$ctime,$blksize,$blocks) = stat($dfile);
# Compare timestamps
if (($mtime + $age) > $now) {
printf ("%s is %d seconds old - skipping\n", $dfile, $now-$mtime) if ($debug);
next;
}
# See if files of the same name already exist in $queueB
if (-e "$queueB/$dfile") {
print "$queueb/$dfile already exists - skipping\n" if ($debug);
next;
}
if (-e "$queueB/$qfile") {
print "$queueb/$qfile already exists - skipping\n" if ($debug);
next;
}
# Try and lock qf* file
unless (open(QF, ">>$qfile")) {
print "$qfile: $!\n" if ($debug);
next;
}
$retval = flock(QF, $LOCK_EX|$LOCK_NB) || ($retval = -1);
if ($retval == -1) {
print "$qfile already flock()ed - skipping\n" if ($debug);
close(QF);
next;
}
print "$qfile now flock()ed\n" if ($debug);
# Show time! Do the link()s
if (link("$dfile", "$queueB/$dfile") == 0) {
&syslog('err', 'link(%s, %s/%s): %m', $dfile, $queueB, $dfile);
print STDERR "$0: link($dfile, $queueB/$dfile): $!\n";
exit (1);
}
if (link("$qfile", "$queueB/$qfile") == 0) {
&syslog('err', 'link(%s, %s/%s): %m', $qfile, $queueB, $qfile);
print STDERR "$0: link($qfile, $queueB/$qfile): $!\n";
unlink("$queueB/$dfile");
exit (1);
}
# Links created successfully. Unlink the original files, release the
# lock, and close the file.
print "links ok\n" if ($debug);
if (unlink($qfile) == 0) {
&syslog('err', 'unlink(%s): %m', $qfile);
print STDERR "$0: unlink($qfile): $!\n";
exit (1);
}
if (unlink($dfile) == 0) {
&syslog('err', 'unlink(%s): %m', $dfile);
print STDERR "$0: unlink($dfile): $!\n";
exit (1);
}
flock(QF, $LOCK_UN);
close(QF);
&syslog('info', '%s moved to %s', $mfile, $queueB);
print "Done with $dfile $qfile\n\n" if ($debug);
}
exit 0;
|
