diff options
Diffstat (limited to 'usr.sbin/sendmail/contrib/re-mqueue.pl')
| -rw-r--r-- | usr.sbin/sendmail/contrib/re-mqueue.pl | 203 |
1 files changed, 0 insertions, 203 deletions
diff --git a/usr.sbin/sendmail/contrib/re-mqueue.pl b/usr.sbin/sendmail/contrib/re-mqueue.pl deleted file mode 100644 index 9a8f8b4..0000000 --- a/usr.sbin/sendmail/contrib/re-mqueue.pl +++ /dev/null @@ -1,203 +0,0 @@ -#!/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. -# -# @(#)$Id$ - -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; |
