Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]



��Yf� �@s#
dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZddlmZ
ddlmZ
ddlm	Z	
dg
Z
ejdkr�dd
lZGdd	�d	e
�Zn>Gd
d	�d	e
�Zdd�Zd
d�Zejee�
Gdd�de
�ZGdd�de
�Zd
S)�N�
)
�context)
�	reduction)
�util�
BufferWrapper�win32c@s@eZ
dZej�Zd
d�Zdd�Zdd�ZdS)�ArenacCs�|
|_xtt
d
�
D]Z}dtj�t|j�
f}tjd|
d|�
}tj�dkrfP|j	�
qWt
d�
�
||_||_|j|jf|_
dS)N�dz	pym-%d-%sr�tagnamer
zCannot find name for new mmap���)�size�range�os�getpid�next�_rand�mmap�_winapiZGetLastError�close�FileExistsError�name�buffer�_state)�selfr�
irZbuf�r�9/opt/alt/python35/lib64/python3.5/multiprocessing/heap.py�__init__#s
	






	
	
zArena.__init__c

Cstj
|�

|jS)
N)rZassert_spawningr)
rrrr�__getstate__2s


zArena.__getstate__cCs>|
\|_|_
|_tjd|jd|j
�
|_dS)Nrr
r)rrrrr)r�staterrr�__setstate__6s

zArena.__setstate__N)	�__name__�
__module__�__qualname__�tempfileZ_RandomNameSequencerrrr rrrrrsrc@seZ
dZddd�
ZdS)rrcCs
|
|_||_
|d
kr�tjddtj�dtj��\|_
}tj|�

tj	|tj
|j
f
�
t|j
ddd�
�c}d}|
|kr�d	|}x%t|
|�
D]}|j
|�

q�W~|j
d	|
|�

WdQRXtj|j
|j�|_dS)Nr�prefixzpym-%d-�dir�wb�closefdFis
ri)r�fdr$ZmkstemprrrZget_temp_dir�unlink�Finalizer�openr
�writerr)rrr)r�
fZbsZzeros�
_rrrrAs"
	
	

	
(













zArena.__init__Nr)r!r"r#rrrrrr?sc

Cs:|jdkrt
d�
�
t|jtj|j�
ffS)NrzDArena is unpicklable because forking was enabled when it was createdr)r)�
ValueError�
rebuild_arenarrZDupFd)
�
arrr�reduce_arenaTs

r3cCst||
j
��S)
N)r�detach)rZdupfdrrrr1Zs
r1c@s�eZ
dZd
Zejdd�
Zedd��
Zdd�Z	dd	�Z
d
d�Zdd
�Zdd�Z
dd�ZdS)�Heap�cCsmtj
�|_tj�|_|
|_g|_i|_i|_	i|_
t�|_g|_
g|_dS)
N)rr�_lastpid�	threadingZLock�_lock�_size�_lengths�_len_to_seq�_start_to_block�_stop_to_block�set�_allocated_blocks�_arenas�_pending_free_blocks)rrrrrrgs


	
	
	
	
	

	z
Heap.__init__cCs|
d
}|||@S)Nrr)�
nZ	alignment�maskrrr�_roundupts

z
Heap._roundupc	Cs
tj
|j|
�}|t|j�
kr�|jt|j|
�tj�}|jd
9_t	j
d|�
t|�
}|jj
|�

|d|fS|j|}|j|}|j�}|s�|j|=|j|=|\}}}|j||f=|j||f=|S)N�z"allocating a new mmap of length %dr
)�bisectZbisect_leftr;�lenrE�maxr:r�PAGESIZEr�inforrA�appendr<�popr=r>)	rrr�length�arena�seq�block�start�stoprrr�_malloczs"

!














zHeap._mallocc	Cs$
|
\}}}y|j||f}Wnt
k
r:


YnX|j|�
\}}y|j||f}Wnt
k
r{


YnX|j|�
\}}|||f}
||}y|j|j|
�

Wn5t
k
r�


|
g
|j|<tj|j|�
Yn
X|
|j||f<|
|j||f<dS)
N)	r>�KeyError�_absorbr=r<rLrGZinsortr;)	rrQrOrRrSZ
prev_blockr/Z
next_blockrNrrr�_free�s(















z
Heap._freecCs}|
\}}}|j||f=|j
||f=||}|j|}|j|
�

|ss|j|=|jj|�

||fS)
N)r=r>r<�remover;)rrQrOrRrSrNrPrrrrV�s










zHeap._absorbc
CsQxJy|jj
�}
Wntk
r+


PYn
X|jj|
�

|j|
�

qWdS)
N)rBrM�
IndexErrorr@rXrW)rrQrrr�_free_pending_blocks�s






zHeap._free_pending_blocksc
Cse|jj
d
�
s%|jj|
�

n<z+|j�
|jj|
�

|j|
�

Wd|jj�
XdS)NF)	r9�acquirerBrLrZr@rXrW�release)rrQrrr�free�s



z	Heap.freecCs�tj
�|jkr|j�
|j��
|j�
|jt|
d
�|j�}
|j	|
�
\}}}||
}||kr�|j
|||f�

|||f}|jj|�

|SWdQRXdS)Nr)
rrr7rr9rZrErI�
_alignmentrTrWr@�add)rrrOrRrSZnew_stoprQrrr�malloc�s














zHeap.mallocN)r!r"r#r^rrJr�staticmethodrErTrWrVrZr]r`rrrrr5cs

r5c@s1eZ
dZe�Zd
d�Zdd�ZdS)rcCsDtj
j|
�
}||
f|_tj|tj
jd
|f
�

dS)N�args)r�_heapr`rrr+r])rrrQrrrr�s

zBufferWrapper.__init__c
Cs3|j\\}
}}}t
|
j�
|||�S)
N)r�
memoryviewr)rrOrRrSrrrr�create_memoryview�s

zBufferWrapper.create_memoryviewN)r!r"r#r5rcrrerrrrr�s	)rGrr�sysr$r8�rrr�__all__�platformr�objectrr3r1�registerr5rrrrr�<module>
s$






	 �