ó
|
]\¬Qc @ s 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 d d d d g Z d Z d d
|
l m
|
Z
|
d e
|
f d YZ d Z e j e e j e d Z e j e e j e e j e e j e y d d l m Z Wn e k
|
rn# Xd Z d Z e j e e e j d k rd d l Z e j Z e j Z e j Z d e! f d YZ" n}d d l# Z# d d l$ Z$ d d l% Z% d d l Z d d l& m' Z' m( Z( m) Z) d d l m* Z* d d l m+ Z+ m, Z, d d Z. d Z/ e j d k o%e0 e d e1 Z2 e j3 j4 j5 d Z6 e' j7 Z e' j8 Z e6 rse j9 j: e j; d a< n e j3 a< d Z= d e1 d Z d e! f d YZ" d Z> d Z? d! Z@ d" ZA d# ZB d$ ZC e j e( eC e j e) eC g ZD d% ZE d S(& iÿÿÿÿN( t utilt processt Popent assert_spawningt exitt duplicatet closet ForkingPicklerc C s, t j s( t d t | j n d S( NsF %s objects should only be shared between processes through inheritance( R t thread_is_spawningt RuntimeErrort typet __name__( t self( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyR 0 s ( t Picklerc B s& e Z e j j Z e d Z RS( c s f d } | | j | <d S( Nc s# | } | j d | | d S( Nt obj( t save_reduce( R R t rv( t reduce( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt
|
dispatcherA s ( t dispatch( t clsR
|
R R ( ( R s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt register? s ( R t
|
__module__R R t copyt classmethodR ( ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyR < s c C sE | j d k r( t | j | j j f f St | j | j j f f Sd S( N( t im_selft Nonet getattrt im_classt im_funct func_name( t m( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt _reduce_methodF s c C s t | j | j f f S( N( R t __objclass__R ( R ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt _reduce_method_descriptorM s ( t partialc C s" t | j | j | j p i f f S( N( t _rebuild_partialt funct argst keywords( t p( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt _reduce_partial\ s c C s t | | | S( N( R# ( R% R& R' ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyR$ ^ s t win32c B sD e Z d Z e j d Z d d Z d Z e d Z
|
RS( c C s£ t j j t j j d | _ t j | _ | j d k r d t j k ri d d l
|
} | j n | j } t j j t j j t j | n d S( Ni t randomiÿÿÿÿ( t syst stdoutt flusht stderrR t
|
returncodet ost forkt pidt modulesR+ t seedt
|
_bootstrapt _exit( R t process_objR+ t code( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt __init__t s c C sÖ | j d k rÏ x\ t rm y t j | j | \ } } Wn/ t j k
|
rh } | j t j k rd q n d SXPq W| | j k rÏ t j | r¢ t j
|
| | _ qÌ t j | s· t t j | | _ qÏ n | j S( N( R0 R t TrueR1 t waitpidR3 t errort errnot EINTRt WIFSIGNALEDt WTERMSIGt WIFEXITEDt AssertionErrort WEXITSTATUS( R t flagR3 t stst e( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt poll s c C s | d k r | j d St j | } d } xb | j } | d k rN Pn | t j } | d k rn Pn t | d | d } t j | q2 | S( Ni gü©ñÒMb@?i g©?( R RH t timet mint sleep( R t timeoutt deadlinet delayt rest remaining( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt wait s c C sd | j d k r` y t j | j t j Wq` t k
|
r\ } | j d d d k r] q] q` Xn d S( NRL g¹?( R0 R R1 t killR3 t signalt SIGTERMt OSErrorRQ ( R RG ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt terminate¨ s c C s t S( N( t False( ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyR ° s N( R R R: R1 t WNOHANGRH R RQ RV t staticmethodR ( ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyR r s
|
( R* t
|
Connectiont PipeConnectioni ( t Finalize( t loadt HIGHEST_PROTOCOLc C s t | | j | d S( N( R t dump( R t filet protocol( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyR_ Æ s i t frozens pythonservice.exes
|
python.exec C s
|
| a d S( N( t _python_exe( t exe( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt set_executableÞ s c C sF | d k r t j } n t j t j | | d | t j j S( Ni ( R t _subprocesst GetCurrentProcesst DuplicateHandlet DUPLICATE_SAME_ACCESSt Detach( t handlet target_processt inheritable( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyR æ s
|
c B s_ e Z d Z e j Z d Z e d Z e d Z d d Z d Z d Z RS( sH
|
Start a subprocess to run the code of a process object
|
c
|
C s7 t j \ } } t t j | d t } t j | t | g } d j d | D } t j
|
t | d d d d d d d \ } } } } | j t | | | _ d | _ | | _ t | j }
|
t j | d } t | t j _ z$ t |
|
| t t | | t Wd t j ` | j Xd S( NRm t c s s | ] } d | Vq d S( s "%s"N( ( t .0t x( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pys <genexpr> s i i t wb( R1 t pipeR t msvcrtt get_osfhandleR; R t get_command_linet joinRf t CreateProcessRc R t CloseR3 R0 t _handlet get_preparation_datat _namet fdopent intR t _tlst process_handleR_ R^ ( R R8 t rfdt wfdt rhandlet cmdt hpt htR3 t tidt prep_datat to_child( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyR: ù s( -
|
|
c C s t t j d d d k S( NR ( R R R~ R ( ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyR s c C s t | t j j S( N( R R R~ R ( Rk ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt duplicate_for_child s c C s¯ | j d k r¨ | d k r' t j } n t d t | d d } t j t | j | } | t j k r¨ t j | j } | t
|
k r t j } n | | _ q¨ n | j S( Ni iè g à?( R0 R Rf t INFINITEt maxR} t WaitForSingleObjectRy t WAIT_OBJECT_0t GetExitCodeProcesst TERMINATERS RT ( R RL t msecsRO R9 ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyRQ " s c C s | j d d S( NRL i ( RQ ( R ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyRH 2 s c C se | j d k ra y t j t | j t Wqa t k
|
r] | j d d d k r^ q^ qa Xn d S( NRL g¹?( R0 R Rf t TerminateProcessR} Ry R t WindowsErrorRQ ( R ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyRV 5 s N( R R t __doc__t threadt _localR~ R: RY R R R RQ RH RV ( ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyR ó s ! c C sF t | d k r> | d d k r> t | d k s: t t St Sd S( sE
|
Return whether commandline indicates we are forking
|
i i s --multiprocessing-forki N( t lenRC R; RW ( t argv( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt
|
is_forkingA s "c C s' t t j r# t t j n d S( sM
|
Run code for process object if this in not the main process
|
N( R R, R t mainR ( ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt freeze_supportL s c C st t t j d t r' t d n t t d t rF t j d g Sd } t j } t g | d | d g Sd S( sR
|
Returns prefix of command line used for spawning a child process
|
t _inheritings÷
|
Attempt to start a new process before the current process
|
has finished its bootstrapping phase.
|
|
This probably means that you are on Windows and you have
|
forgotten to use the proper idiom in the main module:
|
|
if __name__ == '__main__':
|
freeze_support()
|
...
|
|
The "freeze_support()" line can be omitted if the program
|
is not going to be frozen to produce a Windows executable.Rb s --multiprocessing-forks0 from multiprocessing.forking import main; main()s -cN(
|
R R t current_processRW R R, t
|
executableR t _args_from_interpreter_flagsRc ( t progt opts( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyRu U s c C s³ t t j s t t t j d } t j | t j } t j | d } t
|
t j _ t | } t | t | } t t j _ | j | j } t | d S( s>
|
Run code specifed by data received over pipe
|
iÿÿÿÿt rbN( R R, R RC R} Rs t open_osfhandleR1 t O_RDONLYR| R; R R R R] t prepareRW R R6 R ( Rk t fdt from_parentt preparation_dataR t exitcode( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyR p s
|
|
c C s. d d l m } m } t d | d t j d t j d | d t j d t j j
|
} | d k rt | j | d <n t r*t r*t t j d
|
d d } | rÅ t j d d k rÅ t j d } n | d k r*t j j | rt j d k rt j j t j | } n t j j | | d <q*n | S( sU
|
Return info about parent needed by child to unpickle process object
|
i ( t _loggert _log_to_stderrt namet sys_patht sys_argvt log_to_stderrt orig_dirt authkeyt log_levelt __main__t __file__i t s -ct main_pathN( R´ s -c( R R© Rª t dictR, t pathR R t ORIGINAL_DIRR R° R t getEffectiveLevelt WINEXEt
|
WINSERVICER R4 R1 t isabsRv t normpath( R« R© Rª t dRµ ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyRz s( c C sV t j s( t d t | j n t | t j | j | j | j f f S( NsL By default %s objects can only be shared between processes
|
using inheritance( R R R R
|
R R t filenot readablet writable( t conn( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt reduce_connection¨ s c
|
C sÑ t j t j d d | k r6 | d t j _ n d | k rX | d t j _ n d | k r{ | d r{ t j n d | k r¡ t j
|
j | d n d | k r½ | d t _ n d | k rÙ | d t _ n d | k rù t j | d n d | k r| d t _ n d
|
| k rÍ| d
|
} t j j t j j | d } | d k rzt j j t j j | } n | d k rÍd d l } | d k r§d } nT t j j | j d ræt j j t j j | g } n t j j | g } | t j k st | | j | | \ } } } z | j d | | | } Wd | rc| j n X| t j d <d | _ xM | j j D]9 } y | j d k r®d | _ n Wqt k
|
rÂqXqWqÍn d S( sE
|
Try to get current process ready to unpickle process object
|
R² R« R° R® R± R¬ R t dirR¯ Rµ i R: t ipythoniÿÿÿÿNs __init__.pyt __parents_main__( t old_main_modulest appendR, R4 R R R« t _authkeyR R® t
|
get_loggert setLevelR· R R1 t chdirR¸ t splitextt basenamet dirnamet impR t
|
startswithRC t find_modulet load_moduleR R t __dict__t valuesR t Exception(
|
t dataRµ t main_nameRÐ t dirsR` t path_namet etct main_moduleR ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyR¤ º sX
|
" ! $ (F R1 R, RS R> t multiprocessingR R t __all__R t pickleR R R R R
|
t saveR" t listRÈ R} t __add__t functoolsR# t ImportErrorR) R$ t platformRI R7 R t dupR R t objectR R Rs Rf t _multiprocessingR* RZ R[ R\ R] R^ R R_ R R RW Rº R t lowert endswithR» t ExitProcesst CloseHandleR· Rv t exec_prefixRc Re R R Ru R Rz RÃ RÇ R¤ ( ( ( s_ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/forking.pyt <module># sn
|
G ! N "
|
