
    k7i
                         S SK r S SKJrJrJr  S SKJrJr  S SKJ	r	J
r
  SSKJr  \ R                  R                  \(       + SS9r\ R                   S	 5       rS
 r\" SSSS9rS rS rS rS rS rg)    N)new_method_callMessageTypeDBusAddress)message_bus	MatchRule)open_dbus_connectionProxy   )have_session_buszTests require DBus session bus)reasonc               #   Z   #    [        SS9 n U v   S S S 5        g ! , (       d  f       g = f7f)NSESSION)bus)r   )conns    X/home/james-whalen/.local/lib/python3.13/site-packages/jeepney/io/tests/test_blocking.pysession_connr      s     	)	,
 
-	,	,s   
+	+
(+c                 H    U R                   R                  S5      (       d   eg )N:)unique_name
startswith)r   s    r   test_connectr      s    ##..s3333    zorg.freedesktop.DBusz/org/freedesktop/DBuszorg.freedesktop.DBus.Peer)bus_nameobject_path	interfacec                     [        [        S5      nU R                  USS9nUR                  R                  [
        R                  :X  d   eUR                  S:X  d   eg )NPing   timeout )r   bus_peersend_and_get_replyheadermessage_typer   method_returnbody)r   	ping_callreplys      r   test_send_and_get_replyr*      sS    &1I++Iq+AE<<$$(A(AAAA::r   c                     [        [        U SS9nSnUR                  U5      nUS;   d   eUR                  USS9u  nUSL d   eg )Nr   r   z+io.gitlab.takluyver.jeepney.examples.Server>   r
         )_timeoutT)r	   r   RequestNameNameHasOwner)r   proxynameres	has_owners        r   
test_proxyr7   !   sX    +|Q7E8D


D
!C,##D1#5JIr   c                    [        [        U 5      nSn[        S[        R                  [        R                  S[        R
                  S9nUR                  SU5        UR                  U5        U R                  U5       nUR                  U5      u  nUS:X  d   eU R                  USS9nUR                  US	U R                  4:X  d   e S S S 5        g ! , (       d  f       g = f)
Nz6io.gitlab.takluyver.jeepney.tests.blocking_test_filtersignalNameOwnerChanged)typesenderr   memberpathr   r
   r.   r    )r	   r   r   r   r   r   add_arg_conditionAddMatchfilterr1   recv_until_filteredr'   r   )r   r   r4   
match_rulematchesr5   
signal_msgs          r   test_filterrG   *   s    
\
*CCD##''!$$J   D) LL			Z	(Gt$axx!55gq5I
4\-E-E"FFFF 
)	(	(s   >AC
C!c                 t   [        U S5      n[        SSS9 nUR                  USS9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 ! , (       d  f       Nv= f! , (       d  f       g = f)
NGetFDr   Tr   
enable_fdsr   r   r   zw+readme)
r   r   r#   r$   r%   r   r&   r'   to_fileread)respond_with_fd
getfd_callr   r)   fs        r   test_recv_fdrR   C   s     ':J	)	=''
A'> 
> <<$$(A(AAAA	A		t	$vvx8### 
%	$	 
>	= 
%	$s   B7B)
B&)
B7c                    U u  p#[        USSU45      n[        SSS9 nUR                  USS9nS S S 5        WR                  R                  [
        R                  L d   eUR                  S   U:X  d   eg ! , (       d  f       NM= f)	NReadFDhr   TrJ   r   r   r   )r   r   r#   r$   r%   r   r&   r'   )temp_file_and_contentsread_from_fd	temp_filedatareadfd_callr   r)   s          r   test_send_fdr[   M   s    ,OI!,#	|LK	)	=''Q'? 
> <<$$(A(AAAA::a=D   	 
>	=s   A66
B)pytestjeepneyr   r   r   jeepney.bus_messagesr   r   jeepney.io.blockingr   r	   utilsr   markskipif
pytestmarkfixturer   r   r"   r*   r7   rG   rR   r[   r!   r   r   <module>re      s     = = 7 ; #[[!A   
  
4 #')G2$!r   