>a.SrSSKrSSKJr SSKJr SSKrSSKJr SSK r SSK J r J r SSK r SSKrSSKJr SSKJrJrJrJr SS KJrJr SS KJr SS KJrJr SS KJrJ r SS K!J"r" SSK#J$r$ SSK%J&r&J'r'J(r( /SQr)"SS5r*Sr+Sr,"SS5r-"SS\-5r."SS\5r/Sr0S"S\ R4Sjjr1S#S\.4Sjjr2\3S :Xa\2"5r4\5"S!\4Rl5 gg)$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_connectionDBusConnectionProxyc2\rSrSrSrSrSrSrSrSr g) _FuturecSUlgN_resultselfs 3lib/python3.13/site-packages/jeepney/io/blocking.py__init___Future.__init__s  c,[UR5$r!)boolr#r$s r&done _Future.done"sDLL!!r)cSU4UlgNFr")r% exceptions r& set_exception_Future.set_exception%sy) r)cSU4Ulg)NTr")r%results r& set_result_Future.set_result(s f~ r)c4URupU(aU$Uer!r")r%successvalues r&r4_Future.result+s L r)r"N) __name__ __module__ __qualname____firstlineno__r'r,r1r5r4__static_attributes__r)r&rrs"*&r)rc:Ub[R"5U-$gr!)time monotonictimeouts r&timeout_to_deadlinerF2s~~')) r)cNUb"[U[R"5- S5$g)Ng)maxrBrC)deadlines r&deadline_to_timeoutrJ7s$8dnn..33 r)c\rSrSrSrSS\R 4SjjrSrSrS\ S\ \ \ R44S jr S rS rSS jrSrSrSrg )DBusConnectionBase=z8Connection machinery shared by this module and threadingsockcXlX l[5Ul[ SS9Ul[ 5UlURRU[5Ul SUl g)Nr)start) rN enable_fdsr parserroutgoing_serialrselectorregisterr select_key unique_name)r%rNrQs r&r'DBusConnectionBase.__init__?sK $h $1~') --00zBr)cU$r!r@r$s r& __enter__DBusConnectionBase.__enter__Hs r)c$UR5 gr/)close)r%exc_typeexc_valexc_tbs r&__exit__DBusConnectionBase.__exit__Ks r)messagereturncUc[UR5nUR(a[R"S5OSnUR X#S9nXC4$)Ni)serialfds)nextrSrQarray serialise)r%rcrgrhdatas r& _serialiseDBusConnectionBase._serialiseOsH >$../F"&//ekk#t   8yr)cURRU/[R[RU4/5nU[ U5:aURR XS5 ggr!)rNsendmsgsocket SOL_SOCKET SCM_RIGHTSlensendall)r%rlrh bytes_sents r&_send_with_fds!DBusConnectionBase._send_with_fdsVs]YY&& Ff''):):C@A D ! II  d;/ 0 "r)cURR5nUbU$UR[U5S9up4URR X4S9 MT)NrD)rh)rRget_next_message_read_some_datarJadd_data)r%rImsgbrhs r&_receiveDBusConnectionBase._receive_sV++..0C ))2Eh2O)PFA KK  , r)Nc URRU5H_up#X R:XdMUR(aUR 5s $[ UR RS55/4s $ [e)Ni) rTselectrVrQ_read_with_fds unwrap_readrNrecv TimeoutError)r%rEkeyevs r&r{"DBusConnectionBase._read_some_datahsb}}++G4GCoo%??..00&tyy~~d';__doc__rqr'rZrar bytesrrjrmrwrr{rr]r?r@r)r&rLrL=sZB V]] 'uhu{{>S6T1-Gr)rLc^\rSrSrSS\R4U4SjjjrSS\4Sjjr\rSS.S\4S jjr SS.S jr SSS .S jr SS S.S\ \ 4SjjrSS.S\4SjjrSrU=r$)rrNc>[TU]X5 SUl[[5Ul[ 5Ul[[U5Ul URR5nUSUl g)NFr) superr' _unwrap_replyrrrouterr_filtersrr bus_proxyHellorW)r%rNrQ hello_reply __class__s r&r'DBusConnection.__init__s] *"Wo &( {D1nn**, &q>r)NrccURX5up4U(aURX45 gURRU5 g)z.Serialise and send a :class:`~.Message` objectN)rmrwrNru)r%rcrgrlrhs r&sendDBusConnection.sends5OOG4      * II  d #r)rDrdc6UR[U55$)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. )rrF)r%rEs r&receiveDBusConnection.receives}}09::r)cURUS9nURRU5 URR U5HnUR R U5 M g)zLReceive one message and apply filters See :meth:`filter`. Returns nothing. rDN)rrincomingrmatchesqueueappend)r%rEr}filters r& recv_messagesDBusConnection.recv_messagessQ ll7l+ S!mm++C0F LL   $1r)rEunwrapc[U5 [U5nUc URn[UR5nUR XS9 UR [U5S9nURRR[RS5nXu:XaU(a [U5$U$URRU5 UR R#U5HnUR$R'U5 M M)zSend a message, wait for the reply and return it Filters are applied to other messages received before the reply - see :meth:`add_filter`. )rgrD)rrFrrirS send_messagerrJheaderfieldsgetr reply_serialrrrrrrr) r%rcrErrIrgmsg_inreply_tors r&send_and_get_reply!DBusConnection.send_and_get_replys  &w/ >''Fd**+ '1\\*=h*G\HF}}++// 0I0I2NH!%f--  KK  (--//7 ##F+8r)r)rbufsizercFUc [US9n[URX5$)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&rDBusConnection.filters$ =)EDMM477r)c[U5n[U5S:Xa)UR[U5S9 [U5S:XaM)UR 5$)a Process 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 rrD)rFrtrrJpopleft)r%rrErIs r&recv_until_filtered"DBusConnection.recv_until_filteredsI 'w/%jAo   ':8'D  E%jAo}}r))rrrrrWrr!)r;r<r=r>rqr'r rrrrrrrrrr? __classcell__rs@r&rrs} *V]] * *$G$L!%;';(,%6:$,67;A8Xe_8"59Wr)rc@^\rSrSrSrSS.U4SjjrSrSrSrU=r $) ra6A 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 NrDc<>[TU]U5 X lX0lgr!)rr' _connection_timeout)r%msggen connectionrErs r&r'Proxy.__init__s  % r)c|URcSOSUR3nSURSURUS3$)Nz , timeout=zProxy(z, ))r_msggenr)r%extras r&__repr__Proxy.__repr__sA}},Z 3O ~R(8(8'9%BBr)cJ^^[R"T5UU4Sj5nU$)Nc>URSTR5nT"U0UD6nURR[R LdeTR RX2SS9$)NrTr)poprr message_typer method_callrr)argskwargsrEr}make_msgr%s r&inner!Proxy._method_call..inner sgjjT]];GD+F+C::**k.E.EE EE##66T7 r)) functoolswraps)r%rrs`` r& _method_callProxy._method_calls%  "  #  r))rr) r;r<r=r>rr'rrr?rrs@r&rrs'"7;  C  r)rcdU(d([[[R"[55eU$)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)r~s r&rrs" ":r{{:/FGG Hr)rdc $^^[R"[RS9m[U5mUU4SjnU"TRU5 [ US9nUHAnU"TR U5 UR [U"TRS555 MC U"TR [5 TRS5 T$![Ra%nTR5 [SUS35UeSnAf TR5 e=f)z=Create a socket and authenticate ready to send D-Bus messages)familycB>TR[T55 U"U6$r!) settimeoutrJ)methrrIrNs r&with_sock_deadline'prep_socket..with_sock_deadline(s +H56T{r))rQizDid not authenticate in z secondsN)rqAF_UNIXrFconnectr rufeedrrrrEr]rr) addrrQrErauthrreq_dataerIrNs @@r& prep_socketr s == /D #7+H 4<<.4H t||X 6 JJ{#5dii#FG H 4<</ OOD K >>P 5gYhGHaO  sA:CD C99DcF[U5n[X1US9n[XA5nU$)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. rD)rrr)busrQ auth_timeoutbus_addrrNconns r&rr>s(s|H x\ BD $ +D Kr)__main__z Unique name:)Fg@)SESSIONFg?)7rrj collectionsrerrnorr itertoolsrr selectorsrrrqrBtypingrjeepneyr r r r jeepney.authr r jeepney.busr jeepney.fdsrrjeepney.wrappersrrjeepney.routingrjeepney.bus_messagesrcommonrrr__all__rrFrJrLrrrrrr;rprintrWr@r)r&rs  1 >>-42",AA (  @@Fj'jZ%I%P  >79* z  !D .$**+r)