⚝
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 :
forkserver.cpython-310.pyc
o }ò5hn/ ã @ sú d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m Z ddl m Z ddl m Z ddl mZ ddl mZ ddl mZ g d ¢Zd Ze d ¡ZG d d „ d eƒZddd„Zdd„ Zdd„ Zdd„ Zeƒ Zej Z ej Z ej Z ej Z dS )é Né )Ú connection)Úprocess)Ú reduction)Úresource_tracker)Úspawn)Úutil)Úensure_runningÚget_inherited_fdsÚconnect_to_new_processÚset_forkserver_preloadé Úqc @ sD e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d „ Zd d „ Zd d„ Z dS )Ú ForkServerc C s. d | _ d | _d | _d | _t ¡ | _dg| _d S )NÚ__main__)Ú_forkserver_addressÚ_forkserver_alive_fdÚ_forkserver_pidÚ_inherited_fdsÚ threadingÚLockÚ_lockÚ_preload_modules©Úself© r ú1/usr/lib/python3.10/multiprocessing/forkserver.pyÚ__init__" s zForkServer.__init__c C s4 | j | ¡ W d ƒ d S 1 sw Y d S ©N)r Ú_stop_unlockedr r r r Ú_stop* s "ÿzForkServer._stopc C sV | j d u rd S t | j¡ d | _t | j d¡ d | _ t | j¡s&t | j¡ d | _d S )Nr ) r ÚosÚcloser Úwaitpidr Ú is_abstract_socket_namespacer Úunlinkr r r r r / s zForkServer._stop_unlockedc C s& t dd„ | jD ƒƒstdƒ‚|| _dS )z>Set list of module names to try to load in forkserver process.c s s | ] }t |ƒtu V qd S r )ÚtypeÚstr)Ú.0Úmodr r r Ú <genexpr>@ s € z4ForkServer.set_forkserver_preload.<locals>.<genexpr>z&module_names must be a list of stringsN)Úallr Ú TypeError)r Ú modules_namesr r r r > s z!ForkServer.set_forkserver_preloadc C s | j S )z”Return list of fds inherited from parent process. This returns None if the current process was not started by fork server. )r r r r r r D s z ForkServer.get_inherited_fdsc C sð | ¡ t|ƒd tkrtdƒ‚t tj¡X}| | j¡ t ¡ \}}t ¡ \}}||| j t ¡ g}||7 }z,z t ||¡ ||fW W t |¡ t |¡ W d ƒ S t |¡ t |¡ ‚ t |¡ t |¡ w 1 sqw Y dS )a; Request forkserver to create a child process. Returns a pair of fds (status_r, data_w). The calling process can read the child process's pid and (eventually) its returncode from status_r. The calling process should write to data_w the pickled preparation and process data. é z too many fdsN)r ÚlenÚMAXFDS_TO_SENDÚ ValueErrorÚsocketÚAF_UNIXÚconnectr r! Úpiper r Úgetfdr Úsendfdsr" )r ÚfdsÚclientÚparent_rÚchild_wÚchild_rÚparent_wÚallfdsr r r r L s0 ÿ ð ðz!ForkServer.connect_to_new_processc sÐ | j Û t ¡ | jdur1t | jtj¡\}}|s" W d ƒ dS t | j¡ d| _ d| _d| _d}| j rKddh‰ t d¡}‡ fdd„| ¡ D ƒ}ni }t tj¡s}t d¡}| |¡ t |¡sit |d ¡ | ¡ t ¡ \}}z<z+| ¡ |g} || ¡ || j |f; }t ¡ } | gt ¡ } | d |g7 } t | | | ¡}W n t |¡ ‚ W t |¡ nt |¡ w || _ || _|| _W d ƒ n1 sÉw Y W d ƒ dS W d ƒ dS 1 sáw Y dS ) zíMake sure that a fork server is running. This can be called from any process. Note that usually a child process will just reuse the forkserver started by its parent, so ensure_running() will do nothing. NzCfrom multiprocessing.forkserver import main; main(%d, %d, %r, **%r)Ú main_pathÚsys_pathÚignorec s i | ] \}}|ˆ v r||“qS r r )r( ÚxÚy©Ú desired_keysr r Ú <dictcomp>„ s z-ForkServer.ensure_running.<locals>.<dictcomp>r3 i€ z-c) r r r r r! r# ÚWNOHANGr" r r r r Úget_preparation_dataÚitemsr2 r3 r Úarbitrary_addressÚbindr r$ ÚchmodÚlistenr5 ÚfilenoÚget_executableÚ _args_from_interpreter_flagsÚspawnv_passfds) r ÚpidÚstatusÚcmdÚdataÚlistenerÚaddressÚalive_rÚalive_wÚ fds_to_passÚexeÚargsr rD r r i sZ ù ÿ ý çè"èzForkServer.ensure_runningN) Ú__name__Ú __module__Ú __qualname__r r r r r r r r r r r r s r c C sè |r4d|v r |dur dt ¡ _z t |¡ W t ¡ `nt ¡ `w |D ]}zt|ƒ W q" ty3 Y q"w t ¡ t ¡ \}}t |d¡ t |d¡ dd„ }t j |t jt ji} dd„ | ¡ D ƒ} t |¡ i } tjtj| d y} t ¡ b} | ¡ t_| | tj¡ | |tj¡ | |tj¡ z( d d „ | ¡ D ƒ}|r¡nq•||v r´t |d ¡d ks²J dƒ‚t ‚||v r t |d¡ z t dt j ¡\}}W n t yÔ Y n5w |dkrÚn/| !|d¡}|durt "|¡}zt#||ƒ W n t$yú Y nw t %|¡ nt& 'd| ¡ qÀ| |v rº| (¡ d }t) *|t+d ¡}t,|ƒt+kr-t-d .t,|ƒ¡ƒ‚|^}}}| %¡ t /¡ }|dkr„d }z<z | %¡ | %¡ ||||g}| 0| 1¡ ¡ t2|||| ƒ}W n t3yv t4j5t4 6¡ Ž t4j7 8¡ Y nw W t 9|¡ n,t 9|¡ w zt#||ƒ W n t$y• Y nw || |< t %|¡ |D ]}t %|¡ q¡W d ƒ n 1 sµw Y W n t:yÖ } z|j;t;j<krÌ‚ W Y d}~nd}~ww q’1 sÜw Y W d ƒ dS 1 síw Y dS )zRun forkserver.r NTFc W s d S r r )Ú_unusedr r r Úsigchld_handler¼ s z main.<locals>.sigchld_handlerc S s i | ] \}}|t ||¡“qS r )Úsignal)r( ÚsigÚvalr r r rF Æ s ÿzmain.<locals>.<dictcomp>)rN c S s g | ]\}}|j ‘qS r )Úfileobj)r( ÚkeyÚeventsr r r Ú <listcomp>Ú s zmain.<locals>.<listcomp>r ó z Not at EOF?i éÿÿÿÿr z.forkserver: waitpid returned unexpected pid %dz Too many ({0:n}) fds to send)=r Úcurrent_processÚ _inheritingr Úimport_main_pathÚ __import__Ú ImportErrorr Ú _close_stdinr! r5 Ú set_blockingrb ÚSIGCHLDÚSIGINTÚSIG_IGNrI Ú set_wakeup_fdr2 r3 Ú selectorsÚDefaultSelectorÚ getsocknameÚ _forkserverr ÚregisterÚ EVENT_READÚselectÚreadÚ SystemExitr# rG ÚChildProcessErrorÚpopÚwaitstatus_to_exitcodeÚ write_signedÚBrokenPipeErrorr" ÚwarningsÚwarnÚacceptr Úrecvfdsr0 r/ Ú RuntimeErrorÚformatÚforkÚextendÚvaluesÚ _serve_oneÚ ExceptionÚsysÚ excepthookÚexc_infoÚstderrÚflushÚ_exitÚOSErrorÚerrnoÚ ECONNABORTED)Ú listener_fdrX Úpreloadr? r@ ÚmodnameÚsig_rÚsig_wra ÚhandlersÚ old_handlersÚ pid_to_fdrV ÚselectorÚrfdsrR Ústsr; Ú returncodeÚsr8 r< ÚcodeÚ unused_fdsÚfdÚer r r Úmain§ sæ ÿ üÿ ÿ ý ÿ þ ÿë ÿÿ þþ€þ € Ü€& ÿ€ÿ±8ør© c C sh t d¡ | ¡ D ] \}}t ||¡ q |D ]}t |¡ q|^t_tj_ t_ t | ¡}t | |¡}|S )Nrj )rb ru rI r! r" ry r r Ú_resource_trackerÚ_fdr Údupr Ú_main) r< r8 r¦ r rc rd r§ Úparent_sentinelr¥ r r r r + s þ r c C sX d}t j}t|ƒ|k r%t | |t|ƒ ¡}|stdƒ‚||7 }t|ƒ|k s t |¡d S )Nri zunexpected EOFr )Ú SIGNED_STRUCTÚsizer/ r! r} ÚEOFErrorÚunpack)r§ rU Úlengthr¤ r r r Ú read_signedB s ür´ c C sB t |¡}|r t | |¡}|dkrtdƒ‚||d … }|sd S d S )Nr zshould not get here)r¯ Úpackr! Úwriterˆ )r§ ÚnÚmsgÚnbytesr r r r‚ L s ür‚ )NN) r– r! rv rb r2 Ústructr r r„ Ú r r Úcontextr r r r Ú__all__r0 ÚStructr¯ Úobjectr r© r r´ r‚ ry r r r r r r r r Ú<module> s<