File: //opt/saltstack/salt/lib/python3.10/multiprocessing/__pycache__/heap.cpython-310.pyc
o
�N�gj- � @ s� d dl Z d dlmZ d dlZd dlZd dlZd dlZd dlZddlm Z m
Z
ddl m Z dgZ
ejdkrAd dlZG dd � d e�ZnG d
d � d e�Zd d � Zd
d� Ze �ee� G dd� de�ZG dd� de�ZdS )� N)� defaultdict� )� reduction�assert_spawning)�util�
BufferWrapper�win32c @ s0 e Zd ZdZe�� Zdd� Zdd� Zdd� Z dS ) �ArenazL
A shared memory area backed by anonymous memory (Windows).
c C sx || _ td�D ]!}dt�� t| j�f }tjd||d�}t�� dkr$ n |� � qt
d��|| _ || _ | j | j f| _
d S )N�d z pym-%d-%s����Ztagnamer z Cannot find name for new mmap)�size�range�os�getpid�next�_rand�mmap�_winapiZ GetLastError�close�FileExistsError�name�buffer�_state)�selfr
�ir �buf� r �:/opt/saltstack/salt/lib/python3.10/multiprocessing/heap.py�__init__& s
�Arena.__init__c C s t | � | jS �N)r r )r r r r � __getstate__5 s zArena.__getstate__c C s, | \| _ | _| _tjd| j | jd�| _d S )Nr r )r
r r r r )r �stater r r � __setstate__9 s zArena.__setstate__N)
�__name__�
__module__� __qualname__�__doc__�tempfileZ_RandomNameSequencer r r" r$ r r r r r s r c @ s8 e Zd ZdZejdkrdgZng Zd
dd�Zdd� Zd S ) r zJ
A shared memory area backed by a temporary file (POSIX).
�linuxz/dev/shmr c C sx || _ || _|dkr1tjdt�� | �|�d�\| _}t�|� t� | tj
| jf� t� | j|� t � | j| j �| _
d S )Nr zpym-%d-)�prefix�dir)r
�fdr) Zmkstempr r � _choose_dir�unlinkr �Finalizer � ftruncater r )r r
r- r r r r r M s
�
r c C s6 | j D ]}t�|�}|j|j |kr| S qt�� S r! )�_dir_candidatesr �statvfs�f_bavail�f_frsizer Z get_temp_dir)r r
�d�str r r r. [ s
�zArena._choose_dirN)r ) r% r& r' r( �sys�platformr2 r r. r r r r r C s
c C s( | j dkr td��t| jt�| j �ffS )Nr zDArena is unpicklable because forking was enabled when it was created)r- �
ValueError�
rebuild_arenar
r ZDupFd)�ar r r � reduce_arenad s
r= c C s t | |�� �S r! )r �detach)r
Zdupfdr r r r; j s r; c @ sz e Zd ZdZdZdZejfdd�Ze dd� �Z
dd� Z d d
� Z d d � Z
d
d� Zdd� Zdd� Zdd� Zdd� Zdd� ZdS )�Heap� i @ c C sX t �� | _t�� | _|| _g | _i | _i | _ i | _
t t �| _
g | _g | _d| _d| _d S �Nr )r r �_lastpid� threading�Lock�_lock�_size�_lengths� _len_to_seq�_start_to_block�_stop_to_blockr �set�_allocated_blocks�_arenas�_pending_free_blocks�
_n_mallocs�_n_frees)r r
r r r r { s
z
Heap.__init__c C s |d }| | | @ S )Nr r )�n� alignment�maskr r r �_roundup� s z
Heap._roundupc C sZ | � t| j|�tj�}| j| jk r| jd9 _t�d|� t|�}| j �
|� |d|fS )N� z"allocating a new mmap of length %dr ) rT �maxrF r �PAGESIZE�_DOUBLE_ARENA_SIZE_UNTILr �infor rM �append)r r
�length�arenar r r �
_new_arena� s
zHeap._new_arenac C s� |j }|| jk r
d S | j�|�}|rJ �| j|df= | j||f= | j�|� | j| }|�|d|f� |sA| j|= | j �|� d S d S rA )
r
� _DISCARD_FREE_SPACE_LARGER_THANrL �poprI rJ rM �removerH rG )r r\ r[ �blocks�seqr r r �_discard_arena� s
�zHeap._discard_arenac C s| t �| j|�}|t| j�kr| �|�S | j| }| j| }|�� }|s+| j|= | j|= |\}}}| j||f= | j||f= |S r! ) �bisect� bisect_leftrG �lenr] rH r_ rI rJ ) r r
r r[ rb �blockr\ �start�stopr r r �_malloc� s
z Heap._mallocc C s� |\}}}z | j ||f }W n ty Y nw | �|�\}}z | j||f }W n ty1 Y nw | �|�\}}|||f}|| }z
| j| �|� W n tyb |g| j|< t�| j|� Y nw || j||f< || j ||f< d S r! ) rJ �KeyError�_absorbrI rH rZ rd �insortrG ) r rg r\ rh ri Z
prev_block�_Z
next_blockr[ r r r �_add_free_block� s.
� �
�zHeap._add_free_blockc C s^ |\}}}| j ||f= | j||f= || }| j| }|�|� |s+| j|= | j�|� ||fS r! )rI rJ rH r` rG )r rg r\ rh ri r[ rb r r r rl � s
z Heap._absorbc C s8 |\}}}| j | }|�||f� |s| �|� d S d S r! )rL r` rc )r rg r\ rh ri ra r r r �_remove_allocated_block� s
�z Heap._remove_allocated_blockc C s< z| j �� }W n
ty Y d S w | �|� | �|� qr! )rN r_ �
IndexErrorro rp �r rg r r r �_free_pending_blocks s �
�zHeap._free_pending_blocksc C s� t �� | jkrtd�t �� | j���| j�d�s | j�|� d S z | j d7 _ | �
� | � |� | � |� W | j�
� d S | j�
� w )Nz$My pid ({0:n}) is not last pid {1:n}Fr )r r rB r: �formatrE �acquirerN rZ rP rs ro rp �releaserr r r r �free s
��
z Heap.freec C s� |dk r t d�|���tj|krtd�|���t�� | jkr"| �� | j �D | j
d7 _
| � � | � t
|d�| j�}| �|�\}}}|| }||k rS| �|||f� | j| �||f� |||fW d � S 1 slw Y d S )Nr �Size {0:n} out of range�Size {0:n} too larger )r: rt r8 �maxsize�
OverflowErrorr r rB r rE rO rs rT rV �
_alignmentrj ro rL �add)r r
r\ rh ri Z real_stopr r r �malloc( s"
$�z Heap.mallocN)r% r& r' r| r^ rX r rW r � staticmethodrT r] rc rj ro rl rp rs rw r~ r r r r r? s s
r? c @ s" e Zd Ze� Zdd� Zdd� ZdS )r c C s^ |dk r t d�|���tj|krtd�|���tj�|�}||f| _t j
| tjj |fd� d S )Nr rx ry )�args) r: rt r8 rz r{ r �_heapr~ r r r0 rw )r r
rg r r r r F s
zBufferWrapper.__init__c C s& | j \\}}}}t|j�||| � S r! )r �
memoryviewr )r r\ rh ri r
r r r �create_memoryviewO s z BufferWrapper.create_memoryviewN)r% r& r' r? r� r r� r r r r r B s )rd � collectionsr r r r8 r) rC �contextr r � r �__all__r9 r �objectr r= r; �registerr? r r r r r �<module> s(
$! P