
    0;ji                        d dl Z d dlZd dlZd dlmZ d dlmZ ddlmZ  e	ed          o e	ed          o e	ej        d          Z
d	 Zd
 Zd Zd Zd Zd Z eej        e            eej        e            eee           dS )    N)
Connection)get_spawning_popen   )registerCMSG_LEN
SCM_RIGHTSsendmsgc                 0    t          j        | d           | S )NT)osset_inheritable)fds    h/root/voice-cloning/.venv/lib/python3.11/site-packages/joblib/externals/loky/backend/_posix_reduction.py_mk_inheritabler      s    r4   I    c                     t                      }|(|                    |                    |                     S t          rddlm} |                    |           S t          d          )zReturn a wrapper for an fd.Nr   )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      sx    "$$Iy<<R@@AAA	 
333333$$R(((1
 
 	
r   c                 |    t          |                                           }t          || j        | j        | j        ffS N)r   fileno_rebuild_socketfamilytypeproto)sdfs     r   _reduce_socketr"   -   s1    	qxxzz		BR1617;;;r   c                 X    |                                  }t          j        ||||          S r   )detachsocketfromfd)r!   r   r   r   r   s        r   r   r   2   s%    	B=VT5111r   c                 L    |                                  }t          |||          S r   )r$   r   )r!   readablewritabler   s       r   rebuild_connectionr*   7   s!    	Bb(H---r   c                 p    t          |                                           }t          || j        | j        ffS r   )r   r   r*   r(   r)   )connr!   s     r   reduce_connectionr-   <   s-    	t{{}}		BDM4=AAAr   )r   r%   _socketmultiprocessing.connectionr   multiprocessing.contextr   	reductionr   hasattrr   r   r   r"   r   r*   r-    r   r   <module>r4      s8   
			   1 1 1 1 1 1 6 6 6 6 6 6       GFJ *%%*y))   

 
 
 < < <
2 2 2
. . .
B B B
 	 ' ' '  ( ( ( & ' ' ' ' 'r   