File manager - Edit - /usr/local/CyberCP/lib/python3.10/site-packages/tornado/__pycache__/httpserver.cpython-310.pyc
Back
o �h ? � @ s d Z ddlZddlZddlmZ ddlmZmZ ddlm Z ddlm Z ddlm Z ddl m Z dd lmZ ddlZdd lmZmZmZmZmZmZmZmZmZ ejrYdd 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 @ sL e Zd ZdZdededdfdd�Z d(d eeje ej gdf f d e d e d e ee eef ejf d e e de de e de e de e de e de e de e de ee ddf dd�Zedee fdd��Zedee fdd��Zd)d d �Zd ej d e ddfd d!�Z d"e d#ej dej!fd$d%�Z"d"e ddfd&d'�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.SSLContext.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`: single-process:: async def main(): server = HTTPServer() server.listen(8888) await asyncio.Event.wait() asyncio.run(main()) In many cases, `tornado.web.Application.listen` can be used to avoid the need to explicitly create the `HTTPServer`. While this example does not create multiple processes on its own, when the ``reuse_port=True`` argument is passed to ``listen()`` you can run the program multiple times to create a multi-process service. 2. `~tornado.tcpserver.TCPServer.add_sockets`: multi-process:: sockets = bind_sockets(8888) tornado.process.fork_processes(0) async def post_fork_main(): server = HTTPServer() server.add_sockets(sockets) await asyncio.Event().wait() asyncio.run(post_fork_main()) The ``add_sockets`` interface is more complicated, but it can be used with `tornado.process.fork_processes` to run a multi-process service with all worker processes forked from a single parent. ``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`. Note that when using this pattern, nothing that touches the event loop can be run before ``fork_processes``. 3. `~tornado.tcpserver.TCPServer.bind`/`~tornado.tcpserver.TCPServer.start`: simple **deprecated** multi-process:: server = HTTPServer() server.bind(8888) server.start(0) # Forks multiple sub-processes IOLoop.current().start() This pattern is deprecated because it requires interfaces in the `asyncio` module that have been deprecated since Python 3.10. Support for creating multiple processes in the ``start`` method will be removed in a future version of Tornado. .. 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. �args�kwargs�returnNc O s d S �N� )�selfr r r r �E/usr/local/CyberCP/lib/python3.10/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_downstreamc C sR || _ || _|| _t|||| pd| | |d�| _tj| || |d� t� | _| | _ d S )Ni )� decompressr# r$ �header_timeoutr' r& r )r r( �read_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.initializec C � t S r �r ��clsr r r �configurable_base� � z HTTPServer.configurable_basec C r1 r r2 r3 r r r �configurable_default� r6 z HTTPServer.configurable_defaultc � s2 �| j rtt| j ��}|�� I dH | j sdS 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 called with ``await``. N)r/ �next�iter�close)r �connr r r �close_all_connections� s ��z HTTPServer.close_all_connections�stream�addressc C s: t ||| j| j�}t|| j|�}| j�|� |�| � d S r )�_HTTPRequestContextr! r) r r- r/ �add� start_serving)r r= r> �contextr; r r r � handle_stream� s � zHTTPServer.handle_stream� server_conn� request_connc C s> t | jtj�r| j�||�}nt| j|�}| jr t||�}|S r )� isinstancer r � HTTPServerConnectionDelegate� start_request�_CallableAdapterr � _ProxyAdapter)r rD rE �delegater r r rH � s zHTTPServer.start_requestc C s | j �t�t|�� d S r )r/ �remove�typing�castr )r rD r r r �on_close s zHTTPServer.on_close) FFNNFNNNNNNN�r N)$�__name__� __module__� __qualname__�__doc__r r r r rG r �HTTPServerRequest�boolr r �str�ssl� SSLContext�int�floatr r0 � classmethodr r r5 r7 r< r �IOStreamr rC �object�HTTPConnection�HTTPMessageDelegaterH rO r r r r r . s| m������� � � � � ���� � �, �� � r c @ s� e Zd Zdeejgdf dejddfdd�Zdeej ej f dej de e d fd d �Zd ede e d fd d �Zddd�Zddd�ZdS )rI r NrE r c C s" || _ || _d | _d | _g | _d S r )� connectionr �requestrK �_chunks)r r rE r r r r s z_CallableAdapter.__init__� start_line�headersc C s" t j| jt�t j|�|d�| _d S )N)ra rd re )r rU ra rM rN �RequestStartLinerb �r rd re r r r �headers_received s �z!_CallableAdapter.headers_received�chunkc C s | j �|� d S r )rc �append�r ri r r r � data_received s z _CallableAdapter.data_receivedc C s8 | j d usJ �d�| j�| j _| j �� | �| j � d S )N� )rb �joinrc �body� _parse_bodyr �r r r r �finish s z_CallableAdapter.finishc C s | ` d S r )rc rq r r r �on_connection_close& s z$_CallableAdapter.on_connection_closerP )rQ rR rS r r rU r_ r r rf �ResponseStartLine� HTTPHeadersr r rh �bytesrl rr rs r r r r rI s$ �� � �� � rI c @ sh e Zd Z ddejdedee deee ddf dd�Z defd d �Z d e j ddfd d �Z ddd�ZdS )r? Nr= r> r! r) r c C s� || _ |jd ur|jj| _nd | _| jtjtjfv r$|d ur$|d | _nd| _|r-|| _n t|t j �r7d| _nd| _| j| _ | j| _ t |pFg �| _d S )Nr z0.0.0.0�https�http)r> �socket�family�address_family�AF_INET�AF_INET6� remote_ipr! rF r � SSLIOStream�_orig_remote_ip�_orig_protocolr. r) )r r= r> r! r) r r r r + s z _HTTPRequestContext.__init__c C s8 | j tjtjfv r | jS t| jt�rt| j�S t | j�S r ) r{ ry r| r} r~ rF r> rv r rW rq r r r �__str__M s z_HTTPRequestContext.__str__re c C s� |� d| j�}dd� t|�d��D �D ] }|| jvr nq|� d|�}t�|�r+|| _|� d|� d| j��}|rA|�d�d �� }|d v rJ|| _d S d S ) z2Rewrite the ``remote_ip`` and ``protocol`` fields.zX-Forwarded-Forc s s � | ]}|� � V qd S r )�strip)�.0�candr r r � <genexpr>] s � z6_HTTPRequestContext._apply_xheaders.<locals>.<genexpr>�,z X-Real-IpzX-SchemezX-Forwarded-Proto���)rx rw N) �getr~ �reversed�splitr) r � is_valid_ipr! r� )r re �ip� proto_headerr r r �_apply_xheadersX 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� r~ r� r! rq r r r �_unapply_xheadersn s z%_HTTPRequestContext._unapply_xheadersr rP )rQ rR rS r r] r r rW r r r� r ru r� r� r r r r r? * s ���� � �" r? c @ s� e Zd Zdejdejddfdd�Zdeejej f dej de e d fd d �Z d ede e d fd d �Zddd�Zddd�Zddd�ZdS )rJ rK rE r Nc C s || _ || _d S r )ra rK )r rK rE r r r r y s z_ProxyAdapter.__init__rd re c C s | j j�|� | j�||�S r )ra rB r� rK rh rg r r r rh � s z _ProxyAdapter.headers_receivedri c C s | j �|�S r )rK rl rk r r r rl � s z_ProxyAdapter.data_receivedc C � | j �� | �� d S r )rK rr �_cleanuprq r r r rr � � z_ProxyAdapter.finishc C r� r )rK rs r� rq r r r rs � r� z!_ProxyAdapter.on_connection_closec C s | j j�� d S r )ra rB r� rq r r r r� � s z_ProxyAdapter._cleanuprP )rQ rR rS r r` r_ r r rf rt ru r r rh rv rl rr rs r� r r r r rJ x s& �� ��� � rJ )%rT ry rX �tornado.escaper �tornado.http1connectionr r �tornador r r �tornado.tcpserverr � tornado.utilr rM r r r r r r r r r � TYPE_CHECKINGr rG r r` rI r^ r? rJ rU � HTTPRequestr r r r �<module> s( , W&N "
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.04 |
proxy
|
phpinfo
|
Settings