Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/utils/__pycache__/debug.cpython-39.pyc
Ðазад
a t�he � @ s d Z ddlZddlZddlZddlmZ ddlmZ ddlmZ ddl m Z ddl m Z zddl mZ W n ey~ dZY n0 d Zd Zdag Zd d � Zed d� �Zdd� Zd'dd�Zd(dd�Zd)dd�Zd*dd�Zdd � Zd d � Z d d � Z d!d"� Z d+d%d&�Z dS ),z:Utilities for debugging memory usage, blocking calls, etc.� N)�contextmanager)�partial)�pprint)�signals)� WhateverIO)�Process)�blockdetection� sample_mem�memdump�sample� humanbytes�mem_rss�ps�cry))g pB�TB)g �A�GB)g 0A�MB)g �@ZKB)g �bc C s dd l }td|�|�� ���d S )Nr z!Blocking detection timed-out at: )�inspect� RuntimeError� getframeinfo)�signum�framer � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/utils/debug.py� _on_blocking" s �r c c sl | s dV n\t d }|tkr dn|}tt d< z$t �| �V W |rH|t d< t �� n|r^|t d< t �� 0 dS )zqContext that raises an exception if process is blocking. Uses ``SIGALRM`` to detect blocking functions. NZALRM)r r Z arm_alarmZ reset_alarm)�timeoutZ old_handlerr r r r ) s �r c C s t � } t�| � | S )z\Sample RSS memory usage. Statistics can then be output by calling :func:`memdump`. )r � _mem_sample�append)Z current_rssr r r r ? s r � c C sL t }t|�| krt|�nt|| �}g t d d �< dd l}|�� t� }||fS )Nr )r �len�listr �gcZcollectr )�samples�S�prevr" � after_collectr r r �_memdumpI s r' c C sh t t|d�}t� du r"|d� dS t| �\}}|rT|d� |D ]}|d|� d�� q>|d|� d�� dS ) z�Dump memory statistics. Will print a sample of all RSS memory samples added by calling :func:`sample_mem`, and in addition print used RSS memory after :func:`gc.collect`. ��fileNz - rss: (psutil not installed).z- rss (sample):z- > �,z - rss (end): �.)r �printr r' )r# r) Zsayr% r& Zmemr r r r S s r c c sN t | �| }t|�D ]4}z| | V W n ty> Y qJY n0 ||7 }qdS )z�Given a list `x` a sample of length ``n`` of that list is returned. For example, if `n` is 10, and `x` has 100 items, a list of every tenth. item is returned. ``k`` can be used as offset. N)r �range� IndexError)�x�n�k�j�_r r r r f s r � c C s" t | �}|| kr|S dj| |d�S )z�Convert float to value suitable for humans. Arguments: f (float): The floating point number. p (int): Floating point precision (default is 5). z{0:.{p}}��p)�int�format)�fr6 �ir r r �hfloatw s r; c s t � fdd�tD ��S )z4Convert bytes to human-readable form (e.g., KB, MB).c 3 s6 | ].\}}� |krt |r � | n� �� |� �V qd S �N)r; )�.0�div�unit��sr r � <genexpr>� s �z humanbytes.<locals>.<genexpr>)�next�UNITSr@ r r@ r r � s �r c C s t � } | dur tt| �j�S dS )z.Return RSS memory usage as a humanized string.N)r r �_process_memory_infoZrssr5 r r r r � s r c C s t du r tdur tt�� �a t S )z�Return the global :class:`psutil.Process` instance. Note: Returns :const:`None` if :pypi:`psutil` is not installed. N)�_processr �os�getpidr r r r r � s r c C s* z | � � W S ty$ | �� Y S 0 d S r< )Z memory_info�AttributeErrorZget_memory_info)�processr r r rE � s rE �=�1 c C s� ddl }| du rt� n| } tt| d�}dd� |�� D �}|| }t�� �� D ]h\}}|�|�} | sdqL|| j � � ||� t j || d� ||� |d� ||� t |j | d� |d� qL| �� S ) zpReturn stack-trace of all active threads. See Also: Taken from https://gist.github.com/737056. r Nr( c S s i | ] }|j |�qS r )�ident)r= �tr r r � <dictcomp>� � zcry.<locals>.<dictcomp>zLOCAL VARIABLES)�stream� )� threadingr r r, � enumerate�sys�_current_frames�items�get�name� traceback� print_stackr �f_locals�getvalue) �outZsepchrZseplenrS �PZtmap�sep�tidr �threadr r r r � s$ r )r )r N)r )r4 )NrK rL ) �__doc__rG rU rZ � contextlibr � functoolsr r Zcelery.platformsr Zcelery.utils.textr Zpsutilr � ImportError�__all__rD rF r r r r r' r r r; r r r rE r r r r r �<module> s:
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка