k7i.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$J%r%J&r& /SQr'"SS5r(Sr)Sr*"SS5r+"SS\+5r,"SS\5r-Sr.S!S\ R4Sjjr/S"S\,4Sjjr0\1S:Xa\0"5r2\3"S \2Rh5 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) message_bus)MessageFilters FilterHandlecheck_replyable)open_dbus_connectionDBusConnectionProxyc2\rSrSrSrSrSrSrSrSr g) _FuturecSUlgN_resultselfs M/home/james-whalen/.local/lib/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%r3_Future.result*s L r(r!N) __name__ __module__ __qualname____firstlineno__r&r+r0r4r3__static_attributes__r(r%rrs"*&r(rc:Ub[R"5U-$gr )time monotonictimeouts r%timeout_to_deadlinerE1s~~')) r(cNUb"[U[R"5- S5$g)Ng)maxrArB)deadlines r%deadline_to_timeoutrI6s$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) rM enable_fdsr parserroutgoing_serialrselectorregisterr select_key unique_name)r$rMrPs r%r&DBusConnectionBase.__init__>sK $h $1~') --00zBr(cU$r r?r#s r% __enter__DBusConnectionBase.__enter__Gs r(c$UR5 gr.)close)r$exc_typeexc_valexc_tbs r%__exit__DBusConnectionBase.__exit__Js r(messagereturncUc[UR5nUR(a[R"S5OSnUR X#S9nXC4$)Ni)serialfds)nextrRrParray serialise)r$rbrfrgdatas r% _serialiseDBusConnectionBase._serialiseNsH >$../F"&//ekk#t   8yr(cURRU/[R[RU4/5nU[ U5:aURR XS5 ggr )rMsendmsgsocket SOL_SOCKET SCM_RIGHTSlensendall)r$rkrg bytes_sents r%_send_with_fds!DBusConnectionBase._send_with_fdsUs]YY&& Ff''):):C@A D ! II  d;/ 0 "r(cURR5nUbU$UR[U5S9up4URR X4S9 MT)NrC)rg)rQget_next_message_read_some_datarIadd_data)r$rHmsgbrgs r%_receiveDBusConnectionBase._receive^sV++..0C ))2Eh2O)PFA KK  , r(Nc URRU5H_up#X R:XdMUR(aUR 5s $[ UR RS55/4s $ [e)Ni) rSselectrUrP_read_with_fds unwrap_readrMrecv TimeoutError)r$rDkeyevs r%rz"DBusConnectionBase._read_some_datagsb}}++G4GCoo%??..00&tyy~~d';r?r(r%rKrK<sZB V]] 'uhu{{>S6T1-Gr(rKc^\rSrSrSS\R4U4SjjjrSS\4Sjjr\rSS.S\4S jjr SS.S jr SS.S jr SS S .S\ \ 4SjjrSS.S\4SjjrSrU=r$)rrMc>[TU]X5 [5Ul[ [ U5UlUR R5nUSUlg)Nr) superr&r_filtersrr bus_proxyHellorV)r$rMrP hello_reply __class__s r%r&DBusConnection.__init__sJ *'( {D1nn**, &q>r(NrbcURX5up4U(aURX45 gURRU5 g)z.Serialise and send a :class:`~.Message` objectN)rlrvrMrt)r$rbrfrkrgs r%sendDBusConnection.sends5OOG4      * II  d #r(rCrcc6UR[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. )r~rE)r$rDs r%receiveDBusConnection.receives}}09::r(cURUS9nURRU5HnURR U5 M g)zLReceive one message and apply filters See :meth:`filter`. Returns nothing. rCN)rrmatchesqueueappend)r$rDr|filters r% recv_messagesDBusConnection.recv_messagess? ll7l+mm++C0F LL   $1r(c[U5 [U5n[UR5nUR XS9 UR [ U5S9nURRR[RS5nXd:XaU$URRU5HnURRU5 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`. )rfrC)rrErhrR send_messagerrIheaderfieldsgetr reply_serialrrrr)r$rbrDrHrfmsg_inreply_tors r%send_and_get_reply!DBusConnection.send_and_get_replys  &w/d**+ '1\\*=h*G\HF}}++// 0I0I2NH! --//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 rrC)rErsrrIpopleft)r$rrDrHs r%recv_until_filtered"DBusConnection.recv_until_filteredsI 'w/%jAo   ':8'D  E%jAo}}r()rrrVrr )r:r;r<r=rpr&r rrrrrrrrrr> __classcell__rs@r%rrs{ *V]] * *$G$L!%;';(,%6:,*7;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 NrCc<>[TU]U5 X lX0lgr )rr& _connection_timeout)r$msggen connectionrDrs 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 Lde[ TRRX2S95$)NrrC) poprr message_typer method_callrrr)argskwargsrDr|make_msgr$s r%inner!Proxy._method_call..innersmjjT]];GD+F+C::**k.E.EE EEd..AAB 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%rr s" ":r{{:/FGG Hr(rcc ^^[R"[RS9m[U5mUU4SjnU"TRU5 [ USS9n[ [S5(a=TR S/[R[R[S54/5 OTRS5 UHAnU"TRU5 UR[U"TRS555 MC U"TR[5 TR'S 5 T$![R a%nTR#5 [%S US 35UeS nAf TR#5 e=f) z=Create a socket and authenticate ready to send D-Bus messages)familycB>TR[T55 U"U6$r ) settimeoutrI)methrrHrMs r%with_sock_deadline'prep_socket..with_sock_deadlines +H56T{r(F)rP inc_null_byte SCM_CREDSiizDid not authenticate in z secondsN)rpAF_UNIXrEconnectr hasattrrorqrrrrtfeedrrrrDr\rr) addrrPrDrauthrreq_dataerHrMs @@r% prep_socketrs% == /D #7+H4<<.5I 6; ' ' LL%F$5$5v7G7Gs#T"U V IIe H t||X 6 JJ{#5dii#FG H 4<</ OOD K >>P 5gYhGHaO  sCD))E3= EE3cF[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. rC)rrr)busrP auth_timeoutbus_addrrMconns r%rr:s(s|H x\ BD $ +D Kr(__main__z Unique name:)Fg@)SESSIONFg?)5rri collectionsrerrnorr itertoolsrr selectorsrrrprAtypingrjeepneyr r r r jeepney.authr r jeepney.busr jeepney.fdsrrjeepney.wrappersrrjeepney.bus_messagesrcommonrrr__all__rrErIrKrrrrrr:rprintrVr?r(r%rs  1 >>-42,AA (  @@Fa'aH%I%P ! !J79* z  !D .$**+r(