hedZddlZddlZddlZddlmZddlmZddlmZddl m Z ddl m Z  ddl mZd Zd ZdagZd Zed Zd ZddZddZddZddZdZdZdZdZddZy#e$rdZY@wxYw)z:Utilities for debugging memory usage, blocking calls, etc.N)contextmanager)partial)pprint)signals) WhateverIO)Process)blockdetection sample_memmemdumpsample humanbytesmem_rsspscry))gpBTB)gAGB)g0AMB)g@KB)gbcDddl}td|j|)Nrz!Blocking detection timed-out at: )inspect RuntimeError getframeinfo)signumframers N/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/utils/debug.py _on_blockingr"s(  +G,@,@,G+HI c#K|sdytd}|tk(rdn|}ttd< tj||r |td<tjy#|r |td<tjwxYww)zqContext that raises an exception if process is blocking. Uses ``SIGALRM`` to detect blocking functions. NALRM)rr arm_alarm reset_alarm)timeout old_handlers rr r )sw  fo )\9d{ & "##G, ,"-    !"-    !s+B A% B %!BB cDt}tj||S)z\Sample RSS memory usage. Statistics can then be output by calling :func:`memdump`. )r _mem_sampleappend) current_rsss rr r ?s )K{# rct}t||kr t|n t||}gtddddl}|j t }||fS)Nr)r&lenlistr gccollectr)samplesSprevr, after_collects r_memdumpr2IsKA!f'47VAw-?DKN JJLIM  rctt|}t |dyt|\}}|r|d|D]}|d|d|d|dy) zDump 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): .)rprintrr2)r.r5sayr0r1mems rr r Ssj %d #C t| ,-"7+D-  C '#a !- a()rc#Kt||z}t|D]} ||||z }y#t$rYywxYww)zGiven 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)xnkj_s rr r fsO A! A 1X A$J Q    s?/? <?<?cLt|}||k(r|Sdj||S)zConvert 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)intformat)frEis rhfloatrJws. AAQ15J--a1-55rc4tfdtDS)z4Convert bytes to human-readable form (e.g., KB, MB).c3ZK|]"\}}|k\rt|r|z n|$ywN)rJ).0divunitss r zhumanbytes..s: C!s( S!c'a ( )$0s(+)nextUNITS)rQs`rr r s  rcXt}|tt|jSy)z.Return RSS memory usage as a humanized string.N)rr _process_memory_inforssrDs rrrs* A}.q15566rc`t#tttjatS)zReturn the global :class:`psutil.Process` instance. Note: Returns :const:`None` if :pypi:`psutil` is not installed. )_processrosgetpidrrrrs$G/299;' Orcb |jS#t$r|jcYSwxYwrM) memory_infoAttributeErrorget_memory_info)processs rrVrVs4)""$$ )&&(()s ..cddl}| tn|}tt|}|j Dcic]}|j |}}||z}t jjD]\}} |j|} | s|| j||tj| ||||d||t| j||d|jScc}w)zpReturn stack-trace of all active threads. See Also: Taken from https://gist.github.com/737056. rNr4zLOCAL VARIABLES)stream ) threadingrrr8 enumerateidentsys_current_framesitemsgetname traceback print_stackrf_localsgetvalue) outsepchrseplenrePttmapseptidrthreads rrrs +*,3CC A!* 3 3 5 61AGGQJ 6D 6 6/C))+113 U#  V[[M #e#. #  #u~~c* $4 <<>! 7sD) )rzN)r))N=1) __doc__rZrhrm contextlibr functoolsrrcelery.platformsrcelery.utils.textrpsutilr ImportError__all__rTrYr&rr r r2r r rJr rrrVrr\rrrs@ %$(     ""**&"67 )mGsA++A54A5