Ki.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 jfdZ/ d"de,fdZ0e1dk(re0Z2e3d e2jhyy)#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*eZdZdZdZdZdZdZy)_Futurecd|_yN_resultselfs _/home/jay/workspace/scripts/.codegraph-venv/lib/python3.12/site-packages/jeepney/io/blocking.py__init__z_Future.__init__s  c,t|jSr)boolr!r"s r$donez _Future.done!sDLL!!r&cd|f|_yNFr )r# exceptions r$ set_exceptionz_Future.set_exception$sy) r&cd|f|_y)NTr )r#results r$ set_resultz_Future.set_result's f~ 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|zSyr)time monotonictimeouts r$timeout_to_deadliner=1s~~')) r&cJ|!t|tjz dSy)Ng)maxr9r:)deadlines r$deadline_to_timeoutrA6s$8dnn..33 r&ceZdZdZddejfdZdZdZdede e e jffdZ d Z d Zdd Zd ZdZy )DBusConnectionBasez8Connection machinery shared by this module and threadingsockc||_||_t|_t d|_t |_|jj|t|_ d|_ y)Nr)start) rD enable_fdsr parserroutgoing_serialrselectorregisterr select_key unique_name)r#rDrGs r$r%zDBusConnectionBase.__init__>sO $h $1~') --00zBr&c|Srr7r"s r$ __enter__zDBusConnectionBase.__enter__Gs r&c$|jyr+)close)r#exc_typeexc_valexc_tbs r$__exit__zDBusConnectionBase.__exit__Js r&messagereturnc|t|j}|jrtjdnd}|j ||}||fS)Ni)serialfds)nextrIrGarray serialise)r#rVrZr[datas r$ _serialisezDBusConnectionBase._serialiseNsL >$../F"&//ekk#t  C 8Syr&c|jj|gtjtj|fg}|t |kr|jj ||dyyr)rDsendmsgsocket SOL_SOCKET SCM_RIGHTSlensendall)r#r_r[ bytes_sents r$_send_with_fdsz!DBusConnectionBase._send_with_fdsUs_YY&& Ff''):):C@A D ! II  d:;/ 0 "r&c |jj}||S|jt|\}}|jj ||Z)Nr;)r[)rHget_next_message_read_some_datarAadd_data)r#r@msgbr[s r$_receivezDBusConnectionBase._receive^sZ++..0C ))2Eh2O)PFAs KK  , r&Nc|jj|D]Z\}}||jk(s|jr|j cSt |j jdgfcSt)Ni) rJselectrLrG_read_with_fds unwrap_readrDrecv TimeoutError)r#r<keyevs r$rlz"DBusConnectionBase._read_some_datagsm}}++G4 AGCdoo%??..00&tyy~~d';S6T1-Gr&rCceZdZddejffd ZddefdZeZdddefdZddd Z ddd Z dd d d e e fdZ dddefdZxZS)rrDct|||t|_t t ||_|j j}|d|_y)Nr) superr%r_filtersrr bus_proxyHellorM)r#rDrG hello_reply __class__s r$r%zDBusConnection.__init__sL z*'( {D1nn**, &q>r&NrVc|j||\}}|r|j||y|jj|y)z.Serialise and send a :class:`~.Message` objectN)r`rirDrg)r#rVrZr_r[s r$sendzDBusConnection.sends;OOGV4 c    c * II  d #r&r;rWc6|jt|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}}09::r&c|j|}|jj|D]}|jj |y)z\Receive one message and apply filters See :meth:`filter`. Returns nothing. r;N)rrmatchesqueueappend)r#r<rnfilters r$ recv_messageszDBusConnection.recv_messagessD ll7l+mm++C0 %F LL   $ %r&ct|t|}t|j}|j || |j t |}|jjjtjd}||k(r|S|jj|D]}|jj|)zSend a message, wait for the reply and return it Filters are applied to other messages received before the reply - see :meth:`add_filter`. )rZr;)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**+ '&1\\*=h*G\HF}}++// 0I0I2NH6! --//7 , ##F+ ,r&r)rbufsizercL| 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 )maxlen)rrr)r#rulerrs r$rzDBusConnection.filters& =)EDMM477r&ct|}t|dk(r*|jt|t|dk(r*|j 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_filteredsI 'w/%jAo   ':8'D  E%jAo}}r&rr)r4r5r6rcr%r rrrrrrrrr __classcell__rs@r$rrsq *V]] *$G$L!%;';(,%6:,*7;A8Xe_8"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;c@t||||_||_yr)rr% _connection_timeout)r#msggen connectionr<rs r$r%zProxy.__init__s  % r&cz|jdnd|j}d|jd|j|dS)Nz , timeout=zProxy(z, ))r_msggenr)r#extras r$__repr__zProxy.__repr__sA}},Z 3O ~R(8(8'9%BBr&cFtjfd}|S)Nc|jdj}|i|}|jjtj usJt jj||S)Nrr;) poprr message_typer method_callrrr)argskwargsr<rnmake_msgr#s r$innerz!Proxy._method_call..innersojjT]];GD+F+C::**k.E.EE EEd..AAWB r&) functoolswraps)r#rrs`` r$ _method_callzProxy._method_calls%  "  #  r&)r4r5r6rr%rrrrs@r$rrs"7; C r&rcX|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" ":r{{:/FGG Hr&rWc tjtjt|fd} |j|t |d}t tdr=j dgtjtjtdfgnjd|D]@}|j||jt|jdB|jtj'd S#tj $r%}j#t%d |d |d }~wj#xYw) z=Create a socket and authenticate ready to send D-Bus messages)familycBjt||Sr) settimeoutrA)methrr@rDs r$with_sock_deadlinez'prep_socket..with_sock_deadlines +H56T{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<<.5I 6; ' LL%F$5$5v7G7Gs#T"U V IIe  IH t||X 6 JJ{#5dii#FG H I 4<</ OOD K >>P 5gYhGHaO  sCD&&E/9 EE/cPt|}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:s,s|H x\ BD $ +D Kr&__main__z Unique name:)Fg@)SESSIONFg?)5rr] collectionsrerrnorr itertoolsrr selectorsrrrcr9typingrjeepneyr r r r jeepney.authr r jeepney.busr jeepney.fdsrrjeepney.wrappersrrjeepney.bus_messagesrcommonrrr__all__rr=rArCrrrtrrr4rprintrMr7r&r$rs  1 >>-42,AA (  @@Fa'aH%I%P ! !J79* z  !D .$**+r&