+ >a.Rt^RIt^RIHt^RIHt^RIt^RIHt^RI t ^RI H t H t ^RI t ^RIt^RIHt^RIHtHtHtHt^RIHtHt^R IHt^R IHtHt^R IHtH t ^R I!H"t"^R I#H$t$^RI%H&t&H't'H(t(.R Ot)!RR4t*Rt+Rt,!RR4t-!RR]-4t.!RR]4t/Rt0R!RRllt1R"RRllt2]3R8Xd]2!4t4]5!R]4Pl4R#R#)#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_replyableDBusConnectionProxyc>a]tRt^toRtRtRtRtRtRt Vt R#)_FuturecRVnR#N_resultselfs&3lib/python3.14/site-packages/jeepney/io/blocking.py__init___Future.__init__s  c,\VP4#r)boolrr s&r"done _Future.done"sDLL!!r%cRV3VnR#FNr)r! exceptions&&r" set_exception_Future.set_exception%sy) r%cRV3VnR#)TNr)r!results&&r" set_result_Future.set_result(s f~ r%c6VPwrV'dV#Vhrr)r!successvalues& r"r0_Future.result+s L r%rN) __name__ __module__ __qualname____firstlineno__r#r(r-r1r0__static_attributes____classdictcell__ __classdict__s@r"rrs#"*&r%rcFVe\P!4V,#R#r)time monotonictimeouts&r"timeout_to_deadlinerD2s~~')) r%cZVe'\V\P!4, R4#R#)Ng)maxr@rA)deadlines&r"deadline_to_timeoutrH7s$8dnn..33 r%cza]tRt^=toRtRV3RlRlltRtRtV3RlRltRt R t RR lt R t R t RtVtR #)DBusConnectionBasez8Connection machinery shared by this module and threadingc4<V^8dQhRS[P/#socksocket)formatr>s"r" __annotate__DBusConnectionBase.__annotate__?s  V]] r%cWnW n\4Vn\ ^R7Vn\ 4VnVPPV\4Vn RVn R#))startN) rN enable_fdsrparserroutgoing_serialrselectorregisterr select_key unique_name)r!rNrWs&&&r"r#DBusConnectionBase.__init__?sK $h $1~') --00zBr%cV#rr s&r" __enter__DBusConnectionBase.__enter__Hs r%c&VP4R#F)close)r!exc_typeexc_valexc_tbs&&&&r"__exit__DBusConnectionBase.__exit__Ks r%cP<V^8dQhRS[RS[S[S[P,3/#)rMmessagereturn)r bytesrarray)rQr>s"r"rRrSOs)'uhu{{>S6Tr%cVf\VP4pVP'd\P!R4MRpVP W#R7pWC3#)Ni)serialfds)nextrYrWro serialise)r!rlrrrsdatas&&& r" _serialiseDBusConnectionBase._serialiseOsJ >$../F"&///ekk#t   8yr%cVPPV.\P\PV3.4pV\ V48d VPP WR4R#R#r)rNsendmsgrP SOL_SOCKET SCM_RIGHTSlensendall)r!rvrs bytes_sents&&& r"_send_with_fds!DBusConnectionBase._send_with_fdsVs]YY&& Ff''):):C@A D ! II  d;/ 0 "r%cVPP4pVeV#VP\V4R7wr4VPP W4R7K\)TrB)rs)rXget_next_message_read_some_datarHadd_data)r!rGmsgbrss&& r"_receiveDBusConnectionBase._receive_sQ++..0C ))2Eh2O)PFA KK  ,r%NcVPPV4Fawr#W P8XgKVP'dVP 4u#\ VP PR44.3u# \h)i) rZselectr\rW_read_with_fds unwrap_readrNrecv TimeoutError)r!rCkeyevs&& r"r"DBusConnectionBase._read_some_datahsd}}++G4GCoo%???..00&tyy~~d';s"r"rRDBusConnection.__annotate__s * *V]] *r%c<\SV`W4RVn\\4Vn\ 4Vn\\V4Vn VPP4pV^,Vn R#r+) superr# _unwrap_replyrrrouterr_filtersrr bus_proxyHellor])r!rNrW hello_reply __class__s&&& r"r#DBusConnection.__init__s] *"Wo &( {D1nn**, &q>r%Nc <V^8dQhRS[/#)rMrlr )rQr>s"r"rRrs$$G$r%c VPW4wr4V'dVPW44R#VPPV4R#)z.Serialise and send a :class:`~.Message` objectN)rwrrNr~)r!rlrrrvrss&&& r"sendDBusConnection.sends5OOG4      * II  d #r%rCc <V^8dQhRS[/#rMrmr)rQr>s"r"rRrs;;';r%c 6VP\V44#)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. )rrD)r!rCs&$r"receiveDBusConnection.receives}}09::r%c VPVR7pVPPV4VPP V4FpVP P V4K R#)zLReceive one message and apply filters See :meth:`filter`. Returns nothing. rBN)rrincomingrmatchesqueueappend)r!rCrfilters&$ r" recv_messagesDBusConnection.recv_messagessQ ll7l+ S!mm++C0F LL   $1r%unwrapc &\V4\V4pVf VPp\VP4pVP WR7VP \V4R7pVPPP\PR4pWu8XdV'd \V4#V#VPPV4VP P#V4FpVP$P'V4K K)zSend a message, wait for the reply and return it Filters are applied to other messages received before the reply - see :meth:`add_filter`. )rrrB)rrDrrtrY send_messagerrHheaderfieldsgetr reply_serialrrrrrrr) r!rlrCrrGrrmsg_inreply_tors &&$$ r"send_and_get_reply!DBusConnection.send_and_get_replys  &w/ >''Fd**+ '1\\*=h*G\HF}}++// 0I0I2NH!%f--  KK  (--//7 ##F+8r%rbufsizec0<V^8dQhRS[S[,/#)rMr)rr)rQr>s"r"rRrs88Xe_8r%c NVf \VR7p\VPW4#)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"rDBusConnection.filters$ =)EDMM477r%c <V^8dQhRS[/#rr)rQr>s"r"rRrsWr%c \V4p\V4^8XdVP\V4R7K-VP 4#)a Process 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 rB)rDr}rrHpopleft)r!rrCrGs&&$ r"recv_until_filtered"DBusConnection.recv_until_filtereds< 'w/%jAo   ':8'D  E}}r%)rrrrr]rdr)r7r8r9r:r#rrrrrrrr;r< __classcell__rr>s@@r"rrs~ * *$$L;;;%t%,T,$,68d8A88"Dr%cJaa]tRt^toRtRR/V3RlltRtRtRtVt V;t #)ra6A 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 rCNc><\SV`V4W nW0nR#r)rr# _connection_timeout)r!msggen connectionrCrs&&&$r"r#Proxy.__init__s  % r%c~VPfRMRVP 2pRVP RVP V R2#)Nz , timeout=zProxy(z, ))r_msggenr)r!extras& r"__repr__Proxy.__repr__sA}},Z 3O ~R(8(8'9%BBr%cJaa\P!S4VV3Rl4pV#)c<VPRSP4pS!V/VBpVPP\P JgQhSP PW2RR7#)rT)rCr)poprr message_typer method_callrr)argskwargsrCrmake_msgr!s*, r"inner!Proxy._method_call..inner sgjjT]];GD+F+C::**k.E.EE EE##66T7 r%) functoolswraps)r!rrsff r" _method_callProxy._method_calls%  "  #  r%)rr) r7r8r9r:rr#rrr;r<rrs@@r"rrs&" d C  r%cfV'g)\\\P!\44hV#)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)rs&r"rrs" ":r{{:/FGG Hr%c8V^8dQhR\P/#rrO)rQs"r"rRrR s r%c 2aa\P!\PR7o\V4oVV3RlpV!SPV4\ VR7pVFApV!SP V4VP \V!SPR444KC V!SP \4SPR4S# \Pd&pSP4\RT R24ThRp?iSP4h;i)z=Create a socket and authenticate ready to send D-Bus messages)familycD<SP\S44V!V!#r) settimeoutrH)methrrGrNs&*r"with_sock_deadline'prep_socket..with_sock_deadline(s +H56T{r%)rWizDid not authenticate in z secondsN)rPAF_UNIXrDconnectr r~feedrrr rCrerr) addrrWrCrauthrreq_dataerGrNs &&& @@r" prep_socketr  s == /D #7+H 4<<.4H t||X 6 JJ{#5dii#FG H 4<</ OOD K >>P 5gYhGHaO  sA=C D DDc$V^8dQhR\/#r)r)rQs"r"rRrR>sr%cL\V4p\W1VR7p\WA4pV#)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. rB)rr r)busrW auth_timeoutbus_addrrNconns&&& r"open_dbus_connectionr>s(s|H x\ BD $ +D Kr%__main__z Unique name:)rrr)Fg@)SESSIONFg?)7rro collectionsrerrnorr itertoolsrr selectorsrrrPr@typingrjeepneyrr r r jeepney.authr r jeepney.busr jeepney.fdsrrjeepney.wrappersrrjeepney.routingrjeepney.bus_messagesrcommonrrr__all__rrDrHrJrrrr rr7rprintr]r`r%r"r"s  1 >>-42",AA (  @@Fj'jZ%I%P <* z  !D .$**+r%