File: //usr/local/lib/python3.10/dist-packages/h11/__pycache__/_state.cpython-310.pyc
o
���g�3 � @ s� U d dl mZmZmZmZmZmZmZ ddlT ddl m
Z
m Z g d�Z G dd� de e d�Z
G d d
� d
e e d�ZG d d � d e e d�ZG d
d� de e d�ZG dd� de e d�ZG dd� de e d�ZG dd� de e d�ZG dd� de e d�ZG dd� de e d�ZG dd� de e d�ZG dd � d e e d�ZG d d � d e e d�ZG d d � d e e d�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$� d$�Z&d%S )&� )�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 ZdS )r
N��__name__�
__module__� __qualname__� r r �5/usr/local/lib/python3.10/dist-packages/h11/_state.pyr
� � r
)� metaclassc @ r )r Nr r r r r r � r r c @ r )r Nr r r r r r � r r c @ r )r Nr r r r r r � r r c @ r )r Nr r r r r r � r r c @ r )r Nr r r r r r � r r c @ r )r Nr r r r r r � r r c @ r )r Nr r r r r r � r r c @ r )r Nr r r r r r � r r c @ r )r Nr r r r r r � r r c @ r )r Nr r r r r r � r r c @ r )�_SWITCH_UPGRADENr r r r r r! � r r! c @ r )�_SWITCH_CONNECTNr r r r r r" � r r" �EVENT_TRIGGERED_TRANSITIONS�STATE_TRIGGERED_TRANSITIONSc @ s� e Zd Zddd�Zdee ddfdd�Zddd �Zd
ee ddfd d �Z ddee d
ee de
ee ddfdd�Z dee d
e ee e
ee ee f f ddfdd�Zddd�Zddd�ZdS )�ConnectionState�returnNc C s d| _ t� | _tttti| _d S )NT)�
keep_alive�set�pending_switch_proposalsr
r r �states��selfr r r �__init__� s zConnectionState.__init__�rolec C s t | j|< | �� d S �N)r r* �!_fire_state_triggered_transitions)r, r. r r r �
process_error s
z ConnectionState.process_errorc C s d| _ | �� d S )NF)r' r0 r+ r r r �process_keep_alive_disabled s z+ConnectionState.process_keep_alive_disabled� switch_eventc C s | j �|� | �� d S r/ )r) �addr0 )r, r3 r r r � process_client_switch_proposal s z.ConnectionState.process_client_switch_proposal�
event_type�server_switch_eventc C s� |}|d ur |t u s J �|| jvrtd�|���||f}|d u r(|tu r(t� | _| �||� |tu r@|tu s8J �| �t ttf� | � � d S )Nz3Received server {} event without a pending proposal)
r r) r �format�Responser( �!_fire_event_triggered_transitions�Requestr
r0 )r, r. r6 r7 � _event_typer r r �
process_event s"
�� z ConnectionState.process_eventc
C sf | j | }z
t| | | }W n ty+ ttt |�}td�|j|| j | ��d �w || j |< d S )Nz4can't handle event type {} when role={} and state={}) r* r# �KeyErrorr r �Eventr r8 r )r, r. r6 �state� new_stater r r r: - s
����z1ConnectionState._fire_event_triggered_transitionsc C s� t | j�}| jr| jt tu rt| jt< | js$| jt tu r$t| jt< | js:ttfD ]}| j| tu r9t| j|< q+| jt | jt f}t �
|i �}| j� |� | j|krWd S qr/ ) �dictr* r) r
r r r' r r r$ �get�update)r, � start_statesr. � joint_state�changesr r r r0 > s&
�
�z1ConnectionState._fire_state_triggered_transitionsc C sH | j ttttikrtd�| j ���| jsJ �| jrJ �tttti| _ d S )Nz'not in a reusable state. self.states={}) r* r
r r r r8 r' r) r r+ r r r �start_next_cyclef s
�
z ConnectionState.start_next_cycle)r& Nr/ )r r r r- r r r1 r2 r5 r? r r= r r r: r0 rH r r r r r% � s0
���
�
�� �
�
(r% N)'�typingr r r r r r r �_events�_utilr r �__all__r
r r r r r r r r r r r! r" r? �EventTransitionTyper; �ConnectionClosed�Data� EndOfMessager9 �InformationalResponser# �__annotations__�StateTransitionTyper$ r% r r r r �<module> s� &p*���� �
�� � �!&� �