o h-@sddlZddlZddlZddlZddlZddlmZddlmZm Z ddl m Z m Z m Z eZeZeZGddde jZddZd d Zd d ZdS) N)common)logutil) components launchersserverscsneZdZdZedZfddZddZddZ d d Z d d Z d dZ dddZ dddZddZZS)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. csddlm}tt_tj_ t j_ t |j_ t tj_ t tj_ d_ d_ i_ d_ jfddg7_dS)Nr)clientsFcsSN)notify_changed)_selfNc:\Users\shubh\Videos\agent\nova\Lib\site-packages\debugpy/adapter/sessions.py@sz"Session.__init__..)debugpy.adapterr super__init__ threadingRLocklocknext_counterid Condition_changed_conditionrmissingZClientclientrZLauncherlauncherrServerserverZno_debugpidZ debug_options is_finalizingZ observers)rr  __class__rrrs(    zSession.__init__cCsd|jdS)NzSession[]rrrrr__str__BszSession.__str__cCs|j|S)z&Lock the session for exclusive access.)racquirerrrr __enter__Es zSession.__enter__cCs|jdS)zUnlock the session.N)rrelease)rexc_type exc_valueexc_tbrrr__exit__JszSession.__exit__cCs<tt|tWddS1swYdSr )_lock _sessionsadd_sessions_changedsetrrrrregisterNs  "zSession.registercCs| |jWdn1swY|j|j|jf}tdd|DrXt$|tvrFt d|t |t WddSWddS1sQwYdSdS)Ncss|] }| p |j VqdSr ) is_connected).0comrrr Zz)Session.notify_changed..z{0} has ended.) r notify_allrr r"allr1r2rinforemover4r5)rrrrrr Ss    "zSession.notify_changedNcsfddd_durtjdd}d|_|!|s7jr/ WddSj|r# WddS1sCwYdS)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. cstd_dS)NT)timesleep timed_outr rrtimeoutwait_for_timeoutrrrEss  z*Session.wait_for..wait_for_timeoutFNzSession.wait_for() timeout)targetnameT)rBrThreaddaemonstartrwait)r predicaterDthreadrrCrwait_foras" $zSession.wait_forcCsz|jrdSd|_td|||durt|j}z|||Wnty4td|t dYnwtd|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$rr>boolr _finalize Exceptionswallow_exceptionos_exit)rwhyterminate_debuggeerrrfinalizes   zSession.finalizec sbtjr5jjr0|rjrjjrjnz jjdd|iWn ty/Ynwj jrjjrjr\jj j s\t djfddtjds\t djrdjj j sijt djfd dzjjWn tyt Ynwjr)jjri}jjrd |d <z jjd |Wn tyYnwjjdur+jjjd kr-jrΈjj j s/tt dtjrjjdurjj fddtD}t|sdS|D])}t d|z t |jt!j"Wnty t d|Ynw|jqqdSdSdSdS)NZ disconnectZterminateDebuggeez!{0} waiting for "exited" event...cs jjduSr )r exit_coderrrrrs z#Session._finalize..)rDz){0} timed out waiting for "exited" event.z${0} waiting for {1} to disconnect...cs jj Sr )r r7rrrrrs TZrestartZ terminatedZlaunchz>"launch" session ended - killing remaining debuggee processes.csg|] }|jvr|qSrr#)r8conn) pids_killedrr s  z%Session._finalize..z Killing {0}zFailed to kill {0})#rZdont_wait_for_first_connectionr"r7r rVZchannelrequestrQZdetach_from_session connectionZprocess_replacedrr>rNrZPROCESS_EXIT_TIMEOUTwarningcloserRrZrestart_requestedZ send_eventZ start_requestcommandZ stop_servingr5r#r3 connectionslenrSkillsignalSIGTERM)rrUrVbodyZconnsrZr)r[rrrPs             zSession._finalizer )__name__ __module__ __qualname____doc__ itertoolscountrrr)r+r0r6r rNrWrP __classcell__rrr%rrs  $  &#rcs@ttfddtDdWdS1swYdS)Nc3s|] }|jkr|VqdSr rY)r8sessionrYrrr:r;zget..)r1rr2rYrrYrget s$rpcCsR ttts WddStWdn1swYtq)zvBlocks until all sessions have ended. A session ends when all components that it manages disconnect from it. TN)r1rcr2r4clearrKrrrrwait_until_endeds rrcCs:tsdSttdddd}|j}|dur|dSdS)NcSs|jSr r()rorrrr"sz report_sockets..)keyr)r2sortedrreport_sockets)rorrrrrus ru)rlrSrerr@ZdebugpyrZdebugpy.commonrrrrrrrr1r5r2Eventr4Z Observablerrprrrurrrrs  y