>a.dZddlZddlmZddlmZddlZddlmZddl Z ddl m Z m Z ddl Z ddlZddlmZddlmZmZmZmZdd lmZmZdd lmZdd lmZmZdd lmZm Z dd l!m"Z"ddl#m$Z$ddl%m&Z&m'Z'm(Z(gdZ)GddZ*dZ+dZ,GddZ-Gdde-Z.GddeZ/dZ0d&de j fd Z1 d'de.fd#Z2e3d$kre2Z4e5d%e4j6dSdS)(z'Synchronous IO wrappers around jeepney N)deque) ECONNRESET)count)DefaultSelector EVENT_READ)Optional)ParserMessage MessageType HeaderFields) AuthenticatorBEGIN)get_bus)FileDescriptor fds_buf_size) ProxyBase unwrap_msg)Router) message_bus)MessageFilters FilterHandlecheck_replyable)open_dbus_connectionDBusConnectionProxyc,eZdZdZdZdZdZdZdS)_Futurecd|_dSN_resultselfs 3lib/python3.11/site-packages/jeepney/io/blocking.py__init__z_Future.__init__s  c*t|jSr )boolr"r#s r%donez _Future.done"sDL!!!r'cd|f|_dSNFr!)r$ exceptions r% set_exceptionz_Future.set_exception%sy) r'cd|f|_dS)NTr!)r$results r% set_resultz_Future.set_result(sf~ r'c"|j\}}|r|S|r r!)r$successvalues r%r0z_Future.result+s  L r'N)__name__ __module__ __qualname__r&r*r.r1r0r'r%rrs_"""***&&&r'rc6|tj|zSdSr )time monotonictimeouts r%timeout_to_deadliner>2s ~')) 4r'cR|$t|tjz dSdS)Ng)maxr:r;)deadlines r%deadline_to_timeoutrB7s*8dn...333 4r'ceZdZdZddejfdZdZdZdede e e j ffd Z d Z d Zdd ZdZdZd S)DBusConnectionBasez8Connection machinery shared by this module and threadingFsockc||_||_t|_t d|_t |_|j|t|_ d|_ dS)Nr)start) rE enable_fdsr parserroutgoing_serialrselectorregisterr select_key unique_name)r$rErHs r%r&zDBusConnectionBase.__init__?s_ $hh $1~~~')) -00zBBr'c|Sr r8r#s r% __enter__zDBusConnectionBase.__enter__Hs r'c.|dSr,)close)r$exc_typeexc_valexc_tbs r%__exit__zDBusConnectionBase.__exit__Ks ur'messagereturnc|t|j}|jrtjdnd}|||}||fS)Ni)serialfds)nextrJrHarray serialise)r$rWr[r\datas r% _serialisezDBusConnectionBase._serialiseOsT >$.//F"&/;ek#t  C 88Syr'c|j|gtjtj|fg}|t |kr$|j||ddSdSr )rEsendmsgsocket SOL_SOCKET SCM_RIGHTSlensendall)r$r`r\ bytes_sents r%_send_with_fdsz!DBusConnectionBase._send_with_fdsVspY&& Ff'):C@A  D ! ! I  d:;;/ 0 0 0 0 0 " !r'c |j}||S|t|\}}|j||`)NTr<)r\)rIget_next_message_read_some_datarBadd_data)r$rAmsgbr\s r%_receivezDBusConnectionBase._receive_sg -+..00C ))2Eh2O2O)PPFAs K  , , ,  -r'Nc|j|D]X\}}||jkrH|jr|cSt |jdgfcSYt)Ni) rKselectrMrH_read_with_fds unwrap_readrErecv TimeoutError)r$r=keyevs r%rmz"DBusConnectionBase._read_some_datahs}++G44 A AGCdo%%?A..00000&ty~~d';';<S6T111---GGGr'rDceZdZddejffd ZddefdZeZdddefd Zddd Z ddd d Z dd dde e fdZ dddefdZxZS)rFrEc2t||d|_tt|_t |_tt||_ |j }|d|_ dS)NFr) superr& _unwrap_replyrrrouterr_filtersrr bus_proxyHellorN)r$rErH hello_reply __class__s r%r&zDBusConnection.__init__sy z***"Woo &(( {D11n**,, &q>r'NrWc|||\}}|r|||dS|j|dS)z.Serialise and send a :class:`~.Message` objectN)rarjrErh)r$rWr[r`r\s r%sendzDBusConnection.sendsYOOGV44 c  $   c * * * * * I  d # # # # #r'r<rXcF|t|S)a+Return the next available message from the connection If the data is ready, this will return immediately, even if timeout<=0. Otherwise, it will wait for up to timeout seconds, or indefinitely if timeout is None. If no message comes in time, it raises TimeoutError. )rqr>)r$r=s r%receivezDBusConnection.receives}}099:::r'c||}|j||j|D]}|j|dS)z\Receive one message and apply filters See :meth:`filter`. Returns nothing. r<N)rrincomingrmatchesqueueappend)r$r=rofilters r% recv_messageszDBusConnection.recv_messagesso ll7l++ S!!!m++C00 % %F L   $ $ $ $ % %r'r=unwrapct|t|}||j}t|j}||| |t|}|jj tj d}||kr|rt|S|S|j||j|D]}|j|)zSend a message, wait for the reply and return it Filters are applied to other messages received before the reply - see :meth:`add_filter`. N)r[Tr<)rr>rr]rJ send_messagerrBheaderfieldsgetr reply_serialrrrrrrr) r$rWr=rrAr[msg_inreply_tors r%send_and_get_replyz!DBusConnection.send_and_get_replys    &w// >'Fd*++ '&111 ,\\*=h*G*G\HHF}+// 0I2NNH6!!.%f---  K  ( ( (-//77 , , ##F++++ ,r'r)rbufsizercR|t|}t|j||S)aCreate a filter for incoming messages Usage:: with conn.filter(rule) as matches: # matches is a deque containing matched messages matching_msg = conn.recv_until_filtered(matches) :param jeepney.MatchRule rule: Catch messages matching this rule :param collections.deque queue: Matched messages will be added to this :param int bufsize: If no deque is passed in, create one with this size N)maxlen)rrr)r$rulerrs r%rzDBusConnection.filters- =)))EDM4777r'ct|}t|dkr6|t|t|dk6|S)aZProcess incoming messages until one is filtered into queue Pops the message from queue and returns it, or raises TimeoutError if the optional timeout expires. Without a timeout, this is equivalent to:: while len(queue) == 0: conn.recv_messages() return queue.popleft() In the other I/O modules, there is no need for this, because messages are placed in queues by a separate task. :param collections.deque queue: A deque connected by :meth:`filter` :param float timeout: Maximum time to wait in seconds rr<)r>rgrrBpopleft)r$rr=rAs r%recv_until_filteredz"DBusConnection.recv_until_filtereds_ 'w//%jjAoo   ':8'D'D  E E E%jjAoo}}r'rr )r5r6r7rdr&r rrrrrrrrr __classcell__rs@r%rrs2 * *V] * * * * * *$$G$$$$L!%;;;';;;;(,%%%%%6:$,,,,,67;A888Xe_8888"59Wr'rc4eZdZdZddfd ZdZdZxZS)rajA blocking proxy for calling D-Bus methods You can call methods on the proxy object, such as ``bus_proxy.Hello()`` to make a method call over D-Bus and wait for a reply. It will either return a tuple of returned data, or raise :exc:`.DBusErrorResponse`. The methods available are defined by the message generator you wrap. You can set a time limit on a call by passing ``_timeout=`` in the method call, or set a default when creating the proxy. The ``_timeout`` argument is not passed to the message generator. All timeouts are in seconds, and :exc:`TimeoutErrror` is raised if it expires before a reply arrives. :param msggen: A message generator object :param ~blocking.DBusConnection connection: Connection to send and receive messages :param float timeout: Default seconds to wait for a reply, or None for no limit Nr<cft|||_||_dSr )rr& _connection_timeout)r$msggen connectionr=rs r%r&zProxy.__init__s.    % r'cR|jdn d|j}d|jd|j|dS)Nz , timeout=zProxy(z, ))r_msggenr)r$extras r%__repr__zProxy.__repr__s@},3O 3O3OB BB(8B%BBBBr'cJtjfd}|S)Nc|dj}|i|}|jjtjusJj||dS)NrTr)poprr message_typer method_callrr)argskwargsr=romake_msgr$s r%innerz!Proxy._method_call..inner sljjT];;G(D+F++C:*k.EEEEE#66WT7 r') functoolswraps)r$rrs`` r% _method_callzProxy._method_calls>  " "      # "  r')r5r6r7rr&rrrrs@r%rrsr"7;       CCC       r'rcb|s,tttjt|S)zRaise ConnectionResetError from an empty read. Sometimes the socket raises an error itself, sometimes it gives no data. I haven't worked out when it behaves each way. )ConnectionResetErrorrosstrerror)rps r%rurus, H":r{:/F/FGGG Hr'F@rXc Dtjtjt|fd} |j|t |}|D]D}|j||t|jdE|jtnT#tj $r-} td|d|d}~w xYw dS)z=Create a socket and authenticate ready to send D-Bus messages)familycRt||Sr ) settimeoutrB)methrrArEs r%with_sock_deadlinez'prep_socket..with_sock_deadline(s* +H55666tT{r')rHizDid not authenticate in z secondsN)rdAF_UNIXr>connectr rhfeedrurvrr=rRrwr) addrrHr=rauthrreq_dataerArEs @@r% prep_socketr sN = / / /D #7++H 4<...444 I IH  t|X 6 6 6 JJ{#5#5di#F#FGG H H H H4<//// >PPP GgGGGHHaO  OOD KsA>B77D(C..DSESSION?cht|}t|||}t||}|S)aConnect to a D-Bus message bus Pass ``enable_fds=True`` to allow sending & receiving file descriptors. An error will be raised if the bus does not allow this. For simplicity, it's advisable to leave this disabled unless you need it. D-Bus has an authentication step before sending or receiving messages. This takes < 1 ms in normal operation, but there is a timeout so that client code won't get stuck if the server doesn't reply. *auth_timeout* configures this timeout in seconds. r<)rrr)busrH auth_timeoutbus_addrrEconns r%rr>s7s||H x\ B B BD $ + +D Kr'__main__z Unique name:)Fr)rFr)7rr^ collectionsrerrnorr itertoolsrr selectorsrrrdr:typingrjeepneyr r r r jeepney.authr r jeepney.busr jeepney.fdsrrjeepney.wrappersrrjeepney.routingrjeepney.bus_messagesrcommonrrr__all__rr>rBrDrrrurrr5rprintrNr8r'r%rs  11111111 >>>>>>>>>>>>--------4444444422222222"""""",,,,,,AAAAAAAAAA   (  @@@@@@@@Fjjjjj'jjjZ%%%%%I%%%P    >79* z   ! !D E.$*+++++r'