U
    adB                     @   s  d dl mZmZ d dlmZ d dlZd dlZd dlZd dl	Z	d dl
T d dl
mZmZ dd ZG dd	 d	ZG d
d dZdd ZeG dd dZeG dd deZdd ZG dd dZG dd deZdd ZG dd dZG dd deZG dd deZG d d! d!Zd"d# ZdS )$    )SequenceIterable)total_orderingN)*)_get_object_traceback_get_tracesc                 C   s   dD ]|}t | dk r@|dkr@|r0d| |f   S d| |f   S t | dk sT|dkrx|rhd| |f   S d	| |f   S | d
 } qd S )N)BZKiBZMiBZGiBTiBd   r   z%+.1f %sz%.1f %si (  r	   z%+.0f %sz%.0f %si   )abs)sizeZsignZunit r   !/usr/lib/python3.8/tracemalloc.py_format_size   s    r   c                   @   sD   e Zd ZdZdZdd Zdd Zdd Zd	d
 Zdd Z	dd Z
dS )	StatisticzS
    Statistic difference on memory allocations between two Snapshot instance.
    	tracebackr   countc                 C   s   || _ || _|| _d S Nr   )selfr   r   r   r   r   r   __init__%   s    zStatistic.__init__c                 C   s   t | j| j| jfS r   )hashr   r   r   r   r   r   r   __hash__*   s    zStatistic.__hash__c                 C   s$   | j |j ko"| j|jko"| j|jkS r   r   r   otherr   r   r   __eq__-   s
    

zStatistic.__eq__c                 C   sB   d| j t| jd| jf }| jr>| j| j }|dt|d 7 }|S )Nz%s: size=%s, count=%iF, average=%s)r   r   r   r   r   textZaverager   r   r   __str__2   s    
zStatistic.__str__c                 C   s   d| j | j| jf S )Nz)<Statistic traceback=%r size=%i count=%i>r   r   r   r   r   __repr__<   s    zStatistic.__repr__c                 C   s   | j | j| jfS r   )r   r   r   r   r   r   r   	_sort_key@   s    zStatistic._sort_keyN__name__
__module____qualname____doc__	__slots__r   r   r   r    r!   r"   r   r   r   r   r      s   
r   c                   @   sD   e Zd ZdZdZdd Zdd Zdd Zd	d
 Zdd Z	dd Z
dS )StatisticDiffzd
    Statistic difference on memory allocations between an old and a new
    Snapshot instance.
    r   r   	size_diffr   
count_diffc                 C   s"   || _ || _|| _|| _|| _d S r   r*   )r   r   r   r+   r   r,   r   r   r   r   K   s
    zStatisticDiff.__init__c                 C   s   t | j| j| j| j| jfS r   )r   r   r   r+   r   r,   r   r   r   r   r   R   s     zStatisticDiff.__hash__c                 C   s<   | j |j ko:| j|jko:| j|jko:| j|jko:| j|jkS r   r*   r   r   r   r   r   V   s    



zStatisticDiff.__eq__c                 C   sP   d| j t| jdt| jd| j| jf }| jrL| j| j }|dt|d 7 }|S )Nz %s: size=%s (%s), count=%i (%+i)FTr   )r   r   r   r+   r   r,   r   r   r   r   r    ]   s    

zStatisticDiff.__str__c                 C   s   d| j | j| j| j| jf S )Nz9<StatisticDiff traceback=%r size=%i (%+i) count=%i (%+i)>r*   r   r   r   r   r!   i   s     zStatisticDiff.__repr__c                 C   s    t | j| jt | j| j| jfS r   )r   r+   r   r,   r   r   r   r   r   r   r"   n   s
     zStatisticDiff._sort_keyNr#   r   r   r   r   r)   D   s   r)   c                 C   s   g }|  D ]d\}}| |d }|d k	rNt||j|j|j |j|j|j }nt||j|j|j|j}|| q|   D ]*\}}t|d|j d|j }|| qz|S Nr   )itemspopr)   r   r   append)	old_group	new_group
statisticsr   statZpreviousr   r   r   _compare_grouped_statst   s*     
 
  r5   c                   @   s\   e Zd ZdZdZdd Zedd Zedd Zd	d
 Z	dd Z
dd Zdd Zdd ZdS )Framez
    Frame of a traceback.
    _framec                 C   s
   || _ d S r   r7   r   framer   r   r   r      s    zFrame.__init__c                 C   s
   | j d S r-   r7   r   r   r   r   filename   s    zFrame.filenamec                 C   s
   | j d S N   r7   r   r   r   r   lineno   s    zFrame.linenoc                 C   s   | j |j kS r   r7   r   r   r   r   r      s    zFrame.__eq__c                 C   s   | j |j k S r   r7   r   r   r   r   __lt__   s    zFrame.__lt__c                 C   s
   t | jS r   )r   r8   r   r   r   r   r      s    zFrame.__hash__c                 C   s   d| j | jf S )Nz%s:%sr;   r>   r   r   r   r   r       s    zFrame.__str__c                 C   s   d| j | jf S )Nz<Frame filename=%r lineno=%r>r@   r   r   r   r   r!      s    zFrame.__repr__N)r$   r%   r&   r'   r(   r   propertyr;   r>   r   r?   r   r    r!   r   r   r   r   r6      s   

r6   c                   @   sf   e Zd ZdZdZdd Zdd Zdd Zd	d
 Zdd Z	dd Z
dd Zdd Zdd ZdddZdS )	Tracebackz`
    Sequence of Frame instances sorted from the oldest frame
    to the most recent frame.
    _framesc                 C   s   t |  tt|| _d S r   )r   r   tuplereversedrD   )r   framesr   r   r   r      s    
zTraceback.__init__c                 C   s
   t | jS r   )lenrD   r   r   r   r   __len__   s    zTraceback.__len__c                 C   s4   t |tr"tdd | j| D S t| j| S d S )Nc                 s   s   | ]}t |V  qd S r   )r6   .0tracer   r   r   	<genexpr>   s     z(Traceback.__getitem__.<locals>.<genexpr>)
isinstanceslicerE   rD   r6   r   indexr   r   r   __getitem__   s    
zTraceback.__getitem__c                 C   s   |j | jkS r   )r8   rD   r9   r   r   r   __contains__   s    zTraceback.__contains__c                 C   s
   t | jS r   )r   rD   r   r   r   r   r      s    zTraceback.__hash__c                 C   s   | j |j kS r   rC   r   r   r   r   r      s    zTraceback.__eq__c                 C   s   | j |j k S r   rC   r   r   r   r   r?      s    zTraceback.__lt__c                 C   s   t | d S r-   )strr   r   r   r   r       s    zTraceback.__str__c                 C   s   dt | f S )Nz<Traceback %r>)rE   r   r   r   r   r!      s    zTraceback.__repr__NFc                 C   s   g }|d k	r2|dkr$| | d  }q6| d | }n| }|rBt |}|D ]@}|d|j|jf  t|j|j }|rF|d|  qF|S )Nr   z  File "%s", line %sz    %s)rF   r0   r;   r>   	linecachegetlinestrip)r   limitZmost_recent_firstlinesZframe_slicer:   liner   r   r   format   s     
zTraceback.format)NF)r$   r%   r&   r'   r(   r   rI   rR   rS   r   r   r?   r    r!   r[   r   r   r   r   rB      s   rB   c                 C   s    t | }|dk	rt|S dS dS )z
    Get the traceback where the Python object *obj* was allocated.
    Return a Traceback instance.

    Return None if the tracemalloc module is not tracing memory allocations or
    did not trace the allocation of the object.
    N)r   rB   )objrG   r   r   r   get_object_traceback   s    r]   c                   @   s`   e Zd ZdZdZdd Zedd Zedd Zed	d
 Z	dd Z
dd Zdd Zdd ZdS )Tracez"
    Trace of a memory block.
    _tracec                 C   s
   || _ d S r   r_   r   rL   r   r   r   r      s    zTrace.__init__c                 C   s
   | j d S r-   r_   r   r   r   r   domain  s    zTrace.domainc                 C   s
   | j d S r<   r_   r   r   r   r   r   	  s    z
Trace.sizec                 C   s   t | jd S )N   )rB   r`   r   r   r   r   r     s    zTrace.tracebackc                 C   s   | j |j kS r   r_   r   r   r   r   r     s    zTrace.__eq__c                 C   s
   t | jS r   )r   r`   r   r   r   r   r     s    zTrace.__hash__c                 C   s   d| j t| jdf S )Nz%s: %sF)r   r   r   r   r   r   r   r      s    zTrace.__str__c                 C   s   d| j t| jd| jf S )Nz'<Trace domain=%s size=%s, traceback=%r>F)rb   r   r   r   r   r   r   r   r!     s    zTrace.__repr__N)r$   r%   r&   r'   r(   r   rA   rb   r   r   r   r   r    r!   r   r   r   r   r^      s   


r^   c                   @   s<   e Zd Zdd Zdd Zdd Zdd Zd	d
 Zdd ZdS )_Tracesc                 C   s   t |  || _d S r   )r   r   _traces)r   tracesr   r   r   r      s    
z_Traces.__init__c                 C   s
   t | jS r   )rH   re   r   r   r   r   rI   %  s    z_Traces.__len__c                 C   s4   t |tr"tdd | j| D S t| j| S d S )Nc                 s   s   | ]}t |V  qd S r   )r^   rJ   r   r   r   rM   *  s     z&_Traces.__getitem__.<locals>.<genexpr>)rN   rO   rE   re   r^   rP   r   r   r   rR   (  s    
z_Traces.__getitem__c                 C   s   |j | jkS r   )r`   re   ra   r   r   r   rS   .  s    z_Traces.__contains__c                 C   s   | j |j kS r   )re   r   r   r   r   r   1  s    z_Traces.__eq__c                 C   s   dt |  S )Nz<Traces len=%s>)rH   r   r   r   r   r!   4  s    z_Traces.__repr__N)	r$   r%   r&   r   rI   rR   rS   r   r!   r   r   r   r   rd     s   rd   c                 C   s&   t j| } | dr"| d d } | S )Nz.pyc)ospathnormcaseendswith)r;   r   r   r   _normalize_filename8  s    
rl   c                   @   s   e Zd Zdd Zdd ZdS )
BaseFilterc                 C   s
   || _ d S r   )	inclusive)r   rn   r   r   r   r   @  s    zBaseFilter.__init__c                 C   s   t d S r   )NotImplementedErrorra   r   r   r   _matchC  s    zBaseFilter._matchN)r$   r%   r&   r   rp   r   r   r   r   rm   ?  s   rm   c                       sJ   e Zd Zd fdd	Zedd Zdd Zd	d
 Zdd Zdd Z	  Z
S )FilterNFc                    s2   t  | || _t|| _|| _|| _|| _d S r   )superr   rn   rl   _filename_patternr>   
all_framesrb   )r   rn   filename_patternr>   rt   rb   	__class__r   r   r   H  s    
zFilter.__init__c                 C   s   | j S r   )rs   r   r   r   r   ru   Q  s    zFilter.filename_patternc                 C   s6   t |}t|| jsdS | jd kr(dS || jkS d S )NFT)rl   fnmatchrs   r>   r   r;   r>   r   r   r   _match_frame_implU  s    
zFilter._match_frame_implc                 C   s   |  ||| j A S r   )rz   rn   ry   r   r   r   _match_frame^  s    zFilter._match_framec                    sH    j r,t fdd|D r" jS  j S n|d \}} ||S d S )Nc                 3   s   | ]\}}  ||V  qd S r   )rz   )rK   r;   r>   r   r   r   rM   c  s   z*Filter._match_traceback.<locals>.<genexpr>r   )rt   anyrn   r{   )r   r   r;   r>   r   r   r   _match_tracebacka  s    
zFilter._match_tracebackc                 C   sD   |\}}}|  |}| jd k	r@| jr2|o0|| jkS |p>|| jkS |S r   )r}   rb   rn   )r   rL   rb   r   r   resr   r   r   rp   l  s    


zFilter._match)NFN)r$   r%   r&   r   rA   ru   rz   r{   r}   rp   __classcell__r   r   rv   r   rq   G  s        	
	rq   c                       s0   e Zd Z fddZedd Zdd Z  ZS )DomainFilterc                    s   t  | || _d S r   )rr   r   _domain)r   rn   rb   rv   r   r   r   x  s    zDomainFilter.__init__c                 C   s   | j S r   )r   r   r   r   r   rb   |  s    zDomainFilter.domainc                 C   s   |\}}}|| j k| j A S r   )rb   rn   )r   rL   rb   r   r   r   r   r   rp     s    
zDomainFilter._match)r$   r%   r&   r   rA   rb   rp   r   r   r   rv   r   r   w  s   
r   c                   @   sX   e Zd ZdZdd Zdd Zedd Zdd	 Zd
d Z	dd Z
dddZdddZdS )SnapshotzB
    Snapshot of traces of memory blocks allocated by Python.
    c                 C   s   t || _|| _d S r   )rd   rf   traceback_limit)r   rf   r   r   r   r   r     s    
zSnapshot.__init__c              	   C   s*   t |d}t| |tj W 5 Q R X dS )z1
        Write the snapshot into a file.
        wbN)openpickledumpZHIGHEST_PROTOCOL)r   r;   fpr   r   r   r     s    zSnapshot.dumpc              
   C   s,   t | d}t|W  5 Q R  S Q R X dS )z.
        Load a snapshot from a file.
        rbN)r   r   load)r;   r   r   r   r   r     s    zSnapshot.loadc                    s@   |rt  fdd|D sdS |r<t  fdd|D r<dS dS )Nc                 3   s   | ]}|  V  qd S r   rp   rK   trace_filterrL   r   r   rM     s   z)Snapshot._filter_trace.<locals>.<genexpr>Fc                 3   s   | ]}|   V  qd S r   r   r   r   r   r   rM     s   T)r|   )r   include_filtersexclude_filtersrL   r   r   r   _filter_trace  s    zSnapshot._filter_tracec                    s   t |tstdt|j |rjg g  |D ] }|jrB| q, | q, fddjjD }njj	 }t
|jS )z
        Create a new Snapshot instance with a filtered traces sequence, filters
        is a list of Filter or DomainFilter instances.  If filters is an empty
        list, return a new Snapshot instance with a copy of the traces.
        z)filters must be a list of filters, not %sc                    s   g | ]}  |r|qS r   )r   rJ   r   r   r   r   r   
<listcomp>  s    z*Snapshot.filter_traces.<locals>.<listcomp>)rN   r   	TypeErrortyper$   rn   r0   rf   re   copyr   r   )r   filtersr   Z
new_tracesr   r   r   filter_traces  s    
zSnapshot.filter_tracesc              
   C   s  |dkrt d|f |r.|dkr.t d| i }i }|s| jjD ]}|\}}}z|| }	W nZ tk
r   |dkr||}
n(|dkr|d d }
n|d d dff}
t|
}	|	||< Y nX z(||	 }| j|7  _| jd7  _W qD tk
r   t|	|d||	< Y qDX qDn| jjD ]}|\}}}|D ]}z|| }	W nF tk
r~   |dkr\|f}
n|d dff}
t|
}	|	||< Y nX z(||	 }| j|7  _| jd7  _W n& tk
r   t|	|d||	< Y nX q(q|S )	N)r   r;   r>   zunknown key_type: %r)r>   r;   z/cumulative mode cannot by used with key type %rr   r>   r=   r   )
ValueErrorrf   re   KeyErrorrB   r   r   r   )r   key_type
cumulativeZstatsZ
tracebacksrL   rb   r   Ztrace_tracebackr   rG   r4   r:   r   r   r   	_group_by  sZ    


zSnapshot._group_byFc                 C   s,   |  ||}t| }|jdtjd |S )zd
        Group statistics by key_type. Return a sorted list of Statistic
        instances.
        Treversekey)r   listvaluessortr   r"   )r   r   r   Zgroupedr3   r   r   r   r3     s    zSnapshot.statisticsc                 C   s6   |  ||}| ||}t||}|jdtjd |S )z
        Compute the differences with an old snapshot old_snapshot. Get
        statistics as a sorted list of StatisticDiff instances, grouped by
        group_by.
        Tr   )r   r5   r   r)   r"   )r   Zold_snapshotr   r   r2   r1   r3   r   r   r   
compare_to   s
    
zSnapshot.compare_toN)F)F)r$   r%   r&   r'   r   r   staticmethodr   r   r   r   r3   r   r   r   r   r   r     s   
3

r   c                  C   s$   t  stdt } t }t| |S )zI
    Take a snapshot of traces of memory blocks allocated by Python.
    zLthe tracemalloc module must be tracing memory allocations to take a snapshot)
is_tracingRuntimeErrorr   Zget_traceback_limitr   )rf   r   r   r   r   take_snapshot  s
    r   )Zcollections.abcr   r   	functoolsr   rx   rU   os.pathrh   r   Z_tracemallocr   r   r   r   r)   r5   r6   rB   r]   r^   rd   rl   rm   rq   r   r   r   r   r   r   r   <module>   s2   &0"?%0 	