i#"2ddlmZmZmZddlZddlZddlZddlZddlZddl m Z dZ e j rdZ n e dZ dd Ze d ZeZ ddlZGd d eZe ddZe dZn#e$reZeZYnwxYwGddeZdS))absolute_importprint_functiondivisionN)sysinfocFtjfd}|S)Nctjtjtj}tj di||rtjSS#|rtjwwxYw)N)gccollect isenableddisableenable)kwenabledfuncs C/usr/local/lib/python3.11/dist-packages/gevent/testing/openfiles.pyfz_collects..f3sz  ,..  4::"::   w   s A--B) functoolswraps)rrs` r _collectsr%s:_T      Hc*tjd)Nzlsof not expected on Windows)unittestSkipTestr rr _run_lsofrCs >???rcddl}tj}|d\}}tj|d|d|}tj|rt jdt|5}| }dddn #1swxYwYtj ||S)Nrget_open_fileszlsof -p z > z lsof failed) tempfileosgetpidmkstempclosesystemrropenreadstripremove)rpidfdtmpname lsof_commandfobjdatas rrrFsikk&&'788 G  ,/CC9 9\ " " 3#M22 2 ']] 'd99;;$$&&D ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' s'B66B:=B:Fc t}i}|dD]}|}|r|dr/t jd|}|dd\}}}} | dds| r|s| dr| dst | ddnt | } | |vr,| |||| |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_filesrCVsy ;;DG 4  zz|| ty11  &&%*"1"I!$r crc7??      RV^^-- %'V^^%5%5BRW3r77BW}}dE7;;r??DA$&BEK&KLLLGBK EnDDCDDDGFO Nrc6tjdr7dtjz}t tj|S t t ddz S#tttj f$rYdSwxYw)N/proc/ /proc/%d/fdT)r;rr) r pathexistsr!lenlistdirrOSErrorr:rr) fd_directorys rdefault_get_number_open_filesrMqs w~~h-$ry{{2 2:l++,,,>---..22 ^X%6 7qqsA88BBceZdZdZdZdS)_TrivialOpenFiler*c||_dSNrP)selfr*s r__init__z_TrivialOpenFile.__init__s DGGGrN)__name__ __module__ __qualname__ __slots__rTr rrrOrOs(      rrOTc zi}tdD]} |rJtjdr+dtjz}tj|}ng}t j}||d<|dxx| dz cc<n$#t$rYwxYwtj d|dD] }|||j < |D]'}||vr!t|} t| || <(|dxxd|fgz cc<|dxxd|fgz cc<|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. 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 rrrsq A AA ("RW^^H-E-E"$129;;#>L!z,77HH!H .**")"4"4"6"67#6#6u#=#==    #$?@@ @  AGADMM 3 3FW$$[[.r22 ]G455Z233sBB22 B?>B?cttj} |S#t$rYdSwxYw)Nr)r]r^num_fdsAttributeError)res rget_number_open_filesrksF."" ??$$ $   11 s ) 77c,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. c|t|_tt|dSrR)rk(_DoesNotLeakFilesMixin__open_files_countsuperrmsetUp)rS __class__s rrqzDoesNotLeakFilesMixin.setUps4"7"9"9 #T**0022222rc tt|t}||jkr)t d|jd|dt dS)NzToo many open files. Before: z < After: z. )rprmtearDownrkror:r)rSafterrrs rrtzDoesNotLeakFilesMixin.tearDownsy #T**33555%'' 4* * * .+++EE"$$$  + *r)rUrVrW__doc__rqrt __classcell__)rrs@rrmrms[ 33333         rrm)F)T) __future__rrrr rr6r rrrWINrrCrMlsof_get_open_filesr]objectrOrrk ImportErrorrmr rrr~s(A@@@@@@@@@     : ;@@@@  Y 6     -KMMM 6 444Y4lYC:::+N9:VFsA:: BB