Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /opt/alt/python33/lib64/python3.3/multiprocessing/__pycache__/ |
�
� 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 | <d S( N( u _extra_reducers( u clsu typeu reduce( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu register+ s u ForkingPickler.registerN( u __name__u
__module__u __qualname__u _extra_reducersu __init__u classmethodu register( u
__locals__( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu ForkingPickler% s c C sE | j d k r( t | j | j j f f St | j | j j f f Sd S( N( u __self__u Noneu getattru __class__u __func__u __name__( u m( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu _reduce_method/ s u _reduce_methodc B s | Ee Z d Z d d � Z d S( u _Cc C s d S( N( ( u self( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu f5 s u _C.fN( u __name__u
__module__u __qualname__u f( u
__locals__( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu _C4 s u _Cc C s t | j | j f f S( N( u getattru __objclass__u __name__( u m( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu _reduce_method_descriptor: s u _reduce_method_descriptor( u partialc C s" t | j | j | j p i f f S( N( u _rebuild_partialu funcu argsu keywords( u p( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu _reduce_partialD s u _reduce_partialc C s t | | | � S( N( u partial( u funcu argsu keywords( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu _rebuild_partialF s u _rebuild_partialu win32c B s_ | Ee Z d Z d d � Z e j d d � Z d d d � Z d d � Z e
d d
� � Z d S( u Popenc C s� t j j � t j j � d | _ t j � \ } } | | _ t j � | _
| j
d k r� t j | � d t j k r� d d l
} | j � n | j � } t j | � n t j | � t j | t j | f � d S( Ni u random( u sysu stdoutu flushu stderru Noneu
returncodeu osu pipeu sentinelu forku pidu closeu modulesu randomu seedu
_bootstrapu _exitu utilu Finalize( u selfu process_obju ru wu randomu code( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu __init__Y s
u Popen.__init__c C s� | j d k r� xj y t j | j | � \ } } WnD t j k
rw } z! | j t j k ra w n d SWYd d } ~ Xq XPq | | j k r� t j | � r� t j | � | _ q� t j
| � s� t � t j | � | _ q� n | j S( N(
u
returncodeu Noneu osu waitpidu pidu erroru errnou EINTRu WIFSIGNALEDu WTERMSIGu WIFEXITEDu AssertionErroru WEXITSTATUS( u selfu flagu pidu stsu e( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu pollo s u
Popen.pollc C sp | j d k ri | d k rG d d l m } | | j g | � sG d Sn | j | d k rb t j n d � S| j S( Ni ( u waitg ( u
returncodeu Noneu multiprocessing.connectionu waitu sentinelu pollu osu WNOHANG( u selfu timeoutu wait( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu wait� s "u
Popen.waitc C sc | j d k r_ y t j | j t j � Wq_ t k
r[ | j d d � d k rW � n Yq_ Xn d S( Nu timeoutg�������?( u
returncodeu Noneu osu killu pidu signalu SIGTERMu OSErroru wait( u self( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu terminate� s
u Popen.terminatec C s d S( NF( u False( ( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu thread_is_spawning� s u Popen.thread_is_spawningN( u __name__u
__module__u __qualname__u __init__u osu WNOHANGu pollu Noneu waitu terminateu staticmethodu thread_is_spawning( u
__locals__( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu PopenW s
( u loadu HIGHEST_PROTOCOLc C s t | | � j | � d S( N( u ForkingPickleru dump( u obju fileu protocol( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu dump� s u dumpi u frozenu pythonservice.exeu
python.exec C s
| a d S( N( u _python_exe( u exe( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu set_executable� s u set_executablec C s@ | d k r t j � } n t j t j � | | d | t j � S( Ni ( u Noneu _winapiu GetCurrentProcessu DuplicateHandleu DUPLICATE_SAME_ACCESS( u handleu target_processu inheritable( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu duplicate� s
c B s} | Ee Z d Z d Z e j � Z d d � Z e d d � � Z e d d � � Z
d d d � Z d
d � Z
d d
� Z d S( u PopenuH
Start a subprocess to run the code of a process object
c C sm d j d d � t � D� � } t | j � } t j � \ } } t t j | � d d
�} t j
| � t | d d d
��� } zL t j
t | d | d d d d d d d � \ } } }
} t j | � Wd t
| � X|
| _ d | _ | | _ t | � | _ t j | t j | j f � t | � t j _ z$ t | | t � t | | t � Wd t j ` XWd QXd S( Nu c s s | ] } d | Vq d S( u "%s"N( ( u .0u x( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu <genexpr>� s u! Popen.__init__.<locals>.<genexpr>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 sF t | � d k r> | d d k r> t | � d k s: t � d Sd Sd S( uE
Return whether commandline indicates we are forking
i i u --multiprocessing-forki NTF( u lenu AssertionErroru 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 � s t � 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
is_forkingu sysu argvu AssertionErroru intu 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 <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( uU
Return info about parent needed by child to unpickle process object
i ( u _loggeru _log_to_stderru nameu sys_pathu sys_argvu
log_to_stderru orig_diru authkeyu log_levelu __main__u __file__i u u -cu main_pathN( u u -c( u utilu _loggeru _log_to_stderru dictu sysu pathu argvu processu ORIGINAL_DIRu current_processu authkeyu Noneu getEffectiveLevelu WINEXEu
WINSERVICEu getattru modulesu osu isabsu joinu normpath( u nameu _loggeru _log_to_stderru du main_path( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu get_preparation_datah s( u get_preparation_datac
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 } | t j k s;t | � � | j | | � \ } } } z | j d | | | � } Wd | r�| j � n X| t j d <d | _ xT t | j j � � D]: } y | j d k r�d | _ n Wq�t! k
r�Yq�Xq�Wq�n d S( uE
Try to get current process ready to unpickle process object
u __main__u nameu authkeyu
log_to_stderru log_levelu sys_pathu sys_argvu diru orig_diru main_pathi u __init__u ipythonNu __init__.pyu __parents_main__(" u old_main_modulesu appendu sysu modulesu processu current_processu nameu _authkeyu utilu
log_to_stderru
get_loggeru setLevelu pathu argvu osu chdiru ORIGINAL_DIRu splitextu basenameu dirnameu __file__u impu Noneu
startswithu AssertionErroru find_moduleu load_moduleu closeu __name__u listu __dict__u valuesu
__module__u Exception(
u datau main_pathu main_nameu main_moduleu impu dirsu fileu path_nameu etcu obj( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu prepare� s^
" !
$
u prepareF(? u osu sysu signalu errnou multiprocessingu utilu processu __all__u assert_spawningu pickleu Pickleru copyregu dispatch_tableu ForkingPickleru _reduce_methodu _Cu registeru typeu fu _reduce_method_descriptoru listu appendu intu __add__u functoolsu partialu ImportErroru _reduce_partialu _rebuild_partialu platformu dupu duplicateu closeu objectu Popenu _threadu msvcrtu _winapiu loadu HIGHEST_PROTOCOLu Noneu dumpu TERMINATEu getattru Falseu WINEXEu
executableu loweru endswithu
WINSERVICEu CloseHandleu pathu joinu exec_prefixu _python_exeu set_executableu
is_forkingu freeze_supportu get_command_lineu mainu get_preparation_datau old_main_modulesu prepare( ( ( u< /opt/alt/python33/lib64/python3.3/multiprocessing/forking.pyu <module>
s`
H !
R "