eddlmZmZmZddlmZmZddlZddlm Z dZ dZ GddZ ea d ZGd d eZiad ZGd deZy))LockThreadBoundedSemaphore)QueueEmptyN) getglobalui STOP_MONITORct|D]}|jt|D]}|jy)zjBlock until `semaphore` gets back to its original state, ie all acquired resources have been released.N)rangeacquirerelease) semaphore originalstateis 1/usr/share/offlineimap3/offlineimap/threadutil.pysemaphoreresetrsF= != !c.eZdZdZdZdZdZdZdZy)accountThreadsznStore the list of all threads in the software so it can be used to find out what's running and what's not.c0t|_g|_yN)rlocklistselfs r__init__zaccountThreads.__init__,sF  rc||j5|jj|dddy#1swYyxYwr)rrappendrthreads raddzaccountThreads.add00 YY % II  V $ % % %2;c||j5|jj|dddy#1swYyxYwr)rrremovers rr%zaccountThreads.remove4r"r#c|j5t|jdkr dddy|jjcdddS#1swYyxYw)N)rlenrpoprs rr)zaccountThreads.pop8sJ YY #499~! # #99==? # # #sAAAcL |j}|y|j$r)r)joinrs rwaitzaccountThreads.wait>s&XXZF~ KKM rN) __name__ __module__ __qualname____doc__rr!r%r)r,rrrr(s &%%# rrct} tjdd}|jit |jt rt |j |tdt|jdt|jd|jtk(ry|j| #t$rY wxYw)zAn infinite "monitoring" loop watching for finished ExitNotifyThread's. This one is supposed to run in the main thread. T<Nz$thread has 'exit_exception' set to 'z' [zC] but this value is unexpected and the ui did not stop the program.)r exitedThreadsgetexit_exception isinstance SystemExitthreadExceptionAssertionErrorreprtype exit_messager threadExitedr)uir s rmonitorr@Ms B  #&&tR0F$$0f33Z@%$""6*$'+6+@+@&A4H]H]C^&`aa $$ 4'; <   sBB?,B?? C  C cPeZdZdZfdZdZddZedZedZ xZ S)ExitNotifyThreadaThis 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.cxtt| |i||jdd|_d|_d|_y)NT)superrBr setDaemonr= _exit_exc_exit_stacktrace)rargskwargs __class__s rrzExitNotifyThread.__init__s= .?? t  $rc tj|t j|dy#t$r0}tj}|j ||Yd}~Kd}~wwxYw)z.Allow profiling of a run and store exceptions.NT)rrun Exception traceback format_excset_exit_exceptionr4put)retbs rrLzExitNotifyThread.runsX + JJt  $%  +%%'B  # #Ar * * +s. A'&A""A'c ||_||_y)zbSets Exception and stacktrace of a thread, so that other threads can query its exit statusN)rFrG)rexcsts rrPz#ExitNotifyThread.set_exit_exceptions "rc|jS)zReturns the cause of the exit, one of: Exception() -- the thread aborted with this exception None -- normal termination.)rFrs rr6zExitNotifyThread.exit_exceptions ~~rc|jS)z4Returns a string representing the stack trace if set)rGrs rexit_stacktracez ExitNotifyThread.exit_stacktraces$$$rr) r-r.r/r0rrLrPpropertyr6rY __classcell__rJs@rrBrBxs? % &#%%rrBc:|tvrt|t|<yy)zInitialize the instance-limited thread implementation. Run up to intancemax threads for the given limitNamespace. This allows to honor maxsyncaccounts and maxconnections.N)limitedNamespacesr)limitNamespace instancemaxs rinitInstanceLimitras"..,<[,I.)/rc*eZdZfdZdZdZxZS)InstanceLimitedThreadc:||_tt||i|yr)r_rDrcr)rr_rHrIrJs rrzInstanceLimitedThread.__init__s , #T3TDVDrcpt|jjtj |yr)r^r_r rBstartrs rrfzInstanceLimitedThread.starts) $--.668t$rc* tj|tr6t|jr"t|jj yyy#tr6t|jr"t|jj wwwxYwr)rBrLr^r_r rs rrLzInstanceLimitedThread.runsz A   & %6t7J7J%K!$"5"56>>@&L  %6t7J7J%K!$"5"56>>@&L s A>B)r-r.r/rrfrLr[r\s@rrcrcsE%Arrc) threadingrrrqueuerrrNofflineimap.uirr rrr4r@rBr^rarcr1rrrksd$54& D (V5%v5%x JA,Ar