Ñò
§ÚêLc @ s d d k Z d d k Z d d k Z d d k l Z l Z d d d d d d g Z d „ Z d d
k l Z d e f d „ ƒ YZ
d „ Z e
i e
e
i ƒ e ƒ d
„ Z e
i e
e i ƒ e ƒ e
i e
e i ƒ e ƒ y d d k l Z Wn e j
o n$ Xd „ Z d „ Z e
i e e ƒ e i d j oA d d k Z e i Z e i Z e i Z d e f d „ ƒ YZ! n{d d k" Z" d d k# Z# d d k$ Z$ d d k Z d d k% l& Z& l' Z' l( Z( d d k l) Z) d d k l* Z* l+ Z+ d d „ Z- d Z. e i d j o e/ e d e0 ƒ Z1 e& i2 Z e& i3 Z e i4 i5 ƒ i6 d ƒ o e i7 i8 e i9 d ƒ a: n
e i4 a: d „ Z; d e0 d „ Z d e f d „ ƒ YZ! d „ Z< d „ Z= d! „ Z> d" „ Z? d# „ Z@ d$ „ ZA e
i e' eA ƒ e
i e( eA ƒ g ZB d% „ ZC d S(& iÿÿÿÿN( t utilt processt Popent assert_spawningt exitt duplicatet closet ForkingPicklerc C s. t i ƒ p t d t | ƒ i ƒ ‚ 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/ /usr/lib64/python2.6/multiprocessing/forking.pyR s
( t Picklerc B s& e Z e i i ƒ Z e d „ ƒ Z RS( c s ‡ f d † } | | i | â s i i t wb( R1 t pipeR t msvcrtt
get_osfhandlet TrueR t get_command_linet joinRa t
CreateProcessR^ R t CloseR3 R0 t _handlet get_preparation_datat _namet fdopent intR t _tlst process_handleRZ RY ( R R8 t rfdt wfdt rhandlet cmdt hpt htR3 t tidt prep_datat to_child( ( s/ /usr/lib64/python2.6/multiprocessing/forking.pyR: Ø s(
-
c C s t t i d d ƒ d j S( NR{ ( R R Rz R ( ( ( s/ /usr/lib64/python2.6/multiprocessing/forking.pyR ù s c C s t | t i i ƒ S( N( R R Rz R{ ( Rf ( ( s/ /usr/lib64/python2.6/multiprocessing/forking.pyt duplicate_for_childý s c C s· | i d j o | d j o
t i } n t d t | d d ƒ ƒ } t i t | i ƒ | ƒ } | t i j o: t i | i ƒ } | t
j o t i } n | | _ q° n | i S( Ni iè g à?(
R0 R Ra t INFINITEt maxRy t WaitForSingleObjectRu t
WAIT_OBJECT_0t GetExitCodeProcesst TERMINATERM RN ( R RF t msecsRI R9 ( ( s/ /usr/lib64/python2.6/multiprocessing/forking.pyRK s
c C s | i d d ƒ S( NRF i ( RK ( R ( ( s/ /usr/lib64/python2.6/multiprocessing/forking.pyRB s c C sk | i d j oW y t i t | i ƒ t ƒ Wqg t j
o' | i d d ƒ d j o ‚ qc qg Xn d S( NRF gš™™™™™¹?( R0 R Ra t TerminateProcessRy Ru R‹ t WindowsErrorRK ( R ( ( s/ /usr/lib64/python2.6/multiprocessing/forking.pyRQ s N( R R t __doc__t threadt _localRz R: RT R R… R RK RB RQ ( ( ( s/ /usr/lib64/python2.6/multiprocessing/forking.pyR Ò s ! c C s1 t | ƒ d j o | d d j o t St Sd S( sE
Return whether commandline indicates we are forking
i i s --multiprocessing-forkN( t lenRp RR ( t argv( ( s/ /usr/lib64/python2.6/multiprocessing/forking.pyt
is_forking s $c C s) t t i ƒ o t ƒ t i ƒ n d S( sM
Run code for process object if this in not the main process
N( R” R, R“ t mainR ( ( ( s/ /usr/lib64/python2.6/multiprocessing/forking.pyt freeze_support+ s c C sq t i ƒ i d j o t t i ƒ o t d ƒ ‚ n t t d t ƒ o t i d g Sd } t
d | d g Sd S( sR
Returns prefix of command line used for spawning a child process
s÷
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.R] s --multiprocessing-forks0 from multiprocessing.forking import main; main()s -cN( ( R t current_processt _identityR” R, R“ R R RR t
executableR^ ( t prog( ( s/ /usr/lib64/python2.6/multiprocessing/forking.pyRq 4 s &
c C sž t t i d ƒ } t i | t i ƒ } t i | d ƒ } t t i
ƒ _ t | ƒ } t
| ƒ t | ƒ } t t i
ƒ _ | i ƒ | i ƒ } t | ƒ d S( s>
Run code specifed by data received over pipe
iÿÿÿÿt rbN( Ry R, R“ Rn t open_osfhandleR1 t O_RDONLYRx Rp R R— t _inheritingRX t prepareRR R R6 R ( Rf t fdt from_parentt preparation_dataR t exitcode( ( s/ /usr/lib64/python2.6/multiprocessing/forking.pyR• N s
c C s2 d d k l } l } t d | d t i d t i d | d t i d t i ƒ i
ƒ } | d j o | i ƒ | d sj
B "
N "