Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /opt/alt/python34/lib64/python3.4/multiprocessing/__pycache__/ |
�
� f � @ 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 m Z d d l 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 d d � Z d
d � Z e j e e � Gd d � d e
� Z Gd d � d e
� Z d S)� N� )�context)� reduction)�util�
BufferWrapper�win32c @ s@ e Z d Z e j � Z d d � Z d d � Z d d � Z d S)�Arenac C s� | | _ xw t d � D]] } d t j � t | j � f } t j d | d | �} t j � d k ri Pn | j � q Wt
d � � | | _ | | _ | j | j f | _
d S)N�d z pym-%d-%sr �tagnamer z Cannot find name for new mmap���)�size�range�os�getpid�next�_rand�mmap�_winapiZ GetLastError�close�FileExistsError�name�buffer�_state)�selfr �ir Zbuf� r �9/opt/alt/python34/lib64/python3.4/multiprocessing/heap.py�__init__# s zArena.__init__c C s t j | � | j S)N)r Zassert_spawningr )r r r r � __getstate__2 s
zArena.__getstate__c C s> | \ | _ | _ | _ t j d | j d | j �| _ d S)Nr r
r )r r r r r )r �stater r r � __setstate__6 s !zArena.__setstate__N) �__name__�
__module__� __qualname__�tempfileZ_RandomNameSequencer r r r r r r r r s r c @ s e Z d Z d d d � Z d S)r r c
C s� | | _ | | _ | d k r� t j d d t j � d t j � � \ | _ } t j | � t j | t j
| j f � t | j d d d �� } | j d | � Wd QXn t
j
| j | j � | _ d S)
Nr �prefixzpym-%d-�dir�wb�closefdFs r )r �fdr$ Zmkstempr r r Z get_temp_dir�unlink�Finalizer �open�writer r )r r r) r �fr r r r ? s (
zArena.__init__Nr )r! r" r# r r r r r r = s c C s= | j d k r t d � � n t | j t j | j � f f S)Nr zDArena is unpicklable because forking was enabled when it was createdr )r) �
ValueError�
rebuild_arenar r ZDupFd)�ar r r � reduce_arenaK s r2 c C s t | | j � � S)N)r �detach)r Zdupfdr r r r0 Q s r0 c @ s� e 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)�Heap� c C sm t j � | _ t j � | _ | | _ g | _ i | _ i | _ i | _
t � | _ g | _
g | _ d S)N)r r �_lastpid� threadingZLock�_lock�_size�_lengths� _len_to_seq�_start_to_block�_stop_to_block�set�_allocated_blocks�_arenas�_pending_free_blocks)r r r r r r ^ s z
Heap.__init__c C s | d } | | | @S)Nr r )�nZ alignment�maskr r r �_roundupk s
z
Heap._roundupc C s t j | j | � } | t | j � k r� | j t | j | � t j � } | j d 9_ t j
d | � t | � } | j j
| � | d | f S| j | } | j | } | j � } | s� | j | =| j | =n | \ } } } | j | | f =| j | | f =| S)N� z"allocating a new mmap of length %dr )�bisectZ bisect_leftr: �lenrD �maxr9 r �PAGESIZEr �infor r@ �appendr; �popr< r= ) r r r �length�arena�seq�block�start�stopr r r �_mallocq s" !
z 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) r= �KeyError�_absorbr< r; rK rF Zinsortr: ) r rP rN rQ rR Z
prev_block�_Z
next_blockrM r r r �_free� s(
z
Heap._freec C s� | \ } } } | j | | f =| j | | f =| | } | j | } | j | � | sv | j | =| j j | � n | | f S)N)r< r= r; �remover: )r rP rN rQ rR rM rO r r r rU � s
z Heap._absorbc C sQ xJ y | j j � } Wn t k
r+ PYn X| j j | � | j | � q Wd S)N)rA rL �
IndexErrorr? rX rW )r rP r r r �_free_pending_blocks� s
zHeap._free_pending_blocksc
C se | j j d � s% | j j | � n< z+ | j � | j j | � | j | � Wd | j j � Xd S)NF) r8 �acquirerA rK rZ r? rX rW �release)r rP r r r �free� s
z Heap.freec
C s� t j � | j k r" | j � n | j j � | j � z� | j t | d � | j � } | j
| � \ } } } | | } | | k r� | j | | | f � n | | | f } | j j
| � | SWd | j j � Xd S)Nr )r r r6 r r8 r[ rZ rD rH �
_alignmentrS rW r? �addr\ )r r rN rQ rR Znew_stoprP r r r �malloc� s
z Heap.mallocN)r! r" r# r^ r rI r � staticmethodrD rS rW rU rZ r] r` r r r r r4 Z s
r4 c @ s1 e Z d Z e � Z d d � Z d d � Z d S)r c C sD t j j | � } | | f | _ t j | t j j d | f �d S)N�args)r �_heapr` r r r+ r] )r r rP r r r r � s zBufferWrapper.__init__c C s3 | j \ \ } } } } t | j � | | | � S)N)r �
memoryviewr )r rN rQ rR r r r r �create_memoryview� s z BufferWrapper.create_memoryviewN)r! r" r# r4 rc r re r r r r r � s )rF r r �sysr$ r7 � r r r �__all__�platformr �objectr r2 r0 �registerr4 r r r r r �<module>
s$ �