One Hat Cyber Team
Your IP :
216.73.216.183
Server IP :
23.137.84.82
Server :
Linux srv25.usacloudserver.us 5.14.0-570.39.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Sep 4 05:08:52 EDT 2025 x86_64
Server Software :
LiteSpeed
PHP Version :
8.1.33
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib64
/
python3.9
/
site-packages
/
borg
/
__pycache__
/
View File Name :
fuse.cpython-39.pyc
a HZ�h_� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m Z d dl m Z ddl mZmZ er�d dlZdd� Zn dZdd� Zdd lmZ e� Zdd lmZ dd lmZ dd lmZmZ dd lm Z ddl m Z m Z m Z m!Z!m"Z"m#Z# ddl m$Z$ ddl%m&Z& ddl'm(Z( ddl)m*Z*m+Z+ ddl,m-Z- ddl.m/Z/ dd� Z0dZ1G dd� d�Z2G dd� d�Z3G d d � d ej4e3�Z5dS ) � N)� defaultdict)�SIGINT� )�llfuse� has_pyfuse3c s t �� �� fdd��}|S )Nc � s � | i |��S �N� )�args�kwargs��fnr �//usr/lib64/python3.9/site-packages/borg/fuse.py�wrapper s z async_wrapper.<locals>.wrapper)� functools�wraps)r r r r r � async_wrapper s r c C s | S r r r r r r r s )� create_logger)� blake2b_128)�Archiver)�Archive�get_item_uid_gid)�FuseVersionsIndex)� daemonize� daemonizing� hardlinkable�signal_handler�format_file_size�Error)�msgpack)�Item)�LRUCache)�uid2user� gid2group)� is_darwin)�RemoteRepositoryc C s: t r*zt�tj� W n Y dS 0 d S n tjdd�S d S )Nr )�workers)r �trio�runr �mainr r r r � fuse_main/ s r) � c @ sF e Zd ZdZdZe�d�Zejdks(J �dd� Z dd� Z d d 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 r r ��_r r r �<lambda>s � z$ItemCache.__init__.<locals>.<lambda>�ZcapacityZdispose) �decrypted_repository� bytearray�meta� write_offset�offset�tempfileZ TemporaryFile�fdr �chunks�indirect_items� direct_items)�selfr4 r r r �__init__U s zItemCache.__init__c C s( || j }|dk rtd��| j| td�kr�| j�| j|�\}}}|| }t| j||d � �}| j�|�}|s�t | j � |g��\} }|| j|< t |�|d � } t �� } | �| � tt | �d�S | j| td�k�r t�| j|d |d � d �} | j�| tj� tt t j| jd d ��d�S td ��d S ) Nr z3ItemCache.get() called with an invalid inode number� I� �Z internal_dict� Sr r, �littlei )Z read_sizez Invalid entry type in self.meta)r8 � ValueErrorr6 �ord�indirect_entry_struct� unpack_from�bytesr; �get�nextr4 �get_many� memoryviewr �Unpacker�feedr �int� from_bytesr: �seek�io�SEEK_SET) r> �inoder8 r0 Zchunk_id_relative_offset� chunk_offsetZchunk_id_offset�chunk_id�chunk�csize�data�unpackerZ fd_offsetr r r rJ { s( z ItemCache.getNFc c s0 t �� }d}d}d}d}| j} | j} | jj} t|| j�|��D �]�\} \} }| d t | �krp| t | j � | _} | | | | d �< | }| d7 } ||7 }t |�}|� |� z|� � }d}W n t jy� d}Y n0 || }|r�t |�| n |�� | }||||| � 7 }||7 }|�rq>t|d�}|�r2||��rB|�sHd|v �rHd}q�|}t |�}|| |k }d}| d t | �k�r�| t | j � | _} |�r�| j�dtj�}| j�|� d |�d d � | | | d �< | jd 7 _n.|| | }| | | d | | |� | jd 7 _| | j }| d7 } ||fV q�q>| | _d S )Nr r2 rA FTrB �partr, rC � rD r r@ )r rN r7 r6 rG � pack_into�zipr4 rL �lenrI � GROW_META_BYrO �unpackZ OutOfData�tellr r: rR rS �SEEK_END�write�to_bytesr= r< r8 )r> Zarchive_item_ids�filter�consider_part_filesr[ Z stream_offsetZ chunk_beginZlast_chunk_lengthZmsgpacked_bytesr7 r6 Zpack_indirect_into�keyrY rZ Zcurrent_id_offset�itemZneed_more_data�start�lengthZ current_itemZcurrent_item_lengthZcurrent_spans_chunks�posZ item_offsetrU r r r �iter_archive_items� sd z ItemCache.iter_archive_items)NF) �__name__� __module__� __qualname__�__doc__ra �struct�StructrG �sizer? rJ rn r r r r r+ B s &r+ c @ sj e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zdd d�Z g fdd�Z g fdd�Z dd� Z dd� Z d S )� FuseBackendzJVirtual filesystem based on archive(s) to provide information to fuse c C s� || _ || _|j| _|| _|| _i | _ttdd� d�| _d| _ i | _ t t �| _ t�� | _t�� | _d | _i | _t|�| _d| _d| _d | _d | _d| _d S )Nc S s d S r r r/ r r r r1 � r2 z&FuseBackend.__init__.<locals>.<lambda>r3 r F) �repository_uncached�_args� numeric_ids� _manifestri �_itemsr �FILES� _inode_cache� inode_count�parentr �dict�contents�os�getuid� default_uid�getgid� default_gid� default_dir�pending_archivesr+ �cache�allow_damaged_files�versions� uid_forced� gid_forced�umask)r> ri �manifest� repositoryr r4 r r r r? � s( zFuseBackend.__init__c C s� | j dd� | jjjr6| jr$td��| �| jjj� npt� | _| j j � | j�D ]V}| jrf| �|j � qN| j dt |j�� d �d�}|| jd t�|j �< |j | j|< qNd S )Nr )r z_for versions view, do not specify a single archive, but always give the repository as location.� e��A)r �mtime)� _create_dirrx �location�archiver� r �_process_archiver �versions_indexrz ZarchivesZlist_considering�namerP �tsZ timestampr� r� �fsencoder� )r> r� Z archive_inoder r r �_create_filesystem s z FuseBackend._create_filesystemc C sV | j �|�}|d ur|S z | j| W S tyP | j�|�}|| j |< | Y S 0 d S r )r} rJ r{ �KeyErrorr� )r> rU rj r r r �get_item$ s zFuseBackend.get_itemc C s. | j �|d �}|d ur*| �|t�|�g� d S r )r� �popr� r� r� )r> rU � archive_namer r r �check_pending_archive1 s z!FuseBackend.check_pending_archivec C s | j d7 _ | j S )Nr )r~ �r> r r r �_allocate_inode7 s zFuseBackend._allocate_inodeNc C sN | � � }|dur4t| j�� d�| j|< || j| _n | j| j|< || j|< |S )zCreate directory NrB )r� r r� Zas_dictr{ r� r )r> r r� �inor r r r� ; s zFuseBackend._create_dirc C s. ||� d� }d}|D ]}| j| | }q|S )N� /r )�splitr� )r> �pathr- �segmentsrU �segmentr r r � find_inodeG s zFuseBackend.find_inodec s� i | _ t�� }t| j| j| j|| jjd�}| jj }t � | jj | jj �}|�� pR|��r\i nd� � �fdd�}t �|||�}| jj|jj|| jjd�D ]�\} } |r�tj�| j�tj�|d� �| _t�| j�} t�| j �} | �rz| � | |�} W n t �y Y n0 | | j | < q�|| �d� }d}|dd� D ]}| � ||�}�q0| �!|d | ||| | � |� q�t�� | }t"�#d ||j$� dS ) z9Build FUSE inode hierarchy from archive metadata )rh Nc sB �r>|s>t | j�r>| �dd�r>d| vr>| �d�d f� | �d�< d S )NZhardlink_masterT�sourcer; r� )r �moderJ )rj Zmatched��hardlink_mastersZpartial_extractr r � peek_and_store_hardlink_mastersZ s ��zEFuseBackend._process_archive.<locals>.peek_and_store_hardlink_masters)rg rh r� r ���z9fuse: _process_archive completed in %.1f s for archive %s)%� file_versions�time� perf_counterr rw ri rz rx rh �strip_componentsr Z build_matcher�patterns�paths�emptyZ build_filterr� rn �metadata�itemsr� �sep�joinr� r� r� �stat�S_ISDIRr� r� r� r{ �_process_inner� _process_leaf�logger�debugr� )r> r� r- Zt0r� r� Zmatcherr� rg � item_inoderj r� �is_dirrU r� r r� Zdurationr r� r r� N sD � � � z FuseBackend._process_archivec s� |j } |` |pi }� fdd�} d dd�} d|v �r0t|j��r0tj�|j�tj�|d � �} |�|jd | f�\} }|� r�t� |�}� j r�� j | }| ||dd�}z� � ||�}W n" t y� t�d | | � Y d S 0 � �|�}|�d d �d |_|� j|< n2| d u�r4| |_|}|� j|< |�r4d | f||j< n|}� j �r�|�s�� �||�}t� | �}| ||�}|d u�r�| ||�}|� j |< |� j|< |�r�|� j| |< d S ) Nc sb d| v r^t |�}� j�|d�\}}t d�dd� | jD ���}||krZ|d7 }||f� j|< |S d S )Nr; )r Nr2 c s s | ]\}}}|V qd S r r )�.0rW r0 r r r � <genexpr>� r2 zBFuseBackend._process_leaf.<locals>.file_version.<locals>.<genexpr>r )r r� rJ r� r; )rj r� Zfile_idZcurrent_versionZ previous_idZ contents_idr� r r � file_version s z/FuseBackend._process_leaf.<locals>.file_versionFc S sJ |r | � dd�}| d|d 7 } tj�| �\} }t�d| �}| | | S )Nr� r r� z.%05d)�rsplitr� r� �splitextr� )r� �version�add_dirZ path_fname�extZ version_encr r r �make_versioned_name� s z6FuseBackend._process_leaf.<locals>.make_versioned_namer� T)r� z#Skipping broken hard link: %s -> %s�nlinkr )F)r� r r� r� r� r� r� r� rJ r� r� r� r� r� r� �warningr� r� r{ r; r� r r� )r> r� rj r r- r� r� r� Zstripped_componentsr� r� r� r� r; Z link_targetr� rU Zenc_pathr r� r r� z sL zFuseBackend._process_leafc C s6 | j | }||v r || }n| �|�}|r2|||< |S r )r� r� )r> r� � parent_inode�dirrU r r r r� � s zFuseBackend._process_inner)N)ro rp rq rr r? r� r� r� r� r� r� r� r� r� r r r r rv � s ,Frv c @ s� e Zd ZdZdd� Zdd� Zd!dd�Zed"d d ��Zd#d d �Z ed$dd��Z ed%dd��Z ed&dd��Z ed'dd��Z ed(dd��Zed)dd��Zedd� �Zer�d d � Znd d � Zed*d d ��Zd S )+�FuseOperationsz(Export archive as a FUSE filesystem c C st t j�| � t�| |||||� || _ttj�dt� � p:d��}t � d|� t |dd� d�| _ t tdd� d�| _d S )NZ BORG_MOUNT_DATA_CACHE_ENTRIESr z$mount data cache capacity: %d chunksc S s d S r r r/ r r r r1 � r2 z)FuseOperations.__init__.<locals>.<lambda>r3 c S s d S r r r/ r r r r1 � r2 )r � Operationsr? rv r4 rP r� �environrJ � cpu_countr� r� r � data_cacher| � _last_pos)r> ri r� r� r r4 Zdata_cache_capacityr r r r? � s zFuseOperations.__init__c C s� t �d| jt| j�tt�| j�t| j�t�| j� �� t �dt| j�� t �d| j j | j j | j j | j j tt�| j j ��tt �| j j�� �j�� t �dt| j�� �| jjttdd� | j�� D ���� | j�� 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 r )r` )r� ri rX r r r r� � r2 z2FuseOperations.sig_info_handler.<locals>.<genexpr>)r� r� r~ r` r r �sys� getsizeofr� r� r= r< r6 r� r� r: �fileno�st_sizer� r� Z _capacity�sumr4 Zlog_instrumentation)r> Zsig_no�stackr r r �sig_info_handler� s $���z FuseOperations.sig_info_handlerFc C s� d dd�}g d�}|r&|� |�d�� tr`||dddt�}|pNtj�|�� d�}|�d |� �� ||d d d t�}|r�||d d d t� ||dd d t�| _ ||dd d t�| _ ||dddt �| _ ||dddt �| _ ||dddt dd�| _| j dur�| j n| j}| j du�r | j n| j} t|�} t| �} t| t��s0J �t| t��s@J �d| j @ } t| t t�� d �| | || d�| _| �� t�| ||� |�s�t| jt��r�t � nDt � �,\} }t � d� | j� | |� W d � n1 �s�0 Y d }z�t!d| j"��D t!d| j"�� t#� }W d � n1 �s"0 Y W d � n1 �sB0 Y |du �pb|t$k�ob|}W t�%|� n t�%|� 0 dS ) z6Mount filesystem on *mountpoint* with *mount_options*.r c S s t | t�sJ �t| �D ]�\}}||kr8| �|� | S |�|d �r| �|� |�dd�d }|tu r�|�� } | dv r~ dS | dv r� dS td| ��|t u r�zt ||d�W S ty� td| �d �Y n0 z||�W S t�y td| �d �Y q0 q|S ) N�=r )�yZyes�true�1T)�n�noZfalse�0Fz unsupported value in option: %s)�base) � isinstance�list� enumerater� � startswithr� �bool�lowerrE rP ) �optionsri ZpresentZ not_presentZ wanted_type�int_base�idx�option�value�vr r r � pop_option� s2 z(FuseOperations.mount.<locals>.pop_option)z fsname=borgfs�ro�default_permissions�,�volname� z (borgfs)zvolname=�ignore_permissionsTFr� r� r� �uidN�gidr� r] )r� i�A r� )r� r� �user�groupr� r� z<fuse: mount local repo, going to background: migrating lock.�SIGUSR1ZSIGINFO)r )&�extendr� r# �strr� r� �basename�appendr� r� r� rP r� r� r� r� r� r! r" r� r r� r� r� r �initrw r$ r r r� r� Z migrate_lockr r� r) r �close)r> Z mountpointZ mount_optionsZ foregroundr� r� r� r� Zdir_uidZdir_gidZdir_userZ dir_groupZdir_modeZold_idZnew_idZumount�signalr r r �mount� sT ! � . �FzFuseOperations.mountNc C sB t �� }d|_d|_d|_d|_d|_d|_d|_d|_ d|_ |S )N� r � ) r Z StatvfsData�f_bsize�f_frsize�f_blocks�f_bfree�f_bavail�f_files�f_ffree�f_favail� f_namemax)r> �ctxZstat_r r r �statfsC s zFuseOperations.statfsc C s� | � |�}t�� }||_d|_d|_d|_|j| j @ |_ |� dd�|_ t || j | j| j| j| jd�\|_|_|� dd�|_|�� |_d|_|j|j d |j |_|j |_}|� d|�|_|� d |�|_ |� d |�|_ |S ) Nr i, r� r )ZnumericZ uid_defaultZ gid_defaultr� r� Zrdevr Zatime�ctimeZ birthtime) r� r ZEntryAttributes�st_inoZ generationZ entry_timeoutZ attr_timeoutr� r� �st_moderJ �st_nlinkr ry r� r� r� r� �st_uid�st_gid�st_rdevZget_sizer� � st_blksize� st_blocksr� � st_mtime_ns� st_atime_ns� st_ctime_nsZst_birthtime_ns)r> rU r rj �entryZmtime_nsr r r �_getattrQ s* � zFuseOperations._getattrc C s | j ||d�S )N)r )r �r> rU r r r r �getattrh s zFuseOperations.getattrc C s | � |�}|�di ��� S )N�xattrs)r� rJ �keys�r> rU r rj r r r � listxattrl s zFuseOperations.listxattrc C sF | � |�}z|�di �| p dW S ty@ t�tj�d �Y n0 d S )Nr" r2 )r� rJ r� r � FUSEErrorZENOATTR)r> rU r� r rj r r r �getxattrq s zFuseOperations.getxattrc C sV | � |� |dkr|}n4|dkr,| j| }n | j| �|�}|sLt�tj��| �|�S )N� .� ..) r� r r� rJ r r& �errno�ENOENTr )r> r� r� r rU r r r �lookupy s zFuseOperations.lookupc C sB | j s.| �|�}d|v r.t�d� t�tj��tr>tj |d�S |S )NZchunks_healthyzzFile has damaged (all-zero) chunks. Try running borg check --repair. Mount with allow_damaged_files to read damaged files.)�fh) r� r� r� r� r r& r* ZEIOr ZFileInfo)r> rU �flagsr rj r r r �open� s zFuseOperations.openc C s | � |� |S r )r� r r r r �opendir� s zFuseOperations.opendirc C sR g }| � |�}| j�|d�\}}||kr0d\}}||8 }|j}t|t|��D ]�} || \} } } | |k r�|| 8 }|| 7 }|d7 }qLt|| | �} | | jv r�| j| }|| t|�kr�| j| = n0| j� | | j �| ��}|| t|�k r�|| j| < |� |||| � � d}|| 8 }|sL|| jv �r2| j� |||f� n||f| j|< �qHqLd� |�S )N)r r r r r2 )r� r� rJ r; �ranger` �minr� ri Zdecryptrw r Zupdr� )r> r- r8 ru �partsrj Zchunk_norV r; r� �id�srY r� rZ r r r �read� s> zFuseOperations.readc � sp d|fd| j | fg}|�| j| �� � t||d � |�D ].\}\}}| �|�}t�||||d �s< qlq<d S �Nr( r) r )r r� r� r� r� r r Z readdir_reply) r> r- �off�token�entries�ir� rU �attrsr r r �readdir� s zFuseOperations.readdirc c sh d|fd| j | fg}|�| j| �� � t||d � |�D ]&\}\}}| �|�}|||d fV q<d S r7 )r r� r� r� r� r )r> r- r8 r: r; r� rU r< r r r r= � s c C s | � |�}t�|j�S r )r� r� r� r� r$ r r r �readlink� s zFuseOperations.readlink)F)N)N)N)N)N)N)N)N)N)ro rp rq rr r? r� r r r r r! r% r' r, r/ r0 r6 r r= r> r r r r r� � s4 \ , r� )6r* r rS r� r� rs r� r9 r� � collectionsr r r Z fuse_implr r r& r r� r Zcrypto.low_levelr Zarchiverr r� r r Z hashindexr Zhelpersr r r r r r r rj r Zlrucacher �platformr! r" Z platformflagsr# Zremoter$ r) r| r+ rv r� r� r r r r �<module> sH - ^