One Hat Cyber Team
Your IP :
216.73.216.183
Server IP :
23.137.84.82
Server :
Linux srv25.usacloudserver.us 5.14.0-570.39.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Sep 4 05:08:52 EDT 2025 x86_64
Server Software :
LiteSpeed
PHP Version :
8.1.33
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib64
/
python3.9
/
multiprocessing
/
__pycache__
/
View File Name :
heap.cpython-39.opt-2.pyc
a �DOgj- � @ s� d dl Z d dlmZ d dlZd dlZd dlZd dlZd dlZddlm Z m Z ddl m Z dgZ ejdkr�d dlZG dd � d e�Zn,G 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 @ s, e Zd Ze�� Zdd� Zdd� Zdd� ZdS )�Arenac C sx || _ td�D ]B}dt�� t| j�f }tjd||d�}t�� dkrH qZ|� � 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 �,/usr/lib64/python3.9/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__�tempfile�_RandomNameSequencer r r" r$ r r r r r s r c @ s4 e Zd ZejdkrdgZng Zd dd�Zdd� ZdS ) r �linuxz/dev/shmr c C sx || _ || _|dkrbtjdt�� | �|�d�\| _}t�|� t� | tj | jf� t� | j|� t � | j| j �| _ d S )Nr zpym-%d-)�prefix�dir)r �fdr( �mkstempr 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 � get_temp_dir)r r �d�str r r r/ [ s zArena._choose_dirN)r )r% r& r' �sys�platformr3 r r/ r r r r r C s c C s( | j dkrtd��t| jt�| j �ffS )Nr zDArena is unpicklable because forking was enabled when it was created)r- � ValueError� rebuild_arenar r �DupFd)�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 )�nZ alignment�maskr r r �_roundup� s z Heap._roundupc C sZ | � t| j|�tj�}| j| jk r0| jd9 _t�d|� t|�}| j � |� |d|fS )N� z"allocating a new mmap of length %dr ) rV �maxrI r �PAGESIZE�_DOUBLE_ARENA_SIZE_UNTILr �infor rP �append)r r �length�arenar r r � _new_arena� s zHeap._new_arenac C sz |j }|| jk rd S | j�|�}| j|df= | j||f= | j�|� | j| }|�|d|f� |sv| j|= | j �|� d S rD ) r � _DISCARD_FREE_SPACE_LARGER_THANrO �poprL rM rP �removerK rJ )r r^ r] �blocks�seqr r r �_discard_arena� s zHeap._discard_arenac C s| t �| j|�}|t| j�kr&| �|�S | j| }| j| }|�� }|sV| j|= | j|= |\}}}| j||f= | j||f= |S r! ) �bisect� bisect_leftrJ �lenr_ rK ra rL rM ) r r r r] rd �blockr^ �start�stopr r r �_malloc� s z Heap._mallocc C s� |\}}}z| j ||f }W n ty. Y n0 | �|�\}}z| j||f }W n tyb Y n0 | �|�\}}|||f}|| }z| j| �|� W n, ty� |g| j|< t�| j|� Y n0 || j||f< || j ||f< d S r! ) rM �KeyError�_absorbrL rK r\ rf �insortrJ ) r ri r^ rj rk Z prev_block�_Z next_blockr] r r r �_add_free_block� s( zHeap._add_free_blockc C s^ |\}}}| j ||f= | j||f= || }| j| }|�|� |sV| j|= | j�|� ||fS r! )rL rM rK rb rJ )r ri r^ rj rk r] rd r r r rn � s z Heap._absorbc C s4 |\}}}| j | }|�||f� |s0| �|� d S r! )rO rb re )r ri r^ rj rk rc r r r �_remove_allocated_block� s z Heap._remove_allocated_blockc C s@ z| j �� }W n ty$ Y q<Y n0 | �|� | �|� q d S r! )rQ ra � IndexErrorrq rr �r ri r r r �_free_pending_blocks s zHeap._free_pending_blocksc C s� t �� | jkr$td�t �� | j���| j�d�s>| j�|� nFz8| j d7 _ | � � | � |� | � |� W | j� � n | j� � 0 d S )Nz$My pid ({0:n}) is not last pid {1:n}Fr )r r rE r< �formatrH �acquirerQ r\ rS ru rq rr �releasert r r r �free s �� z Heap.freec C s� |dk rt d�|���tj|kr.td�|���t�� | jkrD| �� | j �� | j d7 _ | � � | � t |d�| j�}| �|�\}}}|| }||k r�| �|||f� | j| �||f� |||fW d � S 1 s�0 Y d S )Nr �Size {0:n} out of range�Size {0:n} too larger )r< rv r: �maxsize� OverflowErrorr r rE r rH rR ru rV rX � _alignmentrl rq rO �add)r r r^ rj rk Z real_stopr r r �malloc( s z Heap.mallocN)r% r& r' r~ r` rZ r rY r � staticmethodrV r_ re rl rq rn rr ru ry r� r r r r rB s s rB c @ s" e Zd Ze� Zdd� Zdd� ZdS )r c C s^ |dk rt d�|���tj|kr.td�|���tj�|�}||f| _t j | tjj |fd� d S )Nr rz r{ )�args) r< rv r: r| r} r �_heapr� r r r1 ry )r r ri r r r r F s zBufferWrapper.__init__c C s& | j \\}}}}t|j�||| � S r! )r � memoryviewr )r r^ rj rk r r r r �create_memoryviewO s z BufferWrapper.create_memoryviewN)r% r& r' rB r� r r� r r r r r B s )rf � collectionsr r r r: r( rF �contextr r � r �__all__r; r �objectr r@ r= �registerrB r r r r r �<module> s& $! P