Bi[HdZddlZddlmZddlZddlmZejdddkredddl Z ddl Z ddl Z ddl Z ddl mZdd lmZdd lmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(dd l)m*Z*dd l)m+Z+m,Z,dd l-m.Z.ddl/m0Z0ddl1m2Z2ddl1m3Z3ddl1m4Z4ddl5m6Z6m7Z7ddl8Z8ddl5m9Z9ddl5m:Z:ddl;mZ>m?Z?m@Z@ddlAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\ddl]m^Z^m_Z_ddl`maZambZbddlcmdZdddlemfZgmhZhmiZimjZjddlkmlZlmmZmmnZnddlompZpddlqmrZrddlsmtZtmuZumvZvmwZwdd lxmyZymzZzdd!l{m|Z|m}Z}m~Z~ddlZdd"lmZdd#l{mZmZejZd$ZgZeD]Zejeed%jeZdSd&Zee ZdZerdd'lmZe2j"Ze2j&Zej*Z d(j/d)d*ad*ad*ad*Zd*ae.ZGd+d,eNZGd-d.eNZGd/d0eZGd1d2eZGd3d4eZGd5d6eZd7Zd8ZdSd9ZdTd:ZGd;dZ dUd?Ze4jZZd@ZdAZGdBdCeZGdDdEePZdFZdGZdHZGdIdJZdKZdLZdMZddNlmZddOl5mZejzeD]ZejePdQZedRk(reyy#YxYw)VzF Entry point module (keep at root): This module starts the debugger. N)contextmanager)collect_return_inforzThe PyDev.Debugger requires Python 2.6 onwards to be run. If you need to use an older Python version, use an older version of the debugger.)partial) defaultdict)IS_JYTH_LESS25 IS_PYCHARM get_thread_idget_current_thread_id dict_keysdict_iter_itemsDebugInfoHolderPYTHON_SUSPEND STATE_SUSPEND STATE_RUN get_framexrangeclear_cached_thread_idINTERACTIVE_MODE_AVAILABLESHOW_DEBUG_INFO_ENVIS_PY34_OR_GREATERIS_PY36_OR_GREATERIS_PY2NULL NO_FTRACEdummy_excepthook IS_CPYTHONGOTO_HAS_RESPONSE) fix_getpass) pydev_imports pydev_log)getfilesystemencoding)is_thread_alive) threading)time)thread) pydevd_iopydevd_vm_type) pydevd_utils) pydevd_vars) overrides)ExceptionBreakpointset_fallback_excepthookdisable_excepthook) CMD_SET_BREAKCMD_SET_NEXT_STATEMENT CMD_STEP_INTO CMD_STEP_OVERCMD_STEP_RETURNCMD_STEP_INTO_MY_CODECMD_THREAD_SUSPENDCMD_RUN_TO_LINECMD_ADD_EXCEPTION_BREAKCMD_SMART_STEP_INTOInternalConsoleExecNetCommandFactoryPyDBDaemonThread_queue ReaderThreadGetGlobalDebuggerget_global_debuggerset_global_debugger WriterThread pydevd_log start_client start_serverInternalGetBreakpointExceptionInternalSendCurrExceptionTrace'InternalSendCurrExceptionTraceProceededCommunicationRolerun_as_pydevd_daemon_thread)CustomFramesContainercustom_frames_container_init)add_exception_to_frameremove_exception_from_frame)kill_all_pydev_threads)trace_dispatchglobal_cache_skipsglobal_cache_frame_skipsshow_tracing_warning)frame_eval_funcdummy_trace_dispatchshow_frame_eval_warning)set_additional_thread_info)save_main_module)ThreadingLogger AsyncioLogger send_messagecur_time) wrap_threads wrap_asyncio) get_fullnamerPathget_package_dir) DONT_TRACE)*get_abs_path_real_path_and_base_from_frameNORM_PATHS_AND_BASE_CONTAINER)r.cV|ddlm}|}tjdk\r |t_yy)Nr)breakpointhook))$_pydevd_bundle.pydevd_breakpointhookrjsys version_info)pydevd_breakpointhookrjs 1/usr/local/lib/python3.12/dist-packages/pydevd.pyinstall_breakpointhookrrJs.$G . 6!3") PluginManagerdummyutf-8FcBeZdZdZeej dZy)PyDBCommandThreadctj||j|_||_|j dy)Nzpydevd.CommandThread)r=__init___py_db_command_thread_eventpy_dbsetNameselfr|s rqrzzPyDBCommandThread.__init__{s2!!$'+0+L+L(  +,rsctjd|jry |js^ |jj |j j|j jd|js]yy#t ddYTxYw#tjtjdYyxYw)N333333?rz#Finishing debug communication...(2)) r'sleep killReceivedr|process_internal_commandsrDr{clearwaitr#debugrnexc_infors rq_on_runzPyDBCommandThread._on_runs 3     /''IJJ88:006680055c: ''Iq"GH / OOCLLN1- .s# B"B AB"BB"",CN)__name__ __module__ __qualname__rzr-r=rrsrqrxrxys'- ''(/)/rsrxcPeZdZdZeej dZddZdZy)CheckOutputThreadcltj|||_|jdd|_y)Nzpydevd.CheckAliveThreadF)r=rzr|r}daemonr~s rqrzzCheckOutputThread.__init__s+!!$'  ./ rsc|jstjd|jj su|jj j rQ tjd|jjt|jd|_|jj|jsyy#tjYXxYw)Nrz)No threads alive, finishing debug sessionT)rr'rr|has_threads_alivewriteremptyr#rfinish_debugging_sessionrP traceback print_excwait_pydb_threads_to_finishcheck_output_redirectrs rqrzCheckOutputThread._on_runs## JJsO:://1djj6G6G6M6M6O*OO$OPJJ779*,002$(! JJ , , .##*'')s !9CC2c tjd|j}tj}tj||zkrQt |dk(r|j |drytj dtj||zkrQtjddj|Dcgc]}||us|jc}zycc}w)Nz)Waiting for pydb daemon threads to finishrf{Gz?z9The following pydb threads may not finished correctly: %sz, ) r#rcreated_pydb_daemon_threadsr'lengetrjoingetName)rtimeoutpydb_daemon_threads started_atts rqrz-CheckOutputThread.wait_pydb_threads_to_finishsCD">>YY[ iikJ00&'1,1D1H1Ht1T JJt iikJ00 S)):M$_QQRZ^Q^QYY[$_`a b$_s C* C*cd|_yNT)rrs rqdo_kill_pydev_threadz&CheckOutputThread.do_kill_pydev_threads  rsN)?) rrrrzr-r=rrrrrsrqrrs2 ''(/)/" b!rsrc4eZdZdZdZdZdZdZdZdZ y) TrackedLockzGThe lock that tracks if it has been acquired by the current thread ctj|_tj|_d|j _yNF)r( allocate_lock_lockr&local_tlsis_lock_acquiredrs rqrzzTrackedLock.__init__s,))+ OO% %* "rscZ|jjd|j_yr)racquirerrrs rqrzTrackedLock.acquires %) "rscZ|jjd|j_yr)rreleaserrrs rqrzTrackedLock.releases %* "rsc$|jyN)rrs rq __enter__zTrackedLock.__enter__  rsc$|jyr)r)rexc_typeexc_valexc_tbs rq__exit__zTrackedLock.__exit__rrsc.|jjSr)rrrs rqis_acquired_by_current_threadz)TrackedLock.is_acquired_by_current_threadsyy)))rsN) rrr__doc__rzrrrrrrrsrqrrs%+ *+*rsrcPeZdZdZgdZdZdZdZdZdZ dZ d Z e d Z y ) "AbstractSingleNotificationBehaviora The basic usage should be: # Increment the request time for the suspend. single_notification_behavior.increment_suspend_time() # Notify that this is a pause request (when a pause, not a breakpoint). single_notification_behavior.on_pause() # Mark threads to be suspended. set_suspend(...) # On do_wait_suspend, use notify_thread_suspended: def do_wait_suspend(...): with single_notification_behavior.notify_thread_suspended(thread_id): ... )_last_resume_notification_time_last_suspend_notification_timer_next_request_time_suspend_time_request_suspended_thread_ids_pause_requestedrctttj|_d|_d|_|j |_tj|_ t|_ d|_ y)NF)rnext itertoolscountrrrrr(rrsetrrrs rqrzz+AbstractSingleNotificationBehavior.__init__s[")$ 0A"B/1,.0+%)%<%<%>"))+ %(U" %rsctdNz#abstract: subclasses must override.AssertionErrorr thread_id stop_reasons rqsend_suspend_notificationz$>@ST = =s AA c,tj|j|j5|jrH||j kDr9||_|j tt|jtdddy#1swYyxYwr) r'rNOTIFY_OF_PAUSE_TIMEOUTrrrrriterr7rs rqrz8AbstractSingleNotificationBehavior._notify_after_timeoutst 4//0 ZZ o))&)M)MM;ND8224T=W=W8X3Y[mn  o o os AB  Bc#,K|j5|j}|rd|_|jj||tk7s|r<|j |j kDr#|j |_|j||ddd d|j5|jj||j|j kr"|j |_ |j|dddy#1swYzxYw#1swYyxYw#|j5|jj||j|j kr"|j |_ |j|dddw#1swYwxYwxYwwr) rrraddr7rrrremoverr)rrrpause_requesteds rqnotify_thread_suspendedz:AbstractSingleNotificationBehavior.notify_thread_suspended!s\ ZZ K"33O(-%  & & * *9 500O--0T0TT;?;U;UD8229kJ K =  =**11)<669]9]]:>:^:^D711)<  = =% K K$ = = =**11)<669]9]]:>:^:^D711)<  = = =sg FA8DFD F AD 7 FD F DF F%AF< FF FFN)rrrr __slots__rrzrrrrrrrrrsrqrrsM$I!&DDCUo==rsrceZdZejddgzZdZeejdZeejdZeeje dZ y)"ThreadsSuspendedSingleNotification!multi_threads_single_notification_py_dbcptj|d|_tj||_yr)rrzrweakrefrefrr~s rqrzz+ThreadsSuspendedSingleNotification.__init__As(*33D916.kk%( rsc|j}|5|jj|jj |yyr)rr add_command cmd_factory&make_thread_resume_single_notification)rrr|s rqrz;ThreadsSuspendedSingleNotification.send_resume_notificationGs<    LL $ $U%6%6%]%]^g%h i rsc|j}|6|jj|jj ||yyr)rrrr'make_thread_suspend_single_notification)rrrr|s rqrzd-Z/d.Z0d/Z1d0Z2d1Z3d2Z4d3Z5d:d4Z6d5Z7d?d6Z8d7Z9d8Z:d9Z;eZ>e?Z?y)@PyDBa8 Main debugging class Lots of stuff going on here: PyDB starts two threads on startup that connect to remote debugger (RDB) The threads continuously read & write commands to RDB. PyDB communicates with these threads through command queues. Every RDB command is processed by calling process_net_command. Every PyDB net command is sent to the net by posting NetCommand to WriterThread queue Some commands need to be executed on the right thread (suspend/resume & friends) These are placed on the internal command queue. c|rt|tjd|_d|_d|_d|_d|_t|_ ttj|_ i|_d|_i|_i|_i|_i|_d|_t+|_t/j0|_t5j6|_|r|j8t:_d|_d|_d|_ tjB|_!d|_"d|_#d|_$d|_%d|_&d|_'d|_(d|_)i|_*d|_+i|_,d|_-d|_.d|_/d|_0d|_1d|_2d|_3i|_4i|_5d|_6tojp|_8tojr|_9d|_:d|_;d|_<d|_=d|_>t||_@t5j|_Bt|_Dd|_Et|_Fd|_Gy)NrFTr)HrBpydevd_tracingreplace_sys_set_trace_funcreaderroutput_checker_threadpy_db_command_threadquittingr<rr r>Queue _cmd_queue breakpointsmtimefile_to_id_to_line_breakpointfile_to_id_to_plugin_breakpointbreak_on_uncaught_exceptionsbreak_on_caught_exceptions ready_to_runr _main_lockr(r_lock_running_thread_idsr&Eventr{rL_finish_debugging_session_termination_event_setsignature_factorySetTrace)skip_on_exceptions_thrown_in_same_context7ignore_exceptions_thrown_in_lines_with_ignore_exception$skip_suspend_on_breakpoint_exceptionskip_print_breakpoint_exceptiondisable_property_tracedisable_property_getter_tracedisable_property_setter_tracedisable_property_deleter_trace_running_thread_ids_set_breakpoints_with_id.filename_to_lines_where_exceptions_are_ignoredpluginhas_plugin_line_breakshas_plugin_exception_breaksthread_analyserasyncio_analyser mpl_in_usempl_hooks_in_debug_consolempl_modules_for_patching_filename_to_not_in_scopefirst_breakpoint_reachedr+is_filter_enabledis_filter_librariesshow_return_valuesremove_return_values_flagredirect_outputuse_frame_eval stop_on_startr&_threads_suspended_single_notificationr_local_thread_trace_funcdict#process_created_msg_received_eventscommunication_rolerstop_on_failed_tests)r set_as_globals rqrzz PyDB.__init__os9   %  5 5 7  %)"$(! ,.%fll3 -/*/1,-/)*,'!%-(.(<(<(>%+4??+<( @D@`@` ! =).&&+#!%&// 9>6GKD571/1,',#-2*-2*.3+ $& (-%?A; &+#+0(# $ */'(*%)+&(-%!-!?!?!A#/#C#C#E "').&$#"7YY]6^3(1(9%4860"&#6 %*!rscl |jj}|S#t$r|j}Y|SwxYwr)r2thread_trace_funcAttributeErrorrQ)rr9s rqget_thread_local_trace_funcz PyDB.get_thread_local_trace_funcsD 4 $ = = O O !  4 $ 3 3    4s 33Nct|jW|jtj|jt r!|rtj |jy||j}n||j_ tj|t r|rtj |yyy)aT Enables tracing. If in regular mode (tracing), will set the tracing function to the tracing function for this thread -- by default it's `PyDB.trace_dispatch`, but after `PyDB.enable_tracing` is called with a `thread_trace_func`, the given function will be the default for the given thread. N) r/rUrrrVrset_trace_to_threadsr;r2r9)rr9apply_to_all_threadss rqenable_tracingzPyDB.enable_tracings !    +  "  # #D$=$= >233D4M4MN   $ $ @ @ B >OD ) ) ; 12 .  / /0A B/:rsc.tjdyr)rrrs rqdisable_tracingzPyDB.disable_tracings%rscn|jsy|xjdz c_|s|jyy)zh When breakpoints change, we have to re-evaluate all the assumptions we've made so far. Nrf)r r!set_tracing_for_untraced_contexts)rremoveds rqon_breakpoints_changedzPyDB.on_breakpoints_changeds3   a   2 2 4rscd}|rtj}tdtD}trCt j }|jD]\}}||vs |j|yt} |D]G}|j|vs||urt|} | j|} ||j|d}I d}d}d}d} y#d}wxYw#d}d}d}d} wxYw)Nc3hK|]*}t|dds t|ddr|j,yw)is_pydev_daemon_threadFpydev_do_not_traceN)getattrident).0rs rq z9PyDB.set_tracing_for_untraced_contexts.. s6 q2E:gaI]_d>e GG s02) r&current_threadrthreadingEnumeraterrn_current_framesitemsset_trace_for_frame_and_parentsrKrXget_topmost_frame) rignore_current_thread ignore_threadignore_thread_ids tid_to_framerframethreadsradditional_infos rqrCz&PyDB.set_tracing_for_untraced_contextss! %446M /1   ..0L$0$6$6$8 @ 5$5588? @)*G ' %Aww"33qM7I &@&CO+==a@E% , @@G $ %"& !%"&s$4C$<CC$C!!C$$ C.c.|jjSrr1rrs rqrz&PyDB.multi_threads_single_notification.s::\\\rsc&||j_yrr\)rnotifys rqrz&PyDB.multi_threads_single_notification2sX^33Ursc^|jtrt||_|jSr)r SUPPORT_PLUGINSrtrs rqget_plugin_lazy_initzPyDB.get_plugin_lazy_init6s$ ;; ?'-DK{{rsc,tj|Sr)r+in_project_rootsrfilenames rqin_project_scopezPyDB.in_project_scope;s,,X66rsc,tj|Sr)r+is_ignored_by_filterrds rqis_ignored_by_filterszPyDB.is_ignored_by_filters>s00::rsc,tj|Sr)r+#is_exception_trace_in_project_scopertraces rqrkz(PyDB.is_exception_trace_in_project_scopeA??FFrsc,tj|Sr)r+#is_top_level_trace_in_project_scoperls rqrpz(PyDB.is_top_level_trace_in_project_scopeDrnrsc,tj|Sr)r+is_test_item_or_set_up_caller)rrXs rqrrz"PyDB.is_test_item_or_set_up_callerGs99%@@rscd|_yr)r6rs rqset_unit_tests_debugging_modez"PyDB.set_unit_tests_debugging_modeJs $(!rsctjD]Q}t|trt j dt |s4|jr t|dsQyy)NWError in debugger: Found PyDBDaemonThread not marked with is_pydev_daemon_thread=True. __pydevd_main_threadTF) r+get_non_pydevd_threads isinstancer=r# error_oncer%isDaemonhasattr)rrs rqrzPyDB.has_threads_aliveMs\446 A!-.$$npq!zz|wq2H'I rscd|_yr)rrs rqrzPyDB.finish_debugging_sessionYs )-&rsc |jdt||_t||_|jj |jj t jdy#YnxYw)N皙?) settimeoutrCrr?rstartr'r)rsocks rqinitialize_networkzPyDB.initialize_network]sb  OOD !#4( "4(    3  s A==Bc|r"tj|_t||}n tj|_t |}|j |yr)rJCLIENTr5rESERVERrFr)rhostportss rqconnectz PyDB.connectisE &7&>&>D #T4(A&7&>&>D #T"A "rscp|jdr||jddzd}|j|S)zm returns internal command queue for a given thread. if new queue is created, notify the RDB about it __frame__|rfN) startswithrfindrrs rqget_internal_queuezPyDB.get_internal_queuets<    ,!)//#"6":"; cF  / /8U8U8Y8YZ`8a b crsczddlmm}m}mGddfd}ddlm}||fd||d|_y) Nr)activate_matplotlibactivate_pylabactivate_pyplot do_enable_guiceZdZdZy)7PyDB.init_matplotlib_support.._MatplotlibHelperFN)rrr_return_control_oscrrsrq_MatplotlibHelperrs"' rsrc@j _jSr)r)rsrqreturn_controlz4PyDB.init_matplotlib_support..return_controls$9J8]8]4]  1$88 8rs)set_return_control_callbackcSrr)rrsrqz.PyDB.init_matplotlib_support..s?RS`?ars) matplotlibzmatplotlib.pyplotpylab)pydev_ipython.matplotlibtoolsrrrrpydev_ipython.inputhookrr')rrrrrrrrs @@@rqinit_matplotlib_supportzPyDB.init_matplotlib_supports:uu ( ( 9 H#N37a>M2@)C%rsct|jdkDrWt|jD]>}|tjvs|jj |}|d|_@yy)NrT)rr'rrnmodulesrr%)rractivate_functions rq_activate_mpl_if_neededzPyDB._activate_mpl_if_neededsd t,, - 1#D$A$AB +S[[((,(E(E(I(I&(Q%%'&*DO  + 2rscB ddlm}|}|r|yy#YyxYw)Nr) get_inputhook)rr)rr inputhooks rq_call_mpl_hookzPyDB._call_mpl_hooks(  =%I   sch|jy|r |jnt5||jvr dddyt |}|j r dddy||j|<ddd|jj |jj|y#1swY>xYwr) rrrrrXpydev_notify_killrrmake_thread_created_message)rrr(use_lockrZs rqnotify_thread_createdzPyDB.notify_thread_createds ;;  .6T * *D 9D444 9 99@O00 9 939D $ $Y / 9  0 0 L LV TU 9 9sB(B(B((B1cz|jy|r |jnt5|jj |d}| dddy|j j }|sd|j _ddd|jj|jj|y#1swY>xYw)z: if thread is not alive, cancel trace_dispatch processing NT) rrrrrrZrrrmake_thread_killed_message)rrrr( was_notifieds rqnotify_thread_not_alivezPyDB.notify_thread_not_alives ;;  .6T * *D @--11)TBF~ @ @ "11CCL;?&&8 @  0 0 K KI VW @ @s B1 )B11B:c 8|j5|ji}t}g}|j5|D]}t |ddrt |t rtjd7t|sC|jso|D]j}t|}t|t|}||k7s*tj|s@tj|}tj ||lt|}|||<|j#||dt%|jj'} | D]}||vs|j)||D]}|j+|d dddt-|dk(r5|j/|D]}t1|ds|j3!nt5t7} | dfD]}|j9|} g} | j;d} |j<s/t | t>r |jAd |_!d |_| jK| r(tEd d tM| | jO|n'tEd d tM| | j)| dddy#1swY3xYw#tEd d tGjHYxYw#tPjR$r| D]} | jU| Y0wxYw#1swYyxYw)z2This function processes internal commands rHFrv)rNrr*Trz*Matplotlib support in debug console failedzprocessing internal command z NOT processing internal command )+rrrOrrJryr=r#rzr%rr rr,has_additional_frames_by_idget_additional_frames_by_idadd_additional_frame_by_idrlistkeysappendrrrr|rr threadingCurrentThreadrrr&r;rr%rDr format_exccan_be_executed_bystrdo_itr>Emptyr)rprogram_threads_alive all_threadsprogram_threads_deadrexisting_thread old_thread_idr frames_by_id thread_idscurr_thread_idrcmds_to_add_backrs rqrzPyDB.process_internal_commandss*__X /  & & ($& !,.K#% ..& L$QAq":EB#A'78!,,.HI(+#774?h0=o0N 6q 9,9!,< #, #='2'N'N}']7B7^7^_l7m (3(N(NyZf(gh%2!$4 ;<-i8229a%2P9Q>"$":":"?"?"AB !+?I (==,33I>?"6LI00U0KLK& LR()Q.--/$1Aq"89..01"77M7O!P"0#!6/I 33I>E(*$/"&+ii&6G#'#B#BzRY[nGo!x$($I$I$K6:DOCG ?&99.I *1.LcRYl [ ' d 3 *1.PRUV]R^ _ 0 7 7 @##/uX /X / & L& LH!x$.q2^`i`t`t`v$w"<</'7/G!IIg.//kX /X /s+LAJ+>7J+6J+ A?J+ -J+:7L2AL3.K"J89A(K!L+J5 0L8!KK+L  L L  LLcvi}t|D]\}}|||j<|||<|jyr)rlineclear_skip_caches)rfileid_to_breakpointr break_dict breakpoint_id pybreakpoints rqconsolidate_breakpointszPyDB.consolidate_breakpointsIsI +:;K+L 9 'M<,8J|(( ) 9' D  rscTtjtjyr)rRrrSrs rqrzPyDB.clear_skip_cachesQs  " &&(rsc  t|||||||}|jrR|j j } || |<tjdkDrtjd| d| |_|jrR|jj } || |<tjdkDrtjd| d| |_ |S#t$rtjd|dYywxYw)Nz,Error unable to add break on exception for: z# (exception could not be imported) rz!Exceptions to hook on terminate:  zExceptions to hook always: ) r. ImportErrorr#errornotify_on_unhandled_exceptionsr copyrDEBUG_TRACE_BREAKPOINTSnotify_on_handled_exceptionsr ) r exception condition expressionrrnotify_on_first_raise_onlyignore_librariesebcps rqadd_break_on_exceptionzPyDB.add_break_on_exceptionUs $,.* B  , ,22779BByM66:2 OP02D - * *00557BByM66:R IJ.0D + %  OOt} A sC"C65C6ct|}t|_||_|jdk(r t |_t |_|S)Nr)rXr suspend_typerpydev_step_cmdr3r pydev_state)rr(rinfos rq _mark_suspendzPyDB._mark_suspend}sC)&1*(   " $#0D ) rsct|jj|r|jj|j||}|r'|j |}| |j |d}|t k(r1|j%|j}d|_|j|||s|jrd}|rmtj}|D]S} t| ddr| |ur|j| t}|j | }|@ |j |d}Uyy#d}wxYw#d}wxYw)a :param thread: The thread which should be suspended. :param stop_reason: Reason why the thread was suspended. :param suspend_other_threads: Whether to force other threads to be suspended (i.e.: when hitting a breakpoint with a suspend all threads policy). :param is_pause: If this is a pause to suspend all threads, any thread can be considered as the 'main' thread paused. NTrI)r1rrrrSrRr1 conditional_breakpoint_exception$_send_breakpoint_condition_exceptionrr+rxrJr7) rr(rsuspend_other_threadsis_pauserrX&conditional_breakpoint_exception_tuplerrs rq set_suspendzPyDB.set_suspendsN 33JJL   7 7 @ @ B!!&+6 **62E !88? E - 'D,Q,Q,]595Z5Z 248D 1  5 5f>d e$)O)O%) ! &==?K  )12D9F{ --a1CDD 2215E() @@G$(E ) !!E<%)EsD,D3,D03D7ct|}|r4t|dk(r%|\}}t|||}|j||yyy)zoIf conditional breakpoint raises an exception during evaluation send exception details to java rN)r rrGr)rr(rrr stacktracers rqrz)PyDB._send_breakpoint_condition_exceptionsP"&) 1c:`6aef6f#I Hj4Y*UG  & &w :7g 1rscXt|}t|||}|j||y)zSends details on the exception which was caught (and where we stopped) to the java side. arg is: exception type, description, traceback object N)r rHr)rr(arg curr_frame_idrrs rqsend_caught_exception_stackz PyDB.send_caught_exception_stacks, "&) 0CO ""7I6rsctt|}t|}|j|||jy)zXSends that some thread was resumed and is no longer showing an exception trace. N)r rIrr)rr(rrs rq%send_caught_exception_stack_proceededz*PyDB.send_caught_exception_stack_proceededs4"&) 9)D ""7I6 &&(rscn|jj}|jj|y)z=Sends a message that a new process has been created. N)rmake_process_created_messagerrrcmds rqsend_process_created_messagez!PyDB.send_process_created_messages*;;= $rsc|jtjk(r|jj rt j dy|jj}tj}||j|j<|jj||jyy)aFWhen `PyDB` works in server mode this method sends a message that a new process is going to be created. After that it waits for the response from the IDE to be sure that the IDE received this message. Waiting for the response is required because the current process might become substituted before it actually sends the message and the IDE will not try to connect to `PyDB` in this case. When `PyDB` works in client mode this method does nothing because the substituted process will try to connect to the IDE itself. z/Skip sending process substitution notification N)r5rJrrrr#rrrr&rr4seqrrr)rrevents rq send_process_will_be_substitutedz%PyDB.send_process_will_be_substituteds  " "&7&>&> ><<> RS""??ACOO%E@ED 4 4SWW = KK # #C ( JJL ?rscd}d}|j}|dk(s|dk(rE|jj}|dvrd}|dk(s||k(r|} |j|_| |_d}nd}|||fS) NFrr)?zrTz.jump is available only within the bottom frame)f_linenof_codeco_namerQf_trace) rrXr func_name next_linestop response_msgold_linecurr_func_namers rqset_next_statementzPyDB.set_next_statements >> F?e{2 #\\11N!22!#C>Y#>  $ 3 3 !%O X|++rsc|jj t}|D]d}t|ddst |dst |ds+|j |k(s;|j |k(sK|jjf |jjy#tjY3xYw#|jjwxYw)NrHF cancel_eventr) rrrOrJr|rframe_idr(rrrr)rrr)rrs rqcancel_async_evaluationzPyDB.cancel_async_evaluations ! &,.K  )16>71nC]bijkmxby y0QZZ85KNN&&( ) OO # # % "    ! OO # # %s:B+ B+ B+B+#B+3B+C+CCC"c h|jd}t|}|j} |jj} |r|jj } d|j_i} |r/|d} | (| j | | j<| j} | (|jj||| | | | }| j|j}|jj|tj 5g}t#tj$D]\}}|j&|j(k(r|jj|jj+||j,|jj|jj||j.t0d| |j3| ddd|j4j7|| 5|j9||||| dddy#1swYExYw#1swYyxYw)a busy waits until the thread state changes to RUN it expects thread's state as attributes of the thread. Upon running, processes any outstanding Stepping commands. :param is_unhandled_exception: If True we should use the line of the exception instead of the current line in the frame as the paused location on the top-level frame (exception info must be passed on 'arg'). rrmrN)frame_to_lineno)rr rrZtrace_suspend_type pydev_message tb_linenotb_frametb_nextrmake_thread_suspend_messagerthread_stack_strrrrLcustom_frames_lockr custom_framesrrK!make_custom_frame_created_messagenamerXr7rr1r_do_wait_suspend)rr(rXrr send_suspend_messageis_unhandled_exceptionr3rrrmessager,tbrfrom_this_threadr) custom_frames rqdo_wait_suspendzPyDB.do_wait_suspend+s &&(*&1 (( --@@ ,,::G8?F " " 5 O%Vn35<>y%Q\^egsFU>VC  ! ! #"33  KK # #C ( " 5 5 2! *9:O:]:]*^ 2&,))V\\9KK++D,<,<,^,^_giuiziz,{|KK++D,<,<,X,XYacocucuxJLNP\-]^ ''1  2 2 8 8 P PQZ\g h ]  ! !&%\K[ \ ] ] 2 2 ] ]sCH<H(H%(H1c |j}|jtk(r|js|j |jtk(rm|jsa|j r|j |jtjd|jtk(r |jsa|jt|tt||jtk(s|jt k(rd|_d|j$_n|jt(k(r+||_d|j$_|j+|nl|jt,k(r+|j+|d|_||j$_n.|jt.k(s|jt0k(r|j+|d}d} |j2} t4sc|j7|||j8|j:\}} } |rd|_t|_t<|_|jA||||||y |j7|||j8|j:\}} } tDrL|jF} |jHjK| || }|jLjO|d|_# |ru|jHjQt||j}|jLjO|t|_t0|_|jS||||yd|_t|_t<|_|jS||||dy|jtTk(r@|jV}|||_|j+|nd|_d|_tX|_~|jHjQt||j}|jLjO|tZj\5|D]6}|jLjO|jHj_|8 dddy#tB$r} d| z} Yd} ~ d} ~ wwxYw#tDrL|jF} |jHjK| || }|jLjO|d|_#wwxYw#1swYyxYw)NrFrrz%s)r9)0rZrrrrr%rrr'rr*r ridrr3r6pydev_step_stoppydev_smart_step_contextsmart_step_stopr4rRr:r8r2rr r&pydev_func_namepydev_next_liner7rr8 ValueErrorr r.r"make_set_next_stmnt_status_messagerrmake_thread_run_messager?r5f_backrrLr4r)rr(rXrr rr=rr"r#r$_err back_framer)s rqr8zPyDB._do_wait_suspendZsL%%   } ,T5S5S  ( ( *""m3D >r B >>- -  3  f&uc2  )@A$$VUK]a$b ( .  5 5i @E%  f\_`a\b de ' .  5 5i @Es$8C D &C((!D  D$D2c ~|jdd}|rJ| t|jj}t |d}|U|r*|j G|j tur5t|_n)|j |jur|j|_|j}|~y#t |}YxYw)NdisableFr) rrer co_filenamerd get_file_typerrrQrJ)rrXkwargsrYabs_path_real_path_and_base file_types rqrRz$PyDB.set_trace_for_frame_and_parentss**Y.z `.KELLLdLd.e+ &&A"&EFI }}0U]])5S(1 ]]$*=*==$($7$7EMLLE%( ! `.XY^._+s B-- B<c|j}||jt|x}|_|jyr)rrrxr)rcurr_pydb_command_threadnew_pydb_command_threads rq_create_pydb_command_threadz PyDB._create_pydb_command_threads@#'#<#< # / $ 9 9 ;>OPT>UU$";%%'rsc|j}||jt|x}|_|jyr)rrrr)rcurr_output_checker_threadrs rq_create_check_output_threadz PyDB._create_check_output_threads?%)%?%?" % 1 & ; ; ==Nt=TT :##%rscD|j|jyr)rbrers rqstart_auxiliary_daemon_threadsz#PyDB.start_auxiliary_daemon_threadss ((* ((*rsc|j|js|j |j|j d|_|j |rtj|jtstr7|jjd}|jj|yy)zO Shared code to prepare debugging by installing traces and registering threads Ncython)rbr.rr#rerU patch_threadsrrrQrTrWrmake_show_warning_messagerr)renable_tracing_from_startrs rqprepare_to_runzPyDB.prepare_to_runs ((*   4#9#9#EI]I]Ii  , , .#'D   $  # #D$7$7 8 #:""<77<<@$$^4ww~~h/#+0#*&&}5ww~~h/w8O#+0#*"CHHQK 77== dM:Jww~~j)!  ? x0AjjG *6' >F 88A;" 1::3H3HRS3U  HHOOArww}}U4[9!< = '' 3''..$2M2MQUQqQq--(,$    ! " $)!,    + N  / / ; *Aqyy{IxQXZ^`acgp}~qA B  ,! !VVXvtUV^bko p "),,. 3 $ MMO ""9a0   -a0D/DA   ,     !zz)^[$QWXX[  t " JJ  F G    !s> S.S>. S;:S;>5T5cN|stj||||S|r&t|d|g||}t||}||Sddl} t | dr@t jdddkr| j|d|S| j|d |S| j||S) zs This function should have frames tracked by unhandled exceptions (the `_exec` name is important). r)levelfromlistrrN_run_module_as_mainrrF) set_argv0) alter_argv) r"execfile __import__rJrunpyr|rnror run_module) rrrrrrrmodfuncrs rqrz PyDB._execs  " "4& 9( A@PZajpqsN35"78''+v511+1O 11+%1P$$[1rsctjjtjj|j |j j }|jj|yr) rnstdoutflushr~rrmake_exit_messagerrrs rqexitingz PyDB.exitingsT   ""$002 $rsc h|jtj}ddlm}|j dd|j dtjjtjjt||}t|}tj|t||i|j j#||}|j$j'| |j(r|j+|j-t/j0dB)Nr)pydevd_frame_utilsrConsoler)rr& currentThread_pydevd_bundlerFrameFCoderr{abspathrrr r,rrArmake_show_console_messagerrr%rrr'r)rrr(rrXrrs rqwait_for_commandszPyDB.wait_for_commandss $$&((*5"((r3E3K3KILNGGOO\^\c\c\k\klt\uLv4xzACJK)&1 ..y2e9e:LM88EJ $##%  * * , JJt  rs)Tr)F)FF)TF)NNFT)@rrrrrzr;r?rArErCpropertyrsetterrarfrirkrprrrtrrrrrrrrrrrrrrrrrrrrrr rrrr&r*r?r8rWrRrbrergrmrjrrrr_trace_dispatchrQrUrVrrsrqrr`sp b*H!C6& 5&'P]]'--_._ 7;GGA) . #* ##c C.+V,X [/z!)&P ;)| ;7)% 2,0 &-]^a_F.4(&+)"DYL6%(%N%O/rsrc"d|d<d|d<d|d<y)NTDEBUG_RECORD_SOCKET_READSrfrrkDEBUG_TRACE_LEVELrsetups rq set_debugrs#)-E %&'(E #$!"E rsc2ddlm}|j|y)Nr)pydev_monkey_qt) _pydev_bundlerpatch_qt)qt_support_moders rqenable_qt_supportrs-_-rsc.tj|y)zE Helper to dump thread info (default is printing to stderr). N)r+ dump_threads)streams rqrrsf%rsctjjdtjjd|rtjdyy)NzUsage: zUpydevd.py --port N [(--client hostname) | --server] --file executable [file_options] r)rnrrexit)doExits rqusagers:JJZ JJmn   rsc eZdZddZdZdZy) _CustomWriterNct|dtjjdd|_||_|rt ||d||_||_y)a :param out_ctx: 1=stdout and 2=stderr :param wrap_stream: Either sys.stdout or sys.stderr. :param bool wrap_buffer: If True the buffer attribute (which wraps writing bytes) should be wrapped. :param callable(str) on_write: May be a custom callable to be called when to write something. If not passed the default implementation will create an io message and send it through the debugger. encodingPYTHONIOENCODINGrvF) wrap_bufferon_writeN) rJrenvironrr_out_ctxrbuffer _on_write)rout_ctx wrap_streamrrs rqrzz_CustomWriter.__init__sI" ZHZ\c9de  '%ZbcDK!rscyrrrs rqrz_CustomWriter.flushs rsc|j|j|y|rtr#t|tr@|j dd}n-t|t r|j |jd}t}|B|jj||j}|jj|yyy)Nrvreplace)errors)rrryunicodeencodebytesdecoderrArmake_io_messagerrr)rrr|rs rqrz_CustomWriter.writes >> % NN1   a))4Aa'yAA')E ''774==I ((- ! rsr)rrrrzrrrrsrqrrs". .rsrcttdsktsdnd}tj}t d|||t_|t_tj|tj |t_yy)N_pydevd_out_buffer_TFrf) r|rnrrrrstdout_originalr) IORedirectorrroriginals rqrr*[ 3- ."(de ::"/8[("S&++Hc6M6M{[ /rscttdsktsdnd}tj}t d|||t_|t_tj|tj |t_yy)N_pydevd_err_buffer_TFr) r|rnrr~rrstderr_originalr)rrs rqrr2rrsc tj t||||||||tjy#tjwxYw)aSets the tracing function with the pydev debug function and initializes needed facilities. @param host: the user may specify another host, if the debug server is not in the same machine (default is the local host) @param stdoutToServer: when this is true, the stdout is passed to the debug server @param stderrToServer: when this is true, the stderr is passed to the debug server so that they are printed in its console and not in this process console. @param port: specifies which port to use for communicating with the server (note that the server must be started in the same port). @note: currently it's hard-coded at 5678 in the client @param suspend: whether a breakpoint should be emulated as soon as this function is called. @param trace_only_current_thread: determines if only the current thread will be traced or all current and future threads will also have the tracing enabled. @param overwrite_prev_trace: deprecated @param patch_multiprocessing: if True we'll patch the functions which create new processes so that launched processes are debugged. @param stop_at_frame: if passed it'll stop at the given frame, otherwise it'll stop in the function which called this method. N)_set_trace_lockr_locked_settracer) rstdoutToServerstderrToServerrsuspendtrace_only_current_threadoverwrite_prev_tracepatch_multiprocessing stop_at_frames rqrprp>sQJ "      % !   !!s =Ac|r ddlm}|jit_t st jtj|dt||d} | t_ t} | j||da|a |atr ttr t!t#| t%} t'| } | j(s"t+j,d| j(s"| j/t1j2t4j6j9 t;t4j<D] \} }| j/|j>" t4j6jA| jC| jEd|s"| jG| jIdtKjLtNndtQ} | j/t1j2t%} t'| } | jE|s| jG|rB|)tR| _*tV| _,|| _-t\| _/y| ja| tbyy#YxYw#t4j6jAwxYw) Nr pydev_monkeyF)clientserverr multiprocessTr)r>)rT)2rrpatch_new_process_functionsr=r connectedr* setup_type SetupHolderrintrrrrrr patch_stdinrrXr r'rrRrrJrLr4rrr5rXrrgr?rjrCatexitregister stoptracerArrr4rrBrrrr1)rrrrrrrrrrdebuggerrrZ_frameIdr>s rqrrvsQ 7 2  4 4 6460 !!#    $D 5 E !&K 6t$ --  "  "H " $4Q7'' JJsO'' 001C1CD0088: ?*9:O:]:]*^ M&,889K9KL M " 4 4 < < >//1T:(  " " $  6 6T 6 R  "'(001C1CD " $4Q7!(  " " $  $+4O '-:O *.;O ++9O (  M 2m  j " 4 4 < < >sJ!=trtjtjd t jdddlm}|t}|r5|jtd|jtdayy#YVxYw)Nr)undo_patch_thread_modulesT)rYF) rrrestore_sys_set_trace_funcrnrpr&rqrrArRrrrP)rrs rqrrs113 T    t $ I!#&(   4 4Y[$ 4 O     " $ +   s BBceZdZdZdZdZy) Dispatchercd|_yr)rrs rqrzzDispatcher.__init__s  rsc||_||_t|j|j|_t ||_d|j _|j jyr)rrrErDispatchReaderrrIr)rrrs rqrzDispatcher.connectsL  "499dii8 $T* ). & rscH |jjy#YyxYwr)rrrs rqclosezDispatcher.close s!  KK , , .  s!N)rrrrzrrrrsrqr r srsr cNeZdZdZeej dZdZdZy)r cf||_tj||jjyr) dispatcherr?rzr)rrs rqrzzDispatchReader.__init__s#$dDOO$:$:;rscbtj}d|_tj|Sr)r&rrHr?r)r dummy_threads rqrzDispatchReader._on_runs) ..0 .3 +##D))rsc.tj|yr)r? handle_exceptrs rqrzDispatchReader.handle_excepts""4(rscR|dk(r"t||j_d|_yy)NcT)rrrr)rcmd_idrtexts rqprocess_commandzDispatchReader.process_commands& R<#&t9DOO $D  rsN) rrrrzr-r?rrrrrsrqr r s0<|##$*%* )%rsr c&|jddS)z The new connection dispatch approach is used by PyDev when the `multiprocess` option is set, the existing connection approach is used by PyCharm when the `multiproc` option is set. multiprocF)rrs rq_should_use_existing_connectionr%s 99[% ((rsctj}|d}|d}t|r=t} |j |||j }|j ||fS||fS#|j wxYw)Nrr)rrrr rrr)rrrrs rqdispatchr-s{   E ?D =D&u-\     tT *??D     :4:    s A''A9cddlm}d|_ddlm}t \}}ddl}|j|)dada t||t||ddddyy)zo When creating a fork from a process in the debugger, we need to reset the whole debugger environment! r)GlobalDebuggerHolderN)clear_thread_local_infoFT)rrrrr) _pydevd_bundle.pydevd_constantsr! global_dbg)_pydevd_frame_eval.pydevd_frame_eval_mainr"rrrrforkedrMrp)r!r"rrrs rqsettrace_forkedr';sqE&*#QJD$-N--/  $& " . # %*/%)&*  rsceZdZdZy)rN)rrrrrrsrqrr_s Ersrc<ddd}|j||}t}|dratjtjj k(r t jjdnddl m }||_ |drt|dy y ) z/ :type setup_options: dict[str, bool] Fr)save-signatures qt-supportr*zACollecting run-time type information is not supported for Jython r)SignatureFactoryr+N) updater@r* get_vm_type PydevdVmTypeJYTHONrnr~r_pydevd_bundle.pydevd_signaturer,rr) setup_optionsdefault_optionsrr,s rqapply_debugger_optionsr4ds +0rBO=)#M "H&'  % % '>+F+F+M+M M JJ  a b I)9);H &\"- 56#rscTddlm}tj}|||t_y)Nr)DebugConsoleStdIn)_pydev_bundle.pydev_stdinr6rnstdin)rr6 orig_stdins rqrrzs;J!(J7CIrsc0t}|sy|jtj\}}}|rE|jj j }|j|rd|vrn|j}|rE|rd}|j}|r|j|jurd}|r|jj j }ttjj|sd|vrnD|dz }|jr/|jj|jur |j}nn|r |j|}d|_t#j$t'||||t)y#t$r ||_YFwxYw)N_pydevdrf)limit)rArArnrr0rrZrfr1r[rr{basenamewith_tracebackr: __traceback__ __cause__rprint_exceptiontyper0)rrKrVr<rer<r1s rqhandle_keyboard_interruptrCsa"$H  <<>LAub ;;%%11  $ $X .9H3L  ZZ  ** w''2;;6G''..::HRWW--h78I OO'%-78 OOOS]23eii 489%05 :UWfXAXA1BO-.3ii8QSbSzSz.{O+(- 2EGhGh(iO% =D ?D f A vH=2.   4 4 6 ;  OO9 :#J #""4.??.%??DOO$8$$>?NN#OQSQZQZQ\#\].$@@B OO$_`  " &EEG vv()R/77##A&112DE$&GGOOA$6M#%77<< y#ILww~~l32%),%CG,@-0_-A/271:!/CGK0D(- !.!'  4((*hI RS77??8,"$'',,x9\"] 58OOP"h 5 58IIK 34 56  U6]D$ U K ! "'6'8H $  !,9O)u%    T4 (  ll5=$iHG    & &w / A  a C\.!(LM!++-  " & DE##%4!' 2%//1w  X  MMO  <  JJ  dK L    ! HHQK !  % '  s'WW5Z'A,X0W?X0;Y. Z ;AY6>A1Y6/Z Z/[\+(W21W25W<?+X-*X00Y+Y36ZZ Z$'Z,/[2[[[  [A\(+ ]4 \??]__main__r)r) NFFi.TFFFN)rrn contextlibrr-_pydevd_bundle.pydevd_collect_try_except_inforro RuntimeErrorrrrr functoolsr collectionsr r#r r r r rrrrrrrrrrrrrrrrrrr rr!r"r#(_pydev_bundle._pydev_filesystem_encodingr$#_pydev_bundle.pydev_is_thread_aliver% _pydev_imps._pydev_saved_modulesr&r'r(rr)r*rr+r,_pydev_bundle.pydev_overrider-!_pydevd_bundle.pydevd_breakpointsr.r/r0_pydevd_bundle.pydevd_commr1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrK#_pydevd_bundle.pydevd_custom_framesrLrM!_pydevd_bundle.pydevd_frame_utilsrNrO-_pydevd_bundle.pydevd_kill_all_pydevd_threadsrP$_pydevd_bundle.pydevd_trace_dispatchrQrrRrSrTr%rUrVrW,_pydevd_bundle.pydevd_additional_thread_inforX_pydevd_bundle.pydevd_utilsrY5pydevd_concurrency_analyser.pydevd_concurrency_loggerrZr[r\r]2pydevd_concurrency_analyser.pydevd_thread_wrappersr^r_pydevd_file_utilsr`rarb pydev_ipython&_pydevd_bundle.pydevd_dont_trace_filesrcrdrerr[__version_info____version_info_str__vrrr __version__rrr`rt"_pydevd_bundle.pydevd_plugin_utils enumeraterOrr__excepthook__rQrrrrremoter&file_system_encodingrxrobjectrrrrrrrrrrrrprrrrr r rrr'rr4rrC#_pydevd_bundle.pydevd_extension_apirDrEextensions_of_typehandleron_debugger_modules_loadedrbrrrsrqrsD  %MBQ& e ff #MMMMMMM&2J?6134'&2nn\\\\\\\\daPkkDDS8xxYBB=g  (AA'(hh+, 3 $$ @(("00((  NN7    ,. /(/D&!(&!R*&*4[=[=|)KH{06{0z## . &1.F1.h\\  #2"l'&&&(m3`2$%\%()  H 7,8 &TE18%889MNEG && &DE h0T zFg? s 7LL!