k7iSSKrSSKrSSKJr SSKJr SSKJrJr SSK J r SSK J r J r Jr SSKJrJr SSKJr S S KJrJrJrJrJr "S S 5rSS jr"SS5r"SS5r"SS\5rg)N)count)Optional) AuthenticatorBEGIN)get_bus)Message MessageTypeParser) ProxyBase unwrap_msg) message_bus)MessageFilters FilterHandle ReplyMatcher RouterClosedcheck_replyablec\rSrSrSrS\R S\R4SjrSS.S\ 4S jjr S \ 4S jr S r S r SrSrg)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`. readerwritercXlX l[5Ul[ SS9UlSUl[R"5Ul g)Nr)start) rrr parserroutgoing_serial unique_nameasyncioLock send_lock)selfrrs L/home/james-whalen/.local/lib/python3.13/site-packages/jeepney/io/asyncio.py__init__DBusConnection.__init__s6  h $1~ Nserialmessagec^# URIShvN Uc[UR5nURR UR U55 URR 5IShvN SSS5IShvN gNyNN !,IShvN (df  g=f7f)z.Serialise and send a :class:`~.Message` objectN)r nextrrwrite serialisedrainr!r(r's r"sendDBusConnection.send so>>>~d223 KK  g//7 8++##% % % ">> & ">>>sWB-B B-A B7B8B< B-BB-BB-B*B  B*&B-returnc# URR5nUbU$URRS5IShvN nU(d[eURR U5 MlN.7f)z5Return the next available message from the connectionNi)rget_next_messagerreadEOFErroradd_data)r!msgbs r"receiveDBusConnection.receive(s_++..0C kk&&t,,A KK  # -s?A2A0/A2c# URR5 URR5IShvN gN7f)zClose the D-Bus connectionN)rclose wait_closedr!s r"r<DBusConnection.close4s+ kk%%'''s8AAAc# U$7fNr>s r" __aenter__DBusConnection.__aenter__9  c@# UR5IShvN gN7frA)r<r!exc_typeexc_valexc_tbs r" __aexit__DBusConnection.__aexit__<sjjls )rrrr rr)__name__ __module__ __qualname____firstlineno____doc__r StreamReader StreamWriterr#rr/r9r<rCrL__static_attributes__rBr%r"rrsR(w33(W=Q=Q(6:&'& $w $( r%rc# [U5n[R"U5IShvN up#[5nUHhnUR U5 UR 5IShvN UR S5IShvN nU(d [S5eURU5 Mj UR [5 UR 5IShvN [X#5n[U5IShvN n[R"[[U5R5S5IShvN n U SUlSSS5IShvN U$GN"NNNNdN+N!,IShvN (df  U$=f7f)z@Open a plain D-Bus connection :return: :class:`DBusConnection` Niz#Socket closed before authentication r)rropen_unix_connectionrr+r-r4r5feedrr DBusRouterwait_forProxyr Hellor) busbus_addrrrauthrreq_datar8connrouter reply_bodys r"open_dbus_connectionre@s$ s|H"77AANF OE Xlln++d# #@A A 1  LL ,,. & )D$6"++E+v,F,L,L,NPRSS %a=  K1B  #  S  Ks%E3E 9E3!E "E3:E;AE3EE3-E.E317E(E)E7 E3EE3 E3E3E3E3EE3E0E!  E0+E3c\rSrSrSrSrSrSrS\4Sjr \ S5r SS.Sjr S \ 4S jrSS S .S \\R"4SjjrSrSrS\ 4SjrSrSrg)rZ`zA '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. NrbcXl[5Ul[5Ul[ R "UR55UlgrA) _connr_repliesr_filtersr create_task _receiver _rcv_task)r!rbs r"r#DBusRouter.__init__js3 $ &(  ,,T^^-=>r%c.URR$rA)rirr>s r"rDBusRouter.unique_namepszz%%%r%r&cR# URRXS9IShvN gN7f)z&Send a message, don't wait for a replyr&N)rir/r.s r"r/DBusRouter.sendtsjjoogo555s '%'r1c# [U5 URR5(a [S5e[ UR R 5nURRU[R"55nURXS9IShvN UIShvN sSSS5 $NN!,(df  g=f7f)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) rrndonerr*rirrjcatchrFuturer/)r!r(r' reply_futs r"send_and_get_replyDBusRouter.send_and_get_replyxs  >>   <= =djj001 ]] )9 :i))G)3 3 3#O; : 3#; :sBBCB5B1 B5#B3$B5' C1B53B55 C?Cr)queuebufsizer{ch[URX=(d [R"U55$)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 )rrkrQueue)r!ruler{r|s r"filterDBusRouter.filters#DMM41P'--:PQQr%c# U$7frArBr>s r"rCDBusRouter.__aenter__rErFc\# URR5(aURR5 gURR5 [R "[ R5 URIShvN SSS5 gN !,(df  g=f7f)NF)rnruresultcancel contextlibsuppressrCancelledErrorrHs r"rLDBusRouter.__aexit__sx >>   NN ! ! #  NN ! ! #$$W%;%;<nn$$=%=<s0A9B,;B B B B,B B)%B,r7c URRU5(ag[URR U55HnUR R U5 M! g![Ra M;f=f)zHandle one received messageN) rjdispatchlistrkmatchesr{ put_nowaitr QueueFull)r!r7rs r" _dispatchDBusRouter._dispatchsi == ! !# & & 4==0056F  '',7$$  s A**BBc# URR5IShvN nURU5 M5N!URR 5 f=f7f)z'Receiver loop - runs in a separate taskN)rir9rrjdrop_all)r!r7s r"rmDBusRouter._receiversI % JJ..00s#0 MM " " $sA<:<AA)rirkrnrj)rNrOrPrQrR _nursery_mgr_send_cancel_scope_rcv_cancel_scoperr#propertyrr/rryrrr~rrCrLrrmrUrBr%r"rZrZ`s L?^? &&-16 %7 %?CA RXgmm%< R W %r%rZc6\rSrSrSrSrSrSSjrSrSr Sr g) 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: ... NcXlgrA)r^)r!r^s r"r#open_dbus_router.__init__sr%c# [UR5IShvN Ul[UR5UlURR 5IShvN $NEN7frA)rer^rbrZreq_ctxrCr>s r"rCopen_dbus_router.__aenter__sF.txx88 !$)), \\,,...9.s"A%A!AA%A#A%#A%c# URRXU5IShvN URR5IShvN gN'N7frA)rrLrbr<rHs r"rLopen_dbus_router.__aexit__s<ll$$X???iioo @s! AA !AA A A)r^rbrSESSION) rNrOrPrQrRrbrr#rCrLrUrBr%r"rrs" DG/  r%rc8^\rSrSrSrU4SjrSrSrSrU=r $)r\aAn 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. c0>[TU]U5 X lgrA)superr#_router)r!msggenrc __class__s r"r#Proxy.__init__s   r%cNSRURUR5$)Nz Proxy({}, {}))format_msggenrr>s r"__repr__Proxy.__repr__s%%dllDLLAAr%c^^UU4SjnU$)Nc># T"U0UD6nURR[RLdeTRR U5IShvN n[ U5$N7frA)header message_typer method_callrryr )argskwargsr7replymake_msgr!s r"inner!Proxy._method_call..innersZD+F+C::**k.E.EE EE,,99#>>Ee$ $?sAA%A#A%rB)r!rrs`` r" _method_callProxy._method_calls %  r%)r) rNrOrPrQrRr#rrrU __classcell__)rs@r"r\r\s Br%r\r)rr itertoolsrtypingr jeepney.authrr jeepney.busrjeepneyrr r jeepney.wrappersr r jeepney.bus_messagesr commonrrrrrrrerZrr\rBr%r"rsa-002, --`@V%V%p  0Ir%