ž
¨ÿ f˜9 c
@ 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 g Z d d „ Z d d l m
Z
d d
l m Z Gd d „ d e
ƒ Z
d d
„ Z Gd d „ d ƒ Z e
j e e ƒ j ƒ e ƒ d d „ Z e
j e e j ƒ e ƒ e
j e e j ƒ e ƒ y d d l m Z Wn e k
r>Yn) Xd d „ Z d d „ Z e
j e e ƒ e j d k r¡e j Z e j Z Gd d „ d e! ƒ Z" n+d d l# Z# d d l$ Z$ d d l% Z% d d l m& Z& m' Z' d d d „ Z) d Z* e j d k oe+ e d d0 ƒ Z- e j. j/ ƒ j0 d ƒ Z1 e% j2 Z e1 rSe j3 j4 e j5 d ƒ a6 n e j. a6 d d! „ Z7 d d0 d" d „ Z Gd# d „ d e! ƒ Z" d$ d% „ Z8 d& d' „ Z9 d( d) „ Z: d* d+ „ Z; d, d- „ Z< g Z= d. d/ „ Z> d S(1 i N( u utilu processu Popenu assert_spawningu duplicateu closeu ForkingPicklerc C s, t j ƒ s( t d t | ƒ j ƒ ‚ n d S( NuF %s objects should only be shared between processes through inheritance( u Popenu thread_is_spawningu RuntimeErroru typeu __name__( u self( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu assert_spawning s ( u Pickler( u dispatch_tablec B s8 | Ee Z d Z i Z d d „ Z e d d „ ƒ Z d S( u ForkingPicklerc G s6 t j | | Œ t j ƒ | _ | j j | j ƒ d S( N( u Pickleru __init__u dispatch_tableu copyu updateu _extra_reducers( u selfu args( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu __init__' s u ForkingPickler.__init__c C s | | j | Ø s u! Popen.__init__..u inheritableu wbu closefdu %si i T( u joinu get_command_lineu get_preparation_datau _nameu osu pipeu duplicateu msvcrtu
get_osfhandleu Trueu closeu openu _winapiu
CreateProcessu _python_exeu Noneu CloseHandleu pidu
returncodeu _handleu intu sentinelu utilu Finalizeu Popenu _tlsu process_handleu dumpu HIGHEST_PROTOCOL( u selfu process_obju cmdu prep_datau rfdu wfdu rhandleu to_childu hpu htu pidu tid( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu __init__× s,
' u Popen.__init__c C s t t j d d ƒ d k S( Nu process_handle( u getattru Popenu _tlsu None( ( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu thread_is_spawningü s u Popen.thread_is_spawningc C s t | t j j ƒ S( N( u duplicateu Popenu _tlsu process_handle( u handle( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu duplicate_for_child s u Popen.duplicate_for_childc 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 à?(
u
returncodeu Noneu _winapiu INFINITEu maxu intu WaitForSingleObjectu _handleu
WAIT_OBJECT_0u GetExitCodeProcessu TERMINATEu signalu SIGTERM( u selfu timeoutu msecsu resu code( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu wait s
u
Popen.waitc C s | j d d ƒ S( Nu timeouti ( u wait( u self( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu poll s u
Popen.pollc C sf | j d k rb y t j t | j ƒ t ƒ Wqb t k
r^ | j d d ƒ d k rZ ‚ n Yqb Xn d S( Nu timeoutg ð?( u
returncodeu Noneu _winapiu TerminateProcessu intu _handleu TERMINATEu OSErroru wait( u self( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu terminate s
u Popen.terminateN( u __name__u
__module__u __qualname__u __doc__u _threadu _localu _tlsu __init__u staticmethodu thread_is_spawningu duplicate_for_childu Noneu waitu pollu terminate( u
__locals__( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu PopenÑ s % c C s. t | ƒ d k r& | d d k r& d Sd Sd S( uE
Return whether commandline indicates we are forking
i i u --multiprocessing-forkNTF( u lenu Trueu False( u argv( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu
is_forking# s "u
is_forkingc C s' t t j ƒ r# t ƒ t j ƒ n d S( uM
Run code for process object if this in not the main process
N( u
is_forkingu sysu argvu mainu exit( ( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu freeze_support. s u freeze_supportc C st t t j ƒ d d ƒ r' t d ƒ ‚ n t t d d ƒ rF t j d g Sd } t j ƒ } t g | d | d g Sd S( uR
Returns prefix of command line used for spawning a child process
u _inheritingu÷
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.u frozenu --multiprocessing-forku0 from multiprocessing.forking import main; main()u -cNF(
u getattru processu current_processu Falseu RuntimeErroru sysu
executableu utilu _args_from_interpreter_flagsu _python_exe( u progu opts( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu get_command_line7 s
u get_command_linec C s¡ t t j d ƒ } t j | t j ƒ } t j | d ƒ } d t j
ƒ _ t | ƒ } t
| ƒ t | ƒ } d t j
ƒ _ | j ƒ | j ƒ } t j | ƒ d S( u?
Run code specified by data received over pipe
i u rbNiÿÿÿÿTF( u intu sysu argvu msvcrtu open_osfhandleu osu O_RDONLYu fdopenu Trueu processu current_processu _inheritingu loadu prepareu Falseu closeu
_bootstrapu exit( u handleu fdu from_parentu preparation_datau selfu exitcode( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu mainR s
u mainc
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
s`
H !
R "