U
    dT                     @   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   M/home/sam/Atlas/atlas_env/lib/python3.8/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   sx   | j r| j  rt | j r>| j jd}|r>| j jd}q*|  jd7  _| | j| j| j	| j| _ | j srt | j S )Ni       )
r
   Z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)Zgunicorn.http.messager   Zgunicorn.http.unreaderr   r   objectr   r   r   r   r   r   <module>   s   (