codekingpro/portable-devtools
115k
1�
2 ��j� � �h � S r SSKJr SSKJrJr SSKJrJrJ r J3r4 SSK J r J
r
Jr Sr " S S 5 rg5) zy6h2/frame_buffer7~~~~~~~~~~~~~~~8 9A data structure that provides a way to iterate over a byte buffer in terms of10frames.11� )� annotations)�InvalidDataError�InvalidFrameError)�ContinuationFrame�Frame� HeadersFrame�PushPromiseFrame� )�FrameDataMissingError�FrameTooLargeError�
ProtocolError�@ c �X � \ rS rSrSrS S S jjrS
S jrSS jrSS jrSS jr SS jr12S r g13)� FrameBuffer� zU14A buffer data structure for HTTP/2 data that allows iteraton in terms of15H2 frames.16c � � [ 5 U l SU l U( a SOSU l [ U R 5 U l / U l g )Nr s PRI * HTTP/2.0
17
18SM
19
20� )� bytearray�_data�max_frame_size� _preamble�len�
_preamble_len�_headers_buffer)�self�servers �UD:\code\apps\devtools\python\user_packages\Python313\site-packages\h2/frame_buffer.py�__init__�FrameBuffer.__init__ s8 � � �[��21� ���@F�<�C��� �� � � 0���Z\�� r c �2 � U R ( aq [ U5 n[ U R U5 nU R SU USU :w a
Sn[ U5 eXS nU =R U- sl U R US U l U =R22 U-
sl g)z[23Add more data to the frame buffer.24 25:param data: A bytestring containing the byte buffer.26NzInvalid HTTP/2 preamble.)r r �minr r
r )r �data�data_len�of_which_preamble�msgs r �add_data�FrameBuffer.add_data' s� � � � � ��4�y�H� #�D�$6�$6�� A� ��~�~� 0� 0�1�T�:L�;L�5M�M�0��#�C�(�(��*�+�D� � � �"3� 3� � !�^�^�,=�,>� ?�D�N� �27�28�d��29r c �\ � XR :� a SU SU R 3n[ U5 eg)z230Confirm that the frame is an appropriate length.31z Received overlong frame: length z, max N)r r )r �lengthr% s r �_validate_frame_length�"FrameBuffer._validate_frame_length; s9 � � �'�'� '�4�V�H�F�4�CV�CV�BW�X�C�$�S�)� )� (r c � � U R ( Ga) U R S R nUSL=( a& [ U[ 5 =( a UR U:H nU( d
Sn[ U5 e[ U[ 5 ( d eU R R U5 [
U R 5 [ :� a
Sn[ U5 eSUR ; aZ U R S nUR R S5 SR S U R 5 5 Ul / U l U$ Sn U$ [ U[ [ 45 ( a- SUR ; a U R R U5 SnU$ )z�32Updates the internal header buffer. Returns a frame that should replace33the current one. May throw exceptions if this frame is invalid.34r Nz"Invalid frame during header block.z&Too many continuation frames received.� END_HEADERSr c 3 �8 # � U H oR v � M g 7f�N)r" )�.0�xs r � <genexpr>�4FrameBuffer._update_header_buffer.<locals>.<genexpr>f s � � �!G�2F�Q�&�&�2F�s �)r � stream_id�35isinstancer r
�appendr �CONTINUATION_BACKLOG�flags�add�joinr" r r )r �fr4 � valid_framer% s r �_update_header_buffer�!FrameBuffer._update_header_bufferC s^ � � � � � � �,�,�Q�/�9�9�I���
� )��1� /�0�)�� � �y�(�
�36 �:��#�C�(�(� �a�!2�3�3� 3�3�
� � � '� '�� *��4�'�'�(�+?�?�>��#�C�(�(� ����'��(�(��+����� � �M�*� ���!G�$�2F�2F�!G�G���')��$� �� �� �� ��\�+;� <�=�=� �Q�W�W�,�
� � � '� '�� *��A��r c � � U $ r/ � )r s r �__iter__�FrameBuffer.__iter__t s � �� r c � � [ U R 5 S: a [ e [ R " [ U R S S 5 5 u p[ U R 5 US- : a [ eU R U5 UR [ U R SSU- 5 5 U R SU- S U l U R U5 nUb U$ U R 5 $ ! [ [ 4 a nSU< 3n[ U5 UeS nAff = f! [ a nSn[ U5 UeS nAf[ a nSn[ U5 UeS nAff = f)N� z$Received frame with invalid header: z&Received frame with non-compliant dataz Frame data missing or invalid)r r �
StopIterationr �parse_frame_header�37memoryviewr r r
r* �38parse_bodyr r= �__next__)r r; r) �errr% � new_frames r rI �FrameBuffer.__next__w sC � � �t�z�z�?�Q� � � � .� �0�0��D�J�J�r��N�1K�L�I�A� �t�z�z�?�V�a�Z� '� � �
�#�#�F�+� 6�
�L�L��D�J�J�q��6��$:�;� <� �Z�Z��&�� �*��39� �.�.�q�1� � &� 1�y�F�t�}�}��F��E !�"3�4� .�8���@�C� ��$�#� -�� .�� � .�:�C� ��$�#� -�� � 6�1�C�'��,�#� 5�� 6�s; �.C* �*D �*D�:D � D�40E � D,�,
E �9E�E )r r r r r N)F)r �bool�return�None)r" �bytesrN rO )r) �intrN rO )r; � Frame | NonerN rR )rN r )rN r ) �__name__�41__module__� __qualname__�__firstlineno__�__doc__r r& r* r= rA rI �__static_attributes__r@ r r r r s( � ��42]��(*�.�b�*Gr r N)rW �43__future__r �hyperframe.exceptionsr r �hyperframe.framer r r r �44exceptionsr r r
r7 r r@ r r �<module>r] s4 ��� #� E� U� U� P� P� � �GG� GGr