Warning: Cannot modify header information - headers already sent by (output started at /var/www/jonas-eriksen.dk/pic/private/index.php:1) in /var/www/jonas-eriksen.dk/pic/private/index.php on line 215
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 ZdddddZddddd 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) reductionassert_spawningRawValueRawArrayValueArraycopy synchronized) cubBhHiIlLfdc C s t j| }tj|}t| |d S )N)ctypessizeofr Z
BufferWrapper
rebuild_ctype)type_sizewrapper 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_typegetr! r memset addressofr __init__)typecode_or_typeargsr objr r r r + s
c C sj t j| | }t|trD|| }t|}tjtj|dtj| |S |t | }t|}|j
| |S dS )z=
Returns a ctypes array allocated from shared memory
r N) r" r#
isinstanceintr! r r$ r% r lenr& )r' size_or_initializerr r) resultr r r r 5 s
T)lockctxc G sX t | f| }|dkr|S |dkr4|p*t }|j }t|dsJtd| t|||dS )z6
Return a synchronization wrapper for a Value
FTNacquirez '%r' has no method 'acquire')r0 )TN)r r RLockhasattrAttributeErrorr )r' r/ r0 r( r) r r r r E s
c C sT t | |}|dkr|S |dkr0|p&t }|j }t|dsFtd| t|||dS )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 | tjr6t| ||S t | tjrf| 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
u s z synchronized..c s s | ]}|t |fV qd S )N)
make_property)r6 namer r r v s z synchronized.. Synchronized)r* SynchronizedBaseAssertionErrorr r Z _SimpleCDatar; r
_type_c_charSynchronizedStringSynchronizedArrayr5 class_cacheKeyErrorZ_fields_dict__name__)r) r/ r0 clssclsnamesr Z classnamer r r r f s"
c C s@ t | t| tjr(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)_ForkingPicklerregisterrJ 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 exectemplate)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 ZdddZdd 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 ZedZdS )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 | jS )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 startstopr 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 ZedZedZdS )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
s: