golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/__pycache__
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.cpython-310.pyc
378 B
Del
OK
_locale_data.cpython-310.pyc
3.23 KB
Del
OK
auth.cpython-310.pyc
39.18 KB
Del
OK
autoreload.cpython-310.pyc
7.02 KB
Del
OK
concurrent.cpython-310.pyc
17.24 KB
Del
OK
curl_httpclient.cpython-310.pyc
12.8 KB
Del
OK
escape.cpython-310.pyc
9.89 KB
Del
OK
gen.cpython-310.pyc
38.39 KB
Del
OK
http1connection.cpython-310.pyc
19.47 KB
Del
OK
httpclient.cpython-310.pyc
25.19 KB
Del
OK
httpserver.cpython-310.pyc
11.45 KB
Del
OK
httputil.cpython-310.pyc
29.84 KB
Del
OK
ioloop.cpython-310.pyc
33.19 KB
Del
OK
iostream.cpython-310.pyc
42.97 KB
Del
OK
locale.cpython-310.pyc
15.22 KB
Del
OK
locks.cpython-310.pyc
16.61 KB
Del
OK
log.cpython-310.pyc
8.07 KB
Del
OK
netutil.cpython-310.pyc
14.32 KB
Del
OK
options.cpython-310.pyc
19.63 KB
Del
OK
process.cpython-310.pyc
10.27 KB
Del
OK
queues.cpython-310.pyc
11.29 KB
Del
OK
routing.cpython-310.pyc
21.08 KB
Del
OK
simple_httpclient.cpython-310.pyc
16.08 KB
Del
OK
stack_context.cpython-310.pyc
10.65 KB
Del
OK
tcpclient.cpython-310.pyc
6.49 KB
Del
OK
tcpserver.cpython-310.pyc
10.06 KB
Del
OK
template.cpython-310.pyc
30.52 KB
Del
OK
testing.cpython-310.pyc
24.61 KB
Del
OK
util.cpython-310.pyc
13.72 KB
Del
OK
web.cpython-310.pyc
105.22 KB
Del
OK
websocket.cpython-310.pyc
39.08 KB
Del
OK
wsgi.cpython-310.pyc
11.5 KB
Del
OK
Edit: httpserver.cpython-310.pyc
o �xe@2 � @ s� d Z ddlmZmZmZ ddlZddlmZ ddlm Z m Z ddl m Z ddl m Z ddl mZ dd l mZ dd lmZ dd lmZ G d d � d eee j�ZG dd� de j�ZG dd� de�ZG dd� de j�Ze jZ 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. � )�absolute_import�division�print_functionN)� native_str)�HTTP1ServerConnection�HTTP1ConnectionParameters)�gen)�httputil)�iostream)�netutil)� TCPServer)� Configurablec @ sn e Zd ZdZdd� Z ddd�Zedd � �Zed d � �Ze j d d � �Z dd� Z dd� Z dd� ZdS )� HTTPServeraK 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(applicaton, 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. c O s d S �N� )�self�args�kwargsr r �O/opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/httpserver.py�__init__� s zHTTPServer.__init__FNc C sZ || _ || _|| _|| _t||| | pd| | |d�| _tj| ||| |d� t� | _ || _ d S )Ni )� decompress� chunk_size�max_header_sizeZheader_timeout� max_body_size� body_timeout� no_keep_alive)�io_loop� ssl_options�max_buffer_sizeZread_chunk_size) �request_callbackr �xheaders�protocolr � conn_paramsr r �set� _connections�trusted_downstream)r r r r r r r! Zdecompress_requestr r Zidle_connection_timeoutr 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 r' r r( r) r r r �configurable_default� r, z HTTPServer.configurable_defaultc c s. � | j rtt| j ��}|�� V | j sd S d S r )r$ �next�iter�close)r �connr r r �close_all_connections� s � �z HTTPServer.close_all_connectionsc C s: t ||| j| j�}t|| j|�}| j�|� |�| � d S r )�_HTTPRequestContextr! r% r r" r$ �addZ start_serving)r �stream�address�contextr1 r r r � handle_stream� s �� zHTTPServer.handle_streamc C s> t | jtj�r| j�||�}nt| j|�}| jr t||�}|S r )� isinstancer r � HTTPServerConnectionDelegate� start_request�_CallableAdapterr � _ProxyAdapter)r � server_conn� request_conn�delegater r r r; � s zHTTPServer.start_requestc C � | j �|� d S r )r$ �remove)r r> r r r �on_close� � zHTTPServer.on_close) FNFNNFNNNNNNN)�__name__� __module__� __qualname__�__doc__r r& � classmethodr+ r- r � coroutiner2 r8 r; rC r r r r r , s( ] � r c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) r< c C s" || _ || _d | _d | _g | _d S r )� connectionr �requestr@ �_chunks)r r r? r r r r � s z_CallableAdapter.__init__c C s t j| j||d�| _d S )N)rK � start_line�headers)r �HTTPServerRequestrK rL �r rN rO r r r �headers_received� s �z!_CallableAdapter.headers_receivedc C rA r )rM �append�r �chunkr r r � data_received� rD z _CallableAdapter.data_receivedc C s* d� | j�| j_| j�� | �| j� d S )N� )�joinrM rL �bodyZ _parse_bodyr �r r r r �finish� s z_CallableAdapter.finishc C s d | _ d S r )rM rZ r r r �on_connection_close� s z$_CallableAdapter.on_connection_closeN)rE rF rG r rR rV r[ r\ r r r r r< � s r< c @ s. e Zd Zd dd�Zdd� Zdd� Zdd � ZdS ) r3 Nc 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)r6 �socket�family�address_family�AF_INET�AF_INET6� remote_ipr! r9 r Z SSLIOStream�_orig_remote_ip�_orig_protocolr# r% )r r5 r6 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 ) ra r_ rb rc rd r9 r6 �bytesr �strrZ r r r �__str__ s z_HTTPRequestContext.__str__c C s� |� d| j�}dd� t|�d��D �D ] }|| jvr nq|� d|�}t�|�r+|| _|� d|� d| j��}|dv r?|| _d S d S ) z2Rewrite the ``remote_ip`` and ``protocol`` fields.zX-Forwarded-Forc s s � | ]}|� � V qd S r )�strip)�.0Zcandr r r � <genexpr> s � z6_HTTPRequestContext._apply_xheaders.<locals>.<genexpr>�,z X-Real-IpzX-SchemezX-Forwarded-Proto)r^ r] N)�getrd �reversed�splitr% r Z is_valid_ipr! )r rO �ipZ proto_headerr r r �_apply_xheaders 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)re rd rf r! rZ r r r �_unapply_xheaders$ s z%_HTTPRequestContext._unapply_xheadersr )rE rF rG r ri rr rs r r r r r3 � s r3 c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )r= c C s || _ || _d S r )rK r@ )r r@ r? r r r r / s z_ProxyAdapter.__init__c C s | j j�|� | j�||�S r )rK r7 rr r@ rR rQ r r r rR 3 s z _ProxyAdapter.headers_receivedc C s | j �|�S r )r@ rV rT r r r rV 7 s z_ProxyAdapter.data_receivedc C � | j �� | �� d S r )r@ r[ �_cleanuprZ r r r r[ : � z_ProxyAdapter.finishc C rt r )r@ r\ ru rZ r r r r\ > rv z!_ProxyAdapter.on_connection_closec C s | j j�� d S r )rK r7 rs rZ r r r ru B rD z_ProxyAdapter._cleanupN) rE rF rG r rR rV r[ r\ ru r r r r r= . s r= ) rH Z __future__r r r r_ Zsalt.ext.tornado.escaper Z salt.ext.tornado.http1connectionr r Zsalt.ext.tornador r r r Zsalt.ext.tornado.tcpserverr Zsalt.ext.tornado.utilr r: r ZHTTPMessageDelegater< �objectr3 r= rP Z HTTPRequestr r r r �<module> s& � (B
Save