+cddlZddlZddlmZddlmZddlmZmZddl m Z ddl m Z m Z mZddlmZmZddlmZd d lmZmZmZmZmZGd d Zdd ZGddZGddZGddeZy)N)count)Optional) AuthenticatorBEGIN)get_bus)Message MessageTypeParser) ProxyBase unwrap_msg) message_bus)MessageFilters FilterHandle ReplyMatcher RouterClosedcheck_replyablecxeZdZdZdej dej fdZdddefdZ d efd Z d Z d Z d Z y)DBusConnectionaPA 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`. readerwriterc||_||_t|_t d|_d|_tj|_ y)Nr)start) rrr parserroutgoing_serial unique_nameasyncioLock send_lock)selfrrs 4/usr/lib/python3/dist-packages/jeepney/io/asyncio.py__init__zDBusConnection.__init__s:  h $1~ NserialmessagecRK|j4d{|t|j}|jj |j ||jj d{dddd{y7x77 #1d{7swYyxYww)z.Serialise and send a :class:`~.Message` objectN)rnextrrwrite serialisedrainr r&r%s r!sendzDBusConnection.send s>> & &~d223 KK  g//7 8++##% % %  & & & &  & & & &sWB'B B'AB6B7B; B'BB'BB'B$B B$ B'returncK |jj}||S|jjdd{}|st|jj |e7(w)z5Return the next available message from the connectionNi)rget_next_messagerreadEOFErroradd_data)r msgbs r!receivezDBusConnection.receive(s`++..0C kk&&t,,A KK  # -s>A+A))A+cK|jj|jjd{y7w)zClose the D-Bus connectionN)rclose wait_closedr s r!r8zDBusConnection.close4s, kk%%'''s8AAAcK|SwNr:s r! __aenter__zDBusConnection.__aenter__9  c@K|jd{y7wr<)r8r exc_typeexc_valexc_tbs r! __aexit__zDBusConnection.__aexit__<sjjls )__name__ __module__ __qualname____doc__r StreamReader StreamWriterr"rr-r6r8r>rFr=r#r!rrsR(w33(W=Q=Q(6:&'& $w $( r#rcKt|}tj|d{\}}t}|D]b}|j ||j d{|j dd{}|s td|j|d|j t|j d{t||}t|4d{}tjtt|jdd{} | d|_dddd{|S77777c7+7#1d{7swY|SxYww)zHOpen a plain D-Bus connection :return: :class:`DBusConnection` Niz#Socket closed before authentication r)rropen_unix_connectionrr)r+r1r2feedrr DBusRouterwait_forProxyr Hellor) busbus_addrrrauthrreq_datar5connrouter reply_bodys r!open_dbus_connectionr\@sG s|H"77AANFF OE Xlln++d# #@A A 1  LL ,,. && )D$))6"++E+v,F,L,L,NPRSS %a=)) K1B  # )S)))) Ks$E'E:E'!E"E':E;A E'E E''E (E'+6E!E "E0 E';E<E'E'E' E' E' EE'E$E E$E'ceZdZdZdZdZdZdefdZe dZ dddZ de fd Z dd d d eej fd ZdZdZde fdZdZy)rQzA '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. NrYc||_t|_t|_t j |j|_yr<) _connr_repliesr_filtersr create_task _receiver _rcv_task)r rYs r!r"zDBusRouter.__init__js5 $ &(  ,,T^^-=>r#c.|jjSr<)r_rr:s r!rzDBusRouter.unique_namepszz%%%r#r$cZK|jj||d{y7w)z&Send a message, don't wait for a replyr$N)r_r-r,s r!r-zDBusRouter.sendts jjoogfo555s !+)+r.cKt||jjr tdt |j j }|jj|tj5}|j||d{|d{cdddS77#1swYyxYww)zSend a method call message and wait for the reply Returns the reply message (method return or error message type). zThis DBusRouter has stoppedr$N) rrddonerr(r_rr`catchrFuturer-)r r&r% reply_futs r!send_and_get_replyzDBusRouter.send_and_get_replyxs  >>   <= =djj001 ]] )9 : %i))GF)3 3 3#O % % 3# % %sBA>B?B3B/ B3!B1"B3% B?/B31B33B<8B?r)queuebufsizermc^t|j||xstj|S)arCreate 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 )rrarQueue)r rulermrns r!filterzDBusRouter.filters%DMM41P'--:PQQr#cK|Swr<r=r:s r!r>zDBusRouter.__aenter__r?r@cFK|jjr|jjy|jjt j t j5|jd{dddy7 #1swYyxYww)NF)rdrhresultcancel contextlibsuppressrCancelledErrorrBs r!rFzDBusRouter.__aexit__sy >>   NN ! ! #  NN ! ! #$$W%;%;< %nn$$ %% %s0A3B!5BBB B!BBB!r4c|jj|ryt|jj |D]} |j j | y#tj$rY7wxYw)zHandle one received messageN) r`dispatchlistramatchesrm put_nowaitr QueueFull)r r4rrs r! _dispatchzDBusRouter._dispatchsk == ! !# & 4==0056 F  '', $$  sA##A98A9cK |jjd{}|j|47#|jj wxYww)z'Receiver loop - runs in a separate taskN)r_r6rr`drop_all)r r4s r!rczDBusRouter._receiversJ % JJ..00s#0 MM " " $sA;9;AA)rGrHrIrJ _nursery_mgr_send_cancel_scope_rcv_cancel_scoperr"propertyrr-rrlrrrprrr>rFrrcr=r#r!rQrQ`s L?^? &&-16 %7 %?CA RXgmm%< R W %r#rQc,eZdZdZdZdZddZdZdZy)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: ... Nc||_yr<)rU)r rUs r!r"zopen_dbus_router.__init__s r#cKt|jd{|_t|j|_|jj d{S7E7wr<)r\rUrYrQreq_ctxr>r:s r!r>zopen_dbus_router.__aenter__sH.txx88 !$)), \\,,...9.s"A%A!AA%A#A%#A%cK|jj|||d{|jjd{y7'7wr<)rrFrYr8rBs r!rFzopen_dbus_router.__aexit__s@ll$$Xw???iioo @s!!AA !AA A ASESSION) rGrHrIrJrYrr"r>rFr=r#r!rrs" DG/  r#rc.eZdZdZfdZdZdZxZS)rSaAn 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. c2t||||_yr<)superr"_router)r msggenrZ __class__s r!r"zProxy.__init__s   r#cNdj|j|jS)Nz Proxy({}, {}))format_msggenrr:s r!__repr__zProxy.__repr__s%%dllDLLAAr#cfd}|S)NcK|i|}|jjtjusJjj |d{}t |S7wr<)header message_typer method_callrrlr )argskwargsr4replymake_msgr s r!innerz!Proxy._method_call..inners[D+F+C::**k.E.EE EE,,99#>>Ee$ $?sAA$A"A$r=)r rrs`` r! _method_callzProxy._method_calls %  r#)rGrHrIrJr"rr __classcell__)rs@r!rSrSs Br#rSr)rrw itertoolsrtypingr jeepney.authrr jeepney.busrjeepneyrr r jeepney.wrappersr r jeepney.bus_messagesr commonrrrrrrr\rQrrSr=r#r!rsa-002, --`@V%V%p  0Ir#