⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.202
Server IP:
97.74.87.16
Server:
Linux 16.87.74.97.host.secureserver.net 5.14.0-503.38.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Fri Apr 18 08:52:10 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.2.28
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib64
/
python3.9
/
multiprocessing
/
__pycache__
/
View File Name :
reduction.cpython-39.opt-1.pyc
a �����DOg(%����������������������@���s��d�dl�mZ�d�dlZd�dlZd�dlZd�dlZd�dlZd�dlZd�dlZddl m Z �g�d�Zejdkp�e ed�o�e ed�o�e ejd �ZG�d d��dej�ZejZd8dd �Zejdk��r�eg�d�7�Zd�dlZd9dd�dd�Zdd��Zdd��Zdd��ZG�dd��de�ZnFeg�d�7�Zd�dlZejdkZdd��Zdd ��Zd!d��Zd"d��Zd#d$��Zd%d&��ZG�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(��ejdk�r�d/d0��Z+d1d2��Z,eeje+��nd3d0��Z+d4d2��Z,eeje+��G�d5d6��d6ed7�Z-dS�):�����)�ABCMetaN����)�context)�send_handle�recv_handle�ForkingPickler�register�dump�win32�CMSG_LEN� SCM_RIGHTS�sendmsgc�����������������������sJ���e�Zd�ZdZi�ZejZ��fdd�Ze dd���Z e d dd��Zej Z ���ZS�) r���z)Pickler subclass used by multiprocessing.c��������������������s*���t���j|���|�j���|�_|�j�|�j��d�S��N)�super�__init__�_copyreg_dispatch_table�copy�dispatch_table�update�_extra_reducers��self�args�� __class__���1/usr/lib64/python3.9/multiprocessing/reduction.pyr���&���s����zForkingPickler.__init__c�����������������C���s���||�j�|<�dS�)z&Register a reduce function for a type.N)r���)�cls�type�reducer���r���r���r���+���s����zForkingPickler.registerNc�����������������C���s ���t����}|�||��|��|���S�r���)�io�BytesIOr ���� getbuffer)r����obj�protocol�bufr���r���r����dumps0���s����zForkingPickler.dumps)N)�__name__� __module__�__qualname__�__doc__r����copyregr���r���r����classmethodr���r&����pickle�loads� __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�j�S�)z<Duplicate a handle. (target_process is a handle not a pid!)Nr���)�_winapi�GetCurrentProcess�DuplicateHandle�DUPLICATE_SAME_ACCESS)�handleZtarget_process�inheritabler4����current_processr���r���r���r2���G���s�����r2���c�������������� ���C���sN���t��t�jd|��}z,t��||t����ddt�jt�jB��W�t��|��S�t��|��0�dS�)z5Steal a handle from process identified by source_pid.Fr���N)r5����OpenProcess�PROCESS_DUP_HANDLEr7���r6���r8����DUPLICATE_CLOSE_SOURCE�CloseHandle)Z source_pidr9���Zsource_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_pidZdhr���r���r���r���_���s����r���c�����������������C���s���|��������S�)�)Receive a handle over a local connection.)�recv�detach)rB���r���r���r���r���d���s����r���c�������������������@���s"���e�Zd�ZdZddd�Zdd��ZdS�)r1���zPicklable wrapper for a handle.Nc�������������� ���C���sf���|d�u�rt����}t�tjd|�}z(t�t���|||dd�|�_W�t�|��nt�|��0�||�_ ||�_ d�S�)NFr���)�os�getpidr5���r<���r=���r7���r6����_handler?����_access�_pid)r���r9����access�pid�procr���r���r���r���j���s���� �zDupHandle.__init__c�������������� ���C���sb���|�j�t���kr|�jS�t�tjd|�j��}z*t�||�jt���|�j dtj �W�t�|��S�t�|��0�dS�)z1Get the handle. This should only be called once.FN)rK���rG���rH���rI���r5���r<���r=���r7���r6���rJ���r>���r?���)r���rN���r���r���r���rF���y���s���� � � �zDupHandle.detach)N)r'���r(���r)���r*���r���rF���r���r���r���r���r1���h���s��� r1���)�DupFd�sendfds�recvfds�darwinc�����������������C���sV���t���d|�}tt|�d�g�}|��|gtjtj|fg��trR|��d�dkrRt d��dS�)z,Send an array of fds over an AF_UNIX socket.�i����r�������Az%did not receive acknowledgement of fdN) �array�bytes�lenr ����socket� SOL_SOCKETr����ACKNOWLEDGErE����RuntimeError)�sock�fds�msgr���r���r���rP�������s ����rP���c�������������� ���C���s��t���d�}|j|�}|��dt�|��\}}}}|s:|s:t�z�trJ|��d��t|�dkrft dt|����|d�\}} } |tj kr�| tjkr�t| �|j�dkr�t�|� | ��t|�d�|d�kr�td�t|�|d����t|�W�S�W�n�ttfy����Y�n0�t d��d S�) z/Receive an array of fds over an AF_UNIX socket.rS���r���rU���zreceived %d items of ancdatar���rT���z Len is {0:n} but msg[0] is {1!r}zInvalid data receivedN)rV����itemsize�recvmsgrY���� CMSG_SPACE�EOFErrorr[���rA���rX���r\���rZ���r���� ValueError� frombytes�AssertionError�format�list� IndexError)r]����size�a� bytes_sizer_����ancdata�flags�addr� cmsg_level� cmsg_type� cmsg_datar���r���r���rQ�������s:���� � � ��rQ���c�����������������C���sF���t��|����t�jt�j��}t||g��W�d����n1�s80����Y��dS�r@���)rY����fromfd�fileno�AF_UNIX�SOCK_STREAMrP���)rB���r9���rC����sr���r���r���r�������s����c�����������������C���sH���t��|����t�jt�j��}t|d�d�W��d����S�1�s:0����Y��dS�)rD���r���r���N)rY���rs���rt���ru���rv���rQ���)rB���rw���r���r���r���r�������s����c�����������������C���sF���t����}|dur |�|�|���S�tr:ddlm}�|�|��S�td��dS�)zReturn a wrapper for an fd.Nr���)�resource_sharerz&SCM_RIGHTS appears not to be available)r����get_spawning_popenrO����duplicate_for_child�HAVE_SEND_HANDLE��rx���rd���)�fd� popen_objrx���r���r���r���rO�������s���� rO���c�����������������C���s2���|�j�d�u�rt|�j|�jjffS�t|�j�|�jjffS�d�S�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|�jpi�ffS�r���)�_rebuild_partial�funcr����keywords)�pr���r���r����_reduce_partial����s����r����c�����������������C���s���t�j|�g|�R�i�|��S�r���)� functools�partial)r����r���r����r���r���r���r��������s����r����c�����������������C���s���ddl�m}�t||��ffS�)Nr���)� DupSocket)rx���r�����_rebuild_socket)rw���r����r���r���r����_reduce_socket����s����r����c�����������������C���s���|�����S�r���)rF���)Zdsr���r���r���r��������s����r����c�����������������C���s"���t�|�����}t||�j|�j|�jffS�r���)rO���rt���r�����familyr����proto)rw����dfr���r���r���r��������s����c�����������������C���s���|�����}tj||||d�S�)N)rt���)rF���rY���)r����r����r���r����r}���r���r���r���r��������s����c�������������������@���sd���e�Zd�ZdZeZeZeZeZeZe j dkr8eZeZe Z neZeZeZeZeZeZeZeZdd��ZdS�)�AbstractReducerz�Abstract 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��j�t��t�ttj�t��t�ttj �t��t�t jt��t�t j t��d�S�r���)r���r���r����r����r����rh����appendr�����int�__add__r����r����r����rY���r����r���r���r���r���r�����s ����zAbstractReducer.__init__N)r'���r(���r)���r*���r���r���r ���r���r����sys�platformr3���r2���r1���rP���rQ���rO���r����r����r����r����r����r���r���r���r���r���r��������s&��� r����)� metaclass)N)NF).�abcr���r+���r����r ���rG���r-���rY���r����r|���r����__all__r�����hasattrr{����Picklerr���r���r ���r5���r2���r3���r���r����objectr1���rV���r[���rP���rQ���rO���r����r����r���r����r����rh���r����r����r����r����r����r����r����r����r����r���r���r���r����<module> ���sj��� � � �#