B
    Wo$c%                 @   s   d 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 ye W n e	k
rX   e
ZY nX dd Zdd Zdd	 Zd
ZdZdddZdddZdS )z
Disk management utilities.
    N)utilc             C   sn   d}x\t | dg D ]H}t t j| |}t|drH||jd 7 }q||jd d d 7 }qW t|d S )z& Return the disk usage in a directory.r   .	st_blocksi      g      @)	oslistdirstatpathjoinhasattrr   st_sizeint)r	   sizefiler    r   *lib/python3.7/site-packages/joblib/disk.py	disk_used   s    
r   c          
   C   s   d}t ||d |d d}y$t|| d  t| dd  }W n< ttfk
rz } ztd| t| f |W dd}~X Y nX |S )z2 Convert a memory text to its value in bytes.
    i         )KMGNzQInvalid literal for size give: %s (type %s) should be alike '10G', '500M', '50K'.)dictr   floatKeyError
ValueErrortype)textZkiloZunitsr   er   r   r   memstr_to_bytes*   s    $$r    c          
   C   sD   yt |  W n0 tk
r> } z|jtjkr. W dd}~X Y nX dS )zgEnsure directory d exists (like mkdir -p on Unix)
    No guarantee that the directory is writable.
    N)r   makedirsOSErrorerrnoZEEXIST)dr   r   r   r   mkdirp8   s
    r%   g?
   c             C   st   g }yt | }W n4 t jk
rF   |dk	r@|t j| t  n Y nX x&|D ]}t j| |}t||d qNW dS )a  Remove all subdirectories in this path.

    The directory indicated by `path` is left in place, and its subdirectories
    are erased.

    If onerror is set, it is called to handle the error with arguments (func,
    path, exc_info) where func is os.listdir, os.remove, or os.rmdir;
    path is the argument to that function that caused it to fail; and
    exc_info is a tuple returned by sys.exc_info().  If onerror is None,
    an exception is raised.
    N)onerror)r   r   errorsysexc_infor	   r
   delete_folder)r	   r'   namesnamefullnamer   r   r   
rm_subdirsK   s    
r/   Tc          	   C   s   t j| r|dk	r$t| d| nd}xt | }yLt|dksF|rjtj| ddd td	|  P nt
d	| t|W n* t
tfk
r   |d7 }|tkr Y nX tt q*W dS )zBUtility function to cleanup a temporary folder if it still exists.NFr   )ignore_errorsr'   zSuccessfully deleted {}z*Expected empty folder {} but got {} files.r   )r   r	   isdirshutilZrmtreer   lenr   debugformatr"   WindowsErrorRM_SUBDIRS_N_RETRYtimeZsleepRM_SUBDIRS_RETRY_TIME)Zfolder_pathr'   Zallow_non_emptyZ	err_countfilesr   r   r   r+   i   s*    
r+   )N)NT)__doc__r   r)   r8   r#   r2   Zmultiprocessingr   r6   	NameErrorr"   r   r    r%   r9   r7   r/   r+   r   r   r   r   <module>   s"   

