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 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 Ú s
-