← Back
Editing: fcgi_base.cpython-311.pyc
� #H\aA� � � � d Z dZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddlZn# e $ r ddlZY nw xY wddlZddlmZ dZej dk reZd� ZneZd� Z eed � � sd e_ dgZdZdZd Zd Zd ZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'e'Z(dZ)d Z*d Z+d Z,dZ-dZ.d Z/d Z0dZ1dZ2dZ3dZ4dZ5dZ6dZ7dZ8 ej9 e7� � Z: ej9 e8� � Z; ddl<Z<dZ=dZ>d� Z? G d� d e@� � ZA G d!� d"eA� � ZB G d#� d$e@� � ZC G d%� d&e@� � ZD G d'� d(e@� � ZEd6d)�ZFd*� ZG G d+� d,e@� � ZH G d-� d.e@� � ZI G d/� d0eI� � ZJ G d1� d2e@� � ZK G d3� d4eK� � ZL G d5� de@� � ZMdS )7zAllan Saddi <allan@saddi.com>z $Revision$� N)� get_errnoTi c �, � | � d� � S )N�latin-1)�decode��ss �7/usr/lib/python3/dist-packages/flup/server/fcgi_base.py�<lambda>r 3 s � �!�(�(�9�-�-� � c � � | S �N� r s r r r 6 s � �!� r �SHUT_WR� �BaseFCGIServer� � � � � � � � � � �FCGI_MAX_CONNS� FCGI_MAX_REQS�FCGI_MPXS_CONNSz!BBHHBxz!HB5xz!LB3xz!B7xz /tmp/fcgi.logc �� � t | k rd S t t d� � }|� t j � � dd� �d|�d�� � |� � � d S # Y d S xY w)N�ar ���zfcgi: � )�DEBUG�open�DEBUGLOG�write�time�ctime�close)�level�msg�fs r �_debugr- r su � ��5�=�=��F� ��X�s�#�#�A� �G�G�d�j�l�l�1�R�4�&8�&8�&8�#�#�#�>�?�?�?� �G�G�I�I�I�I�I�� ��D�D���s �AA. �.A3c �R � e Zd ZdZd� Zd� Zd� Zdd�Zdd�Zdd �Z d� Z d� ZeZd � Z dS )�InputStreamz� File-like object representing FastCGI input streams (FCGI_STDIN and FCGI_DATA). Supports the minimum methods required by WSGI spec. c �| � || _ |j j | _ d| _ g | _ d| _ d| _ d| _ d S )Nr r F) �_conn�server�inputStreamShrinkThreshold�_shrinkThreshold�_buf�_bufList�_pos�_avail�_eof)�self�conns r �__init__zInputStream.__init__� s? � ��� � !%�� F����� ��� ��� ������ � � r c � � | j | j k rB| j | j d� | _ | xj | j z c_ d| _ | j dk sJ �dS dS )z6Gets rid of already read data (since we can't rewind).Nr )r7 r4 r5 r8 �r: s r � _shrinkBufferzInputStream._shrinkBuffer� sb � ��9��-�-�-�� �$�)�*�*�-�D�I��K�K�4�9�$�K�K��D�I��;�!�#�#�#�#� .�-� $�#r c �8 � | j � � � dS )z(Waits for more data to become available.N)r1 � process_inputr>