Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/__pycache__/httpserver.cpython-39.pyc
Ðазад
a _�h�= � @ s d Z ddlZddlZddlmZ ddlmZmZ ddlm Z ddlm Z ddlm Z ddl m Z dd lmZ ddlZdd lmZmZmZmZmZmZmZmZmZ ejr�dd lmZ G d d � d e ee j �Z G dd� de j �Z G dd� de �Z!G dd� de j �Z"e j#Z$dS )a� A non-blocking, single-threaded HTTP server. Typical applications have little direct interaction with the `HTTPServer` class except to start a server at the beginning of the process (and even that is often done indirectly via `tornado.web.Application.listen`). .. versionchanged:: 4.0 The ``HTTPRequest`` class that used to live in this module has been moved to `tornado.httputil.HTTPServerRequest`. The old name remains as an alias. � N)� native_str)�HTTP1ServerConnection�HTTP1ConnectionParameters)�httputil)�iostream)�netutil)� TCPServer)� Configurable) �Union�Any�Dict�Callable�List�Type�Tuple�Optional� Awaitable)�Setc @ s� e Zd ZdZeedd�dd�Zdeeje ej gdf f e e ee e ef ejf e e eeeeeeee dd�dd �Zeee d �d d ��Zeee d �d d��Zdd �dd�Zeje dd�dd�Z e ej ej d�dd�Z!e dd�dd�Z"dS )� HTTPServera� A non-blocking, single-threaded HTTP server. A server is defined by a subclass of `.HTTPServerConnectionDelegate`, or, for backwards compatibility, a callback that takes an `.HTTPServerRequest` as an argument. The delegate is usually a `tornado.web.Application`. `HTTPServer` supports keep-alive connections by default (automatically for HTTP/1.1, or for HTTP/1.0 when the client requests ``Connection: keep-alive``). If ``xheaders`` is ``True``, we support the ``X-Real-Ip``/``X-Forwarded-For`` and ``X-Scheme``/``X-Forwarded-Proto`` headers, which override the remote IP and URI scheme/protocol for all requests. These headers are useful when running Tornado behind a reverse proxy or load balancer. The ``protocol`` argument can also be set to ``https`` if Tornado is run behind an SSL-decoding proxy that does not set one of the supported ``xheaders``. By default, when parsing the ``X-Forwarded-For`` header, Tornado will select the last (i.e., the closest) address on the list of hosts as the remote host IP address. To select the next server in the chain, a list of trusted downstream hosts may be passed as the ``trusted_downstream`` argument. These hosts will be skipped when parsing the ``X-Forwarded-For`` header. To make this server serve SSL traffic, send the ``ssl_options`` keyword argument with an `ssl.SSLContext` object. For compatibility with older versions of Python ``ssl_options`` may also be a dictionary of keyword arguments for the `ssl.wrap_socket` method.:: ssl_ctx = ssl.create_default_context(ssl.Purpose.CLIENT_AUTH) ssl_ctx.load_cert_chain(os.path.join(data_dir, "mydomain.crt"), os.path.join(data_dir, "mydomain.key")) HTTPServer(application, ssl_options=ssl_ctx) `HTTPServer` initialization follows one of three patterns (the initialization methods are defined on `tornado.tcpserver.TCPServer`): 1. `~tornado.tcpserver.TCPServer.listen`: simple single-process:: server = HTTPServer(app) server.listen(8888) IOLoop.current().start() In many cases, `tornado.web.Application.listen` can be used to avoid the need to explicitly create the `HTTPServer`. 2. `~tornado.tcpserver.TCPServer.bind`/`~tornado.tcpserver.TCPServer.start`: simple multi-process:: server = HTTPServer(app) server.bind(8888) server.start(0) # Forks multiple sub-processes IOLoop.current().start() When using this interface, an `.IOLoop` must *not* be passed to the `HTTPServer` constructor. `~.TCPServer.start` will always start the server on the default singleton `.IOLoop`. 3. `~tornado.tcpserver.TCPServer.add_sockets`: advanced multi-process:: sockets = tornado.netutil.bind_sockets(8888) tornado.process.fork_processes(0) server = HTTPServer(app) server.add_sockets(sockets) IOLoop.current().start() The `~.TCPServer.add_sockets` interface is more complicated, but it can be used with `tornado.process.fork_processes` to give you more flexibility in when the fork happens. `~.TCPServer.add_sockets` can also be used in single-process servers if you want to create your listening sockets in some way other than `tornado.netutil.bind_sockets`. .. versionchanged:: 4.0 Added ``decompress_request``, ``chunk_size``, ``max_header_size``, ``idle_connection_timeout``, ``body_timeout``, ``max_body_size`` arguments. Added support for `.HTTPServerConnectionDelegate` instances as ``request_callback``. .. versionchanged:: 4.1 `.HTTPServerConnectionDelegate.start_request` is now called with two arguments ``(server_conn, request_conn)`` (in accordance with the documentation) instead of one ``(request_conn)``. .. versionchanged:: 4.2 `HTTPServer` is now a subclass of `tornado.util.Configurable`. .. versionchanged:: 4.5 Added the ``trusted_downstream`` argument. .. versionchanged:: 5.0 The ``io_loop`` argument has been removed. N)�args�kwargs�returnc O s d S �N� )�selfr r r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/httpserver.py�__init__� s zHTTPServer.__init__F)�request_callback� no_keep_alive�xheaders� ssl_options�protocol�decompress_request� chunk_size�max_header_size�idle_connection_timeout� body_timeout� max_body_size�max_buffer_size�trusted_downstreamr c C sR || _ || _|| _t|||| p d| | |d�| _tj| || |d� t� | _| | _ d S )Ni )� decompressr# r$ Zheader_timeoutr' r& r )r r( Zread_chunk_size) r r r! r � conn_paramsr r �set� _connectionsr) )r r r r r r! r" r# r$ r% r& r' r( r) r r r � initialize� s( � �zHTTPServer.initialize�r c C s t S r �r ��clsr r r �configurable_base� s z HTTPServer.configurable_basec C s t S r r0 r1 r r r �configurable_default� s z HTTPServer.configurable_defaultc � s( | j r$tt| j ��}|�� I dH q dS )a% Close all open connections and asynchronously wait for them to finish. This method is used in combination with `~.TCPServer.stop` to support clean shutdowns (especially for unittests). Typical usage would call ``stop()`` first to stop accepting new connections, then ``await close_all_connections()`` to wait for existing connections to finish. This method does not currently close open websocket connections. Note that this method is a coroutine and must be caled with ``await``. N)r- �next�iter�close)r �connr r r �close_all_connections� s z HTTPServer.close_all_connections)�stream�addressr c C s: t ||| j| j�}t|| j|�}| j�|� |�| � d S r )�_HTTPRequestContextr! r) r r+ r- �addZ start_serving)r r: r; �contextr8 r r r � handle_stream� s � zHTTPServer.handle_stream)� server_conn� request_connr c C s> t | jtj�r | j�||�}n t| j|�}| jr:t||�}|S r )� isinstancer r � HTTPServerConnectionDelegate� start_request�_CallableAdapterr � _ProxyAdapter)r r@ rA �delegater r r rD � s zHTTPServer.start_request)r@ r c C s | j �t�t|�� d S r )r- �remove�typing�castr )r r@ r r r �on_close� s zHTTPServer.on_close) FFNNFNNNNNNN)#�__name__� __module__� __qualname__�__doc__r r r r rC r �HTTPServerRequest�boolr �str�ssl� SSLContext�int�floatr r. � classmethodr r r3 r4 r9 r �IOStreamr r? �object�HTTPConnection�HTTPMessageDelegaterD rK r r r r r . sX a ���� , � r c @ s� e Zd Zeejgdf ejdd�dd�Zeej ej f ej e e d d�dd�Zee e d d�d d �Zdd �d d �Zdd �dd�ZdS )rE N)r rA r c C s" || _ || _d | _d | _g | _d S r )� connectionr �requestrG �_chunks)r r rA r r r r � s z_CallableAdapter.__init__�� start_line�headersr c C s" t j| jt�t j|�|d�| _d S )N)r\ r` ra )r rP r\ rI rJ �RequestStartLiner] �r r` ra r r r �headers_received s �z!_CallableAdapter.headers_received��chunkr c C s | j �|� d S r )r^ �append�r rf r r r � data_received s z _CallableAdapter.data_receivedr/ c C s8 | j d usJ �d�| j�| j _| j �� | �| j � d S )N� )r] �joinr^ �bodyZ _parse_bodyr �r r r r �finish s z_CallableAdapter.finishc C s | ` d S r )r^ rm r r r �on_connection_close s z$_CallableAdapter.on_connection_close)rL rM rN r r rP rZ r r rb �ResponseStartLine� HTTPHeadersr r rd �bytesri rn ro r r r r rE � s � � rE c @ s\ e Zd Zd ejeee ee dd�dd�Z ed�dd�Z e j dd�d d �Z dd�d d �ZdS )r< N)r: r; r! r) r c C s� || _ |jd ur |jj| _nd | _| jtjtjfv rH|d urH|d | _nd| _|rZ|| _nt|t j �rnd| _nd| _| j| _ | j| _ t |p�g �| _d S )Nr z0.0.0.0�https�http)r; �socket�family�address_family�AF_INET�AF_INET6� remote_ipr! rB r Z SSLIOStream�_orig_remote_ip�_orig_protocolr, r) )r r: r; r! r) r r r r s$ �� z _HTTPRequestContext.__init__r/ c C s< | j tjtjfv r| jS t| jt�r.t| j�S t | j�S d S r ) rw ru rx ry rz rB r; rr r rR rm r r r �__str__A s z_HTTPRequestContext.__str__)ra r c C s� |� d| j�}dd� t|�d��D �D ]}|| jvr& q:q&|� d|�}t�|�rV|| _|� d|� d| j��}|r�|�d�d �� }|d v r�|| _d S ) z2Rewrite the ``remote_ip`` and ``protocol`` fields.zX-Forwarded-Forc s s | ]}|� � V qd S r )�strip)�.0�candr r r � <genexpr>Q rj z6_HTTPRequestContext._apply_xheaders.<locals>.<genexpr>�,z X-Real-IpzX-SchemezX-Forwarded-Proto���)rt rs N) �getrz �reversed�splitr) r Z is_valid_ipr! r~ )r ra �ipZ proto_headerr r r �_apply_xheadersL s �z#_HTTPRequestContext._apply_xheadersc C s | j | _| j| _dS )z�Undo changes from `_apply_xheaders`. Xheaders are per-request so they should not leak to the next request on the same connection. N)r{ rz r| r! rm r r r �_unapply_xheadersb s z%_HTTPRequestContext._unapply_xheaders)N)rL rM rN r rX r r rR r r r} r rq r� r� r r r r r< s �� " r< c @ s� e Zd Zejejdd�dd�Zeejej f ej e e d d�dd�Z ee e d d�d d �Zdd �d d �Zdd �dd�Zdd �dd�ZdS )rF N)rG rA r c C s || _ || _d S r )r\ rG )r rG rA r r r r m s z_ProxyAdapter.__init__r_ c C s | j j�|� | j�||�S r )r\ r> r� rG rd rc r r r rd u s z _ProxyAdapter.headers_receivedre c C s | j �|�S r )rG ri rh r r r ri s z_ProxyAdapter.data_receivedr/ c C s | j �� | �� d S r )rG rn �_cleanuprm r r r rn � s z_ProxyAdapter.finishc C s | j �� | �� d S r )rG ro r� rm r r r ro � s z!_ProxyAdapter.on_connection_closec C s | j j�� d S r )r\ r> r� rm r r r r� � s z_ProxyAdapter._cleanup)rL rM rN r r[ rZ r r rb rp rq r r rd rr ri rn ro r� r r r r rF l s � � rF )%rO ru rS Ztornado.escaper Ztornado.http1connectionr r �tornador r r Ztornado.tcpserverr Z tornado.utilr rI r r r r r r r r r � TYPE_CHECKINGr rC r r[ rE rY r< rF rP Z HTTPRequestr r r r �<module> s& , K&N"
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка