JFIF $
d d 7
Viewing File: /usr/lib/python3.9/site-packages/dnf/__pycache__/drpm.cpython-39.pyc
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
-Back to Directory
nL+D550H?Mx ,D"v]qv;6*Zqn)ZP 0 !1 A "#a$2Qr D8 a Ri[f\mIykIw0 cuFcRı?lO7к_f˓[C$殷WF<_W ԣs KcëIzyQy /_LKℂ;C",pFA: /]=H ~,ls/9ć:[=/#f;)x {ٛEQ )~ =𘙲r*2~ a _V=' kumF D}KYYC)({ *g&f`툪ry`=^cJ.I](*`wq 1dđ#̩͑0;H]u搂@:~וKL Nsh}OIR*8:2 !lDJVo( 3=M(zȰ+i*NA r6KnSl )!JJӁ* %݉?|D}d5:eP0R;{$X'xF@.ÊB {,WJuQɲRI;9QE琯62fT.DUJ;*cP A\ILNj!J۱+O\ ͔]ޒ SJȧc%ANolՎprULZԛerE2=XDXgVQeӓk yP7U*omQIs,K`)6\G3t?pgjrmۛجwluGtf h9uyP0D;Uڽ"OXlif$)&|ML0Zrm1[HXPlPR0'G=i2N +0e2]] 9VTPO7h(F*癈 '=QVZDF,d߬~TX
G[`le69CR(!S2!P
<0x < !1AQ "Raq02Br#SCTb
?Ζ"]mH5WR7k.ۛ!}Q~+yԏz|@T20S~Kek *zFf^2X*(@8r?CIuI|֓>^ExLgNUY+{.RѪ
τVYTD I62'8Y2 7'\TP.6d&˦@Vqi|8- OΕ]ʔ U=TL8=;6c| !qfF3aů&~$l}'NWUs$Uk^SV:U# 6w++s&r+nڐ{@29 gL
u"TÙM=6 (^"7r} =6YݾlCuhquympǦ
G jhsǜNlɻ}o7 #S6aw4!OSrD57%|?x>L
|/nD6?/8w#[)L7+6〼T ATg ! %5MmZ/c-{1_Je"|^$'O&ޱմ Trb$ w)R$&
N1EtdU3Uȉ1pM" N*(DN yd96.(jQ)X
5cQɎMyW? Q*!R>6=7)Xj5`J]e 8%t!+'!1Q 5 !1 AQaqё#2"0BRb ? Gt^## .llQT $v,,m 㵜5 ubV =sY+@d{N! dnO< .-B; _wJt6;QJd.Qc%p{ 1,sNDdFHI0ГoXшe黅XۢF:)[FGXƹ/w_cMeD,ʡcc. WDtA$j@:) -# u
c1<@ۗ9F)KJ-hpP]_x[qBlbp ʖw q"LFGd ƶ*s+ډ_Zc"? %t[IP 6J]#=ɺVvvCGsGh1 >)6|ey?Lӣm,4GWUi` ]uJVoV DG< SB 6ϏQ@ TiUly OU0kfV~~}SZ@*WUUi##; s/[ =!7}" WN]'(L! ~y5g9T̅JkbM' +s:S + B)v@Mj
e Cf jE 0Y\QnzG1д~Wo{T 9?`Rmyhsy3!HAD]mc1~2L Su7xT;j$`}4->L#vzŏ ILS ֭ T { rjGKC; bpU= -`BsK.SFw4Mq]ZdHS0)tLg