+ >a^RIt^RIt^RIHt^RIHt^RIHtHt^RI H t ^RI H t H t Ht^RIHtHt^RIHt^R IHtHtHtHtHt!R R 4tRR lt!R R4t!RR4t!RR]4tR#)N)count)Optional) AuthenticatorBEGIN)get_bus)Message MessageTypeParser) ProxyBase unwrap_msg) message_bus)MessageFilters FilterHandle ReplyMatcher RouterClosedcheck_replyablecta]tRt^toRtV3RlRltRR/V3RlRlltV3RlR ltR tR t R t R t Vt R#)DBusConnectiona<A plain D-Bus connection with no matching of replies. This doesn't run any separate tasks: sending and receiving are done in the task that calls those methods. It's suitable for implementing servers: several worker tasks can receive requests and send replies. For a typical client pattern, see :class:`DBusRouter`. cN<V^8dQhRS[PRS[P/#)readerwriter)asyncio StreamReader StreamWriter)format __classdict__s"2lib/python3.14/site-packages/jeepney/io/asyncio.py __annotate__DBusConnection.__annotate__s'((w33(W=Q=Q(cWnW n\4Vn\ ^R7VnRVn\P!4Vn R#))startN) rrr parserroutgoing_serial unique_namerLock send_lock)selfrrs&&&r__init__DBusConnection.__init__s6  h $1~ r!serialNc <V^8dQhRS[/#)rmessager)rrs"rrr s&&'&r!c x"VP;_uu_4GRjxL Vf\VP4pVPP VP V44VPP 4GRjxL RRR4GRjxL R#L{LL +GRjxL 'giR#;i5i)z.Serialise and send a :class:`~.Message` objectN)r)nextr&rwrite serialisedrainr*r/r-s&&$rsendDBusConnection.send sq>>>>~d223 KK  g//7 8++##% % % ">> & ">>>s]B:BB:A!BBB B:BB:BB:B7 #B&$ B7 /B7 1 B:c <V^8dQhRS[/#rreturnr0)rrs"rrr (s $ $w $r!c "VPP4pVeV#VPPR4GRjxL pV'g\hVPP V4KoL/5i)z5Return the next available message from the connectionNi)r%get_next_messagerreadEOFErroradd_data)r*msgbs& rreceiveDBusConnection.receive(sZ++..0C kk&&t,,A KK  #-sAA4A2 A4$A4c "VPP4VPP4GRjxL R#L5i)zClose the D-Bus connectionN)rclose wait_closedr*s&rrFDBusConnection.close4s+ kk%%'''s8AAAc"V#5iNrHs&r __aenter__DBusConnection.__aenter__9  cB"VP4GRjxL R#L5irK)rFr*exc_typeexc_valexc_tbs&&&&r __aexit__DBusConnection.__aexit__<sjjls )r&r%rr)r'r) __name__ __module__ __qualname____firstlineno____doc__r+r7rCrFrMrV__static_attributes____classdictcell__rs@rrrsC((&T&& $ $( r!rc"\V4p\P!V4GRjxL wr#\4pVFipVP V4VP 4GRjxL VP R4GRjxL pV'g \R4hVPV4Kk VP \4VP 4GRjxL \W#4p\V4;_uu_4GRjxL p\P!\\V4P4^ 4GRjxL p V ^,VnRRR4GRjxL V#EL/LLLLhL/L +GRjxL 'giT#;i5i)z@Open a plain D-Bus connection :return: :class:`DBusConnection` Niz#Socket closed before authentication)rropen_unix_connectionrr3r5r>r?feedrr DBusRouterwait_forProxyr Hellor') busbus_addrrrauthrreq_datarBconnrouter reply_bodys & ropen_dbus_connectionrn@s* s|H"77AANF OE Xlln++d# #@A A 1  LL ,,. & )D$6"++E+v,F,L,L,NPRSS %a=  K1B  #  S  Ks%FE9F!E"F:E; FAFE&F6E7F:7E%1E!2E% FE#FFFFF!E%#F%E? +E., E? 7E? 9 Fca]tRt^`toRtRtRtRtV3RlRlt] R4t RR/Rlt V3RlR lt R RR ^/V3R lR llt RtRtV3RlRltRtRtVtR#)rczA 'client' D-Bus connection which can wait for a specific reply. This runs a background receiver task, and makes it possible to send a request and wait for the relevant reply. Nc <V^8dQhRS[/#)rrk)r)rrs"rrDBusRouter.__annotate__js??^?r!cWn\4Vn\4Vn\ P !VP44VnR#rK) _connr_repliesr_filtersr create_task _receiver _rcv_task)r*rks&&rr+DBusRouter.__init__js3 $ &(  ,,T^^-=>r!c.VPP#rK)rsr'rHs&rr'DBusRouter.unique_namepszz%%%r!r-c Z"VPPWR7GRjxL R#L5i)z&Send a message, don't wait for a replyr-N)rsr7r6s&&$rr7DBusRouter.sendtsjjoogo555s +)+c <V^8dQhRS[/#r:r0)rrs"rrrqxs % %7 %r!c "\V4VPP4'd \R4h\ VP P 4pVPPV\P!44;_uu_4pVPWR7GRjxL VGRjxL uuRRR4#LL +'giR#;i5i)ztSend a method call message and wait for the reply Returns the reply message (method return or error message type). zThis DBusRouter has stoppedr}N) rrxdonerr2rsr&rtcatchrFuturer7)r*r/r- reply_futs&& rsend_and_get_replyDBusRouter.send_and_get_replyxs  >>   <= =djj001 ]] )9 : :i))G)3 3 3#O; : 3#; : :sBB CC%B>& C/C0C3 C>CC C CqueuebufsizecD<V^8dQhRS[S[P,/#)rr)rrQueue)rrs"rrrqs R RXgmm%< Rr!c j\VPY;'g\P!V44#)a:Create a filter for incoming messages Usage:: with router.filter(rule) as queue: matching_msg = await queue.get() :param MatchRule rule: Catch messages matching this rule :param asyncio.Queue queue: Send matching messages here :param int bufsize: If no queue is passed in, create one with this size )rrurr)r*rulerrs&&$$rfilterDBusRouter.filters&DMM41P1P'--:PQQr!c"V#5irKrLrHs&rrMDBusRouter.__aenter__rOrPcx"VPP4'dVPP4R#VPP4\P !\ P4;_uu_4VPGRjxL RRR4R#L +'giR#;i5i)NF)rxrresultcancel contextlibsuppressrCancelledErrorrRs&&&&rrVDBusRouter.__aexit__s{ >>   NN ! ! #  NN ! ! #$$W%;%;<<nn$$=%=<s0BB:B&B$B& B:$B&& B7 1 B:c <V^8dQhRS[/#)rrAr0)rrs"rrrqs  W r!c VPPV4'dR#\VPP V44FpVP P V4K! R# \PdK=i;i)zHandle one received messageN) rtdispatchlistrumatchesr put_nowaitr QueueFull)r*rArs&& r _dispatchDBusRouter._dispatchsi == ! !# & & 4==0056F  '',7$$  s A--BBc "VPP4GRjxL pVPV4K6L TPP 4i;i5i)z'Receiver loop - runs in a separate taskN)rsrCrrtdrop_all)r*rAs& rrwDBusRouter._receiversF % JJ..00s#1 MM " " $sA<:<AA)rsrurxrt)rXrYrZr[r\ _nursery_mgr_send_cancel_scope_rcv_cancel_scoper+propertyr'r7rrrMrVrrwr]r^r_s@rrcrc`s L?? &&6D6 % % Rd RA R R  %%r!rccBa]tRt^toRtRtRtRRltRtRt Rt Vt R#)open_dbus_routerzOpen a D-Bus 'router' to send and receive messages Use as an async context manager:: async with open_dbus_router() as router: ... NcWnR#rK)rg)r*rgs&&rr+open_dbus_router.__init__sr!c"\VP4GRjxL Vn\VP4VnVPP 4GRjxL #LEL5irK)rnrgrkrcreq_ctxrMrHs&rrMopen_dbus_router.__aenter__sF.txx88 !$)), \\,,...9.s"A%A!AA%A#A%#A%c"VPPWV4GRjxL VPP4GRjxL R#L(L5irK)rrVrkrFrRs&&&&rrVopen_dbus_router.__aexit__s<ll$$X???iioo @s! AA !AA A A)rgrkrSESSION) rXrYrZr[r\rkrr+rMrVr]r^r_s@rrrs* DG/   r!rcBaa]tRt^toRtV3RltRtRtRtVt V;t #)reaAn asyncio proxy for calling D-Bus methods You can call methods on the proxy object, such as ``await 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. :param msggen: A message generator object. :param ~asyncio.DBusRouter router: Router to send and receive messages. c2<\SV`V4W nR#rK)superr+_router)r*msggenrl __class__s&&&rr+Proxy.__init__s   r!cNRPVPVP4#)z Proxy({}, {}))r_msggenrrHs&r__repr__Proxy.__repr__s%%dllDLLAAr!caaVV3RlpV#)c<"S!V/VBpVPP\PJgQhSPP V4GRjxL p\ V4#L5irK)header message_typer method_callrrr )argskwargsrAreplymake_msgr*s*, rinner!Proxy._method_call..innersZD+F+C::**k.E.EE EE,,99#>>Ee$ $?sAA&A$A&rL)r*rrsff r _method_callProxy._method_calls %  r!)r) rXrYrZr[r\r+rrr]r^ __classcell__)rrs@@rreres Br!rer)rr itertoolsrtypingr jeepney.authrr jeepney.busrjeepneyrr r jeepney.wrappersr r jeepney.bus_messagesr commonrrrrrrrnrcrrerLr!rrsa-002, --`@V%V%p  0Ir!