
    nfy                     h    d dl Z d dlZ G d d          Z G d de          Z G d de          ZdS )    Nc                   (    e Zd Zd Zd ZddZd ZdS )Unreaderc                 6    t          j                    | _        d S N)ioBytesIObufselfs    U/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/gunicorn/http/unreader.py__init__zUnreader.__init__   s    :<<    c                     t                      r   )NotImplementedErrorr
   s    r   chunkzUnreader.chunk   s    !###r   Nc                 |   |$t          |t                    st          d          ||dk    rdS |dk     rd }| j                            dt
          j                   |L| j                                        r3| j                                        }t          j
                    | _        |S ||                                 }|S | j                                        |k     r|                                 }|s3| j                                        }t          j
                    | _        |S | j                            |           | j                                        |k     | j                                        }t          j
                    | _        | j                            ||d                     |d |         S )Nz&size parameter must be an int or long.r   r   )
isinstanceint	TypeErrorr	   seekosSEEK_ENDtellgetvaluer   r   r   write)r   sizeretdr   datas         r   readzUnreader.read   su   JtS$9$9DEEEqyysaxxa%%%<DHMMOO<(##%%Cz||DHJ<

AHhmmoo$$JJLLE h'')):<<
HNN5!!! hmmoo$$ x  "":<<tDEE{###ETE{r   c                     | j                             dt          j                   | j                             |           d S )Nr   )r	   r   r   r   r   )r   r   s     r   unreadzUnreader.unread3   s4    a%%%tr   r   )__name__
__module____qualname__r   r   r    r"    r   r   r   r      sV             $ $ $   @    r   r   c                   &     e Zd Zd fd	Zd Z xZS )SocketUnreader    c                 d    t                                                       || _        || _        d S r   )superr   sockmxchunk)r   r,   	max_chunk	__class__s      r   r   zSocketUnreader.__init__9   s+    	 r   c                 @    | j                             | j                  S r   )r,   recvr-   r
   s    r   r   zSocketUnreader.chunk>   s    y~~dl+++r   )r)   r#   r$   r%   r   r   __classcell__r/   s   @r   r(   r(   8   sL        ! ! ! ! ! !
, , , , , , ,r   r(   c                   $     e Zd Z fdZd Z xZS )IterUnreaderc                 p    t                                                       t          |          | _        d S r   )r+   r   iter)r   iterabler/   s     r   r   zIterUnreader.__init__C   s*    NN			r   c                 n    | j         sdS 	 t          | j                   S # t          $ r d | _         Y dS w xY w)Nr   )r8   nextStopIterationr
   s    r   r   zIterUnreader.chunkG   sM    y 	3		??" 	 	 	DI33	s    44r2   r4   s   @r   r6   r6   B   sG        # # # # #      r   r6   )r   r   r   r(   r6   r&   r   r   <module>r=      s   
 
			 				) ) ) ) ) ) ) )X, , , , ,X , , ,    8     r   