summaryrefslogtreecommitdiff
path: root/Mailman/Queue
Commit message (Collapse)AuthorAgeFilesLines
...
* intermediatebwarsaw2001-02-151-24/+122
|
* intermediatebwarsaw2001-02-151-1/+1
|
* intermediatebwarsaw2001-02-151-1/+1
|
* intermediatebwarsaw2001-02-151-0/+1
|
* __init__(): Accept information for hash space slicing (slice numberbwarsaw2001-02-151-87/+112
| | | | | | | | | | | | | | | | | | | | | | | | | | | | and total number of slices). Create the runner-specific switchboard, the shunt switchboard (for messages that generate uncaught exceptions), and the mainloop stop flag. We also have no need for a runner-specific lock since the qrunner watchdog infrastructure handles all that for us now. _dequeue(): This is no longer part of the Runner interface (it's been moved to the Switchboard). run(), __oneloop(), __onefile(): Rework the mainloop for flexibility and robustness. run() is the main loop and handles KeyboardInterrupt exceptons, guaranteed cleanup at mainloop exit, checking the stop flag and calling _doperiod() after each cycle through the mainloop, and sleeping for a while if there are no files in the queue directory. __oneloop() handles cruising through the list of all the files in the queue (modulo any hash space slicing) exactly once. __onefile(): handles the work for one queue file. _snooze(): sleeps for a specified amount of time. _log(): A convenient logging facility for subclasses _start(), _onefile(): deleted.
* intermediatebwarsaw2001-02-151-33/+53
|
* intermediatebwarsaw2001-02-151-91/+72
|
* intermediatebwarsaw2001-02-151-0/+27
|
* intermediatebwarsaw2001-02-151-0/+47
|
* intermediatebwarsaw2001-02-151-0/+230
|
* intermediatebwarsaw2001-02-151-0/+55
|
* Multiple queue runner classes, in a new package Mailman.Queue.bwarsaw2000-12-207-0/+513
Runner is the base class providing the framework for other qrunner specializations. IncomingRunner runs through qfiles/in taking messages from the smtpd, sending them through the standard message handler pipeline and potentially writing the message to qfiles/out or qfiles/news. OutgoingRunner takes message from qfiles/out and hands them over to the MTA. NewsRunner takes message from qfiles/news and hands them over to the news server.