+c0dZddlZddlmZddlmZddlZddlmZddl Z ddl m Z m Z ddl Z ddlZddlmZddlmZdd lmZmZmZmZdd lmZmZdd lmZdd lmZmZdd l m!Z!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(m)Z)m*Z*gdZ+GddZ,dZ-dZ.GddZ/Gdde/Z0Gdde!Z1dZ2d#de jfdZ3 d$de0fd Z4e5d!k(re4Z6e7d"e6jpyy)%z'Synchronous IO wrappers around jeepney N)deque) ECONNRESET)count)DefaultSelector EVENT_READ)Optional)warn)ParserMessage MessageType HeaderFields) AuthenticatorBEGIN)get_bus)FileDescriptor fds_buf_size) ProxyBase unwrap_msg)Router) message_bus)MessageFilters FilterHandlecheck_replyable)open_dbus_connectionDBusConnectionProxyc*eZdZdZdZdZdZdZy)_Futurecd|_yN_resultselfs 5/usr/lib/python3/dist-packages/jeepney/io/blocking.py__init__z_Future.__init__ s  c,t|jSr!)boolr#r$s r&donez _Future.done#sDLL!!r(cd|f|_yNFr")r% exceptions r& set_exceptionz_Future.set_exception&sy) r(cd|f|_y)NTr")r%results r& set_resultz_Future.set_result)s f~ r(c,|j\}}|r|S|r!r")r%successvalues r&r1z_Future.result,s L r(N)__name__ __module__ __qualname__r'r+r/r2r1r(r&rrs"*&r(rc6|tj|zSyr!)time monotonictimeouts r&timeout_to_deadliner?3s~~')) r(cJ|!t|tjz dSy)Ng)maxr;r<)deadlines r&deadline_to_timeoutrC8s$8dnn..33 r(ceZdZdZddejfdZdZdZdede e e jffdZ d Z d Zdd Zd ZdZy )DBusConnectionBasez8Connection machinery shared by this module and threadingsockc||_||_t|_t d|_t |_|jj|t|_ d|_ y)Nr)start) rF enable_fdsr parserroutgoing_serialrselectorregisterr select_key unique_name)r%rFrIs r&r'zDBusConnectionBase.__init__@sO $h $1~') --00zBr(c|Sr!r9r$s r& __enter__zDBusConnectionBase.__enter__Is r(c$|jyr-)close)r%exc_typeexc_valexc_tbs r&__exit__zDBusConnectionBase.__exit__Ls r(messagereturnc|t|j}|jrtjdnd}|j ||}||fS)Ni)serialfds)nextrKrIarray serialise)r%rXr\r]datas r& _serialisezDBusConnectionBase._serialisePsL >$../F"&//ekk#t  C 8Syr(c|jj|gtjtj|fg}|t |kr|jj ||dyyr!)rFsendmsgsocket SOL_SOCKET SCM_RIGHTSlensendall)r%rar] bytes_sents r&_send_with_fdsz!DBusConnectionBase._send_with_fdsWs_YY&& Ff''):):C@A D ! II  d:;/ 0 "r(c |jj}||S|jt|\}}|jj ||Z)Nr=)r])rJget_next_message_read_some_datarCadd_data)r%rBmsgbr]s r&_receivezDBusConnectionBase._receive`sZ++..0C ))2Eh2O)PFAs KK  , r(Nc|jj|D]Z\}}||jk(s|jr|j cSt |j jdgfcSt)Ni) rLselectrNrI_read_with_fds unwrap_readrFrecv TimeoutError)r%r>keyevs r&rnz"DBusConnectionBase._read_some_dataism}}++G4 AGCdoo%??..00&tyy~~d';sZB V]] 'uhu{{>S6T1-Gr(rEceZdZddejffd ZedZddefdZeZ dddefd Z ddd Z ddd d Z dd dde efdZdddefdZxZS)rrFct|||tt|_t |_tt||_ |jj}|d|_ y)Nr) superr'rr_routerr_filtersrr bus_proxyHellorO)r%rFrI hello_reply __class__s r&r'zDBusConnection.__init__sW z*g &( {D1nn**, &q>r(c4tdd|jS)Nz@conn.router is deprecated, see the docs for APIs to use instead. stacklevel)r rr$s r&routerzDBusConnection.routers O ||r(NrXc|j||\}}|r|j||y|jj|y)z.Serialise and send a :class:`~.Message` objectN)rbrkrFri)r%rXr\rar]s r&sendzDBusConnection.sends;OOGV4 c    c * II  d #r(r=rYc6|jt|S)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. )rrr?)r%r>s r&receivezDBusConnection.receives}}09::r(c|j|}|jj||jj |D]}|j j |y)z\Receive one message and apply filters See :meth:`filter`. Returns nothing. r=N)rrincomingrmatchesqueueappend)r%r>rpfilters r& recv_messageszDBusConnection.recv_messagessV ll7l+ c"mm++C0 %F LL   $ %r()r>unwrapct|t|}|d}n tddt|j}|j || |j t|}|jjjtjd}||k(r|r t|S|S|jj||j j#|D]}|j$j'|)zSend a message, wait for the reply and return it Filters are applied to other messages received before the reply - see :meth:`add_filter`. FzePassing unwrap= to .send_and_get_reply() is deprecated and will break in a future version of Jeepney.rr)r\r=)rr?r r^rK send_messagerrCheaderfieldsgetr reply_serialrrrrrrr) r%rXr>rrBr\msg_inreply_tors r&send_and_get_replyz!DBusConnection.send_and_get_replys  &w/ >F >JK Md**+ '&1\\*=h*G\HF}}++// 0I0I2NH6!%f--  LL ! !& )--//7 , ##F+ ,r(r)rbufsizercL| t|}t|j||S)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&rzDBusConnection.filters& =)EDMM477r(ct|}t|dk(r*|jt|t|dk(r*|j S)aZProcess 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 rr=)r?rhrrCpopleft)r%rr>rBs r&recv_until_filteredz"DBusConnection.recv_until_filteredsI 'w/%jAo   ':8'D  E%jAo}}r(rr!)r6r7r8rer'propertyrr rrrrrrrrr __classcell__rs@r&rrs *V]] * $G$L!%;';(,%6:$,<7;A8Xe_8"59Wr(rc4eZdZdZddfd ZdZdZxZS)rajA 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 Nr=c@t||||_||_yr!)rr' _connection_timeout)r%msggen connectionr>rs r&r'zProxy.__init__s  % r(cz|jdnd|j}d|jd|j|dS)Nz , timeout=zProxy(z, ))r_msggenr)r%extras r&__repr__zProxy.__repr__ sA}},Z 3O ~R(8(8'9%BBr(cFtjfd}|S)Nc|jdj}|i|}|jjtj usJt jj||S)Nrr=) poprr message_typer method_callrrr)argskwargsr>rpmake_msgr%s r&innerz!Proxy._method_call..innersojjT]];GD+F+C::**k.E.EE EEd..AAWB r() functoolswraps)r%rrs`` r& _method_callzProxy._method_calls%  "  #  r()r6r7r8rr'rrrrs@r&rrs"7; C r(rcX|s'tttjt|S)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)rqs r&rvrvs" ":r{{:/FGG Hr(rYc &tjtjt|fd} |j|t |}|D]@}|j ||j t|jdB|j tjdS#tj$r%}jtd|d|d}~wjxYw)z=Create a socket and authenticate ready to send D-Bus messages)familycBjt||Sr!) settimeoutrC)methrrBrFs r&with_sock_deadlinez'prep_socket..with_sock_deadline1s +H56T{r()rIizDid not authenticate in z secondsN)reAF_UNIXr?connectrrifeedrvrwrr>rSrxr) addrrIr>rauthrreq_dataerBrFs @@r& prep_socketr)s == /D #7+H 4<<.4 IH t||X 6 JJ{#5dii#FG H I 4<</ OOD K >>P 5gYhGHaO  sA;CD C::DcPt|}t|||}t||}|S)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. r=)rrr)busrI auth_timeoutbus_addrrFconns r&rrGs,s|H x\ BD $ +D Kr(__main__z Unique name:)Fg@)SESSIONFg?)9rr_ collectionsrerrnorr itertoolsrr selectorsrrrer;typingrwarningsr jeepneyr r r r jeepney.authrr jeepney.busr jeepney.fdsrrjeepney.wrappersrrjeepney.routingrjeepney.bus_messagesrcommonrrr__all__rr?rCrErrrvrrr6rprintrOr9r(r&rs  1 >>-42",AA (  @@Fr'rj%I%P  >79* z  !D .$**+r(