ó
|
]\¬Qc @ sy d d d g 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 Z d d l Z d d l m
|
Z
|
m Z d d l m Z m Z m Z m Z d d l m Z m Z d Z d Z e j Z d
|
Z d
|
g Z e e d r d Z e d g 7Z n e j d k r.d Z e d g 7Z n e d Z d Z d Z d Z d e f d YZ! d d d Z# e j d k re$ d Z% n d d l m& Z& e$ d Z% d e f d YZ' d Z( e j d k rd e f d YZ) d Z* n d Z+ d Z, d Z- d Z. d! Z/ d" Z0 d# e f d$ YZ1 d% Z2 d& Z3 d' e! f d( YZ4 d) Z5 d S(* t Clientt Listenert PipeiÿÿÿÿN( t current_processt AuthenticationError( t get_temp_dirt Finalizet sub_debugt debug( t duplicatet closei g 4@t AF_INETt AF_UNIXt win32t AF_PIPEc C s t j | S( N( t time( t timeout( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyt _init_timeoutI s c C s t j | k S( N( R ( t t( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyt _check_timeoutL s c C sw | d k r d S| d k r5 t j d d d t S| d k rg t j d d t j t j f St d
|
d S( s?
|
Return an arbitrary free address for the given family
|
R t localhosti R t prefixs listener-t dirR s \\.\pipe\pyc-%d-%d-s unrecognized familyN( R i ( t tempfilet mktempR t ost getpidt _mmap_countert nextt
|
ValueError( t family( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyt arbitrary_addressS s c C se t | t k r d St | t k r; | j d r; d St | t k rQ d St d | d S( s]
|
Return the types of the address
|
|
This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE'
|
R s \\R R s address type of %r unrecognizedN( t typet tuplet strt
|
startswithR ( t address( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyt address_typeb s !c B sS e Z d Z d d d d d Z d Z d Z e d Z e d Z RS( s
|
Returns a listener object.
|
|
This is a wrapper for a bound socket which is 'listening' for
|
connections, or for a Windows named pipe.
|
i c C s | p | r t | p t } | p- t | } | d k rQ t | | | _ n t | | | | _ | d k r t | t r t d n | | _
|
d S( NR s authkey should be a byte string( R% t default_familyR t PipeListenert _listenert SocketListenert Nonet
|
isinstancet bytest TypeErrort _authkey( t selfR$ R t backlogt authkey( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyt __init__| s c C s? | j j } | j r; t | | j t | | j n | S( sz
|
Accept a connection on the bound socket or named pipe of `self`.
|
|
Returns a `Connection` object.
|
( R( t acceptR. t deliver_challenget answer_challenge( R/ t c( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR3 s
|
c C s | j j S( sA
|
Close the bound socket or named pipe of `self`.
|
( R( R
|
( R/ ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR
|
s c C s
|
| j j S( N( R( t _address( R/ ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyt <lambda> s c C s
|
| j j S( N( R( t _last_accepted( R/ ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR8 s N(
|
t __name__t
|
__module__t __doc__R* R2 R3 R
|
t propertyR$ t last_accepted( ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR u s c C s | p t | } | d k r- t | } n t | } | d k ra t | t ra t d n | d k r t | | t | | n | S( s=
|
Returns a connection to the address of a `Listener`
|
R s authkey should be a byte stringN( R% t
|
PipeClientt SocketClientR* R+ R, R- R5 R4 ( R$ R R1 R6 ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR ¡ s c C sË | r
t j \ } } | j t | j t t j t j | j } t j t j | j } | j | j n< t j
|
\ } } t j | d t } t j | d t } | | f S( sL
|
Returns pair of connection objects at either end of a pipe
|
t writablet readable( t sockett
|
socketpairt setblockingt Truet _multiprocessingt
|
ConnectionR t dupt filenoR
|
t pipet False( t duplext s1t s2t c1t c2t fd1t fd2( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR · s
|
( R c C sU t d } | r; t j } t j t j B} t t } } n t j } t j } d t } } t j | | t j t j Bt j
|
Bd | | t j t j } t j | | d t j t j d t j } t j | t j d d y t j | t j Wn/ t k
|
r } | j d t j k r! q!n Xt j | d | } t j | d | }
|
| |
|
f S( sL
|
Returns pair of connection objects at either end of a pipe
|
R i i RA RB N( R R t PIPE_ACCESS_DUPLEXt GENERIC_READt GENERIC_WRITEt BUFSIZEt PIPE_ACCESS_INBOUNDt CreateNamedPipet PIPE_TYPE_MESSAGEt PIPE_READMODE_MESSAGEt PIPE_WAITt NMPWAIT_WAIT_FOREVERt NULLt
|
CreateFilet OPEN_EXISTINGt SetNamedPipeHandleStateR* t ConnectNamedPipet WindowsErrort argst ERROR_PIPE_CONNECTEDRG t PipeConnection( RM R$ t openmodet accesst obsizet ibsizet h1t h2t eRP RQ ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR Í s2 $
|
R) c B s, e Z d Z d d Z d Z d Z RS( sO
|
Representation of a socket which is bound to an address and listening
|
i c C sö t j t t | | _ yb | j j t j t j d | j j t | j j | | j j | | j j
|
| _ Wn$ t j k
|
r£ | j j n X| | _ d | _ | d k ré t | t j d | f d d | _ n d | _ d S( Ni R Rd t exitpriorityi ( RC t getattrt _sockett
|
setsockoptt
|
SOL_SOCKETt SO_REUSEADDRRE RF t bindt listent getsocknameR7 t errorR
|
t _familyR* R9 R R t unlinkt _unlink( R/ R$ R R0 ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR2 û s $c C sT | j j \ } | _ | j t t | j } t j | } | j | S( N(
|
Rp R3 R9 RE RF R RJ RG RH R
|
( R/ t st fdt conn( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR3 s
|
c C s- | j j | j d k r) | j n d S( N( Rp R
|
Rz R* ( R/ ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR
|
s ( R: R; R< R2 R3 R
|
( ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR) ÷ s c C sß t | } t j t t | } | j t t } xs y | j | WnX t j k
|
r¨ } | j d t j
|
k s
t | r t d | n t j d q= XPq= t | j } t j | } | j | S( sO
|
Return a connection object connected to the socket given by `address`
|
i s failed to connect to address %sg{®Gáz?( R% RC Ro RE RF R t connectRw Rd t errnot ECONNREFUSEDR R R t sleepR RJ RG RH R
|
( R$ R R{ R Rm R| R} ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR@ s$ "
|
R' c B s2 e Z d Z d d Z d Z e d Z RS( s0
|
Representation of a named pipe
|
c C s | | _ t j | t j t j t j Bt j Bt j t t t j t j
|
} | g | _ d | _ t d | j t | t j d | j | j f d d | _ d S( Ns listener created with address=%rRd Rn i ( R7 R RY RT RZ R[ R\ t PIPE_UNLIMITED_INSTANCESRW R] R^ t _handle_queueR* R9 R R R' t _finalize_pipe_listenerR
|
( R/ R$ R0 t handle( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR2 C s c C sÅ t j | j t j t j t j Bt j Bt j t t t j t j
|
} | j j | | j j d } y t j | t j
|
Wn8 t k
|
r· } | j d t j t j f k r¸ q¸ n Xt j | S( Ni ( R RY R7 RT RZ R[ R\ R RW R] R^ R t appendt popRb Rc Rd Re t ERROR_NO_DATARG Rf ( R/ t newhandleR
Rm ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR3 V s
|
c C s, t d | x | D] } t | q Wd S( Ns closing listener with address=%r( R R
|
( t queueR$ R
( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR j s N( R: R; R< R* R2 R3 t staticmethodR ( ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR' ? s c C sÈ t } x yH t j | d t j | t j t j Bd t j t j d t j } WnD t k
|
r } | j d t j
|
t j f k s t | r q q XPq t j | t j d d t j | S( sU
|
Return a connection object connected to the pipe given by `address`
|
iè i N( R R t WaitNamedPipeR_ RU RV R^ R` Rc Rd t ERROR_SEM_TIMEOUTt ERROR_PIPE_BUSYR Ra R[ R* RG Rf ( R$ R t hRm ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR? p s "
|
i s #CHALLENGE#s #WELCOME#s #FAILURE#c C s¡ d d l } t | t s! t t j t } | j t | | j | | j
|
} | j d } | | k r | j t n | j t t d d S( Niÿÿÿÿi s digest received was wrong( t hmacR+ R, t AssertionErrorR t urandomt MESSAGE_LENGTHt
|
send_bytest CHALLENGEt newt digestt
|
recv_bytest WELCOMEt FAILURER ( t
|
connectionR1 R t messageR t response( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR4 s c C s¹ d d l } t | t s! t | j d } | t t t k sV t d | | t t } | j | | j } | j | | j d } | t
|
k rµ t d n d S( Niÿÿÿÿi s message = %rs digest sent was rejected( R R+ R, R R t lenR R R R R R ( R R1 R R R R ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR5 ¡ s & t ConnectionWrapperc B s# e Z d Z d Z d Z RS( c C sO | | _ | | _ | | _ x- d D]% } t | | } t | | | q" Wd S( NRJ R
|
t pollR R ( s filenos closeR s
|
recv_bytess
|
send_bytes( t _connt _dumpst _loadsRo t setattr( R/ R} t dumpst loadst attrt obj( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR2 ² s c C s# | j | } | j j | d S( N( R¢ R¡ R ( R/ R¨ R{ ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyt send¹ s c C s | j j } | j | S( N( R¡ R R£ ( R/ R{ ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyt recv¼ s ( R: R; R2 R© Rª ( ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR ± s c C s% t j | f d d d d j d S( Ni t utf8( t xmlrpclibR¥ R* t encode( R¨ ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyt
|
_xml_dumpsÀ s c C s% t j | j d \ \ } } | S( NR« ( R¬ R¦ t decode( R{ R¨ t method( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyt
|
_xml_loadsà s !t XmlListenerc B s e Z d Z RS( c C s+ d d l a t j | } t | t t S( Niÿÿÿÿ( R¬ R R3 R R® R± ( R/ R¨ ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR3 È s ( R: R; R3 ( ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyR² Ç s c O s% d d l a t t | | t t S( Niÿÿÿÿ( R¬ R R R® R± ( Rd t kwds( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyt XmlClientÎ s (6 t __all__R t sysRC R R R t itertoolsRG t multiprocessingR R t multiprocessing.utilR R R R t multiprocessing.forkingR R
|
RW t CONNECTION_TIMEOUTt countR R& t familiest hasattrt platformR R R R% t objectR R* R RF R R R) R@ R' R? R R R R R4 R5 R R® R± R² R´ ( ( ( sb /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/connection.pyt <module># s` " , *' 1
|
