Mh+ddlZddlZddlZddlZddlZddlmZddlmZm Z ddl m Z m Z m Z ejZeZejZGdde jZdZdZd ZdS) N)common)logutil) components launchersserverscveZdZdZejdZfdZdZdZ dZ dZ dZ d d Z d d Zd ZxZS)SessionzA debug session involving a client, an adapter, a launcher, and a debug server. The client and the adapter are always present, and at least one of launcher and debug server is present, depending on the scenario. c0ddlm}tt j_tj_ t j j_ tj |j_ tj t j_ tj t&j_ d_ d_ i_ d_ xjfdgz c_dS)Nr)clientsFc,SN)notify_changed)_selfs X/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/debugpy/adapter/sessions.pyz"Session.__init__..@sd&9&9&;&;)debugpy.adapterr super__init__ threadingRLocklocknext_counterid Condition_changed_conditionrmissingClientclientrLauncherlauncherrServerserverno_debugpid debug_options is_finalizing observers)rr __class__s` rrzSession.__init__s++++++ O%% t}%%"+"5di"@"@ (w~>> 3"*41CDD  !(w~>>   21I"2 ;;;;<<rcd|jdS)NzSession[]rrs r__str__zSession.__str__Bs$$'$$$$rc8|j|S)z&Lock the session for exclusive access.)racquirer1s r __enter__zSession.__enter__Es  rc8|jdS)zUnlock the session.N)rrelease)rexc_type exc_valueexc_tbs r__exit__zSession.__exit__Js rct5t|tddddS#1swxYwYdSr)_lock _sessionsadd_sessions_changedsetr1s rregisterzSession.registerNs  $ $ MM$     ! ! # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s4A  A A c|5|jdddn #1swxYwY|j|j|jf}t d|Drst 5|tvrHtj d|t |t ddddS#1swxYwYdSdS)Nc3,K|]}| p|j VdSr) is_connected).0coms r z)Session.notify_changed..Zs/EE33w.c..EEEEEErz{0} has ended.) r notify_allr#r%r'allr=r>rinforemover@rA)rrs rrzSession.notify_changedSs]  1 1  # . . 0 0 0 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 [$-< EE*EEE E E , , ,9$$H-t444$$T***%))+++  , , , , , , , , , , , , , , , , , , , ,s)--(ACC C NcJfdd_1tjd}d|_|5|s8jr ddddSj|8 ddddS#1swxYwYdS)a`Waits until predicate() becomes true. The predicate is invoked with the session locked. If satisfied, the method returns immediately. Otherwise, the lock is released (even if it was held at entry), and the method blocks waiting for some attribute of either self, self.client, self.server, or self.launcher to change. On every change, session is re-locked and predicate is re-evaluated, until it is satisfied. While the session is unlocked, message handlers for components other than the one that is waiting can run, but message handlers for that one are still blocked. If timeout is not None, the method will unblock and return after that many seconds regardless of whether the predicate was satisfied. The method returns False if it timed out, and True otherwise. cftjd_dS)NT)timesleep timed_outr)rtimeoutwait_for_timeoutsrrSz*Session.wait_for..wait_for_timeoutss4 Jw   )-  &    ! ! ! ! !rFNzSession.wait_for() timeout)targetnameT)rQrThreaddaemonstartr wait)r predicaterRthreadrSs` ` @rwait_forzSession.wait_forasF$ " " " " " " " &+"  %'.JF!FM LLNNN   ikk /#-!         ',,... ikk /                   sB'$BBBcJ|jrdSd|_tjd|||t|j} |||n9#t $r,tjd|tj dYnwxYwtjd|dS)aFinalizes the debug session. If the server is present, sends "disconnect" request with "terminateDebuggee" set as specified request to it; waits for it to disconnect, allowing any remaining messages from it to be handled; and closes the server channel. If the launcher is present, sends "terminate" request to it, regardless of the value of terminate; waits for it to disconnect, allowing any remaining messages from it to be handled; and closes the launcher channel. If the client is present, sends "terminated" event to it. If terminate_debuggee=None, it is treated as True if the session has a Launcher component, and False otherwise. NTz{0}; finalizing {1}.z Fatal error while finalizing {0}r z{0} finalized.) r+rrKboolr% _finalize Exceptionswallow_exceptionos_exit)rwhyterminate_debuggees rfinalizezSession.finalizes"    F! 'd333  %!%dm!4!4   NN3 2 3 3 3 3     !"Dd K K K HQKKKKK   !4(((((sA3B  B ctjjrjjrc|r-jr&jjrjn4 jjdd|in#t$rYnwxYwj jrjjr jr_jj j sNtj dfdtjstjdjrjj j sjtj djfd jjn##t$rtjYnwxYwjrjjrEi}jjrd |d < jjd |n#t$rYnwxYwjjIjjjd kr5jrjj j stjtj d t5jr+jjjj fdtjD}t=|sdS|D]|}tj d| t?j |jtBj"n%#t$rtjd|YnwxYw|j}dSdSdSdS)N disconnectterminateDebuggeez!{0} waiting for "exited" event...c jjduSr)r% exit_coder1srrz#Session._finalize..sDM34?r)rRz){0} timed out waiting for "exited" event.z${0} waiting for {1} to disconnect...cjj Sr)r%rEr1srrz#Session._finalize..sdm&@"@rTrestart terminatedlaunchz>"launch" session ended - killing remaining debuggee processes.c&g|] }|jv |Sr))rFconn pids_killeds r z%Session._finalize..s0 8;66666rz Killing {0}zFailed to kill {0})#rdont_wait_for_first_connectionr'rEr%rechannelrequestr`detach_from_session connectionprocess_replacedrrKr\rPROCESS_EXIT_TIMEOUTwarningcloserar#restart_requested send_event start_requestcommand stop_servingrAr)r? connectionslenrbkillsignalSIGTERM)rrdrebodyconnsrsrts` @rr_zSession._finalizes .000 ; .{' % $- DM@R*S% K + + - - - = (T]7 ({ S4;#9#J S.s/LL9K9KW9K9K9K9KLLr)r=rr>rrs`rgetr s TTLLLLILLLdSSTTTTTTTTTTTTTTTTTTs !7;;c t5tts ddddStdddn #1swxYwYtt)zvBlocks until all sessions have ended. A session ends when all components that it manages disconnect from it. TN)r=rr>r@clearrYrqrrwait_until_endedrs !  & &y>>  & & & & & & & &  # # % % % & & & & & & & & & & & & & & &    !sAAAActsdSttdd}|j}||dSdS)Nc|jSrr0)rs rrz report_sockets.."sGJr)keyr)r>sortedr#report_sockets)rr#s rrrsW Y$>$>???BG ^F r)rrbrrrOdebugpyrdebugpy.commonrrrrrrrr=rAr>Eventr@ Observabler rrrrqrrrs   $$$$$$$$::::::::::   CEE #IO%%u2u2u2u2u2dou2u2u2pTTT ! ! !     r