Submit
Path:
~
/
/
opt
/
alt
/
python37
/
lib64
/
python3.7
/
site-packages
/
guppy
/
heapy
/
__pycache__
/
File Content:
Remote.cpython-37.pyc
B �]>= � @ s d Z ddlmZ ddlmZ ddlmZmZ ddlT ddl m Z ddl m Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlZddlZG d d � d e�ZG d d � d �ZG d d� dej�ZG dd� d�Z G dd� d�Z G dd� dej �Z dd� Z dd� Z!da"da#e �$e!� dS )z4 Support remote access to a Python interpreter. � )�cmd)�hpy)�heapyc�Target)�*)�Console)� mutbitsetNc @ s e Zd ZdS )� SocketClosedN)�__name__� __module__� __qualname__� r r �E/opt/alt/python37/lib64/python3.7/site-packages/guppy/heapy/Remote.pyr s r c @ s e Zd Zdd� Zdd� ZdS )�IsolatedCallerc C s || _ d S )N)�func)�selfr r r r �__init__" s zIsolatedCaller.__init__c O s | j ||�S )N)r )r �args�kwdsr r r �__call__% s zIsolatedCaller.__call__N)r r r r r r r r r r s r c @ s e Zd Zddd�ZdS )�QueueWithReadline���c C s0 x*y | j dd�S tjk r& wY qX qW d S )Ng �?)Ztimeout)�get�queueZEmpty)r �sizer r r �readline* s zQueueWithReadline.readlineN)r )r r r r r r r r r ) s r c @ s* e Zd Zdd� Zedd� �Zd dd�ZdS ) �InterruptableSocketc C s< || _ | j j| _| j j| _| j j| _| j j| _| j j| _d S )N)�_backing�fileno�close�readable�writable�seekable)r Zbackingr r r r 6 s z InterruptableSocket.__init__c C s | j jS )N)r �closed)r r r r r# > s zInterruptableSocket.closedr c C s( xt � | gg g d�d sqW | j�|�S )Ng �?r )�selectr �read)r r r r r r% B s zInterruptableSocket.readN)r )r r r r �propertyr# r% r r r r r 5 s r c @ s( e Zd Zdd� Zd dd�Zd dd�ZdS ) � NotiInputc C s || _ || _d S )N)�input�output)r r( r) r r r r J s zNotiInput.__init__r c C s | � |�S )N)r )r r r r r r% N s zNotiInput.readc C s | j �t� | j�|�S )N)r) �writeZREADLINEr( r )r r r r r r R s zNotiInput.readlineN)r )r )r r r r r% r r r r r r' I s r' c @ s� e Zd ZejZejZdZdZ d-dd�Z dd� Z dd � Z d d � Z d d � Zdd� Zdd� ZejjZdd� ZeZdd� Zdd� ZdZdd� Zdd � Zd d � Z d d � Z d!d"� Z d#d$� Z d%d&� Z d'd(� Z!d)d*� Z"d+d,� Z#dS ).�Annexr z<Annex> Nc C sh t j�| � |d krt}t|f| _|| _|jjd � | j �|_ d | _ d| _ t�� | _i | _| �d� d S )Nzguppy.heapy.Remoter � )r �Cmdr Z HEAPYPORTZ LOCALHOST�server_address�target�sys�modulesr � asynch_closer �socket�isclosed�_thread� allocate_lock� closelock� intlocals�do_reset)r r/ Zportr r r r ] s zAnnex.__init__c C sX | j �� z| js d| _| �� W d | j �� X x"t| d�rR| j�� rRt� d� q2W d S )N� �thg �?) r7 �acquirer4 � disconnect�release�hasattrr; Zis_alive�time�sleep)r r r r r2 n s zAnnex.asynch_closec C s� t � | j| j�| _ x`| jsny| j �| j� W n< tk rB � Y q t jk rh | jrZ� t� d� Y qX P qW d S t j | j j ddd�ddd�| _ tt j t| j j ddd��ddd�| j �| _tj| _| �� tjj| | j| j d � d S ) N� �wbr )� bufferingzutf-8T)�encoding� write_through�rb)�stdin�stdout)r3 �address_family� socket_typer4 �connectr. � SystemExit�errorr@ rA �io� TextIOWrapperZmakefilerI r' r rH r0 �stderr�start_ki_threadr r- r )r r r r rL � s, z Annex.connectc sb t � ��j� t�� jd��_�j�� ���fdd�}tj|dd��_�jd j �j_ �j� � d S )N)r( r) c st zRxL��j krN� j�� } | s P | tkrB��j krLt��jjt� q�� | � qW W d ��j krnt��jjt � X d S )N) r3 r( r ZKEYBOARDINTERRUPTr � set_async_excr/ � annex_thread�KeyboardInterruptZputr )�line)�ostdinr r r3 r r �run� s z"Annex.start_ki_thread.<locals>.runr )r/ r �hp) r rH r' r) r3 � threadingZThreadr; r8 � _hiding_tag_�start)r rX r )rW r r r3 r rR � s zAnnex.start_ki_threadc C s� | j }|d krd S d | _ y|�t� W n tk r: Y nX y|�t j� W n tk r` Y nX y |�� W n tk r� Y nX d t_d S )N) r3 �sendZDONE� ExceptionZshutdownZ SHUT_RDWRr r0 �last_traceback)r Zsockr r r r= � s" zAnnex.disconnectc C s | � � dS )Nr: )r2 )r �argr r r �do_close� s zAnnex.do_closec C s t d| jd� d S )Na� close ----- Close and disable this remote connection completely. It can then not be reopened other than by some command from within the target process. Normally you shouldn't need to use this command, because you can return to the Monitor via other commands (<Ctrl-C> or .) keeping the connection open. But it might be useful when you want to get rid of the remote control interpreter and thread, if it uses too much memory or disturbs the target process in some other way.)�file)�printrI )r r r r � help_close� s zAnnex.help_closec C s t d| jd� d S )Nz�h(elp) ----- Without argument, print the list of available commands. With a command name as argument, print help about that command.)rb )rc rI )r r r r �help_h� s z Annex.help_hc C sl t j}t j}t j}z@| jt _| jt _| jt _tt jt j| jd�}|�d|j � W d |t _|t _|t _X d S )N)rH rI �localsz8Remote interactive console. To return to Annex, type %r.)r0 rH rI rQ r r8 ZinteractZEOF_key_sequence)r r` rW ZostdoutZostderrZconr r r �do_int� s z Annex.do_intc C s t d| jd� d S )Na{ int ----- Interactive console. Bring up a Python console in the Remote Control interpreter. This console will initially have access to a heapy constructor, named hpy, and a ready-made instance, named hp, and the target (see also the reset command). Other things may be imported as needed. After returning to the Annex (by q) or to the Monitor (by . or <Ctrl-C>), the data in the interactive console will remain there - and will be available till the next time the console is entered. But the data may be cleared and reset to the initial state - a new heapy instance will be created - by the 'reset' command of Annex. It should be noted that the interpreter thread under investigation is executing in parallell with the remote control interpreter. So there may be some problems to do with that if both are executing at the same time. This has to be dealt with for each case specifically.)rb )rc rI )r r r r �help_int s zAnnex.help_intZ a1e55f5dc4c9f708311e9f97b8098cd3c C s� | j d }g }|| _g }|| j | j< td| j � ||| j d | j |g}|�� }|j|� |@ r�td| jd� xZt|�D ]>\}}|�|�|@ rttd| | jd� t|�|�j | jd� qtW ntd| jd� | `| j | j= d S )NrY �0� __builtins__zIsolation test failed.)rb z)-- Shortest Path(s) to testobjects[%d] --zIsolation test succeeded.) r8 Z_a�_bname�eval�heapZisorc rI � enumerateZshpaths) r r` rY �a�bZ testobjects�h�i�vr r r � do_isolatest# s, zAnnex.do_isolatestc C s t d| jd� d S )Nad isolatest ---------- Isolation test. Test that the target interpreter heap view is isolated from the data in the remote control interpreter. Data introduced here, eg in the interactive console, should not be seen in the heap as reported by hp.heap() etc. This is achieved by setting hp to not follow the calling interpreter root. However, this isolation may become broken. This test is intended to diagnose this problem. The test checks that none of a number of test objects is visible in the target heap view. If the test failed, it will show the shortest path(s) to each of the test objects that was visible.)rb )rc rI )r r r r �help_isolatestA s zAnnex.help_isolatestc C s t d| jd� t d| jd� d S )Nz(To return to Monitor, type <Ctrl-C> or .)rb z4To close this connection ('permanently'), type close)rc rI )r r` r r r �do_qP s z Annex.do_qc C s t d| jd� d S )Nz�q ----- Quit. This doesn't currently do anything except printing a message. (I thought it would be too confusing to have a q (quit) command from the Annex, when there was a similarly named command in the Monitor.))rb )rc rI )r r r r �help_qT s z Annex.help_qc C s: | j �� | j �| j| �� | jd�� | j d | j d< d S )N)r rY r/ rY rq )r8 �clear�updater r/ )r r` r r r r9 ] s zAnnex.do_resetc C s t d| jd� d S )Na reset ----- Reset things to an initial state. This resets the state of the interactive console data only, for now. It is reinitialized to contain the following: hpy --- from guppy import hpy hp --- hp = hpy() target --- a reference to some data in the target interpreter h --- h = hp; h is a shorthand for hp (The hpy function is modified here from the normal one so it sets some options to make it be concerned with the target interpreter heap under investigation rather than the current one.) )rb )rc rI )r r r r � help_reseth s zAnnex.help_resetc C s� t d| jd� t d| jd� t d| jjj | jd� t d| jjj | jd� t d| jj | jd� t d| jj | jd� t d| jd� d S )NzTarget overview)rb z$------------------------------------z target.sys.executable = %sz target.sys.argv = %sz target.wd = %sz target.pid = %d)rc rI r/ r0 � executable�argvZwd�pid)r r` r r r �do_statz s z Annex.do_statc C s t d| jd� d S )Na� stat ----- Print an overview status table, with data from the target interpreter. In the table, sys.executable and sys.argv means the current values of those attributes in the sys module of the target interpreter. The row labeled target.wd is the working directory of the target interpreter, at the time the Remote Control interpreter was started (the actual working directory may have changed since that time). The row labeled target.pid is the process id of the target interpreter. )rb )rc rI )r r r r � help_stat� s zAnnex.help_statc O sH ddl m} |||�}d|j_| j|j_|j| j_|j| jj_d|_|S )Nr )r r: zhp.)�guppyr ZViewZ is_hiding_calling_interpreterr/ r[ r Zreprefix)r r r r rY r r r r � s z Annex.hpyc C s� z�x�| j s�| �� | j s�| �d� xty | �� W q$ tk rF P Y q$ tk r� ytj| jd� W n$ tk r� tjt jd� P Y nX w$Y q$X q$W | � � qW W d | � � X d S )Nr, )rb ) r4 rL r~ Zcmdloopr r^ � traceback� print_excrI r0 r= r2 )r r r r rX � s& z Annex.run)N)$r r r r3 ZAF_INETrJ Z SOCK_STREAMrK Z use_rawinput�promptr r2 rL rR r= ra rd r r- Zdo_helpZdo_hre Z help_helprg rh rk rt ru rv rw r9 rz r~ r r rX r r r r r+ W s6 # r+ c C sB t d k r d S ttdd�r d S d} t�� at�| dti�a t t_ d S )NZ#_is_guppy_heapy_remote_interpreter_r z�# Set a flag to stop recursion when importing site # in case sitecustomize tries to do Remote.on() import sys sys._is_guppy_heapy_remote_interpreter_ = 1 import site from guppy.heapy import Remote Remote.Annex(target).run() r/ )rT �getattrr0 r r/ r Z interpreter)Z start_annexr r r �on� s r� c C s� t d kr d S xDtd�D ]6} y tj}W n tk rB t�d� Y qX |� P qW � t�t t � x"t tj dt �stP q`t�d� q`W d a ad S )N� g�������?z t%d_async_exc) rT �ranger/ r �AttributeErrorr@ rA r rS rM r? Z RootState)rr r r r r �off� s r� )%�__doc__Z guppy.etcr r� r Z guppy.heapyr r Zguppy.heapy.RemoteConstantsZguppy.heapy.Consoler Z guppy.setsr �atexitrO r r$ r3 r0 r@ r5 rZ r� r^ r r ZQueuer r r' r- r+ r� r� rT r/ �registerr r r r �<module> s: d
Edit
Rename
Chmod
Delete
FILE
FOLDER
Name
Size
Permission
Action
Classifiers.cpython-37.opt-1.pyc
52243 bytes
0644
Classifiers.cpython-37.pyc
52287 bytes
0644
Console.cpython-37.opt-1.pyc
1178 bytes
0644
Console.cpython-37.pyc
1178 bytes
0644
Doc.cpython-37.opt-1.pyc
13613 bytes
0644
Doc.cpython-37.pyc
13666 bytes
0644
ImpSet.cpython-37.opt-1.pyc
1278 bytes
0644
ImpSet.cpython-37.pyc
1278 bytes
0644
Monitor.cpython-37.opt-1.pyc
14347 bytes
0644
Monitor.cpython-37.pyc
14371 bytes
0644
OutputHandling.cpython-37.opt-1.pyc
10903 bytes
0644
OutputHandling.cpython-37.pyc
10903 bytes
0644
Part.cpython-37.opt-1.pyc
22430 bytes
0644
Part.cpython-37.pyc
22563 bytes
0644
Path.cpython-37.opt-1.pyc
19137 bytes
0644
Path.cpython-37.pyc
19239 bytes
0644
Prof.cpython-37.opt-1.pyc
71354 bytes
0644
Prof.cpython-37.pyc
71489 bytes
0644
RM.cpython-37.opt-1.pyc
205 bytes
0644
RM.cpython-37.pyc
205 bytes
0644
RefPat.cpython-37.opt-1.pyc
18300 bytes
0644
RefPat.cpython-37.pyc
18334 bytes
0644
Remote.cpython-37.opt-1.pyc
13801 bytes
0644
Remote.cpython-37.pyc
13801 bytes
0644
RemoteConstants.cpython-37.opt-1.pyc
301 bytes
0644
RemoteConstants.cpython-37.pyc
301 bytes
0644
Spec.cpython-37.opt-1.pyc
58993 bytes
0644
Spec.cpython-37.pyc
58993 bytes
0644
Target.cpython-37.opt-1.pyc
540 bytes
0644
Target.cpython-37.pyc
540 bytes
0644
UniSet.cpython-37.opt-1.pyc
78560 bytes
0644
UniSet.cpython-37.pyc
78667 bytes
0644
Use.cpython-37.opt-1.pyc
19944 bytes
0644
Use.cpython-37.pyc
19944 bytes
0644
View.cpython-37.opt-1.pyc
17390 bytes
0644
View.cpython-37.pyc
17390 bytes
0644
__init__.cpython-37.opt-1.pyc
539 bytes
0644
__init__.cpython-37.pyc
539 bytes
0644
pbhelp.cpython-37.opt-1.pyc
10821 bytes
0644
pbhelp.cpython-37.pyc
10821 bytes
0644
N4ST4R_ID | Naxtarrr
