Dashboard
PHP:
8.1.33
OS:
Linux
User:
lawtemple
/
/
usr
/
lib64
/
python2.7
/
multiprocessing
📤 Upload
📝 New File
📁 New Folder
Close
Editing: forking.pyo
� a Ofc @ 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 r�d 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/ /usr/lib64/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/ /usr/lib64/python2.7/multiprocessing/forking.pyt dispatcherA s ( t dispatch( t clsR R R ( ( R s/ /usr/lib64/python2.7/multiprocessing/forking.pyt register? s ( R t __module__R R t copyt classmethodR ( ( ( s/ /usr/lib64/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/ /usr/lib64/python2.7/multiprocessing/forking.pyt _reduce_methodF s c C s t | j | j f f S( N( R t __objclass__R ( R ( ( s/ /usr/lib64/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/ /usr/lib64/python2.7/multiprocessing/forking.pyt _reduce_partial\ s c C s t | | | � S( N( R# ( R% R& R' ( ( s/ /usr/lib64/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/ /usr/lib64/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 | � | _ q� n | j S( N( R0 R t TrueR1 t waitpidR3 t errort errnot EINTRt WIFSIGNALEDt WTERMSIGt WEXITSTATUS( R t flagR3 t stst e( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyt poll� s c C s� | d k r | j d � St j � | } d } xc | j � } | d k rN Pn | t j � } | d k rn Pn t | d | d � } t j | � q2 W| S( Ni g����Mb@?i g�������?( R RF t timet mint sleep( R t timeoutt deadlinet delayt rest remaining( ( s/ /usr/lib64/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( NRJ g�������?( R0 R R1 t killR3 t signalt SIGTERMt OSErrorRO ( R RE ( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyt terminate� s c C s t S( N( t False( ( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyR � s N( R R R: R1 t WNOHANGRF R RO RT t staticmethodR ( ( ( s/ /usr/lib64/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/ /usr/lib64/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/ /usr/lib64/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/ /usr/lib64/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( NRk t c s s | ] } d | Vq d S( s "%s"N( ( t .0t x( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pys <genexpr> s i i t wb( R1 t pipeR t msvcrtt get_osfhandleR; R t get_command_linet joinRd t CreateProcessRa 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/ /usr/lib64/python2.7/multiprocessing/forking.pyR: � s( - c C s t t j d d � d k S( NR} ( R R R| R ( ( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyR s c C s t | t j j � S( N( R R R| R} ( Ri ( ( s/ /usr/lib64/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 Rd t INFINITEt maxR{ t WaitForSingleObjectRw t WAIT_OBJECT_0t GetExitCodeProcesst TERMINATERQ RR ( R RJ t msecsRM R9 ( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyRO " s c C s | j d d � S( NRJ i ( RO ( R ( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyRF 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( NRJ g�������?( R0 R Rd t TerminateProcessR{ Rw R� t WindowsErrorRO ( R ( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyRT 5 s N( R R t __doc__t threadt _localR| R: RW R R� R RO RF RT ( ( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyR � s ! c C s. t | � d k r& | d d k r& t St Sd S( sE Return whether commandline indicates we are forking i i s --multiprocessing-forkN( t lenR; RU ( t argv( ( s/ /usr/lib64/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/ /usr/lib64/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.R` s --multiprocessing-forks0 from multiprocessing.forking import main; main()s -cN( R R t current_processRU R R, t executableR t _args_from_interpreter_flagsRa ( t progt opts( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyRs U s c C s� 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 specified by data received over pipe i����t rbN( R{ R, R� Rq t open_osfhandleR1 t O_RDONLYRz R; R R� R� R[ t prepareRU R R6 R ( Ri t fdt from_parentt preparation_dataR t exitcode( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyR� p s c C sL 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 rHt rH| d d j � j d � rHt t j d d d � } | r� t j d d k r� t j d } n | d k rHt j j | � r,t j d k r,t j j t j | � } n t j j | � | d <qHn | 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_leveli s pythonservice.exet __main__t __file__t s -ct main_pathN( R� s -c( R R� R� t dictR, t pathR� R t ORIGINAL_DIRR� R� R t getEffectiveLevelt WINEXEt WINSERVICEt lowert endswithR R4 R1 t isabsRt t normpath( R� R� R� t dR� ( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyRx � 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/ /usr/lib64/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�t j d } | | _ q�| 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 } | j | | � \ } } } z | j d | | | � } Wd | rm| j � n X| t j d <d | _ xM | j j � D]9 } y | j d k r�d | _ n Wq�t k r�q�Xq�Wq�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 dirnameR� t impR t startswitht find_modulet load_moduleR R t __dict__t valuesR t Exception( t dataR� t main_namet main_moduleR� t dirsR^ t path_namet etcR ( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyR� � s\ " ! $ (F R1 R, RQ 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 platformRG R7 R t dupR R t objectR R� Rq Rd t _multiprocessingR* RX RY RZ R[ R\ R R] R� R RU R� R� R� R� R� t ExitProcesst CloseHandleR� Rt t exec_prefixRa Rc R� R� Rs R� Rx R� R� R� ( ( ( s/ /usr/lib64/python2.7/multiprocessing/forking.pyt <module># sn G ! N #
Save
Cancel