ó Gh\c@sddlmZmZmZmZyddlmZmZWn'ek reddlmZmZnXddl Z ddl Z ddl m Z dZd„Zdefd„ƒYZeƒad „Zd efd „ƒYZiad „Zd efd„ƒYZdS(iÿÿÿÿ(tLocktThreadtBoundedSemaphoret currentThread(tQueuetEmptyN(t getglobaluit STOP_MONITORcCsFxt|ƒD]}|jƒq Wxt|ƒD]}|jƒq.WdS(sjBlock until `semaphore` gets back to its original state, ie all acquired resources have been released.N(trangetacquiretrelease(t semaphoret originalstateti((s0/usr/share/offlineimap/offlineimap/threadutil.pytsemaphorereset"staccountThreadscBs;eZdZd„Zd„Zd„Zd„Zd„ZRS(snStore the list of all threads in the software so it can be used to find out what's running and what's not.cCstƒ|_g|_dS(N(Rtlocktlist(tself((s0/usr/share/offlineimap/offlineimap/threadutil.pyt__init__0s cCs$|j|jj|ƒWdQXdS(N(RRtappend(Rtthread((s0/usr/share/offlineimap/offlineimap/threadutil.pytadd4s cCs$|j|jj|ƒWdQXdS(N(RRtremove(RR((s0/usr/share/offlineimap/offlineimap/threadutil.pyR8s cCs:|j+t|jƒdkr#dS|jjƒSWdQXdS(Ni(RtlenRtNonetpop(R((s0/usr/share/offlineimap/offlineimap/threadutil.pyR<s cCs7x0tr2|jƒ}|dkr%Pn|jƒqWdS(N(tTrueRRtjoin(RR((s0/usr/share/offlineimap/offlineimap/threadutil.pytwaitBs    (t__name__t __module__t__doc__RRRRR(((s0/usr/share/offlineimap/offlineimap/threadutil.pyR,s     cCsÆtƒ}x¶trÁy˜tjtdƒ}|jdk r‰t|jtƒrQt‚n|j|ƒt dt |jƒt |jƒfƒ‚n |j t krœPn |j|ƒWq tk r½q Xq WdS(sKAn infinite "monitoring" loop watching for finished ExitNotifyThread's. This one is supposed to run in the main thread. :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<snthread has 'exit_exception' set to '%s' [%s] but this value is unexpected and the ui did not stop the program.N(RRt exitedThreadstgettexit_exceptionRt isinstancet SystemExittthreadExceptiontAssertionErrortreprttypet exit_messageRt threadExitedR(tuiR((s0/usr/share/offlineimap/offlineimap/threadutil.pytmonitorPs    % tExitNotifyThreadcBsJeZdZd„Zd„Zdd„Zed„ƒZed„ƒZ RS(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. All instances are made daemon threads (setDaemon(True), so we bail out when the mainloop dies. The thread can set instance variables self.exit_message for a human readable reason of the thread exit. There is one instance of this class at runtime. The main thread waits for the monitor to end.cOsEtt|ƒj||Ž|jtƒd|_d|_d|_dS(N( tsuperR.Rt setDaemonRRR*t _exit_exct_exit_stacktrace(Rtargstkwargs((s0/usr/share/offlineimap/offlineimap/threadutil.pyR’s    cCsWytj|ƒWn/tk rB}tjƒ}|j||ƒnXtj|tƒdS(s.Allow profiling of a run and store exceptions.N( Rtrunt Exceptiont tracebackt format_exctset_exit_exceptionR!tputR(Rtettb((s0/usr/share/offlineimap/offlineimap/threadutil.pyR5›s  cCs||_||_dS(sbSets Exception and stacktrace of a thread, so that other threads can query its exit statusN(R1R2(Rtexctst((s0/usr/share/offlineimap/offlineimap/threadutil.pyR9¨s cCs|jS(sˆReturns the cause of the exit, one of: Exception() -- the thread aborted with this exception None -- normal termination.(R1(R((s0/usr/share/offlineimap/offlineimap/threadutil.pyR#¯scCs|jS(s4Returns a string representing the stack trace if set(R2(R((s0/usr/share/offlineimap/offlineimap/threadutil.pytexit_stacktrace·sN( RRR RR5RR9tpropertyR#R?(((s0/usr/share/offlineimap/offlineimap/threadutil.pyR.†s   cCs#|tkrt|ƒt|s "    "  6<