/opt/alt/python34/lib64/python3.4/multiprocessing/__pycache__
Edit: /opt/alt/python34/lib64/python3.4/multiprocessing/__pycache__/reduction.cpython-34.pyc (7784B)
f @ s d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d d d d g Z e j
d k p e e d
o e e d o e e j d Z Gd
d d e j
Z e j Z d d d Z e j
d k rfe d d d g 7Z d d l Z d d d d Z d d Z d d Z d d Z Gd d d e Z nj e d d d g 7Z d d l Z e j
d k Z d d Z d d Z d d Z d d Z d d Z d! d" Z Gd# d$ d$ Z e e e j e d% d& Z! e e e" j# e! e e e$ j% e! d' d( Z& d) d* Z' e e j( e& e j
d k rd+ d, Z) d- d. Z* e e j e) n( d/ d, Z) d0 d. Z* e e j e) d S)1 N )context send_handle recv_handleForkingPicklerregisterdumpwin32CMSG_LEN
SCM_RIGHTSsendmsgc sg e Z d Z d Z i Z e j Z f d d Z e d d Z
e d d d Z e j
Z
S) r z)Pickler subclass used by multiprocessing.c s9 t j | | j j | _ | j j | j d S)N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducers)selfargs) __class__ >/opt/alt/python34/lib64/python3.4/multiprocessing/reduction.pyr % s zForkingPickler.__init__c C s | | j |
r. r3 r4 r0 r/ r? r5 r6 )r rC r r r r; t s zDupHandle.detach)r" r# r$ r% r r; r r r r r+ c s DupFdsendfdsrecvfdsdarwinc C s~ t j d | } t t | d g } | j | g t j t j | f g t rz | j d d k rz t d n d S)z,Send an array of fds over an AF_UNIX socket.i r Az%did not receive acknowledgement of fdN)
arraybyteslenr socket
SOL_SOCKETr ACKNOWLEDGEr: RuntimeError)sockZfdsmsgr r r rE s
%c C sT t j d } | j | } | j d t j | \ } } } } | rZ | rZ t n y t rs | j d n t | d k r t d t | n | d \ } } }
| t j
k r(| t j k r(t |
| j d k r t n | j
|
t | d | d k s t t | SWn t t f k
rCYn Xt d d S) z/Receive an array of fds over an AF_UNIX socket.rH r rJ z received %d items of ancdatar rI zInvalid data receivedN)rK itemsizeZrecvmsgrN r
EOFErrorrP r7 rM rQ rO r
ValueErrorZ frombytesAssertionErrorlist
IndexError) rR sizeaZ
bytes_sizerS ZancdataflagsZaddrZ
cmsg_levelZ cmsg_typeZ cmsg_datar r r rF s,
'
c
C s> t j | j t j t j } t | | g Wd QXd S)z&Send a handle over a local connection.N)rN fromfdfilenoAF_UNIX SOCK_STREAMrE )r8 r2 r9 sr r r r s $c
C s? t j | j t j t j } t | d d SWd QXd S)z)Receive a handle over a local connection.r r N)rN r] r^ r_ r` rF )r8 ra r r r r s $c C sa t j } | d k r. | j | j | St rQ d d l m } | j | St d d S)zReturn a wrapper for an fd.Nr )resource_sharerz&SCM_RIGHTS appears not to be available)r Zget_spawning_popenrD Zduplicate_for_childHAVE_SEND_HANDLE rb rV )fdZ popen_objrb r r r rD s
c C sE | j d k r( t | j | j j f f St | j | j j f f Sd S)N)__self__getattrr __func__r" )mr r r _reduce_method s rj c @ s e Z d Z d d Z d S)_Cc C s d S)Nr )r r r r f s z_C.fN)r" r# r$ rl r r r r rk s rk c C s t | j | j f f S)N)rg __objclass__r" )ri r r r _reduce_method_descriptor s rn c C s" t | j | j | j p i f f S)N)_rebuild_partialfuncr keywords)pr r r _reduce_partial s rs c C s t j | | | S)N) functoolspartial)rp r rq r r r ro s ro c C s# d d l m } t | | f f S)Nr ) DupSocket)rb rv _rebuild_socket)ra rv r r r _reduce_socket s rx c C s
| j S)N)r; )Zdsr r r rw s rw c C s1 t | j } t | | j | j | j f f S)N)rD r^ rw familyr proto)ra dfr r r rx s c C s% | j } t j | | | d | S)Nr^ )r; rN )r{ ry r rz re r r r rw s )+r& rt r r< r( rN sysrd r __all__platformhasattrrc ZPicklerr r r r. r, r- r r objectr+ rK rP rE rF rD rj rk r rl rn rX appendint__add__rs ro ru rx rw r r r r
s^ #