
    osj]                    X   d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ d dl	Z
d dlZ
d dlZ
d dlZ
d dlZ
ddlmZ ddlmZmZmZ ddlmZmZmZ ddlmZmZmZ dd	lmZ dd
lm Z  ddl!m"Z"  ejF                  d      Z$ddZ% G d dejL                        Z' G d de"      Z( G d d      Z)y)    )annotationsN)AsyncGenerator   )AsyncNetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError)OriginRequestResponse)	AsyncLockAsyncSemaphoreAsyncShieldCancellation)Trace)safe_async_iterate   )AsyncConnectionInterfacezhttpcore2.http2c                :    t        d | j                  D              S )Nc              3  r   K   | ]/  \  }}|j                         d k(  xs |j                         dk(   1 yw)s   content-length   transfer-encodingN)lower).0k_vs      I/root/.hermes/venv/lib/python3.12/site-packages/httpcore2/_async/http2.py	<genexpr>z#has_body_headers.<locals>.<genexpr>   s7     pW\WXZ\qwwy--R>R1RRps   57)anyheaders)requests    r   has_body_headersr       s    p`g`o`oppp    c                      e Zd ZdZdZdZy)HTTPConnectionStater   r      N)__name__
__module____qualname__ACTIVEIDLECLOSED r!   r   r#   r#      s    FDFr!   r#   c                  Z   e Zd ZdZej
                  j                  d      Z	 d!	 	 	 	 	 d"dZd#dZ	d$dZ
d%dZd%d	Zd&d
Zd%dZd'dZd(dZ	 	 	 	 	 	 d)dZd!d*dZd+dZd,dZd-dZd.dZd$dZd/dZd0dZd1dZd1dZd1dZd1dZd1dZd1dZd2dZ d2dZ!d3dZ"	 	 	 d4	 	 	 	 	 	 	 d5d Z#y)6AsyncHTTP2Connection   F)validate_inbound_headersNc                   || _         || _        || _        t        j                  j                  | j                        | _        t        j                  | _
        d | _        d| _        t               | _        t               | _        t               | _        t               | _        d| _        d| _        d| _        i | _        d | _        d | _        d | _        y )N)configr   F)_origin_network_stream_keepalive_expiryh2
connectionH2ConnectionCONFIG	_h2_stater#   r)   _state
_expire_at_request_countr   
_init_lock_state_lock
_read_lock_write_lock_sent_connection_init_used_all_stream_ids_connection_error_events_connection_terminated_read_exception_write_exception)selforiginstreamkeepalive_expirys       r   __init__zAsyncHTTP2Connection.__init__)   s     %/?334;;3G)..(,#+$;#+$;%*"$)!!&  	 NR#1526r!   c           	       K   | j                  |j                  j                        s/t        d|j                  j                   d| j                         | j
                  4 d {    | j                  t        j                  t        j                  fv r2| xj                  dz  c_
        d | _        t        j                  | _        n
t               d d d       d {    | j                  4 d {    | j                  s	 d|i}t        dt         ||      4 d {     | j"                  di | d {    d d d       d {    d| _        d| _        | j,                  j.                  j0                  }t3        |      | _        t7        || j*                  z
        D ]$  }| j4                  j9                          d {    & d d d       d {    | j4                  j9                          d {    	 | j,                  j;                         }g | j<                  |<   	 ||d}t        dt         ||      4 d {    | jI                  ||       d {    d d d       d {    t        d	t         ||      4 d {    | jK                  ||       d {    d d d       d {    t        d
t         ||      4 d {   }| jM                  ||       d {   \  }	}
|	|
f|_'        d d d       d {    tQ        	
tS        | ||      d| jT                  |d      S 7 7 Y# 1 d {  7  sw Y   jxY w7 ]7 47 7 # 1 d {  7  sw Y   !xY w# t$        $ r@}t'               5  | j)                          d {  7   d d d        |# 1 sw Y   |xY wd }~ww xY w7 7 # 1 d {  7  sw Y   xY w7 # t>        j@                  jB                  $ rJ d| _"        | xj                  dz  c_
        | j4                  jG                          d {  7   t               w xY w7 7 7 # 1 d {  7  sw Y   xY w7 7 7 # 1 d {  7  sw Y   xY w7 7 7 # 1 d {  7  sw Y   xY w# t$        $ r}t'               5  d|i}t        dt         ||      4 d {  7   | jW                  |       d {  7   d d d       d {  7   n# 1 d {  7  sw Y   nxY wd d d        n# 1 sw Y   nxY wtY        |t>        j@                  jZ                        r,| j\                  rt_        | j\                        ta        |      |d }~ww xY ww)NzAttempted to send request to z on connection to r   r   send_connection_initTr   	stream_idsend_request_headerssend_request_bodyreceive_response_headersrP   s   HTTP/2)http_versionnetwork_streamrP   )statusr   content
extensionsrP   response_closedr+   )1can_handle_requesturlrI   RuntimeErrorr2   r>   r:   r#   r(   r)   r<   r;   r   r=   rA   r   logger_send_connection_initBaseExceptionr   aclose_max_streamsr9   local_settingsmax_concurrent_streamsr   _max_streams_semaphorerangeacquireget_next_available_stream_idrD   r5   
exceptionsNoAvailableStreamIDErrorrB   release_send_request_headers_send_request_body_receive_responsereturn_valuer   HTTP2ConnectionByteStreamr3   _response_closed
isinstanceProtocolErrorrE   r	   r   )rH   r   
sci_kwargsexclocal_settings_max_streams_rP   kwargstracerW   r   s              r   handle_async_requestz)AsyncHTTP2Connection.handle_async_requestK   s.    &&w{{'9'9:
 !>w{{?Q?Q>RRdeieqeqdrstt## 	/ 	/{{299;N;S;STT##q(#"&188,..	/ 	/ ?? 	@ 	@--"+W!5J$%;VWjY G G8d88F:FFFG G .2* %&!-1^^-J-J-a-a*.<=W.X+9D<M<MMN @A55==???@)	@ 	@. ))11333	+CCEI&(DLL#*	!(yAF3VWfM W W00I0VVVW W0&'6J T T--g-SSST T7&Q 7 7UZ(,(>(>wZc(>(d"d&,g%6"7 7 1$9U$-&*&:&:!*		 	i	/ 	/ 	/ 	/ 	/	@GFG G G G$ 02 ,"kkm++,I,I @+	@ 	@ 	@ 	@. 	4
 }}55 	+(,D%1$--55777(**		+WVW W W WTST T T T7"d7 7 7 7  	(* E%y1 !2FGVL E E//)/DDDE E E E EE E E
 #r}}::; ..-d.I.IJJ )--I-	s  A%V
'L5(V
+A)L;V
L8 V
4M5V
8OM3 M!M3$M:M;M?M3
MM3A6ON?OV
O!V
9O:V
?)O )R% QR% QQ Q$R% /Q0R% 
Q'R% Q0%Q*&Q0*R% 5Q-6R% RR% R+R	,R<R% R,R% 4V
8V
;MMM		V
M3MM3M0	#M&$M0	+M33	N<<
N7N*N
N* 
N7*N4/N77N<<OV
OOO	V
AQ4P75QV
R% QR% Q$QQ$	R% *Q0-R% 0R6Q97R>	R% 	RR% R"RR"R% %	V.
V8T$S
T$T.S1
/T4T$?T T$TTTT$	V$T-	)AVVV
c           	     V  K   t         j                  j                  dt         j                  j                  j                  dt         j                  j                  j
                  dt         j                  j                  j                  di      | j                  _        | j                  j                  t         j                  j                  j                  = | j                  j                          | j                  j                  d       | j                  |       d{    y7 w)z
        The HTTP/2 connection requires some initial setup before we can start
        using individual request/response streams on it.
        Tr   d   r.   )clientinitial_values   N)r5   settingsSettingsSettingCodesENABLE_PUSHMAX_CONCURRENT_STREAMSMAX_HEADER_LIST_SIZEr9   rc   ENABLE_CONNECT_PROTOCOLinitiate_connectionincrement_flow_control_window_write_outgoing_data)rH   r   s     r   r_   z*AsyncHTTP2Connection._send_connection_init   s      )+(<(< ((44a((??((==u )= 
)
% NN))"++*B*B*Z*Z[**,44U;''000s   DD)!D'"D)c                X  K   t        |       }|j                  D cg c]  \  }}|j                         dk(  s| c}}d   }d|j                  fd|fd|j                  j
                  fd|j                  j                  fg|j                  D cg c])  \  }}|j                         dvr|j                         |f+ c}}z   }| j                  j                  |||       | j                  j                  d	|
       | j                  |       d{    yc c}}w c c}}w 7 w)z@
        Send the request headers to a given stream ID.
           hostr   s   :methods
   :authoritys   :schemes   :path)r   r   )
end_streamr   rT   N)r    r   r   methodr\   schemetargetr9   send_headersr   r   )rH   r   rP   r   r   v	authorityr   s           r   rl   z*AsyncHTTP2Connection._send_request_headers   s     *'22
 $+??K41aaggi76JQKAN	 (I&++,w{{))*	
  
1wwy WWYN

 	##Iw:#N44Ui4P''000' L
 	1s.   D*DDAD*.D"AD*D(D*c                  K   t        |      syt        |j                  t        j                        sJ t        |j                        4 d{   }|2 3 d{   }| j                  |||       d{    %7 +7 "7 	6 ddd      d{  7   n# 1 d{  7  sw Y   nxY w| j                  ||       d{  7   yw)zP
        Iterate over the request body sending it to a given stream ID.
        N)r    rr   rJ   typingAsyncIterabler   _send_stream_data_send_end_stream)rH   r   rP   iteratorchunks        r   rm   z'AsyncHTTP2Connection._send_request_body   s       ('..&*>*>???%gnn5 	H 	H' H He,,WiGGG	HHG  (	H 	H 	H 	H 	H ##GY777s   ACA:CBB A<B B4A>5B:C<B >B BCBCB%BB%!C=C >Cc                   K   |rr| j                  ||       d{   }t        t        |      |      }|d| ||d }}| j                  j	                  ||       | j                  |       d{    |rqyy7 ]7 w)zI
        Send a single chunk of data in one or more data frames.
        N)_wait_for_outgoing_flowminlenr9   	send_datar   )rH   r   rP   datamax_flow
chunk_sizer   s          r   r   z&AsyncHTTP2Connection._send_stream_data   s}      !99'9MMHSY1J{
+T*+->4ENN$$Y6++G444 M 5s(   A<A8AA<.A:/A<6A<:A<c                x   K   | j                   j                  |       | j                  |       d{    y7 w)z`
        Send an empty data frame on on a given stream ID with the END_STREAM flag set.
        N)r9   r   r   )rH   r   rP   s      r   r   z%AsyncHTTP2Connection._send_end_stream   s.      	!!),''000s   0:8:c                r  K   	 | j                  ||       d{   }t        |t        j                  j                        rn@d}g }|j
                  J |j
                  D ]L  \  }}|dk(  rt        |j                  dd            }(|j                  d      r:|j                  ||f       N ||fS 7 w)zT
        Return the response status code and headers for a given stream ID.
        N   s   :statusasciiignore)errors   :)
_receive_stream_eventrr   r5   eventsResponseReceivedr   intdecode
startswithappend)rH   r   rP   eventstatus_coder   r   r   s           r   rn   z&AsyncHTTP2Connection._receive_response	  s      44WiHHE%!;!;< 
 -/}}(((MM 	'DAqJ!!((78("DE\\$'1v&		' W%% Is   B7B5BB7B7c                 K   	 | j                  ||       d{   }t        |t        j                  j                        rm|j
                  J |j                  J |j
                  }| j                  j                  ||       | j                  |       d{    |j                   n%t        |t        j                  j                        ry7 7 <w)z]
        Iterator that returns the bytes of the response body for a given stream ID.
        N)r   rr   r5   r   DataReceivedflow_controlled_lengthr   r9   acknowledge_received_datar   StreamEnded)rH   r   rP   r   amounts        r   _receive_response_bodyz+AsyncHTTP2Connection._receive_response_body  s      44WiHHE%!7!7833???zz---5588K//888jj E299#8#89 H 9s"   CCB CC;CCc                N  K   | j                   j                  |      s6| j                  ||       d{    | j                   j                  |      s6| j                   |   j                  d      }t	        |t
        j                  j                        rt        |      |S 7 ow)z
        Return the next available event for a given stream ID.

        Will read more data from the network if required.
        Nr   )	rD   get_receive_eventspoprr   r5   r   StreamResetr	   )rH   r   rP   r   s       r   r   z*AsyncHTTP2Connection._receive_stream_event-  s      ,,""9-&&w	::: ,,""9-Y'++A.eRYY223%e,,	 ;s   1B%B#B%AB%c           	       K   | j                   4 d{    | j                  S| j                  j                  }|r&|r$||kD  r| xj                  dz  c_        t	               t        | j                        || j                  j                  |      sq| j                  |       d{   }|D ]R  }t        |t        j                  j                        rKt        dt        |      4 d{   }| j                  |       d{    ||_        ddd      d{    st        |t        j                  j"                  t        j                  j$                  t        j                  j&                  t        j                  j(                  f      rC|j*                  | j                  v s| j                  |j*                     j-                  |       &t        |t        j                  j.                        sL|| _        U ddd      d{    | j1                  |       d{    y7 7 7 I7 37 # 1 d{  7  sw Y   xY w7 C# 1 d{  7  sw Y   SxY w7 Aw)zp
        Read some data from the network until we see one or more events
        for a given stream ID.
        Nr   receive_remote_settings)r?   rE   last_stream_idr<   r   r	   rD   r   _read_incoming_datarr   r5   r   RemoteSettingsChangedr   r^   _receive_remote_settings_changero   r   r   r   r   rP   r   ConnectionTerminatedr   )rH   r   rP   r   r   r   ry   s          r   r   z$AsyncHTTP2Connection._receive_events<  s    
 ?? #	< #	<**6!%!<!<!K!KI4N''1,'022)$*E*EFF  (8(8(C#77@@# <E!%)H)HI#()BFG#T 7 7X]"&"F"Fu"MMM16E.7 7 7 $II66II22II11II11	 !??dll: LL9@@G#E299+I+IJ6;3'<!#	< #	<J ''000K#	< A7M7 7 7 7%#	< #	< #	< #	<J 	1s   I.H0I.BI)H3*AI-H6
.I1H?H9
H?IH<BI,AI<
II.II.*I,+I.3I6I9H?<I?IIIII.I)I I)%I.c                |  K   |j                   j                  t        j                  j                  j
                        }|rt        |j                  | j                  j                  j                        }|r|| j                  k7  r|| j                  kD  rG| j                  j                          d {    | xj                  dz  c_        || j                  kD  rG|| j                  k  rH| j                  j                          d {    | xj                  dz  c_        || j                  k  rGy y y y y 7 7 0w)Nr   )changed_settingsr   r5   r   r   r   r   	new_valuer9   rc   rd   rb   re   rk   rg   )rH   r   rd   new_max_streamss       r   r   z4AsyncHTTP2Connection._receive_remote_settings_changeh  s    !&!7!7!;!;BKK<T<T<k<k!l!!&00--DDO ?d6G6G#G%(9(9955==???%%*% &(9(99 &(9(9955==???%%*% &(9(99	 $H " @ @s0   B1D<3D84(D<,D<	D:
(D<3D<:D<c                  K   | j                   j                          d {    | j                  4 d {    | j                  |= | j                  r%| j                  s| j                          d {    n| j                  t        j                  k(  ry| j                  smt        j                  | _        | j                  (t        j                         }|| j                  z   | _        | j                  r| j                          d {    d d d       d {    y 7 7 7 7 7 # 1 d {  7  sw Y   y xY wwN)re   rk   r>   rD   rE   ra   r:   r#   r(   r)   r4   time	monotonicr;   rB   )rH   rP   nows      r   rq   z%AsyncHTTP2Connection._response_closedw  s     ))11333## 	( 	(Y'**4<<kkm## 3 : ::4<<166))5..*C&)D,B,B&BDO,,++-''	( 	( 	( 	4	( $ (	( 	( 	( 	(sy   D>DD>D!D>9D)2D#3BD)	D%
D)D>D'D>!D>#D)%D)'D>)D;/D20D;7D>c                   K   | j                   j                          t        j                  | _        | j
                  j                          d {    y 7 wr   )r9   close_connectionr#   r*   r:   r3   ra   rH   s    r   ra   zAsyncHTTP2Connection.aclose  s=      	''))00""))+++s   AAAAc                  K   |j                   j                  di       }|j                  dd       }| j                  | j                  	 | j                  j	                  | j
                  |       d {   }|dk(  rt        d      	 | j                  j                  |      }|S 7 2# t        $ r}|| _        d| _        |d }~ww xY ww)Ntimeoutreadr!   zServer disconnectedT)rY   r   rF   r3   r   READ_NUM_BYTESr	   	ExceptionrC   r9   receive_data)rH   r   timeoutsr   r   ru   r   s          r   r   z(AsyncHTTP2Connection._read_incoming_data  s     %%)))R8,,vt,+&&&	--2243F3FPPDs{)*?@@  )-(C(CD(I% Q  	 $'D %)D"I	s<   AC	
)B( 3B&4B( C	&B( (	C1CCC	c                  K   |j                   j                  di       }|j                  dd       }| j                  4 d {    | j                  j	                         }| j
                  | j
                  	 | j                  j                  ||       d {    d d d       d {    y 7 l7 # t        $ r}|| _        d| _	        |d }~ww xY w7 *# 1 d {  7  sw Y   y xY ww)Nr   writeT)
rY   r   r@   r9   data_to_sendrG   r3   r   r   rC   )rH   r   r   r   r   ru   s         r   r   z)AsyncHTTP2Connection._write_outgoing_data  s     %%)))R8,,w-## 	 	>>668L$$0+++**00wGGG	 	 	 H  ),%)-&		 	 	 	sw   ?C*B.C*3C9B2B0B2C*(C)C*0B22	C;CCCC*C'CC'#C*c                N  K   | j                   j                  |      }| j                   j                  }t        ||      }|dk  r\| j	                  |       d{    | j                   j                  |      }| j                   j                  }t        ||      }|dk  r\|S 7 Iw)a  
        Returns the maximum allowable outgoing flow for a given stream.

        If the allowable flow is zero, then waits on the network until
        WindowUpdated frames have increased the flow rate.
        https://tools.ietf.org/html/rfc7540#section-6.9
        r   N)r9   local_flow_control_windowmax_outbound_frame_sizer   r   )rH   r   rP   
local_flowmax_frame_sizeflows         r   r   z,AsyncHTTP2Connection._wait_for_outgoing_flow  s      ..BB9M
"nnDD:~.ai&&w///AA)LJ!^^CCNz>2D	 ai
 	 0s   AB%B#AB%!B%c                     || j                   k(  S r   )r2   rH   rI   s     r   r[   z'AsyncHTTP2Connection.can_handle_request  s    %%r!   c                $    | j                          S r   )	is_closedr   s    r   is_connectedz!AsyncHTTP2Connection.is_connected  s    >>###r!   c                   | j                   t        j                  k7  xrd | j                   xrU | j                   xrF | j
                  j                  j                  t        j                  j                  j                  k(   S r   )r:   r#   r*   rC   rB   r9   state_machinestater5   r6   ConnectionStater   s    r   is_availablez!AsyncHTTP2Connection.is_available  sq    KK.555 a***a---a ^^11772==;X;X;_;__`		
r!   c                X    t        j                         }| j                  }|d uxr ||kD  S r   )r   r   r;   )rH   r   	expire_ats      r   has_expiredz AsyncHTTP2Connection.has_expired  s-    nn OO	$8y8r!   c                <    | j                   t        j                  k(  S r   )r:   r#   r)   r   s    r   is_idlezAsyncHTTP2Connection.is_idle  s    {{16666r!   c                     y)NTr+   r   s    r   can_multiplexz"AsyncHTTP2Connection.can_multiplex  s    r!   c                <    | j                   t        j                  k(  S r   )r:   r#   r*   r   s    r   r   zAsyncHTTP2Connection.is_closed  s    {{18888r!   c                |    t        | j                        }|d| j                  j                   d| j                   S )Nz
, HTTP/2, , Request Count: )strr2   r:   namer<   r   s     r   infozAsyncHTTP2Connection.info  s:    T\\":dkk&6&6%77HI\I\H]^^r!   c           	         | j                   j                  }t        | j                        }d| d|d| j                  j
                   d| j                   d	S )N<z [z, r   z]>)	__class__r%   r   r2   r:   r   r<   )rH   
class_namerI   s      r   __repr__zAsyncHTTP2Connection.__repr__  sU    ^^,,
T\\":,b
"T[[-=-=,>>OPTPcPcOddfggr!   c                   K   | S wr   r+   r   s    r   
__aenter__zAsyncHTTP2Connection.__aenter__  s     s   c                @   K   | j                          d {    y 7 wr   )ra   )rH   exc_type	exc_value	tracebacks       r   	__aexit__zAsyncHTTP2Connection.__aexit__  s      kkms   r   )rI   r
   rJ   r   rK   zfloat | None)r   r   returnr   )r   r   r  None)r   r   rP   r   r  r  )r   r   rP   r   r   bytesr  r  )r   r   rP   r   r  z%tuple[int, list[tuple[bytes, bytes]]])r   r   rP   r   r  AsyncGenerator[bytes])r   r   rP   r   r  zKh2.events.ResponseReceived | h2.events.DataReceived | h2.events.StreamEnded)r   r   rP   z
int | Noner  r  )r   zh2.events.RemoteSettingsChangedr  r  )rP   r   r  r  r  r  )r   r   r  zlist[h2.events.Event])r   r   rP   r   r  r   )rI   r
   r  bool)r  r	  )r  r   )r  r-   )NNN)r   ztype[BaseException] | Noner  zBaseException | Noner  ztypes.TracebackType | Noner  r  )$r%   r&   r'   r   r5   r1   H2Configurationr8   rL   rz   r_   rl   rm   r   r   rn   r   r   r   r   rq   ra   r   r   r   r[   r   r   r   r   r   r   r   r   r   r  r+   r!   r   r-   r-   %   s   NYY&&&FF *.	 7 7 # 7 '	 7D\|1>1>8	51&( +.	T*1X+(,86(&$
979_h
 04*.04	, ( .	
 
r!   r-   c                  $    e Zd ZddZddZddZy)rp   c                <    || _         || _        || _        d| _        y )NF)_connection_request
_stream_id_closed)rH   r6   r   rP   s       r   rL   z"HTTP2ConnectionByteStream.__init__  s    %#r!   c               r  K   | j                   | j                  d}	 t        dt        | j                   |      4 d {    t	        | j
                  j                  | j                   | j                              4 d {   }|2 3 d {   }| 7 X7 7 6 d d d       d {  7   n# 1 d {  7  sw Y   nxY wd d d       d {  7   y # 1 d {  7  sw Y   y xY w# t        $ r@}t               5  | j                          d {  7   d d d        |# 1 sw Y   |xY wd }~ww xY ww)NrO   receive_response_body)
r  r  r   r^   r   r  r   r`   r   ra   )rH   rx   r   r   ru   s        r   	__aiter__z#HTTP2ConnectionByteStream.__aiter__  s    !]]I	4fdmmVT $ $-$$;;DMM]a]l]l;m $ $'/ $ $e#$$$x$ $ $ $ $$ $ $ $ $  	 )* $kkm##$I$I	s   D7 C+ BC+ ?C BCB/BB
BB/C+ CBB/C(B+)C/C	5B86C	=CC+ CC+ D7C(CC($C+ 'D7(C+ +	D44
D/>D"DD"
D/"D,	'D//D44D7c                L  K   | j                   syd| _         d| j                  i}t        dt        | j                  |      4 d {    | j
                  j                  | j                         d {    d d d       d {    y y 7 D7 7 
# 1 d {  7  sw Y   y xY ww)NTrP   rZ   rT   )r  r  r   r^   r  r  rq   )rH   rx   s     r   ra   z HTTP2ConnectionByteStream.aclose(  s     ||DL!4??3F.vN S S&&77$//7RRRS S S SRS S S SsZ   AB$B	B$*B2B3B7B$BB$BB$B!BB!B$N)r6   r-   r   r   rP   r   r  r  )r  r  r  )r%   r&   r'   rL   r  ra   r+   r!   r   rp   rp     s    "Sr!   rp   )r   r   r  r	  )*
__future__r   enumloggingr   typesr   collections.abcr   	h2.configr5   h2.connection	h2.eventsh2.exceptionsh2.settings_backends.baser   _exceptionsr   r   r	   _modelsr
   r   r   _synchronizationr   r   r   _tracer   _utilsr   
interfacesr   	getLoggerr^   r    IntEnumr#   r-   rp   r+   r!   r   <module>r(     s    "      *      / Y Y / / Q Q  ' 0			,	-q$,, h3 hVS Sr!   