⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.103
Server IP:
45.79.8.107
Server:
Linux localhost 5.15.0-161-generic #171-Ubuntu SMP Sat Oct 11 08:17:01 UTC 2025 x86_64
Server Software:
nginx/1.18.0
PHP Version:
8.1.2-1ubuntu2.22
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.10
/
multiprocessing
/
__pycache__
/
View File Name :
reduction.cpython-310.pyc
o i(% @ s d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m Z g dZ ej dkp@e edo@e edo@e ejd ZG d d d ejZejZd8d d Zej dkr~e g d7 Z d dlZd9ddddZdd Zdd Zdd ZG dd deZn#e g d7 Z d dlZej d kZd d Z d d Z d!d Zd"d Zd#d$ Z d%d& Z G d'd( d(Z ee!e j"e d)d* Z#ee!e$j%e# ee!e&j'e# d+d, Z(d-d. Z)eej*e( ej dkrd/d0 Z+d1d2 Z,eeje+ nd3d0 Z+d4d2 Z,eeje+ G d5d6 d6ed7Z-dS ): )ABCMetaN )context) send_handle recv_handleForkingPicklerregisterdumpwin32CMSG_LEN SCM_RIGHTSsendmsgc sJ e Zd ZdZi ZejZ fddZe dd Z e d ddZ e j Z ZS ) r z)Pickler subclass used by multiprocessing.c s* t j| | j | _| j| j d S N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducersselfargs __class__ 0/usr/lib/python3.10/multiprocessing/reduction.pyr & s zForkingPickler.__init__c C s || j |< dS )z&Register a reduce function for a type.N)r )clstypereducer r r r + s zForkingPickler.registerNc C s t }| ||| | S r )ioBytesIOr getbuffer)r objprotocolbufr r r dumps0 s zForkingPickler.dumpsr )__name__ __module__ __qualname____doc__r copyregr r r classmethodr r& pickleloads __classcell__r r r r r ! s r c C s t ||| dS )z3Replacement for pickle.dump() using ForkingPickler.N)r r )r# filer$ r r r r : s r ) DupHandle duplicate steal_handleF)source_processc C s6 t }|du r |}|du r|}t || |d|t jS )z<Duplicate a handle. (target_process is a handle not a pid!)Nr )_winapiGetCurrentProcessDuplicateHandleDUPLICATE_SAME_ACCESS)handletarget_process inheritabler4 current_processr r r r2 G s r2 c C sJ t t jd| }zt ||t ddt jt jB W t | S t | w )z5Steal a handle from process identified by source_pid.Fr )r5 OpenProcessPROCESS_DUP_HANDLEr7 r6 r8 DUPLICATE_CLOSE_SOURCE CloseHandle) source_pidr9 source_process_handler r r r3 S s r3 c C s t |tj|}| | dS z&Send a handle over a local connection.N)r1 r5 r8 send)connr9 destination_piddhr r r r _ s r c C s | S ))Receive a handle over a local connection.)recvdetach)rE r r r r d s r c @ s" e Zd ZdZdddZdd ZdS )r1 z Picklable wrapper for a handle.Nc C sf |d u rt }ttjd|}ztt |||dd| _W t| nt| w || _ || _ d S )NFr ) osgetpidr5 r= r> r7 r6 _handler@ _access_pid)r r9 accesspidprocr r r r j s zDupHandle.__init__c C s^ | j t kr | jS ttjd| j }zt|| jt | j dtj W t | S t | w )z1Get the handle. This should only be called once.F) rO rK rL rM r5 r= r> r7 r6 rN r? r@ )r rR r r r rJ y s zDupHandle.detachr )r' r( r) r* r rJ r r r r r1 h s r1 )DupFdsendfdsrecvfdsdarwinc C sZ t d|}tt|d g}| |gtjtj|fg tr)| ddkr+t ddS dS )z,Send an array of fds over an AF_UNIX socket.i r Az%did not receive acknowledgement of fdN) arraybyteslenr socket SOL_SOCKETr ACKNOWLEDGErI RuntimeError)sockfdsmsgr r r rT s rT c C s t d}|j| }| dt|\}}}}|s |s tz[tr%| d t|dkr3t dt| |d \}} } |tj kro| tj krtt| |j dkrOt | | t|d |d krjtdt||d t|W S W t dW t d t tfy Y t dw ) z/Receive an array of fds over an AF_UNIX socket.rW r rY z received %d items of ancdatar rX z Len is {0:n} but msg[0] is {1!r}zInvalid data received)rZ itemsizerecvmsgr] CMSG_SPACEEOFErrorr_ rD r\ r` r^ r ValueError frombytesAssertionErrorformatlist IndexError) ra sizea bytes_sizerc ancdataflagsaddr cmsg_level cmsg_type cmsg_datar r r rU sB rU c C sH t | t jt j}t||g W d dS 1 s w Y dS rC )r] fromfdfilenoAF_UNIX SOCK_STREAMrT )rE r9 rF sr r r r s "c C sH t | t jt j}t|dd W d S 1 s w Y dS )rH r r N)r] rw rx ry rz rU )rE r{ r r r r s $c C sB t }|dur||| S tr ddlm} || S td)zReturn a wrapper for an fd.Nr )resource_sharerz&SCM_RIGHTS appears not to be available)r get_spawning_popenrS duplicate_for_childHAVE_SEND_HANDLE r| rh )fd popen_objr| r r r rS s rS c C s. | j d u rt| j| jjffS t| j | jjffS r )__self__getattrr __func__r' mr r r _reduce_method s r c @ s e Zd Zdd ZdS )_Cc C s d S r r )r r r r f s z_C.fN)r' r( r) r r r r r r s r c C s t | j| jffS r )r __objclass__r' r r r r _reduce_method_descriptor s r c C s t | j| j| jp i ffS r )_rebuild_partialfuncr keywords)pr r r _reduce_partial r c C s t j| g|R i |S r ) functoolspartial)r r r r r r r r r c C s ddl m} t|| ffS )Nr ) DupSocket)r| r _rebuild_socket)r{ r r r r _reduce_socket s r c C s | S r )rJ )dsr r r r s r c C s" t | }t|| j| j| jffS r )rS rx r familyr proto)r{ dfr r r r s c C s | }tj||||dS )N)rx )rJ r] )r r r r r r r r r s c @ sd e Zd ZdZeZeZeZeZeZe j dkr e Z e Z e Z neZeZeZeZeZeZeZeZdd ZdS )AbstractReducerzAbstract base class for use in implementing a Reduction class suitable for use in replacing the standard reduction mechanism used in multiprocessing.r c G sN t tt jt t ttjt t ttj t t t j t t t j t d S r )r r r r r rl appendr int__add__r r r r] r r r r r r s zAbstractReducer.__init__N)r' r( r) r* r r r r r sysplatformr3 r2 r1 rT rU rS r r r r r r r r r r r s( r ) metaclassr )NF).abcr r+ r r rK r- r] r r r __all__r hasattrr Picklerr r r r5 r2 r3 r r objectr1 rZ r_ rT rU rS r r r r r rl r r r r r r r r r r r r r <module> sl #