Ñò áJœOc @sÆddklZddklZddklZdZdefd„ƒYZd„Zd„Z eƒZ e i Z e i Z defd„ƒYZeZd„ZeƒZd„ZeiZeiZdS(iÿÿÿÿ(tdeque(t Condition(ttimetsendertreceivet interrupttZNoticetrealmt Subscriptionstinitt getVariablet setVariablet unsetVariabletSimpleBlockingQueuecBs/eZd„Zd„Zed„Zd„ZRS(cCs%tƒ|_tƒ|_t|_dS(N(RtitemsRt conditiontFalset interrupted(tself((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyt__init__s  cCs/|iiiƒz|ii|ƒWdQXdS(N(Rt__exit__t __enter__Rtpushleft(Rtitem((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pytput scCs}|iiiƒzb|o;xG|ip)|iiƒ|iot|_dSqWn|ipdS|iiƒSWdQXdS(N( RRRRtwaitRRtNonetpopright(Rtblock((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyttakes     cCs5|iiiƒzt|_|iiƒWdQXdS(N(RRRtTrueRt notifyAll(R((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyRs (t__name__t __module__RRRRR(((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyR s   cCsdS(sATHENA.MIT.EDU((((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyt$scCsdS(tME((((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyR"%scBs;eZd„Zd„Zd„ZeeeƒZd„ZRS(cKs©d|_d|_d|_d|_tƒ|_d|_t|_d|_d|_ d|_ d|_ g|_ g|_ x*|iƒD]\}}t|||ƒq…WdS(NitmessagetpersonalitR#sdClass $class, Instance $instance: To: @bold($recipient) at $time $date From: @bold{$1 <$sender>} $2(tkindtclstinstancetuidRtportRtautht recipientRtopcodetformatt other_fieldstfieldst iteritemstsetattr(Rtoptionstktv((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyR-s               cCsdi|iƒS(Nt(tjoinR1(R((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyt getmessage@scCs|idƒ|_dS(NR7(tsplitR1(Rtnewmsg((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyt setmessageCscCsti|ƒdS(N(tqueueR(R((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pytsendHs(R R!RR9R<tpropertyR$R>(((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyR,s    cCsdS(N(R(((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyR"LscCsti|dƒS(N(t variablestgetR(R5((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyR"PsN( ssendersreceives interruptsZNoticesrealms Subscriptionssinits getVariables setVariables unsetVariable(t collectionsRt threadingRRt__all__tobjectR RRR=RRRRtsetRR tdictR@R t __setitem__R t __delitem__R (((sE/mit/zmobile/testing/lib/python2.6/site-packages/zserv/test_zephyr.pyts