;ς
’)?Bc           @   sχ   d  Z  d k Z d k Z d k Z d k Z d k Z d k Z d k l Z d k l	 Z	 d k l
 Z
 d k l Z d k l Z d k l Z d k l Z d	 k l Z d
 Z y e e f Wn e j
 o d Z d Z n Xd e e f d     YZ d S(   s   Outgoing queue runner.N(   s   mm_cfg(   s   Message(   s   Errors(   s   LockFile(   s   Runner(   s   Switchboard(   s   BounceMixin(   s   syslogi
   i   i    s   OutgoingRunnerc           B   s;   t  Z e i Z e d d  Z d   Z e i	 Z	 d   Z
 RS(   Ni   c         C   sq   t  i |  | |  t i |   d t i } t	 |  } t t i | d  |  _ t |  _ t t i  |  _ d  S(   Ns   Mailman.Handlers.s   process(   s   Runners   __init__s   selfs   slices	   numslicess   BounceMixins   mm_cfgs   DELIVERY_MODULEs   modnames
   __import__s   mods   getattrs   syss   moduless   _funcs   Falses   _OutgoingRunner__loggeds   Switchboards   RETRYQUEUE_DIRs   _OutgoingRunner__retryq(   s   selfs   slices	   numslicess   modnames   mod(    (    s,   /var/mailman/Mailman/Queue/OutgoingRunner.pys   __init__3   s    	c         C   s  | i d d  } t i   | j  o t Sn | i   y` t i   } |  i | | |  | t i   j o! t d d t  t i d  n t |  _ Wnzt i j
 oY t i } | d j o
 d } n |  i o# t d d t i |  t |  _ n t Snt i j
 o} | i d  o |  i | | d  q|  i | i   | i |  | i o­ t i   }	 | i } | i d	 d  }
 | i d
 |	  } t$ |  |
 j o |	 | j o t SqΤn |	 t i% } t$ |  | d	 <| | d
 <| | d <|  i& i' | |  qn Xt Sd  S(   Ns   deliver_afteri    s   errors   child process leaked thru: %si   s   smtps+   Cannot connect to SMTP server %s on port %ss   probe_tokens   last_recip_counts   deliver_untils   recips((   s   msgdatas   gets   deliver_afters   times   Trues   mlists   Loads   oss   getpids   pids   selfs   _funcs   msgs   syslogs   modnames   _exits   Falses   _OutgoingRunner__loggeds   sockets   errors   mm_cfgs   SMTPPORTs   ports   SMTPHOSTs   Errorss   SomeRecipientsFaileds   es   _probe_bounces   _queue_bouncess   internal_names   permfailuress   tempfailuress   nows   recipss   last_recip_counts   deliver_untils   lens   DELIVERY_RETRY_PERIODs   _OutgoingRunner__retryqs   enqueue(   s   selfs   mlists   msgs   msgdatas   pids   recipss   ports   deliver_untils   es   nows   last_recip_counts   deliver_after(    (    s,   /var/mailman/Mailman/Queue/OutgoingRunner.pys   _dispose@   sL    
	
	
	

c         C   s   t  i |   t i |   d  S(   N(   s   BounceMixins   _cleanups   selfs   Runner(   s   self(    (    s,   /var/mailman/Mailman/Queue/OutgoingRunner.pys   _cleanup   s    (   s   __name__s
   __module__s   mm_cfgs   OUTQUEUE_DIRs   QDIRs   Nones   __init__s   _disposes   BounceMixins   _doperiodics   _cleanup(    (    (    s,   /var/mailman/Mailman/Queue/OutgoingRunner.pys   OutgoingRunner0   s
   		C	(   s   __doc__s   oss   syss   copys   times   sockets   emails   Mailmans   mm_cfgs   Messages   Errorss   LockFiles   Mailman.Queue.Runners   Runners   Mailman.Queue.Switchboards   Switchboards   Mailman.Queue.BounceRunners   BounceMixins   Mailman.Logging.Syslogs   syslogs   DEAL_WITH_PERMFAILURES_EVERYs   Trues   Falses	   NameErrors   OutgoingRunner(   s   BounceMixins   Errorss   Falses   sockets   DEAL_WITH_PERMFAILURES_EVERYs   Runners   Trues   Switchboards   LockFiles   syss   syslogs   mm_cfgs   OutgoingRunners   times   Messages   copys   oss   email(    (    s,   /var/mailman/Mailman/Queue/OutgoingRunner.pys   ?   s*   						