
    6-i                     (   S SK r S SKrS SKrS SKJr  S SKJr  SSKJr  \	" \S5      =(       a#    \	" \S5      =(       a    \	" \R                  S5      r
S	 rS
 rS rS rS rS r\" \R                  \5        \" \R                  \5        \" \\5        g)    N)
Connection)get_spawning_popen   )registerCMSG_LEN
SCM_RIGHTSsendmsgc                 4    [         R                  " U S5        U $ )NT)osset_inheritable)fds    a/var/www/html/venv/lib/python3.13/site-packages/joblib/externals/loky/backend/_posix_reduction.py_mk_inheritabler      s    r4 I    c                     [        5       nUb   UR                  UR                  U 5      5      $ [        (       a  SSKJn  UR                  U 5      $ [        S5      e)zReturn a wrapper for an fd.r   )resource_sharerz[Cannot pickle connection object. This object can only be passed when spawning a new process)r   DupFdduplicate_for_childHAVE_SEND_HANDLEmultiprocessingr   	TypeError)r   	popen_objr   s      r   r   r      sV    "$Iy<<R@AA		3$$R((1
 	
r   c                     [        U R                  5       5      n[        XR                  U R                  U R
                  44$ N)r   fileno_rebuild_socketfamilytypeproto)sdfs     r   _reduce_socketr"   -   s0    	qxxz	BR166177;;;r   c                 P    U R                  5       n[        R                  " XAX#5      $ r   )detachsocketfromfd)r!   r   r   r   r   s        r   r   r   2   s    	B==T11r   c                 :    U R                  5       n[        X1U5      $ r   )r$   r   )r!   readablewritabler   s       r   rebuild_connectionr*   7   s    	BbH--r   c                 p    [        U R                  5       5      n[        XR                  U R                  44$ r   )r   r   r*   r(   r)   )connr!   s     r   reduce_connectionr-   <   s*    	t{{}	BMM4==AAAr   )r   r%   _socketmultiprocessing.connectionr   multiprocessing.contextr   	reductionr   hasattrr   r   r   r"   r   r*   r-    r   r   <module>r4      s    
   1 6  FJ *%*y) 

 <
2
.
B
 	 '  ( & 'r   