File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/cheroot/__pycache__/server.cpython-310.pyc
Back
o ;jL9 � @ s| d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlmZ ddlmZmZmZ ddlmZmZ ddlm Z m Z ddl m Z d Z e�!� d kZ" e�#d d ��$d �Z% e" oxe% Z& e&r�z ddl'Z'ddl(Z(W n e)y� dZ&d\Z'Z(Y nw ddl*Z*nd\Z'Z(Z*e"r�e+e d�r�e+e d�s�de _,e+e d�s�de _-e+e d�s� er�dnde _.dZ/dZ0dZ1d Z2d Z3d Z4d Z5d Z6d!Z7d"Z8e �9d �:d#e8f��Z;e<� Z=g d$�Z>e+ed%�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� )� __version__� connections�errors)�IS_PPC�bton)�MakeFile� StreamWriter)� threadpool) � ChunkedRFile�DropUnderscoreHeaderReader�Gateway�HTTPConnection� HTTPRequest� HTTPServer� HeaderReader�KnownLengthRFile�SizeCheckWrapper�get_ssl_adapter_class�WindowsZSERVER_SOFTWARE� zGoogle App Engine/F)NN)NNN�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 ri }d} |� � }|std��|tkr |S |�t�s#td��|dd� tthv r2|�� }n!z |�td�\}}W n tyG td��w |�� }| � |�}|}| � |�sYq|t v rk|� |�}|rkd� ||f�}|||< q )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. NT�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�hname�line�v�k�existing� rC �B/opt/saltstack/salt/lib/python3.10/site-packages/cheroot/server.py�__call__� s< � � �zHeaderReader.__call__c C s dS )NTrC �r< �key_namerC rC rD r8 s zHeaderReader._allow_headerc C s |� � �� S �N)r4 �titlerF rC rC rD r7 s zHeaderReader._transform_keyrH )�__name__� __module__� __qualname__�__doc__rE r8 r7 rC rC rC rD r � s 9 r c s e Zd ZdZ� fdd�Z� ZS )r zDCustom HeaderReader to exclude any headers with underscores in them.c s t t| ��|�}|o d|vS )N�_)�superr r8 )r< rG �orig�� __class__rC rD r8 s z(DropUnderscoreHeaderReader._allow_header)rJ rK rL rM r8 � __classcell__rC rC rQ rD 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= rT rC rC rD �__init__ s zSizeCheckWrapper.__init__c C s | j r | j| j krtj�d S d S rH )rT rU r �MaxSizeExceeded�r< rC rC rD � _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= �readrU �lenrY �r< �size�datarC rC rD r[ ( s zSizeCheckWrapper.readc C s� |dur| j �|�}| jt|�7 _| �� |S g } | j �d�}| jt|�7 _| �� |�|� t|�dk sB|dd� tkrGt�|�S q )��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 NT� ���) r= r. rU r\ rY �append�LF�EMPTYr; )r< r^ r_ �resrC rC rD r. 6 s �zSizeCheckWrapper.readliner c C �X d}g }| � |�}|r*|�|� |t|�7 }d| k r"|kr# |S | � |�}|s |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. rc r\ �r< �sizehint�total�linesr? rC rC rD � readlinesQ � � �zSizeCheckWrapper.readlinesc C � | j �� dS �z*Release resources allocated for ``rfile``.N�r= �closerX rC rC rD rs f � zSizeCheckWrapper.closec C � | S �zReturn file iterator.rC rX rC rC rD �__iter__j � zSizeCheckWrapper.__iter__c C s( t | j�}| jt|�7 _| �� |S �zGenerate next file chunk.)�nextr= rU r\ rY �r< r_ rC rC rD �__next__n s zSizeCheckWrapper.__next__rH �r ) rJ rK rL rM rV rY r[ r. rn rs rw r| rz rC rC rC rD 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_lengthrC rC rD rV s zKnownLengthRFile.__init__Nc C �L | j dkrdS |du r| j }nt|| 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)r~ �minr= r[ r\ r] rC rC rD r[ � � zKnownLengthRFile.readc C r� )r` r r% N)r~ r� r= r. r\ r] rC rC rD r. � r� zKnownLengthRFile.readliner c C rg rh ri rj rC rC rD rn � ro zKnownLengthRFile.readlinesc C rp rq rr rX rC rC rD rs � rt zKnownLengthRFile.closec C ru rv rC rX rC rC rD rw � rx zKnownLengthRFile.__iter__c C s t | j�}| jt|�8 _|S ry )rz r= r~ r\ r{ rC rC rD r| � s zKnownLengthRFile.__next__rH r} ) rJ rK rL rM rV r[ r. rn rs rw r| rz rC rC rC rD r x 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= rT rU re �buffer�bufsize�closed)r< r= rT r� rC rC rD rV � s zChunkedRFile.__init__c C s | j rd S | j�� }| jt|�7 _| jr#| j| jkr#t�d| j��|�� � t d�}z |� d�}t |d�}W n t yE t d|����w |dkrOd| _ d S | jr^| j| | jkr^td��| j�|�}| jt|�7 _| j|7 _| j�d�}|tkr�t dt|� d ��d S ) N�Request Entity Too Larger r � zBad chunked transfer size: T� z2Bad chunked transfer coding (expected '\r\n', got �))r� r= r. rU r\ rT r rW r4 r5 � SEMICOLON�pop�intr/ �IOErrorr[ r� r0 �repr)r< r? Z chunk_size�chunkZcrlfrC rC rD �_fetch� sH � �� ����zChunkedRFile._fetchNc C s� t }|dkr|S |rt|�|kr|S | js | �� | js |S |r9|t|� }|| jd|� 7 }| j|d� | _n|| j7 }t | _q )rZ r TN)re r\ r� r� )r< r^ r_ r~ rC rC rD r[ s" �zChunkedRFile.readc C s� t }|dkr|S |rt|�|kr|S | js | �� | js |S | j�t�}|r^|dkrC|t|� }|| jd|� 7 }| j|d� | _n9t|t|� |�}|| jd|� 7 }| j|d� | _n |dkrk|| j7 }t | _n|| jd|� 7 }| j|d� | _q )r` r Trb N)re r\ r� r� �findrd r� )r< r^ r_ Z newline_posr~ rC rC rD r. 2 s2 �zChunkedRFile.readliner c C rg rh ri rj rC rC rD rn [ ro zChunkedRFile.readlinesc c sz � | j std�� | j�� }|std��| jt|�7 _| jr*| j| jkr*td��|tkr0dS |� t�s9td��|V q )zhRead HTTP headers and yield them. :yields: CRLF separated lines :ytype: bytes z:Cannot read trailers until the request body has been read.Tr, r� r- N) r� r/ r= r. rU r\ rT r� r0 r1 )r< r? rC rC rD �read_trailer_linesp s$ �� �z ChunkedRFile.read_trailer_linesc C rp rq rr rX rC rC rD rs � rt zChunkedRFile.close)r� rH r} ) rJ rK rL rM rV r� r[ r. rn r� rs rC rC rC rD r � s + ) r c @ s� e Zd ZdZdZ dZ i Z g Z dZ dZ 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 jdurd| _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_headersrR �close_connection� chunked_read� chunked_write� proxy_mode� strict_mode)r< r� r� r� r� rC rC rD rV � s" zHTTPRequest.__init__c C s� t | jj| jj�| _z| �� }W n tjy! | �dd� Y dS w |s&dS z| � � }W n tjy= | �dd� Y dS w |sBdS 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 rW �simple_response�read_request_headersr� )r< �successrC rC rD � parse_request� s6 � �� �� zHTTPRequest.parse_requestc C s� | j �� }d| _|s dS |tkr| j �� }|sdS |�t�s&| �dd� dS zH|�� �td�\}}}|� d�s@| �dd� W dS |dd � �d d �}t |�dkrY| �dd � W dS t t t |��}|d krm| �dd� W dS W n ttfy� | �dd� Y dS w || _|�� | _| jr�|| jkr�d}| �d|� dS z tj�|�\}}} } } W n ty� | �dd� Y dS w |p�|} | jdkr�| jr�| r�|n| } n�| jdk�r0| js�| �d� dS tj�d�d|f��} | \}}}}}t}t� t�� | j }W d � n 1 �sw Y ||k�p| �pt ||||f�}|�r%| �dd� dS | }} t } } } nz| j�o:| j �o:| }|�rG | �dd� dS | j�oT|� t � �oT| }|�rc d}| �d|� dS | �rn| �dd� dS | d u �r{| �dd � dS z d d � t �| �D �}W n t�y� } z| �d|j!d � W Y d }~dS d }~ww t"�|�} | � t ��s�t | } |tu�r�|| _#|| _$| | _%| | _&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 rC )�urllib�parse�unquote_to_bytes��.0�xrC rC rD � <listcomp>� s ��z1HTTPRequest.read_request_line.<locals>.<listcomp>r � z HTTP/%s.%s),r= r. r� r0 r1 r� r4 r5 r2 � startswithr\ �tuple�mapr� r/ � IndexError�uri�upper�methodr� r� r� �urlsplit� UnicodeErrorr� r; re � contextlib�suppress�port�any� FORWARD_SLASH�QUOTED_SLASH_REGEX�args� QUOTED_SLASHr� � authority�path�qsr� �protocolZrequest_protocolr� r� )r< Z request_liner� r� Z req_protocolZrpZrespr� r� r� r� �fragmentZuri_is_absolute_formZ uri_splitZ_schemeZ _authority�_pathZ_qsZ _fragmentZ_portZ invalid_pathZdisallowed_absoluteZatoms�ex�sprC rC rD r� � s � � ��� � � � ��� � ������ ��� � � ��� z HTTPRequest.read_request_linec C s� z | � | j| j� W n ty& } z| �d|jd � W Y d}~dS d}~ww | jj}z t| j� dd��}W n tyF | �dd� Y dS w |rU||krU| �dd� dS | j d krg| j� d d �d krfd | _ n | j� d d �dkrsd | _ d}| j d kr�| j� d�}|r�dd� |� d�D �}d| _ |r�|D ]}|dkr�d | _ q�| �d� d | _ dS | j� dd �dkr�d �| jj�d�tdttf�}z | jj�|� W d S tjy� } z|jd tjvr܂ W Y d}~d S d}~ww 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 rC )r4 �lowerr� rC rC rD r� s z4HTTPRequest.read_request_headers.<locals>.<listcomp>� ,� chunkedz501 Unimplementedr) s 100-continue�asciis 100 Continue)� header_readerr= r� r/ r� r� r� �max_request_body_sizer� r: r� r� r5 r� r; r� �encoder2 r0 r� �wfile�write�socket�errorr �socket_errors_to_ignore)r< r� �mrbs�cl�te�enc�msgrC rC rD r� � s| �� �� � � �� � ���z HTTPRequest.read_request_headersc C s� | j j}| jrt| jj|�| _n"t| j�dd��}|r*||k r*| j s(| � dd� dS t | jj|�| _| j � | �� � | jo@| �� | jrM| jj�d� dS 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� rC rC rD r� E s$ � ��zHTTPRequest.respondr c C s� t |�}d| jj|f }dt|� }d}|�d�|�d�|�d�g}|dd� dv r:d| _| jd kr8|�d � nd }|�t� |rPt |t �rK|�d�}|�|� z | j j � t �|�� W dS tjyz } z|jd tjvro� W Y d}~dS d}~ww ) z+Write a simple response back to the client.z%s %s zContent-Length: %s zContent-Type: text/plain � ISO-8859-1N� > Z414Z413Tr� s Connection: close r� r )�strr� r� r\ r� r� r� rc r0 � isinstancer� r� r� re r; r� r� r� r r� )r< r� r� Z proto_statusr � content_type�bufr� rC rC rD r� \ s4 � ���zHTTPRequest.simple_responsec C s | j s d| _ | �� dS dS )z:Ensure headers are sent to the client if not already sent.TN)r� � send_headersrX rC rC rD r� � s �z HTTPRequest.ensure_headers_sentc C sZ | j r$|r$tt|��dd� �d�}|t|tg}| jj�t� |�� dS | jj�|� dS )z$Write unbuffered data to the client.r� Nr� ) r� �hexr\ r� r0 r� r� r� re r; )r< r� Zchunk_size_hexr� rC rC rD r� � s zHTTPRequest.writec C s� dd� | j D �}t| jdd� �}|dkrd| _n&d|vr?|dk s%|d v r&n| jd ko/| jd k}|r<d| _| j �d � nd| _| jsJ| jj }| | _d |vrf| jd kr]| jr\| j �d� n | jsf| j �d� d| j v r{| j �dd| jj � �� d�f� | js�| j s�t | jdd�}|dkr�| j�|� d|vr�| j �dtjjdd�� d�f� d|vr�| 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 rC )r� )r� �key�valuerC rC rD r� � s z,HTTPRequest.send_headers.<locals>.<listcomp>Nr� i� Ts content-length�� > i0 �� �� r� s HEAD)r* r� s connection)r( r� )r( r� r� ztimeout=r� r~ r s dates Date)�usegmts servers Serverr� ) r� r� r� r� r� r� r� rc r� � can_add_keepalive_connection�timeoutr� r� �getattrr= r[ �email�utils� formatdate� server_namer� r2 r0 r6 r� r� r� re r; ) r< Zhkeysr� Z needs_chunkedZcan_keepr~ �protor� rA r@ rC rC rD r� � sh � � �� �� �� zHTTPRequest.send_headers)FT)r )rJ rK rL rM r� r� r� r� r� r� r� r r� rV r� r� r� r� r� r� r� r� rC rC rC rD r � s8 !" fd % 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�makefilerC rC rD rV � s zHTTPConnection.__init__c C s� d}z-| � | j| �}|�� | jjd r| jd7 _|js!W dS d}|�� |js-W dS W dS tj y� } zG|j d }d}||v rQ|rJ|rP|j rP| � |d� n'|t jvrq| jjdt|� tjdd � | � |d � W Y d }~dS W Y d }~dS W Y d }~dS d }~w ttfy� � t jy� Y dS t jy� | �|� Y dS ty� } z| jjt|�tjdd � | � |d � W Y d }~dS d }~ww ) 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_errsrC rC rD � communicate sh �!� � � � � �� � ����zHTTPConnection.communicatec C s` |r|j rd S z| jj}W n ty | jj}Y nw 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� rC rC rD r M s �� z HTTPConnection._handle_no_sslc C sT |r|j rdS z|�|� W dS tjy Y dS tjy) | �|� Y dS w )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 �responserC rC rD r ^ s �z!HTTPConnection._conditional_errorc C s, | j �� | js| �� | j�� dS dS )z,Close the socket underlying this connection.N)r= rs r �_close_kernel_socketr� rX rC rC rD rs n s zHTTPConnection.closec C s� d}t s | jjtjkrtd��| jstd��z| j�tjtj t � |��}W n tj y6 } z t|�d}~ww t � ||�\}}}|||fS )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�gidrC rC rD r � s, ����� z HTTPConnection.get_peer_credsc C s | � � \}}}|S )z,Return the id of the connected peer process.�r )r< r- rN rC rC rD �peer_pid� � zHTTPConnection.peer_pidc C s | � � \}}}|S )z1Return the user id of the connected peer process.r0 )r< rN r. rC rC rD �peer_uid� r2 zHTTPConnection.peer_uidc C s | � � \}}}|S )z2Return the group id of the connected peer process.r0 )r< rN r/ rC rC rD �peer_gid� r2 zHTTPConnection.peer_gidc C s> t std��| 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�getpwuidr3 �pw_name�grp�getgrgidr4 �gr_name)r< �user�grouprC rC rD r � s ��z!HTTPConnection.resolve_peer_credsc C s | � � \}}|S )z2Return the username of the connected peer process.�r )r< r< rN rC rC rD � peer_user� � zHTTPConnection.peer_userc C s | � � \}}|S )z/Return the group of the connected peer process.r> )r< rN r= rC rC rD � peer_group� r@ zHTTPConnection.peer_groupc C sn t | jd| jj�}z|tj� W dS tjy Y dS tjy6 } z|jtjvr+� W Y d}~dS d}~ww )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< rB �erC rC rD r" � s � ���z#HTTPConnection._close_kernel_socket) rJ rK rL rM Z remote_addrZ remote_portZssl_env�io�DEFAULT_BUFFER_SIZEr r r r r r Z last_usedr rV r r r r rs r �propertyr1 r3 r4 r r? rA r" rC rC rC rD r � s< 6, r c @ s� e Zd ZdZdZdZdZ dZ dZ dZ dZ dZ dZ dZ dZ de��Z dZ d Z d Z d Z d Z eZ dZ d Z d Z d Z dZ dAd d�Z dd� Z dd� Z dd� Z e!dd� �Z"e"j#dd� �Z"dd� Z$dd� Z%d d � Z&d d � Z'd d!� Z(e)j*d"d#� �Z+e!d$d%� �Z,d&d'� Z-dBd*d+�Z.dCd,d-�Z/d.d/� Z0e1d0d1� �Z2e3 dDd2d3��Z4e1d4d5� �Z5e1d6d7� �Z6d8d9� Z7e!d:d;� �Z8e!d<d=� �Z9e8j#d>d;� �Z8d?d@� Z:dS )Er zAn HTTP server.z 127.0.0.1Nr� r� � g �?zCheroot/Fr Trb c C s^ || _ || _tj| |p d|d�| _|s| j}|| _|| _|o || _|| _ | � � t � � | _ 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 )r� �maxN)� bind_addrr� r Z ThreadPool�requests�versionr� r r � reuse_port� clear_stats�queue�Queue�_unservicable_conns) r< rK r� � minthreads� maxthreadsr� r r rN rC rC rD rV U s ��zHTTPServer.__init__c s� d� _ d� _i dd�d� fdd��d� fd d��d d�d � fd d��d � fdd��d� fdd��d� fdd��dd�ddd� �ddd� �ddd� �ddd� �d d d� �d d d� �d i �� _� jtjd!t� � < dS )"z Reset server stat counters..Nr r Fz Bind Addressc s t � j�S rH )r� rK ��srX rC rD �<lambda>� s z(HTTPServer.clear_stats.<locals>.<lambda>zRun timec s | d rdp � � � S )Nr rb ��runtimerU rX rC rD rW � s �Acceptsz Accepts/secc s | d � � � S )NrZ rX rU rX rC rD rW � s rQ c � t � jdd �S )N�qsize�r� rL rU rX rC rD rW � � ZThreadsc s t t� jdg ��S )NZ_threads)r\ r� rL rU rX rC rD rW � s z Threads Idlec r[ )NZidler] rU rX rC rD rW � r^ z Socket Errors�Requestsc S �* | d rdpt dd� | d �� D �d�S )Nr rb c s � � | ] }|d |�V qdS )r_ NrC �r� �wrC rC rD � <genexpr>� � � �;HTTPServer.clear_stats.<locals>.<lambda>.<locals>.<genexpr>�Worker Threadsr ��sum�valuesrU rC rC rD rW � � �� Bytes Readc S r` )Nr rb c s ra )rl NrC rb rC rC rD rd � re rf rg r rh rU rC rC rD rW � rk � Bytes Writtenc S r` )Nr rb c s ra )rm NrC rb rC rC rD rd � re rf rg r rh rU rC rC rD rW � rk � Work Timec S r` )Nr rb c s ra )rn NrC rb rC rC rD rd � re rf rg r rh rU rC rC rD rW � rk zRead Throughputc S r` )Nr rb c s �, � | ]}|d |�|d |�pd V qdS )rl rn ���ư>NrC rb rC rC rD rd � � � � �rf rg r rh rU rC rC rD rW � � ��zWrite Throughputc S r` )Nr rb c s ro )rm rn rp NrC rb rC rC rD rd � rq rf rg r rh rU rC rC rD rW � rr rg zCheroot HTTPServer %d)� _start_time� _run_timer r r+ �idrX rC rX rD rO � sH � � �� � � � � � ���� �'�/�1zHTTPServer.clear_statsc C s$ | j du r| jS | jt�� | j S )zReturn server uptime.N)rs rt �timerX rC rC rD rY � s zHTTPServer.runtimec C s d| j | jj| jf S )z1Render Server instance representing bind address.z %s.%s(%r))rK rR rJ rK rX rC rC rD �__str__� s �zHTTPServer.__str__c C � | 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_addrrX rC rC rD rK � s zHTTPServer.bind_addrc C s( t |t�r|d dv rtd��|| _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� r/ ry )r< r� rC rC rD rK � s � c C sj z| � � W dS ty } z | j}|s|| _||�d}~w ty4 } z | j}|s-|| _||�d}~ww )z4Run the server forever, and stop it cleanly on exit.N)�startr � interruptr )r< Z kb_intr_excZunderlying_interruptZ sys_exit_excrC rC rD � safe_start� s ���zHTTPServer.safe_startc C s� d| _ | jdu rd| j | _d| _d}t�dd�r$t�dtjtj�| _n�t | j t t f�rPz| � | j � W n� tjyO } zd|| j |f }t�|�|�d}~ww | j \}}zt�||tjtjdtj�}W n$ tjy� tj}| j }d|v r}tj}|d }|tjdd |fg}Y nw |D ]8}|\} } } } } z | �| | | � W n% tjy� } zd|| |f }| jr�| j�� d| _W Y d}~q�d}~ww | js�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�softwarerM r� �os�getenv�fromfd�AF_INET� SOCK_STREAMr� rK r� �bytes�bind_unix_socketr� � getaddrinfo� AF_UNSPEC� AI_PASSIVE�gaierrorr �bindrs � settimeout�listen�request_queue_sizer ZConnectionManager� _connectionsrL rz r� rv rs )r< r� Zserr�hostr� �infoZ sock_typerK rf �af�socktyper� � _canonname�sarC rC rD �prepare sj �� �� �� zHTTPServer.preparec C s� | j rP| j�� }|tu rdS t| |�}z|�d� W n) ttjfy& Y q t yC } z| j j t |�t jdd� W Y d}~nd}~ww d|_|�� | j sdS dS )z(Serve connections we can't handle a 503.Nz503 Service UnavailableTr )r� rR r: �_STOPPING_FOR_INTERRUPTr r� �OSErrorr r r r� r r� r r r rs )r< r� �requestr� rC rC rD �_serve_unservicableQ s( ��� �z HTTPServer._serve_unservicablec C s� t j| jd��� | jr:| js:z | j�| j� W n t t fy" � t y3 | j dt jdd� Y nw | jr:| jr| jrN| jrHt�d� | js@| jrP| j�dS dS )z1Serve requests, after invoking :func:`prepare()`.��targetzError in HTTPServer.serveTr g�������?N)� threading�Threadr� rz r� r{ r� �run�expiration_intervalr r r r r r �_stopping_for_interruptrv �sleeprX rC rC rD �servej s, �� � ��zHTTPServer.servec C s | � � | �� dS )zmRun the server forever. It is shortcut for invoking :func:`prepare()` then :func:`serve()`. N)r� r� rX rC rC rD rz � s zHTTPServer.startc c sF � | � � tj| jd�}d|_|�� z |V W | �� dS | �� w )z4Context manager for running this server in a thread.r� TN)r� r� r� r� �daemonrz �stop)r< �threadrC rC rD �_run_in_thread� 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� rX rC rC rD r� � s z'HTTPServer.can_add_keepalive_connectionc C s" | j r | j�|� dS |�� dS )z7Put an idle connection back into the ConnectionManager.N)r� r� �putrs �r< r� rC rC rD �put_conn� s zHTTPServer.put_connr � c C sF t j�|�d�� t j�� |r!t�� }t j�|� t j�� dS dS )z�Write error message to log. :param msg: error message :type msg: str :param level: logging level :type level: int :param traceback: add traceback to output or not :type traceback: bool � N)�sys�stderrr� �flush� traceback_� format_exc)r< r� r r ZtblinesrC rC rD r � s �zHTTPServer.error_logc C sB | � | j|||| j| j| j�}| �|| j� }| _| �|�| _|S )z.Create (or recreate) the actual socket object.)�prepare_socketrK �nodelayr� rN � bind_socketr� �resolve_real_bind_addr)r< r$ �typer� r rC rC rD r� � s � zHTTPServer.bindc C s� t r td��d}zt�| j� W nE ty Y n= ty4 } zt|�}d|vr*� W Y d}~n'd}~w tyV } zt|�}d|vrLd|vrLd|vrL� W Y d}~nd}~ww | j|t j t j d| j | j | jd �}z t�|�� |� d }W n ty� d }Y nw z| �||�}W n t jy� |�� � w | �|�}z! |s�zt�||� W n ty� tj||d d � Y nw d }W n ty� Y nw |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 )rK r$ r� r� r� r� rN TF)�follow_symlinksz(Failed to set socket fs mode permissions)r )r# r/ r� �unlinkrK r� � TypeErrorr� r� r� r% r� r� r� rN �fchmod�filenor� r� rs r� �lchmodr �chmodr r r )r< rK Zfs_permissionsZtyp_err�err_msgZval_errr Z FS_PERMS_SETrC rC rD r� � s� � � ����� � �� �� ��zHTTPServer.bind_unix_socketc C s� |d d� \}}|dk}| j tjtjhvrtd��|r td��ttd�r/| �tjtjd� d S ttd�r?| �tjtj d� d S t rL| �tjtj d� d S t d��) 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� r� r r/ �hasattr� setsockoptr) r� r� r# � SO_REUSEADDRr& )�socket_rK Z_hostr� �IS_EPHEMERAL_PORTrC rC rD �_make_socket_reusable! s �z HTTPServer._make_socket_reusablec C s� t � |||�}t�|� |dd� \} } | dk} |r!| j||d� ts/| s/ |�t jt jd� |rAt|t t f�sA|�t j t j d� |durJ|� |�}tt d�oW|t jkoW| dv } | r{t�tt j�� |�t jt jd� W d � |S 1 svw Y |S )z%Create and prepare the socket object.Nr� r �r� rK r r > z::0z ::0.0.0.0z::)r� r Zprevent_socket_inheritancer� r# r� r) r� r� r� r� � IPPROTO_TCP� TCP_NODELAYr� r� r r� r� r r� r r ) �clsrK r$ r� r� r� r� rN r r� r� r� Zlistening_ipv6rC rC rD r� ; s: ��� � � zHTTPServer.prepare_socketc C s | � |� | S )z#Bind the socket to given interface.)r� r� rC rC rD r� v s zHTTPServer.bind_socketc C s> | � � }| jtjtjhv r |dd� S t|t�r t|�}|S )z/Retrieve actual bind address from bound socket.Nr� )� getsocknamer$ r� r� r r� r� r r� rC rC rD r� | s � z!HTTPServer.resolve_real_bind_addrc C s6 z | j �|� W dS tjy | j�|� Y dS w )z#Process an incoming HTTPConnection.N)rL r� rP �FullrR r� rC rC rD � process_conn� s �zHTTPServer.process_connc C rx )z Flag interrupt of the server.)r~ rX rC rC rD r{ � s zHTTPServer.interruptc C s | j tu S )z8Return whether the server is responding to an interrupt.)r~ r� rX rC rC rD r� � 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� r~ r� r r r r� )r< r{ rC rC rD r{ � s c C sr | j sdS d| _ | j�t� | jdur | jt�� | j 7 _d| _| j�� t | dd�}|r�t | j t t f�s�z |�� dd� \}}W n tjy_ } z|jd tjvrU� W Y d}~nDd}~ww t�||tjtj�D ]4}|\}}}} } d} zt�|||�} | �d� | �||f� | �� W qj tjy� | r�| �� Y qjw t|d�r�|�� d| _| j�� | j�| j � dS )z5Gracefully shutdown a server that is serving forever.NFr� r� r g �?rs ) r� rR r� r� rs rt rv r� r� r� r� rK r� r� r� r� r� r� r r� r� r� r� r� �connectrs r� rL �shutdown_timeout) r< r r� r� r� rf r� r� r� r� Z_sarV rC rC rD r� � sT ��� � �� zHTTPServer.stop)rI rb NFFF)r r� Fr} )F);rJ rK rL rM ry r~ r� rS rT r� r� r� r� r� r� r rM r r� r� r� r� r ZConnectionClassr� r r rN Zkeep_alive_conn_limitrV rO rY rw rH rK �setterr| r� r� r� rz r� �contextmanagerr� r� r� r r� r� � staticmethodr� � classmethodr� r� r� r� r{ r� r� rC rC rC rD r � s� �,7 K T �: 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 rC rC rD rV � s zGateway.__init__c C s t �)z>Process the current request. Must be overridden in a subclass.)r& rX rC rC rD r� � rx zGateway.respondN)rJ rK rL rM rV r� rC rC rC rD r � s r z%cheroot.ssl.builtin.BuiltinSSLAdapterz&cheroot.ssl.pyopenssl.pyOpenSSLAdapter)�builtinZ pyopensslr� c C s� t | �� }t|t�rW|�d�}||d d� }|d|� }z tj| }|du r*t�W n ty> t|t � t � dg�}Y nw zt ||�}W |S t yV t d||f ��w |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 )�nameZadapterZlast_dotZ attr_nameZmod_path�modrC rC rD r s, � � � ��r )r� )KrM r� � email.utilsr� rF r r� �platformrP �rer� r� r� rv r r� � urllib.parser� � functoolsr r r r r Z_compatr r r r r �workersr �__all__�systemr# r� r� ZIS_GAEr5 r9 r6 � ImportErrorr* r� r r r rd r0 r3 r2 r6 r� re ZASTERISKr� r� �compiler; r� r r� r9 r+ r r r r r r r r r r� r rC rC rC rD �<module> s� C � GaZ B ` �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings