Mh?^dZddlZddlZddlmZddlmZmZddlm Z ddlm Z ddlm Z ddl m Z dd lmZddlZdd lmZmZmZmZmZmZmZmZmZejrdd lmZGd d e ee jZGdde jZGddZ Gdde jZ!e j"Z#dS)aA 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)HTTP1ServerConnectionHTTP1ConnectionParameters)httputil)iostream)netutil) TCPServer) Configurable) UnionAnyDictCallableListTypeTupleOptional Awaitable)SetceZdZdZdededdfdZ d deeje ej gdffd e d e d e ee eefejfd e ed e de ede ede ede ede ede ede eeddfdZedeefdZedeefdZd!dZdejdeddfdZdedej dej!fdZ"deddfdZ#dS)" HTTPServeraA 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. argskwargsreturnNcdSN)selfrrs R/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/tornado/httpserver.py__init__zHTTPServer.__init__s Frequest_callback no_keep_alivexheaders ssl_optionsprotocoldecompress_request chunk_sizemax_header_sizeidle_connection_timeout body_timeout max_body_sizemax_buffer_sizetrusted_downstreamc ||_||_||_t|||| pd| | ||_t j||| |t|_| |_ dS)Ni) decompressr'r(header_timeoutr+r*r")r$r,read_chunk_size) r!r#r%r conn_paramsr rset _connectionsr-)rr!r"r#r$r%r&r'r(r)r*r+r,r-s r initializezHTTPServer.initializes.!1    4)!+2:d'%'     #+&      EE"4r ctSrrclss rconfigurable_basezHTTPServer.configurable_baser ctSrr7r8s rconfigurable_defaultzHTTPServer.configurable_defaultr;r cK|jrDtt|j}|d{V|jBdSdS)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)r4nextiterclose)rconns rclose_all_connectionsz HTTPServer.close_all_connectionssl T.//00D**,,            r streamaddressct|||j|j}t||j|}|j|||dSr)_HTTPRequestContextr%r-rr2r4add start_serving)rrDrEcontextrBs r handle_streamzHTTPServer.handle_streamsf% GT]D,C  %VT-=wGG d### 4     r server_conn request_connct|jtjr|j||}nt |j|}|jrt||}|Sr) isinstancer!rHTTPServerConnectionDelegate start_request_CallableAdapterr# _ProxyAdapter)rrLrMdelegates rrQzHTTPServer.start_requestsg d+X-R S S M,::; UUHH'(=|LLH = =$X|<  1{8##?#EF -       (3X5OOP %  )D/ "    5Xio-F,,,, r rRc eZdZ d dejdedeedeeeddf dZ defdZ d e j ddfd Z d d ZdS)rGNrDrEr%r-rc||_|j|jj|_nd|_|jtjtjfvr||d|_nd|_|r||_n)t|tj rd|_nd|_|j|_ |j|_ t|pg|_dS)Nrz0.0.0.0httpshttp)rEsocketfamilyaddress_familyAF_INETAF_INET6 remote_ipr%rOr SSLIOStream_orig_remote_ip_orig_protocolr3r-)rrDrEr%r-s rrz_HTTPRequestContext.__init__+s  = $"(-"6D  "&D   FNFO#D D D#$QZDNN'DN  #$DMM  4 5 5 ##DMM"DM#~"m"%&8&>B"?"?r c|jtjtjfvr|jSt |jtrt|jSt|jSr) rrrrrrOrErrrars r__str__z_HTTPRequestContext.__str__MsW  6>6?"C C C> !  e , , %dl++ +t|$$ $r rqc|d|j}dt|dDD] }||jvrn|d|}t j|r||_|d|d|j}|r-|dd}|dvr ||_d Sd S) z2Rewrite the ``remote_ip`` and ``protocol`` fields.zX-Forwarded-Forc3>K|]}|VdSr)strip).0cands r z6_HTTPRequestContext._apply_xheaders..]s*DDD4::<<DDDDDDr ,z X-Real-IpzX-SchemezX-Forwarded-Proto)rrN) getrreversedsplitr-r is_valid_ipr%r)rrqip proto_headers r_apply_xheadersz#_HTTPRequestContext._apply_xheadersXs[[*DN ; ;DDHRXXc]],C,CDDD  B0001 [[b ) )  r " " DN{{  $7GG    ?(--c2226<<>>L , , ,(DMMM - ,r c6|j|_|j|_dS)zUndo changes from `_apply_xheaders`. Xheaders are per-request so they should not leak to the next request on the same connection. N)rrrr%rs r_unapply_xheadersz%_HTTPRequestContext._unapply_xheadersns -+ r rrZ)r[r\r]rrgrrrarrrrrrrrr rrGrG*s 37 @ @! @ @3- @ %T#Y/ @  @ @ @ @D % % % % %)x';))))),,,,,,,r rGceZdZdejdejddfdZdeejej fdej de e dfdZ d ede e dfd Zdd Zdd Zdd ZdS)rSrTrMrNc"||_||_dSr)rmrT)rrTrMs rrz_ProxyAdapter.__init__ys '  r rprqcv|jj||j||Sr)rmrJrrTrurts rruz_ProxyAdapter.headers_receiveds5 //888}--j'BBBr rvc6|j|Sr)rTrzrys rrzz_ProxyAdapter.data_receiveds}**5111r c`|j|dSr)rTr_cleanuprs rrz_ProxyAdapter.finishs'  r c`|j|dSr)rTrrrs rrz!_ProxyAdapter.on_connection_closes' ))+++ r cB|jjdSr)rmrJrrs rrz_ProxyAdapter._cleanups 1133333r rZ)r[r\r]rrjrirr rsrrrrrurrzrrrrr rrSrSxs!.!-!  !!!!C(3X5OOPC%C )D/ " CCCC252Xio-F2222444444r rS)$r^rrbtornado.escapertornado.http1connectionrrtornadorrrtornado.tcpserverr tornado.utilr rWr r r rrrrrr TYPE_CHECKINGrrPrrjrRrGrSr_ HTTPRequestrr rrs   %%%%%%TTTTTTTT''''''%%%%%% UUUUUUUUUUUUUUUUUUUUUU SRSRSRSRSRL(*OSRSRSRl#####x3###LK,K,K,K,K,K,K,K,\44444H0444D( r