⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.12
/
multiprocessing
/
__pycache__
/
View File Name :
reduction.cpython-312.pyc
CRh(% f d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m Z g dZ ej dk( xs) e ed xr e ed xr e ej d Z G d d ej Zej" Zd)d Zej dk( r'e g d z Z d dlZd*dddZd Zd Zd Z G d de Zn)e g dz Z d dlZej dk( Zd Z d Z d Zd Zd Z d Z G d d Z e e! e jD e d Z# e e!e$jJ e# e e!e&jN e# d Z(d! Z) eejT e( ej dk( rd" Z+d# Z, eej e+ nd$ Z+d% Z, eej e+ G d& d'e( Z-y)+ )ABCMetaN )context) send_handle recv_handleForkingPicklerregisterdumpwin32CMSG_LEN SCM_RIGHTSsendmsgc x e Zd ZdZi Zej Z fdZe d Z e dd Z e j Z xZS )r z)Pickler subclass used by multiprocessing.c t | | | j j | _ | j j | j y N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducers)selfargs __class__s 0/usr/lib/python3.12/multiprocessing/reduction.pyr zForkingPickler.__init__& sA $ " : : ? ? A ""4#7#78 c " || j |< y)z&Register a reduce function for a type.N)r )clstypereduces r r zForkingPickler.register+ s %+D!r c z t j } | || j | |j S r )ioBytesIOr getbuffer)r objprotocolbufs r dumpszForkingPickler.dumps0 s. jjl C $}} r r )__name__ __module__ __qualname____doc__r copyregr r r classmethodr r) pickleloads __classcell__)r s @r r r ! sO 3O % 4 49 + + LLEr r c : t || j | y)z3Replacement for pickle.dump() using ForkingPickler.N)r r )r& filer' s r r r : s 4"'',r ) DupHandle duplicate steal_handle)source_processc t j }||}||}t j || |d|t j S )z<Duplicate a handle. (target_process is a handle not a pid!)r )_winapiGetCurrentProcessDuplicateHandleDUPLICATE_SAME_ACCESS)handletarget_process inheritabler8 current_processs r r6 r6 G sO "335 ! ,N ! ,N&& FN {G 9 9; ;r c B t j t j d| } t j ||t j ddt j t j z t j | S # t j | w xY w)z5Steal a handle from process identified by source_pid.Fr )r: OpenProcessPROCESS_DUP_HANDLEr< r; r= DUPLICATE_CLOSE_SOURCE CloseHandle) source_pidr> source_process_handles r r7 r7 S s~ ' 3 3 & &z!; 7**%v))+Q--0N0NNP 5 6G 5 6s A B B c \ t |t j | }| j | yz&Send a handle over a local connection.N)r5 r: r= send)connr> destination_piddhs r r r _ s! vw < <o N " r c > | j j S ))Receive a handle over a local connection.)recvdetach)rL s r r r d s yy{!!##r c e Zd ZdZddZd Zy)r5 z Picklable wrapper for a handle.Nc X |t j }t j t j d| } t j t j |||dd | _ t j | || _ || _ y # t j | w xY w)NFr ) osgetpidr: rC rD r< r; _handlerF _access_pid)r r> accesspidprocs r r zDupHandle.__init__j s { iik&&w'A'A5#ND * & 6 6--/D&% 4 ##D)!DLDI ##D)s 1B B)c | j t j k( r | j S t j t j d| j } t j || j t j | j dt j t j | S # t j | w xY w)z1Get the handle. This should only be called once.F) rY rU rV rW r: rC rD r< r; rX rE rF )r r\ s r rR zDupHandle.detachy s yyBIIK'||#&&w'A'A5'+yy2D * ..$,,(A(A(CLL%)G)GI ##D)##D)s A C Cr )r* r+ r, r- r rR r r r5 r5 h s - *r r5 )DupFdsendfdsrecvfdsdarwinc t j d| }t t | dz g }| j |gt j t j |fg t r | j d dk7 r t d yy)z,Send an array of fds over an AF_UNIX socket.i r Az%did not receive acknowledgement of fdN) arraybyteslenr socket SOL_SOCKETr ACKNOWLEDGErQ RuntimeError)sockfdsmsgs r r` r` sr kk#s#SX^$% cUf / /1B1BC H IJ 499Q<4/ FG G 0;r c t j d }|j |z }| j dt j | \ }}}}|s|st t r| j d t | dk7 rt dt | z |d \ }} } |t j k( r| t j k( rxt | |j z dk7 rt |j | t | dz |d k7 r't dj t | |d t! | S t d # t t" f$ r Y t d w xY w) z/Receive an array of fds over an AF_UNIX socket.rd r rf z received %d items of ancdatar re z Len is {0:n} but msg[0] is {1!r}zInvalid data received)rg itemsizerecvmsgrj CMSG_SPACEEOFErrorrl rK ri rm rk r ValueError frombytesAssertionErrorformatlist IndexError) rn sizea bytes_sizerp ancdataflagsaddr cmsg_level cmsg_type cmsg_datas r ra ra sT KK ZZ$& $(LLF4E4Ej4Q$R!WeT7N $7|q "#A#&w<$0 1 1/6qz ,J 9f / //V . ..y>AJJ.!3$$ I&q6C<3q6)(:AA FCF,- - Aw 233 J' 233 s C"E E$#E$c t j | j t j t j 5 }t ||g ddd y# 1 sw Y yxY wrJ )rj fromfdfilenoAF_UNIX SOCK_STREAMr` )rL r> rM ss r r r s> ]]4;;=&..&:L:L MQR Ax N M Ms AA"c t j | j t j t j 5 }t |d d cddd S # 1 sw Y yxY w)rP r r N)rj r r r r ra )rL r s r r r s@ ]]4;;=&..&:L:L MQR1a=# N M Ms AA$c t j }| |j |j | S t rddlm} |j | S t d )zReturn a wrapper for an fd.r )resource_sharerz&SCM_RIGHTS appears not to be available)r get_spawning_popenr_ duplicate_for_childHAVE_SEND_HANDLE r rv )fd popen_objr s r r_ r_ sS ..0 ??9#@#@#DE E )"((, , EF Fr c | j (t | j | j j ffS t | j | j j ffS r )__self__getattrr __func__r* ms r _reduce_methodr sH zzajj&9&9:::QZZ%8%8999r c e Zd Zd Zy)_Cc y r r^ )r s r fz_C.f s r N)r* r+ r, r r^ r r r r s r r c > t | j | j ffS r )r __objclass__r* r s r _reduce_method_descriptorr s Q^^QZZ0 00r c \ t | j | j | j xs i ffS r )_rebuild_partialfuncr keywords)ps r _reduce_partialr s% affaffajj.>B ? ??r c 4 t j | g|i |S r ) functoolspartial)r r r s r r r s T 5D 5H 55r c , ddl m} t || ffS )Nr ) DupSocket)r r _rebuild_socket)r r s r _reduce_socketr s . 1 //r c " | j S r )rR )dss r r r s yy{r c t | j }t || j | j | j ffS r )r_ r r familyr proto)r dfs r r r s2 188: QXXqvvqww ???r c T | j }t j |||| S )N)r )rR rj )r r r r r s r r r s" YY[}}VT5<<r c v e Zd ZdZeZeZeZeZeZe j dk( re Z e Z e Z neZeZeZeZeZeZeZeZd Zy)AbstractReducerzAbstract base class for use in implementing a Reduction class suitable for use in replacing the standard reduction mechanism used in multiprocessing.r c n t t t j t t t t j t t t t j t t t j t t t j t y r )r r r r r rz appendr int__add__r r r rj r )r r s r r zAbstractReducer.__init__ s\ bdff ~.dkk"$=>ckk"$=>""O4 /r N)r* r+ r, r- r r r r r sysplatformr7 r6 r5 r` ra r_ r r r r r r r^ r r r r sl $NH D K K ||w # #N 9 '#N%O0r r ) metaclassr )NF).abcr r. r r# rU r0 rj r r r __all__r hasattrr Picklerr r r r: r6 r7 r r objectr5 rg rl r` ra r_ r r r r r rz r r r r r r r r r r^ r r <module>r s N LLG+ 8 VZ0 7 V\27 V]]I6 V^^ . " "- <<7 99G ;$( ; 7 $ *F *F ..G ,,(*KH48! $ G : bdff ~ &1 dkk 5 6 ckk 5 6@6 O , <<70 V]]N+@= V]]N+ 0 0r