U
|
M ±dô3 ã @ sê U d dl mZmZmZmZmZmZmZ ddlT ddl m
|
Z
|
m Z ddddd d
|
d d d ddg Z G dd de e dZ G dd de e dZG dd de e dZG dd de e dZG dd d e e dZG dd
|
d
|
e e dZG dd d e e dZG dd d e e dZG dd de e dZG dd d e e dZG dd de e dZG d d d e e dZG d d d e e dZeee 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 @ s e Zd ZdS )r N©Ú__name__Ú
|
__module__Ú __qualname__© r r úAd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\h11/_state.pyr s )Ú metaclassc @ s e Zd ZdS )r Nr r r r r r s c @ s e Zd ZdS )r Nr r r r r r s c @ s e Zd ZdS )r Nr r r r r r s c @ s e Zd ZdS )r Nr r r r r r s c @ s e Zd ZdS )r Nr r r r r r s c @ s e Zd ZdS )r Nr r r r r r s c @ s e Zd ZdS )r Nr r r r r r £ s c @ s e Zd ZdS )r Nr r r r r r § s c @ s e Zd ZdS )r Nr r r r r r ¬ s c @ s e Zd ZdS )r Nr r r r r r ° s c @ s e Zd ZdS )Ú_SWITCH_UPGRADENr r r r r r ´ s r c @ s e Zd ZdS )Ú_SWITCH_CONNECTNr r r r r r ¸ s r ÚEVENT_TRIGGERED_TRANSITIONSÚSTATE_TRIGGERED_TRANSITIONSc @ sÄ e Zd ZddddZee ddddZdddd Zee dd
|
d d Zdee ee e
|
ee dd ddZ ee e ee e ee ee f f ddddZddddZddddZdS )ÚConnectionStateN)Úreturnc C s d| _ t | _tttti| _d S )NT)Ú
|
keep_aliveÚsetÚpending_switch_proposalsr r r Ústates©Úselfr r r Ú__init__ú s zConnectionState.__init__)Úroler$ c 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% r. r) r r r Úprocess_keep_alive_disabled s z+ConnectionState.process_keep_alive_disabled)Ú switch_eventr$ c C s | j |¡ | ¡ d S r- )r' Úaddr. )r* r1 r r r Ú process_client_switch_proposal s z.ConnectionState.process_client_switch_proposal)r, Ú
|
event_typeÚserver_switch_eventr$ c C s |}|d k r8|t kst|| jkr0td |¡||f}|d krP|tkrPt | _| ||¡ |tkr|t kspt| t tt f¡ |
|
¡ d S )Nz3Received server {} event without a pending proposal) r ÚAssertionErrorr' r ÚformatÚResponser& Ú!_fire_event_triggered_transitionsÚRequestr r. )r* r, r4 r5 Z _event_typer r r Ú process_event s"
|
ÿÿ z ConnectionState.process_event)r, r4 r$ c
|
C sl | j | }zt| | | }W n> tk
|
r\ ttt |}td |j|| j | ¡d Y nX || j |< d S )Nz4can't handle event type {} when role={} and state={}) r( r! ÚKeyErrorr r ÚEventr r7 r )r* r, r4 ÚstateZ new_stater r r r9 - s
|
ÿÿüz1ConnectionState._fire_event_triggered_transitionsc C s² t | j}| jr(| jt tkr(t| jt< | jsF| jt tkrFt| jt< | jsrttfD ] }| j| tkrTt| j|< qT| jt | jt f}t
|
|i ¡}| j |¡ | j|kr d S q d S r- ) Údictr( r' r r r r% r r r" ÚgetÚupdate)r* Z start_statesr, Z joint_stateÚchangesr r r r. > s
|
|
|
|
z1ConnectionState._fire_state_triggered_transitionsc C sH | j ttttikr"td | j ¡| js,t| jr6ttt tt i| _ d S )Nz'not in a reusable state. self.states={})
|
r( r r r r r7 r% r6 r' r r) r r r Ústart_next_cyclef s
|
ÿ
|
|
z ConnectionState.start_next_cycle)N)r r r r+ r r r/ r0 r3 r= r r; r r r9 r. rC r r r r r# ù s" ü
|
û ü (r# N)'Útypingr r r r r r r Z_eventsZ_utilr r Ú__all__r r r r r r r r r r r r r r= ZEventTransitionTyper: ZConnectionClosedÚDataZ EndOfMessager8 ZInformationalResponser! Ú__annotations__ZStateTransitionTyper" r# r r r r Ú<module>q sÖ $õ*ÿÿÿÿ
|
|
ø
|
ü ü
|
îõ !&ÿ ö
|
