Submit
Path:
~
/
/
usr
/
lib64
/
python3.6
/
site-packages
/
borg
/
__pycache__
/
File Content:
fuse.cpython-36.pyc
3 y��bnz � @ sB d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl m Z d dl Z ddl mZ e� Z ddlmZ ddlmZ ddlmZ dd lmZ dd lmZmZmZmZm Z dd lm Z dd l m Z dd l m!Z! ddl"m#Z# e$e j%d�Z&e$e j%d�Z'e$e j%d�Z(dd� Z)dZ*G dd� d�Z+G dd� de j,�Z-dS )� N)� defaultdict)�SIGINT� )� create_logger)� blake2b_128)�Archiver)�Archive)�FuseVersionsIndex)� daemonize� hardlinkable�signal_handler�format_file_size�Error)�msgpack)�Item)�LRUCache)�RemoteRepository� st_mtime_ns� st_birthtime�st_birthtime_nsc C s t jdd�S )Nr )�workers)�llfuse�main� r r � /usr/lib64/python3.6/fuse.py� fuse_main# s r � c @ sF e Zd ZdZdZejd�Zejdks(t �dd� Z dd � Z dd d �Z d S )� ItemCachez� This is the "meat" of the file system's metadata storage. This class generates inode numbers that efficiently index items in archives, and retrieves items from these inode numbers. � i z=cII� c C sJ || _ t� | _d| _d| _tjdd�| _tddd� d�| _ d| _ d| _ d S ) Nr i@B zborg-tmp)�prefix� c S s d S )Nr )�_r r r �<lambda>_ s z$ItemCache.__init__.<locals>.<lambda>)�capacity�dispose) �decrypted_repository� bytearray�meta� write_offset�offset�tempfileZ TemporaryFile�fdr �chunks�indirect_items� direct_items)�selfr& r r r �__init__A s zItemCache.__init__c C s( || j }|dk rtd��| j| td�kr�| jj| j|�\}}}|| }t| j||d � �}| jj|�}|s�t | j j |g��\} }|| j|< t |�|d � } t j� } | j| � tt | �d�S | j| td�k�r tj| j|d |d � d �} | jj| tj� tt t j| jd d ��d�S td ��d S ) Nr z3ItemCache.get() called with an invalid inode number� I� )� internal_dict� Sr r �littlei )Z read_sizez Invalid entry type in self.meta)r* � ValueErrorr( �ord�indirect_entry_struct� unpack_from�bytesr- �get�nextr& �get_many� memoryviewr �Unpacker�feedr �int� from_bytesr, �seek�io�SEEK_SET) r0 �inoder* r" Zchunk_id_relative_offset� chunk_offsetZchunk_id_offset�chunk_id�chunk�csize�data�unpackerZ fd_offsetr r r r< g s( z ItemCache.getNFc # s t j� }d�d}d}d� | j}| j}| jj} � �fdd�} �x�t|| jj|��D �]�\} \} } |d t |�kr�|t | j � | _}| |||d �< |}|d7 }||7 }t | �}|j | � �x8y|j | �}W n t jk r� P Y nX t|d�}|r�||� �s| �rd|k�rd� q�� }t |�}�| |k }d� |d t |�k�rX|t | j � | _}|�r�| jjdtj�}| jj|� d |jd d � |||d �< | jd 7 _n.�| | }| ||d || |� | jd 7 _|| j }|d7 }||fV q�W qPW || _d S )Nr � c s � | 7 � �t | �7 �d S )N)�len)Zappend_msgpacked_bytes)�msgpacked_bytes� stream_offsetr r � write_bytes� s z1ItemCache.iter_archive_items.<locals>.write_bytesr3 )r4 �partr r5 � r6 r r2 )r r@ r) r( r9 � pack_into�zipr& r> rO r; � GROW_META_BYrA �unpackZ OutOfDatar r, rD rE �SEEK_END�write�to_bytesr/ r. r* )r0 Zarchive_item_ids�filter�consider_part_filesrM Z chunk_beginZlast_chunk_lengthr) r( Zpack_indirect_intorR �keyrK rL Zcurrent_id_offset�itemZ current_itemZcurrent_item_lengthZcurrent_spans_chunks�posZ item_offsetrG r )rP rQ r �iter_archive_items sZ $ " z ItemCache.iter_archive_itemsi i )NF) �__name__� __module__� __qualname__�__doc__rW �struct�Structr9 �size�AssertionErrorr1 r< ra r r r r r . s &r c s� e Zd ZdZdZdZdZdZdZ� fdd�Z dd� Z d d � Z d1d d �Z d2d d�Z g fdd�Zdd� Zdd� Zdd� Zd3dd�Zdd� Zg fdd �Zd4d d �Zd5d d �Zd6d!d"�Zd#d$� Zd7d%d&�Zd8d'd(�Zd9d)d*�Zd+d,� Z d-d.� Z d:d/d0�Z � Z S );�FuseOperationsz(Export archive as a FUSE filesystem FNr c s� t � j� || _|| _|| _|| _|| _i | _tt dd� d�| _ d| _ i | _ t t�| _tj� | _tj� | _d | _i | _t|�| _ttjjdtj � p�d��}t j d|� t|dd� d�| _ tt d d� d�| _ d S ) Nc S s d S )Nr )r" r r r r# � s z)FuseOperations.__init__.<locals>.<lambda>)r$ r% r Z BORG_MOUNT_DATA_CACHE_ENTRIESr z$mount data cache capacity: %d chunksc S s d S )Nr )r" r r r r# � s c S s d S )Nr )r" r r r r# � s )!�superr1 �repository_uncachedr& �args�manifestr^ �itemsr �FILES� _inode_cache� _inode_count�parentr �dict�contents�os�getuid� default_uid�getgid� default_gid� default_dir�pending_archivesr �cacherB �environr< � cpu_count�logger�debug� data_cache� _last_pos)r0 r^ Z repositoryrn rm r& Zdata_cache_capacity)� __class__r r r1 � s( zFuseOperations.__init__c C s� | j dd� | jjjr6| jr$td��| j| jjj� ntt� | _xj| j j j | j�D ]V}| jrh| j|j � qP| j dt |jj� d �d�}|| jd tj|j �< |j | j|< qPW d S )Nr )rs z_for versions view, do not specify a single archive, but always give the repository as location.g e��A)rs �mtime)� _create_dirrm �location�archive�versionsr �process_archiver �versions_indexrn ZarchivesZlist_considering�namerB ZtsZ timestampru rv �fsencoder| )r0 r� Z archive_inoder r r �_create_filesystem s z!FuseOperations._create_filesystemc C s� t jd| jt| j�ttj| j�t| j�tj| j� �� t jdt| j�� t jd| j j | j j | j j | j j ttj| j j ��tt j| j jj� �j�� t jdt| jj� �| jjttdd� | jj� D ���� | jj� d S )Nz$fuse: %d synth inodes, %d edges (%s)zfuse: %d pending archivesz]fuse: ItemCache %d entries (%d direct, %d indirect), meta-array size %s, direct items size %sz#fuse: data cache: %d/%d entries, %sc s s | ]\}}t |�V qd S )N)rO )�.0r^ rJ r r r � <genexpr> s z2FuseOperations.sig_info_handler.<locals>.<genexpr>)r� r� rr rO rs r �sys� getsizeofr| r} r/ r. r( rv �statr, �fileno�st_sizer� ro Z _capacity�sumr& Zlog_instrumentation)r0 Zsig_no�stackr r r �sig_info_handler s ( z FuseOperations.sig_info_handlerc C s� ddd�}dddg}|r(|j |jd�� ||dd d t�}|rL||dd d t� ||d d d t�| _||d d d t�| _||d ddt�| _||dddt�| _||dddtdd�| _| jdk r�| jn| j }| jdk r�| jn| j }d| j @ } t | tt j � d �||d�| _ | j� tj| ||� |�sBt� \} } t| jt��sB| jj| | � d } zRtd| j��$ td| j�� t� } W dQ R X W dQ R X | dk�p�| tk�o�|} W dtj| � X dS )z6Mount filesystem on *mountpoint* with *mount_options*.r c S s t | t�st�� x�t| �D ]�\}}||kr8| j|� |S |j|d �r| j|� |jdd�d }|tkr�|j� } | dkr|dS | dkr�d S t d | ��|t kr�y t ||d�S t k r� t d | �d �Y nX y||�S t k � r� t d | �d �Y qX qW |S d S )N�=r �y�yes�true�1T�n�no�false�0Fz unsupported value in option: %s)�base)r� r� r� r� )r� r� r� r� ) � isinstance�listri � enumerate�pop� startswith�split�bool�lowerr7 rB ) �optionsr^ ZpresentZ not_presentZ wanted_type�int_base�idxZoption�value�vr r r � pop_option& s2 z(FuseOperations.mount.<locals>.pop_optionz fsname=borgfsZroZdefault_permissions�,�ignore_permissionsTF�allow_damaged_filesr� �uidN�gid�umaskrT )r� i�A g e��A)�moder� r� r� �SIGUSR1ZSIGINFO)r )�extendr� r� r� r� rB � uid_forced� gid_forcedr� rx rz r �timer{ r� r Zinitr r� rl r Z migrate_lockr r� r r �close)r0 Z mountpointZ mount_optionsZ foregroundr� r� r� Zdir_uidZdir_gidZdir_modeZold_idZnew_idZumount�signalr r r �mount# s: ! zFuseOperations.mountc C sN | j � }|dk r4tf | jj� �| j|< || j| _n | j| j|< || j|< |S )zCreate directory N)�allocate_inoder r{ Zas_dictro r� rs )r0 rs r� Zinor r r r� p s zFuseOperations._create_dirc s� i | _ tj� }t| j| j| j|| jjd�}| jj }t j | jj | jj �}|j� pR|��r\i nd� � �fdd�}t j|||�}x�| jj|jj|| jjd�D ]�\} } |r�tjj| jjtj�|d� �| _tj| j�} tj| j �} | �ry| j | |�} W n t k �r Y nX | | j| < q�|| jd� }d}x"|dd � D ]}| j ||�}�q6W | j |d | ||| | � |� q�W tj� | }t!j"d||j#� dS ) z9Build FUSE inode hierarchy from archive metadata )r] Nc sD �r@| r@t | j�r@| jdd�r@d| kr@| jd�d f� | jd�< d S )NZhardlink_masterT�sourcer- �path)r r� r< )r_ Zmatched)�hardlink_masters�partial_extractr r � peek_and_store_hardlink_masters� s zGFuseOperations.process_archive.<locals>.peek_and_store_hardlink_masters)r\ r] � /r z8fuse: process_archive completed in %.1f s for archive %s���r� )$� file_versionsr� Z perf_counterr rl r^ rn rm r] �strip_componentsr Z build_matcherZpatterns�paths�emptyZ build_filterr} ra Zmetadataro rv �sep�joinr� r� r� r� �S_ISDIRr� � _find_inode�KeyError� process_inner� process_leafr� r� r� )r0 � archive_namer Zt0r� r� Zmatcherr� r\ � item_inoder_ r� �is_dirrG �segmentsrs �segmentZdurationr )r� r� r r� | s> z FuseOperations.process_archivec s� |j } |` |pi }� fdd�} d dd�} d|ko8t|j��r,tjj|jjtj�|d � �} |j|jd | f�\} }|r�tj |�}� j r�� j | }| ||dd�}y� j ||�}W n" t k r� tjd | | � d S X � j|�}|jd d �d |_|� j|< n2| d k �r0| |_|}|� j|< |�r0d | f||j< n|}� j �r~| �r~� j||�}tj | �}| ||�}|d k �r~| ||�}|� j |< |� j|< |�r�|� j| |< d S ) Nc sf d| krbt |�}� jj|d�\}}dd� | jD �}t dj|��}||kr^|d7 }||f� j|< |S d S )Nr- r c S s g | ]\}}}|�qS r r )r� rI r" r r r � <listcomp>� s zEFuseOperations.process_leaf.<locals>.file_version.<locals>.<listcomp>rN r )r N)r r� r< r- r� )r_ r� Zfile_idZcurrent_versionZ previous_idZ chunk_idsZ contents_id)r0 r r � file_version� s z1FuseOperations.process_leaf.<locals>.file_versionFc S sJ |r | j dd�}| d|d 7 } tjj| �\} }tjd| �}| | | S )Nr� r z.%05dr� )�rsplitrv r� �splitextr� )r� �version�add_dirZ path_fnameZextZ version_encr r r �make_versioned_name� s z8FuseOperations.process_leaf.<locals>.make_versioned_namer� T)r� z#Skipping broken hard link: %s -> %s�nlinkr )F)r� r r� rv r� r� r� r� r< r� r� r� r� r� r� �warning�get_itemr� ro r- r� rs ru )r0 r� r_ rs r r� r� r� Zstripped_componentsr� r� r� r� r- Z link_targetr� rG Zenc_pathr )r0 r r� � sL zFuseOperations.process_leafc C s6 | j | }||kr || }n| j|�}|r2|||< |S )N)ru r� )r0 r� � parent_inode�dirrG r r r r� � s z FuseOperations.process_innerc C s | j d7 _ | j S )Nr )rr )r0 r r r r� � s z FuseOperations.allocate_inodec C sL t j� }d|_d|_d|_d|_d|_d|_d|_d|_ t |d�rHd|_ |S )Ni r � f_namemax� ) r Z StatvfsData�f_bsize�f_frsize�f_blocks�f_bfree�f_bavail�f_files�f_ffree�f_favail�hasattrr� )r0 �ctxZstat_r r r �statfs� s zFuseOperations.statfsc C sR | j j|�}|d k r|S y | j| S tk rL | jj|�}|| j |< |S X d S )N)rq r< ro r� r} )r0 rG r_ r r r r� s zFuseOperations.get_itemc C s2 ||j d� }d}x|D ]}| j| | }qW |S )Nr� r )r� ru )r0 r� r r� rG r� r r r r� s zFuseOperations._find_inodec C s\ | j |�}tj� }||_d|_d|_d|_|j| j @ |_ |j dd�|_ | j d k rX| j n|j dkrh|j n| j|_| jd k r�| jn|jdkr�|jn| j|_|j dd�|_|j� |_d|_|j|j d |j |_|j}t�r||_|j d|�|_ |j d|�|_ t �rX|j d |�|_ nF|d |_ |j d|�d |_!|j d|�d |_"t#�rX|j d |�d |_$|S ) Nr i, r� r Zrdevi ZatimeZctimeZ birthtimeg e��A)%r� r �EntryAttributes�st_inoZ generationZ entry_timeoutZ attr_timeoutr� r� �st_moder< �st_nlinkr� r� rx �st_uidr� r� rz �st_gid�st_rdevZget_sizer� � st_blksize� st_blocksr� �have_fuse_xtime_nsr � st_atime_ns� st_ctime_ns�have_fuse_birthtime_nsr �st_mtime�st_atime�st_ctime�have_fuse_birthtimer )r0 rG r� r_ �entryZmtime_nsr r r �getattr s6 (( zFuseOperations.getattrc C s | j |�}|jdi �j� S )N�xattrs)r� r< �keys)r0 rG r� r_ r r r � listxattr> s zFuseOperations.listxattrc C sF | j |�}y|jdi �| p dS tk r@ tjtj�d �Y nX d S )Nr rN )r� r< r� r � FUSEErrorZENOATTR)r0 rG r� r� r_ r r r �getxattrB s zFuseOperations.getxattrc C s* | j j|d �}|r&| j|tj|�g� d S )N)r| r� r� rv r� )r0 rG r� r r r �_load_pending_archiveI s z$FuseOperations._load_pending_archivec C sV | j |� |dkr|}n4|dkr,| j| }n | j| j|�}|sLtjtj��| j|�S )N� .s ..) r rs ru r< r r �errno�ENOENTr )r0 r� r� r� rG r r r �lookupO s zFuseOperations.lookupc C s2 | j s.| j|�}d|kr.tjd� tjtj��|S )NZchunks_healthyzzFile has damaged (all-zero) chunks. Try running borg check --repair. Mount with allow_damaged_files to read damaged files.)r� r� r� r� r r r ZEIO)r0 rG �flagsr� r_ r r r �open[ s zFuseOperations.openc C s | j |� |S )N)r )r0 rG r� r r r �opendirg s zFuseOperations.opendirc C sT g }| j |�}| jj|d�\}}||kr0d\}}||8 }|j}�xt|t|��D ]�} || \} } } | |k r�|| 8 }|| 7 }|d7 }qPt|| | �} | | jkr�| j| }|| t|�kr�| j| = n0| jj | | j j| ��}|| t|�k r�|| j| < |j |||| � � d}|| 8 }|sP|| jk�r6| jj |||f� n||f| j|< P qPW dj |�S )Nr r rN )r r )r r )r� r� r< r- �rangerO �minr� r^ Zdecryptrl �appendZupdr� )r0 �fhr* rh �partsr_ Zchunk_norH r- r� �id�srK r� rL r r r �readk s> zFuseOperations.readc c sh d|fd| j | fg}|j| j| j� � x8t||d � |�D ]"\}\}}|| j|�|d fV q>W d S )Nr s ..r )rs r� ru ro r� r )r0 r ZoffZentries�ir� rG r r r �readdir� s zFuseOperations.readdirc C s | j |�}tj|j�S )N)r� rv r� r� )r0 rG r� r_ r r r �readlink� s zFuseOperations.readlink)F)N)N)N)N)N)N)N)N)N) rb rc rd re r� r� r� r� r� r1 r� r� r� r� r� r� r� r� r� r� r� r r r r r r r r r r � __classcell__r r )r� r rj � s8 M ,G +rj ).r rE rv r� rf r� r+ r� � collectionsr r� r r r� r Zcrypto.low_levelr Zarchiverr r� r Z hashindexr Zhelpersr r r r r r r_ r Zlrucacher Zremoter r� r� r� r r� r rp r Z Operationsrj r r r r �<module> s: +
Submit
FILE
FOLDER
Name
Size
Permission
Action
__init__.cpython-36.opt-1.pyc
289 bytes
0644
__init__.cpython-36.pyc
719 bytes
0644
__main__.cpython-36.opt-1.pyc
165 bytes
0644
__main__.cpython-36.pyc
165 bytes
0644
_version.cpython-36.opt-1.pyc
133 bytes
0644
_version.cpython-36.pyc
133 bytes
0644
archive.cpython-36.opt-1.pyc
61040 bytes
0644
archive.cpython-36.pyc
61249 bytes
0644
archiver.cpython-36.opt-1.pyc
177490 bytes
0644
archiver.cpython-36.pyc
178018 bytes
0644
cache.cpython-36.opt-1.pyc
40019 bytes
0644
cache.cpython-36.pyc
40279 bytes
0644
constants.cpython-36.opt-1.pyc
1870 bytes
0644
constants.cpython-36.pyc
1915 bytes
0644
fuse.cpython-36.opt-1.pyc
17457 bytes
0644
fuse.cpython-36.pyc
17531 bytes
0644
helpers.cpython-36.opt-1.pyc
81995 bytes
0644
helpers.cpython-36.pyc
82837 bytes
0644
locking.cpython-36.opt-1.pyc
13814 bytes
0644
locking.cpython-36.pyc
13888 bytes
0644
logger.cpython-36.opt-1.pyc
7593 bytes
0644
logger.cpython-36.pyc
7593 bytes
0644
lrucache.cpython-36.opt-1.pyc
1994 bytes
0644
lrucache.cpython-36.pyc
2191 bytes
0644
nanorst.cpython-36.opt-1.pyc
5565 bytes
0644
nanorst.cpython-36.pyc
5669 bytes
0644
patterns.cpython-36.opt-1.pyc
13541 bytes
0644
patterns.cpython-36.pyc
13541 bytes
0644
remote.cpython-36.opt-1.pyc
36814 bytes
0644
remote.cpython-36.pyc
37012 bytes
0644
repository.cpython-36.opt-1.pyc
49853 bytes
0644
repository.cpython-36.pyc
50395 bytes
0644
selftest.cpython-36.opt-1.pyc
3406 bytes
0644
selftest.cpython-36.pyc
3566 bytes
0644
shellpattern.cpython-36.opt-1.pyc
1775 bytes
0644
shellpattern.cpython-36.pyc
1775 bytes
0644
upgrader.cpython-36.opt-1.pyc
12017 bytes
0644
upgrader.cpython-36.pyc
12017 bytes
0644
version.cpython-36.opt-1.pyc
1948 bytes
0644
version.cpython-36.pyc
1948 bytes
0644
xattr.cpython-36.opt-1.pyc
11749 bytes
0644
xattr.cpython-36.pyc
11749 bytes
0644
N4ST4R_ID | Naxtarrr
