.Ph.dZddlZddlmZddlmZddlZddlmZddl Z ddl m Z m Z ddl Z ddlZddlmZddlmZmZmZmZdd lmZmZdd lmZdd lmZmZdd lmZm Z dd l!m"Z"ddl#m$Z$m%Z%m&Z&gdZ'GddZ(dZ)dZ*GddZ+Gdde+Z,GddeZ-dZ.d%de j fdZ/ d&de,fd"Z0e1d#kre0Z2e3d$e2j4dSdS)'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) message_bus)MessageFilters FilterHandlecheck_replyable)open_dbus_connectionDBusConnectionProxyc,eZdZdZdZdZdZdZdS)_Futurecd|_dSN_resultselfs S/var/www/html/test/jupyter/venv/lib/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|rr )r#successvalues r$r/z_Future.result*s  L r&N)__name__ __module__ __qualname__r%r)r-r0r/r&r$rrs_"""***&&&r&rc6|tj|zSdSr)time monotonictimeouts r$timeout_to_deadliner=1s ~')) 4r&cR|$t|tjz dSdS)Ng)maxr9r:)deadlines r$deadline_to_timeoutrA6s*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) rD enable_fdsr parserroutgoing_serialrselectorregisterr select_key unique_name)r#rDrGs r$r%zDBusConnectionBase.__init__>s_ $hh $1~~~')) -00zBBr&c|Srr7r"s r$ __enter__zDBusConnectionBase.__enter__Gs r&c.|dSr+)close)r#exc_typeexc_valexc_tbs r$__exit__zDBusConnectionBase.__exit__Js ur&messagereturnc|t|j}|jrtjdnd}|||}||fS)Ni)serialfds)nextrIrGarray serialise)r#rVrZr[datas r$ _serialisezDBusConnectionBase._serialiseNsT >$.//F"&/;ek#t  C 88Syr&c|j|gtjtj|fg}|t |kr$|j||ddSdSr)rDsendmsgsocket SOL_SOCKET SCM_RIGHTSlensendall)r#r_r[ bytes_sents r$_send_with_fdsz!DBusConnectionBase._send_with_fdsUspY&& Ff'):C@A  D ! ! I  d:;;/ 0 0 0 0 0 " !r&c |j}||S|t|\}}|j||`)NTr;)r[)rHget_next_message_read_some_datarAadd_data)r#r@msgbr[s r$_receivezDBusConnectionBase._receive^sg -+..00C ))2Eh2O2O)PPFAs K  , , ,  -r&Nc|j|D]X\}}||jkrH|jr|cSt |jdgfcSYt)Ni) rJselectrLrG_read_with_fds unwrap_readrDrecv TimeoutError)r#r<keyevs r$rlz"DBusConnectionBase._read_some_datags}++G44 A AGCdo%%?A..00000&ty~~d';';<S6T111---GGGr&rCceZdZddejffd ZddefdZeZdddefd Zddd Z ddd Z dd d de e fdZ dddefdZxZS)rFrDct||t|_t t ||_|j}|d|_dS)Nr) superr%r_filtersrr bus_proxyHellorM)r#rDrG hello_reply __class__s r$r%zDBusConnection.__init__sd z***'(( {D11n**,, &q>r&NrVc|||\}}|r|||dS|j|dS)z.Serialise and send a :class:`~.Message` objectN)r`rirDrg)r#rVrZr_r[s r$sendzDBusConnection.sendsYOOGV44 c  $   c * * * * * I  d # # # # #r&r;rWcF|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. )rpr=)r#r<s r$receivezDBusConnection.receives}}099:::r&c||}|j|D]}|j|dS)z\Receive one message and apply filters See :meth:`filter`. Returns nothing. r;N)rrmatchesqueueappend)r#r<rnfilters r$ recv_messageszDBusConnection.recv_messagessY ll7l++m++C00 % %F L   $ $ $ $ % %r&ct|t|}t|j}||| |t |}|jj tj d}||kr|S|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`. )rZTr;)rr=r\rI send_messagerrAheaderfieldsgetr reply_serialrrrr)r#rVr<r@rZmsg_inreply_tors r$send_and_get_replyz!DBusConnection.send_and_get_replys    &w//d*++ '&111 ,\\*=h*G*G\HHF}+// 0I2NNH6!! -//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=rfrrApopleft)r#rr<r@s r$recv_until_filteredz"DBusConnection.recv_until_filtereds_ 'w//%jjAoo   ':8'D'D  E E E%jjAoo}}r&rr)r4r5r6rcr%r rrrrrrrrr __classcell__rs@r$rrs0 * *V] * * * * * *$$G$$$$L!%;;;';;;;(,%%%%%6:,,,,,*7;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|}|jjtjusJt j||S)Nrr;) poprr message_typer method_callrrr)argskwargsr<rnmake_msgr#s r$innerz!Proxy._method_call..innerswjjT];;G(D+F++C:*k.EEEEEd.AAWB r&) functoolswraps)r#rrs`` r$ _method_callzProxy._method_calls>  " "      # "  r&)r4r5r6rr%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)ros r$rtrt s, H":r{:/F/FGGG Hr&F@rWc tjtjt|fd} |j|t |d}t tdr=dgtjtjtdfgn d|D]D}|j || t|jdE|j tnT#tj$r-}t%d |d |d }~wxYwd S) z=Create a socket and authenticate ready to send D-Bus messages)familycRt||Sr) settimeoutrA)methrr@rDs r$with_sock_deadlinez'prep_socket..with_sock_deadlines* +H55666tT{r&F)rG inc_null_byte SCM_CREDSiizDid not authenticate in z secondsN)rcAF_UNIXr=connectr hasattrrbrdrrrrgfeedrtrurr<rQrvr) addrrGr<rauthrreq_dataer@rDs @@r$ prep_socketrs = / / /D #7++H4<...5III 6; ' '  LL%F$5v7Gs#T"U V V V V IIe    I IH  t|X 6 6 6 JJ{#5#5di#F#FGG H H H H4<//// >PPP GgGGGHHaO  OOD KsC&DE0.(EE0SESSION?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)busrG auth_timeoutbus_addrrDconns r$rr:s7s||H x\ B B BD $ + +D Kr&__main__z Unique name:)Fr)rFr)5rr] collectionsrerrnorr itertoolsrr selectorsrrrcr9typingrjeepneyr r r r jeepney.authr r jeepney.busr jeepney.fdsrrjeepney.wrappersrrjeepney.bus_messagesrcommonrrr__all__rr=rArCrrrtrrr4rprintrMr7r&r$rs  11111111 >>>>>>>>>>>>--------4444444422222222,,,,,,AAAAAAAAAA   (  @@@@@@@@Faaaaa'aaaH%%%%%I%%%P   !! !!!!J79* z   ! !D E.$*+++++r&