KOKINIO - MANAGER
Edit File: drpm.cpython-312.opt-1.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