Format: application/x-python-code
1 o
2
3 .'h�3 � @ s� U d dl mZmZmZmZmZmZmZ ddlT ddl m
4 Z
5 m Z g d�Z G dd� de e d�Z
6 G d d
7 � d
8 e e d�ZG d d � d e e d�ZG d
9 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
10 ee ee eiee ee eiee eiee eiee eiei ei ei ieee ee ee e
11 feiee!ee ee!efee efeiee ee eiee eiee eiee eiei ei iiZ"ee#d!< eeee ee f eee ee f f Z$eefe
12 eieefeeieefeeieefeeieefe
13 eieefe
14 eieefe
15 eiiZ%e$e#d"< G d#d$� d$�Z&d%S )&� )�cast�Dict�Optional�Set�Tuple�Type�Union� )�*)�LocalProtocolError�Sentinel) �CLIENT�SERVER�IDLE�
16 SEND_RESPONSE� SEND_BODY�DONE�
17 MUST_CLOSE�CLOSED�MIGHT_SWITCH_PROTOCOL�SWITCHED_PROTOCOL�ERRORc @ � e Zd ZdS )r
18 N��__name__�
19 __module__� __qualname__� r r �@C:\Users\shubh\Videos\agent\nova\Lib\site-packages\h11/_state.pyr
20 � � r
21 )� 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
22 ee ddfd d �Z ddee d
23 ee de
24 ee ddfdd�Z dee d
25 e ee e
26 ee ee f f ddfdd�Zddd�Zddd�ZdS )�ConnectionState�returnNc C s d| _ t� | _tttti| _d S )NT)�
27 keep_alive�set�pending_switch_proposalsr
28 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 �
29 process_error s
30 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�
31 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)
32 r r) r �format�Responser( �!_fire_event_triggered_transitions�Requestr
33 r0 )r, r. r6 r7 Z _event_typer r r �
34 process_event s"
35 �� z ConnectionState.process_eventc
36 C sf | j | }z
37 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
38 ����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 �
39 |i �}| j� |� | j|krWd S qr/ ) �dictr* r) r
40 r r r' r r r$ �get�update)r, Z start_statesr. Z joint_state�changesr r r r0 > s&
41
42
43
44 �
45 �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
46 r r r r8 r' r) r r+ r r r �start_next_cyclef s
47 �
48
49 z ConnectionState.start_next_cycle)r& Nr/ )r r r r- r r r1 r2 r5 r> r r< r r r: r0 rE r r r r r% � s0
50
51 ���
52 �
53 �� �
54 �
55 (r% N)'�typingr r r r r r r Z_eventsZ_utilr r �__all__r
56 r r r r r r r r r r r! r" r> ZEventTransitionTyper; ZConnectionClosedZDataZ EndOfMessager9 ZInformationalResponser# �__annotations__ZStateTransitionTyper$ r% r r r r �<module> s� &p*���� �
57 �� � �!&� �