U ʼb.@s^ddlTddlmZmZgZdZeD]Zeeee<q(eddeD7Ze e e e e eie ee eeiee eiee eiee eieieieiiee e eee e e feieeeee eefeeefeie ee eeiee eiee eiee eieieiiiZeefe eieefeeiee feeieefeeieefe eie efe eieefe eiiZGdddeZdS) )*)LocalProtocolError make_sentinelzCLIENT SERVER IDLE SEND_RESPONSE SEND_BODY DONE MUST_CLOSE CLOSED MIGHT_SWITCH_PROTOCOL SWITCHED_PROTOCOL ERROR _SWITCH_UPGRADE _SWITCH_CONNECTcCsg|]}|ds|qS)_) startswith).0sr ./tmp/pip-unpacked-wheel-rko__zic/h11/_state.py s r c@sNeZdZddZddZddZddZdd d Zd d ZddZ ddZ d S)ConnectionStatecCs d|_t|_tttti|_dS)NT) keep_alivesetpending_switch_proposalsCLIENTIDLESERVERstatesselfr r r __init__szConnectionState.__init__cCst|j|<|dSN)ERRORr!_fire_state_triggered_transitions)rroler r r process_errors zConnectionState.process_errorcCsd|_|dS)NF)r rrr r r process_keep_alive_disabledsz+ConnectionState.process_keep_alive_disabledcCs|j||dSr)raddr)rZ switch_eventr r r process_client_switch_proposals z.ConnectionState.process_client_switch_proposalNcCs|dk r4|tkst||jkr,td|||f}|dkrL|tkrLt|_||||tkr||t kslt|ttt f| dS)Nz3Received server {} event without a pending proposal) rAssertionErrorrrformatResponser!_fire_event_triggered_transitionsRequestrr)rr event_typeZserver_switch_eventr r r process_events     zConnectionState.process_eventc Cs\|j|}zt|||}Wn.tk rLtd|j||j|YnX||j|<dS)Nz4can't handle event type {} when role={} and state={})rEVENT_TRIGGERED_TRANSITIONSKeyErrorrr __name__)rrr$stateZ new_stater r r r"s  z1ConnectionState._fire_event_triggered_transitionscCst|j}|jr(|jttkr(t|jt<|jsF|jttkrFt|jt<|jsrttfD]}|j|tkrTt|j|<qT|jt|jtf}t |i}|j ||j|krdSqdSr) dictrrrDONEMIGHT_SWITCH_PROTOCOLr r MUST_CLOSESTATE_TRIGGERED_TRANSITIONSgetupdate)rZ start_statesrZ joint_statechangesr r r rs         z1ConnectionState._fire_state_triggered_transitionscCs@|jttttikrtd|js$t|jr.ttttti|_dS)Nznot in a reusable state) rrr+rrr rrrrr r r start_next_cycle(s   z ConnectionState.start_next_cycle)N) r( __module__ __qualname__rrrrr%r"rr2r r r r r s   (r N) Z_eventsZ_utilrr__all__splitZ sentinelstokenglobalsrrr#Z SEND_BODYZConnectionClosedZCLOSEDDataZ EndOfMessager+r-r,ZSWITCHED_PROTOCOLrrr!Z SEND_RESPONSEZInformationalResponseZ_SWITCH_UPGRADEZ_SWITCH_CONNECTr&r.objectr r r r r rs<