+
    TŎi
.                        ^ RI t ^ RIt^ RIt^ RIt^ RIHtHt ^ RIHtH	t	H
t
HtHt ^ RIHt ^RIHt ^RIHt ^RIHt ]'       d   ^ RIHt M ^ RIHt Rt ! R R]4      tR R lt ! R R	]4      t ! R R
]4      t ! R R]4      t ! R R]4      t  ! R R]4      t! ! R R]4      t" ! R R]"4      t# ! R R]"4      t$R#   ] d    ]t Lxi ; i)    N)ABCabstractmethod)TYPE_CHECKINGAnyListOptionalSet)URL)PathLikeApplicationServer)
SSLContextBaseSiteTCPSiteUnixSiteNamedPipeSiteSockSite
BaseRunner	AppRunnerServerRunnerGracefulExitc                       ] tR t^#t^tRtR# )r    N)__name__
__module____qualname____firstlineno__code__static_attributes__r       a/Users/ahmad/.openclaw/workspace/scripts/.venv/lib/python3.14/site-packages/aiohttp/web_runner.pyr   r   #   s    Dr"   c                    V ^8  d   QhRR/#    returnNr   )formats   "r#   __annotate__r)   '   s      d r"   c                      \        4       hN)r   r   r"   r#   _raise_graceful_exitr,   '   s
    
.r"   c                      a  ] tR t^+t o RtRRRRR^/V 3R lR llt]]V 3R lR	 l4       4       t]V 3R
 lR l4       t	V 3R lR lt
RtV tR# )r   shutdown_timeout      N@ssl_contextNbacklogc          
      D   < V ^8  d   QhRRRS[ RS[S[,          RS[RR/# )r&   runnerr   r.   r0   r1   r'   N)floatr   r   int)r(   __classdict__s   "r#   r)   BaseSite.__annotate__.   sB     > >>  	>
 j)> > 
>r"   c                   VP                   f   \        R4      hVR8w  d&   Rp\        P                  ! V\        ^R7       W!n        Wn        W0n        W@n        R V n	        R # )Nz(Call runner.setup() before making a siter/   z,shutdown_timeout should be set on BaseRunner)
stacklevel)
serverRuntimeErrorwarningswarnDeprecationWarning_shutdown_timeout_runner_ssl_context_backlog_server)selfr3   r.   r0   r1   msgs   &&$$$ r#   __init__BaseSite.__init__.   sU     == IJJt#@CMM#1a@'7$'9=r"   c                    < V ^8  d   QhRS[ /# r&   r'   str)r(   r6   s   "r#   r)   r7   C   s      c r"   c                    R # r+   r   rD   s   &r#   nameBaseSite.nameA   s     	r"   c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r7   G   s     % %T %r"   c                D   "   V P                   P                  V 4       R # 5ir+   )r@   	_reg_siterM   s   &r#   startBaseSite.startF   s     t$s    c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r7   J   s     ' 'D 'r"   c                   "   V P                   P                  V 4       V P                  e   V P                  P                  4        V P                   P	                  V 4       R # 5ir+   )r@   _check_siterC   close_unreg_siterM   s   &r#   stopBaseSite.stopJ   sC       &<<#LL   &s   A!A#)rB   r@   rC   rA   )r@   rA   rB   rC   )r   r   r   r   	__slots__rF   propertyr   rN   rS   rZ   r!   __classdictcell__r6   s   @r#   r   r   +   sl     BI> #'	>
 -1> > >&    % %' 'r"   c                      a a ] tR t^Rt oRtRRRRRR^RRRR/V3R lV 3R	 llllt]V3R
 lR l4       tV3R lV 3R lltRt	Vt
V ;t# )r   Nr.   r/   r0   r1   reuse_address
reuse_portc                   < V ^8  d   QhRRRS[ S[,          RS[ S[,          RS[RS[ S[,          RS[RS[ S[,          R	S[ S[,          R
R/	# )r&   r3   r   hostportr.   r0   r1   ra   rb   r'   N)r   rK   r5   r4   r   bool)r(   r6   s   "r#   r)   TCPSite.__annotate__U   sz     & && sm& sm	&  & j)& &  ~& TN& 
&r"   c                  < \         S	V `  VVVVR 7       W n        Vf   V P                  '       d   RMRpW0n        Wpn        Wn        R# )r.   r0   r1   Ni   i  )superrF   _hostrA   _port_reuse_address_reuse_port)
rD   r3   rd   re   r.   r0   r1   ra   rb   	__class__s
   &&&&$$$$$r#   rF   TCPSite.__init__U   sR     	-#	 	 	
 
<,,,4$D
+%r"   c                    < V ^8  d   QhRS[ /# rI   rJ   )r(   r6   s   "r#   r)   rg   o   s     I Ic Ir"   c                    V P                   '       d   R MRpV P                  '       g   RMV P                  p\        \        P                  ! WV P
                  R7      4      # )httpshttpz0.0.0.0schemerd   re   )rA   rk   rK   r
   buildrl   )rD   rv   rd   s   &  r#   rN   TCPSite.namen   sA     ---6 $


y

399FDJJGHHr"   c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   rg   t   s     
 
T 
r"   c           
     h  <"   \         SV `  4       G R j  xL
  \        P                  ! 4       pV P                  P
                  pVf   Q hVP                  VV P                  V P                  V P                  V P                  V P                  V P                  R7      G R j  xL
 V n        R #  L L5i)N)sslr1   ra   rb   )rj   rS   asyncioget_event_loopr@   r:   create_serverrk   rl   rA   rB   rm   rn   rC   rD   loopr:   ro   s   &  r#   rS   TCPSite.startt   s     gmo%%'$$!!!!//JJJJ!!MM--'' 0 
 
	 	
s"   B2B.BB2"B0#B20B2)rk   rl   rm   rn   rC   )rk   rl   rm   rn   )NNr   r   r   r   r\   rF   r]   rN   rS   r!   r^   __classcell__ro   r6   s   @@r#   r   r   R   sk     CI& #'& -1& & )-& &*& &2 I I

 
 
r"   c                      a a ] tR t^t oRtRRRRR^/V3R lV 3R lllt]V3R lR	 l4       tV3R
 lV 3R lltRt	Vt
V ;t# )r   r.   r/   r0   Nr1   c                J   < V ^8  d   QhRRRS[ RS[RS[S[,          RS[RR/# )	r&   r3   r   pathr.   r0   r1   r'   N)r   r4   r   r   r5   )r(   r6   s   "r#   r)   UnixSite.__annotate__   sL       
   j)  
r"   c               :   < \         SV `  VVVVR 7       W n        R# )ri   N)rj   rF   _path)rD   r3   r   r.   r0   r1   ro   s   &&&$$$r#   rF   UnixSite.__init__   s*     	-#	 	 	
 
r"   c                    < V ^8  d   QhRS[ /# rI   rJ   )r(   r6   s   "r#   r)   r      s     0 0c 0r"   c                R    V P                   '       d   R MRpV RV P                   R2# )rs   rt   ://unix::)rA   r   )rD   rv   s   & r#   rN   UnixSite.name   s+     ---6$**Q//r"   c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r      s     

 

T 

r"   c                &  <"   \         SV `  4       G R j  xL
  \        P                  ! 4       pV P                  P
                  pVf   Q hVP                  VV P                  V P                  V P                  R7      G R j  xL
 V n
        R #  Lw L5i)N)r{   r1   )rj   rS   r|   r}   r@   r:   create_unix_serverr   rA   rB   rC   r   s   &  r#   rS   UnixSite.start   s~     gmo%%'$$!!!!44JJ!!MM	 5 
 
	 	
s"   BBA+BBBBr   rC   r   r   r   s   @@r#   r   r      sU     I
 #' -1  " 0 0

 

 

r"   c                   ~   a a ] tR t^t oR
tRR/V3R lV 3R lllt]V3R lR l4       tV3R lV 3R lltR	t	Vt
V ;t# )r   r.   r/   c                .   < V ^8  d   QhRRRS[ RS[RR/# )r&   r3   r   r   r.   r'   N)rK   r4   )r(   r6   s   "r#   r)   NamedPipeSite.__annotate__   s-      "*-DI	r"   c                  < \         P                  ! 4       p\        V\         P                  4      '       g   \	        R 4      h\
        SV `  WR7       W n        R# )z9Named Pipes only available in proactor loop under windows)r.   N)r|   r}   
isinstanceProactorEventLoopr;   rj   rF   r   )rD   r3   r   r.   r   ro   s   &&&$ r#   rF   NamedPipeSite.__init__   sT     %%''++
 
 K  	C
r"   c                    < V ^8  d   QhRS[ /# rI   rJ   )r(   r6   s   "r#   r)   r            c r"   c                    V P                   # r+   r   rM   s   &r#   rN   NamedPipeSite.name       zzr"   c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r      s     " "T "r"   c                  <"   \         SV `  4       G R j  xL
  \        P                  ! 4       pV P                  P
                  pVf   Q hVP                  W P                  4      G R j  xL
 pV^ ,          V n        R #  Lh L5ir+   )	rj   rS   r|   r}   r@   r:   start_serving_piper   rC   )rD   r   r:   rC   ro   s   &   r#   rS   NamedPipeSite.start   sq     gmo%%'$$!!!//JJ
 
 qz 	
s"   BA>AB)B *B Br   r   r   r   s   @@r#   r   r      s?     ILP   " " "r"   c                      a a ] tR t^t oRtRRRRR^/V3R lV 3R lllt]V3R lR	 l4       tV3R
 lV 3R lltRt	Vt
V ;t# )r   r.   r/   r0   Nr1   c                ^   < V ^8  d   QhRRRS[ P                   RS[RS[S[,          RS[RR/# )	r&   r3   r   sockr.   r0   r1   r'   N)socketr4   r   r   r5   )r(   r6   s   "r#   r)   SockSite.__annotate__   sP       mm
   j)  
r"   c               ~  < \         S
V `  VVVVR 7       W n        V P                  '       d   RMRp\	        \
        R4      '       d7   VP                  \
        P                  8X  d   V RVP                  4        R2pM:VP                  4       R,          w  r\        \        P                  ! WhV	R7      4      pWpn        R# )	ri   rs   rt   AF_UNIXr   r   :Nr&   Nru   N)rj   rF   _sockrA   hasattrr   familyr   getsocknamerK   r
   rw   _name)rD   r3   r   r.   r0   r1   rv   rN   rd   re   ro   s   &&&$$$    r#   rF   SockSite.__init__   s     	-#	 	 	
 
 ---669%%$++*GXXd&6&6&8%9;D))+B/JDsyyEFD
r"   c                    < V ^8  d   QhRS[ /# rI   rJ   )r(   r6   s   "r#   r)   r      r   r"   c                    V P                   # r+   )r   rM   s   &r#   rN   SockSite.name   r   r"   c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r      s     
 
T 
r"   c                $  <"   \         SV `  4       G R j  xL
  \        P                  ! 4       pV P                  P
                  pVf   Q hVP                  W P                  V P                  V P                  R7      G R j  xL
 V n
        R #  Lv L5i)N)r   r{   r1   )rj   rS   r|   r}   r@   r:   r~   r   rA   rB   rC   r   s   &  r#   rS   SockSite.start   sy     gmo%%'$$!!!!//):):DMM 0 
 
	 	
s"   BBA*B BBB)r   rC   r   )r   r   r   r   s   @@r#   r   r      sU     "I
 #' -1  0  
 
 
r"   c                   D  a  ] tR t^t o RtRRRR/V 3R lR llt]V 3R lR l4       t]V 3R	 lR
 l4       t]V 3R lR l4       t	V 3R lR lt
]V 3R lR l4       tV 3R lR lt]V 3R lR l4       t]V 3R lR l4       tV 3R lR ltV 3R lR ltV 3R lR ltRtV tR# ) r   handle_signalsFr.   r/   c                0   < V ^8  d   QhRS[ RS[RS[RR/# )r&   r   r.   kwargsr'   N)rf   r4   r   )r(   r6   s   "r#   r)   BaseRunner.__annotate__   s5     2 2 2  	2
 2 
2r"   c               F    Wn         W0n        R V n        . V n        W n        R # r+   _handle_signals_kwargsrC   _sitesr?   )rD   r   r.   r   s   &$$,r#   rF   BaseRunner.__init__   s#      .)-&(!1r"   c                0   < V ^8  d   QhRS[ S[,          /# rI   )r   r   )r(   r6   s   "r#   r)   r     s      ( r"   c                    V P                   # r+   )rC   rM   s   &r#   r:   BaseRunner.server  s    ||r"   c                0   < V ^8  d   QhRS[ S[,          /# rI   )r   r   )r(   r6   s   "r#   r)   r     s     	 	49 	r"   c                    . pV P                    FO  pVP                  pVf   K  VP                  pVf   K'  V F"  pVP                  VP	                  4       4       K$  	  KQ  	  V# r+   )r   rC   socketsappendr   )rD   retsiter:   r   r   s   &     r#   	addressesBaseRunner.addresses  sY    KKD\\F! ..& '

4#3#3#56 !(   
r"   c                0   < V ^8  d   QhRS[ S[,          /# rI   )r	   r   )r(   r6   s   "r#   r)   r     s        s8}  r"   c                ,    \        V P                  4      # r+   )setr   rM   s   &r#   sitesBaseRunner.sites  s    4;;r"   c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r     s     1 1T 1r"   c                N  "   \         P                  ! 4       pV P                  '       dJ    VP                  \        P
                  \        4       VP                  \        P                  \        4       V P                  4       G R j  xL
 V n
        R #   \         d     L,i ; i L5ir+   )r|   r}   r   add_signal_handlersignalSIGINTr,   SIGTERMNotImplementedError_make_serverrC   rD   r   s   & r#   setupBaseRunner.setup  s|     %%'''7KL''8LM
 "..00	 '  1s5   (B%AB 3B%B#B%B B%B  B%c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r   $  s     G G Gr"   c                   "   R# 5i)z8Call any shutdown hooks to help server close gracefully.Nr   rM   s   &r#   shutdownBaseRunner.shutdown#  s        c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r   '  s      t r"   c                  "   \        V P                  4       F  pVP                  4       G R j  xL
  K  	  V P                  '       d~   \        P
                  ! ^ 4      G R j  xL
  V P                  P                  4        V P                  4       G R j  xL
  V P                  P                  V P                  4      G R j  xL
  V P                  4       G R j  xL
  R V n        V P                  '       dW   \        P                  ! 4       p VP                  \        P                  4       VP                  \        P                  4       R # R #  EL! L L L L~  \          d     R # i ; i5ir+   )listr   rZ   rC   r|   sleeppre_shutdownr   r?   _cleanup_serverr   get_running_loopremove_signal_handlerr   r   r   r   )rD   r   r   s   &  r#   cleanupBaseRunner.cleanup'  s    
 %D))+ & <<< --"""LL%%'--/!!,,''(>(>???""$$$++-D**6==9**6>>:	   
 #!?$ ' s   ,E,EE,	E,"E#1E,E,E,EE,EE,7E,>E E,E,E,E,E,E)%E,(E))E,c                    < V ^8  d   QhRS[ /# rI   r   )r(   r6   s   "r#   r)   r   C  s      F r"   c                   "   R # 5ir+   r   rM   s   &r#   r   BaseRunner._make_serverB       r   c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r   G        t r"   c                   "   R # 5ir+   r   rM   s   &r#   r   BaseRunner._cleanup_serverF  r   r   c                $   < V ^8  d   QhRS[ RR/# r&   r   r'   Nr   )r(   r6   s   "r#   r)   r   J  s     ! !h !4 !r"   c                ~    WP                   9   d   \        R V RV  24      hV P                   P                  V4       R# )Site z! is already registered in runner N)r   r;   r   rD   r   s   &&r#   rR   BaseRunner._reg_siteJ  s7    ;;tf,MdVTUU4 r"   c                $   < V ^8  d   QhRS[ RR/# r   r   )r(   r6   s   "r#   r)   r   O  s     R R RT Rr"   c                H    WP                   9  d   \        R V RV  24      hR# r   z is not registered in runner N)r   r;   r   s   &&r#   rW   BaseRunner._check_siteO  s*    {{"tf,I$PQQ #r"   c                $   < V ^8  d   QhRS[ RR/# r   r   )r(   r6   s   "r#   r)   r   S  s     ! ! !T !r"   c                ~    WP                   9  d   \        R V RV  24      hV P                   P                  V4       R# r   )r   r;   remover   s   &&r#   rY   BaseRunner._unreg_siteS  s7    {{"tf,I$PQQ4 r"   )r   r   rC   r?   r   Nr   )r   r   r   r   r\   rF   r]   r:   r   r   r   r   r   r   r   r   rR   rW   rY   r!   r^   r_   s   @r#   r   r      s     XI2  %2 #'	2 2   	 	    1 1 G G 6    ! !
R R! !r"   c                      a a ] tR tRt oRtRtRR/V3R lV 3R llltV3R lR ltV3R	 lR
 ltV3R lR lt	Rt
VtV ;t# )r   iY  zLow-level web server runnerr   Fc                0   < V ^8  d   QhRS[ RS[RS[RR/# )r&   
web_serverr   r   r'   N)r   rf   r   )r(   r6   s   "r#   r)   ServerRunner.__annotate__^  s-     & & &59&MP&	&r"   c               8   < \         SV `  ! RR V/VB  Wn        R# )r   Nr   )rj   rF   _web_server)rD   r  r   r   ro   s   &&$,r#   rF   ServerRunner.__init__^  s      	AA&A%r"   c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r	  d  s       r"   c                   "   R # 5ir+   r   rM   s   &r#   r   ServerRunner.shutdownd       r   c                    < V ^8  d   QhRS[ /# rI   r   )r(   r6   s   "r#   r)   r	  g  s        F  r"   c                "   "   V P                   # 5ir+   r  rM   s   &r#   r   ServerRunner._make_serverg  s     s   c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r	  j  r   r"   c                   "   R # 5ir+   r   rM   s   &r#   r   ServerRunner._cleanup_serverj  r  r   r  )r   r   r   r   __doc__r\   rF   r   r   r   r!   r^   r   r   s   @@r#   r   r   Y  sB     % I&<A& &      r"   c                      a a ] tR tRt oRtRtRR/V3R lV 3R lllt]V3R lR l4       tV3R	 lR
 lt	V3R lR lt
V3R lR ltRtVtV ;t# )r   in  zWeb Application runnerr   Fc                0   < V ^8  d   QhRS[ RS[RS[RR/# )r&   appr   r   r'   N)r   rf   r   )r(   r6   s   "r#   r)   AppRunner.__annotate__s  s-     	 		37	KN			r"   c                  < \         SV `  ! RR V/VB  \        V\        4      '       g   \	        RP                  V4      4      hWn        R# )r   z?The first argument should be web.Application instance, got {!r}Nr   )rj   rF   r   r   	TypeErrorr(   _app)rD   r  r   r   ro   s   &&$,r#   rF   AppRunner.__init__s  sI     	AA&A#{++%%+VC[  	r"   c                    < V ^8  d   QhRS[ /# rI   r   )r(   r6   s   "r#   r)   r    s      [ r"   c                    V P                   # r+   r  rM   s   &r#   r  AppRunner.app~  s    yyr"   c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r    s     # # #r"   c                V   "   V P                   P                  4       G R j  xL
  R #  L5ir+   )r  r   rM   s   &r#   r   AppRunner.shutdown  s     ii  """   )')c                    < V ^8  d   QhRS[ /# rI   r   )r(   r6   s   "r#   r)   r    s     B BF Br"   c                ~  "   \         P                  ! 4       pV P                  P                  V4       V P                  P                  P                  4        V P                  P                  4       G R j  xL
  V P                  P                  4        V P                  P                  ! RRV/V P                  B #  LF5i)Nr   r   )	r|   r}   r  	_set_loop
on_startupfreezestartup_make_handlerr   r   s   & r#   r   AppRunner._make_server  s     %%'		D!		##%ii!!!		yy&&ADADLLAA 	"s   A2B=4B;5AB=c                   < V ^8  d   QhRR/# r%   r   )r(   r6   s   "r#   r)   r    s     " "t "r"   c                V   "   V P                   P                  4       G R j  xL
  R #  L5ir+   )r  r   rM   s   &r#   r   AppRunner._cleanup_server  s     ii!!!r(  r#  )r   r   r   r   r  r\   rF   r]   r  r   r   r   r!   r^   r   r   s   @@r#   r   r   n  sX      I	:?	 	  # #B B" " "r"   )	r   r   r   r   r   r   r   r   r   )%r|   r   r   r<   abcr   r   typingr   r   r   r   r	   yarlr
   typedefsr   web_appr   r  r   r{   r   ImportErrorobject__all__
SystemExitr   r,   r   r   r   r   r   r   r   r   r   r"   r#   <module>r=     s        # : :     "
: $'s $'N/
h /
d#
x #
L"H ">&
x &
Rd! d!N: *!"
 !"w
  
s   C 	CC