.Ph ddlmZddlmZddlmZmZmZmZGddZ GddZ Gdd Z Gd d e Z d efd ZdS))contextmanager)count) HeaderFieldsMessage MessageFlag MessageTypeceZdZdZdZdS)MessageFiltersc:i|_t|_dSN)filtersr filter_idsselfs Q/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/jeepney/io/common.py__init__zMessageFilters.__init__s ''c#~K|jD] }|j|r|V!dSr )r valuesrulematches)rmessagehandles rrzMessageFilters.matches sOl))++  F{""7++    rN)__name__ __module__ __qualname__rrrrr r s2"""rr c,eZdZdefdZdZdZdZdS) FilterHandler c||_t|j|_||_||_||jj|j<dSr )_filtersnextr _filter_idrqueuer )rr rr$s rrzFilterHandle.__init__s@ w122  15 do...rc*|jj|j=dSr )r!r r#rs rclosezFilterHandle.closes M !$/ 2 2 2rc|jSr )r$rs r __enter__zFilterHandle.__enter__s zrc.|dS)NF)r&)rexc_typeexc_valexc_tbs r__exit__zFilterHandle.__exit__ s urN)rrrr rr&r(r-rrrrrs\66666333rrc>eZdZdZedZdZddefdZdS) ReplyMatcherci|_dSr _futuresrs rrzReplyMatcher.__init__&s  rc#RK||j|< |V|j|=dS#|j|=wxYw)z>Context manager to capture a reply for the given serial numberNr1)rserialfutures rcatchzReplyMatcher.catch)sH!' f &LLL f%%% f% % % % %s &c|jjtjd}||jvr"|j||dSdS)zDispatch an incoming message which may be a reply Returns True if a task was waiting for it, otherwise False. TF)headerfieldsgetr reply_serialr2 set_result)rmsg rep_serials rdispatchzReplyMatcher.dispatch3sS Z&**<+DbII  & & M* % 0 0 5 5 545rNexcc|td}|jic}|_|D]}||dS)z4Throw an error in any task still waiting for a replyNz(D-Bus router closed before reply arrived) RouterClosedr2r set_exception)rrAfuturesfuts rdrop_allzReplyMatcher.drop_all?s_ ;IJJC!%>>## # #C   c " " " " # #rr ) rrrrrr6r@ ExceptionrGrrrr/r/%sm&&^&   ##I######rr/ceZdZdZdS)rCaRaised in tasks waiting for a reply when the router is closed This will also be raised if the receiver task crashes, so tasks are not stuck waiting for a reply that can never come. The router object will not be usable after this is raised. N)rrr__doc__rrrrCrCHs  DrrCr>c|jjtjkrt d|jjdt j|jjzrtddS)z4Raise an error if we wouldn't expect a reply for msgz,Only method call messages have replies (not )z/This message has the no_reply_expected flag setN) r9 message_typer method_call TypeErrorrno_reply_expectedflags ValueError)r>s rcheck_replyablerSRst z+"999; # 7;;;<< <$sz'77LJKKKLLrN) contextlibr itertoolsrjeepneyrrrrr rr/rHrCrSrrrrWs%%%%%%CCCCCCCCCCCC( # # # # # # # #F     9   LLLLLLLr