o
    riT                     @   s@   d dl mZ d dlmZmZ G dd deZG dd deZdS )    )Request)SocketUnreaderIterUnreaderc                   @   s,   e Zd ZdZdd Zdd Zdd ZeZdS )ParserNc                 C   s<   || _ t|drt|| _nt|| _d | _|| _d| _d S )Nrecvr   )cfghasattrr   unreaderr   mesgsource_addr	req_count)selfr   sourcer    r   S/var/www/html/pca-backend/venv/lib/python3.10/site-packages/gunicorn/http/parser.py__init__   s   


zParser.__init__c                 C   s   | S )Nr   )r   r   r   r   __iter__   s   zParser.__iter__c                 C   sz   | j r| j  rt | j r | j jd}|r | j jd}|s|  jd7  _| | j| j| j	| j| _ | j s:t | j S )Ni       )
r
   should_closeStopIterationbodyreadr   
mesg_classr   r	   r   )r   datar   r   r   __next__   s   zParser.__next__)__name__
__module____qualname__r   r   r   r   nextr   r   r   r   r   
   s    r   c                   @   s   e Zd ZeZdS )RequestParserN)r   r   r   r   r   r   r   r   r   r   2   s    r   N)gunicorn.http.messager   gunicorn.http.unreaderr   r   objectr   r   r   r   r   r   <module>   s   (