Name	Size	Mode	Actions
arrow.cpython-36.pyc	7328	0644	editdlrm
cached.cpython-36.pyc	23030	0644	editdlrm
dask.cpython-36.pyc	4656	0644	editdlrm
dbfs.cpython-36.pyc	13351	0644	editdlrm
dvc.cpython-36.pyc	2622	0644	editdlrm
ftp.cpython-36.pyc	10444	0644	editdlrm
git.cpython-36.pyc	3750	0644	editdlrm
github.cpython-36.pyc	7404	0644	editdlrm
hdfs.cpython-36.pyc	7093	0644	editdlrm
http.cpython-36.pyc	20752	0644	editdlrm
jupyter.cpython-36.pyc	4131	0644	editdlrm
libarchive.cpython-36.pyc	6005	0644	editdlrm
local.cpython-36.pyc	11912	0644	editdlrm
memory.cpython-36.pyc	6697	0644	editdlrm
reference.cpython-36.pyc	16142	0644	editdlrm
sftp.cpython-36.pyc	6104	0644	editdlrm
smb.cpython-36.pyc	10591	0644	editdlrm
tar.cpython-36.pyc	4502	0644	editdlrm
webhdfs.cpython-36.pyc	14712	0644	editdlrm
zip.cpython-36.pyc	3276	0644	editdlrm
__init__.cpython-36.pyc	156	0644	editdlrm

3 8%Eg��@s�dd
lZdd
l
Z
dd
lZdd
lZddlmZ
dd
lZddlmZ
ddl m Z
ddlmZ
ddd�Z e
jd �
ZGd d�de�ZGdd �d e�Zd
S)�N)
�BufferedReader)
�AbstractArchiveFileSystem)
�compr)
�infer_compression�file� directory)�
0�
5�tarcsDeZ
dZd
ZdZdZd�f
dd� Zdd�Zd d �Zddd �
Z �Z S)� TarFileSystemzzCompressed Tar archives as a file-system (read-only) Supports the following formats: tar.gz, tar.bz2, tar.xz �r NcsD
t�j
f|�

t|
t�r.tj|
f
|p&i�
j�}
|dkr�d}yPt|
d
�rN|
j}n:t|
d�r`|
j}n(t|
d�rr|
j }nt|
d�r�|
j �d}Wn2tk r�
}
ztj d|���

WYdd}~XnX|dk r�t|�
}tj d|�d|���

|dk r�t||
�
}
|
|_tj||
j�
|
j�|_tj|jd�
|_d|_||_d|_|j�
dS) N�original�path�name�infoz:Unable to determine file name, not inferring compression: zInferred compression z from file name )
�fileobj)�super�__init__� isinstance�str�fsspec�open�hasattrr rrr� Exception�logger�warningrrZ_fo_ref�weakref�finalize�close� __enter__�fo�tarfile�TarFiler � dir_cache�index_store�index�_index)�selfr r$Zstorage_options�compression�kwargsr�ex)
� __class__��D/usr/local/lib/python3.6/site-packages/fsspec/implementations/tar.pyrs<















zTarFileSystem.__init__c
CsVi}
xF|jD]<}|j
�}t|d
|d
<|j
�djd�
}||jf|
|<qW|
|_dS)N�typer�
/)r �get_info�typemap�rstrip�offset_datar%)r'�outZtirrr,r,r-r&Vs




zTarFileSystem._indexc
CsR|jdk rdSi|_x8|j
j�D]*}
|
j�}t|d
|d
<||j|d<q WdS)Nr.r)r#r � getmembersr0r1)r'�memberrr,r,r-� _get_dirsbs




zTarFileSystem._get_dirs�rbcKsl|d
krtd�
�
|j
|
\}}|ddkr2td�
�
t|jt�rF|j}ntj|j�
}|j|�

t||j|
�
�S)Nr8z#Read-only filesystem implementationr.rzCan only handle regular files) � ValueErrorr%rr r�copy�seek�TarContainedFiler)r'r�moder)�details�offsetZnewfor,r,r-�_openms






zTarFileSystem._open)rNNN)
r8)�__name__� __module__�__qualname__�__doc__Zroot_marker�protocolrr&r7r@� __classcell__r,r,)
r+r-rs
:rc@sLeZ
dZd
Zdd�Zdd�Zddd�
Zdd d�
Zdd �Zdd�Z dd�Z dS)r<z7 Represent/wrap a TarFileSystem's file object. cCs8||_|d
|_
|
|_|
j�|_|j|j
|_d|_dS)N�sizeF)rrG�of�tell�start�end�closed)r'rHrr,r,r-r�s





zTarContainedFile.__init__c

Cs|jj
�|jS)
N)rHrIrJ)
r'r,r,r-rI�s
zTarContainedFile.tell�
cCs^|jrt
d
�
�
|
dkr&|j|jj�}
|
|j|j�krF|j|j�}
|
dkrRdS|jj|
�
S)Nzfile is closedr
rM�)rLr9rKrHrI�read)r'�
nr,r,r-rO�s








zTarContainedFile.readr
cCs�|jrt
d
�
�
|dkr2tt|j|j|
�|j�}
nR|dkrXtt|j|j�|
�|j�}
n,|dkr|tt|j|j|
�|j�}
nt
d�
�
|jj|
�

dS)Nzfile is closedr
rM�zWhence must be (0, 1, 2)) rLr9�min�maxrJrKrIrHr;)r'Zto�whencer,r,r-r;�s








zTarContainedFile.seekc

Cs|jj
�
d
|_dS)NT)rHrrL)
r'r,r,r-r�s

zTarContainedFile.closec


Cs|S)
Nr,)
r'r,r,r-r�s
zTarContainedFile.__enter__c
Cs|j�
dS)
N)
r)r'�exc_type�exc_val�exc_tbr,r,r-�__exit__�s
zTarContainedFile.__exit__N�����)
rY)
r
)rArBrCrDrrIrOr;rrrXr,r,r,r-r<s  r<)r:�loggingr!r�iorrZfsspec.archiverZfsspec.compressionrZfsspec.utilsrr1� getLoggerrr�objectr<r,r,r,r-�
s






  n