+c ddlmZddlmZddlmZmZmZmZGddZ GddZ Gdd Z Gd d e Z d efd Zy))contextmanager)count) HeaderFieldsMessage MessageFlag MessageTypeceZdZdZdZy)MessageFiltersc0i|_t|_yN)filtersr filter_idsselfs 3/usr/lib/python3/dist-packages/jeepney/io/common.py__init__zMessageFilters.__init__s 'c#K|jjD]"}|jj|s|$ywr )r valuesrulematches)rmessagehandles rrzMessageFilters.matches s9ll))+ F{{""7+  s 9AAN)__name__ __module__ __qualname__rrrrr r s "rr c*eZdZdefdZdZdZdZy) FilterHandler c||_t|j|_||_||_||jj |j<yr )_filtersnextr _filter_idrqueuer )rr rr$s rrzFilterHandle.__init__sA w112  15 doo.rcF|jj|j=yr )r!r r#rs rclosezFilterHandle.closes MM ! !$// 2rc|jSr )r$rs r __enter__zFilterHandle.__enter__s zzrc$|jy)NF)r&)rexc_typeexc_valexc_tbs r__exit__zFilterHandle.__exit__ s rN)rrrr rr&r(r-rrrrrs663rrc6eZdZdZedZdZddefdZy) ReplyMatcherci|_yr _futuresrs rrzReplyMatcher.__init__&s  rc#rK||j|< ||j|=y#|j|=wxYww)z>Context manager to capture a reply for the given serial numberNr1)rserialfutures rcatchzReplyMatcher.catch)s8!' f &L f% f%s7%747c|jjjtjd}||j vr|j |j |yy)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.dispatch3sO ZZ&&**<+D+DbI  & MM* % 0 0 5rNexcc| td}|jic}|_|jD]}|j|y)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?sH ;IJC!%>># #C   c " #rr ) rrrrrr6r@ ExceptionrGrrrr/r/%s,&& #I#rr/ceZdZdZy)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   rrCr>c|jjtjk7r#t d|jjdt j |jjzr tdy)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_replyablerSRsl zz+"9"99 # 7 78;< <$$szz'7'77JKK8rN) contextlibr itertoolsrjeepneyrrrrr rr/rHrCrSrrrrWsJ%CC( # #F 9 LLr