ї цLАTвnЦСv≈dZdZddlZddlZddlZddlZddlZddlmZddl m Z gd╒Zeedі╚re═ gd╒і╚eed і╚re═ gd ╒і╚eedі╚rejZnejZGd└d і╚ZGd└deі╚ZGd└deі╚Zeedі╚r Gd└dі╚ZGd└deі╚ZGd└dі╚ZGd└dі╚Zeedі╚rGd└deeі╚ZGd└deeі╚ZGd└deeі╚ZGd └d!eeі╚Zeed і╚r:Gd"└d#eі╚ZGd$└d%eі╚ZGd&└d'eeі╚ZGd(└d)eeі╚Z Gd*└d+і╚Z!Gd,└d-e!і╚Z"Gd.└d/eі╚Z#Gd0└d1e!і╚Z$dS)2aqGeneric socket server classes. This module tries to capture the various aspects of defining a server: For socket-based servers: - address family: - AF_INET{,6}: IP (Internet Protocol) sockets (default) - AF_UNIX: Unix domain sockets - others, e.g. AF_DECNET are conceivable (see - socket type: - SOCK_STREAM (reliable stream, e.g. TCP) - SOCK_DGRAM (datagrams, e.g. UDP) For request-based servers (including socket-based): - client address verification before further looking at the request (This is actually a hook for any processing that needs to look at the request before anything else, e.g. logging) - how to handle multiple requests: - synchronous (one request is handled at a time) - forking (each request is handled by a new process) - threading (each request is handled by a new thread) The classes in this module favor the server type that is simplest to write: a synchronous TCP/IP server. This is bad class design, but saves some typing. (There's also the issue that a deep class hierarchy slows down method lookups.) There are five classes in an inheritance diagram, four of which represent synchronous servers of four types: +------------+ | BaseServer | +------------+ | v +-----------+ +------------------+ | TCPServer |------->| UnixStreamServer | +-----------+ +------------------+ | v +-----------+ +--------------------+ | UDPServer |------->| UnixDatagramServer | +-----------+ +--------------------+ Note that UnixDatagramServer derives from UDPServer, not from UnixStreamServer -- the only difference between an IP and a Unix stream server is the address family, which is simply repeated in both unix server classes. Forking and threading versions of each type of server can be created using the ForkingMixIn and ThreadingMixIn mix-in classes. For instance, a threading UDP server class is created as follows: class ThreadingUDPServer(ThreadingMixIn, UDPServer): pass The Mix-in class must come first, since it overrides a method defined in UDPServer! Setting the various member variables also changes the behavior of the underlying server mechanism. To implement a service, you must derive a class from BaseRequestHandler and redefine its handle() method. You can then run various versions of the service by combining one of the server classes with your request handler class. The request handler class must be different for datagram or stream services. This can be hidden by using the request handler subclasses StreamRequestHandler or DatagramRequestHandler. Of course, you still have to use your head! For instance, it makes no sense to use a forking server if the service contains state in memory that can be modified by requests (since the modifications in the child process would never reach the initial state kept in the parent process and passed to each child). In this case, you can use a threading server, but you will probably have to use locks to avoid two requests that come in nearly simultaneous to apply conflicting changes to the server state. On the other hand, if you are building e.g. an HTTP server, where all data is stored externally (e.g. in the file system), a synchronous class will essentially render the service "deaf" while one request is being handled -- which may be for a very long time if a client is slow to read all the data it has requested. Here a threading or forking server is appropriate. In some cases, it may be appropriate to process part of a request synchronously, but to finish processing in a forked child depending on the request data. This can be implemented by using a synchronous server and doing an explicit fork in the request handler class handle() method. Another approach to handling multiple simultaneous requests in an environment that supports neither threads nor fork (or where these are too expensive or inappropriate for the service) is to maintain an explicit table of partially finished requests and to use a selector to decide which request to work on next (or whether to handle a new incoming request). This is particularly important for stream services where each client can potentially be connected for a long time (if threads or subprocesses cannot be used). Future work: - Standard classes for Sun RPC (which uses either UDP or TCP) - Standard mix-in classes to implement various authentication and encryption schemes XXX Open problems: - What to do with out-of-band data? BaseServer: - split generic "request" functionality out into BaseServer class. Copyright (C) 2000 Luke Kenneth Casson Leighton example: read entries from a SQL database (requires overriding get_request() to return a table entry from the database). entry is processed by a RequestHandlerClass. z0.4ИN)зBufferedIOBase)з monotonic) з BaseServerз TCPServerз UDPServerзThreadingUDPServerзThreadingTCPServerзBaseRequestHandlerзStreamRequestHandlerзDatagramRequestHandlerзThreadingMixInзfork)зForkingUDPServerзForkingTCPServerзForkingMixInзAF_UNIX)зUnixStreamServerзUnixDatagramServerзThreadingUnixStreamServerзThreadingUnixDatagramServerзPollSelectorcС~≈eZdZdZdZd└Zd└Zdd└Zd└Zd└Z d └Z d └Zd└Zd└Z d └Zd└Zd└Zd└Zd└Zd└Zd└Zd└ZdS)raоBase class for server classes. Methods for the caller: - __init__(server_address, RequestHandlerClass) - serve_forever(poll_interval=0.5) - shutdown() - handle_request() # if you do not use serve_forever() - fileno() -> int # for selector Methods that may be overridden: - server_bind() - server_activate() - get_request() -> request, client_address - handle_timeout() - verify_request(request, client_address) - server_close() - process_request(request, client_address) - shutdown_request(request) - close_request(request) - service_actions() - handle_error() Methods for derived classes: - finish_request(request, client_address) Class variables that may be overridden by derived classes or instances: - timeout - address_family - socket_type - allow_reuse_address - allow_reuse_port Instance variables: - RequestHandlerClass - socket NcС`≈||_||_tjі╚|_d|_dS)З/Constructor. May be extended, do not override.FN)зserver_addressзRequestHandlerClassз threadingзEventз_BaseServer__is_shut_downз_BaseServer__shutdown_request)зselfrrs З9/opt/alt/python-internal/lib64/python3.11/socketserver.pyз__init__zBaseServer.__init__иs0─Ю,┬ть#6┬т щ'°oя/т/┬ть"'┬тппСcС≈dS╘zSCalled by constructor to activate the server. May be overridden. N╘╘r!s r"зserver_activatezBaseServer.server_activateпС ─П ┬r$ГЮ?cСЗ≈|j═і╚ tі╚5}|═|tjі╚|jsN|═|і╚}|jrn1|r|═і╚|═ і╚|j╞Ndddі╚n#1swxYwYd|_|j═ і╚dS#d|_|j═ і╚wxYw)zяHandle one request at a time until shutdown. Polls for shutdown every poll_interval seconds. Ignores self.timeout. If you need to do periodic tasks, do them in another thread. NF)rзclearз_ServerSelectorзregisterз selectorsз EVENT_READr зselectз_handle_request_noblockзservice_actionsзset)r!з poll_intervalзselectorзreadys r"з serve_foreverzBaseServer.serve_foreverьsE─П тв!р!я#т#п#П &У !я"т"П +═hьв!р!═$ґ т(<я=т=п=Ют1П+ь$÷O O╗Mя:т:░EЮт.ПььП7ьв4р4я6т6п6Юв(р(я*т*п*Пт1П+П +П +П +Я +Т +П +П +П +П +П +П +ЬЬЬП +П +П +П +П',┬Dт#ьтв#р#я%т%п%п%п%ЬП',┬Dт#ьтв#р#я%т%п%п%ЬЬЬs/⌡C╘A6B+бCб+B/б/Cб2B/б3Cц"C:cСF≈d|_|j═і╚dS)zюStops the serve_forever loop. Blocks until the loop has finished. This must be called while serve_forever() is running in another thread, or it will deadlock. TN)r rзwaitr(s r"зshutdownzBaseServer.shutdownУs'─П#'┬тьтв р я"т"п"п"п"r$cС≈dS)z║Called by the serve_forever() loop. May be overridden by a subclass / Mixin to implement any code that needs to be run during the loop. Nr'r(s r"r4zBaseServer.service_actionsЪr*r$cС≈|j═і╚}|─|j}n|j│t||jі╚}|│t і╚|z}tі╚5}|═|tjі╚ |═ |і╚}|r |═ і╚cdddі╚S|│7|t і╚z }|dkr |═і╚cdddі╚S▄q#1swxYwYdS)zOHandle one request, possibly blocking. Respects self.timeout. NTr)зsocketз gettimeoutзtimeoutзminзtimer.r/r0r1r2r3зhandle_timeout)r!rAзdeadliner7r8s r"зhandle_requestzBaseServer.handle_requestsb─П■+в(р(я*т*┬ь┬?ь■l┬G┬Gь ▄\п %щ≤'═4є<я0т0┬Gьпщ▒v■v═я'┬HУя т П 9═(ьвр≤d╔Iт$8я9т9п9П 9ь ÷ ╗я0т0░ьП9ьв7р7я9т9П 9П 9П 9П 9Я 9Т 9П 9П 9Пп*ь"*ґT╘V╛Vя"3≤ь"═Q ;≤;ь#'в#6р#6я#8т#8П 9П 9П 9П 9Я 9Т 9П 9П 9П 9П 9П 9П 9П 9ЬЬЬП 9П 9П 9П 9П 9П 9sа!AC4б:,C4ц3C4ц4C8ц;C8cС├≈ |═і╚\}}n#t$rYdSwxYw|═||і╚rk |═||і╚dS#t$r/|═||і╚|═|і╚YdS|═|і╚┌xYw|═|і╚dS)zЙHandle one request, without blocking. I assume that selector.select() has returned that the socket is readable before this function was called, so there should be no risk of blocking in get_request(). N)зget_requestзOSErrorзverify_requestзprocess_requestз Exceptionзhandle_errorзshutdown_request╘r!зrequestзclient_addresss r"r3z"BaseServer._handle_request_noblock0sЫ─П ь&*в&6р&6я&8т&8я#┬G░^░^ЬщП П П ь┬F┬FП ЬЬЬЮвр≤w╗я7т7П +П ьв$р$═W╗nя=т=п=п=п=ЬщП /П /П /ьв!р!═'╗>я:т:п:ьв%р%═gя.т.п.п.п.п.П ьв%р%═gя.т.п.ьЬЬЬЮв!р!═'я*т*п*п*п*s┌ (ї(аAа5B)бB)cС≈dS)zcCalled if no new request arrives within self.timeout. Overridden by ForkingMixIn. Nr'r(s r"rDzBaseServer.handle_timeoutGs ─П ┬r$cС≈dS)znVerify the request. May be overridden. Return True if we should proceed with this request. Tr'rOs r"rJzBaseServer.verify_requestNs ─П┬tr$cС\≈|═||і╚|═|і╚dS)zVCall finish_request. Overridden by ForkingMixIn and ThreadingMixIn. N)зfinish_requestrNrOs r"rKzBaseServer.process_requestVs4─П вр≤G═^я4т4п4ьвр≤gя&т&п&п&п&r$cС≈dS╘zDCalled to clean-up the server. May be overridden. Nr'r(s r"зserver_closezBaseServer.server_close_r*r$cС4≈|═|||і╚dS)z8Finish one request by instantiating RequestHandlerClass.N)rrOs r"rUzBaseServer.finish_requestgs ─Юв р ═╗.╦$я?т?п?п?п?r$cС0≈|═|і╚dS╘z3Called to shutdown and close an individual request.N╘з close_request╘r!rPs r"rNzBaseServer.shutdown_requestkС─Ювр≤7я#т#п#п#п#r$cС≈dS╘z)Called to clean up an individual request.Nr'r^s r"r]zBaseServer.close_requestoС─Ю┬r$cСз≈tdtj╛і╚td|tj╛і╚ddl}|═і╚tdtj╛і╚dS)ztHandle an error gracefully. May be overridden. The default is to print a traceback and continue. z(----------------------------------------)зfilez4Exception occurred during processing of request fromrN)зprintзsysзstderrз tracebackз print_exc)r!rPrQrhs r"rMzBaseServer.handle_errorsss─У ┬f²3°:п&я&т&п&щ пDь╔єП -Я -Т -П -Юпппьврятпщ ┬f²3°:п&я&т&п&п&п&r$cС≈|S╘Nr'r(s r"з __enter__zBaseServer.__enter__─s─ь┬r$cС.≈|═і╚dSrk)rX)r!зargss r"з__exit__zBaseServer.__exit__┐s─ьврятпппr$)r+)з__name__з __module__з__qualname__з__doc__rAr#r)r9r<r4rFr3rDrJrKrXrUrNr]rMrlror'r$r"rr≥s-─────П*П*ПX─GП(П(П(П П П П&П&П&П&П:#П#П#П П П П&9П9П9П<+П+П+П. П П ПППП'П'П'П П П П@П@П@П$П$П$П П П П'П'П'ППППППППr$rcСl≈eZdZdZejZejZdZ dZ dZdd└Zd└Z d└Zd└Zd └Zd └Zd└Zd└Zd S)raJBase class for various socket-based server classes. Defaults to synchronous IP stream (i.e., TCP). Methods for the caller: - __init__(server_address, RequestHandlerClass, bind_and_activate=True) - serve_forever(poll_interval=0.5) - shutdown() - handle_request() # if you don't use serve_forever() - fileno() -> int # for selector Methods that may be overridden: - server_bind() - server_activate() - get_request() -> request, client_address - handle_timeout() - verify_request(request, client_address) - process_request(request, client_address) - shutdown_request(request) - close_request(request) - handle_error() Methods for derived classes: - finish_request(request, client_address) Class variables that may be overridden by derived classes or instances: - timeout - address_family - socket_type - request_queue_size (only for stream sockets) - allow_reuse_address - allow_reuse_port Instance variables: - server_address - RequestHandlerClass - socket ИFTcС≈t═|||і╚tj|j|jі╚|_|rE |═і╚|═і╚dS#|═і╚┌xYwdS)rN)rr#r?зaddress_familyзsocket_typeзserver_bindr)rX)r!rrзbind_and_activates r"r#zTCPServer.__init__аs≤─Евр≤D═.п2EяFтFпFщ■m═Dт$7ь$(т$4Я6Т6┬▄ЮП П ьв р я"т"п"ьв$р$я&т&п&п&п&ЬП ьв!р!я#т#п#ьЬЬЬП П sа(A.а.BcС╟≈|jrEttdі╚r0|j═tjtjdі╚|jrEttdі╚r0|j═tjtjdі╚|j═|j і╚|j═ і╚|_ dS)zOCalled by constructor to bind the socket. May be overridden. зSO_REUSEADDRИзSO_REUSEPORTN)зallow_reuse_addressзhasattrr?з setsockoptз SOL_SOCKETr|зallow_reuse_portr~зbindrзgetsocknamer(s r"ryzTCPServer.server_bindнs╣─Пт#П Nґ╣╦я(Gт(GП Nь▄Kв"р"╔6т#4╣fт6Iх1яMтMпMьт П N╔WґV╟^я%Dт%DП Nь▄Kв"р"╔6т#4╣fт6Iх1яMтMпMь▄вр≤т,я-т-п-ь"°kв5р5я7т7┬тппr$cСD≈|j═|jі╚dSr&)r?зlistenзrequest_queue_sizer(s r"r)zTCPServer.server_activateшs#─П ▄вр≤4т2я3т3п3п3п3r$cС8≈|j═і╚dSrW)r?зcloser(s r"rXzTCPServer.server_closeЦs─П ▄врятпппr$cС4≈|j═і╚S)zMReturn socket file number. Interface required by selector. )r?зfilenor(s r"r▄zTCPServer.filenoКС─П▄{в!р!я#т#п#r$cС4≈|j═і╚S)zYGet the request and client address from the socket. May be overridden. )r?зacceptr(s r"rHzTCPServer.get_requestСr█r$cС▓≈ |═tjі╚n#t$rYnwxYw|═|і╚dSr[)r<r?зSHUT_WRrIr]r^s r"rNzTCPServer.shutdown_requestШs\─П П вр²V°^я,т,п,п,ЬщП П П ь┬DП ЬЬЬЮвр≤7я#т#п#п#п#s┌"╒ /ў/cС.≈|═і╚dSra)r┼r^s r"r]zTCPServer.close_requests─Ю▐ ┼ ┴▄┬┬┬r$N)T)rprqrrrsr?зAF_INETrwзSOCK_STREAMrxr┬rr┐r#ryr)rXr▄rHrNr]r'r$r"rr┤s©─────П,П,П\■^─NЮт$─KЮпЮпЮпППППП8П8П8П4П4П4ПППП$П$П$П$П$П$П$П$П$ПППППr$rcСD≈eZdZdZdZdZejZdZ d└Z d└Zd└Zd└Z dS) rzUDP server class.Fi cС\≈|j═|jі╚\}}||jf|fSrk)r?зrecvfromзmax_packet_size)r!зdataзclient_addrs r"rHzUDPServer.get_requests1─ь °Kв0р0╟т1EяFтFя┬┬kь░d■kп"═Kп/п/r$cС≈dSrkr'r(s r"r)zUDPServer.server_activaterbr$cС0≈|═|і╚dSrkr\r^s r"rNzUDPServer.shutdown_requestr_r$cС≈dSrkr'r^s r"r]zUDPServer.close_request"rbr$N)rprqrrrsrr┐r?з SOCK_DGRAMrxr≤rHr)rNr]r'r$r"rr so─────ЮпЮпЮпЮт#─KЮ─OП0П0П0П П П П$П$П$П П П П П r$rcСP┤≈eZdZdZdZdZdZdZdd°d└Zd └Z d └Z d└Z┬fd└Z┬xZ S) rz5Mix-in class to handle each request in a new process.i,NИ(TF╘зblockingcС└≈|j─dSt|jі╚|jkr┘ tjddі╚\}}|j═|і╚n4#t$r|j═і╚Ynt$rYn!wxYwt|jі╚|jk╟┘|j═ і╚D]z} |rdntj }tj||і╚\}}|j═|і╚▄F#t$r|j═|і╚Y▄lt$rY▄wwxYwdS)z7Internal routine to wait for children that have exited.NИЪЪЪЪr)зactive_childrenзlenзmax_childrenзosзwaitpidзdiscardзChildProcessErrorr-rIзcopyзWNOHANG)r!r╒зpidз_зflagss r"зcollect_childrenzForkingMixIn.collect_children0s├─Ют#п+ь░У░dт*я+т+╗tт/@р@п@Пщ°Z╗╗Aя.т.▒F░C≤ьт(в0р0╟я5т5п5п5Ьщ(П1П1П1Ют(в.р.я0т0п0п0п0щПППь░EПЬЬЬУ░dт*я+т+╗tт/@р@п@Пт+в0р0я2т2П П ░П ь!)п9≤A≤Aґr╛z░Eщ°Z╗╗Uя3т3▒F░C≤Пт(в0р0╟я5т5п5п5Ьщ(П6П6П6Ют(в0р0╟я5т5п5п5п5щПППь░DПЬЬЬП П s0╗2Aа#Bб BбBцADд$D=д1 D=дт>п>п>п>П?ЬЬЬП)ьв-р-╗gя6т6п6Е°═я(т(п(п(п(Ь²°═я(т(п(п(ЬЬЬЬП)ьв-р-╗gя6т6п6Е°═я(т(п(п(Ь²°═я(т(п(п(ЬЬЬЬЬЬsNа$A=ап!я?т?п?п?п?r$)rprqrrrsrAr╔rїr╪r╠rDr4rKrXз __classcell__╘rЎs@r"rr's╔Ь─────ьCпCЮ┬ь┬ь┬Ю┬Ю/4П! П! П! П! П! ПF $П $П $П $П $П $П )П )П )П2 @П @П @П @П @П @П @П @П @r$rcС4┤≈eZdZdZ┬fd└Zd└Zd└Zd└Z┬xZS)з_Threadsz2 Joinable list of all non-daemon threads. cС└∙≈|═і╚|jrdStі╚═|і╚dSrk)зreapзdaemonr╩зappend)r!зthreadrЎs ─r"rфz_Threads.append┐s;Ь─ь▐ ┼ ┴▄┬ь▄=П ь┬Fщ ┴▄▐┼░vятпппr$cС*≈g|dd┘c|dd┘<}|Srkr')r!зresults r"зpop_allz_Threads.pop_all┴s"─ь≤d═1═1═1°g┬┬┬Q┬Q┬Q┴░ь┬ r$cС\≈|═і╚D]}|═і╚▄dSrk)rйзjoin╘r!rгs r"rлz _Threads.join█s2─ь≈l▓l▒n■nП П ┬Fь▐K┼K┴M▄M┬M┬MП П r$cС(≈d└|Dі╚|dd┘<dS)Nc3СBK≈|]}|═і╚╞|V≈▄dSrk)зis_alive)з.0rгs r"З z _Threads.reap..▓s1ХХ─пBпB≤f╟Ї╡я0Aт0AпB░6пBпBпBпBпBпBr$r'r(s r"rдz _Threads.reap▒s!─ьBпB╗пBяBтB┬┬Q┬Q┬Q┴┬┬r$) rprqrrrsrфrйrлrдr©rюs@r"rбrбsvЬ─────ППППППППППППППCПCПCПCПCПCПCr$rбcС≈eZdZdZd└Zd└ZdS)з _NoThreadsz) Degenerate version of _Threads. cС≈dSrkr'rмs r"rфz_NoThreads.append≥С─ь┬r$cС≈dSrkr'r(s r"rлz_NoThreads.join°rжr$N)rprqrrrsrфrлr'r$r"rтrт∙s<─────ППП П П П П П П П r$rтcСJ┤≈eZdZdZdZdZeі╚Zd└Zd└Z ┬fd└Z ┬xZS)r z4Mix-in class to handle each request in a new thread.FTcСЮ≈ |═||і╚n&#t$r|═||і╚YnwxYw|═|і╚dS#|═|і╚wxYw)zgSame as in BaseServer but as a thread. In addition, exception handling is done here. N)rUrLrMrNrOs r"зprocess_request_threadz%ThreadingMixIn.process_request_thread╛s█─П +ьвр═╗я8т8п8п8ЬщП 7П 7П 7ьвр≤g═~я6т6п6п6п6П 7ЬЬЬП в!р!═'я*т*п*п*п*Ь┬Dв!р!═'я*т*п*п*ЬЬЬs!┌≤A≥ <╧A╩<╪AаA-cС ≈|jr/t|і╚═dtі╚і╚t j|j||f╛і╚}|j|_|j ═ |і╚|═і╚dS)z*Start a new thread to process the request.з_threads)зtargetrnN)r╪зvarsз setdefaultrбrзThreadrззdaemon_threadsrеrэrфзstart)r!rPrQзts r"rKzThreadingMixIn.process_request╧s┌─ЮтП :щ░┴J▄Jв!р!═*ґh╘j╛jя9т9п9щт═dт&Aь%,╗nп$=П ?Я ?Т ?┬Ют&┬▄ь▄ вр≤Qятпь ▐┼┴ ▄ ┬ ┬ ┬ r$cСz∙≈tі╚═і╚|j═і╚dSrk)r╩rXrэrлrҐs ─r"rXzThreadingMixIn.server_closeцs3Ь─щ ┴▄врятпь▄ врятпппr$)rprqrrrsrАr╪rтrэrзrKrXr©rюs@r"r r ═suЬ─────ь>п>П─NЮ─NП┬z┴|▄|─HП+П+П+ППППППППППППr$r cС≈eZdZdS)rN╘rprqrrr'r$r"rrиС───────r$rcС≈eZdZdS)rNrФr'r$r"rrйrГr$rcС≈eZdZdS)rNrФr'r$r"rrлrГr$rcС≈eZdZdS)r NrФr'r$r"r r мrГr$r cС≈eZdZejZdS)rN╘rprqrrr?rrwr'r$r"rrяС─────ь°┬┬┬r$rcС≈eZdZejZdS)rNrЛr'r$r"rrтrМr$rcС≈eZdZdS)rNrФr'r$r"rrвrГr$rcС≈eZdZdS)rNrФr'r$r"rrыrГr$rcС*≈eZdZdZd└Zd└Zd└Zd└ZdS)r a╔Base class for request handler classes. This class is instantiated for each request to be handled. The constructor sets the instance variables request, client_address and server, and then calls the handle() method. To implement a specific service, all you need to do is to derive a class which defines a handle() method. The handle() method can find the request as self.request, the client address as self.client_address, and the server (in case it needs access to per-server information) as self.server. Since a separate instance is created for each request, the handle() method can define other arbitrary instance variables. cСэ≈||_||_||_|═і╚ |═і╚|═і╚dS#|═і╚wxYwrk)rPrQзserverзsetupзhandleзfinish)r!rPrQrСs r"r#zBaseRequestHandler.__init__МsZ─ь┬▄ь,┬ть┬▄ь▐ ┼ ┴▄┬П ь▐K┼K┴M▄M┬MЮ▐K┼K┴M▄M┬M┬M┬MЬ┬D▐K┼K┴M▄M┬M┬MЬЬЬs╚AаA+cС≈dSrkr'r(s r"rТzBaseRequestHandler.setupВrжr$cС≈dSrkr'r(s r"rУzBaseRequestHandler.handleЗrжr$cС≈dSrkr'r(s r"rЖzBaseRequestHandler.finishЩrжr$N)rprqrrrsr#rТrУrЖr'r$r"r r шsZ─────ППП ППП П П П П П П П П П П r$r cС.≈eZdZdZdZdZdZdZd└Zd└Z dS)rz4Define self.rfile and self.wfile for stream sockets.rєrNFcС╦≈|j|_|j│|j═|jі╚|jr0|j═tjtjdі╚|j═ d|j і╚|_|jdkrt|jі╚|_dS|j═ d|jі╚|_dS)NTзrbrзwb)rPз connectionrAз settimeoutзdisable_nagle_algorithmr│r?зIPPROTO_TCPзTCP_NODELAYзmakefileзrbufsizeзrfileзwbufsizeз _SocketWriterзwfiler(s r"rТzStreamRequestHandler.setupsҐ─ь°,┬▄ь▄<п#ь▄Oв&р&═tє|я4т4п4ьт'П Aь▄Oв&р&╔vт'9щ'-т'9╦4Я AТ AП AЮ■_в-р-╗d╟DЄMяBтB┬▄ ь▄=≤Aрпщ&═tєя7т7┬D▄J┬J┬JЮ°в1р1╟$╦╪ яFтF┬D▄J┬J┬Jr$cСБ≈|jjs0 |j═і╚n#tj$rYnwxYw|j═і╚|j═і╚dSrk)rзclosedзflushr?зerrorr┼rr(s r"rЖzStreamRequestHandler.finish+s─ь▄zт П П ь■ в р я"т"п"п"Ьщ■<П П П П░П ЬЬЬП ▄ врятпь▄ врятпппs▌(╗:╧:) rprqrrrsrrrArrТrЖr'r$r"rr sV─────Ю>п>П─Hь─HП─GП$пПGПGПGП П П П П r$rcС*≈eZdZdZd└Zd└Zd└Zd└ZdS)rz┌Simple writable BufferedIOBase implementation for a socket Does not hold data in a buffer, avoiding any need to call flush().cС≈||_dSrk)з_sock)r!зsocks r"r#z_SocketWriter.__init__;s ─ь┬▄ ┬ ┬ r$cС≈dS)NTr'r(s r"зwritablez_SocketWriter.writable>s─ь┬tr$cС√≈|j═|і╚t|і╚5}|jcdddі╚S#1swxYwYdSrk)rзsendallз memoryviewзnbytes)r!зbзviews r"зwritez_SocketWriter.writeAs┼─ь▄ вр≤1ятпщ ≤┴]▄]П ≤dь■;П П П П Я Т П П П П П П ЬЬЬП П П П П П s╙>ЎAаAcС4≈|j═і╚Srk)rr▄r(s r"r▄z_SocketWriter.filenoFs─ь▄zв р я"т"п"r$N)rprqrrrsr#rrr▄r'r$r"rr6s\─────ПJПJПППППППППП #П#П#П#П#r$rcС≈eZdZdZd└Zd└ZdS)rz6Define self.rfile and self.wfile for datagram sockets.cС┌≈ddlm}|j\|_|_||jі╚|_|і╚|_dS)Nr)зBytesIO)зiorrPзpacketr?rr)r!rs r"rТzDatagramRequestHandler.setupMsH─ьпппппь#'є<я ┬▄░T■[ь░W≤T°[я)т)┬▄ ь░W▒Y■Y┬▄ ┬ ┬ r$cСt≈|j═|j═і╚|jі╚dSrk)r?зsendtorзgetvaluerQr(s r"rЖzDatagramRequestHandler.finishSs1─ь▄вр≤4°:в.р.я0т0╟$т2EяFтFпFпFпFr$N)rprqrrrsrТrЖr'r$r"rrIs=─────Ю@п@ППППGПGПGПGПGr$r)%rsз__version__r?r0r╗rfrrrrCrз__all__r─зextendrr.зSelectSelectorrrrrзlistrбrтr rrrr rrrrr rrrr'r$r"Зr(s`ППvПvПt─П─ ─ ─ ьпппь ─ ─ ─ ь ─ ─ ─ ьпппьпппппь"п"п"п"п"п"П7П7П7─П─7┬2┬vятПLь┤N┌NпJпJпJяKтKпKь ─7┬6░9ятП4ь┤N┌NП3П3П3Я4Т4П4П─7┬9░nя%т%П/ьт,─O─OЮт.─OПkПkПkПkПkЯkТkПkП\@П@П@П@П@░ Я@Т@П@ПF П П П П ░ Я Т П П8─7┬2┬vятПV@ПU@ПU@ПU@ПU@ПU@ЯU@ТU@ПU@ПpCПCПCПCПC┬tЯCТCПCП, П П П П Я Т П П%П%П%П%П%Я%Т%П%ПP─7┬2┬vятП:ь9п9п9п9п9≤<╗я9т9п9ь9п9п9п9п9≤<╗я9т9п9Ю9п9п9п9п9≤╗я9т9п9ь9п9п9п9п9≤╗я9т9п9Ю ─7┬6░9ятП PП(П(П(П(П(≤9Я(Т(П(П(П(П(П(П(≤YЯ(Т(П(ПLпKпKпKпK═Nп4DяKтKпKЮOпOпOпOпO═nп6HяOтOпOП# П# П# П# П# Я# Т# П# П\+П+П+П+П+п-Я+Т+П+ПZ#П#П#П#П#░NЯ#Т#П#П&GПGПGПGПGп/ЯGТGПGПGПGr$