Edit File: sharedctypes.cpython-37.pyc
B � f� � @ sB 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 je je jd �Zd d� Zdd� Zdd� Z ddd�dd�Z ddd�dd �Z dd � Z d&dd �Z dd� Z!dd� Z"dd � Z#d Z$i Z%e�&� 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�q�Q�f�dc C s t �| �}t�|�}t| |d �S )N)�ctypes�sizeofr Z BufferWrapper� rebuild_ctype)�type_�size�wrapper� r! �A/opt/alt/python37/lib64/python3.7/multiprocessing/sharedctypes.py� _new_value' s r# c G s< t �| | �}t|�}t�t�|�dt�|�� |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 �| | �}t|t�rD|| }t|�}t�t�|�dt�|�� |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 6 s T)�lock�ctxc G sX t | f|�� }|dkr|S |dkr4|p*t� }|�� }t|d�sJtd| ��t|||d�S )z6 Return a synchronization wrapper for a Value F)TN�acquirez%r has no method 'acquire')r2 )r r �RLock�hasattr�AttributeErrorr )r) r1 r2 r* r+ r! r! r" r F s c C sT t | |�}|dkr|S |dkr0|p&t� }|�� }t|d�sFtd| ��t|||d�S )z9 Return a synchronization wrapper for a RawArray F)TNr3 z%r has no method 'acquire')r2 )r r r4 r5 r6 r )r) r/ r1 r2 r+ r! r! r" r T s c C s t t| ��}| t�|�d< |S )Nr )r# �typer Zpointer)r+ Znew_objr! r! r" r b s c C s� t | t�rtd��|pt� }t | tj�r4t| ||�S t | tj�rd| jtj krXt | ||�S t | ||�S t | �}y t | }W nR tk r� dd� |jD �}dd� |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>v s z synchronized.<locals>.<listcomp>c S s i | ]}t |�|�qS r! )� make_property)r8 �namer! r! r" � <dictcomp>w s z synchronized.<locals>.<dictcomp>� Synchronized)r, �SynchronizedBase�AssertionErrorr r Z _SimpleCDatar= r �_type_�c_char�SynchronizedString�SynchronizedArrayr7 � class_cache�KeyErrorZ_fields_�__name__)r+ r1 r2 �clsZscls�namesr Z classnamer! r! r" r g 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_r7 )r+ r! r! r" � reduce_ctype� s rJ c C s8 |d k r| | } t �| t� |�� }| �|�}||_|S )N)�_ForkingPickler�registerrJ Zcreate_memoryviewZ from_bufferrI )r r �lengthZbufr+ r! r! r" r � s r c C sJ yt | S tk rD i }tt| fd |� || t | < || S X d S )N� )� prop_cacherE �exec�template)r; r r! r! r" r: � s r: 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�}|�� | _| jj| _| jj| _d S )NT)Zforce)�_obj�_lockr r4 r3 �release)�selfr+ r1 r2 r! r! r" r( � s zSynchronizedBase.__init__c C s | j �� S )N)rS � __enter__)rU r! r! r" rV � s zSynchronizedBase.__enter__c G s | j j|� S )N)rS �__exit__)rU r* r! r! r" rW � s zSynchronizedBase.__exit__c C s t | � t| j| jffS )N)r r rR rS )rU r! r! r" � __reduce__� s zSynchronizedBase.__reduce__c C s | j S )N)rR )rU r! r! r" �get_obj� s zSynchronizedBase.get_objc C s | j S )N)rS )rU r! r! r" �get_lock� s zSynchronizedBase.get_lockc C s dt | �j| jf S )Nz<%s wrapper for %s>)r7 rF rR )rU r! r! r" �__repr__� s zSynchronizedBase.__repr__)NN) rF � __module__� __qualname__r( rV rW rX rY rZ r[ r! r! r! r" r> � s r> c @ s e Zd Zed�ZdS )r= �valueN)rF r\ r] r: r^ r! r! r! r" r= � s r= c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) rC c C s t | j�S )N)r. rR )rU r! r! r" �__len__� s zSynchronizedArray.__len__c C s | � | j | S Q R X d S )N)rR )rU r r! r! r" � __getitem__� s z SynchronizedArray.__getitem__c C s | � || j |< W d Q R X d S )N)rR )rU r r^ r! r! r" � __setitem__� s z SynchronizedArray.__setitem__c C s | � | j ||� S Q R X d S )N)rR )rU �start�stopr! r! r" � __getslice__� s z SynchronizedArray.__getslice__c C s" | � || j ||�< W d Q R X d S )N)rR )rU rb rc �valuesr! r! r" � __setslice__� s z SynchronizedArray.__setslice__N)rF r\ r] r_ r` ra rd rf r! r! r! r" rC � s rC c @ s e Zd Zed�Zed�ZdS )rB r^ �rawN)rF r\ r] r: r^ rg r! r! r! r" rB � s rB )NN)-r �weakref� r r �contextr r ZForkingPicklerrK �__all__rA Zc_wcharZc_byteZc_ubyteZc_shortZc_ushortZc_intZc_uintZc_longZc_ulongZ c_longlongZ c_ulonglongZc_floatZc_doubler$ r# r r r r r r rJ r r: rQ rO �WeakKeyDictionaryrD �objectr> r= rC rB r! r! r! r" �<module> s<
Back to File Manager