⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.16
Server IP:
97.74.87.16
Server:
Linux 16.87.74.97.host.secureserver.net 5.14.0-503.38.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Fri Apr 18 08:52:10 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.2.28
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib64
/
python3.9
/
multiprocessing
/
__pycache__
/
View File Name :
heap.cpython-39.opt-1.pyc
a �����DOgj-����������������������@���s����d�dl�Z�d�dlmZ�d�dlZd�dlZd�dlZd�dlZd�dlZddlm Z m Z �ddlmZ�dgZ ejdkr�d�dlZG�dd ��d e�Zn,G�d d ��d e�Zdd��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�]B}dt���t|�j�f�}tjd||d�}t���dkrH�qZ|� ���qt d��||�_||�_|�j�|�jf|�_ d�S�)N�d���z pym-%d-%s����Ztagnamer���zCannot find name for new mmap)�size�range�os�getpid�next�_rand�mmap�_winapiZGetLastError�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__�__doc__�tempfile�_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���||�_�||�_|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���r0���[���s ���� zArena._choose_dirN)r���) r%���r&���r'���r(����sys�platformr4���r���r0���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���� rA���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��Zd d ��Zdd��Z d d��Zdd��Zdd��Zdd��Zdd��Zdd��ZdS�)�Heap����i��@�c�����������������C���sX���t����|�_t���|�_||�_g�|�_i�|�_i�|�_ i�|�_ tt�|�_ 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���)rW����maxrJ���r����PAGESIZE�_DOUBLE_ARENA_SIZE_UNTILr����infor ���rQ����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�rE���) r ����_DISCARD_FREE_SPACE_LARGER_THANrP����poprM���rN���rQ����removerL���rK���)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_leftrK����lenr`���rL���rb���rM���rN���) r���r ���r���r^���re����blockr_����start�stopr���r���r����_malloc����s���� zHeap._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!���) rN����KeyError�_absorbrM���rL���r]���rg����insortrK���) r���rj���r_���rk���rl���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!���)rM���rN���rL���rc���rK���)r���rj���r_���rk���rl���r^���re���r���r���r���ro�������s���� zHeap._absorbc�����������������C���s4���|\}}}|�j�|�}|�||f��|s0|��|��d�S�r!���)rP���rc���rf���)r���rj���r_���rk���rl���rd���r���r���r����_remove_allocated_block����s ���� zHeap._remove_allocated_blockc�����������������C���s@���z|�j����}W�n�ty$���Y�q<Y�n0�|��|��|��|��q�d�S�r!���)rR���rb���� IndexErrorrr���rs����r���rj���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���rF���r=����formatrI����acquirerR���r]���rT���rv���rr���rs����releaseru���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=���rw���r;����maxsize� OverflowErrorr���r���rF���r���rI���rS���rv���rW���rY���� _alignmentrm���rr���rP����add)r���r ���r_���rk���rl���Z real_stopr���r���r����malloc(��s ���� zHeap.mallocN)r%���r&���r'���r���ra���r[���r���rZ���r����staticmethodrW���r`���rf���rm���rr���ro���rs���rv���rz���r����r���r���r���r���rC���s���s��� rC���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���r{���r|���)�args)r=���rw���r;���r}���r~���r����_heapr����r���r���r2���rz���)r���r ���rj���r���r���r���r���F��s���� zBufferWrapper.__init__c�����������������C���s&���|�j�\\}}}}t|j�|||���S�r!���)r���� memoryviewr���)r���r_���rk���rl���r ���r���r���r����create_memoryviewO��s����zBufferWrapper.create_memoryviewN)r%���r&���r'���rC���r����r���r����r���r���r���r���r���B��s��� )rg����collectionsr���r���r���r;���r)���rG����contextr���r�����r����__all__r<���r����objectr ���rA���r>����registerrC���r���r���r���r���r����<module> ���s&��� $!�P