Ñò
§ÚêLc @ s d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k l Z l
Z
d d k l Z d g Z
e i d j o* d d k l Z d e f d „ ƒ YZ n d e f d „ ƒ YZ d
e f d „ ƒ YZ d e f d „ ƒ YZ d S(
iÿÿÿÿN( t Finalizet info( t assert_spawningt
BufferWrappert win32( R t Arenac B s/ e Z e i ƒ Z d „ Z d „ Z d „ Z RS( c C se | | _ d t i ƒ t i i ƒ f | _ t i d | i d | i ƒ| _ | i | i f | _ d S( Ns pym-%d-%diÿÿÿÿt tagname(
t sizet ost getpidR t _countert nextt namet mmapt buffert _state( t selfR ( ( s, /usr/lib64/python2.6/multiprocessing/heap.pyt __init__# s "!c C s t | ƒ | i S( N( R R ( R ( ( s, /usr/lib64/python2.6/multiprocessing/heap.pyt __getstate__* s
c C s> | \ | _ | _ | _ t i d | i d | i ƒ| _ d S( NiÿÿÿÿR ( R R R R
R ( R t state( ( s, /usr/lib64/python2.6/multiprocessing/heap.pyt __setstate__. s !( t __name__t
__module__t itertoolst countR
R R R ( ( ( s, /usr/lib64/python2.6/multiprocessing/heap.pyR s c B s e Z d „ Z RS( c C s+ t i d | ƒ | _ | | _ d | _ d S( Niÿÿÿÿ( R
R R t NoneR ( R R ( ( s, /usr/lib64/python2.6/multiprocessing/heap.pyR 7 s ( R R R ( ( ( s, /usr/lib64/python2.6/multiprocessing/heap.pyR 5 s t Heapc B sY e Z d Z e i d „ Z e d „ ƒ Z d „ Z d „ Z d „ Z
d „ Z d „ Z RS( i c C sd t i ƒ | _ t i ƒ | _ | | _ g | _ h | _ h | _ h | _
t ƒ | _ g | _
d S( N( R R t _lastpidt threadingt Lockt _lockt _sizet _lengthst _len_to_seqt _start_to_blockt _stop_to_blockt sett _allocated_blockst _arenas( R R ( ( s, /usr/lib64/python2.6/multiprocessing/heap.pyR D s c C s | d } | | | @S( Ni ( ( t nt alignmentt mask( ( s, /usr/lib64/python2.6/multiprocessing/heap.pyt _roundupO s
c C s
t i | i | ƒ } | t | i ƒ j og | i t | i | ƒ t i ƒ } | i d 9_ t d | ƒ t
| ƒ } | i i | ƒ | d | f S| i | } | i
| } | i ƒ } | p | i
| =| i | =n | \ } } } | i | | f =| i | | f =| S( Ni s" allocating a new mmap of length %di ( t bisectt bisect_leftR t lenR* t maxR R
t PAGESIZER R R& t appendR! t popR" R# ( R R t it lengtht arenat seqt blockt startt stop( ( s, /usr/lib64/python2.6/multiprocessing/heap.pyt _mallocU s" !
c
C s' | \ } } } y | i | | f } Wn t j
o n X| i | ƒ \ } } y | i | | f } Wn t j
o n X| i | ƒ \ } } | | | f } | | } y | i | i | ƒ Wn6 t j
o* | g | i | s x