ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
a
i(% @ s d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
g dZ ej dkpe
edoe
edoe
ejd ZG d
d d ejZejZd8d d
Zej dk re g d7 Z d dlZd9ddddZdd Zdd Zdd ZG dd deZnFe g d7 Z d dlZej d kZd d Z d d Z d!d Zd"d Zd#d$ Z d%d& Z G d'd( d(Z ee!e j"e d)d* Z#ee!e$j%e# ee!e&j'e# d+d, Z(d-d. Z)eej*e( ej dkrd/d0 Z+d1d2 Z,eeje+ n d3d0 Z+d4d2 Z,eeje+ G d5d6 d6ed7Z-dS ): )ABCMetaN )context) send_handle recv_handleForkingPicklerregisterdumpwin32CMSG_LEN
SCM_RIGHTSsendmsgc sJ e Zd ZdZi ZejZ fddZe dd Z
e d ddZ e j
Z
ZS )
r z)Pickler subclass used by multiprocessing.c s* t j| | j | _| j| j d S N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducersselfargs __class__ 1/usr/lib64/python3.9/multiprocessing/reduction.pyr & s zForkingPickler.__init__c C s || j |< dS )z&Register a reduce function for a type.N)r )clstypereducer r r r + s zForkingPickler.registerNc C s t }| ||| | S r )ioBytesIOr getbuffer)r objprotocolbufr r r dumps0 s zForkingPickler.dumps)N)__name__
__module__ __qualname____doc__r copyregr r r classmethodr r& pickleloads
__classcell__r r r r r ! s
r c C s t ||| dS )z3Replacement for pickle.dump() using ForkingPickler.N)r r )r# filer$ r r r r : s r ) DupHandle duplicate steal_handleF)source_processc C s6 t }|du r|}|du r |}t || |d|t jS )z r? )r rN r r r rF y s
zDupHandle.detach)N)r' r( r) r* r rF r r r r r1 h s
r1 )DupFdsendfdsrecvfdsdarwinc C sV t d|}tt|d g}| |gtjtj|fg trR| ddkrRt ddS )z,Send an array of fds over an AF_UNIX socket.i r Az%did not receive acknowledgement of fdN)
arraybyteslenr
socket
SOL_SOCKETr ACKNOWLEDGErE RuntimeError)sockfdsmsgr r r rP s
rP c C s t d}|j| }| dt|\}}}}|s:|s:tztrJ| d t|dkrft dt| |d \}} }
|tj
kr| tj krt|
|j dkrt |
|
t|d |d krtdt||d t|W S W n t tfy Y n0 t dd S )
z/Receive an array of fds over an AF_UNIX socket.rS r rU z received %d items of ancdatar rT z Len is {0:n} but msg[0] is {1!r}zInvalid data receivedN)rV itemsizerecvmsgrY
CMSG_SPACEEOFErrorr[ rA rX r\ rZ r
ValueError frombytesAssertionErrorformatlist
IndexError) r] sizea
bytes_sizer_ ancdataflagsaddr
cmsg_level cmsg_type cmsg_datar r r rQ s:
rQ c C sF t | t jt j }t||g W d n1 s80 Y dS r@ )rY fromfdfilenoAF_UNIX SOCK_STREAMrP )rB r9 rC sr r r r s c C sH t | t jt j }t|dd W d S 1 s:0 Y dS )rD r r N)rY rs rt ru rv rQ )rB rw r r r r s c C sF t }|dur ||| S tr:ddlm} || S tddS )zReturn a wrapper for an fd.Nr )resource_sharerz&SCM_RIGHTS appears not to be available)r get_spawning_popenrO duplicate_for_childHAVE_SEND_HANDLE rx rd )fd popen_objrx r r r rO s
rO c C s2 | j d u r t| j| jjffS t| j | jjffS d S r )__self__getattrr __func__r' mr r r _reduce_method s
r c @ s e Zd Zdd ZdS )_Cc C s d S r r )r r r r f s z_C.fN)r' r( r) r r r r r r s r c C s t | j| jffS r )r __objclass__r' r r r r _reduce_method_descriptor s r c C s t | j| j| jpi ffS r )_rebuild_partialfuncr keywords)pr r r _reduce_partial s r c C s t j| g|R i |S r ) functoolspartial)r r r r r r r s r c C s ddl m} t|| ffS )Nr ) DupSocket)rx r _rebuild_socket)rw r r r r _reduce_socket s r c C s | S r )rF )Zdsr r r r s r c C s" t | }t|| j| j| jffS r )rO rt r familyr proto)rw dfr r r r s c C s | }tj||||dS )N)rt )rF rY )r r r r r} r r r r s c @ sd e Zd ZdZeZeZeZeZeZe j
dkr8e Z e Z e
Z
n eZeZeZeZeZeZeZeZdd ZdS )AbstractReducerzAbstract base class for use in implementing a Reduction class
suitable for use in replacing the standard reduction mechanism
used in multiprocessing.r
c G sN t tt jt t ttjt t ttj t t t
j t t t
j
t d S r )r r r r r rh appendr int__add__r r r rY r r r r r r s
zAbstractReducer.__init__N)r' r( r) r* r r r r r sysplatformr3 r2 r1 rP rQ rO r r r r r r r r r r r s&
r ) metaclass)N)NF).abcr r+ r r rG r- rY r r| r __all__r hasattrr{ Picklerr r r r5 r2 r3 r r objectr1 rV r[ rP rQ rO r r r r r rh r r r r r r r r r r r r r
sj
#