|
Server : Apache System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64 User : dh_edsupp ( 6597262) PHP Version : 8.2.26 Disable Function : NONE Directory : /lib/python3/dist-packages/duplicity/__pycache__/ |
Upload File : |
o
�~�_= � @ s d Z ddlmZ ddlmZ e�� ddlmZ ddlZddl Z ddl
Z
ddl m Z ddl m
Z
ddl mZ dd l mZ dd
l mZ dd l mZ d d
� ZG dd� de
j�Zd dd�Zdd� ZG dd� de
j�ZG dd� de�ZG dd� de�ZG dd � d e�ZdS ) zManage temporary files� )�print_function)�standard_library)�objectN)�log)�path)� file_naming)�tempdir)�config)�gpgc C s t �� �� } t| �S )z
Return a new TempPath
)r �default�mktemp�TempPath)�filename� r �4/usr/lib/python3/dist-packages/duplicity/dup_temp.py� new_temppath) s r c @ s e Zd ZdZdd� Zdd� ZdS )r
z.
Path object used as a temporary file
c C � t j�| � t�� �| j� dS �z#
Forget and delete
N)r �Path�deleter r �forget�name��selfr r r r 5 � zTempPath.deletec C �" t tj�| |��}|�| j� |S )�F
Returns a fileobj. When that is closed, delete file
)�
FileobjHookedr r �open�addhookr �r �mode�fhr r r �open_with_delete< � zTempPath.open_with_deleteN)�__name__�
__module__� __qualname__�__doc__r r# r r r r r
1 s r
Fc s� t js$t�� j����� �t�t���d��t ��
d��� �||d�}n t j � j�fd�}d}|r3d}t |�
|�d� �||d�}� ����fdd�}t jsR|�
|� |S ) a
Return a file object open for writing, will write to filename
Data will be processed and written to a temporary file. When the
return fileobject is closed, rename to final position. filename
must be a recognizable duplicity data file.
�� parseresults�wb)�tdp�dirpath�partname�permname�remname)�index�abNc s �� � ���� ���� d S �N)�rename�appendr r �r- r. �tdr, �tdpnamer r �rename_and_forget[ s z.get_fileobj_duppath.<locals>.rename_and_forget)r �restartr �TemporaryDirectoryr r � TempDupPathr �parser �
filtered_openr �DupPathr ) r- r. r/ r0 � overwriter" �dpr! r9 r r6 r �get_fileobj_duppathE s$ ��
rB c C s t �� �� }t|| d�S )zD
Return a new TempDupPath, using settings from parseresults
r) )r r r r< )r* r r r r �new_tempduppathe s rC c @ s* e Zd ZdZdd� Zdd� Zd
dd�Zd S ) r< z1
Like TempPath, but build around DupPath
c C r r )r r? r r r r r r r r r r q r zTempDupPath.deletec C r )zO
Returns a filtered fileobj. When that is closed, delete file
)r r r? r> r r r r r r �filtered_open_with_deletex r$ z%TempDupPath.filtered_open_with_delete�rbc C s. |dksJ �t tj�| |��}|�| j� |S )r rE )r r r? r r r r r r r r# � s z TempDupPath.open_with_deleteN)rE )r% r& r' r( r rD r# r r r r r< m s
r< c @ s� e Zd ZdZ d dd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z d dd�Z
dd� Z dd� Z dd� Z
dd� Zdd� Zee�ZdS ) r z0
Simulate a file, but add hook on close
Nc C s4 || _ d| _g | _|| _|| _|| _|| _|| _dS )zF
Initializer. fileobj is the file object to simulate
FN)�fileobj�closed�hooklistr, r- r. r/ r0 )r rF r, r- r. r/ r0 r r r �__init__� s
zFileobjHooked.__init__c C � | j �|�S )z9
Write fileobj, return result of write()
)rF �write)r �bufr r r rK � � zFileobjHooked.writec C s | j �� t�| j �� � dS )z/
Flush fileobj and force sync.
N)rF �flush�os�fsync�filenor r r r rN � s
zFileobjHooked.flushc C s6 t jrJ �| j�| j�| j�� | j�� | j d= dS )zY
We have achieved the first checkpoint, make file visible and permanent.
r N)
r r: r, r4 r- r5 r. rF rN rH r r r r �
to_partial� s
zFileobjHooked.to_partialc C s� t �| j�}| j�| j�}| j�| j�}t|�}|jr&tj ||j
t j d� n|j
r6tj||j
tjt j d� nt�|j
|j
� tj�|� dS )z�
We have written the last checkpoint, now encrypt or compress
and send a copy of it to the remote for final storage.
��sizeN)r r= r0 r- r5 r. �SrcIter�
compressedr
�
GzipWriteFiler �sys�maxsize� encrypted� GPGWriteFiler � gpg_profile�shutil�copyfile�backend�move)r �pr�src�tgt�src_iterr r r � to_remote� s zFileobjHooked.to_remotec C sn | j �| j�}| j �| j�}t|�}t�| j�}|jr-tj ||j
t j d� t
�|j
� dS t
�|j
|j
� dS )zC
We are finished, rename to final, gzip if needed.
rS N)r- r5 r. r/ rU r r= rV r
rW r rX rY rO �unlinkr4 )r rb rc rd ra r r r �to_final� s zFileobjHooked.to_final���c C rJ )z7
Read fileobj, return result of read()
)rF �read)r �lengthr r r ri � rM zFileobjHooked.readc C s
| j �� S )z5
Returns current location of fileobj
)rF �tellr r r r rk � s
zFileobjHooked.tellc C rJ )z0
Seeks to a location of fileobj
)rF �seek)r �offsetr r r rl � rM zFileobjHooked.seekc C s$ | j �� rJ �| jD ]}|� q
dS )z?
Close fileobj, running hooks right afterwards
N)rF �closerH �r �hookr r r rn � s
�zFileobjHooked.closec C s | j �|� dS )zM
Add hook (function taking no arguments) to run upon closing
N)rH r5 ro r r r r � s zFileobjHooked.addhookc C s | j jS )z-
Return the name of the file
)rF r r r r r �get_name� s zFileobjHooked.get_name)NNNNN)rh )r% r& r' r( rI rK rN rR re rg ri rk rl rn r rq �propertyr r r r r r � s"
�
r c @ s e Zd ZdZdd� ZdS )�Blockz+
Data block to return from SrcIter
c C s
|| _ d S r3 )�data)r rt r r r rI � s
zBlock.__init__N)r% r& r' r( rI r r r r rs � s rs c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) rU z7
Iterate over source and return Block of data.
c C s || _ |�d�| _d S )NrE )rb r �fp)r rb r r r rI s zSrcIter.__init__c C sh z t | j�| �� ��}W n ty' t�td�| jj t
� � f tj j
� Y nw |js2| j�� t�|S )NzFailed to read %s: %s)rs ru ri �
get_read_size� Exceptionr �
FatalError�_rb �uc_namerX �exc_info� ErrorCode�genericrt rn �
StopIteration)r �resr r r �__next__
s
���
zSrcIter.__next__c C � dS )Ni r r r r r rv � zSrcIter.get_read_sizec C r� )N� r r r r r �
get_footer r� zSrcIter.get_footerN)r% r& r' r( rI r� rv r� r r r r rU s rU )F) r( �
__future__r �futurer �install_aliases�builtinsr rO rX r] � duplicityr r r r r r
r r r
rB rC r? r< r rs rU r r r r �<module> s,
p