Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/cheroot/__pycache__/server.cpython-39.pyc
Ðазад
a p�hj0 � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlmZ ddlmZmZmZ ddlmZ ddlmZ ddlm Z dd l m Z m Z d Z e �!� d kZ"e�#d d ��$d�Z%e" o�e% Z&e&�r:zddl'Z'ddl(Z(W n e)�y0 dZ&d\Z'Z(Y n0 ddl*Z*e"�rpe+ed��rpe+ed��s^de_,e+ed��spde_-e+ed��s�e�r�dnde_.dZ/dZ0dZ1d Z2d Z3d Z4d Z5d Z6d!Z7d"Z8e�9d �:d#e8f��Z;e<� Z=g d$�Z>e+e d%��s�i e _?G d&d'� d'�Z@G d(d)� d)e@�ZAG d*d+� d+�ZBG d,d-� d-�ZCG d.d/� d/�ZDG d0d1� d1�ZEG d2d3� d3�ZFG d4d5� d5�ZGG d6d7� d7�ZHd8d9d:�ZId>d<d=�ZJdS )?a� A high-speed, production ready, thread pooled, generic HTTP server. For those of you wanting to understand internals of this module, here's the basic call flow. The server's listening thread runs a very tight loop, sticking incoming connections onto a Queue:: server = HTTPServer(...) server.start() -> serve() while ready: _connections.run() while not stop_requested: child = socket.accept() # blocks until a request comes in conn = HTTPConnection(child, ...) server.process_conn(conn) # adds conn to threadpool Worker threads are kept in a pool and poll the Queue, popping off and then handling each connection in turn. Each connection can consist of an arbitrary number of requests and their responses, so we run a nested loop:: while True: conn = server.requests.get() conn.communicate() -> while True: req = HTTPRequest(...) req.parse_request() -> # Read the Request-Line, e.g. "GET /page HTTP/1.1" req.rfile.readline() read_headers(req.rfile, req.inheaders) req.respond() -> response = app(...) try: for chunk in response: if chunk: req.write(chunk) finally: if hasattr(response, "close"): response.close() if req.close_connection: return For running a server you can invoke :func:`start() <HTTPServer.start()>` (it will run the server forever) or use invoking :func:`prepare() <HTTPServer.prepare()>` and :func:`serve() <HTTPServer.serve()>` like this:: server = HTTPServer(...) server.prepare() try: threading.Thread(target=server.serve).start() # waiting/detecting some appropriate stop condition here ... finally: server.stop() And now for a trivial doctest to exercise the test suite .. testsetup:: from cheroot.server import HTTPServer >>> 'HTTPServer' in globals() True � N)� lru_cache� )� connections�errors� __version__)�bton)�IS_PPC)� threadpool)�MakeFile� StreamWriter) � HTTPRequest�HTTPConnection� HTTPServer� HeaderReader�DropUnderscoreHeaderReader�SizeCheckWrapper�KnownLengthRFile� ChunkedRFile�Gateway�get_ssl_adapter_class�Windows�SERVER_SOFTWARE� zGoogle App Engine/F)NN�AF_INET6� IPPROTO_IPV6�) � IPV6_V6ONLY� � SO_PEERCRED� � � s � � � :� ;� � *� /s %2Fs (?i))s Accepts Accept-Charsets Accept-Encodings Accept-Languages Accept-Rangess Allows Cache-Control� Connections Content-Encodings Content-Language� Expects If-Matchs If-None-Matchs Pragmas Proxy-Authenticates TEs Trailer� Transfer-Encodings Upgrades Varys Vias Warnings WWW-Authenticate� statisticsc @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS ) r z`Object for reading headers from an HTTP request. Interface and default implementation. Nc C s� |du r i }|� � }|s td��|tkr*q�|�t�s<td��|dd� ttfv rZ|�� }nFz|�td�\}}W n ty� td��Y n0 |�� }| � |�}|}| � |�s�q |t v r�|� |�}|r�d� ||f�}|||< q |S )a� Read headers from the given stream into the given header dict. If hdict is None, a new header dict is created. Returns the populated header dict. Headers which are repeated are folded together using a comma if their specification so dictates. This function raises ValueError when the read bytes violate the HTTP spec. You should probably return "400 Bad Request" if this happens. N�Illegal end of headers.� HTTP requires CRLF terminatorsr zIllegal header line.s , )�readline� ValueError�CRLF�endswith�SPACE�TAB�strip�split�COLON�_transform_key� _allow_header�comma_separated_headers�get�join)�self�rfileZhdict�line�v�k�hname�existing� rD �~/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/cheroot/server.py�__call__� s4 zHeaderReader.__call__c C s dS )NTrD �r= �key_namerD rD rE r9 � s zHeaderReader._allow_headerc C s |� � �� S �N)r5 �titlerG rD rD rE r8 � s zHeaderReader._transform_key)N)�__name__� __module__� __qualname__�__doc__rF r9 r8 rD rD rD rE r � s 8r c s e Zd ZdZ� fdd�Z� ZS )r zDCustom HeaderReader to exclude any headers with underscores in them.c s t t| ��|�}|od|vS )N�_)�superr r9 )r= rH �orig�� __class__rD rE r9 � s z(DropUnderscoreHeaderReader._allow_header)rK rL rM rN r9 � __classcell__rD rD rR rE r � s r c @ sZ e Zd ZdZdd� Zdd� Zddd�Zdd d �Zdd d �Zdd� Z dd� Z dd� Z e Z dS )r z�Wraps a file-like object, raising MaxSizeExceeded if too large. :param rfile: ``file`` of a limited size :param int maxlen: maximum length of the file being read c C s || _ || _d| _dS )z%Initialize SizeCheckWrapper instance.r N)r> �maxlen� bytes_read)r= r> rU rD rD rE �__init__ s zSizeCheckWrapper.__init__c C s | j r| j| j krt�� �d S rI )rU rV r �MaxSizeExceeded�r= rD rD rE � _check_length s z SizeCheckWrapper._check_lengthNc C s* | j �|�}| jt|�7 _| �� |S )��Read a chunk from ``rfile`` buffer and return it. :param size: amount of data to read :type size: int :returns: chunk from ``rfile``, limited by size if specified :rtype: bytes )r> �readrV �lenrZ �r= �size�datarD rD rE r\ s zSizeCheckWrapper.readc C s� |dur2| j �|�}| jt|�7 _| �� |S g }| j �d�}| jt|�7 _| �� |�|� t|�dk s�|dd� tkr6t�|�S q6dS )��Read a single line from ``rfile`` buffer and return it. :param size: minimum amount of data to read :type size: int :returns: one line from ``rfile`` :rtype: bytes N� ���) r> r/ rV r] rZ �append�LF�EMPTYr< )r= r_ r` �resrD rD rE r/ s zSizeCheckWrapper.readliner c C sV d}g }| � |�}|rR|�|� |t|�7 }d| k r@|krFqR nqR| � |�}q|S �z�Read all lines from ``rfile`` buffer and return them. :param sizehint: hint of minimum amount of data to read :type sizehint: int :returns: lines of bytes read from ``rfile`` :rtype: list[bytes] r �r/ rd r] �r= �sizehint�total�linesr? rD rD rE � readlines9 s zSizeCheckWrapper.readlinesc C s | j �� dS �z*Release resources allocated for ``rfile``.N�r> �closerY rD rD rE rq N s zSizeCheckWrapper.closec C s | S �zReturn file iterator.rD rY rD rD rE �__iter__R s zSizeCheckWrapper.__iter__c C s( t | j�}| jt|�7 _| �� |S �zGenerate next file chunk.)�nextr> rV r] rZ �r= r` rD rD rE �__next__V s zSizeCheckWrapper.__next__)N)N)r ) rK rL rM rN rW rZ r\ r/ rn rq rs rw ru rD rD rD rE r � s r c @ sR e Zd ZdZdd� Zddd�Zddd�Zdd d �Zd d � Zdd� Z dd� Z e Z dS )r z�Wraps a file-like object, returning an empty string when exhausted. :param rfile: ``file`` of a known size :param int content_length: length of the file being read c C s || _ || _dS )z%Initialize KnownLengthRFile instance.N)r> � remaining)r= r> �content_lengthrD rD rE rW g s zKnownLengthRFile.__init__Nc C sL | j dkrdS |du r | j }n t|| j �}| j�|�}| j t|�8 _ |S )z�Read a chunk from ``rfile`` buffer and return it. :param size: amount of data to read :type size: int :rtype: bytes :returns: chunk from ``rfile``, limited by size if specified r r& N)rx �minr> r\ r] r^ rD rD rE r\ l s zKnownLengthRFile.readc C sL | j dkrdS |du r | j }n t|| j �}| j�|�}| j t|�8 _ |S )ra r r& N)rx rz r> r/ r] r^ rD rD rE r/ � s zKnownLengthRFile.readliner c C sV d}g }| � |�}|rR|�|� |t|�7 }d| k r@|krFqR nqR| � |�}q|S rh ri rj rD rD rE rn � s zKnownLengthRFile.readlinesc C s | j �� dS ro rp rY rD rD rE rq � s zKnownLengthRFile.closec C s | S rr rD rY rD rD rE rs � s zKnownLengthRFile.__iter__c C s t | j�}| jt|�8 _|S rt )ru r> rx r] rv rD rD rE rw � s zKnownLengthRFile.__next__)N)N)r ) rK rL rM rN rW r\ r/ rn rq rs rw ru rD rD rD rE r ` s r c @ sP e Zd ZdZddd�Zdd� Zddd �Zdd d �Zdd d�Zdd� Z dd� Z dS )r a� Wraps a file-like object, returning an empty string when exhausted. This class is intended to provide a conforming wsgi.input value for request entities that have been encoded with the 'chunked' transfer encoding. :param rfile: file encoded with the 'chunked' transfer encoding :param int maxlen: maximum length of the file being read :param int bufsize: size of the buffer used to read the file � c C s( || _ || _d| _t| _|| _d| _dS )z!Initialize ChunkedRFile instance.r FN)r> rU rV rf �buffer�bufsize�closed)r= r> rU r} rD rD rE rW � s zChunkedRFile.__init__c C s | j r d S | j�� }| jt|�7 _| jrF| j| jkrFt�d| j��|�� � t d�}z|� d�}t |d�}W n" t y� t dj|d���Y n0 |dkr�d| _ d S | jr�| j| | jkr�td��| j�|�}| jt|�7 _| j|7 _| j�d�}|tk�rt d t|� d ��d S ) N�Request Entity Too Larger r � z)Bad chunked transfer size: {chunk_size!r})� chunk_sizeT� z2Bad chunked transfer coding (expected '\r\n', got �))r~ r> r/ rV r] rU r rX r5 r6 � SEMICOLON�pop�intr0 �format�IOErrorr\ r| r1 �repr)r= r? r� �chunkZcrlfrD rD rE �_fetch� sF � �� ���zChunkedRFile._fetchNc C s� t }|dkr|S |r$t|�|kr$|S | js<| �� | js<|S |rp|t|� }|| jd|� 7 }| j|d� | _q|| j7 }t | _qdS )r[ r N)rf r] r| r� )r= r_ r` rx rD rD rE r\ � s zChunkedRFile.readc C s� t }|dkr|S |r$t|�|kr$|S | js<| �� | js<|S | j�t�}|r�|dkr�|t|� }|| jd|� 7 }| j|d� | _q�t|t|� |�}|| jd|� 7 }| j|d� | _q|dkr�|| j7 }t | _q|| jd|� 7 }| j|d� | _qdS )ra r rc N)rf r] r| r� �findre rz )r= r_ r` Z newline_posrx rD rD rE r/ s. zChunkedRFile.readliner c C sV d}g }| � |�}|rR|�|� |t|�7 }d| k r@|krFqR nqR| � |�}q|S rh ri rj rD rD rE rn D s zChunkedRFile.readlinesc c sx | j std��| j�� }|s$td��| jt|�7 _| jrP| j| jkrPtd��|tkrZqt|� t�sltd��|V qdS )zhRead HTTP headers and yield them. :yields: CRLF separated lines :ytype: bytes z:Cannot read trailers until the request body has been read.r- r r. N) r~ r0 r> r/ rV r] rU r� r1 r2 )r= r? rD rD rE �read_trailer_linesY s � z ChunkedRFile.read_trailer_linesc C s | j �� dS ro rp rY rD rD rE rq w s zChunkedRFile.close)r{ )N)N)r ) rK rL rM rN rW r� r\ r/ rn r� rq rD rD rD rE r � s + * r c @ s~ e Zd ZdZdZdZi Zg ZdZdZ dZ e � Z ddd�Z dd� Zd d � Zd d � Zd d� Zddd�Zdd� Zdd� Zdd� ZdS )r zrAn HTTP Request (and response). A single HTTP connection may consist of multiple request/response pairs. NFTc C sx || _ || _d| _d| _d| _| j jdur0d| _d| _i | _d| _g | _ d| _ | j j | _ d| _ | j j| _|| _|| _dS )a Initialize HTTP request container instance. Args: server (HTTPServer): web server object receiving this request conn (HTTPConnection): HTTP connection object for this request proxy_mode (bool): whether this HTTPServer should behave as a PROXY server for certain requests strict_mode (bool): whether we should return a 400 Bad Request when we encounter a request that a HTTP compliant client should not be making Fs httpNs httpszHTTP/1.0r )�server�conn�ready�started_request�scheme� ssl_adapter�response_protocol� inheaders�status� outheaders� sent_headersrS �close_connection� chunked_read� chunked_write� proxy_mode� strict_mode)r= r� r� r� r� rD rD rE rW � s" zHTTPRequest.__init__c C s� t | jj| jj�| _z | �� }W n" tjyB | �dd� Y dS 0 |sLdS z | � � }W n" tjyz | �dd� Y dS 0 |s�dS d| _ dS )z;Parse the next HTTP request start-line and message-headers.z414 Request-URI Too LongzHThe Request-URI sent with the request exceeds the maximum allowed bytes.N� 413 Request Entity Too LargezCThe headers sent with the request exceed the maximum allowed bytes.T) r r� r> r� �max_request_header_size�read_request_liner rX �simple_response�read_request_headersr� )r= �successrD rD rE � parse_request� s2 � � �zHTTPRequest.parse_requestc C s� | j �� }d| _|sdS |tkr2| j �� }|s2dS |�t�sL| �dd� dS z�|�� �td�\}}}|� d�s�| �dd� W dS |dd � �d d �}t |�dkr�| �dd � W dS t t t |��}|d kr�| �dd� W dS W n& ttf�y | �dd� Y dS 0 || _|�� | _| j�r<|| jk�r<d}| �d|� dS ztj�|�\}}} } } W n" t�yx | �dd� Y dS 0 |�p�|} | jdk�r�| j�r�| �r�|n| } �n�| jdk�rb| j�s�| �d� dS tj�d�d|f��} | \}}}}}t}z | j}W n t�y Y n0 ||k�p4| �p4t ||||f�}|�rL| �dd� dS | }} t } } } n�| j�ov| j �ov| }|�r�| �dd� dS | j�o�|� t � �o�| }|�r�d}| �d|� dS | �r�| �dd� dS | d u �r�| �dd � dS zd d � t �| �D �}W n: t�yF } z | �d|j d � W Y d }~dS d }~0 0 t �|�} | � t ��sft | } |tu�rv|| _!|| _"| | _#| | _$t | j%j&d �t | j%j&d �f}|d |d k�r�| �d� dS || _'d!t(||� | _)dS )"z�Read and parse first line of the HTTP request. Returns: bool: True if the request line is valid or False if it's malformed. TF�400 Bad Requestr. r� s HTTP/z$Malformed Request-Line: bad protocol� N� .r z#Malformed Request-Line: bad version)r r z 505 HTTP Version Not SupportedzCannot fulfill requestzMalformed Request-Linez�Malformed method name: According to RFC 2616 (section 5.1.1) and its successors RFC 7230 (section 3.1.1) and RFC 7231 (section 4.1) method names are case-sensitive and uppercase.zMalformed Request-URIs OPTIONSs CONNECTz405 Method Not Allowedr& s //zFInvalid path in Request-URI: request-target must match authority-form.z2Absolute URI not allowed if server is not a proxy.z�Invalid path in Request-URI: request-target must contain origin-form which starts with absolute-path (URI starting with a slash "/").z!Illegal #fragment in Request-URI.z Invalid path in Request-URI.c S s g | ]}t j�|��qS rD )�urllib�parse�unquote_to_bytes��.0�xrD rD rE � <listcomp>� s �z1HTTPRequest.read_request_line.<locals>.<listcomp>r � z HTTP/%s.%s)*r> r/ r� r1 r2 r� r5 r6 r3 � startswithr] �tuple�mapr� r0 � IndexError�uri�upper�methodr� r� r� �urlsplit� UnicodeErrorr� r< rf �port�any� FORWARD_SLASH�QUOTED_SLASH_REGEX�args� QUOTED_SLASHr� � authority�path�qsr� �protocolZrequest_protocolrz r� )r= Z request_liner� r� Z req_protocol�rp�respr� r� r� r� �fragmentZuri_is_absolute_formZ uri_splitZ_schemeZ _authority�_pathZ_qsZ _fragmentZ_portZ invalid_pathZdisallowed_absoluteZatoms�ex�sprD rD rE r� � s � � �� � ��� ������ ��� � � � z HTTPRequest.read_request_linec C s� z| � | j| j� W n8 tyL } z | �d|jd � W Y d}~dS d}~0 0 | jj}zt| j� dd��}W n ty� | �dd� Y dS 0 |r�||kr�| �dd� dS | j d kr�| j� d d �d kr�d | _ n| j� d d �dkr�d | _ d}| j d k�r | j� d�}|�r dd� |� d�D �}d| _ |�r\|D ].}|dk�rBd | _ n| �d� d | _ dS �q,| j� dd �dk�r�d �| jj�d�tdttf�}z| jj�|� W n< tj�y� } z |jd tjv�rȂ W Y d}~n d}~0 0 d S )z�Read ``self.rfile`` into ``self.inheaders``. Ref: :py:attr:`self.inheaders <HTTPRequest.outheaders>`. :returns: success status :rtype: bool r� r NF� Content-Lengthz Malformed Content-Length Header.r� �CThe entity sent with the request exceeds the maximum allowed bytes.�HTTP/1.1r) r& � closeT� Keep-Aliver+ c S s g | ]}|� � r|� � �� �qS rD )r5 �lowerr� rD rD rE r� � r& z4HTTPRequest.read_request_headers.<locals>.<listcomp>� ,� chunkedz501 Unimplementedr* s 100-continue�asciis 100 Continue)� header_readerr> r� r0 r� r� r� �max_request_body_sizer� r; r� r� r6 r� r< r� �encoder3 r1 r� �wfile�write�socket�errorr �socket_errors_to_ignore)r= r� �mrbs�cl�te�enc�msgrD rD rE r� � sb � � �z HTTPRequest.read_request_headersc C s� | j j}| jr t| jj|�| _nDt| j�dd��}|rT||k rT| j sP| � dd� dS t | jj|�| _| j � | �� � | jo�| �� | jr�| jj�d� dS )z/Call the gateway and write its iterable output.r� r r� r� Ns 0 )r� r� r� r r� r> r� r� r; r� r� r �gateway�respondr� �ensure_headers_sentr� r� r� )r= r� r� rD rD rE r� ( s �zHTTPRequest.respondr c C s� t |�}d| jj|f }dt|� }d}|�d�|�d�|�d�g}|dd� dv rtd| _| jd krp|�d � nd }|�t� |r�t |t �r�|�d�}|�|� z| j j � t �|�� W n8 tjy� } z |jd tjvr܂ W Y d}~n d}~0 0 dS ) z+Write a simple response back to the client.z%s %s zContent-Length: %s zContent-Type: text/plain � ISO-8859-1N� )Z413Z414Tr� s Connection: close r� r )�strr� r� r] r� r� r� rd r1 � isinstancer� r� r� rf r< r� r� r� r r� )r= r� r� Z proto_statusry � content_type�bufr� rD rD rE r� ? s. � zHTTPRequest.simple_responsec C s | j sd| _ | �� dS )z:Ensure headers are sent to the client if not already sent.TN)r� � send_headersrY rD rD rE r� d s z HTTPRequest.ensure_headers_sentc C sX | j rF|rFtt|��dd� �d�}|t|tg}| jj�t� |�� n| jj�|� dS )z$Write unbuffered data to the client.r� Nr� ) r� �hexr] r� r1 r� r� r� rf r< )r= r� Zchunk_size_hexr� rD rD rE r� j s zHTTPRequest.writec C s� dd� | j D �}t| jdd� �}|dkr2d| _nLd|vr~|dk s~|d v rLn2| jd ko^| jd k}|rxd| _| j �d � nd| _| js�| jj }| | _d |vr�| jd kr�| jr�| j �d� n| js�| j �d� d| j v r�| j �ddj | jj d�� d�f� | j�s,| j �s,t| jdd�}|dk�r,| j�|� d|v�rV| j �dtjjdd�� d�f� d|v�rz| j �d| jj� d�f� | jj� d�}|t | j t g}| j D ]$\}} |�|t t | t � �q�|�t� | jj�t � |�� dS ) z�Assert, process, and send the HTTP response message-headers. You must set ``self.status``, and :py:attr:`self.outheaders <HTTPRequest.outheaders>` before calling this. c S s g | ]\}}|� � �qS rD )r� )r� �key�valuerD rD rE r� y r& z,HTTPRequest.send_headers.<locals>.<listcomp>Nr� i� Ts content-length�� )�� �� i0 r� s HEAD)r+ r� s connection)r) r� )r) r� r� z timeout={connection_timeout})Zconnection_timeoutr� rx r s dates Date)�usegmts servers Serverr� ) r� r� r� r� r� r� r� rd r� � can_add_keepalive_connectionr� �timeoutr� r� �getattrr> r\ �email�utils� formatdate� server_namer� r3 r1 r7 r� r� r� rf r< ) r= Zhkeysr� Z needs_chunkedZcan_keeprx �protor� rA r@ rD rD rE r� s sh � ��� � � zHTTPRequest.send_headers)FT)r )rK rL rM rN r� r� r� r� r� r� r� r r� rW r� r� r� r� r� r� r� r� rD rD rD rE r | s& !" d` % r c @ s� e Zd ZdZdZdZdZejZ ejZ e Z dZ dZdZefdd�Zdd� ZdZdd � Zd d � Zd d � Zdd� Zedd� �Zedd� �Zedd� �Zdd� Z edd� �Z edd� �Z d d � Z dS ) r z#An HTTP connection (active socket).NFc C sn || _ || _||d| j�| _||d| j�| _d| _| j j| _| j j| _t dd�| j �| _ t dd�| j �| _ dS )aB Initialize HTTPConnection instance. Args: server (HTTPServer): web server object receiving this request sock (socket._socketobject): the raw socket object (usually TCP) for this connection makefile (file): a fileobject class for reading from the socket �rb�wbr r )�maxsizeN) r� r� �rbufsizer> �wbufsizer� � requests_seen�peercreds_enabled�peercreds_resolve_enabledr �resolve_peer_creds�get_peer_creds)r= r� �sock�makefilerD rD rE rW � s ��zHTTPConnection.__init__c C s~ d}zZ| � | j| �}|�� | jjd r6| jd7 _|jsBW dS d}|�� |jsZW dS W �n tj y� } zp|j d }d}||v r�|r�|r�|j r�| � |d� n2|t jvr�| jjdt|� tjdd � | � |d � W Y d }~n�d }~0 ttfy� � Y n| t j�y Y nh t j�y0 | �|� Y nJ t�yx } z0| jjt|�tjdd � | � |d � W Y d }~n d }~0 0 dS ) zrRead each request and respond appropriately. Returns true if the connection should be kept open. F�Enabledr Tr )z timed outz The read operation timed outz408 Request Timeoutzsocket.error %s��level� tracebackz500 Internal Server ErrorN)�RequestHandlerClassr� r� �statsr� r� r� r� r� r� r� r� �_conditional_errorr r� � error_logr� �logging�WARNING�KeyboardInterrupt� SystemExit� FatalSSLAlert� NoSSLError�_handle_no_ssl� Exception�ERROR)r= Z request_seen�reqr� ZerrnumZ timeout_errsrD rD rE � communicate� sH � �"zHTTPConnection.communicatec C s` |r |j rd S z | jj}W n ty4 | jj}Y n0 t|d| j�| _d}|�d|� d| _ d S )Nr� zUThe client sent a plain HTTP request, but this server only speaks HTTPS on this port.r� T) r� r� �_sock�AttributeError�_socketr r� r� r� �linger)r= r Z resp_sockr� rD rD rE r . s � z HTTPConnection._handle_no_sslc C sR |r |j rdS z|�|� W n0 tjy0 Y n tjyL | �|� Y n0 dS )zvRespond with an error. Don't bother writing if a response has already started being written. N)r� r� r r r r )r= r �responserD rD rE r ? s z!HTTPConnection._conditional_errorc C s( | j �� | js$| �� | j�� n dS )z,Close the socket underlying this connection.N)r> rq r �_close_kernel_socketr� rY rD rD rE rq O s zHTTPConnection.closec C s� d}t s| jjtjkr td��n| js.td��z | j�tjtj t � |��}W n, tj yx } zt|�W Y d}~n&d}~0 0 t � ||�\}}}|||fS dS )a� Return the PID/UID/GID tuple of the peer socket for UNIX sockets. This function uses SO_PEERCRED to query the UNIX PID, UID, GID of the peer, which is only available if the bind address is a UNIX domain socket. Raises: NotImplementedError: in case of unsupported socket type RuntimeError: in case of SO_PEERCRED lookup unsupported or disabled Z3iz5SO_PEERCRED is only supported in Linux kernel and WSLz0Peer creds lookup is disabled within this serverN)� IS_WINDOWSr� �family�AF_UNIX�NotImplementedErrorr� � RuntimeError� getsockopt� SOL_SOCKETr �struct�calcsizer� �unpack)r= ZPEERCRED_STRUCT_DEFZ peer_credsZ socket_err�pid�uid�gidrD rD rE r b s$ ��� z HTTPConnection.get_peer_credsc C s | � � \}}}|S )z,Return the id of the connected peer process.�r )r= r' rO rD rD rE �peer_pid� s zHTTPConnection.peer_pidc C s | � � \}}}|S )z1Return the user id of the connected peer process.r* )r= rO r( rD rD rE �peer_uid� s zHTTPConnection.peer_uidc C s | � � \}}}|S )z2Return the group id of the connected peer process.r* )r= rO r) rD rD rE �peer_gid� s zHTTPConnection.peer_gidc C s@ t std��n| js td��t�| j�j}t� | j �j }||fS )a Look up the username and group tuple of the ``PEERCREDS``. :returns: the username and group tuple of the ``PEERCREDS`` :raises NotImplementedError: if the OS is unsupported :raises RuntimeError: if UID/GID lookup is unsupported or disabled z�UID/GID lookup is unavailable under current platform. It can only be done under UNIX-like OS but not under the Google App Enginez-UID/GID lookup is disabled within this server) �IS_UID_GID_RESOLVABLEr r� r! �pwd�getpwuidr, �pw_name�grp�getgrgidr- �gr_name)r= �user�grouprD rD rE r � s ��z!HTTPConnection.resolve_peer_credsc C s | � � \}}|S )z2Return the username of the connected peer process.�r )r= r5 rO rD rD rE � peer_user� s zHTTPConnection.peer_userc C s | � � \}}|S )z/Return the group of the connected peer process.r7 )r= rO r6 rD rD rE � peer_group� s zHTTPConnection.peer_groupc C sl t | jd| jj�}z|tj� W nF tjy4 Y n4 tjyf } z|jtjvrR� W Y d}~n d}~0 0 dS )z0Terminate the connection at the transport level.Z sock_shutdownN) r� r� �shutdown� SHUT_RDWRr Z#acceptable_sock_shutdown_exceptionsr� �errnoZ$acceptable_sock_shutdown_error_codes)r= r: �erD rD rE r � s � z#HTTPConnection._close_kernel_socket) rK rL rM rN Z remote_addrZ remote_portZssl_env�io�DEFAULT_BUFFER_SIZEr� r� r r r� r� Z last_usedr rW r r r r rq r �propertyr+ r, r- r r8 r9 r rD rD rD rE r � s: 3+ r c @ sv e Zd ZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZdjed �ZdZd Zd Zd Zd ZeZdZd Zd Zd Z dZ d@dd�Z dd� Z dd� Z dd� Z!e"dd� �Z#e#j$dd� �Z#dd� Z%dd � Z&d d � Z'd d � Z(e)j*d!d"� �Z+e"d#d$� �Z,d%d&� Z-dAd)d*�Z.dBd+d,�Z/d-d.� Z0e1d/d0� �Z2e3dCd1d2��Z4e1d3d4� �Z5e1d5d6� �Z6d7d8� Z7e"d9d:� �Z8e"d;d<� �Z9e8j$d=d:� �Z8d>d?� Z:dS )Dr zAn HTTP server.z 127.0.0.1Nr� r� � g �?zCheroot/{version!s})�versionFr Trc c C sT || _ || _tj| |pd|d�| _|s,| j}|| _|| _|o>|| _|| _ | � � dS )a Initialize HTTPServer instance. Args: bind_addr (tuple): network interface to listen to gateway (Gateway): gateway for processing HTTP requests minthreads (int): minimum number of threads for HTTP thread pool maxthreads (int): maximum number of threads for HTTP thread pool server_name (str): web server name to be advertised via Server HTTP header reuse_port (bool): if True SO_REUSEPORT option would be set to socket r )rz �maxN) � bind_addrr� r Z ThreadPool�requestsrB r� r� r� � reuse_port� clear_stats) r= rD r� � minthreads� maxthreadsr� r� r� rF rD rD rE rW 3 s ��zHTTPServer.__init__c s� d� _ d� _d� fdd�� fdd�d� fdd�� fdd�� fd d�� fd d�dd d� d d� d d� dd� dd� dd� i d�� _� jtjdt� � < dS )z Reset server stat counters..Nr Fc s t � j�S rI )r� rD ��srY rD rE �<lambda>\ r& z(HTTPServer.clear_stats.<locals>.<lambda>c s | d rdp� � � S )Nr rc ��runtimerJ rY rD rE rL ] r& c s | d � � � S )N�AcceptsrM rJ rY rD rE rL _ r& c s t � jdd �S )N�qsize�r� rE rJ rY rD rE rL ` r& c s t t� jdg ��S )N�_threads)r] r� rE rJ rY rD rE rL a r& c s t � jdd �S )NZidlerQ rJ rY rD rE rL b r& c S s* | d rdp(t dd� | d �� D �d�S )Nr rc c s s | ]}|d |�V qdS )�RequestsNrD �r� �wrD rD rE � <genexpr>e r& �;HTTPServer.clear_stats.<locals>.<lambda>.<locals>.<genexpr>�Worker Threadsr ��sum�valuesrJ rD rD rE rL d s �c S s* | d rdp(t dd� | d �� D �d�S )Nr rc c s s | ]}|d |�V qdS )� Bytes ReadNrD rT rD rD rE rV h r& rW rX r rY rJ rD rD rE rL g s �c S s* | d rdp(t dd� | d �� D �d�S )Nr rc c s s | ]}|d |�V qdS )� Bytes WrittenNrD rT rD rD rE rV k r& rW rX r rY rJ rD rD rE rL j s �c S s* | d rdp(t dd� | d �� D �d�S )Nr rc c s s | ]}|d |�V qdS )� Work TimeNrD rT rD rD rE rV o r& rW rX r rY rJ rD rD rE rL n s �c S s* | d rdp(t dd� | d �� D �d�S )Nr rc c s s* | ]"}|d |�|d |�p d V qdS )r\ r^ ���ư>NrD rT rD rD rE rV r s �rW rX r rY rJ rD rD rE rL q s ��c S s* | d rdp(t dd� | d �� D �d�S )Nr rc c s s* | ]"}|d |�|d |�p d V qdS )r] r^ r_ NrD rT rD rD rE rV x s �rW rX r rY rJ rD rD rE rL w s ��)r z Bind AddresszRun timerO z Accepts/sec�QueueZThreadsz Threads Idlez Socket ErrorsrS r\ r] r^ zRead ThroughputzWrite ThroughputrX zCheroot HTTPServer %d)� _start_time� _run_timer r r, �idrY rD rY rE rG V s( �%zHTTPServer.clear_statsc C s( | j du r| jS | jt�� | j S dS )zReturn server uptime.N)ra rb �timerY rD rD rE rN � s zHTTPServer.runtimec C s d| j | jj| jf S )z1Render Server instance representing bind address.z %s.%s(%r))rL rS rK rD rY rD rD rE �__str__� s �zHTTPServer.__str__c C s | j S )a� Return the interface on which to listen for connections. For TCP sockets, a (host, port) tuple. Host values may be any :term:`IPv4` or :term:`IPv6` address, or any valid hostname. The string 'localhost' is a synonym for '127.0.0.1' (or '::1', if your hosts file prefers :term:`IPv6`). The string '0.0.0.0' is a special :term:`IPv4` entry meaning "any active interface" (INADDR_ANY), and '::' is the similar IN6ADDR_ANY for :term:`IPv6`. The empty string or :py:data:`None` are not allowed. For UNIX sockets, supply the file name as a string. Systemd socket activation is automatic and doesn't require tempering with this variable. .. glossary:: :abbr:`IPv4 (Internet Protocol version 4)` Internet Protocol version 4 :abbr:`IPv6 (Internet Protocol version 6)` Internet Protocol version 6 )� _bind_addrrY rD rD rE rD � s zHTTPServer.bind_addrc C s( t |t�r |d dv r td��|| _dS )z5Set the interface on which to listen for connections.r )r NzzHost values of '' or None are not allowed. Use '0.0.0.0' (IPv4) or '::' (IPv6) instead to listen on all active interfaces.N)r� r� r0 rf )r= r� rD rD rE rD � s �c C s� z | � � W nr tyF } z"| j}|s,|| _||�W Y d}~nBd}~0 ty~ } z"| j}|sd|| _||�W Y d}~n d}~0 0 dS )z4Run the server forever, and stop it cleanly on exit.N)�startr � interruptr )r= Z kb_intr_excZunderlying_interruptZ sys_exit_excrD rD rE � safe_start� s zHTTPServer.safe_startc C s d| _ | jdu r d| j | _d| _d}t�dd�rJt�dtjtj�| _�n`t | j t t f�r�z| � | j � W nB tjy� } z(d|| j |f }t�|�|�W Y d}~n d}~0 0 n�| j \}}z t�||tjtjdtj�}W nL tj�y$ tj}| j }d|v �rtj}|d }|tjdd |fg}Y n0 |D ]~}|\} } } } } z| �| | | � W �q�W nN tj�y� } z2d|| |f }| j�r�| j�� d| _W Y d}~n d}~0 0 �q*| j�s�t�|��| j�d � | j�| j� t�| �| _| j � � d | _ t � � | _ dS ) z�Prepare server to serving requests. It binds a socket's port, setups the socket to ``listen()`` and does other preparing things. Nz %s ServerzNo socket could be createdZ LISTEN_PIDr� z%s -- (%s: %s)r �:)r r r r T)!� _interrupt�softwarerB r� �os�getenv�fromfd�AF_INET� SOCK_STREAMr� rD r� �bytes�bind_unix_socketr� � getaddrinfo� AF_UNSPEC� AI_PASSIVE�gaierrorr �bindrq � settimeout�listen�request_queue_sizer ZConnectionManager� _connectionsrE rg r� rd ra )r= r� Zserr�hostr� �infoZ sock_typerD rg �af�socktyper� � _canonname�sarD rD rE �prepare� sX $ � zHTTPServer.preparec C s� | j r\| js\z| j�| j� W q ttfy6 � Y q tyX | jdt j dd� Y q 0 q | jr�| j rtt � d� qb| jr�| j�dS )z1Serve requests, after invoking :func:`prepare()`.zError in HTTPServer.serveTr g�������?N)r� rh r| �run�expiration_intervalr r r r r r �_stopping_for_interruptrd �sleeprY rD rD rE �serve s � zHTTPServer.servec C s | � � | �� dS )zmRun the server forever. It is shortcut for invoking :func:`prepare()` then :func:`serve()`. N)r� r� rY rD rD rE rg + s zHTTPServer.startc c sF | � � tj| jd�}d|_|�� z|V W | �� n | �� 0 dS )z4Context manager for running this server in a thread.)�targetTN)r� � threading�Threadr� �daemonrg �stop)r= �threadrD rD rE �_run_in_thread7 s zHTTPServer._run_in_threadc C s | j o | jjS )z>Flag whether it is allowed to add a new keep-alive connection.)r� r| r� rY rD rD rE r� C s z'HTTPServer.can_add_keepalive_connectionc C s | j r| j�|� n|�� dS )z7Put an idle connection back into the ConnectionManager.N)r� r| �putrq �r= r� rD rD rE �put_connH s zHTTPServer.put_connr � c C sD t j�dj|d�� t j�� |r@t�� }t j�|� t j�� dS )z�Write error message to log. Args: msg (str): error message level (int): logging level traceback (bool): add traceback to output or not z{msg!s} )r� N)�sys�stderrr� r� �flush� traceback_� format_exc)r= r� r r ZtblinesrD rD rE r P s zHTTPServer.error_logc C sB | � | j|||| j| j| j�}| �|| j� }| _| �|�| _|S )z.Create (or recreate) the actual socket object.)�prepare_socketrD �nodelayr� rF � bind_socketr� �resolve_real_bind_addr)r= r �typer� r rD rD rE rx ` s � zHTTPServer.bindc C s� t r td��d}zt�| j� W n� ty2 Y nz tyf } z t|�}d|vrR� W Y d}~nNd}~0 ty� } z.t|�}d|vr�d|vr�d|vr�� W Y d}~n d}~0 0 | j|t j t j d| j | j | jd �}zt�|�� |� d }W n ty� d }Y n0 z| �||�}W n t j�y. |�� � Y n0 | �|�}zD|�s|zt�||� W n$ t�yv tj||d d � Y n0 d }W n t�y� Y n0 |�s�| jd tjd� || _|| _ |S )z*Create (or recreate) a UNIX socket object.z0AF_UNIX sockets are not supported under Windows.i� zJremove() argument 1 must be encoded string without null bytes, not unicodeNz'unlink: embedded null character in pathzembedded null bytez0argument must be a string without NUL charactersr )rD r r� r� r� r� rF TF)�follow_symlinksz(Failed to set socket fs mode permissions)r )r r0 rm �unlinkrD �OSError� TypeErrorr� r� r� r rq r� r� rF �fchmod�filenor� r� rq r� �lchmodr �chmodr r r )r= rD Zfs_permissionsZtyp_err�err_msgZval_errr Z FS_PERMS_SETrD rD rE rs l s~ � ������� � �zHTTPServer.bind_unix_socketc C s� |d d� \}}|dk}| j tjtjfvr2td��|r>td��ttd�r\| �tjtjd� n>ttd�rz| �tjtj d� n t r�| �tjtj d� nt d��d S ) Nr� r z Cannot reuse a non-IP socketz"Cannot reuse an ephemeral port (0)�SO_REUSEPORT_LBr � SO_REUSEPORTz,Current platform does not support port reuse) r r� rp r r0 �hasattr� setsockoptr# r� r� r � SO_REUSEADDRr )�socket_rD r} r� �IS_EPHEMERAL_PORTrD rD rE �_make_socket_reusable� s �z HTTPServer._make_socket_reusablec C s� t � |||�}t�|� |dd� \} } | dk} |rB| j||d� ts\| s\|�t jt jd� |r�t|t t f�s�|�t j t j d� |dur�|� |�}tt d�o�|t jko�| dv } | r�z|�t jt jd� W n tt jfy� Y n0 |S )z%Create and prepare the socket object.Nr� r �r� rD r r )z::z::0z ::0.0.0.0)r� r Zprevent_socket_inheritancer� r r� r# r� r� r� rr � IPPROTO_TCP� TCP_NODELAYrx r� r r r r r� ) �clsrD r r� r� r� r� rF r r} r� r� Zlistening_ipv6rD rD rE r� � s2 �� �zHTTPServer.prepare_socketc C s | � |� | S )z#Bind the socket to given interface.)rx r� rD rD rE r� s zHTTPServer.bind_socketc C s< | � � }| jtjtjfv r&|dd� S t|t�r8t|�}|S )z/Retrieve actual bind address from bound socket.Nr� )� getsocknamer r� rp r r� rr r r� rD rD rE r� s � z!HTTPServer.resolve_real_bind_addrc C s2 z| j �|� W n tjy, |�� Y n0 dS )z#Process an incoming HTTPConnection.N)rE r� �queue�Fullrq r� rD rD rE � process_conn* s zHTTPServer.process_connc C s | j S )z Flag interrupt of the server.)rk rY rD rD rE rh 2 s zHTTPServer.interruptc C s | j tu S )z8Return whether the server is responding to an interrupt.)rk �_STOPPING_FOR_INTERRUPTrY rD rD rE r� 7 s z"HTTPServer._stopping_for_interruptc C s@ t | _t|t�r| �d� t|t�r.| �d� | �� || _dS )a Perform the shutdown of this server and save the exception. Typically invoked by a worker thread in :py:mod:`~cheroot.workers.threadpool`, the exception is raised from the thread running :py:meth:`serve` once :py:meth:`stop` has completed. z!Keyboard Interrupt: shutting downz SystemExit raised: shutting downN)r� rk r� r r r r� )r= rh rD rD rE rh < s c C sr | j s dS d| _ | jdur2| jt�� | j 7 _d| _| j�� t| dd�}|�rVt| jt t f��s<z|� � dd� \}}W n8 t j y� } z |jd tjvr�� W Y d}~n�d}~0 0 t �||t jt j�D ]n}|\}}}} } d} z2t � |||�} | �d� | �||f� | �� W q� t j �y8 | �r4| �� Y q�0 q�t|d��rP|�� d| _ | j�� | j�| j� dS )z5Gracefully shutdown a server that is serving forever.NFr� r� r g �?rq )r� ra rb rd r| r� r� r� rD r� rr r� r� r� r� r r� rt ru rq ry �connectrq r� rE �shutdown_timeout) r= r r} r� r� rg r r� r� r� Z_sarK rD rD rE r� P sD � zHTTPServer.stop)rA rc NFFF)r r� F)r )F);rK rL rM rN rf rk r� rH rI r� r� r{ r� r� r� r� r rB rl r� r� r� r� r ZConnectionClassr� r� r� rF Zkeep_alive_conn_limitrW rG rN re r@ rD �setterri r� r� rg � contextlib�contextmanagerr� r� r� r rx rs � staticmethodr� � classmethodr� r� r� r� rh r� r� rD rD rD rE r � s� � #+ G S � 4 r c @ s e Zd ZdZdd� Zdd� ZdS )r zDBase class to interface HTTPServer with other systems, such as WSGI.c C s || _ dS )zuInitialize Gateway instance with request. Args: req (HTTPRequest): current HTTP request N)r )r= r rD rD rE rW � s zGateway.__init__c C s t �dS )z>Process the current request. Must be overridden in a subclass.N)r rY rD rD rE r� � s zGateway.respondN)rK rL rM rN rW r� rD rD rD rE r � s r z%cheroot.ssl.builtin.BuiltinSSLAdapterz&cheroot.ssl.pyopenssl.pyOpenSSLAdapter)�builtinZ pyopensslr� c C s� t | �� }t|t�r�|�d�}||d d� }|d|� }z tj| }|du rVt� �W n& ty~ t|t � t � dg�}Y n0 zt ||�}W n" t y� t d||f ��Y n0 |S )z/Return an SSL adapter class for the given name.�.r Nr z!'%s' object has no attribute '%s') � ssl_adaptersr� r� r� �rfindr� �modules�KeyError� __import__�globals�localsr� r )�name�adapterZlast_dot� attr_nameZmod_path�modrD rD rE r � s( �� r )r� )KrN rm r> �re� email.utilsr� r� r� rd r r� r �platformr� r� r� � urllib.parser� � functoolsr r r r r �_compatr r �workersr r r r �__all__�systemr rn r� ZIS_GAEr. r2 r/ � ImportErrorr$ r� r r r re r1 r4 r3 r7 r� rf ZASTERISKr� r� �compiler< r� r r� r: r, r r r r r r r r r r� r rD rD rD rE �<module> s� C FaZ C W 7�
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка