⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.30
Server IP:
45.79.8.107
Server:
Linux localhost 5.15.0-140-generic #150-Ubuntu SMP Sat Apr 12 06:00:09 UTC 2025 x86_64
Server Software:
nginx/1.18.0
PHP Version:
8.1.2-1ubuntu2.21
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.10
/
multiprocessing
/
__pycache__
/
View File Name :
process.cpython-310.pyc
o }ò5h9/ ã @ s2 g d ¢Z ddlZddlZddlZddlZddlZddlmZ z ej e ¡ ¡Z W n e y3 dZ Y nw dd„ Z dd„ Zdd „ Zd d „ ZG d d „ d eƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZdaeƒ ae d¡aeƒ a [i Z e ej ¡ ƒD ]\Z!Z"e!dd… dkr“de!vr“de!› e e" < q{eƒ Z#dS ))Ú BaseProcessÚcurrent_processÚactive_childrenÚparent_processé N)ÚWeakSetc C ó t S )z@ Return process object representing the current process )Ú_current_process© r r ú./usr/lib/python3.10/multiprocessing/process.pyr % ó r c C s t ƒ ttƒS )zN Return list of process objects corresponding to live child processes )Ú_cleanupÚlistÚ _childrenr r r r r + s r c C r )z? Return process object representing the parent process )Ú_parent_processr r r r r 3 r r c C s* t tƒD ]} | j ¡ d urt | ¡ qd S ©N)r r Ú_popenÚpollÚdiscard)Úpr r r r = s €þr c @ s e Zd ZdZdd„ Zddddi fddœdd„Zd d „ Zd d „ Zd d„ Zdd„ Z dd„ Z d.dd„Z dd„ Z dd„ Z edd„ ƒZejdd„ ƒZed d „ ƒZejd d „ ƒZed d „ ƒZejd!d „ ƒZed"d#„ ƒZed$d%„ ƒZeZed&d'„ ƒZd(d)„ Zd.d*d+„Zed,d-„ ƒZdS )/r z€ Process objects represent activity that is run in a separate process The class is analogous to `threading.Thread` c C s t ‚r )ÚNotImplementedError©Úselfr r r Ú_PopenM ó zBaseProcess._PopenNr )Údaemonc C s° |d u sJ dƒ‚t tƒ}tj|f | _tj ¡ | _t ¡ | _tj | _ d | _ d| _ || _ t|ƒ| _t|ƒ| _|pHt| ƒjd d dd„ | jD ƒ¡ | _|d urQ|| _t | ¡ d S )Nz#group argument must be None for nowFú-ú:c s s | ]}t |ƒV qd S r )Ústr)Ú.0Úir r r Ú <genexpr>^ s € z'BaseProcess.__init__.<locals>.<genexpr>)ÚnextÚ_process_counterr Ú _identityÚ_configÚcopyÚosÚgetpidÚ _parent_pidÚnameÚ _parent_namer Ú_closedÚ_targetÚtupleÚ_argsÚdictÚ_kwargsÚtypeÚ__name__ÚjoinÚ_namer Ú _danglingÚadd)r ÚgroupÚtargetr) ÚargsÚkwargsr Úcountr r r Ú__init__P s" ÿzBaseProcess.__init__c C s | j rtdƒ‚d S )Nzprocess object is closed)r+ Ú ValueErrorr r r r Ú _check_closedc s ÿzBaseProcess._check_closedc C s" | j r| j | ji | j¤Ž dS dS )zQ Method to be run in sub-process; can be overridden in sub-class N)r, r. r0 r r r r Úrung s ÿzBaseProcess.runc C sz | ¡ | jdu s J dƒ‚| jt ¡ ksJ dƒ‚tj d¡r"J dƒ‚tƒ | | ¡| _| jj | _ | ` | ` | `t | ¡ dS )z% Start child process Nz cannot start a process twicez:can only start a process object created by current processr z3daemonic processes are not allowed to have children)r> r r( r& r' r r$ Úgetr r ÚsentinelÚ _sentinelr, r. r0 r r6 r r r r Ústartn s ÿÿ zBaseProcess.startc C ó | ¡ | j ¡ dS )zT Terminate process; sends SIGTERM signal or uses TerminateProcess() N)r> r Ú terminater r r r rE € ó zBaseProcess.terminatec C rD )zT Terminate process; sends SIGKILL signal or uses TerminateProcess() N)r> r Úkillr r r r rG ‡ rF zBaseProcess.killc C sV | ¡ | jt ¡ ksJ dƒ‚| jdusJ dƒ‚| j |¡}|dur)t | ¡ dS dS )z5 Wait until child process terminates z can only join a child processNz can only join a started process)r> r( r& r' r Úwaitr r )r ÚtimeoutÚresr r r r3 Ž s ÿzBaseProcess.joinc C s\ | ¡ | tu r dS | jt ¡ ksJ dƒ‚| jdu r dS | j ¡ }|du r'dS t | ¡ dS )z1 Return whether process is alive Tz can only test a child processNF) r> r r( r& r' r r r r )r Ú returncoder r r Úis_alive™ s zBaseProcess.is_alivec C sH | j dur | j ¡ du rtdƒ‚| j ¡ d| _ | `t | ¡ d| _dS )z Close the Process object. This method releases resources held by the Process object. It is an error to call this method if the child process is still running. Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)r r r= ÚcloserB r r r+ r r r r rM ¬ s zBaseProcess.closec C ó | j S r )r4 r r r r r) ½ ó zBaseProcess.namec C s t |tƒs J dƒ‚|| _d S )Nzname must be a string)Ú isinstancer r4 )r r) r r r r) Á s c C s | j dd¡S )z4 Return whether process is a daemon r F)r$ r@ r r r r r Æ s zBaseProcess.daemonc C s | j du s J dƒ‚|| jd< dS )z1 Set whether process is a daemon Nzprocess has already startedr )r r$ )r Údaemonicr r r r Í s c C s | j d S )NÚauthkey)r$ r r r r rR Õ s zBaseProcess.authkeyc C s t |ƒ| jd< dS )z2 Set authorization key of process rR N)ÚAuthenticationStringr$ )r rR r r r rR Ù s c C s" | ¡ | jdu r | jS | j ¡ S )zM Return exit code of process or `None` if it has yet to stop N)r> r r r r r r Úexitcodeà s zBaseProcess.exitcodec C s& | ¡ | tu r t ¡ S | jo| jjS )zU Return identifier (PID) of process or `None` if it has yet to start )r> r r& r' r Úpidr r r r Úidentê s zBaseProcess.identc C s* | ¡ z| jW S ty tdƒd‚w )z{ Return a file descriptor (Unix) or handle (Windows) suitable for waiting for process termination. zprocess not startedN)r> rB ÚAttributeErrorr= r r r r rA ÷ s ÿzBaseProcess.sentinelc C sè d }| t u r d}n&| jrd}n | jt ¡ krd}n| jd u r!d}n| j ¡ }|d ur-d}nd}t| ƒjd| j g}| jd urG| d| jj ¡ | d| j ¡ | |¡ |d uret ||¡}| d | ¡ | jrm| d ¡ d d |¡ S ) NÚstartedÚclosedÚunknownÚinitialÚstoppedzname=%rzpid=%sz parent=%sz exitcode=%sr z<%s>ú )r r+ r( r& r' r r r1 r2 r4 ÚappendrU Ú_exitcode_to_namer@ r r3 )r rT ÚstatusÚinfor r r Ú__repr__ s0 zBaseProcess.__repr__c C sÌ ddl m}m} zÍzO| jd ur| | j¡ t d¡atƒ a | ¡ t }| a t | j | j|ƒatjr6t ¡ ¡ z| ¡ W ~n~w | d¡ z | ¡ d}W | ¡ n| ¡ w W nY ty‰ } z%|jd u rhd}nt|jtƒrr|j}n t j t |jƒd ¡ d}W Y d }~n?d }~w d}dd l }t j d| j! ¡ | "¡ Y W t #¡ | d| ¡ | $¡ |S W t #¡ | d| ¡ | $¡ |S W t #¡ | d| ¡ | $¡ |S t #¡ | d| ¡ | $¡ w )Né )ÚutilÚcontextz child process calling self.run()r Ú z Process %s: z process exiting with exitcode %d)%Ú rd re Ú _start_methodÚ_force_start_methodÚ itertoolsr; r" Úsetr Ú _close_stdinr Ú_ParentProcessr* r( r Ú threadingÚ_HAVE_THREAD_NATIVE_IDÚ main_threadÚ_set_native_idÚ _after_forkra r? Ú_exit_functionÚ SystemExitÚcoderP ÚintÚsysÚstderrÚwriter Ú tracebackr) Ú print_excÚ _shutdownÚ_flush_std_streams)r Úparent_sentinelrd re Ú old_processrT Úerz r r r Ú _bootstrap" sh ÿ € í€üü zBaseProcess._bootstrapc C s" ddl m} | j ¡ | ¡ d S )Nrc ©rd )rg rd Ú_finalizer_registryÚclearÚ_run_after_forkersr‚ r r r rr R s zBaseProcess._after_forkr )r2 Ú __module__Ú __qualname__Ú__doc__r r< r> r? rC rE rG r3 rL rM Úpropertyr) Úsetterr rR rT rV rU rA rb r Ú staticmethodrr r r r r r G sJ ÿ 0r c @ s e Zd Zdd„ ZdS )rS c C s, ddl m} |ƒ d u rtdƒ‚tt| ƒffS )Nrc )Úget_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)re rŒ Ú TypeErrorrS Úbytes)r rŒ r r r Ú __reduce__^ s ÿz AuthenticationString.__reduce__N)r2 r† r‡ r r r r r rS ] s rS c @ s6 e Zd Zdd„ Zdd„ Zedd„ ƒZd dd „ZeZdS ) rm c C s4 d| _ || _|| _d | _d | _d| _|| _i | _d S )Nr F)r# r4 Ú_pidr( r r+ rB r$ )r r) rU rA r r r r< n s z_ParentProcess.__init__c C s ddl m} || jgdd S )Nr ©rH ©rI ©Úmultiprocessing.connectionrH rB )r rH r r r rL x s z_ParentProcess.is_alivec C rN r )r r r r r rV | rO z_ParentProcess.identNc C s ddl m} || jg|d dS )z6 Wait until parent process terminates r r‘ r’ Nr“ )r rI rH r r r r3 € s z_ParentProcess.joinr ) r2 r† r‡ r< rL r‰ rV r3 rU r r r r rm l s rm c @ s e Zd Zdd„ Zdd„ ZdS )Ú _MainProcessc C s8 d| _ d| _d | _d | _d| _tt d¡ƒddœ| _d S )Nr Ú MainProcessFé z/mp)rR Ú semprefix) r# r4 r( r r+ rS r& Úurandomr$ r r r r r< s ÿz_MainProcess.__init__c C s d S r r r r r r rM ¡ r z_MainProcess.closeN)r2 r† r‡ r< rM r r r r r• s r• rc é ÚSIGÚ_r )$Ú__all__r& rw Úsignalrj rn Ú _weakrefsetr ÚpathÚabspathÚgetcwdÚ ORIGINAL_DIRÚOSErrorr r r r Úobjectr rŽ rS rm r• r r r; r" rk r r_ r Ú__dict__Úitemsr) Úsignumr5 r r r r Ú<module> sB ÿ ! €