R?g ?SrSSKrSSKrSSKJr SSKJrJr SSKJ r SSKJ r SSKJ r SSK J r SS KJr SSKrSS KJrJrJrJrJrJrJrJrJr \R4(aSS KJr "S S \ \\ R85r"SS\ R<5r"SS\ 5r!"SS\ R<5r"\ RFr$g)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)Setc\rSrSrSrS\S\SS4SjrS!S\\R\ \R/S44S \ S \ S \ \\\\4\R"4S \ \S \ S\ \S\ \S\ \S\ \S\ \S\ \S\ \\SS4Sjjr\S\\4Sj5r\S\\4Sj5rS"SjrS\R:S\SS4SjrS\ S\RBS\RD4Sjr#S\ SS4Sjr$S r%g)# HTTPServer.aA 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. argskwargsreturnNcgN)selfrrs 4/usr/lib/python3/dist-packages/tornado/httpserver.py__init__HTTPServer.__init__s request_callback no_keep_alivexheaders ssl_optionsprotocoldecompress_request chunk_sizemax_header_sizeidle_connection_timeout body_timeout max_body_sizemax_buffer_sizetrusted_downstreamc XlX0lXPl[UUUU =(d SU U US9Ul[ R "UUU US9 [5UlXl g)Ni) decompressr)r*header_timeoutr-r,r$)r&r.read_chunk_size) r#r%r'r conn_paramsr r set _connectionsr/)rr#r$r%r&r'r(r)r*r+r,r-r.r/s r initializeHTTPServer.initializesi.!1  4)!+2:d'%'   #+&   E"4r"c[$rrclss rconfigurable_baseHTTPServer.configurable_baser"c[$rr:r;s rconfigurable_defaultHTTPServer.configurable_defaultr?r"c# UR(aJ[[UR55nUR5IShvN UR(aMIggN7f)aClose 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)r6nextiterclose)rconns rclose_all_connections HTTPServer.close_all_connectionssGT../0D**,   sAA!AA!A!streamaddressc[XURUR5n[XRU5nUR R U5 URU5 gr)_HTTPRequestContextr'r/rr4r6add start_serving)rrJrKcontextrGs r handle_streamHTTPServer.handle_streamsS% T]]D,C,C %V-=-=wG d# 4 r" server_conn request_connc[UR[R5(aURR X5nO[ URU5nUR (a [X25nU$r) isinstancer#rHTTPServerConnectionDelegate start_request_CallableAdapterr% _ProxyAdapter)rrSrTdelegates rrXHTTPServer.start_requests[ d++X-R-R S S,,::;UH'(=(=|LH ==$X$>#?#EF --    (33X5O5OOP %%  )D/ " 5Xio-F, r"rYc \rSrSrSS\R S\S\\S\\ \SS4 Sjjr S\4S jr S \ RSS4S jrSS jrS rg)rMi*NrJrKr'r/rcX lURbURRUlOSUlUR[R[R 4;aUb USUlOSUlU(aX0lO.[U[R5(aSUlOSUlUR Ul URUl [U=(d /5Ulg)Nrz0.0.0.0httpshttp)rKsocketfamilyaddress_familyAF_INETAF_INET6 remote_ipr'rVr SSLIOStream_orig_remote_ip_orig_protocolr5r/)rrJrKr'r/s rr _HTTPRequestContext.__init__+s  == $"(--"6"6D "&D    FNNFOO#D D#$QZDN'DN $M  4 4 5 5#DM"DM#~~"mm"%&8&>B"?r"cUR[R[R4;a UR$[ UR [5(a[UR 5$[UR 5$r) rrrrrrVrKrrrkrs r__str___HTTPRequestContext.__str__MsX   6>>6??"C C>> !  e , ,dll+ +t||$ $r"r}cURSUR5nS[URS555HnX R;dM O URSU5n[ R "U5(aX lURSURSUR55nU(a"URS5SR5nUS;aX0lg g ) z2Rewrite the ``remote_ip`` and ``protocol`` fields.zX-Forwarded-Forc3@# UHoR5v M g7fr)strip).0cands r 6_HTTPRequestContext._apply_xheaders..]sD,CD::<<,Cs,z X-Real-IpzX-SchemezX-Forwarded-Proto)rrN) getrreversedsplitr/r is_valid_ipr'r)rr}ip proto_headers r_apply_xheaders#_HTTPRequestContext._apply_xheadersXs[[*DNN ;DHRXXc],CDB000E[[b )   r " "N{{  $7G  (--c226<<>L , ,(M -r"cHURUlURUlg)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_xheaders%_HTTPRequestContext._unapply_xheadersns --++ r")rrrKrr'rr/rrc)rdrerfrgrrqrrrkrr rrrrrrurr"rrMrM*s 37 @!! @ @3- @ %T#Y/ @  @D % %)x';';)),,r"rMc\rSrSrS\R S\R SS4SjrS\\R\R4S\RS\ \ S4S jrS \S\ \ S4S jrSS jrSS jrSSjrSrg)rZixr[rTrNcX lXlgrrxr[)rr[rTs rr _ProxyAdapter.__init__ys ' r"r|r}cURRRU5 URR X5$r)rxrPrr[rrs rr_ProxyAdapter.headers_receiveds1 //8}}--jBBr"rc8URRU5$r)r[rrs rr_ProxyAdapter.data_receiveds}}**511r"cXURR5 UR5 gr)r[r_cleanuprs rr_ProxyAdapter.finishs  r"cXURR5 UR5 gr)r[rrrs rr!_ProxyAdapter.on_connection_closes ))+ r"cLURRR5 gr)rxrPrrs rr_ProxyAdapter._cleanups 113r"rrc)rdrerfrgrrtrsr r rrrrrrrrrrrrurr"rrZrZxs!..!--!  !C(33X5O5OOPC%%C )D/ " C252Xio-F24r"rZ)%rhrrltornado.escapertornado.http1connectionrrtornadorrrtornado.tcpserverr tornado.utilr r_r r r rrrrrr TYPE_CHECKINGrrWrrtrYrrrMrZri HTTPRequestrr"rrs  %T'% UUU SRL(*O*OSRl#x33#LK,&K,\4H004D(( r"