← back to Atmos Game
assets/gen/.venv/lib/python3.12/site-packages/h11/__pycache__/_state.cpython-312.pyc
30 lines
�
c�bj�3 � �V � U d dl mZmZmZmZmZmZmZ ddl� ddl m
Z
m Z g d�Z G d� de e �� Z
G d � d
e e �� Z G d � d e e �� Z G d
� de e �� Z G d� de e �� Z G d� de e �� Z G d� de e �� Z G d� de e �� Z G d� de e �� Z G d� de e �� Z G d� d e e �� Z G d � d e e �� Z G d � d e e �� Zeee eee eeee eee ee f f ee f f f Ze
ee ee eiee ee eiee eiee eiee eiei ei ei ieee ee ee e
feiee!ee ee!efee efeiee ee eiee eiee eiee eiei ei iiZ"ee#d!< eeee ee f eee ee f f Z$eefe
eieefeeieefeeieefeeieefe
eieefe
eieefe
eiiZ%e$e#d"< G d#� d$� Z&y%)&� )�cast�Dict�Optional�Set�Tuple�Type�Union� )�*)�LocalProtocolError�Sentinel) �CLIENT�SERVER�IDLE�
SEND_RESPONSE� SEND_BODY�DONE�
MUST_CLOSE�CLOSED�MIGHT_SWITCH_PROTOCOL�SWITCHED_PROTOCOL�ERRORc � � e Zd Zy)r N��__name__�
__module__� __qualname__� � �a/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/h11/_state.pyr r � � � �r r )� metaclassc � � e Zd Zy)r Nr r r r r r � r! r r c � � e Zd Zy)r Nr r r r r r � r! r r c � � e Zd Zy)r Nr r r r r r � r! r r c � � e Zd Zy)r Nr r r r r r � r! r r c � � e Zd Zy)r Nr r r r r r � r! r r c � � e Zd Zy)r Nr r r r r r � r! r r c � � e Zd Zy)r Nr r r r r r � r! r r c � � e Zd Zy)r Nr r r r r r � r! r r c � � e Zd Zy)r Nr r r r r r � r! r r c � � e Zd Zy)r Nr r r r r r � r! r r c � � e Zd Zy)�_SWITCH_UPGRADENr r r r r. r. � r! r r. c � � e Zd Zy)�_SWITCH_CONNECTNr r r r r0 r0 � r! r r0 �EVENT_TRIGGERED_TRANSITIONS�STATE_TRIGGERED_TRANSITIONSc �� � e Zd Zdd�Zdee ddfd�Zdd�Zdee ddfd�Z ddee d ee d
e
ee ddfd �Z dee d e ee e
ee ee f f ddfd �Zdd
�Zdd�Zy)�ConnectionState�returnNc �f � d| _ t � | _ t t t
t i| _ y )NT)�
keep_alive�set�pending_switch_proposalsr r r �states��selfs r �__init__zConnectionState.__init__� s) � �
��� >A�U��%�=C�T�6�SW�<X�� r �rolec �J � t | j |< | j � y �N)r r: �!_fire_state_triggered_transitions)r< r> s r �
process_errorz ConnectionState.process_error s � � !�� � �D�� �.�.�0r c �2 � d| _ | j � y )NF)r7 rA r; s r �process_keep_alive_disabledz+ConnectionState.process_keep_alive_disabled s � � ��� �.�.�0r � switch_eventc �Z � | j j |� | j � y r@ )r9 �addrA )r< rE s r � process_client_switch_proposalz.ConnectionState.process_client_switch_proposal s" � � �%�%�)�)�,�7� �.�.�0r �
event_type�server_switch_eventc �4 � |}|�'|t u sJ �|| j vr t d� �||f}|�|t u rt � | _ | j ||� |t u r*|t u sJ �| j t t t f� | j � y )Nz@Received server _SWITCH_UPGRADE event without a pending proposal) r r9 r �Responser8 �!_fire_event_triggered_transitions�Requestr rA )r< r> rI rJ � _event_types r �
process_eventz ConnectionState.process_event s� � � OY� � � *��6�>� !�>�"�$�*G�*G�G�(�V�� � &�':�;�K� � &�;�(�+B�,/�E�D� )� �.�.�t�[�A� �'� !��6�>� !�>� � 2� 2�6�G�V�;L� M� �.�.�0r c � � | j | } t | | | }|| j |< y # t $ rL t t t
|� }t
dj |j || j | � � d �w xY w)Nz4can't handle event type {} when role={} and state={}) r: r1 �KeyErrorr r �Eventr �formatr )r< r> rI �state� new_states r rM z1ConnectionState._fire_event_triggered_transitions+ s� � �
� � �D�!�� �3�D�9�%�@��L�I� &�� � �D��� � � �d�5�k�:�6�J�$�F�M�M� �'�'��t�{�{�4�/@��� �
� �s
�0 �ABc �| � t | j � }| j r0| j t t u rt
| j t < | j s0| j t t
u rt | j t < | j s:t t fD ]+ }| j | t u s�t | j |< �- | j t | j t f}t j |i � }| j j |� | j |k( ry ��<r@ ) �dictr: r9 r r r r7 r r r2 �get�update)r< � start_statesr> � joint_state�changess r rA z1ConnectionState._fire_state_triggered_transitions< s� � �� �� � �,�L� �,�,��;�;�v�&�$�.�*?�D�K�K��'��0�0��;�;�v�&�*?�?�*.�D�K�K��'��?�?� #�V� ,�D��{�{�4�(�D�0�,6�� � �D�)� -�
�;�;�v�.�� � �F�0C�D�K�1�5�5�k�2�F�G� �K�K� � �w� '��{�{�l�*��I r c �� � | j t t t t ik7 rt d| j � �� �| j
sJ �| j rJ �t t t t i| _ y )Nz%not in a reusable state. self.states=)r: r r r r r7 r9 r r; s r �start_next_cyclez ConnectionState.start_next_cycled s_ � � �;�;�6�4���6� 6�$�7�� � �}�E��
�
��� ���0�0�0�0� �t�V�T�2�� r )r5 Nr@ )r r r r= r r
rB rD rH rS r rP r r rM rA r_ r r r r4 r4 � s� � � Y�1�$�x�.� 1�T� 1�1�1�4��>� 1�d� 1� 9=� 1��8�n�1� ��K�1� &�d�8�n� 5� 1�
� 1�0&��8�n�&� �$�u�+�u�T�%�[�$�x�.�-H�'I�I�J�&�
� &�"&�P 3r r4 N)'�typingr r r r r r r �_events�_utilr r
�__all__r r r r r r r r r r r r. r0 rS �EventTransitionTyperN �ConnectionClosed�Data� EndOfMessagerL �InformationalResponser1 �__annotations__�StateTransitionTyper2 r4 r r r �<module>rk s� ��b A� @� @� � /� �� �X�� � �X�� �
�8�x� � �H�� � ��H� � �8�x� � ��X� � �X�� � �H�� �
�H�� � ��H� � �h�(� � �h�(� � ���N�� �X�� �U�4��;��d�5�k�4��>�&A� B�B�
C�T�(�^�
S�T� V���� � � �w� �#3�V�<��D�)�\�4�8� � ��(��%�v�.��!�6�*� �r��2�
�r�
� � � �f� �i�
�f� �}�
� � !�=� �i�
"�O� 4�6G�
�� '�):�
� �D�)�\�4�8� � ��(��%�v�.��!�6�*��2�
�r�%
� 4� � 0� �B � �$�x�.�$�x�.�
(�)�4��X���X��0N�+O�O�� � � -�.��9J�0K� �T�N�V�Z�(� �T�N�V�Z�(�
�D�M�F�J�'� �6�N�V�Z�(� �6�N�V�Z�(� �5�M�F�J�'� 4� � 0� � t3� t3r