⚝
One Hat Cyber Team
⚝
Your IP:
160.79.109.140
Server IP:
162.254.39.145
Server:
Linux premium289.web-hosting.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64
Server Software:
LiteSpeed
PHP Version:
8.2.28
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib64
/
python3.6
/
multiprocessing
/
__pycache__
/
View File Name :
sharedctypes.cpython-36.pyc
3 \e � @ s: d dl Z d dlZddlmZ ddlmZ ddlmZmZ ejZ dddd d d gZ e j e j e j e je je je je je je je je jd � Zd d� Zdd� Zdd� Zddd�dd�Zddd�dd �Z dd � Z d&dd �Z dd� Z dd� Z dd � Z!d Z"i Z#ej$� Z%G d d � d e&�Z'G d d!� d!e'�Z(G d"d#� d#e'�Z)G d$d%� d%e)�Z*dS )'� N� )�heap)� get_context)� reduction�assert_spawning�RawValue�RawArray�Value�Array�copy� synchronized) �c�u�b�B�h�H�i�I�l�L�f�dc C s t j| �}tj|�}t| |d �S )N)�ctypes�sizeofr Z BufferWrapper� rebuild_ctype)�type_�size�wrapper� r �4/usr/lib64/python3.6/multiprocessing/sharedctypes.py� _new_value& s r! c G s< t j| | �}t|�}tjtj|�dtj|�� |j|� |S )z> Returns a ctypes object allocated from shared memory r )�typecode_to_type�getr! r �memset� addressofr �__init__)�typecode_or_type�argsr �objr r r r + s c C sj t j| | �}t|t�rD|| }t|�}tjtj|�dtj|�� |S |t |� }t|�}|j |� |S dS )z= Returns a ctypes array allocated from shared memory r N) r" r# � isinstance�intr! r r$ r% r �lenr& )r' �size_or_initializerr r) �resultr r r r 5 s T)�lock�ctxc G sX t | f|�� }|dkr|S |dkr4|p*t� }|j� }t|d�sJtd| ��t|||d�S )z6 Return a synchronization wrapper for a Value FTN�acquirez '%r' has no method 'acquire')r0 )TN)r r �RLock�hasattr�AttributeErrorr )r' r/ r0 r( r) r r r r E s c C sT t | |�}|dkr|S |dkr0|p&t� }|j� }t|d�sFtd| ��t|||d�S )z9 Return a synchronization wrapper for a RawArray FTNr1 z '%r' has no method 'acquire')r0 )TN)r r r2 r3 r4 r )r' r- r/ r0 r) r r r r S s c C s t t| ��}| tj|�d< |S )Nr )r! �typer Zpointer)r) Znew_objr r r r a s c C s� t | t� std��|p t� }t | tj�r6t| ||�S t | tj�rf| jtj krZt | ||�S t | ||�S t | �}y t | }W nV tk r� dd� |jD �}tdd� |D ��}d|j }t |tf|� }t |< Y nX || ||�S d S )Nzobject already synchronizedc S s g | ] }|d �qS )r r )�.0Zfieldr r r � <listcomp>u s z synchronized.<locals>.<listcomp>c s s | ]}|t |�fV qd S )N)� make_property)r6 �namer r r � <genexpr>v s z synchronized.<locals>.<genexpr>� Synchronized)r* �SynchronizedBase�AssertionErrorr r Z _SimpleCDatar; r �_type_�c_char�SynchronizedString�SynchronizedArrayr5 � class_cache�KeyErrorZ_fields_�dict�__name__)r) r/ r0 �cls�scls�namesr Z classnamer r r r f s" c C s@ t | � t| tj�r(t| j| j| jffS tt| �| jd ffS d S )N) r r* r r r r> �_wrapperZ_length_r5 )r) r r r � reduce_ctype s rJ c C s8 |d k r| | } t j| t� |j� }| j|�}||_|S )N)�_ForkingPickler�registerrJ Zcreate_memoryviewZ from_bufferrI )r r ZlengthZbufr) r r r r � s r c C sJ yt | S tk rD i }tt| fd |� || t | < || S X d S )N� )� prop_cacherC �exec�template)r9 r r r r r8 � s r8 z� def get%s(self): self.acquire() try: return self._obj.%s finally: self.release() def set%s(self, value): self.acquire() try: self._obj.%s = value finally: self.release() %s = property(get%s, set%s) c @ sF e Zd Zddd�Zdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z dS )r< Nc C sB || _ |r|| _n|p tdd�}|j� | _| jj| _| jj| _d S )NT)Zforce)�_obj�_lockr r2 r1 �release)�selfr) r/ r0 r r r r& � s zSynchronizedBase.__init__c C s | j j� S )N)rR � __enter__)rT r r r rU � s zSynchronizedBase.__enter__c G s | j j|� S )N)rR �__exit__)rT r( r r r rV � s zSynchronizedBase.__exit__c C s t | � t| j| jffS )N)r r rQ rR )rT r r r � __reduce__� s zSynchronizedBase.__reduce__c C s | j S )N)rQ )rT r r r �get_obj� s zSynchronizedBase.get_objc C s | j S )N)rR )rT r r r �get_lock� s zSynchronizedBase.get_lockc C s dt | �j| jf S )Nz<%s wrapper for %s>)r5 rE rQ )rT r r r �__repr__� s zSynchronizedBase.__repr__)NN) rE � __module__� __qualname__r& rU rV rW rX rY rZ r r r r r< � s r< c @ s e Zd Zed�ZdS )r; �valueN)rE r[ r\ r8 r] r r r r r; � s r; c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) rA c C s t | j�S )N)r, rQ )rT r r r �__len__� s zSynchronizedArray.__len__c C s | � | j | S Q R X d S )N)rQ )rT r r r r � __getitem__� s z SynchronizedArray.__getitem__c C s | � || j |< W d Q R X d S )N)rQ )rT r r] r r r � __setitem__� s z SynchronizedArray.__setitem__c C s | � | j ||� S Q R X d S )N)rQ )rT �start�stopr r r � __getslice__� s z SynchronizedArray.__getslice__c C s" | � || j ||�< W d Q R X d S )N)rQ )rT ra rb �valuesr r r � __setslice__� s z SynchronizedArray.__setslice__N)rE r[ r\ r^ r_ r` rc re r r r r rA � s rA c @ s e Zd Zed�Zed�ZdS )r@ r] �rawN)rE r[ r\ r8 r] rf r r r r r@ � s r@ )NN)+r �weakref� r r �contextr r ZForkingPicklerrK �__all__r? Zc_wcharZc_byteZc_ubyteZc_shortZc_ushortZc_intZc_uintZc_longZc_ulongZc_floatZc_doubler" r! r r r r r r rJ r r8 rP rN �WeakKeyDictionaryrB �objectr< r; rA r@ r r r r �<module> s: