← Back
Editing: inventory.cpython-312.opt-1.pyc
� �]�i� � � � d dl Z d dlZd dlmZ dgZej j � Z G d� de� Z G d� de� Z y)� N)�consts� Inventoryc �J � e Zd ZdZd d�Zd� Zd� Zd� Zd� Zd� Z d � Z d � Z d d �Z y)r z� Inventory object can handle information about available hardware devices. It also informs the plugins about related hardware events. Nc � � |�|| _ nt j � | _ |�t j }|j | j � | _ |�t j }|r | j j |� |� t � }|| _ d | _ i | _ y # t $ r t j d� Y �Bw xY w)Nz�cannot set udev monitor receive buffer size, we are probably running inside container or with limited capabilites, TuneD functionality may be limited)� _udev_context�pyudev�Context�Monitor� from_netlink� _udev_monitorr �CFG_DEF_UDEV_BUFFER_SIZE�set_receive_buffer_size�EnvironmentError�log�warning�_MonitorObserverFactory�_monitor_observer_factory�_monitor_observer�_subscriptions)�self� udev_context�udev_monitor_cls�monitor_observer_factory� buffer_sizer s �=/usr/lib/python3.12/site-packages/tuned/hardware/inventory.py�__init__zInventory.__init__ s� � �� �$�4�� ���(�4��� � �n�n��'�4�4�T�5G�5G�H�$�����0�0�;� �S����.�.�{�;� �%� 5� 7��#;�$� � �$���$��� � S��K�K� R� S�S�s �+B( �( C �C c �J � t j j | j ||� }|S # t j $ r d}Y |S w xY w# t $ rM t j j | j ||� }Y |S # t j $ r d}Y Y |S w xY ww xY w)z9Get a pyudev.Device object for the sys_name (e.g. 'sda').N)r �Devices� from_namer �DeviceNotFoundByNameError�AttributeError�Device)r � subsystem�sys_name�ds r � get_devicezInventory.get_device) s� � � � ���� � ��!3�!3�Y��I�A� �(�� � *� *� � �A� �(� �� � � �� � � � �� 2� 2�I�x�H�A� �(�� � *� *� � �A� �(� �� �s? �+0 �A �A �A � A � B"�+B�B �B"� B � B"c �: � | j j |�� S )z)Get list of devices on a given subsystem.)r# )r � list_devices)r r# s r � get_deviceszInventory.get_devices8 s � � � � � (� (�9� (� =�=� c �Z � |j | j vry t j }|j sd|dkD r_t j d|t j fz � t j t j � d}|j s|dkD r�_|j st j d|z � | j |j D ] \ }} |||� � y # t $ r7}t j d|z � t j |� Y d }~�Nd }~ww xY w)Nr zLDevice '%s' is uninitialized, waiting '%.2f' seconds for its initialization.���zoUnsuccessfully waited for device '%s' initialization, continuing with uninitialized device, problems may occur.z+Exception occured in event handler of '%s'.)r# r r �!HOTPLUG_WAIT_FOR_DEV_INIT_RETRIES�is_initializedr �debug� HOTPLUG_WAIT_FOR_DEV_INIT_DELAY�time�sleep�warn� Exception�error� exception)r �event�device�retry�plugin�callback�es r �_handle_udev_eventz Inventory._handle_udev_event< s � � � � �T� 0� 0� 0� � � 2� 2�%� � !� !�e�a�i��9�9� [�_e�gm� hN� hN� _O� O� P��:�:�f�4�4�5� �5� � !� !�e�a�i� � � ��8�8� }� AG� G� H� � /� /��0@�0@� A��v�x�� �U�F�� B�� � ��I�I�;�f�D�E��M�M�!�����s � C*�* D*�3-D%�%D*c �( � t j d|�d|�d�� ||f}|| j v r | j | j |� y|g| j |< | j j |� | j j � y)z7Register handler of device events on a given subsystem.zadding handler: � (�)N)r r/ r �appendr � filter_by�start)r r: r# r; � callback_datas r � subscribezInventory.subscribeO s} � ��)�)��F� ;�<��8�$�-��$�%�%�%����y�!�(�(� �7�%2�$5�4���y�!���� � � �*������ r* c �� � | j �et j d� | j j | j | j � | _ | j j � y y )Nzstarting monitor observer)r r r/ r �creater r= rC �r s r �start_processing_eventsz!Inventory.start_processing_events[ sZ � � ���#��9�9� (�)� � :� :� A� A�$�BT�BT�VZ�Vm�Vm� n�4����� � �!� $r* c � � | j �7t j d� | j j � d | _ y y )Nzstopping monitor observer)r r r/ �stoprH s r �stop_processing_eventsz Inventory.stop_processing_eventsa s: � � ���'��9�9� (�)���� � � � �4�� (r* c � � | j | D ]G }|\ }}||k( s�t j d|�d|�d�� | j | j |� �I y )Nzremoving handler: r? r@ )r r r/ �remove)r r: r# rD �_pluginr; s r �_unsubscribe_subsystemz Inventory._unsubscribe_subsystemg sS � ��*�*�9�5�m�&��G�X� ����I�I�Y��?�@���� �"�)�)�-�8� 6r* c �� � g }| j D ]I }|�||k( s� | j ||� t | j | � dk( s�9|j |� �K |D ] }| j |= � y)z4Unregister handler registered with subscribe method.Nr )r rP �lenrA )r r: r# �empty_subsystems� _subsystems r � unsubscribezInventory.unsubscriben su � ����'�'�j���:��2�� � �� �3� �4� � �z� *�+�q�0�� � �Z�(� (� %�j� ���:�&� %r* )NNNNT�N) �__name__� __module__� __qualname__�__doc__r r& r) r= rE rI rL rP rU � r* r r r s4 � �� �4 � >��& �"� !� 9� 'r* c � � e Zd Zd� Zy)r c �, � t j |i |��S rV )r �MonitorObserver)r �args�kwargss r rG z _MonitorObserverFactory.create{ s � � � � �� 0�� 0�0r* N)rW rX rY rG r[ r* r r r z s � �1r* r ) r � tuned.logs�tunedr �__all__�logs�getr �objectr r r[ r* r �<module>rg s@ �� � � � �-�� �j�j�n�n���o'�� o'�b1�f� 1r*
Save File
Cancel