"e ddlmZddlmZddlmZmZmZddlZddl Z ddl m Z ddl Z ddl mZddlmZdZGd d eZGd d eZGd deZdZy)) threading)PyDBDaemonThread)thread_get_ident IS_CPYTHONNULLN) pydev_log)is_current_thread_main_thread) pydevd_utilsFc.eZdZdZdZdZdZdZdZy)_TimeoutThreadam The idea in this class is that it should be usually stopped waiting for the next event to be called (paused in a threading.Event.wait). When a new handle is added it sets the event so that it processes the handles and then keeps on waiting as needed again. This is done so that it's a bit more optimized than creating many Timer threads. ctj||tj|_g|_tj |_yN)r__init__rEvent_event_handlesLock_lockselfpy_dbs ?/usr/lib/python3/dist-packages/_pydevd_bundle/pydevd_timeout.pyrz_TimeoutThread.__init__s7!!$.oo'  ^^% c"d}|jstr.|tjdntjd||jj ||jrg|_y|j}|jsyy)Nz1pydevd_timeout: Wait until a new handle is added.z#pydevd_timeout: Next wait time: %s.)_kill_received_DEBUGrcriticalrwaitrprocess_handles)r wait_times r_on_runz_TimeoutThread._on_run#sw %%$&&'Z[&&'LiX KK  Y '"" " ,,.I%%rc|j5trtjd|jj |j }gx}|_tj}d}|D]}||jkre|jsYtrtjd||j|| |j}Z|j|ksj|j}wtrtjd||j| dddy||z }|dkrtjd||cdddS#1swYyxYw)zx :return int: Returns the time we should be waiting for to process the next event properly. z"pydevd_timeout: Processing handlesNz(pydevd_timeout: Handle NOT processed: %sz$pydevd_timeout: Handle processed: %srz5pydevd_timeout: Expected timeout to be > 0. Found: %s) rrrrrclearrtime abs_timeoutdisposedappendexec_on_timeout)rhandles new_handlescurtimemin_handle_timeouthandletimeouts rrz_TimeoutThread.process_handles3s@ ZZ' ""#GH KK   mmG*, ,K$- iikG!% ! -V///!**+UW]^&&v.)1-3-?-?*++.@@-3-?-?*!**+QSYZ**,! -$")C' ' F-w6a<&&'^`ghO' ' ' sC E >E !!E  Ectj||j5|jj dddy#1swYyxYwr)rdo_kill_pydev_threadrrsetrs rr0z#_TimeoutThread.do_kill_pydev_threadas:--d3 ZZ  KKOO    s AAc|j5|jj||jj dddy#1swYyxYwr)rrr'rr1)rr-s radd_on_timeout_handlez$_TimeoutThread.add_on_timeout_handlefs> ZZ  MM  ( KKOO    s 6A  AN) __name__ __module__ __qualname____doc__rr!rr0r4rrr r s!&/ ,\ rr c.eZdZdZdZdZdZdZeZy)_OnTimeoutHandlecd|d|_tj||_||_||_|i}||_d|_y)Nz_OnTimeoutHandle()F)_strweakrefref_trackerr% on_timeoutkwargsr&)rtrackerr%rBrCs rrz_OnTimeoutHandle.__init__nsC.8:  G, &$ >F  rc |j}|j}|jsr2s r__str__z_OnTimeoutHandle.__str__s yyrN) r5r6r7rr(rIrOrQ__repr__r9rrr;r;ls# V$  #Hrr;ceZdZdZdZddZy)TimeoutTrackerzC This is a helper class to track the timeout of something. cxd|_tj|_t j ||_yr)_threadrrrr?r@_py_dbrs rrzTimeoutTracker.__init__s' ^^% kk%( rNc|j5|jStrtjdt |j |_|jjtj}t|||z||}trtjd||jj||cdddS#1swYyxYw)a This can be called regularly to always execute the given function after a given timeout: call_on_timeout(py_db, 10, on_timeout) Or as a context manager to stop the method from being called if it finishes before the timeout elapses: with call_on_timeout(py_db, 10, on_timeout): ... Note: the callback will be called from a PyDBDaemonThread. Nz'pydevd_timeout: Created _TimeoutThread.z!pydevd_timeout: Added handle: %s.) rrVrrrr rWstartr$r;r4)rr.rBrCr+r-s rcall_on_timeoutzTimeoutTracker.call_on_timeoutsZZ ||#&&'PQ-dkkm<  ""$iikG%dGg,=z6RF""#FO LL . .v 6   s B=CCr)r5r6r7r8rrZr9rrrTrTs) rrTcrttrtjfd}|Sfd}|S)aQ The idea here is returning a callback that when called will generate a KeyboardInterrupt in the thread that called this function. If this is the main thread, this means that it'll emulate a Ctrl+C (which may stop I/O and sleep operations). For other threads, this will call PyThreadState_SetAsyncExc to raise a KeyboardInterrupt before the next instruction (so, it won't really interrupt I/O or sleep operations). :return callable: Returns a callback that will interrupt the current thread (this may be called from an auxiliary thread). cZtjdtjy)Nz"Callback to interrupt main thread.)rdebugr interrupt_main_thread) main_threadsrraise_on_this_threadzCcreate_interrupt_this_thread_callback..raise_on_this_threads OO@ A  . .{ ;rctratjdtjj tj tjtytjdy)NzInterrupt thread: %sz=It is only possible to interrupt non-main threads in CPython.) rrr]ctypes pythonapiPyThreadState_SetAsyncExcc_long py_objectKeyboardInterrupt)tidsrr`zCcreate_interrupt_this_thread_callback..raise_on_this_threadsM 6<  ::6==;MvO_O_`qOrs _`r)rr rcurrent_thread)r`r_rhs @@r%create_interrupt_this_thread_callbackrjs<  C$&..0  <  a r)"_pydev_bundle._pydev_saved_modulesr#_pydevd_bundle.pydevd_daemon_threadr_pydevd_bundle.pydevd_constantsrrrrbr$ _pydev_bundlerr?_pydevd_bundle.pydevd_utilsr _pydevd_bundler rr objectr;rTrjr9rrrrsW8@NN #E' [%[|2v2j&V&R% r