File: //lib64/python3.9/site-packages/borg/platform/__pycache__/base.cpython-39.opt-1.pyc
a
HZ�h}* � @ sr d dl Z d dlZd dlZd dlZd dlmZ d dlmZ dZe edej
�Z ddl m
Z
dd �d
d �Zdd �d d
�Zdd �dd�Zd0dd�Zd1dd�Zzd dlmZ d2dd�ZW n ey� d3dd�ZY n0 d4dd�Zdd� Zd d � ZG d d � d �ZG d d!� d!�Zd"d#� Zd5d%d&�Z e� � Z e e �Z e � d'�d Z ej!�"d(�Z#e#�sVe � d)e�$� � �Z#d*d+� Z%d,d-� Z&d.d/� Z'dS )6� N)� safe_unlink)�is_win32z1.2_05� fdatasync� )�ENOATTRF)�follow_symlinksc C s g S )a
Return xattr names of a file (list of bytes objects).
*path* can either be a path (bytes) or an open file descriptor (int).
*follow_symlinks* indicates whether symlinks should be followed
and only applies when *path* is not an open file descriptor.
� )�pathr r r �8/usr/lib64/python3.9/site-packages/borg/platform/base.py� listxattr s r c C s t tt�t�| ��dS )a:
Read xattr and return its value (as bytes).
*path* can either be a path (bytes) or an open file descriptor (int).
*name* is the name of the xattr to read (bytes).
*follow_symlinks* indicates whether symlinks should be followed
and only applies when *path* is not an open file descriptor.
N)�OSErrorr �os�strerror)r �namer r r r
�getxattr' s r c C s dS )aP
Write xattr on *path*.
*path* can either be a path (bytes) or an open file descriptor (int).
*name* is the name of the xattr to read (bytes).
*value* is the value to write (bytes).
*follow_symlinks* indicates whether symlinks should be followed
and only applies when *path* is not an open file descriptor.
Nr )r r �valuer r r r
�setxattr5 s r c C s dS )zl
Saves ACL Entries
If `numeric_ids` is True the user/group field is not preserved only uid/gid
Nr )r �item�st� numeric_ids�fdr r r
�acl_getA s r c C s dS )zz
Restore ACL Entries
If `numeric_ids` is True the stored uid/gid is used instead
of the user/group names
Nr )r r r r r r r
�acl_setI s r ��lchflagsc C s t | |� d S �Nr �r Z bsd_flagsr r r r
� set_flagsU s r c C s d S r r r r r r
r X s c C s t |dd�S )zHReturn BSD-style file flags for path or stat without following symlinks.�st_flagsr )�getattr)r r r r r r
� get_flags\ s r c
C sx t rd S t�| tj�}zPzt�|� W n2 tyX } z|jtjkrD� W Y d }~n
d }~0 0 W t�|� n t�|� 0 d S r ) r r
�open�O_RDONLY�fsyncr �errno�EINVAL�close)r r Zos_errorr r r
�sync_dira s r' c C sD t td�r@ttd| �}zt�| |||� W n ty> Y n0 d S )N�
posix_fadviseZ POSIX_FADV_)�hasattrr
r r( r )r �offset�lenZadvicer r r
� safe_fadviser s
r, c @ sH e Zd ZdZddd�dd�Zdd� Zd d
� Zd d � Zd
d� Zdd� Z dS )�SyncFilea(
A file class that is supposed to enable write ordering (one way or another) and data durability after close().
The degree to which either is possible varies with operating system, file system and hardware.
This fallback implements a naive and slow way of doing this. On some operating systems it can't actually
guarantee any of the above, since fsync() doesn't guarantee it. Furthermore it may not be possible at all
to satisfy the above guarantees on some hardware or operating systems. In these cases we hope that the thorough
checksumming implemented catches any corrupted data due to misordered, delayed or partial writes.
Note that POSIX doesn't specify *anything* about power failures (or similar failures). A system that
routinely loses files or corrupts file on power loss is POSIX compliant.
Calling SyncFile(path) for an existing path will raise FileExistsError, see comment in __init__.
TODO: Use F_FULLSYNC on OSX.
TODO: A Windows implementation should use CreateFile with FILE_FLAG_WRITE_THROUGH.
NF�r �binaryc C sJ |rdnd}|| _ |du r*t||d�| _ntj||d�| _| j�� | _dS )aJ
Open a SyncFile.
:param path: full path/filename
:param fd: additionally to path, it is possible to give an already open OS-level fd
that corresponds to path (like from os.open(path, ...) or os.mkstemp(...))
:param binary: whether to open in binary mode, default is False.
�xb�xN)�mode)r r! �fr
�fdopen�filenor )�selfr r r/ r2 r r r
�__init__� s zSyncFile.__init__c C s | S r r )r6 r r r
� __enter__� s zSyncFile.__enter__c C s | � � d S r )r& )r6 �exc_type�exc_val�exc_tbr r r
�__exit__� s zSyncFile.__exit__c C s | j �|� d S r )r3 �write)r6 �datar r r
r= � s zSyncFile.writec C s6 ddl m} | j�� |�| j� t| jddd� dS )z�
Synchronize file contents. Everything written prior to sync() must become durable before anything written
after sync().
� ��platformr ZDONTNEEDN)� rA r3 �flushr r r, )r6 rA r r r
�sync� s
z
SyncFile.syncc C sb ddl m} d}z2tj�| j�}| �� W | j�� |r^|�|� n| j�� |r\|�|� 0 dS )zsync() and close.r? r@ N) rB rA r
r �dirnamerD r3 r& r' )r6 rA rE r r r
r& � s
�
zSyncFile.close)
�__name__�
__module__� __qualname__�__doc__r7 r8 r< r= rD r& r r r r
r- � s r- c @ s* e Zd ZdZd
dd�Zdd� Zdd� Zd S ) �SaveFilea�
Update file contents atomically.
Must be used as a context manager (defining the scope of the transaction).
On a journaling file system the file contents are always updated
atomically and won't become corrupted, even on power failures or
crashes (for caveats see SyncFile).
SaveFile can safely by used in parallel (e.g. by multiple processes) to write
to the same target path. Whatever writer finishes last (executes the os.replace
last) "wins" and has successfully written its content to the target path.
Internally used temporary files are created in the target directory and are
named <BASENAME>-<RANDOMCHARS>.tmp and cleaned up in normal and error conditions.
Fc C sB || _ || _tj�|�| _tj�|�d | _d | _d | _d | _ d S )N�-)
r/ r r
rE �dir�basename�
tmp_prefix�tmp_fd� tmp_fnamer3 )r6 r r/ r r r
r7 � s zSaveFile.__init__c C sR ddl m} ddlm} || jd| jdd�\| _| _|j| j| j| j d�| _
| j
S )Nr? r@ )� mkstemp_modez.tmpi� )�prefix�suffixrL r2 r. ) rB rA Z
helpers.fsrQ rN rL rO rP r- r/ r3 )r6 rA rQ r r r
r8 � s
zSaveFile.__enter__c C s� ddl m} | j�� d | _|d ur2t| j� d S zDzt�| j| j � W n t
yf t| j� � Y n0 W |� | j � n|� | j � 0 d S )Nr? r@ )
rB rA r3 r& rO r rP r
�replacer r r' rL )r6 r9 r: r; rA r r r
r< � s
zSaveFile.__exit__N)F)rF rG rH rI r7 r8 r< r r r r
rJ � s
rJ c C s t | �S )z}terminal output width of string <s>
For western scripts, this is just len(s), but for cjk glyphs, 2 cells are used.
)r+ )�sr r r
�swidth� s rV rB c C sn | � � } | r| dkr t�� } z t�| ddtjdtj�}W n tyJ Y n 0 |D ]}|d rP|d } qjqP| S )zpGet fully qualified domain name from name.
An empty argument is interpreted as meaning the local host.
z0.0.0.0Nr � )�strip�socket� gethostnameZ getaddrinfoZ
SOCK_DGRAMZ AI_CANONNAMEr )r �addrs�addrr r r
�getfqdn s r] �.Z BORG_HOST_ID�@c C s d} t �� }t|| fS )z�
Return identification tuple (hostname, pid, thread_id) for 'us'.
This always returns the current pid, which might be different from before, e.g. if daemonize() was used.
Note: Currently thread_id is *always* zero.
r )r
�getpid�hostid)Z thread_id�pidr r r
�get_process_id( s rc c C s t �dS )ze
Check if the (host, pid, thread_id) combination corresponds to a potentially alive process.
N��NotImplementedError)�hostrb �threadr r r
�
process_alive4 s rh c C s t �dS )z Return whether *pid* is alive.Nrd )rb r r r
�local_pid_alive; s ri )FN)FN)N)N)N)rB )(r$ r
rY ZuuidZ borg.helpersr Zborg.platformflagsr Z API_VERSIONr r# r Zxattrr r r r r r r r � ImportErrorr r' r, r- rJ rV r] rZ �hostnameZfqdn�split�environ�getra Zgetnoderc rh ri r r r r
�<module> sD
G2