;ς
’)?Bc           @   s   d  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 e
 f d	     YZ d S(
   s   Incoming queue runner.N(   s   StringIO(   s   mm_cfg(   s   Errors(   s   LockFile(   s   Runner(   s   syslogs   IncomingRunnerc           B   s,   t  Z e i Z d   Z d   Z d   Z RS(   Nc         C   s’   y | i d t i  Wn t i j
 o d Sn Xz\ |  i | | |  } | | d <|  i | | | |  } | o | d =n | i   | SWd  | i   Xd  S(   Ns   timeouti   s   pipeline(   s   mlists   Locks   mm_cfgs   LIST_LOCK_TIMEOUTs   LockFiles   TimeOutErrors   selfs   _get_pipelines   msgs   msgdatas   pipelines   _dopipelines   mores   Saves   Unlock(   s   selfs   mlists   msgs   msgdatas   pipelines   more(    (    s,   /var/mailman/Mailman/Queue/IncomingRunner.pys   _disposep   s    		

 c         C   s$   | i d t | d t i   Sd  S(   Ns   pipeline(   s   msgdatas   gets   getattrs   mlists   mm_cfgs   GLOBAL_PIPELINE(   s   selfs   mlists   msgs   msgdata(    (    s,   /var/mailman/Mailman/Queue/IncomingRunner.pys   _get_pipeline   s    		c   	      C   s1  x&| o| i d  } d | } t |  y^ t i   } t i	 | i
 | | |  | t i   j o! t d d |  t i d  n Wq t i j
 o' t d d | i d d	   d Sq t i j
 o d Sq t i j
 o  } | i | | |  d Sq | i d |    q Xq Wd Sd  S(
   Ni    s   Mailman.Handlers.s   errors   child process leaked thru: %si   s   vettes   Message discarded, msgid: %ss
   message-ids   n/a(   s   pipelines   pops   handlers   modnames
   __import__s   oss   getpids   pids   syss   moduless   processs   mlists   msgs   msgdatas   syslogs   _exits   Errorss   DiscardMessages   gets   HoldMessages   RejectMessages   es   BounceMessages   insert(	   s   selfs   mlists   msgs   msgdatas   pipelines   es   modnames   handlers   pid(    (    s,   /var/mailman/Mailman/Queue/IncomingRunner.pys   _dopipeline   s0     

	(   s   __name__s
   __module__s   mm_cfgs   INQUEUE_DIRs   QDIRs   _disposes   _get_pipelines   _dopipeline(    (    (    s,   /var/mailman/Mailman/Queue/IncomingRunner.pys   IncomingRunnerm   s   			(   s   __doc__s   syss   oss	   cStringIOs   StringIOs   Mailmans   mm_cfgs   Errorss   LockFiles   Mailman.Queue.Runners   Runners   Mailman.Logging.Syslogs   syslogs   IncomingRunner(	   s   Errorss   IncomingRunners   StringIOs   Runners   syss   syslogs   mm_cfgs   LockFiles   os(    (    s,   /var/mailman/Mailman/Queue/IncomingRunner.pys   ?   s   P		