o }h0@sdZddlZddlmZddlmZddlZddlmZddl 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+GdddZ,ddZ-ddZ.GdddZ/Gddde/Z0Gddde!Z1dd Z2d,d#e j fd$d%Z3 'd-d#e0fd(d)Z4e5d*kre4Z6e7d+e6j8dSdS).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@s4eZdZddZddZddZddZd d Zd S) _FuturecCs d|_dSN_resultselfr#E/var/www/html/env/lib/python3.10/site-packages/jeepney/io/blocking.py__init__  z_Future.__init__cCs t|jSr)boolr r!r#r#r$done#r&z _Future.donecCd|f|_dSNFr)r" exceptionr#r#r$ set_exception&z_Future.set_exceptioncCr))NTr)r"resultr#r#r$ set_result)r-z_Future.set_resultcCs|j\}}|r |S|rr)r"successvaluer#r#r$r.,s z_Future.resultN)__name__ __module__ __qualname__r%r(r,r/r.r#r#r#r$rs  rcCs|dur t|SdSr)time monotonictimeoutr#r#r$timeout_to_deadline3s r9cCs|dur t|tdSdS)Ng)maxr5r6)deadliner#r#r$deadline_to_timeout8sr<c@sxeZdZdZddejfddZddZdd Zd ed e e e j ffd d Z ddZ ddZdddZddZddZdS)DBusConnectionBasez8Connection machinery shared by this module and threadingFsockcCsB||_||_t|_tdd|_t|_|j|t |_ d|_ dS)Nr)start) r> enable_fdsr parserroutgoing_serialrselectorregisterr select_key unique_name)r"r>r@r#r#r$r%@s  zDBusConnectionBase.__init__cCs|Srr#r!r#r#r$ __enter__IszDBusConnectionBase.__enter__cCs |dSr*)close)r"exc_typeexc_valexc_tbr#r#r$__exit__LszDBusConnectionBase.__exit__messagereturncCs<|dur t|j}|jrtdnd}|j||d}||fS)Ni)serialfds)nextrBr@array serialise)r"rMrPrQdatar#r#r$ _serialisePs  zDBusConnectionBase._serialisecCsD|j|gtjtj|fg}|t|kr |j||ddSdSr)r>sendmsgsocket SOL_SOCKET SCM_RIGHTSlensendall)r"rUrQ bytes_sentr#r#r$_send_with_fdsWs  z!DBusConnectionBase._send_with_fdscCs> |j}|dur |S|jt|d\}}|jj||dq)NTr7)rQ)rAget_next_message_read_some_datar<add_data)r"r;msgbrQr#r#r$_receive`s zDBusConnectionBase._receiveNcCsN|j|D]\}}||jkr$|jr|St|jdgfSqt)Ni) rCselectrEr@_read_with_fds unwrap_readr>recv TimeoutError)r"r8keyevr#r#r$r`is  z"DBusConnectionBase._read_some_datacCsT|j}|j|t\}}}}|ttdd@r!|tdt |t |fS)N MSG_CTRUNCrz&Unable to receive all file descriptors) rA bytes_desiredr>recvmsgrgetattrrXrH RuntimeErrorrgr from_ancdata)r"nbytesrUancdataflags_r#r#r$rfss z!DBusConnectionBase._read_with_fdscCs|j|jdS)zClose the connectionN)rCrHr>r!r#r#r$rH{s zDBusConnectionBase.closeFr)r2r3r4__doc__rXr%rGrLr bytesrrSrVr^rdr`rfrHr#r#r#r$r=>s   r=cseZdZddejffdd ZeddZddefd d ZeZ dd d efd dZ dd ddZ dddddZ dddde efddZdd d efddZZS)rFr>csDt||tt|_t|_tt||_ |j }|d|_ dS)Nr) superr%rr_routerr_filtersrr bus_proxyHellorF)r"r>r@ hello_reply __class__r#r$r%s    zDBusConnection.__init__cCstddd|jS)Nz@conn.router is deprecated, see the docs for APIs to use instead. stacklevel)rrzr!r#r#r$routerszDBusConnection.routerNrMcCs4|||\}}|r|||dS|j|dS)z.Serialise and send a :class:`~.Message` objectN)rVr^r>r\)r"rMrPrUrQr#r#r$sendszDBusConnection.sendr7rNcCs|t|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. )rdr9)r"r8r#r#r$receiveszDBusConnection.receivecCs:|j|d}|j||j|D]}|j|qdS)z\Receive one message and apply filters See :meth:`filter`. Returns nothing. r7N)rrzincomingr{matchesqueueappend)r"r8rbfilterr#r#r$ recv_messagess  zDBusConnection.recv_messages)r8unwrapc Cst|t|}|durd}ntdddt|j}|j||d |jt|d}|jj t j d }||kr?|r=t |S|S|j||j|D]}|j|qKq") zSend a message, wait for the reply and return it Filters are applied to other messages received before the reply - see :meth:`add_filter`. NFzePassing unwrap= to .send_and_get_reply() is deprecated and will break in a future version of Jeepney.rr)rPTr7)rr9rrRrB send_messagerr<headerfieldsgetr reply_serialrrzrr{rrr) r"rMr8rr;rPmsg_inreply_torr#r#r$send_and_get_replys(  z!DBusConnection.send_and_get_replyr)rbufsizercCs |dur t|d}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 N)maxlen)rrr{)r"rulerrr#r#r$rs zDBusConnection.filtercCs8t|}t|dkr|jt|dt|dks |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 rr7)r9r[rr<popleft)r"rr8r;r#r#r$recv_until_filtereds   z"DBusConnection.recv_until_filteredrvr)r2r3r4rXr%propertyrr rrrrrrrrr __classcell__r#r#rr$rs   rcs6eZdZdZddfdd ZddZdd ZZS) 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 Nr7cst|||_||_dSr)ryr% _connection_timeout)r"msggen connectionr8rr#r$r%s  zProxy.__init__cCs4|jdurdnd|j}d|jd|j|dS)Nz , timeout=zProxy(z, ))r_msggenr)r"extrar#r#r$__repr__ szProxy.__repr__cstfdd}|S)NcsB|dj}|i|}|jjtjusJtjj||dS)Nrr7) poprr message_typer method_callrrr)argskwargsr8rbmake_msgr"r#r$inners z!Proxy._method_call..inner) functoolswraps)r"rrr#rr$ _method_callszProxy._method_call)r2r3r4rwr%rrrr#r#rr$rs rcCs|s tttt|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)rcr#r#r$rgsrgF@rNc stjtjdt|fdd}z)|j|t|d}|D]}|j||t|jdq |jt Wn!tj yU}z  t d|d|d}~w  dS) z=Create a socket and authenticate ready to send D-Bus messages)familycst||Sr) settimeoutr<)methrr;r>r#r$with_sock_deadline1sz'prep_socket..with_sock_deadline)r@izDid not authenticate in z secondsN)rXAF_UNIXr9connectr r\feedrgrhrr8rHrir)addrr@r8rauthrreq_dataer#rr$ prep_socket)s&    rSESSION?cCs$t|}t|||d}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. r7)rrr)busr@ auth_timeoutbus_addrr>connr#r#r$rGs r__main__z Unique name:)Fr)rFr)9rwrS collectionsrerrnorr itertoolsrr selectorsrrrXr5typingrwarningsrjeepneyr r r r jeepney.authr r jeepney.busr jeepney.fdsrrjeepney.wrappersrrjeepney.routingrjeepney.bus_messagesrcommonrrr__all__rr9r<r=rrrgrrr2rprintrFr#r#r#r$sJ        Cu(