Ñò u©×Nc @søddklZlZlZddklZlZddkZddklZddk Z ddk Z ddk l Z d„Zddd„ƒYZed ƒad „Zd „Zd efd „ƒYZhZeƒZd„Zdefd„ƒYZdS(iÿÿÿÿ(tLocktThreadtBoundedSemaphore(tQueuetEmptyN(t get_ident(t getglobaluicCsFxt|ƒD]}|iƒq Wxt|ƒD]}|iƒq.WdS(s`Wait until the semaphore gets back to its original state -- all acquired resources released.N(trangetacquiretrelease(t semaphoret originalstateti((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pytsemaphoreresets   t threadlistcBs5eZd„Zd„Zd„Zd„Zd„ZRS(cCstƒ|_g|_dS(N(Rtlocktlist(tself((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyt__init__(s cCs6|iiƒz|ii|ƒWd|iiƒXdS(N(RRRtappendR (Rtthread((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pytadd,s cCs6|iiƒz|ii|ƒWd|iiƒXdS(N(RRRtremoveR (RR((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyR3s cCsH|iiƒz&t|iƒpdS|iiƒSWd|iiƒXdS(N(RRtlenRtNonetpopR (R((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyR:s  cCs,x%|iƒ}|pdS|iƒqdS(N(Rtjoin(RR((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pytresetCs  (t__name__t __module__RRRRR(((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyR's     idcCs@x9y titdƒ}||ƒWqtj oqXqdS(sAn infinite "monitoring" loop watching for finished ExitNotifyThread's. :param callback: the function to call when a thread terminated. That function is called with a single argument -- the ExitNotifyThread that has terminated. The monitor will not continue to monitor for other threads until 'callback' returns, so if it intends to perform long calculations, it should start a new thread itself -- but NOT an ExitNotifyThread, or else an infinite loop may result. Furthermore, the monitor will hold the lock all the while the other thread is waiting. :type callback: a callable function i<N(t exitthreadstgettTrueR(tcallbacktthrd((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pytexitnotifymonitorloopQs cCs™tƒ}|iƒdjo>t|iƒtƒo t‚n|i|ƒtidƒn<|iƒdjo|i ƒtidƒn|i |ƒdS(sCalled when a thread exits.t EXCEPTIONidtSYNC_WITH_TIMER_TERMINATEN( Rt getExitCauset isinstancetgetExitExceptiont SystemExittthreadExceptiontsystexittgetExitMessaget terminatet threadExited(Rtui((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyt threadexitedls    tExitNotifyThreadcBsteZdZd Zd„Zd„Zd„Zd„Zd„Z d„Z d„Z d„Z d „Z ed „ƒZRS( s‹This class is designed to alert a "monitor" to the fact that a thread has exited and to provide for the ability for it to find out why.cCsotƒ|_yÄtipti|ƒn¦yddk}Wntj oddk}nX|i ƒ}y|i dt ƒt ƒƒ}Wnt j onX|itiitid|i|iƒfƒƒWnO|idƒto4|itiƒdƒtiƒ}|i|ƒq/nX|idƒt|dƒp|idƒntoti|tƒndS(NiÿÿÿÿsThread.run(self)s %s_%s.profR$itNORMALt exitmessage( RtthreadidR2t profiledirRtruntcProfilet ImportErrortprofiletProfiletrunctxtglobalstlocalsR)t dump_statstostpathRtgetNamet setExitCauseR+tsetExitExceptiontexc_infot tracebackt format_exctsetExitStackTracethasattrtsetExitMessageRRtputR (RR:tprofttb((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyR7„s4   !   cCs ||_dS(N(t exitcause(Rtcause((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyRC¤scCs|iS(sReturns the cause of the exit, one of: 'EXCEPTION' -- the thread aborted because of an exception 'NORMAL' -- normal termination.(RN(R((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyR&¦scCs ||_dS(N(t exitexception(Rtexc((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyRD«scCs|iS(sdIf getExitCause() is 'EXCEPTION', holds the value from sys.exc_info()[1] for this exception.(RP(R((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyR(­scCs ||_dS(N(texitstacktrace(Rtst((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyRH±scCs|iS(skIf getExitCause() is 'EXCEPTION', returns a string representing the stack trace for this exception.(RR(R((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pytgetExitStackTrace³scCs ||_dS(sSets the exit message to be fetched by a subsequent call to getExitMessage. This message may be any object or type except None.N(R4(Rtmsg((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyRJ·scCs|iS(sFor any exit cause, returns the message previously set by a call to setExitMessage(), or None if there was no such message set.(R4(R((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyR-¼scCs ||_dS(s6If set, will output profile information to 'directory'N(R6(tclst directory((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pytset_profiledirÂsN(RRt__doc__RR6R7RCR&RDR(RHRTRJR-t classmethodRX(((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/threadutil.pyR2~s        cCs<tiƒti|ƒpt|ƒt|s     (   N