
    k7i4                        S SK r S SKrS SKJrJrJrJr  S SKJrJ	r	  S SK
JrJrJr  SSKJr  \R                   R                   \R                   R#                  \(       + SS9/rS	 r\" S
SSS9rS rS rS rS rS rS rS rg)    N)DBusAddressDBusErrorResponseMessageTypenew_method_call)message_bus	MatchRule)open_dbus_connectionopen_dbus_routerProxy   )have_session_buszTests require DBus session bus)reasonc                     #    [        SS9I S h  vN n U  IS h  vN   U R                  R                  S5      (       d   eS S S 5      IS h  vN   g  NB N9 N	! , IS h  vN  (       d  f       g = f7f)NSESSIONbus:)r	   unique_name
startswith)conns    T/home/james-whalen/.local/lib/python3.13/site-packages/jeepney/io/tests/test_trio.pytest_connectr      sK     %)44Dt**3//// tt 5tttsT   A2A
A2AA2#AA2AA2A2A2A/A!A/+A2zorg.freedesktop.DBusz/org/freedesktop/DBuszorg.freedesktop.DBus.Peer)bus_nameobject_path	interfacec                    #    [        [        S5      n [        SS9 IS h  vN n[        R                  " S5         UR                  U 5      I S h  vN nS S S 5        S S S 5      IS h  vN   WR                  R                  [        R                  :X  d   eUR                  S:X  d   eg  N N[! , (       d  f       N_= f NV! , IS h  vN  (       d  f       Nk= f7f)NPingr   r       )r   bus_peerr
   trio
fail_aftersend_and_get_replyheadermessage_typer   method_returnbody	ping_callreqreplys      r   test_send_and_get_replyr,       s     &1II..#__Q00;;E   /. <<$$(A(AAAA:: /;   /...sn   CB*CCB.B,B.CC(B?)AC,B..
B<	8C?CCC
CCc                    #    [        [        S5      n [        SS9 IS h  vN n[        R                  " S5         UR                  U 5      I S h  vN nS S S 5        S S S 5      IS h  vN   WR                  R                  [        R                  :X  d   eg  Nw NI! , (       d  f       NM= f ND! , IS h  vN  (       d  f       NY= f7f)NSnartr   r   r   )
r   r    r
   r!   r"   r#   r$   r%   r   errorr(   s      r   test_send_and_get_reply_errorr0   *   s     '2II..#__Q00;;E   /. <<$$(9(9999	 /;   /...sm   C	BC	B/BBBB/C	(B-)0C	B
B*	&B/-C	/C5B86CC	c                  >  #    [        SS9 IS h  vN n [        [        U 5      nSnUR                  U5      I S h  vN nUS;   d   eUR	                  U5      I S h  vN u  nUSL d   eS S S 5      IS h  vN   g  Nj NA N" N! , IS h  vN  (       d  f       g = f7f)Nr   r   z+io.gitlab.takluyver.jeepney.examples.Server>   r      T)r
   r   r   RequestNameNameHasOwner)r*   proxynameres	has_owners        r   
test_proxyr;   3   s     I..#k3'<%%d++l""" --d33
	D    /.. , 4 /...sf   BA;B'BA= BA?B*B5B6B=B?BBB	B
BBc                  J  #    [        SS9 IS h  vN n [        [        U 5      n[        R                  " [
        5         UR                  S5      I S h  vN   S S S 5        S S S 5      IS h  vN   g  Na N! , (       d  f       N#= f N! , IS h  vN  (       d  f       g = f7f)Nr   r   z:123)r
   r   r   pytestraisesr   r5   )r*   r7   s     r   test_proxy_errorr?   >   sk     I..#k3']],-##F+++ . /.. , .- /...sm   B#A2B#+B	A6A4A6B	!B#,B-B#4A66
B	 B	B#	B BB B#c            	      &  #    Sn [        SS9 IS h  vN n[        [        U5      n[        S[        R                  [        R
                  S[        R                  S9nUR                  SU 5        UR                  U5      I S h  vN   UR                  U5       IS h  vN nUR                  U 5      I S h  vN u  nUS:X  d   e[        R                  " S	5         UR                  5       I S h  vN nS S S 5        WR                  U S
UR                  4:X  d   eS S S 5      IS h  vN   S S S 5      IS h  vN   g  GN+ N N N NU! , (       d  f       NY= f N1! , IS h  vN  (       d  f       NF= f N=! , IS h  vN  (       d  f       g = f7f)Nz2io.gitlab.takluyver.jeepney.tests.trio_test_filterr   r   signalNameOwnerChanged)typesenderr   memberpathr   r   g       @ )r
   r   r   r   r   r   r   add_arg_conditionAddMatchfilterr5   r!   r"   receiver'   r   )r8   routerr   
match_rulechanr9   
signal_msgs          r   test_filterrP   E   s*    ?DI..&K(''!++%((

 	$$Q- ll:&&&==,,..DC!8O8%#'<<>1
 &??tR1C1C&DDDD -, /.. 	',. 2 &%	 -,,, /...s   FD=FA.E7E E7EE7"E7E8$EE0E
1E5'EE7'E(E7,F7E58F E7E7EE
EEE7E2	!E$"E2	.E75F7F=F >F
Fc                 ,  #    [        U S5      n[        R                  " S5         [        SSS9 IS h  vN nUR	                  U5      I S h  vN nS S S 5      IS h  vN   S S S 5        WR
                  R                  [        R                  L d   eUR                  S   R                  S5       nUR                  5       S:X  d   e S S S 5        g  N N Nx! , IS h  vN  (       d  f       N= f! , (       d  f       N= f! , (       d  f       g = f7f)	NGetFDr   r   Tr   
enable_fdsr   zw+readme)r   r!   r"   r
   r#   r$   r%   r   r&   r'   to_fileread)respond_with_fd
getfd_callrL   r+   fs        r   test_recv_fdr[   _   s      ':J		#	dCCv 33J??E DC 
 <<$$(A(AAAA	A		t	$vvx8### 
%	$	 D? DCCC 
	
 
%	$s   #DC2CC2CCCC2CC2"AD1D		DC2CC2C/	C!C/	+C22
D <D
DDc                   #    U u  p#[        USSU45      n[        R                  " S5         [        SSS9 IS h  vN nUR	                  U5      I S h  vN nS S S 5      IS h  vN   S S S 5        WR
                  R                  [        R                  L d   eUR                  S   U:X  d   eg  Nt N] NO! , IS h  vN  (       d  f       Nd= f! , (       d  f       Nm= f7f)NReadFDhr   r   TrS   r   )
r   r!   r"   r
   r#   r$   r%   r   r&   r'   )temp_file_and_contentsread_from_fd	temp_filedatareadfd_callrL   r+   s          r   test_send_fdrd   j   s     ,OI!,#	|LK		#	dCCv 33K@@E DC 
 <<$$(A(AAAA::a=D   	 D@ DCCC 
	st   *C!CB0CB6B2B6C$B4%C)AC!0C2B64C6C	<B?=C		C
CC!)r!   r=   jeepneyr   r   r   r   jeepney.bus_messagesr   r   jeepney.io.trior	   r
   r   utilsr   markskipif
pytestmarkr   r    r,   r0   r;   r?   rP   r[   rd   r       r   <module>rm      s      P P 7  $ KK
KK%E  
0
 #'):!,E4$!rl   