`fedZddlZddlZddlZddlmZddlmZddlmZddl m Z ddl m Z  ddl mZn #e$rdZYnwxYwd Zd ZdagZd Zed Zd ZddZddZddZddZdZdZdZdZddZdS) 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)gbcTddl}td||)Nrz!Blocking detection timed-out at: )inspect RuntimeError getframeinfo)signumframers D/var/www/html/env/lib/python3.11/site-packages/celery/utils/debug.py _on_blockingr"s6NNN IG,@,@,G,GII  c#$K|sdVdStd}|tkrdn|}ttd< tj|V|r |td<tjdS#|r |td<tjwxYw)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 )s  " fo )\99dd{ & "#G,, , , , ."-   ! ! ! ! ! ."-   ! ! ! !s A..!BcVt}t||S)z\Sample RSS memory usage. Statistics can then be output by calling :func:`memdump`. )r _mem_sampleappend) current_rsss rr r ?s' ))K{### r ct}t||krt|nt||}gtdd<ddl}|t }||fS)Nr)r&lenlistr gccollectr)samplesSprevr- after_collects r_memdumpr3IsgA!ff''4777VAw-?-?DKN IIIJJLLLIIM  rctt|}t |ddSt|\}}|r|d|D]}|d|d|d|ddS) 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): .)rprintrr3)r/r6sayr1r2mems rr r Ss %d # # #C tt|  ,---"7++D- "   " "C C #   ! ! ! !C( ((()))))rc#Kt||z}t|D]%} ||Vn#t$rYdSwxYw||z }&dS)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 fsy A! A 1XX A$JJJJ    EEE  Q s 2 AAc^t|}||kr|nd||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)frGis rhfloatrLws4 AAQ11J--a1-555rcDtfdtDS)z4Convert bytes to human-readable form (e.g., KB, MB).c3^K|]'\}}|k t|r|z n|V(dSN)rL).0divunitss r zhumanbytes..sX C!s(( S'!c''a ( (0$00"*(((r)nextUNITS)rSs`rr r s;   rcht}|!tt|jSdS)z.Return RSS memory usage as a humanized string.N)rr _process_memory_inforssrFs rrrs1 A}.q115666}rclt't ttjatS)zReturn the global :class:`psutil.Process` instance. Note: Returns :const:`None` if :pypi:`psutil` is not installed. )_processrosgetpidrrrrs'G/29;;'' Orct |S#t$r|cYSwxYwrO) memory_infoAttributeErrorget_memory_info)processs rrXrXsL)""$$$ )))&&((((()s 77=1c6ddl}|tn|}tt|}d|D}||z}t jD]\}}||} | s|| j ||tj |||||d||t|j ||d|S)zpReturn stack-trace of all active threads. See Also: Taken from https://gist.github.com/737056. rNr5ci|] }|j| Sr^)ident)rPts r zcry..s 6 6 61AGQ 6 6 6rzLOCAL VARIABLES)stream ) threadingrrr9 enumeratesys_current_framesitemsgetname traceback print_stackrf_localsgetvalue) outsepchrseplenrmPtmapseptidrthreads rrrs4 +*,,,3CC   A 7 6 3 3 5 5 6 6 6D 6/C)++1133   U#   V[  #e#.... #   #u~c**** $ <<>>r)r))r)N)r)rD)Nrdre) __doc__r\rort contextlibr functoolsrrcelery.platformsrcelery.utils.textrpsutilr ImportError__all__rVr[r&rr r r3r r rLr rrrXrr^rrrs@@ %%%%%%$$$$$$((((((GGG     """*****&"6666777   )))s 5??