آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ U 'â7`؛+م@s4ddlZddlZddlZddlmZmZddlmZmZm Z m Z ddlmZddl mZddlmZzddlmZWnek rŒeZYnXd ZGd d„deƒZddœd d„ZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZ dS)éN)عABCعabstractmethod)عAnyعListعOptionalعSet)عURLé)عApplication)عServer)ع SSLContext) عBaseSiteعTCPSiteعUnixSiteع NamedPipeSiteعSockSiteع BaseRunnerع AppRunnerعServerRunnerعGracefulExitc@seZdZdZdS)rr N)ع__name__ع __module__ع__qualname__عcode©rrْE/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/web_runner.pyrsr©عreturncCs tƒ‚dS©N)rrrrrع_raise_graceful_exit#src@sjeZdZdZddddœdeeeeddœdd „Ze e ed œdd„ƒƒZe dd œd d„ƒZ dd œdd„ZdS)r )ع_runnerع_shutdown_timeoutع_ssl_contextع_backlogع_serverçN@Né€©عshutdown_timeoutعssl_contextعbacklogr)عrunnerr(r)r*rcCs4|jdkrtdƒ‚||_||_||_||_d|_dS)Nz(Call runner.setup() before making a site)عserverعRuntimeErrorr r!r"r#r$)عselfr+r(r)r*rrrع__init__*s zBaseSite.__init__rcCsdSrr©r.rrrعname:sz BaseSite.namecأs|j |،dSr)r ع _reg_siter0rrrعstart?szBaseSite.startcأsژ|j |،|jdkr&|j |،dS|j ،t|jdƒrL|j ،IdH|j ،IdH|jjsht ‚|jj |j ،IdH|j |،dS)Nعwait_closed)r ع_check_siter$ع_unreg_siteعcloseعhasattrr4عshutdownr,عAssertionErrorr!r0rrrعstopCs z BaseSite.stop)rrrع __slots__عfloatrrعintr/عpropertyrعstrr1r3r;rrrrr 's"ْùr cs~eZdZdZdddddddœdeeeeeeeeee ee ddœ ‡fdd „Z eed œdd„ƒZdd œ‡fd d„Z ‡ZS)r)ع_hostع_portع_reuse_addressع_reuse_portNr%r&)r(r)r*ع reuse_addressع reuse_portr) r+عhostعportr(r)r*rErFrc sFtƒj||||dچ||_|dkr0|jr,dnd}||_||_||_dS)Nr'iû iگ)عsuperr/rAr"rBrCrD) r.r+rGrHr(r)r*rErF©ع __class__rrr/UsüzTCPSite.__init__rcCs8|jr dnd}|jdkrdn|j}ttj|||jdچƒS)Nعhttpsعhttpz0.0.0.0©عschemerGrH)r"rAr@rعbuildrB)r.rOrGrrrr1nszTCPSite.namec ƒs\tƒ ،IdHt ،}|jj}|dk s,t‚|j||j|j |j |j|j|j dچIdH|_dS)N)عsslr*rErF)rIr3عasyncioعget_event_loopr r,r:ع create_serverrArBr"r#rCrDr$©r.عloopr,rJrrr3tsùz TCPSite.start)NN)rrrr<rr@r>r=rعboolr/r?r1r3ع __classcell__rrrJrrRs.üُِrcsbeZdZdZddddœdeeeeeddœ‡fdd „Z e ed œdd„ƒZdd œ‡fd d„Z‡Z S)r©ع_pathr%Nr&r'r)r+عpathr(r)r*rcstƒj||||dچ||_dS)Nr')rIr/rZ)r.r+r[r(r)r*rJrrr/‡s üzUnixSite.__init__rcCs |jr dnd}|›d|j›d‌S)NrLrMْ://unix:ْ:)r"rZ)r.rOrrrr1کsz UnixSite.namecƒsPtƒ ،IdHt ،}|jj}|dk s,t‚|j||j|j |j dچIdH|_dS)N)rQr*)rIr3rRrSr r,r:Zcreate_unix_serverrZr"r#r$rUrJrrr3‌sےzUnixSite.start)rrrr<r@r=rrr>r/r?r1r3rXrrrJrr„sùّrcsVeZdZdZddœdeeddœ‡fdd„Zeed œd d„ƒZdd œ‡fdd „Z ‡Z S)rrYr%©r(rN)r+r[r(rcs6t ،}t|tjƒstdƒ‚tƒj||dچ||_dS)Nz8Named Pipes only available in proactorloop under windowsr^)rRrSع isinstanceZProactorEventLoopr-rIr/rZ)r.r+r[r(rVrJrrr/ھsےzNamedPipeSite.__init__rcCs|jSrrYr0rrrr1µszNamedPipeSite.namecƒsNtƒ ،IdHt ،}|jj}|dk s,t‚| ||j،IdH}|d|_ dS)Nr) rIr3rRrSr r,r:Zstart_serving_piperZr$)r.rVr,r$rJrrr3¹szNamedPipeSite.start)rrrr<r@r=r/r?r1r3rXrrrJrr§sے‏rcsdeZdZdZddddœdejeeeeddœ‡fdd „Z e ed œdd„ƒZdd œ‡fd d„Z ‡ZS)r)ع_sockع_namer%Nr&r'r)r+عsockr(r)r*rc s†tƒj||||dچ||_|jr$dnd}ttdƒrT|jtjkrT|›d| ،›d‌}n(| ،dd…\}} t t j||| dچƒ}||_dS) Nr'rLrMعAF_UNIXr\r]érN) rIr/r`r"r8عsocketعfamilyrcعgetsocknamer@rrPra) r.r+rbr(r)r*rOr1rGrHrJrrr/إs üzSockSite.__init__rcCs|jSr)rar0rrrr1فsz SockSite.namecƒsPtƒ ،IdHt ،}|jj}|dk s,t‚|j||j|j |j dچIdH|_dS)N)rbrQr*)rIr3rRrSr r,r:rTr`r"r#r$rUrJrrr3لsےzSockSite.start)rrrr<rer=rrr>r/r?r@r1r3rXrrrJrrآsùّrc@sىeZdZdZddœeeddœdd„Zeee dœd d „ƒZ eeedœdd„ƒZee edœd d„ƒZddœdd„Zeddœdd„ƒZddœdd„Zee dœdd„ƒZeddœdd„ƒZeddœdd„Zeddœdd„Zeddœdd„ZdS) r©ع_handle_signalsع_kwargsr$ع_sitesF©عhandle_signalsN)rmعkwargsrcKs||_||_d|_g|_dSrrh)r.rmrnrrrr/îszBaseRunner.__init__rcCs|jSr)r$r0rrrr,ôszBaseRunner.servercCsHg}|jD]8}|j}|dk r |j}|dk r |D]}| | ،،q.q |Sr)rkr$عsocketsعappendrg)r.عretعsiter,rorbrrrع addressesّs zBaseRunner.addressescCs t|jƒSr)عsetrkr0rrrعsitesszBaseRunner.sitescأsXt ،}|jrDz | tjt،| tjt،Wntk rBYnX| ،IdH|_ dSr)rRrSriZadd_signal_handlerعsignalعSIGINTrعSIGTERMعNotImplementedErrorع_make_serverr$©r.rVrrrعsetupszBaseRunner.setupcأsdSrrr0rrrr9szBaseRunner.shutdowncأs„t ،}|jdkrdSt|jƒD]}| ،IdHq | ،IdHd|_|jr€z| t j ،| t j،Wntk r~YnXdSr) rRrSr$عlistrkr;ع_cleanup_serverriZremove_signal_handlerrvrwrxry)r.rVrrrrrعcleanups zBaseRunner.cleanupcأsdSrrr0rrrrz0szBaseRunner._make_servercأsdSrrr0rrrr~4szBaseRunner._cleanup_server)rrrcCs.||jkrtd|›d|›‌ƒ‚|j |،dS)NْSite z! is already registered in runner )rkr-rp©r.rrrrrr28s zBaseRunner._reg_sitecCs"||jkrtd|›d|›‌ƒ‚dS©Nr€z is not registered in runner )rkr-rپrrrr5=s zBaseRunner._check_sitecCs.||jkrtd|›d|›‌ƒ‚|j |،dSr‚)rkr-عremoverپrrrr6As zBaseRunner._unreg_site)rrrr<rWrr/r?rrr,rrsrr rur|rr9rrzr~r2r5r6rrrrrës& rcs`eZdZdZdZddœeeeddœ‡fdd„Zdd œd d„Z ed œdd „Z dd œdd„Z‡ZS)rzLow-level web server runner©ع_web_serverFrlN)ع web_serverrmrnrcs tƒjfd|i|—ژ||_dS)Nrm)rIr/r…)r.r†rmrnrJrrr/LszServerRunner.__init__rcأsdSrrr0rrrr9RszServerRunner.shutdowncأs|jSrr„r0rrrrzUszServerRunner._make_servercأsdSrrr0rrrr~XszServerRunner._cleanup_server) rrrع__doc__r<rrWrr/r9rzr~rXrrrJrrGsے‏rcsreZdZdZdZddœeeeddœ‡fdd„Ze ed œd d„ƒZ dd œdd „Zed œdd„Z dd œdd„Z‡ZS)rzWeb Application runner©ع_appFrlN)عapprmrnrcs8tƒjfd|i|—ژt|tƒs.td |،ƒ‚||_dS)Nrmz?The first argument should be web.Application instance, got {!r})rIr/r_r ع TypeErrorعformatr‰)r.rٹrmrnrJrrr/as ےےzAppRunner.__init__rcCs|jSrrˆr0rrrrٹlsz AppRunner.appcأs|j ،IdHdSr)r‰r9r0rrrr9pszAppRunner.shutdowncأsRt ،}|j |،|jj ،|j ،IdH|j ،|jjfd|i|j—ژS)NrV) rRrSr‰Z _set_loopZ on_startupZfreezeZstartupZ _make_handlerrjr{rrrrzss zAppRunner._make_servercأs|j ،IdHdSr)r‰rr0rrrr~|szAppRunner._cleanup_server)rrrr‡r<r rWrr/r?rٹr9rrzr~rXrrrJrr\sے‏ r)!rRrvreعabcrrعtypingrrrrZyarlrZweb_appr r†rrQrعImportErrorعobjectع__all__ع SystemExitrrr rrrrrrrrrrrعs, +2#)\