o tPf#"@sddlmZmZmZddlZddlZddlZddlZddlZddl m Z ddZ e j r0ddZ ne d dZ dd d Ze d dZeZzddlZWn eyVeZeZYnwGdddeZe dddZe ddZGdddeZdS))absolute_importprint_functiondivisionN)sysinfocstfdd}|S)NcsPttt}tzdi|W|rtSS|r'tww)N)gccollect isenableddisableenable)kwenabledfuncrY/var/www/html/humari/django-venv/lib/python3.10/site-packages/gevent/testing/openfiles.pyf3s  z_collects..f) functoolswraps)rrrrr _collects%s rcCs td)Nzlsof not expected on Windows)unittestSkipTestrrrr _run_lsofC rcCsddl}t}|d\}}t|d||f}t|r$tdt|}| }Wdn1s9wYt ||S)Nrget_open_fileszlsof -p %s > %sz lsof failed) tempfileosgetpidmkstempclosesystemrropenreadstripremove)rpidfdtmpname lsof_commandfobjdatarrrrFs      Fc Kst}i}|dD]]}|}|r|drq td|}|dd\}}}} | dds4| rg|s=| dr=q | dsKt| ddnt| } | |vrc| |||| |f} td| ||| <q |sqtd|f||d<|S) N COMMANDz\s+zUerror when parsing lsof output: duplicate fd=%r line=%r split=%r previous=%r data: %szfailed to parse lsof: %sr*) rsplitr# startswithreisdigitintgetAssertionError) pipes_kwargsr*resultsliner/_command_pid_userr&paramsrrrdefault_get_open_filesVs* $ r>c CsXtjdrdt}tt|Sz ttdddWSttt j fy+YdSw)N/proc/ /proc/%d/fdT)r6rr) rpathexistsrlenlistdirrOSErrorr5rr) fd_directoryrrrdefault_get_number_open_filesqs  rGc@seZdZdZddZdS)_TrivialOpenFiler&cCs ||_dSNrI)selfr&rrr__init__rz_TrivialOpenFile.__init__N)__name__ __module__ __qualname__ __slots__rLrrrrrHs rHTc Ksi}tdD]9}z.|rtjdrdt}t|}ng}t}||d<|d| d7<Wnt y?Yqwt d|dD]}|||j <qI|D]}||vrct|} t| || <qS|dd|fg7<|dd|fg7<|S) a Return a list of popenfile and pconn objects. Note that other than `fd`, they have different attributes. .. important:: If you want to find open sockets, on Windows and linux, it is important that the socket at least be listening (socket.listen(1)). Unlike the lsof implementation, this will only return sockets in a state like that. r?r@r*allzUnable to read open filesz From psutilzfd files)rangerrArBrrDpsutilProcess open_files connectionsrErrr&r3rH) count_closing_as_open_kwr8_rFfd_filesprocessxfd_strr&rrrrs2         rcCs(t}z|WStyYdSw)Nr)rTrUnum_fdsAttributeError)r\rrrget_number_open_filess   racs,eZdZdZfddZfddZZS)DoesNotLeakFilesMixinz A test case mixin that helps find a method that's leaking an open file. Only mix this in when needed to debug, it slows tests down. cst|_tt|dSrJ)ra(_DoesNotLeakFilesMixin__open_files_countsuperrbsetUp)rK __class__rrreszDoesNotLeakFilesMixin.setUpcs8tt|t}||jkrtd|j|tfdS)Nz/Too many open files. Before: %s < After: %s. %s)rdrbtearDownrarcr5r)rKafterrfrrrhs zDoesNotLeakFilesMixin.tearDown)rMrNrO__doc__rerh __classcell__rrrfrrbs rb)F)T) __future__rrrrrr1rrrrWINrr>rGlsof_get_open_filesrT ImportErrorrraobjectrHrbrrrrs8          6