⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.155
Server IP:
57.129.66.90
Server:
Linux vps-7f548908 5.15.0-160-generic #170-Ubuntu SMP Wed Oct 1 10:06:56 UTC 2025 x86_64
Server Software:
LiteSpeed
PHP Version:
8.2.27
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
usr
/
lib
/
python3.10
/
multiprocessing
/
__pycache__
/
Edit File: util.cpython-310.pyc
o i6 @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ ddlm Z g dZ d Z dZ dZ dZd Zd Zd Zdad ad d Zdd Zdd Zdd Zdd Zd?ddZdd Zdd Ze Z d d Z d d Z e Z e! Z"d!d" Z#d#d$ Z$i Z%e! Z&G d%d& d&e'Z(d?d'd(Z)d)d* Z*d a+eee)e j,e j-fd+d,Z.e/e. G d-d. d.e'Z0G d/d0 d0ej1Z2ze 3d1Z4W n e5y d2Z4Y nw d3d4 Z6d5d6 Z7d7d8 Z8d9d: Z9d;d< Z:d=d> Z;dS )@ N) _args_from_interpreter_flags )process) sub_debugdebuginfo sub_warning get_logger log_to_stderr get_temp_dirregister_after_fork is_exitingFinalizeForkAwareThreadLockForkAwareLocalclose_all_fds_exceptSUBDEBUG SUBWARNING multiprocessingz+[%(levelname)s/%(processName)s] %(message)sFc G t rt jt| g|R d S d S N)_loggerlogr msgargs r +/usr/lib/python3.10/multiprocessing/util.pyr , r c G r r )r r DEBUGr r r r! r 0 r" r c G r r )r r INFOr r r r! r 4 r" r c G r r )r r r r r r r! r 8 r" r c C s ddl } | zAts<| tadt_ttdr#tt t t n tj t di f tj t di f W | tS W | tS W | tS | w )z0 Returns logger used by multiprocessing r N unregisterr )logging _acquireLockr getLogger LOGGER_NAME propagatehasattratexitr% _exit_functionregister _exithandlersremoveappend _releaseLock)r& r r r! r < s( r c C sJ ddl }t }|t}| }|| || | r!|| dat S )zB Turn on logging and add a handler which prints to stderr r NT) r& r FormatterDEFAULT_LOGGING_FORMAT StreamHandler setFormatter addHandlersetLevel_log_to_stderrr )levelr& logger formatterhandlerr r r! r W s r c C s t jdkrdS tt drdS dS )NlinuxTgetandroidapilevelF)sysplatformr+ r r r r! #_platform_supports_abstract_socketsl s rB c C sD | sdS t | tr| d dkS t | tr| d dkS td| d)NFr zaddress type of z unrecognized) isinstancebytesstr TypeError)addressr r r! is_abstract_socket_namespacet s rI c C s* | | t }|d urd |jd< d S d S )Ntempdir)r current_process_config)rmtreerJ rK r r r! _remove_temp_dir s rN c C sf t jd} | d u r1dd l}dd l}|jdd} td| td t |j | fdd | t jd< | S )NrJ r zpymp-)prefixzcreated temp directory %si)r exitpriority) r rK rL getshutiltempfilemkdtempr r rN rM )rJ rR rS r r r! r s r c C sf t t } | | D ]$\\}}}}z|| W q ty0 } z td| W Y d }~q d }~ww d S )Nz after forker raised exception %s)list_afterfork_registryitemssort Exceptionr )rW indexidentfuncobjer r r! _run_after_forkers s r_ c C s | t ttt| |f< d S r )rV next_afterfork_counterid)r] r\ r r r! r s r c @ sF e Zd ZdZdddZdeeejfddZ dd Z d d Z d d Z dS )r zA Class which supports object finalization using weakrefs r Nc C s |d urt |tstd|t||d ur t|| | _n|d u r'td|| _ || _ |p0i | _ |t t f| _t | _| t| j< d S )Nz3Exitpriority ({0!r}) must be None or int, not {1!s}z+Without object, exitpriority cannot be None)rD intrG formattypeweakrefref_weakref ValueError _callback_args_kwargsr` _finalizer_counter_keyosgetpid_pid_finalizer_registry)selfr] callbackr kwargsrP r r r! __init__ s zFinalize.__init__c C s z|| j = W n ty |d Y dS w | j| kr"|d d}n|d| j| j| j | j| ji | j}d | _ | _ | _ | _| _ |S )zQ Run the callback unless it has already been called or cancelled z finalizer no longer registeredz+finalizer ignored because different processNz/finalizer calling %s with args %s and kwargs %s)rn KeyErrorrq rj rk rl rh )rs wrrr r rp resr r r! __call__ s zFinalize.__call__c C sD zt | j= W n ty Y dS w d | _ | _ | _ | _| _dS )z3 Cancel finalization of the object N)rr rn rw rh rj rk rl rs r r r! cancel s zFinalize.cancelc C s | j tv S )zS Return whether this finalizer is still waiting to invoke callback )rn rr r{ r r r! still_active s zFinalize.still_activec C s z| }W n ttfy d }Y nw |d u r d| jj S d| jjt| jd| jf }| jr8|dt| j 7 }| j rD|dt| j 7 }| j d d urV|dt| j d 7 }|d S ) Nz<%s object, dead>z<%s object, callback=%s__name__z, args=z , kwargs=r z, exitpriority=>) rh AttributeErrorrG __class__r~ getattrrj rk rF rl rn )rs r] xr r r! __repr__ s$ zFinalize.__repr__)r NN) r~ __module__ __qualname____doc__rv rr r ro rp rz r| r} r r r r r! r s r c s t du rdS du rdd nfdd fddtt D }|jdd |D ]'}t |}|durOtd | z| W q( tyN d dl}| Y q(w q(du rZt dS dS ) z Run all finalizers whose exit priority is not None and at least minpriority Finalizers with highest priority are called first; finalizers with the same priority will be called in reverse order of creation. Nc S s | d d uS Nr r pr r r! <lambda> s z!_run_finalizers.<locals>.<lambda>c s | d d uo | d kS r r r ) minpriorityr r! r c s g | ]} |r|qS r r ).0key)fr r! <listcomp># r z#_run_finalizers.<locals>.<listcomp>T)reversez calling %sr ) rr rU rX rQ r rY traceback print_excclear)r keysr finalizerr r )r r r! _run_finalizers s* r c C s t pt du S )z6 Returns true if the process is shutting down N)_exitingr r r r! r 8 s r c C s t sBda | d |d |d | d ur9| D ]}|jr(| d|j |j q| D ] }| d|j | q,|d | d S d S )NTzprocess shutting downz2running all "atexit" finalizers with priority >= 0r z!calling terminate() for daemon %sz calling join() for process %sz)running the remaining "atexit" finalizers)r daemonname_popen terminatejoin)r r r active_childrenrK r r r r! r- @ s" r- c @ s, e Zd Zdd Zdd Zdd Zdd Zd S ) r c C s. t | _| jj| _| jj| _t| tj d S r ) threadingLock_lockacquirereleaser r _at_fork_reinitr{ r r r! rv q s z ForkAwareThreadLock.__init__c C s | j d S r )r r r{ r r r! r w s z#ForkAwareThreadLock._at_fork_reinitc C | j S r )r __enter__r{ r r r! r z s z ForkAwareThreadLock.__enter__c G s | j j| S r )r __exit__)rs r r r r! r } z ForkAwareThreadLock.__exit__N)r~ r r rv r r r r r r r! r p s r c @ s e Zd Zdd Zdd ZdS )r c C s t | dd d S )Nc S r r )__dict__r )r] r r r! r s z)ForkAwareLocal.__init__.<locals>.<lambda>)r r{ r r r! rv s zForkAwareLocal.__init__c C s t | dfS )Nr )re r{ r r r! __reduce__ r zForkAwareLocal.__reduce__N)r~ r r rv r r r r r! r s r SC_OPEN_MAX c C sb t | dtg } | | d tksJ dtt| d D ]}t| | d | |d q d S )Nz fd too larger )rU MAXFDrX rangelenro closerange)fdsir r r! r s r c C s t jd u rd S zt j W n ttfy Y nw z ttjtj} z t| dddt _W W d S t| ttfyD Y d S w )Nzutf-8F)encodingclosefd) r@ stdincloseOSErrorri ro opendevnullO_RDONLY)fdr r r! _close_stdin s" r c C sP zt j W n ttfy Y nw zt j W d S ttfy' Y d S w r )r@ stdoutflushr ri stderrr r r r! _flush_std_streams s r c C s dd l }tttt|}t \}}z(||t| gd|d d dddddd||ddd d d dd W t | t | S t | t | w )Nr Tr F) _posixsubprocesstuplesortedmaprc ro pipe fork_execfsencoder )pathr passfdsr errpipe_read errpipe_writer r r! spawnv_passfds s r c G s | D ]}t | qdS )z/Close each file descriptor given as an argumentN)ro r )r r r r r! close_fds s r c C sZ ddl m} t ddlm} |j ddlm} |j t | | dS )zKCleanup multiprocessing resources when multiprocessing tests completed.r )support) forkserver)resource_trackerN) testr r _cleanupr r _forkserver_stopr _resource_trackerr gc_collect reap_children)r r r r r r! _cleanup_tests s r r )<ro itertoolsr@ rf r, r subprocessr r __all__NOTSETr r# r$ r r) r4 r r9 r r r r r r rB rI abstract_sockets_supportedrN r WeakValueDictionaryrV countra r_ r rr rm objectr r r r r rK r- r. r localr sysconfr rY r r r r r r r r r r! <module> sr V, *
Simpan