| Server IP : 192.158.238.246 / Your IP : 3.22.27.22 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python310/lib64/python3.10/multiprocessing/__pycache__/ |
Upload File : |
o
�?OgH � @ s� d dgZ ddlmZ ddlZddlZddlZddlZddlZddlZej dkr/ddl
Z
dZ nddl Z dZ dd l
mZ ejejB Zd
Ze rHd Znd Zd
d� ZG dd � d �ZdZG dd� d�ZdS )� SharedMemory�
ShareableList� )�partialN�ntFT� )�resource_tracker� z/psm_Zwnsm_c C s$ t tt� d } tt�| � }|S )N� )�_SHM_SAFE_NAME_LENGTH�len�_SHM_NAME_PREFIX�secretsZ token_hex)�nbytes�name� r �D/opt/alt/python310/lib64/python3.10/multiprocessing/shared_memory.py�_make_filename( s r c @ s� e Zd Z dZdZdZdZejZ dZ
e rdndZ ddd�Z
d d
� Zd d � Zd
d� Zedd� �Zedd� �Zedd� �Zdd� Zdd� ZdS )r N���i� TFr c C sx |dkst d��|rttjB | _|dkrt d��|d u r&| jtj@ s&t d��tr�|d u rL t� }z
tj || j| j
d�| _ W n t yF Y q,w || _
n| jrSd| n|}tj || j| j
d�| _ || _
z |ro|rot�| j |� t�| j �}|j}t�| j |�| _W n ty� | �� � w t�| j
d� n�|r� |d u r�t� n|}t�tjtjtj |d ? d
@ |d
@ |�}z1t� � }|tj kr�|d ur�t t j t�!t j �|tj ��W t�"|� q�tjd ||d �| _W t�"|� nt�"|� w || _
n?|| _
t�#tj$d
|�}zt�%|tj$ddd�}W t�"|� nt�"|� w z t�&|�}W t�'|� nt�'|� w tjd ||d �| _|| _(t)| j�| _*d S )Nr z!'size' must be a positive integerz4'size' must be a positive number different from zeroz&'name' can only be None if create=TrueT)�mode�/�
shared_memory� l �� r )ZtagnameF)+�
ValueError�_O_CREX�os�O_RDWR�_flags�O_EXCL�
_USE_POSIXr � _posixshmemZshm_open�_mode�_fd�FileExistsError�_name�_prepend_leading_slash� ftruncate�fstat�st_size�mmap�_mmap�OSError�unlinkr �register�_winapiZCreateFileMappingZINVALID_HANDLE_VALUEZNULLZPAGE_READWRITEZ GetLastErrorZERROR_ALREADY_EXISTS�errnoZEEXIST�strerrorZ CloseHandleZOpenFileMappingZ
FILE_MAP_READZ
MapViewOfFileZVirtualQuerySizeZUnmapViewOfFile�_size�
memoryview�_buf) �selfr �create�sizeZstatsZ temp_nameZh_mapZlast_error_codeZp_bufr r r �__init__K s� � �� �
�
� ��� zSharedMemory.__init__c C s$ z| � � W d S ty Y d S w �N)�closer* �r3 r r r �__del__� s
�zSharedMemory.__del__c C s | j | jd| jffS )NF)� __class__r r5 r9 r r r �
__reduce__� s ��zSharedMemory.__reduce__c C s | j j� d| j�d| j� d�S )N�(z, size=�))r; �__name__r r5 r9 r r r �__repr__� s zSharedMemory.__repr__c C � | j S r7 )r2 r9 r r r �buf� � zSharedMemory.bufc C s0 | j }tr| jr| j �d�r| j dd � }|S )Nr r )r# r r$ �
startswith)r3 Z
reported_namer r r r � s
zSharedMemory.namec C rA r7 )r0 r9 r r r r5 � rC zSharedMemory.sizec C sb | j d ur| j �� d | _ | jd ur| j�� d | _tr-| jdkr/t�| j� d| _d S d S d S )Nr r )r2 �releaser) r8 r r! r r9 r r r r8 � s
�zSharedMemory.closec C s2 t r| jrt�| j� t�| jd� d S d S d S )Nr )r r# r Z
shm_unlinkr �
unregisterr9 r r r r+ � s
�zSharedMemory.unlink)NFr )r? �
__module__� __qualname__r# r! r) r2 r r r r r r$ r6 r: r< r@ �propertyrB r r5 r8 r+ r r r r r 2 s*
n
�utf8c @ s e Zd Z edededededdjdiZ dZ
dd � d
d � d d � d d � d
�Z e dd� �Z
d5dd�dd�Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zed#d$� �Zed%d&� �Zed'd(� �Zed)d*� �Zed+d,� �Z ed-d.� �Z ed/d0� �Z d1d2� Z d3d4� Z e!e"j#�Z$dS )6r �q�dzxxxxxxx?z%dsNzxxxxxx?x� c C s | S r7 r ��valuer r r �<lambda> � zShareableList.<lambda>c C s | � d��t�S �N� )�rstrip�decode� _encodingrN r r r rP s c C s
| � d�S rR )rT rN r r r rP s
c C s d S r7 r )Z_valuer r r rP rQ )r r r � c C s8 t | ttd jf�s dS t | t�rdS t | t�rdS dS )Nr r r rW )�
isinstance�str�bytesr; rN r r r �_extract_recreation_code s
z&ShareableList._extract_recreation_code�r c s� |d u s|d urc|p d}�fdd�|D �}t |��_d}dg�_|D ]}||d dkr.�jnt|d d� �7 }�j�|� q"�fdd�|D �}t�d�j d � |� �j
�j �}t |d
|d ��_
nt |��_
|d ur�t� tjd�j �j
jd�jg�j�R � tjd � |��j
j�jg� fd d
�|D ��R � tj�j
�j
j�jg� fdd
�|D ��R � tj�j �j
j�jg|�R � d S t ���_tt��j�j
jd���_d S )Nr c sP g | ]$}t |ttf�s� jt|� n� jt|� � jt|�� j d f �qS )r )rX rY rZ �_types_mapping�type�
_alignmentr ��.0�itemr9 r r �
<listcomp>- s �� ��z*ShareableList.__init__.<locals>.<listcomp>r r �sc s g | ]}� � |��qS r )r[ r` r9 r r rc ? s
�rK � T)r4 r5 c 3 s( � | ]}t |t�r|�� �n|V qd S r7 )rX rY �encode�ra �v��_encr r � <genexpr>Z s �& z)ShareableList.__init__.<locals>.<genexpr>c 3 s � | ]}|� � �V qd S r7 )rf rg ri r r rk ` s � rM )r � _list_len�_allocated_offsetsr_ �int�append�structZcalcsize�_format_size_metainfo�join�_format_packing_metainfo� _format_back_transform_codesr �shmrV � pack_intorB �_offset_data_start�_offset_packing_formats� _offset_back_transform_codes�list� unpack_from)r3 Zsequencer Z_formats�offset�fmtZ_recreation_codesZrequested_sizer )rj r3 r r6 * s�
�
&
�����
������� �
�
�zShareableList.__init__c C sl |dkr|n|| j }|| j ks| j dk rtd��t�d| jj| j|d �d }|�d�}|�t �}|S )Nr � Requested position out of range.�8srM rS )
rl �
IndexErrorrp r{ ru rB rx rT rU rV )r3 �positionrh r} �
fmt_as_strr r r �_get_packing_formats s ��
z!ShareableList._get_packing_formatc C sH || j ks | j dk rtd��t�d| jj| j| �d }| j| }|S )Nr r~ �b)rl r� rp r{ ru rB ry �_back_transforms_mapping)r3 r� �transform_codeZtransform_functionr r r �_get_back_transform� s ��
z!ShareableList._get_back_transformc C sj || j ks | j dk rtd��t�d| jj| j|d |�t�� | � |�}t�d| jj| j
| |� d S )Nr r~ r rM r� ) rl r� rp rv ru rB rx rf rV r[ ry )r3 r� r� rO r� r r r �!_set_packing_format_and_transform� s �
�z/ShareableList._set_packing_format_and_transformc C sr |dkr|n|| j }z| j| j| }t�| �|�| jj|�\}W n ty- td��w | � |�}||�}|S )Nr zindex out of range)
rl rw rm rp r{ r� ru rB r� r� )r3 r� r| rh Zback_transformr r r � __getitem__� s
� �
zShareableList.__getitem__c C s� |dkr|n|| j }z| j| }| j| }| �|�}W n ty' td��w t|ttf�s9| jt |� }|}n0| j|d | }t|t�rL|�
t �n|}t |�|krXt
d��|d dkra|}n| jt |f }| �|||� t�|| jj||� d S )Nr z assignment index out of ranger z(bytes/str item exceeds available storager rd )rl rm rw r� r� rX rY rZ r] r^ rf rV r r r� rp rv ru rB ) r3 r� rO Z item_offsetr| Zcurrent_formatZ
new_formatZ
encoded_valueZallocated_lengthr r r � __setitem__� s:
� �� ��zShareableList.__setitem__c C s t | j| jjd�dfS )Nr\ r )r r; ru r r9 r r r r< � � zShareableList.__reduce__c C s t �d| jjd�d S )NrK r )rp r{ ru rB r9 r r r �__len__� r� zShareableList.__len__c C s" | j j� dt| �� d| jj�d�S )Nr= z, name=r> )r; r? rz ru r r9 r r r r@ � s "zShareableList.__repr__c s d� � fdd�t� j�D ��S )Nre c 3 s � | ]}� � |�V qd S r7 )r� )ra �ir9 r r rk � s �
�z'ShareableList.format.<locals>.<genexpr>)rr �rangerl r9 r r9 r �format� s �zShareableList.formatc C s d| j d S )NrK r �rl r9 r r r rq � s z#ShareableList._format_size_metainfoc C � d| j S )Nr r� r9 r r r rs � �
z&ShareableList._format_packing_metainfoc C r� )Nr� r� r9 r r r rt � r� z*ShareableList._format_back_transform_codesc C s | j d d S )Nr rM r� r9 r r r rw � s z ShareableList._offset_data_startc C s | j | jd S )Nr )rw rm r9 r r r rx � � z%ShareableList._offset_packing_formatsc C s | j | jd S )NrM )rx rl r9 r r r ry r� z*ShareableList._offset_back_transform_codesc s t � fdd�| D ��S )Nc 3 s � | ]}� |kV qd S r7 r )ra �entryrN r r rk
s � z&ShareableList.count.<locals>.<genexpr>)�sum)r3 rO r rN r �count s zShareableList.countc C s2 t | �D ] \}}||kr| S qt|�d���)Nz not in this container)� enumerater )r3 rO r� r� r r r �index s �zShareableList.indexr7 )%r? rG rH rn �float�boolrY rZ r; r] r_ r� � staticmethodr[ r6 r� r� r� r� r� r< r� r@ rI r� rq rs rt rw rx ry r� r� � classmethod�types� GenericAlias�__class_getitem__r r r r r � sV ��
I!
)�__all__� functoolsr r( r r. rp r
r� r r- r r re r �O_CREATr r r
r r r rV r r r r r �<module> s2
F