ó
Rü½cc           @   s„   d  d l  Z  d  d l m Z d  d l m Z d  d l m Z y e e f Wn e	 k
 ri d Z d Z n Xd e f d „  ƒ  YZ
 d S(	   iÿÿÿÿN(   t   mm_cfg(   t   Runner(   t   Switchboardi   i    t   RetryRunnerc           B   sA   e  Z e j Z e j d  ƒ Z d d d „ Z d „  Z	 d „  Z
 RS(   i   i   c         C   s)   t  j |  | | ƒ t t j ƒ |  _ d  S(   N(   R   t   __init__R   R    t   OUTQUEUE_DIRt   _RetryRunner__outq(   t   selft   slicet	   numslices(    (    s8   /export/web/mailman/mailman/Mailman/Queue/RetryRunner.pyR   #   s    c         C   s?   | j  d d ƒ } t j ƒ  | k  r( t S|  j j | | ƒ t S(   Nt   deliver_afteri    (   t   gett   timet   TrueR   t   enqueuet   False(   R   t   mlistt   msgt   msgdataR
   (    (    s8   /export/web/mailman/mailman/Mailman/Queue/RetryRunner.pyt   _dispose'   s
    c         C   s   t  j |  j ƒ d  S(   N(   R   t   sleept	   SLEEPTIME(   R   t   filecnt(    (    s8   /export/web/mailman/mailman/Mailman/Queue/RetryRunner.pyt   _snooze/   s    N(   t   __name__t
   __module__R    t   RETRYQUEUE_DIRt   QDIRt   minutesR   t   NoneR   R   R   (    (    (    s8   /export/web/mailman/mailman/Mailman/Queue/RetryRunner.pyR      s
   		(   R   t   MailmanR    t   Mailman.Queue.RunnerR   t   Mailman.Queue.SwitchboardR   R   R   t	   NameErrorR   (    (    (    s8   /export/web/mailman/mailman/Mailman/Queue/RetryRunner.pyt   <module>   s   
