
    Ug                         d dl Z d dlmZmZ d dlmZ d dlmZ d dlm	Z	m
Z
 ed             Z edddg           ed	dd
g          d                         ZdS )    N)make_memmapconcurrency_safe_rename)
with_numpy)parametrize)Paralleldelayedc                     |                      d          j        }dt          j        z  }t          j        dz   }t	          ||d|          }|j        |k    sJ d S )Nz	test.mmap      zw+)shapemodeoffset)joinstrpathmmapALLOCATIONGRANULARITYr   r   )tmpdirfnamesizer   
memmap_objs        Y/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/joblib/test/test_backports.pytest_memmapr   	   s`    KK$$,Et))D'!+FU$T&IIIJ&&&&&&    dst_contentzdst contentbackend	threadingc                      fdt          d          D             }|D ]}|                    d                                d          |                    |            t          d|          fd|D                                                        sJ                                 dk    sJ |D ]}|                                rJ d S )Nc                 @    g | ]}                     d |z            S )zsrc_%d)r   ).0ir   s     r   
<listcomp>z0test_concurrency_safe_rename.<locals>.<listcomp>   s)    ===qX\**===r      zsrc contentdst)n_jobsr   c              3   h   K   | ],} t          t                    |j        j                  V  -d S )N)r   r   r   )r   src_pathdst_paths     r   	<genexpr>z/test_concurrency_safe_rename.<locals>.<genexpr>   sR       ( ( 	)'(()98;KLL( ( ( ( ( (r   )rangewriter   r   existsread)r   r   r   	src_pathsr&   r'   s   `    @r   test_concurrency_safe_renamer.      s    >===E!HH===I & &}%%%%{{5!!H{###'HAw''' ( ( ( (!( ( (    ??==??m++++ % %??$$$$$$% %r   )r   joblib.backportsr   r   joblib.test.commonr   joblib.testingr   joblibr   r   r   r.    r   r   <module>r4      s     A A A A A A A A ) ) ) ) ) ) & & & & & & $ $ $ $ $ $ $ $ ' ' ' ]T=122Y{+,,% % -, 32% % %r   