U [e @s|ddlmZddlmZddlmZmZmZmZGdddZ GdddZ Gdd d Z Gd d d e Z ed d dZdS))contextmanager)count) HeaderFieldsMessage MessageFlag MessageTypec@seZdZddZddZdS)MessageFilterscCsi|_t|_dSN)filtersr filter_idsselfrS/var/www/html/services/stratfitenv/lib/python3.8/site-packages/jeepney/io/common.py__init__szMessageFilters.__init__ccs&|jD]}|j|r |Vq dSr )r valuesrulematches)r messagehandlerrrr s zMessageFilters.matchesN)__name__ __module__ __qualname__rrrrrrrsrc@s2eZdZedddZddZddZdd Zd S) FilterHandle)r cCs0||_t|j|_||_||_||jj|j<dSr )_filtersnextr _filter_idrqueuer )r r rrrrrrs  zFilterHandle.__init__cCs|jj|j=dSr )rr rr rrrcloseszFilterHandle.closecCs|jSr )rr rrr __enter__szFilterHandle.__enter__cCs |dS)NF)r)r exc_typeexc_valexc_tbrrr__exit__ szFilterHandle.__exit__N)rrrrrrrr#rrrrrsrc@s8eZdZddZeddZddZd edd d ZdS) ReplyMatchercCs i|_dSr _futuresr rrrr&szReplyMatcher.__init__ccs$||j|<z |VW5|j|=XdS)z>Context manager to capture a reply for the given serial numberNr%)r serialfuturerrrcatch)s  zReplyMatcher.catchcCs8|jjtjd}||jkr0|j||dSdSdS)zDispatch an incoming message which may be a reply Returns True if a task was waiting for it, otherwise False. TFN)headerfieldsgetrZ reply_serialr& set_result)r msgZ rep_serialrrrdispatch3s  zReplyMatcher.dispatchN)exccCs:|dkrtd}|ji}|_|D]}||q&dS)z4Throw an error in any task still waiting for a replyNz(D-Bus router closed before reply arrived) RouterClosedr&r set_exception)r r1futuresfutrrrdrop_all?s  zReplyMatcher.drop_all)N) rrrrrr)r0 Exceptionr6rrrrr$%s   r$c@seZdZdZdS)r2aRaised 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__rrrrr2Hsr2r/cCs<|jjtjkr"td|jjdtj|jj@r8tddS)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) r+Z message_typer method_call TypeErrorrZno_reply_expectedflags ValueErrorr9rrrcheck_replyableRsr?N) contextlibr itertoolsrZjeepneyrrrrrrr$r7r2r?rrrrs   #