📁 File Manager Pro
v10.0.3 | PHP: 8.1.34
Server: Apache
2026-06-21 21:47:29
📂
/ (Root)
/
opt
/
alt
/
python35
/
lib64
/
python3.5
/
multiprocessing
/
__pycache__
📍 /opt/alt/python35/lib64/python3.5/multiprocessing/__pycache__
🔄 Refresh
✏️
Editing: reduction.cpython-35.opt-2.pyc
Read Only
���]� � @ s� d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d d d d g Z e j d k p� e e d � o� e e d � o� e e j d � Z Gd d � d e j � Z e j Z d d d � Z e j d k rfe d d d g 7Z d d l Z d d d d � Z d d � Z d d � Z d d � Z Gd d � d e � Z nj e d d d g 7Z d d l Z e j d k Z d d � Z d d � Z d d � Z d d � Z d d � Z d! d" � Z Gd# d$ � d$ � Z e e e � j � e � d% d& � Z! e e e" j# � e! � e e e$ j% � e! � d' d( � Z& d) d* � Z' e e j( e& � e j d k r�d+ d, � Z) d- d. � Z* e e j e) � n( d/ d, � Z) d0 d. � Z* e e j e) � d S)1� N� )�context� send_handle� recv_handle�ForkingPickler�register�dump�win32�CMSG_LEN� SCM_RIGHTS�sendmsgc sa e Z d Z i Z e j Z � f d d � Z e d d � � Z e d d d � � Z e j Z � S)r c s9 t � j | � | j j � | _ | j j | j � d S)N)�super�__init__�_copyreg_dispatch_table�copy�dispatch_table�update�_extra_reducers)�self�args)� __class__� �./opt/alt/python35/lib64/python3.5/reduction.pyr % s zForkingPickler.__init__c C s | | j | <d S)N)r )�cls�type�reducer r r r * s zForkingPickler.registerNc C s, t j � } | | | � j | � | j � S)N)�io�BytesIOr � getbuffer)r �obj�protocol�bufr r r �dumps/ s zForkingPickler.dumps) �__name__� __module__� __qualname__r �copyregr r r � classmethodr r" �pickle�loadsr r )r r r s c C s t | | � j | � d S)N)r r )r �filer r r r r 9 s � DupHandle� duplicate� steal_handleFc C s= | d k r t j � } t j t j � | | d | t j � S)Nr )�_winapi�GetCurrentProcess�DuplicateHandle�DUPLICATE_SAME_ACCESS)�handleZtarget_process� inheritabler r r r, F s c C s] t j t j d | � } z0 t j | | t j � d d t j t j B� SWd t j | � Xd S)NFr )r. � OpenProcess�PROCESS_DUP_HANDLEr0 r/ r1 �DUPLICATE_CLOSE_SOURCE� CloseHandle)Z source_pidr2 Zsource_process_handler r r r- N s c C s& t | t j | � } | j | � d S)N)r+ r. r1 �send)�connr2 �destination_pidZdhr r r r Z s c C s | j � j � S)N)�recv�detach)r9 r r r r _ s c @ s+ e Z d Z d d d � Z d d � Z d S)r+ Nc C s� | d k r t j � } t j t j d | � } z+ t j t j � | | | d d � | _ Wd t j | � X| | _ | | _ d S)NFr ) �os�getpidr. r4 r5 r0 r/ �_handler7 �_access�_pid)r r2 �access�pid�procr r r r e s zDupHandle.__init__c C s{ | j t j � k r | j St j t j d | j � } z/ t j | | j t j � | j d t j � SWd t j | � Xd S)NF) rA r= r> r? r. r4 r5 r0 r/ r@ r6 r7 )r rD r r r r< t s zDupHandle.detach)r# r$ r% r r< r r r r r+ c s �DupFd�sendfds�recvfds�darwinc C s{ t j d | � } t t | � d g � } | j | g t j t j | f g � t rw | j d � d k rw t d � � d S)N�i� r � Az%did not receive acknowledgement of fd) �array�bytes�lenr �socket� SOL_SOCKETr � ACKNOWLEDGEr; � RuntimeError)�sock�fds�msgr r r rF � s %c C s( t j d � } | j | } | j d t j | � � \ } } } } | rW | rW t � y� t rm | j d � t | � d k r� t d t | � � � | d \ } } } | t j k r� | t j k r� t | � | j d k r� t � | j | � t | � SWn t t f k rYn Xt d � � d S)NrI r rK z received %d items of ancdatar zInvalid data received)rL �itemsize�recvmsgrO r �EOFErrorrQ r8 rN rR rP r � ValueError� frombytes�list� IndexError) rS �size�a� bytes_sizerU �ancdata�flags�addr� cmsg_level� cmsg_type� cmsg_datar r r rG � s* ' c C s? t j | j � t j t j � � } t | | g � Wd QRXd S)N)rO �fromfd�fileno�AF_UNIX� SOCK_STREAMrF )r9 r2 r: �sr r r r � s $c C s@ t j | j � t j t j � � } t | d � d SWd QRXd S)Nr r )rO rf rg rh ri rG )r9 rj r r r r � s $c C sa t j � } | d k r. | j | j | � � St rQ d d l m } | j | � St d � � d S)Nr )�resource_sharerz&SCM_RIGHTS appears not to be available)r �get_spawning_popenrE �duplicate_for_child�HAVE_SEND_HANDLE� rk rY )�fd� popen_objrk r r r rE � s c C sE | j d k r( t | j | j j f f St | j | j j f f Sd S)N)�__self__�getattrr �__func__r# )�mr r r �_reduce_method� s rv c @ s e Z d Z d d � Z d S)�_Cc C s d S)Nr )r r r r �f� s z_C.fN)r# r$ r% rx r r r r rw � s rw c C s t | j | j f f S)N)rs � __objclass__r# )ru r r r �_reduce_method_descriptor� s rz c C s" t | j | j | j p i f f S)N)�_rebuild_partial�funcr �keywords)�pr r r �_reduce_partial� s r c C s t j | | | � S)N)� functools�partial)r| r r} r r r r{ � s r{ c C s# d d l m } t | | � f f S)Nr )� DupSocket)rk r� �_rebuild_socket)rj r� r r r �_reduce_socket� s r� c C s | j � S)N)r< )Zdsr r r r� � s r� c C s1 t | j � � } t | | j | j | j f f S)N)rE rg r� �familyr �proto)rj �dfr r r r� � s c C s% | j � } t j | | | d | �S)Nrg )r< rO )r� r� r r� rp r r r r� � s )+r& r� r r= r( rO �sysro r �__all__�platform�hasattrrn �Picklerr r r r. r, r- r r �objectr+ rL rQ rF rG rE rv rw r rx rz r[ �append�int�__add__r r{ r� r� r� r r r r �<module> s^ #
💾 Save Changes
❌ Cancel