U [e.@sdZddlZddlmZddlmZddlZddlmZddl Z ddl m Z m Z ddl Z ddlZddlmZddlmZmZmZmZdd lmZmZdd lmZdd lmZmZdd lmZm Z dd l!m"Z"ddl#m$Z$ddl%m&Z&m'Z'm(Z(dddgZ)GdddZ*ddZ+ddZ,GdddZ-Gddde-Z.GdddeZ/ddZ0d*e j d"d#d$Z1d+e.d"d'dZ2e3d(kre2Z4e5d)e4j6dS),z'Synchronous IO wrappers around jeepney N)deque) ECONNRESET)count)DefaultSelector EVENT_READ)Optional)ParserMessage MessageType HeaderFields) AuthenticatorBEGIN)get_bus)FileDescriptor fds_buf_size) ProxyBase unwrap_msg)Router) message_bus)MessageFilters FilterHandlecheck_replyableopen_dbus_connectionDBusConnectionProxyc@s4eZdZddZddZddZddZd d Zd S) _FuturecCs d|_dSN_resultselfr"U/var/www/html/services/stratfitenv/lib/python3.8/site-packages/jeepney/io/blocking.py__init__sz_Future.__init__cCs t|jSr)boolrr r"r"r#done"sz _Future.donecCsd|f|_dSNFr)r! exceptionr"r"r# set_exception%sz_Future.set_exceptioncCsd|f|_dS)NTr)r!resultr"r"r# set_result(sz_Future.set_resultcCs|j\}}|r|S|dSrr)r!successvaluer"r"r#r*+s z_Future.resultN)__name__ __module__ __qualname__r$r&r)r+r*r"r"r"r#rs rcCs|dk rt|SdSr)time monotonictimeoutr"r"r#timeout_to_deadline2s r5cCs|dk rt|tdSdS)Ng)maxr1r2)deadliner"r"r#deadline_to_timeout7sr8c@sveZdZdZdejdddZddZdd Zee e e j fd d d Z d dZ ddZdddZddZddZdS)DBusConnectionBasez8Connection machinery shared by this module and threadingFsockcCsB||_||_t|_tdd|_t|_|j|t |_ d|_ dS)Nr)start) r; enable_fdsrparserroutgoing_serialrselectorregisterr select_key unique_name)r!r;r=r"r"r#r$?s zDBusConnectionBase.__init__cCs|Srr"r r"r"r# __enter__HszDBusConnectionBase.__enter__cCs |dSr')close)r!exc_typeexc_valexc_tbr"r"r#__exit__KszDBusConnectionBase.__exit__)messagereturncCs<|dkrt|j}|jr"tdnd}|j||d}||fS)Ni)serialfds)nextr?r=arrayZ serialise)r!rJrMrNdatar"r"r# _serialiseOs  zDBusConnectionBase._serialisecCs@|j|gtjtj|fg}|t|kr<|j||ddSr)r;sendmsgsocket SOL_SOCKET SCM_RIGHTSlensendall)r!rQrNZ bytes_sentr"r"r#_send_with_fdsVs  z!DBusConnectionBase._send_with_fdscCs@|j}|dk r|S|jt|d\}}|jj||dqdS)Nr3)rN)r>Zget_next_message_read_some_datar8Zadd_data)r!r7msgbrNr"r"r#_receive_s  zDBusConnectionBase._receiveNcCsR|j|D]<\}}||jkr |jr0|St|jdgfSq tdS)Ni) r@selectrBr=_read_with_fds unwrap_readr;recv TimeoutError)r!r4keyZevr"r"r#rZhs   z"DBusConnectionBase._read_some_datacCsT|j}|j|t\}}}}|ttdd@rB|tdt |t |fS)N MSG_CTRUNCrz&Unable to receive all file descriptors) r>Z bytes_desiredr;recvmsgrgetattrrTrE RuntimeErrorr`rZ from_ancdata)r!nbytesrQZancdataflags_r"r"r#r_rs  z!DBusConnectionBase._read_with_fdscCs|j|jdS)zClose the connectionN)r@rEr;r r"r"r#rEzs zDBusConnectionBase.close)F)N)r.r/r0__doc__rTr$rDrIr bytesrrPrRrYr]rZr_rEr"r"r"r#r9=s   r9cseZdZdejdfdd ZdedddZeZdd ed d d Zdd d dZ dddddZ ddde e dddZ dd ed ddZZS)rFr:csJt||d|_tt|_t|_tt ||_ |j }|d|_ dS)NFr) superr$ _unwrap_replyrrrouterr_filtersrrZ bus_proxyZHellorC)r!r;r=Z hello_reply __class__r"r#r$s   zDBusConnection.__init__N)rJcCs2|||\}}|r"|||n |j|dS)z.Serialise and send a :class:`~.Message` objectN)rRrYr;rX)r!rJrMrQrNr"r"r#sendszDBusConnection.sendr3rKcCs|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. )r]r5)r!r4r"r"r#receiveszDBusConnection.receivecCs:|j|d}|j||j|D]}|j|q$dS)z\Receive one message and apply filters See :meth:`filter`. Returns nothing. r3N)ruroincomingrpmatchesqueueappend)r!r4r[filterr"r"r# recv_messagess  zDBusConnection.recv_messagesr4unwrapc Cst|t|}|dkr|j}t|j}|j||d|jt|d}|jj t j d}||krp|rlt |S|S|j||j|D]}|j|qq6dS)zSend a message, wait for the reply and return it Filters are applied to other messages received before the reply - see :meth:`add_filter`. N)rMr3)rr5rnrOr? send_messagerur8headerfieldsgetr Z reply_serialrrorvrprwrxry) r!rJr4r}r7rMZmsg_inZreply_torzr"r"r#send_and_get_replys  z!DBusConnection.send_and_get_replyr)rxbufsize)rxcCs |dkrt|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)rrrp)r!rulerxrr"r"r#rzs  zDBusConnection.filtercCs.t|}t|dkr&|jt|dq|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 rr3)r5rWr{r8popleft)r!rxr4r7r"r"r#recv_until_filtereds z"DBusConnection.recv_until_filtered)F)N)r.r/r0rTr$r rsrrur{rrrrzr __classcell__r"r"rqr#rs   cs6eZdZdZddfdd 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 Nr3cst|||_||_dSr)rmr$ _connection_timeout)r!Zmsggen connectionr4rqr"r#r$s zProxy.__init__cCs4|jdkrdn d|j}d|jd|j|dS)Nz , timeout=zProxy(z, ))rZ_msggenr)r!extrar"r"r#__repr__szProxy.__repr__cstfdd}|S)Ncs<|dj}||}|jjtjks*tjj||ddS)NrTr|) poprrZ message_typer method_callAssertionErrorrr)argskwargsr4r[make_msgr!r"r#inner s z!Proxy._method_call..inner) functoolswraps)r!rrr"rr# _method_callszProxy._method_call)r.r/r0rkr$rrrr"r"rqr#rscCs|stttt|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)r\r"r"r#r`sr`F@rtc stjtjdt|fdd}zR|j|t|d}|D]&}|j||t|jdq@|jt WnRtj k r}z t d|d|W5d}~XYn YnX dS) z=Create a socket and authenticate ready to send D-Bus messages)familycst||Sr) settimeoutr8)methrr7r;r"r#with_sock_deadline(sz'prep_socket..with_sock_deadline)r=izDid not authenticate in z secondsN)rTAF_UNIXr5connectr rXfeedr`rar r4rErbr)addrr=r4rZauthrZreq_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. r3)rrr)busr=Z auth_timeoutZbus_addrr;connr"r"r#r>s __main__z Unique name:)Fr)rFr)7rkrP collectionsrerrnorr itertoolsrr selectorsrrrTr1typingrZjeepneyrr r r Z jeepney.authr r Z jeepney.busrZ jeepney.fdsrrZjeepney.wrappersrrZjeepney.routingrZjeepney.bus_messagesrcommonrrr__all__rr5r8r9rrr`rrr.rprintrCr"r"r"r#sN       Cm(