Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/lib/python3.9/site-packages/dnf/__pycache__/ |
a
�!c� � @ s� d dl mZ d dl mZ d dlmZ d dlmZ d dlmZ d dl Z
d dl Z
d dl Z
d dl
Z
d dlZd dlZd dlZdZe�d�ZG d d
� d
e
jj�ZG d d � d e�ZdS )
� )�absolute_import)�unicode_literals)�hexlify)�unlink_f)�_Nz/usr/bin/applydeltarpm�dnfc sX e Zd Z� fdd�Zdd� Z� fdd�Zdd� Zed d
� �Zed d � �Z d
d� Z
� Z S )� DeltaPayloadc s" t t| ��||� || _|| _d S �N)�superr �__init__�
delta_info�delta)�selfr r
�pkg�progress�� __class__� �,/usr/lib/python3.9/site-packages/dnf/drpm.pyr ) s zDeltaPayload.__init__c C s t j�| jj�S r )�os�path�basenamer
�location�r r r r �__str__. s zDeltaPayload.__str__c s2 t t| ��|||� |tjjjkr.| j�| � d S r ) r
r �_end_cb�libdnf�repoZPackageTargetCBZTransferStatus_ERRORr �enqueue)r ZcbdataZ lr_status�msgr r r r 1 s zDeltaPayload._end_cbc C sh | j }|j\}}t�|�}t|��� }tjj� |�}|tjjj
krRt � t
d�|� |j|||j|jd�S )Nz unsupported checksum type: %s)Z relative_urlZ
checksum_typeZchecksumZ expectedsizeZbase_url)r
�chksum�hawkeyZ chksum_namer �decoder r Z
PackageTargetZ checksumTypeZChecksumType_UNKNOWN�loggerZwarningr r � downloadsizeZbaseurl)r r
ZctypeZcsumr Z
ctype_coder r r �_target_params6 s
�zDeltaPayload._target_paramsc C s | j jS r )r
r$ r r r r �
download_sizeH s zDeltaPayload.download_sizec C s | j jS r )r r$ r r r r �
_full_sizeL s zDeltaPayload._full_sizec C s$ | j j}tj�| jjjtj�|��S r ) r
r r r �joinr r Zpkgdirr )r r r r r �localPkgP s zDeltaPayload.localPkg) �__name__�
__module__� __qualname__r r r r% �propertyr& r' r) �
__classcell__r r r r r ( s
r c @ s> e Zd Zddd�Zdd� Zdd� Zdd � Zd
d � Zd d
� ZdS )� DeltaInfoNc C s� d| _ t�ttj�rd| _ zt�d�| _W n ttfyF d| _Y n0 |du r`t j
� � j | _ n|| _ || _
|| _g | _i | _i | _dS )z�A delta lookup and rebuild context
query -- installed packages to use when looking up deltas
progress -- progress obj to display finished delta rebuilds
FT�SC_NPROCESSORS_ONLN� N)�deltarpm_installedr �access�
APPLYDELTA�X_OK�sysconf�
deltarpm_jobs� TypeError�
ValueErrorr ZconfZConf�deltarpm_percentage�queryr �queue�jobs�err)r r; r r: r r r r V s zDeltaInfo.__init__c C s� | j s
dS |jjr| js dS |�� r(dS tj�|�� �r<dS |j | j d }d}| j
j |j |j
d�D ](}|�|j�}|rd|j|k rd|j}|}qd|r�t| |||�S dS )z&Turn a po to Delta RPM po, if possibleN�d )�name�arch)r2 r Zdeltarpmr: Z
_is_local_pkgr r �existsr) �_sizer; �filterr@ rA Zget_delta_from_evrZevrr$ r )r Zpor ZbestZ
best_deltaZipor
r r r �
delta_factorym s$ zDeltaInfo.delta_factoryc C s� t �tjjd||d? |d@ � | j�|�}|j}|dkrXt|j� � � t
d�g| j |< nB|j� � stt
d�g| j |< n&t
�|� � � | j�|tjjt
d�� d S )Nz drpm: %d: return code: %d, %d� � r zDelta RPM rebuild failedz(Checksum of the delta-rebuilt RPM failedZdone)r# �logr �logging�SUBDEBUGr= �popr r r) r r> ZverifyLocalPkgr �unlinkr �end�callbackZ STATUS_DRPM)r �pid�code�ploadr r r r �job_done� s �
zDeltaInfo.job_donec
C sb t t d|jj|�� |j�� g}tjtjg|�R � }t�t j
j d|d� |dd � �� || j
|< d S )Nz-azdrpm: spawned %d: %s� � )r4 r rA r) r �spawnl�P_NOWAITr# rH r rI rJ r( r= )r rQ Z
spawn_argsrO r r r � start_job� s ��zDeltaInfo.start_jobc C sh | j r,t�dtj�\}}|s q,| �||� q | j�|� t| j �| jk rd| � | j�
d�� | js8qdq8d S )N���r ) r= r �waitpid�WNOHANGrR r< �append�lenr7 rW rK )r rQ rO rP r r r r � s zDeltaInfo.enqueuec C s< | j r8t�� \}}| �||� | jr | �| j�d�� q dS )z!Wait until all jobs have finishedr N)r= r �waitrR r< rW rK )r rO rP r r r r] � s
zDeltaInfo.wait)N) r* r+ r, r rE rR rW r r] r r r r r/ U s
r/ )Z
__future__r r Zbinasciir Z dnf.yum.miscr Zdnf.i18nr Z dnf.callbackr Z dnf.loggingZdnf.repor! rI Z libdnf.repor r r4 Z getLoggerr# r ZPackagePayloadr �objectr/ r r r r �<module> s
-