📁 File Manager Pro
v10.0.3 | PHP: 8.1.34
Server: Apache
2026-06-21 19:06:07
📂
/ (Root)
/
opt
/
alt
/
python33
/
lib64
/
python3.3
/
multiprocessing
/
__pycache__
📍 /opt/alt/python33/lib64/python3.3/multiprocessing/__pycache__
🔄 Refresh
✏️
Editing: heap.cpython-33.pyc
Read Only
� �� fe c @ s� d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z d d l m Z d g Z e j d k r� d d l Z Gd d � d e � Z n Gd d � d e � Z Gd d � d e � Z Gd d � d e � Z d S( i N( u Finalizeu info( u assert_spawningu BufferWrapperu win32c B sD | Ee Z d Z e j � Z d d � Z d d � Z d d � Z d S( u Arenac C s� | | _ d t j � t t j � f | _ t j d | j d | j �| _ t j � d k sj t d � � | j | j f | _ d S( Nu pym-%d-%di u tagnamei u tagname already in usei����( u sizeu osu getpidu nextu Arenau _counteru nameu mmapu bufferu _winapiu GetLastErroru AssertionErroru _state( u selfu size( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu __init__# s "! u Arena.__init__c C s t | � | j S( N( u assert_spawningu _state( u self( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu __getstate__* s u Arena.__getstate__c C sY | \ | _ | _ | _ t j d | j d | j �| _ t j � t j k sU t � d S( Ni u tagnamei����( u sizeu nameu _stateu mmapu bufferu _winapiu GetLastErroru ERROR_ALREADY_EXISTSu AssertionError( u selfu state( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu __setstate__. s !u Arena.__setstate__N( u __name__u __module__u __qualname__u itertoolsu countu _counteru __init__u __getstate__u __setstate__( u __locals__( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu Arena s u Arenac B s | Ee Z d Z d d � Z d S( u Arenac C s+ t j d | � | _ | | _ d | _ d S( Ni i����( u mmapu bufferu sizeu Noneu name( u selfu size( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu __init__7 s u Arena.__init__N( u __name__u __module__u __qualname__u __init__( u __locals__( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu Arena5 s c B s� | Ee Z d Z d Z e j d d � Z e d d � � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d S( u Heapi c C sm t j � | _ t j � | _ | | _ g | _ i | _ i | _ i | _ t � | _ g | _ g | _ d S( N( u osu getpidu _lastpidu threadingu Locku _locku _sizeu _lengthsu _len_to_sequ _start_to_blocku _stop_to_blocku setu _allocated_blocksu _arenasu _pending_free_blocks( u selfu size( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu __init__D s u Heap.__init__c C s | d } | | | @S( Ni ( ( u nu alignmentu mask( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu _roundupQ s u Heap._roundupc C s t j | j | � } | t | j � k r� | j t | j | � t j � } | j d 9_ t d | � t | � } | j j | � | d | f S| j | } | j | } | j � } | s� | j | =| j | =n | \ } } } | j | | f =| j | | f =| S( Ni u" allocating a new mmap of length %di ( u bisectu bisect_leftu _lengthsu lenu _roundupu maxu _sizeu mmapu PAGESIZEu infou Arenau _arenasu appendu _len_to_sequ popu _start_to_blocku _stop_to_block( u selfu sizeu iu lengthu arenau sequ blocku startu stop( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu _mallocW s" ! u Heap._mallocc C s$ | \ } } } y | j | | f } Wn t k r: Yn X| j | � \ } } y | j | | f } Wn t k r{ Yn X| j | � \ } } | | | f } | | } y | j | j | � Wn5 t k r� | g | j | <t j | j | � Yn X| | j | | f <| | j | | f <d S( N( u _stop_to_blocku KeyErroru _absorbu _start_to_blocku _len_to_sequ appendu bisectu insortu _lengths( u selfu blocku arenau startu stopu prev_blocku _u next_blocku length( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu _freem s( u Heap._freec C s� | \ } } } | j | | f =| j | | f =| | } | j | } | j | � | sv | j | =| j j | � n | | f S( N( u _start_to_blocku _stop_to_blocku _len_to_sequ removeu _lengths( u selfu blocku arenau startu stopu lengthu seq( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu _absorb� s u Heap._absorbc C sP xI y | j j � } Wn t k r+ PYn X| j j | � | j | � q d S( N( u _pending_free_blocksu popu IndexErroru _allocated_blocksu removeu _free( u selfu block( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu _free_pending_blocks� s u Heap._free_pending_blocksc C s� t j � | j k s t � | j j d � s@ | j j | � n< z+ | j � | j j | � | j | � Wd | j j � Xd S( NF( u osu getpidu _lastpidu AssertionErroru _locku acquireu Falseu _pending_free_blocksu appendu _free_pending_blocksu _allocated_blocksu removeu _freeu release( u selfu block( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu free� s u Heap.freec C s� d | k o t j k n s% t � t j � | j k rG | j � n | j j � | j � z� | j t | d � | j � } | j | � \ } } } | | } | | k r� | j | | | f � n | | | f } | j j | � | SWd | j j � Xd S( Ni i ( u sysu maxsizeu AssertionErroru osu getpidu _lastpidu __init__u _locku acquireu _free_pending_blocksu _roundupu maxu _alignmentu _mallocu _freeu _allocated_blocksu addu release( u selfu sizeu arenau startu stopu new_stopu block( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu malloc� s % u Heap.mallocN( u __name__u __module__u __qualname__u _alignmentu mmapu PAGESIZEu __init__u staticmethodu _roundupu _mallocu _freeu _absorbu _free_pending_blocksu freeu malloc( u __locals__( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu Heap@ s u Heapc B s5 | Ee Z d Z e � Z d d � Z d d � Z d S( u BufferWrapperc C sf d | k o t j k n s% t � t j j | � } | | f | _ t | t j j d | f �d S( Ni u args( u sysu maxsizeu AssertionErroru BufferWrapperu _heapu mallocu _stateu Finalizeu free( u selfu sizeu block( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu __init__� s %u BufferWrapper.__init__c C s3 | j \ \ } } } } t | j � | | | � S( N( u _stateu memoryviewu buffer( u selfu arenau startu stopu size( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu create_memoryview� s u BufferWrapper.create_memoryviewN( u __name__u __module__u __qualname__u Heapu _heapu __init__u create_memoryview( u __locals__( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu BufferWrapper� s ( u bisectu mmapu osu sysu threadingu itertoolsu _multiprocessingu multiprocessing.utilu Finalizeu infou multiprocessing.forkingu assert_spawningu __all__u platformu _winapiu objectu Arenau Heapu BufferWrapper( ( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/heap.pyu <module> s �
💾 Save Changes
❌ Cancel