;ò
¢)?Bc           @   sÌ   d  Z  d k 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 Z y e e f Wn e j
 o d Z d Z n Xe Z d	 f  d
 „  ƒ  YZ d S(   s:   Reading and writing message objects and message metadata.
N(   s   mm_cfg(   s   Utils(   s   Message(   s   syslogl   ÿÿÿÿÿÿÿÿÿÿÿi   i    s   Switchboardc           B   s>   t  Z e d d „ Z d „  Z h  d „ Z d „  Z d „  Z RS(   Ni   c         C   sÏ   | |  _ t i d ƒ } zM y t i |  i d ƒ Wn/ t j
 o# } | i	 t	 i
 j o ‚  qd n XWd  t i | ƒ Xt |  _ t |  _ | d j o6 t d | | |  _ t d | d | d |  _ n d  S(   Ni    iø  i   (   s   whichqs   selfs   _Switchboard__whichqs   oss   umasks   omasks   mkdirs   OSErrors   es   errnos   EEXISTs   Nones   _Switchboard__lowers   _Switchboard__uppers	   numslicess   shamaxs   slice(   s   selfs   whichqs   slices	   numslicess   es   omask(    (    s)   /var/mailman/Mailman/Queue/Switchboard.pys   __init__B   s    	  		c         C   s   |  i Sd  S(   N(   s   selfs   _Switchboard__whichq(   s   self(    (    s)   /var/mailman/Mailman/Queue/Switchboard.pys   whichqV   s    c         K   s×  | i ƒ  } | i | ƒ | i d d ƒ } t i ƒ  } t	 o | i d ƒ o d } t i | | ƒ } n d } t i t | ƒ | ƒ } | | | } | i d | ƒ } | d t i | ƒ i ƒ  } t i i |  i | d ƒ }	 |	 d	 } t i | d
 <x/ | i  ƒ  D]! } | i" d ƒ o | | =qqW| d j | d <t i# d ƒ }
 zb t% | d ƒ } zA | i' | ƒ t i( | | | ƒ | i) ƒ  t i* | i+ ƒ  ƒ Wd  | i, ƒ  XWd  t i# |
 ƒ Xt i- | |	 ƒ | Sd  S(   Ns   listnames
   --nolist--s
   _plaintexti   i    s   received_times   +s   .pcks   .tmps   versions   _s	   _parsemsgi   s   w(.   s	   _metadatas   copys   datas   updates   _kwss   gets   listnames   times   nows   SAVE_MSGS_AS_PICKLESs   protocols   cPickles   dumpss   _msgs   msgsaves   strs   hashfoods
   setdefaults   rcvtimes   shas   news	   hexdigests   filebases   oss   paths   joins   selfs   _Switchboard__whichqs   filenames   tmpfiles   mm_cfgs   QFILE_SCHEMA_VERSIONs   keyss   ks
   startswiths   umasks   omasks   opens   fps   writes   dumps   flushs   fsyncs   filenos   closes   rename(   s   selfs   _msgs	   _metadatas   _kwss   tmpfiles   protocols   filebases   hashfoods   msgsaves   filenames   omasks   fps   rcvtimes   nows   datas   listnames   k(    (    s)   /var/mailman/Mailman/Queue/Switchboard.pys   enqueueY   sD    
 
  c         C   sœ   t  i i |  i | d ƒ } t | ƒ } t  i	 | ƒ z" t
 i | ƒ } t
 i | ƒ } Wd  | i ƒ  X| i d ƒ o t i | t i ƒ } n | | f Sd  S(   Ns   .pcks	   _parsemsg(   s   oss   paths   joins   selfs   _Switchboard__whichqs   filebases   filenames   opens   fps   unlinks   cPickles   loads   msgs   datas   closes   gets   emails   message_from_strings   Message(   s   selfs   filebases   fps   filenames   datas   msg(    (    s)   /var/mailman/Mailman/Queue/Switchboard.pys   dequeue‹   s     c         C   sþ   h  } |  i } |  i } x  t i |  i ƒ D]Œ } | i
 d ƒ o q+ n t i i | ƒ d } | i d ƒ \ } }
 | p$ | t |
 d ƒ j o
 | j  n o | | t | ƒ <q+ q+ W| i ƒ  } | i ƒ  g  i } | D] }	 | | |	 ƒ qß ~ Sd  S(   Ns   .pcki    s   +i   (   s   timess   selfs   _Switchboard__lowers   lowers   _Switchboard__uppers   uppers   oss   listdirs   _Switchboard__whichqs   fs   endswiths   paths   splitexts   filebases   splits   whens   digests   longs   floats   keyss   sorts   appends   _[1]s   k(   s   selfs   uppers   lowers   fs   keyss   whens   filebases   timess   _[1]s   ks   digest(    (    s)   /var/mailman/Mailman/Queue/Switchboard.pys   filesš   s    		 /
(   s   __name__s
   __module__s   Nones   __init__s   whichqs   enqueues   dequeues   files(    (    (    s)   /var/mailman/Mailman/Queue/Switchboard.pys   SwitchboardA   s
   	2	(   s   __doc__s   oss   shas   times   emails   errnos   cPickles   marshals   Mailmans   mm_cfgs   Utilss   Messages   Mailman.Logging.Syslogs   syslogs   shamaxs   Trues   Falses	   NameErrors   SAVE_MSGS_AS_PICKLESs   Switchboard(   s   cPickles   Falses   syslogs   errnos   Utilss   Switchboards   shamaxs   marshals   Trues   shas   mm_cfgs   times   SAVE_MSGS_AS_PICKLESs   Messages   oss   email(    (    s)   /var/mailman/Mailman/Queue/Switchboard.pys   ?   s&   							