File: //lib/python3.12/site-packages/dnf/__pycache__/drpm.cpython-312.pyc
�
�(f� � �� � 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 dlZdZ ej& d� Z G d � d
e
j* j, � Z G d � d e� Zy)
� )�absolute_import)�unicode_literals)�hexlify)�unlink_f)�_Nz/usr/bin/applydeltarpm�dnfc �Z � � e Zd Z� fd�Zd� Z� fd�Zd� Zed� � Zed� � Z d� Z
� xZ S )� DeltaPayloadc �J �� t t | � ||� || _ || _ y �N)�superr
�__init__�
delta_info�delta)�selfr r �pkg�progress� __class__s ��-/usr/lib/python3.12/site-packages/dnf/drpm.pyr zDeltaPayload.__init__) s" �� �
�l�D�*�3��9�$�����
� c �h � t j j | j j � S r )�os�path�basenamer �location�r s r �__str__zDeltaPayload.__str__. s! � ��w�w� � ��
�
� 3� 3�4�4r c � �� t t | � |||� |t j j
j k7 r | j j | � y y r ) r
r
�_end_cb�libdnf�repo�PackageTargetCB�TransferStatus_ERRORr �enqueue)r �cbdata� lr_status�msgr s �r r zDeltaPayload._end_cb1 sF �� �
�l�D�)�&�)�S�A� �� � �3�3�H�H� H� �O�O� #� #�D� )� Ir c � � | j }|j \ }}t j |� }t |� j � }t j j j |� }|t j j j k( r t j t d� |� |j |||j |j d�S )Nz unsupported checksum type: %s)� relative_url�
checksum_type�checksum� expectedsize�base_url)r �chksum�hawkey� chksum_namer �decoder r! �
PackageTarget� checksumType�ChecksumType_UNKNOWN�logger�warningr r � downloadsize�baseurl)r r �ctype�csumr. �
ctype_codes r �_target_paramszDeltaPayload._target_params6 s� � ��
�
���l�l� ��t��"�"�5�)���� �%�%�'���[�[�.�.�;�;�E�B�
� ����2�2�G�G� G� �N�N�1� <�=�u� E� #�^�^� (� � "� /� /� � � �
�
r c �. � | j j S r )r r7 r s r �
download_sizezDeltaPayload.download_sizeH s � ��z�z�&�&�&r c �. � | j j S r )r r7 r s r �
_full_sizezDeltaPayload._full_sizeL s � ��x�x�$�$�$r c �� � | j j }t j j | j
j j t j j |� � S r ) r r r r �joinr r! �pkgdirr )r r s r �localPkgzDeltaPayload.localPkgP sC � ��:�:�&�&���w�w�|�|�D�H�H�M�M� 0� 0�"�'�'�2B�2B�8�2L�M�Mr ) �__name__�
__module__� __qualname__r r r r< �propertyr> r@ rD �
__classcell__)r s @r r
r
( sE �� ��
5�*�
�$ �'� �'� �%� �%�Nr r
c �2 � e Zd Zdd�Zd� Zd� Zd� Zd� Zd� Zy) � DeltaInfoNc � � d| _ t j t t j � rd| _ t j
d� | _ |�.t j j � j | _ n|| _ || _
|| _ g | _ i | _ i | _ y# t t f$ r
d| _ Y �sw xY w)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 �conf�Conf�deltarpm_percentage�queryr �queue�jobs�err)r rZ r rY s r r zDeltaInfo.__init__V s� � �
#(�� �
�9�9�Z���� )�&*�D� #� #�!#���,A�!B�D� � � &�'*�x�x�}�}��'J�'J�D� $�':�D� $���
� ��
���
��� ����� �:�&� #�!"�D� � #�s �B- �-C�Cc �" � | j sy|j j r | j sy|j � ryt
j j |j � � ry|j | j z dz }d}| j j |j |j �� D ]> }|j |j � }|s�!|j |k s�1|j }|}�@ |rt# | |||� S y)z&Turn a po to Delta RPM po, if possibleN�d )�name�arch)rO r! �deltarpmrY �
_is_local_pkgr r �existsrD �_sizerZ �filterr` ra �get_delta_from_evr�evrr7 r
)r �por �best�
best_delta�ipor s r �
delta_factoryzDeltaInfo.delta_factorym s� � ��&�&���w�w� � �t�'?�'?��
� � � ��
�7�7�>�>�"�+�+�-� (���x�x�$�2�2�2�S�8���
��:�:�$�$�"�'�'����$�@�C��)�)�#�'�'�2�E���+�+�d�2� �)�)�� "�
� A�
� ��j�"�h�?� ?�r c �n � t j t j j d||dz |dz � | j
j
|� }|j }|dk7 r=t |j j � � t d� g| j |< y |j j � st d� g| j |< y t j |j � � | j j! |t j" j$ t d� � y )Nz drpm: %d: return code: %d, %d� � r zDelta RPM rebuild failedz(Checksum of the delta-rebuilt RPM failed�done)r5 �logr �logging�SUBDEBUGr\ �popr r rD r r] �verifyLocalPkgr �unlinkr �end�callback� STATUS_DRPM)r �pid�code�ploadr s r �job_donezDeltaInfo.job_done� s� � ��
�
�3�;�;�'�'�)H�#��1�9�d�T�k� +� � � �
�
�c�"���i�i�� �1�9� �U�Y�Y�'�'�)� *� � 9� :� ;�D�H�H�S�M����)�)�+� � I� J� K�D�H�H�S�M� �I�I�e�n�n�&� '� �M�M� � �e�S�\�\�%=�%=�q��y� Ir c
� � t t d|j j |j � |j j � g}t j
t j g|��� }t j t j j d|dj |dd � � || j |< y )Nz-azdrpm: spawned %d: %s� � )rQ r ra rD r �spawnl�P_NOWAITr5 rr r rs rt rB r\ )r r} �
spawn_argsr{ s r � start_jobzDeltaInfo.start_job� s� � � �*��E�I�I�N�N��n�n�&�� � �(:�(:�(<�>�
� �i�i�� � �1�j�1���
�
�3�;�;�'�'�)?���8�8�J�q�r�N�+� -� �� � �#�r c �� � | j rIt j dt j � \ }}|sn | j ||� | j r�I| j
j
|� t | j � | j k r[| j | j
j d� � | j
sy t | j � | j k r�Zy y )N���r ) r\ r �waitpid�WNOHANGr~ r[ �append�lenrT r� ru )r r} r{ r| s r r$ zDeltaInfo.enqueue� s� � ��i�i��
�
�2�r�z�z�2�I�C���� �M�M�#�t� $� �i�i�
�
�
���%� ��$�)�)�n�t� 1� 1�1� �N�N�4�:�:�>�>�!�,� -��:�:�� �$�)�)�n�t� 1� 1�1r c � � | j rmt j � \ }}| j ||� | j r*| j | j j
d� � | j r�lyy)z!Wait until all jobs have finishedr N)r\ r �waitr~ r[ r� ru )r r{ r| s r r� zDeltaInfo.wait� sO � ��i�i���� �I�C�� �M�M�#�t� $��z�z����t�z�z�~�~�a� 0�1� �i�ir r ) rE rF rG r rm r~ r� r$ r� � r r rK rK U s! � ��.�4J� � �2r rK )�
__future__r r �binasciir � dnf.yum.miscr �dnf.i18nr � dnf.callbackr � dnf.logging�dnf.repor/ rs � libdnf.repor r rQ � getLoggerr5 r! �PackagePayloadr
�objectrK r� r r �<module>r� si ��* '� '� � !� � � � �
� � � �
%�
� �� � �5� !��*N�3�8�8�*�*� *N�Z_2�� _2r