eb d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
n # e $ r Y nw xY wd dl Z d dl
Z
d dlT d dlmZ d dlmZ d dlmZ d dlmZ G d dej Zd Zdd
Zd Z G d d
ej Z G d dej Z G d d Z d Z!e"dk r e! dS dS ) N)*)Console)
mutnodeset)ptable)cmdc e Zd ZdS )ServerN)__name__
__module__ __qualname__ g/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/guppy/heapy/Monitor.pyr r s Dr r c X t j | gg g | \ }}}t | S N)selectlen)fdwaitrwxs r ioreadyr s* mRD"b$//GAq! q66Mr c h | d S # t j $ r |rY d S Y nw xY w2)N g?)timeout)getqueueEmpty)qnoblocks r queue_get_interruptibler" $ s[ 555%% %{
s 00)CLOSEDc > e Zd ZdZd Zd Zd Zd dZd Zd Z d Z
d
S ) Handlerr c | j d ss| j j | | j t | j d | j
d S d S )Nr ) isclosedtasservermonitorremove_connectiondataqput CONN_CLOSEDrequestshutdowncloseselfs r r2 z
Handler.close5 s } ## ! K 1 1$ 7 7 7 JNN; ' ' ' L ! !! $ $ $ L ! !r c |j d s|dz
}| j |j d d S )N
utf-8)endswithr0 sendencoder4 r s r send_cmdzHandler.send_cmd< sG s|D!! 4KC *#*W--.....r c | j dk r| dd | j dk r| dd | |d S )Nz>>> r r )retdataz cont)promptexec_cmdr; s r browser_cmdzHandler.browser_cmdA s^ ;& MM#qM ) ) ) ;* $ $ MM&!M , , ,}}S!},,,r r c 6 | | | d| _ g } t | j | }| | j rnt j d 5|t u rt |d dk rKd| _ |r | |d njt j
|d nD|d dk r6|d | _ | j
rd| _ n d| _ nJ |rd | S d S )NFr r DATAPROMPTT )r< promptstater" r- timesleepr/ EOFErrorappendsysstdoutwriter@ emptyjoin)r4 r r> r! datasps r rA zHandler.exec_cmdH s6 ? MM# $D '
G<> ! " "r c | j d D ]S}| | r rD )r@ rG r r( r Queuer- r* r+ add_connectionrfilereadlinedecoderJ r8 re socketerrorREADLINEr r. rA rU r2 )r4 rb r@ s r handlezHandler.handlev sd "
[]]
**4000 /
z**,,33G<< 2"=111==&& +"6***+ fl+
}}X&&
/ oH
~o.
& 1222;&%)]]tQ]%G%GDN
~... /
s A&C CCN)r r ) r
r r allow_reuse_addressr2 r< rB rA r] rc rn r
r r r% r% 2 s ! ! !/ / /
- - - " " " "B " " " r r% c e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d Z d
Z e
j j Zd Zd Zd
Zd Zd Zd Zd Zd Zd Zd Zd Zd Z dS )MonitorConnectionr c r i | _ t j | d| _ d| _ d| _ d| _ || _ t t t ft x| _
}|| j
_ t j | j d | _ | j d S )Nr z
r
)targetargs)aliasesr Cmd__init__hnor( forceexitr@ r+ r LOCALHOST HEAPYPORTr% r* threadingThread
run_serverststart)r4 r+ ss r rw zMonitorConnection.__init__ s
" )Y!7AAA a % "$/(*, , ,
r c d| _ | j j d | j d | j _ d S )Nr r' c dS Nr r
)r ys r z)MonitorConnection.close.. s ! r )r( r* rk r1 server_closeverify_requestr3 s r r2 zMonitorConnection.close sH
##A&&& """%3^ """r c t j | | t j | d d S )NrF )r rv defaultdo_help)r4 r[ s r r zMonitorConnection.default s4 d### b!!!!!r c | j }| j s| | j | d S r )r* r( handle_requestr )r4 r s r r~ z MonitorConnection.run_server sG K-
- r c |sd S |} | | }| | }| || }|S # t $ r | | Y d S w xY wr )precmdonecmdpostcmd
BaseException handle_error)r4 r r[ stops r rA zMonitorConnection.exec_cmd s
F $;;t$$D;;t$$D<<d++DK $ $ $ d # # # # # # $s AA
A-,A-c t dt j t ddt j t t | t j ddl} |j t dt j dS )ztHandle an error gracefully. May be overridden.
The default is to print a traceback and continue.
z(----------------------------------------)filez0Exception happened during processing the command )endr r N)printrL stderrrepr traceback print_exc)r4 cmdliner s r r z MonitorConnection.handle_error s f3:&&&&
@CJ ( ( ( (
d7mm#*----
f3:&&&&&&r c r || _ |s|S | }|d | j v r | j |d }d|v rd}|dd D ]n}| dt | z | }| dt | z d ||d }|dz }o| dd |dd }n#|dz d |dd z }| }|d | j v |d dk rp| d }|dk rU||d
z d }| j | |d|
}|S ) z*Handle alias expansion and ';;' separator.r %r Nz%>=r z%*aliasz;;r' ) curlinerV ru replacestrrP findlstripcmdqueuerK rstrip)r4 r[ rt iitmpArgmarkernexts r r zMonitorConnection.precmd s Kzz||1g %%<Q(Dd{{ "122h F <<c"gg
(. 0 0D <<B(+bcc(;(; = =DaBB||D#((48*<*<==czCHHT!""X$6$66::<A Ac $ t d d S )Nzint
-----
Local interactive console.
This will bring up a Python console locally in
the same interpreter process that the Monitor itself.r r3 s r help_intzMonitorConnection.help_int s#
9 : : : : :r c |s| j }t | }| j j | }| d rt d d S t d|z | t d S )NnoninterruptiblezCError: Can not interrupt this remote connection (uses Python < 2.4)z+Sending KeyboardInterrupt to connection %s.)conidintr+ connectionsr] r r< KEYBOARDINTERRUPT)r4 r cs r do_kizMonitorConnection.do_ki s *C#hh L $S ) 88& ' ' * G
H
H
H
H
H
?#E F F F
JJ( ) ) ) ) )r c $ t d d S )Na\ ki
-----
Keyboard Interrupt
Send a command to interrupt the remote thread on the specified
connection (default is the last one connected to).
Notes:
It currently only works with Python >= 2.4. The remote thread will
not always be awakened, for example if it is waiting in
time.sleep(). Sometimes using several ki commands helps.r r3 s r help_kizMonitorConnection.help_ki% s#
< = = = = =r c g dg}t | j j D ]C\ }}| || d | d g Dt
|| j d S )N)CIDPIDARGVz
target.pidztarget.sys.argv)listr+ r itemsrK r] r rM )r4 r tablecidr s r do_lczMonitorConnection.do_lc3 s '''( T\ 5 ; ; = =>> : :HC LL# **\22 **%6779
:
:
:
: udk"""""r c $ t d d S )Na lc
-----
List Connections.
List the currently open connections.
The table printed has one line per connection in this form:
CID PID ARGV
1 17999 ['/home/nilsson/bin/solitaire.py']
CID is the connection ID, which may be used as argument to the sc
command.
PID is the process ID of the target interpreter process. In Linux,
this is the parent of the remote control interpreter thread that runs
the Annex that the connection is talking to.
ARGV is the argument vector in the target Python interpereter.r r3 s r help_lczMonitorConnection.help_lc< s)
B C C C C Cr c |rt | | _ t d| j z | j | j j | j d S )NzFRemote connection %d. To return to Monitor, type or .)r r r r+ set_connectionr r s r do_sczMonitorConnection.do_scO sW " SDJ
VY]Yccddd ##DL$
-----
Set connection to communicate with a remote thread.
With an argument, set current connection to the number specified.
Without argument, use the same connection as last time. You will then
be talking to a remote process via that connection. You can return to
Monitor at any time by . You may also use the '.' command
(followed by ), if the remote process is waiting for input.
The '.' character may be followed by a monitor command, to execute it
directly instead of returning to the monitor. For example, when
talking to a connection, '.sc 1' will directly change to connection 1.r r3 s r help_sczMonitorConnection.help_scU s)
J K K K K Kr c dS r r
r s r do_qzMonitorConnection.do_qc s qr c $ t d d S )Nzq
-----
Quit from the monitor.
This will not exit from Python itself if called from an interactive
interpreter. To make sure to exit from Python, use the exit command.r r3 s r help_qzMonitorConnection.help_qf s)
H I I I I Ir N) r
r r
use_raw_inputrw r2 r r~ rA r r r r r rv r do_hr r r r r r r r r r r r r
r r rq rq sp M
4 4 4 " " "
$
$
$ ' ' ' > 7?DD D D : : :
*
*
* = = = # # #C C C&J J J K K K I I I I Ir rq c B e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d Z d
S ) Monitorr c f t | x| _ | _ i | _ d| _ d | _ d S r )rq
connectionmonitor_connectionr idsr@ r3 s r rw zMonitor.__init__q s3 4Ed4K4KK$1 r c | j sd| _ | j | j _ nIt dgd t | j D z dz | _ | j S )Nr c g | ]}|S r
r
).0r s r
z!Monitor.newid..| s I I Ia I I Ir )r r r r maxr keysr3 s r newidz
Monitor.newidw sm MDH,0HD # ) )A3 I I40@0E0E0G0G+H+H I I IIJJ1LDHxr c | }|| j |< ||_ | d|z d S )Nz *** Connection %s opened ***)r r
monitor_id print_async)r4 r hids r rg zMonitor.add_connection sD jjll * #
7#=>>>>>r c | j Vt d|z t j | j t j dS dS )zS Print text only if we are waiting for input,
and then restore the prompt. Nr6 )r@ r rL rM rN flush)r4 texts r r zMonitor.print_async sX ; " $t) J T[ ) ) ) J # "r c | j |j = || j u r| | j | d|j z d S )Nz *** Connection %s closed ***)r r r r r r r4 r s r r, zMonitor.remove_connection sd Z 2 3 ( ( 7 8 8 8 7#./ 0 0 0 0 0r c d}|s1 |s| j }|j | _ || j ur| d d t |j }d | _ d } |j d r%|dk r
| j | _ n|dd }| j }n| j }|r6 | | }n# t $ r d}Y nw xY w|| j u r|rd}|nd# t $ r! t d | j | _ d}Y n:t $ r. t d t d | j | _ Y -w xY w|1d | _ | d S # d | _ | w xY w)Nr r )r r! .z%*** End Of File - Exiting Monitor ***KeyboardInterruptz1Use the ki command to interrupt a remote process.)
r r@ r rA inputrW rJ r r r2 )r4 r connr r s r runz Monitor.run s ) D #
" " ) #&*k t'>>> MMdAM > > > #DK 0 0&* #)3>#.. 3 "czz262I&)!""g'+'> $(?D ) &$(MM#$6$6#+ & & &$% & #t'> > >1 >'(/ # )0 EABBB&*&=DO DDD( -...MNNN&*&=DO H ? #
L DK JJLLLLL DK JJLLLLs_ E BC B/ .C / B>;C =B>>C E (D29E ;3D2.E 1D22E E2c P t | j D ],} | # t j $ r Y )w xY w | j n# t j $ r Y nw xY w| j j rt j d d S d S r )
r r valuesr2 rk rl r ry os_exit)r4 r s r r2 z
Monitor.close s d&--//00 A
<
# ) ) + + + +| D " , HQKKKKK s! ?AAA/ /B Bc , || _ |j | _ d S r )r r@ r s r r zMonitor.set_connection s $ ' r N) r
r r r rw r rg r r, r r2 r r
r r r r n s M ? ? ? 0 0 0* * *X ( ( ( ( (r r c ~ ddl m} | t }| dS )zmonitor() [0]
Start an interactive remote monitor.
This can be used to get information about the state, in
particular the memory usage, of separately running Python
processes.
References
[0] heapy_Use.html#heapykinds.Use.monitorr )RemoteN) guppy.heapyr offr r )r ms r r+ r+ s= #"""""
JJLLL AEEGGGGGr __main__)r )#r pprintsignalrk socketserverrL r| rH r r_ ri ImportErrorr r guppy.heapy.RemoteConstantsguppy.heapy.Consoler
guppy.setsr
guppy.etc.etcr guppy.etcr ThreadingTCPServerr r r" r/ StreamRequestHandlerr% rv rq r r+ r
r
r r r s1
OOOO D
) ) ) ) ' ' ' ' ' ' ! ! ! ! ! ! \
,
\ \ \ \ \l/ \ \ \~ZI ZI ZI ZI ZI ZI ZI ZIza( a( a( a( a( a( a( a(H " z GIIIII s / 77