| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | intermediate | bwarsaw | 2001-02-15 | 1 | -24/+122 | |
| | | ||||||
| * | intermediate | bwarsaw | 2001-02-15 | 1 | -1/+1 | |
| | | ||||||
| * | intermediate | bwarsaw | 2001-02-15 | 1 | -1/+1 | |
| | | ||||||
| * | intermediate | bwarsaw | 2001-02-15 | 1 | -0/+1 | |
| | | ||||||
| * | __init__(): Accept information for hash space slicing (slice number | bwarsaw | 2001-02-15 | 1 | -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. | |||||
| * | intermediate | bwarsaw | 2001-02-15 | 1 | -33/+53 | |
| | | ||||||
| * | intermediate | bwarsaw | 2001-02-15 | 1 | -91/+72 | |
| | | ||||||
| * | intermediate | bwarsaw | 2001-02-15 | 1 | -0/+27 | |
| | | ||||||
| * | intermediate | bwarsaw | 2001-02-15 | 1 | -0/+47 | |
| | | ||||||
| * | intermediate | bwarsaw | 2001-02-15 | 1 | -0/+230 | |
| | | ||||||
| * | intermediate | bwarsaw | 2001-02-15 | 1 | -0/+55 | |
| | | ||||||
| * | Multiple queue runner classes, in a new package Mailman.Queue. | bwarsaw | 2000-12-20 | 7 | -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. | ||||||
