PATH:
opt
/
cloudlinux
/
venv
/
lib
/
python3.11
/
site-packages
/
lvestats
/
plugins
/
generic
/
burster
/
__pycache__
/
Editing: overload.cpython-311.pyc
� X�9i� � � � d dl mZ d dlmZmZmZ ddlmZ G d� de� � Z G d� de� � Z G d � d e� � Z G d � d � � Z dde de fd�Zdefd�ZdS )� )�deque)� NamedTuple�Self�Protocol� )�loggerc � � e Zd ZU ededefd�� � Zeed< eed< eed< eed< eed< eed < eed < eed < eed < eed < dS )� StatsTimes�line�returnc �x � | d� |� � � � � � dd � D � � � S )Nc 3 �4 K � | ]}t |� � V � �d S �N)�int)�.0�vs ��/builddir/build/BUILDROOT/lve-stats-4.2.14-1.el8.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/generic/burster/overload.py� <genexpr>z,StatsTimes.from_proc_stat.<locals>.<genexpr> s( � � � �>�>��S��V�V�>�>�>�>�>�>� r )�strip�split)�clsr s r �from_proc_statzStatsTimes.from_proc_stat s= � � �s�>�>�T�Z�Z�\�\�%7�%7�%9�%9�!�"�"�%=�>�>�>�?�?r �user�nice�system�idle�iowait�irq�softirq�steal�guest� guest_niceN) �__name__� __module__� __qualname__� classmethod�strr r r �__annotations__� r r r r s� � � � � � � ��@�#� @�$� @� @� @� �[�@� �I�I�I� �I�I�I� �K�K�K� �I�I�I� �K�K�K� �H�H�H� �L�L�L� �J�J�J� �J�J�J��O�O�O�O�Or r c � � e Zd Zdefd�ZdS )�GetStatsr c � � d S r r* ��selfs r �__call__zGetStats.__call__ s � � �r N)r$ r% r& r r0 r* r r r, r, s/ � � � � � � �*� � � � � � r r, c �0 � e Zd ZU eed< eed< defd�ZdS )�OverloadCheckResult� is_overloaded� server_loadr c � � | j S r )r3 r. s r �__bool__z OverloadCheckResult.__bool__( s � ��!�!r N)r$ r% r& �boolr) �floatr6 r* r r r2 r2 $ sI � � � � � � ���������"�$� "� "� "� "� "� "r r2 c �2 � e Zd Zdedededdfd�Zdefd�ZdS )�OverloadChecker�idle_time_threshold� get_stats�max_samples_numberr Nc � � d | _ || _ t |�� � | _ t |�� � | _ || _ || _ d S )N)�num)�maxlen)� _prev_stats�_idle_time_threshold� _get_weights�_weightsr �_idle_times_history� _get_stats�_max_samples_number)r/ r; r< r= s r �__init__zOverloadChecker.__init__- sP � � ���$7��!�$�);�<�<�<�� �#(�0B�#C�#C�#C�� �#���#5�� � � r c �l � | � � � }| j �|n%t d� t || j � � D � � � }|| _ |j t |� � z }n# t $ r d}Y nw xY w| j � |� � t | j � � }| j d |� }d� t || j � � D � � }t |� � }|| j k r|t |� � z }t j d|| j � � t || j k d|z �� � S )Nc 3 �& K � | ] \ }}||z V � � d S r r* )r �new�olds r r z+OverloadChecker.__call__.<locals>.<genexpr>? sF � � � � D � D ���c� �#�I�D � D � D � D � D � D r g c � � g | ] \ }}||z �� S r* r* )r �weight� idle_times r � <listcomp>z,OverloadChecker.__call__.<locals>.<listcomp>P s1 � � � � �!�� � �Y� � � � r z'Current idle time: %02.2f, threshold %sr )r3 r4 )rF rA r �zipr �sum�ZeroDivisionErrorrE �append�lenrD rG r �debugrB r2 )r/ �stats�deltarO � samples_num�relevant_weights�weighted_idle_times�weighted_idle_times r r0 zOverloadChecker.__call__: s� � ����!�!�� �)�1���z� D � D � �5�$�*�+�+�D � D � D � 8 �� !��� � � �S��Z�Z�/�I�I�� � � � ��I�I�I� ���� � �'�'� �2�2�2��$�2�3�3� � �=� �+� �6�� � � �#�T�%=�>�>� � � �� !�!4� 5� 5�� ��1� 1� 1� �#�&6�"7�"7� 7� �� �>�@R�TX�Tm�n�n�n�"�,�t�/H�H�� .�.� � � � s � A$ �$ A3�2A3) r$ r% r& r8 r, r rH r2 r0 r* r r r: r: , sj � � � � � � 6� "� 6� � 6� � 6� � 6� 6� 6� 6�$ �-� $ � $ � $ � $ � $ � $ r r: � ��������?r? �alphac �v ��� �fd�t | � � D � � }t |� � ��fd�|D � � S )Nc � �� g | ]}�|z ��S r* r* )r �ir_ s �r rP z _get_weights.<locals>.<listcomp>c s �� �.�.�.�a�u��z�.�.�.r c � �� g | ]}|�z ��S r* r* )r rN �totals �r rP z _get_weights.<locals>.<listcomp>f s �� � 1� 1� 1�v�F�U�N� 1� 1� 1r )�rangerR )r? r_ �weightsrd s ` @r rC rC a sH ��� �.�.�.�.�5��:�:�.�.�.�G� ��L�L�E� 1� 1� 1� 1�� 1� 1� 1�1r r c � � t dd�� � 5 } t � | � � � � � cd d d � � S # 1 swxY w Y d S )Nz /proc/stat�ascii)�encoding)�openr r �readline)�fds r �read_times_from_procrm i s� � � �l�W� -� -� -� 8���(�(���� � �7�7�8� 8� 8� 8� 8� 8� 8� 8� 8� 8� 8� 8���� 8� 8� 8� 8� 8� 8s �,A � A�AN)r] r^ )� collectionsr �typingr r r �_logsr r r, r2 r: r r8 rC rm r* r r �<module>rq s< �� � � � � � � -� -� -� -� -� -� -� -� -� -� � � � � � �� � � � �� � � �$ � � � � �x� � � � "� "� "� "� "�*� "� "� "�2 � 2 � 2 � 2 � 2 � 2 � 2 � 2 �j2� 2�c� 2�u� 2� 2� 2� 2�8�j� 8� 8� 8� 8� 8� 8r
SAVE
CANCEL