3
ft` @ 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 dlZdZejdZG d d
d
e
jjZG d d d eZdS )
)absolute_import)unicode_literals)hexlify)unlink_f)_Nz/usr/bin/applydeltarpmdnfc sX e Zd Z fddZdd Z fddZdd Zed d
Zed d Z d
d Z
Z S ) DeltaPayloadc s" t t| j|| || _|| _d S )N)superr __init__
delta_infodelta)selfr r pkgprogress) __class__ /usr/lib/python3.6/drpm.pyr
) s zDeltaPayload.__init__c C s t jj| jjS )N)ospathbasenamer location)r
r r r __str__. s zDeltaPayload.__str__c s2 t t| j||| |tjjjkr.| jj| d S )N) r r _end_cblibdnfrepoZPackageTargetCBZTransferStatus_ERRORr enqueue)r
ZcbdataZ lr_statusmsg)r r r r 1 s zDeltaPayload._end_cbc C sh | j }|j\}}tj|}t|j }tjjj |}|tjjj
krRt j t
d| |j|||j|jdS )Nz unsupported checksum type: %s)Z relative_urlZ
checksum_typeZchecksumZ expectedsizeZbase_url)r chksumhawkeyZ chksum_namer decoder r Z
PackageTargetZ checksumTypeZChecksumType_UNKNOWNloggerZwarningr r downloadsizeZbaseurl)r
r ZctypeZcsumr Z
ctype_coder r r _target_params6 s
zDeltaPayload._target_paramsc C s | j jS )N)r r! )r
r r r
download_sizeH s zDeltaPayload.download_sizec C s | j jS )N)r r! )r
r r r
_full_sizeL s zDeltaPayload._full_sizec C s$ | j j}tjj| jjjtjj|S )N) 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 ZdddZdd Zdd Zdd Zd
d Zd d
ZdS ) DeltaInfoNc C s d| _ tjttjrd| _ ytjd| _W n ttfk
rH d| _Y nX |dkrbt j
j j | _ n|| _ || _
|| _g | _i | _i | _dS )zA delta lookup and rebuild context
query -- installed packages to use when looking up deltas
progress -- progress obj to display finished delta rebuilds
FTSC_NPROCESSORS_ONLN N)deltarpm_installedr access
APPLYDELTAX_OKsysconf
deltarpm_jobs TypeError
ValueErrorr ZconfZConfdeltarpm_percentagequeryr queuejobserr)r
r8 r r7 r r r r
V s zDeltaInfo.__init__c C s | j s
dS |jj s | j r dS |j r,dS tjj|j r@dS |j | j d }d}x@| j
j |j |j
dD ](}|j|j}|rj|j|k rj|j}|}qjW |rt| |||S dS )z&Turn a po to Delta RPM po, if possibleNd )namearch)r/ r Zdeltarpmr7 Z
_is_local_pkgr r existsr& Z_sizer8 filterr= r> Zget_delta_from_evrZevrr! r )r
Zpor ZbestZ
best_deltaZipor r r r
delta_factorym s$ zDeltaInfo.delta_factoryc C s t jtjjd||d? |d@ | jj|}|j}|dkrXt|jj t
dg| j |< nB|jj stt
dg| j |< n&t
j|j | jj|tjjt
d d S )Nz drpm: %d: return code: %d, %d r zDelta RPM rebuild failedz(Checksum of the delta-rebuilt RPM faileddone)r logr loggingSUBDEBUGr: popr r r& r r; ZverifyLocalPkgr unlinkr endcallbackZ STATUS_DRPM)r
pidcodeploadr r r r job_done s
zDeltaInfo.job_donec C s` t t d|jj|j |jj g}tjtjf| }tjt j
j d|dj |dd || j
|< d S )Nz-azdrpm: spawned %d: %s )r1 r r> r& r spawnlP_NOWAITr rE r rF rG r% r: )r
rN Z
spawn_argsrL r r r start_job s zDeltaInfo.start_jobc C sp x.| j r.tjdtj\}}|s P | j|| qW | jj| x.t| j | jk rj| j | jj
d | js>P q>W d S )NrQ r ) r: r waitpidWNOHANGrO r9 appendlenr4 rT rH )r
rN rL rM r r r r s zDeltaInfo.enqueuec C s@ x:| j r:tj \}}| j|| | jr| j| jjd qW dS )z!Wait until all jobs have finishedr N)r: r waitrO r9 rT rH )r
rL rM r r r rZ s
zDeltaInfo.wait)N) r' r( r) r
rA rO rT r rZ 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 rF Z libdnf.repor r r1 Z getLoggerr r ZPackagePayloadr objectr, r r r r s
-