<|h#"ddlmZmZmZddlZddlZddlZddlZddlZddl m Z dZ e jrdZ ne dZ ddZe d ZeZ ddlZGd d eZe dd Ze d ZGddeZy#e$reZeZYwxYw))absolute_importprint_functiondivisionN)sysinfocBtjfd}|S)Nctjtjtj}tj di||rtjSS#|rtjwwxYw)N)gccollect isenableddisableenable)kwenabledfuncs W/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/testing/openfiles.pyfz_collects..f3sZ  ,,.  :": w s A22B ) functoolswraps)rrs` r _collectsr%s'__T   Hc,tjd)Nzlsof not expected on Windows)unittestSkipTestr rr _run_lsofrCs >??rcddl}tj}|jd\}}tj|d|d|}tj |rt jdt|5}|jj}dddtj|S#1swY xYw)Nrget_open_fileszlsof -p z > z lsof failed) tempfileosgetpidmkstempclosesystemrropenreadstripremove)rpidfdtmpname lsof_commandfobjdatas rrrFsiik&&'78 G  ,/9 99\ "##M2 2 '] 'd99;$$&D ' '  ' 's ?B==Cc "t}i}|jdD]}|j}|r|jdr't jd|}|dd\}}}} | ddj s| j sk|s| dj r| dj st | ddn t | } | |vr$| |||j| |f} td| z||| <|std|||d<|S) N COMMANDz\s+zUerror when parsing lsof output: duplicate fd=%r line=%r split=%r previous=%r data: %szfailed to parse lsof: r.) rsplitr' startswithreisdigitintgetAssertionError) pipes_kwargsr.resultsliner4_command_pid_userr*paramss rdefault_get_open_filesrCVs  ;DG 4 zz|ty1 &%*"1I!$r cr7??  RV^^-%'V^^%5RW3r7BW}dE7;;r?DA$&BEK&KLLGBK%& DCDDGFO Nrc$tjjdr5dtjz}t tj |S t t ddz S#tttjf$rYywxYw)N/proc/ /proc/%d/fdT)r;rr) r pathexistsr!lenlistdirrOSErrorr:rr) fd_directorys rdefault_get_number_open_filesrMqso ww~~h$ryy{2 2::l+,,>-.22 ^X%6%6 7sA..BBceZdZdZdZy)_TrivialOpenFiler*c||_yNrP)selfr*s r__init__z_TrivialOpenFile.__init__s DGrN)__name__ __module__ __qualname__ __slots__rTr rrrOrOs   rrOc Zi}tdD]} |rLtjjdr-dtjz}tj |}ng}t j}|j|d<|dxx|jdz cc<ntjd|dD]}|||j<|D] }||vst|} t| || <"|dxxd|fgz cc<|dxxd|fgz cc<|S#t$rYwxYw) 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. rErFr.allzUnable to read open filesz From psutilzfd files)ranger rGrHr!rJpsutilProcess open_files connectionsrKrrr*r8rO) count_closing_as_open_kwr=_rLfd_filesprocessxfd_strr*s rrrs=q AA (RWW^^H-E$1299;#>L!zz,7H!H ..*")"4"4"67#6#6u#==/ A8##$?@ @ AGADDM  3FW$[.r2  3 ]G455Z233  sBD D*)D*cjtj} |jS#t$rYywxYw)Nr)r]r^num_fdsAttributeError)res rget_number_open_filesrks2.." ??$ $  s & 22c,eZdZdZfdZfdZxZS)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. cHt|_tt|yrR)rk(_DoesNotLeakFilesMixin__open_files_countsuperrmsetUp)rS __class__s rrqzDoesNotLeakFilesMixin.setUps"7"9 #T02rc tt| t}||jkDr&t d|jd|dt y)NzToo many open files. Before: z < After: z. )rprmtearDownrkror:r)rSafterrrs rrtzDoesNotLeakFilesMixin.tearDownsP #T35%' 4** * ++"$  +r)rUrVrW__doc__rqrt __classcell__)rrs@rrmrms 3  rrm)F)T) __future__rrrr rr6r rrrWINrrCrMlsof_get_open_filesr]objectrOrrk ImportErrorrmr rrr~s(A@   : ;;@  6    -K 6 44lFW:+N9:sA;; BB