ó ¾?Tc@s%dZddlZddlZddlZddlZddlmZddlmZddlm Z ddl m Z m Z m Z mZde fd„ƒYZd efd „ƒYZd „Zd „Zd efd„ƒYZedd„Zejddƒd„ƒZejd„ƒZd„ZdS(spy.test configiÿÿÿÿN(tsleep(tdeque(tTIMEOUT(thandlert BaseComponenttDebuggertManagertWatchercBsGeZd„Zeddddƒd„ƒZd„Zd dd„ZRS( cCstjƒ|_tƒ|_dS(N(t threadingtLockt_lockRtevents(tself((s./home/prologic/work/circuits/tests/conftest.pytinitstchannelt*tpriorityg33333?@cOs$|j|jj|ƒWdQXdS(N(R R tappend(R teventtargstkwargs((s./home/prologic/work/circuits/tests/conftest.pyt _on_events cCs|jjƒdS(N(R tclear(R ((s./home/prologic/work/circuits/tests/conftest.pyRsg@cCsÃz»x´tt|tƒƒD]œ}|dkrf|j,x$|jD]}|j|kr@tSq@WWdQXnF|j;x3|jD](}|j|krz||jkrztSqzWWdQXt tƒqWWdXdS(N( trangetintRtNoneR R tnametTruetchannelsR(R RRttimeouttiR((s./home/prologic/work/circuits/tests/conftest.pytwait!s   N(t__name__t __module__R RRRRR(((s./home/prologic/work/circuits/tests/conftest.pyRs  tFlagcBseZeZRS((R R!tFalsetstatus(((s./home/prologic/work/circuits/tests/conftest.pyR"6scGsUt}d}xB|j|ƒD]1}|sCt}|j||Œ}ntdƒqW|S(Ngš™™™™™¹?(R#Rt waitEventRtfireR(tmanagerRt event_nameRtfiredtvaluetr((s./home/prologic/work/circuits/tests/conftest.pytcall_event_from_name:scGst|||j|ŒS(N(R,R(R'RR((s./home/prologic/work/circuits/tests/conftest.pyt call_eventEst WaitEventcBs eZddd„Zd„ZRS(g@cs|dkr!t|ddƒ}n||_||_tƒ‰t|d|ƒ‡fd†ƒ}|jj|ƒ|_ˆ|_dS(NRcs tˆ_dS(N(RR$(R RR(tflag(s./home/prologic/work/circuits/tests/conftest.pyton_eventTs(RtgetattrRR'R"Rt addHandlerR/(R R'RRRR0((R/s./home/prologic/work/circuits/tests/conftest.pyt__init__Ks    !cCs]zBx;tt|jtƒƒD] }|jjr3tSttƒqWWd|jj |j ƒXdS(N( RRRRR/R$RRR't removeHandlerR(R R((s./home/prologic/work/circuits/tests/conftest.pyR[s   N(R R!RR3R(((s./home/prologic/work/circuits/tests/conftest.pyR.Isg@cCs€ddlm}xitt||ƒƒD]Q}t|tjƒrU|||ƒrntSnt||ƒ|krntSt |ƒq'WdS(Niÿÿÿÿ(R( tcircuits.core.managerRRRt isinstancet collectionstCallableRR1R(tobjtattrR*RRR((s./home/prologic/work/circuits/tests/conftest.pytwait_forestscopetsessioncsˆtƒ‰‡fd†}|j|ƒtˆdƒ}ˆjƒ|jƒsPt‚|jjjrht }nt }t d|ƒj ˆƒˆS(NcsˆjƒdS(N(tstop((R'(s./home/prologic/work/circuits/tests/conftest.pyt finalizertststartedR ( Rt addfinalizerR.tstartRtAssertionErrortconfigtoptiontverboseRR#Rtregister(trequestR?twaiterRF((R's./home/prologic/work/circuits/tests/conftest.pyR'ps    cs5tƒjˆƒ‰‡‡fd†}|j|ƒˆS(Ncs'tˆdƒ}ˆjƒ|jƒdS(Nt unregistered(R.t unregisterR(RI(R'twatcher(s./home/prologic/work/circuits/tests/conftest.pyR?‹s (RRGRA(RHR'R?((R'RLs./home/prologic/work/circuits/tests/conftest.pyRL‡s cCsJtdtfdtfdtfdtjfdtjd fdtffƒS(NR.R;R-tPLATFORMtPYVERiR,(tdictR.R;R-tsystplatformt version_infoR,(((s./home/prologic/work/circuits/tests/conftest.pytpytest_namespace•s    (t__doc__tpytestRPRR7ttimeRRR5RtcircuitsRRRRRtobjectR"R,R-R.RR;tfixtureR'RLRS(((s./home/prologic/work/circuits/tests/conftest.pyts"    "#