| Server IP : 209.209.40.120 / Your IP : 216.73.217.112 Web Server : Microsoft-IIS/10.0 System : Windows NT NEWWWW 10.0 build 17763 (Windows Server 2019) i586 User : NEWWWW$ ( 0) PHP Version : 8.3.30 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : C:/Python312/Lib/site-packages/mysql/connector/fabric/__pycache__/ |
Upload File : |
�
��f � �B � d Z ddlZd� Z G d� de� Z G d� de� Zy)zImplementing load balancing� Nc � � t | |z dz j t j d� t j �� � S )z%Calculate ratio
Returns int
�d �1)�rounding)�int�quantize�decimal�Decimal�ROUND_HALF_DOWN)�part�wholes �BC:\Python312\Lib\site-packages\mysql/connector/fabric/balancing.py� _calc_ratior sB � �
��U�
�3��(�(����� �w�'>�'>� )� @� A� A� c �B � e Zd ZdZd� Zd� Zd� Zed� � Zed� � Z y)�BaseSchedulingzABase class for all scheduling classes dealing with load balancingc � � g | _ g | _ y)�
InitializeN)�_members�_ratios��selfs r �__init__zBaseScheduling.__init__+ s � ���
��� r c � � t �)aH Set members and ratios
This methods sets the members using the arguments passed. Each
argument must be a sequence where the second item is the weight.
The first element is an identifier. For example:
('server1', 0.6), ('server2', 0.8)
Setting members means that the load will be reset. If the members
are the same as previously set, nothing will be reset or set.
If no arguments were given the members will be set to an empty
list.
Raises ValueError when weight can't be converted to a Decimal.
��NotImplementedError)r �argss r � set_memberszBaseScheduling.set_members0 s
� �" "�!r c � � t �)�Returns the next memberr r s r �get_nextzBaseScheduling.get_nextC s � �!�!r c � � | j S )z(Returns the members of this loadbalancer)r r s r �memberszBaseScheduling.membersG s � � �}�}� r c � � | j S )z"Returns the ratios for all members)r r s r �ratioszBaseScheduling.ratiosL s � � �|�|�r N)
�__name__�
__module__� __qualname__�__doc__r r r! �propertyr# r% � r r r r ' s< � �K��
"�&"� � � � � � � � r r c �P � � e Zd ZdZ� fd�Zed� � Zd� Zd� Zd� Z d� Z
d� Z � xZ S ) �WeightedRoundRobinz.Class for doing Weighted Round Robin balancingc �x �� t t | � � g | _ d| _ d| _ |r | j |� yy)� Initializingr N)�superr- r �_load� _next_member� _nr_membersr )r r � __class__s �r r zWeightedRoundRobin.__init__V s@ �� �
� �$�0�2���
� ��� ��� � �D� � �d� #� r c � � | j S )zReturns the current load)r1 r s r �loadzWeightedRoundRobin.load` s � � �z�z�r c �z � |sg | _ y g }|D ]L }t |� } t j t |d � � |d< |j t |� � �N |j d� d�� | j |k( ry || _ t |� | _ t d� | j D � � }g | _ | j D ]/ \ }}| j j t ||z dz � � �1 | j! � y # t j
$ r t
dj |�� � �w xY w) N� z Member '{member}' is invalid)�memberc � � | d S )Nr8 r+ )�xs r �<lambda>z0WeightedRoundRobin.set_members.<locals>.<lambda>t s
� �q��t� r T)�key�reversec 3 �& K � | ] }|d �� � y�w)r8 Nr+ )�.0�is r � <genexpr>z1WeightedRoundRobin.set_members.<locals>.<genexpr>z s � �� �5�!��1��5�s �r )r �listr r
�str�InvalidOperation�
ValueError�format�append�tuple�sort�lenr3 �minr r �reset)r r � new_membersr9 �
min_weight�_�weights r r z WeightedRoundRobin.set_memberse s. � �� �D�M� �� �� .�F��&�\�F�
$� #�O�O�C��q� �N� ;��q� �
� � �u�V�}� -� .� ���^�T��:� �=�=�K� '� �#��
� �{�+����5�t�}�}�5�5�
��� � � � � >�I�A�v� �L�L� � ��F�:�$5��$;� <� =� >� �
�
� �� �+�+�
$� �!?�!F�!F�!� "G� "#� $� $�
$�s �$D � /D:c �< � d| _ dg| j z | _ y)zReset the loadr N)r2 r3 r1 r s r rM zWeightedRoundRobin.reset� s � � ����S�4�+�+�+��
r c � � | j | j k( r| j � | j }| j | | j | k( r2|dz | j z }| j | | j | k( r�2| j |xx dz
cc< |dz | j z | _ | j
| S )r r8 )r r1 rM r2 r3 r )r �currents r r! zWeightedRoundRobin.get_next� s� � � �<�<�4�:�:� %� �J�J�L� �#�#���j�j��!�T�\�\�'�%:�:� ��{�d�&6�&6�6�G� �j�j��!�T�\�\�'�%:�:�
�
�
�7��q� �� $�q�[�D�,<�,<� <��� �}�}�W�%�%r c �f � dj | j | j | j �� S )Nz&{class_}(load={load}, ratios={ratios}))�class_r6 r% )rG r4 r6 r% r s r �__repr__zWeightedRoundRobin.__repr__� s/ � �7�>�>��>�>�����;�;� ?�
�
r c �4 � | j |j k( S )N)r r# )r �others r �__eq__zWeightedRoundRobin.__eq__� s � ��}�}��
�
�-�-r )
r& r' r( r) r r* r6 r rM r! rW rZ �
__classcell__)r4 s @r r- r- R s8 �� �8�$� �� ���6,�
&�$
�.r r- )r) r r �objectr r- r+ r r �<module>r] s0 ��0 "� �A�( �V� ( �VM.� � M.r