Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

Repository URL to install this package:

Details    
ray / purelib / ray / thirdparty_files / psutil / __pycache__ / _pssunos.cpython-310.pyc
Size: Mime:
o

‚‚õb‘cã@s8dZddlZddlZddlZddlZddlZddlZddlmZddlm	Z	ddl
mZddl
mZddl
m
Zdd	l
mZdd
lmZddlmZddlmZdd
lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z ddlm!Z!gd¢Z"e #¡Z$ej%Z%ej&dkZ'dZ(dZ)ej*ej+ej,ej-ej.ej/ej0ej1ej2ej3ej4ej-ej5ej6iZ7ej8ej9ej:ej;ej<ej=ej>ej?ej@ejAejBejCejDejEejFejGejHejIejJejKejLejMejNejOejPe(ejQe)iZReSddddd d!d"d#d$d%d&d'd(ZTed)gd*¢ƒZUed+gd,¢ƒZVed-gd.¢ƒZWed/d0d1gƒZXeXZYed2gd3¢ƒZZed4d5d6 [eZj\¡ƒZ]d7d8„Z^d9d:„Z_d;d<„Z`d=d>„Zad?d@„ZbdAdB„ZcdCdD„ZdejeZeejfZfdYdFdG„ZgejhZhejiZidZdIdJ„ZjdKdL„ZkdMdN„ZldOdP„ZmdQdR„ZndSdT„ZodUdV„ZpGdWdX„dXeqƒZrdS)[z'Sun OS Solaris platform implementation.éN)Ú
namedtuple)ÚAF_INETé)Ú_common)Ú_psposix)Ú
_psutil_posix)Ú
_psutil_sunos)ÚAF_INET6)ÚAccessDenied)Ú
NoSuchProcess)Ú
ZombieProcess)Údebug)Úget_procfs_path)Ú
isfile_strict)Úmemoize_when_activated)Úsockfam_to_enum)Úsocktype_to_enum)Ú
usage_percent)ÚPY3)ÚFileNotFoundError)ÚPermissionError)ÚProcessLookupError)Úb)Ú	CONN_IDLEÚ
CONN_BOUNDZPROCFS_PATHlZIDLEZBOUNDéééééééé	é
é)ÚppidÚrssÚvmsÚcreate_timeÚniceÚnum_threadsÚstatusÚttynrÚuidÚeuidÚgidÚegidÚ	scputimes)ÚuserÚsystemÚidleZiowaitÚ	pcputimes)r2r3Ú
children_userÚchildren_systemÚsvmem)ÚtotalÚ	availableÚpercentÚusedÚfreeÚpmemr&r'Ú
pmmap_grouped)Úpathr&Z	anonymousÚlockedÚ	pmmap_extzaddr perms ú cCsFt d¡t}t d¡t}}||}t||dd}t|||||ƒS)zReport virtual memory metrics.Ú
SC_PHYS_PAGESÚSC_AVPHYS_PAGESr©Zround_N)ÚosÚsysconfÚ	PAGE_SIZErr8)r9r=Zavailr<r;©rJú6/tmp/pip-target-wec6zj2z/lib/python/psutil/_pssunos.pyÚvirtual_memory{s
rLc
	Cs
t ¡\}}tjddtjdddgtjd}| ¡\}}tr&| 	t
jj¡}|j
dkr2td|j
ƒ‚| ¡ d	¡d
d…}|sCtdƒ‚d}}|D]"}| ¡}|d
d…\}	}
|tt|	ƒdƒ7}|tt|
ƒdƒ7}qI||}t||d
d}t |||||t|t¡S)zReport swap memory metrics.z/usr/bin/envzPATH=/usr/sbin:/sbin:%sÚPATHZswapz-l)Ústdoutrz'swap -l' failed (retcode=%s)Ú
rNzno swap device(s) configuredrrirF)ÚcextZswap_memÚ
subprocessÚPopenrGÚenvironÚPIPEÚcommunicaterÚdecodeÚsysrNÚencodingÚ
returncodeÚRuntimeErrorÚstripÚsplitÚintrrZsswaprI)
ÚsinZsoutÚprNÚstderrÚlinesr9r=ÚlineÚtÚfr<r;rJrJrKÚswap_memory†s6ÿÿþ
ÿrecCst ¡}tdd„t|ŽDƒŽS)z-Return system-wide CPU times as a named tuplecSóg|]}t|ƒ‘qSrJ)Úsum©Ú.0ÚxrJrJrKÚ
<listcomp>¯ózcpu_times.<locals>.<listcomp>N)rPÚ
per_cpu_timesr1Úzip©ÚretrJrJrKÚ	cpu_times¬srqcCst ¡}dd„|DƒS)z5Return system per-CPU times as a list of named tuplescSsg|]}t|Ž‘qSrJ)r1rhrJrJrKrkµrlz!per_cpu_times.<locals>.<listcomp>N)rPrmrorJrJrKrm²srmcCs"zt d¡WStyYdSw)z0Return the number of logical CPUs in the system.ÚSC_NPROCESSORS_ONLNN)rGrHÚ
ValueErrorrJrJrJrKÚcpu_count_logical¸s
þrtcCót ¡S)z-Return the number of CPU cores in the system.N)rPÚcpu_count_coresrJrJrJrKrvÁórvcCs$t ¡\}}}}d}t ||||¡S)z*Return various CPU stats as a named tuple.rN)rPÚ	cpu_statsrZ	scpustats)Zctx_switchesZ
interruptsZsyscallsZtrapsZsoft_interruptsrJrJrKrxÆs

ÿrxFcCs¤g}t ¡}|D]G}|\}}}}|dkrd}|s<z	t|ƒjs WqWnty;}ztd||fƒWYd}~qd}~wwd}	}
t |||||	|
¡}| |¡q|S)zReturn system disk partitions.ÚnoneÚzskipping %r: %sN)	rPÚdisk_partitionsÚ
disk_usager9ÚOSErrorr
rZ	sdiskpartÚappend)ÚallÚretlistZ
partitionsÚ	partitionZdeviceZ
mountpointZfstypeÚoptsÚerrZmaxfileZmaxpathZntuplerJrJrKr{×s,
ÿ€ýÿr{éÿÿÿÿc
Cstj ¡}|dkr| dd¡||vr#td|d dd„|Dƒ¡fƒ‚tj|\}}t |¡}tƒ}|D]T}|\}}	}
}}}
}|	|vrDq4|
|vrIq4|	t	t
fvr]|rVtj|Ž}|r]tj|Ž}t|
}
t
|	ƒ}	t|
ƒ}
|dkryt ||	|
|||
|¡}n
t ||	|
|||
¡}| |¡q4t|ƒS)	z»Return socket connections.  If pid == -1 return system-wide
    connections (as opposed to connections opened by one process only).
    Only INET sockets are returned (UNIX are not).
    r„Úunixrz+invalid %r kind argument; choose between %sz, cSrfrJ)ÚreprrhrJrJrKrkrlz#net_connections.<locals>.<listcomp>N)rZ	conn_tmapÚcopyÚpoprsÚjoinrPÚnet_connectionsÚsetrr	ÚaddrÚTCP_STATUSESrrZsconnÚpconnÚaddÚlist)ÚkindÚ_pidZcmapZfamiliesÚtypesÚrawlistrpÚitemÚfdÚfamÚtype_ÚladdrÚraddrr+ÚpidÚntrJrJrKrŠüs:
ÿ


rŠcCsRt ¡}| ¡D]\}}|\}}}}ttdƒrt |¡}t ||||¡||<q|S)z)Get NIC stats (isup, duplex, speed, mtu).Ú	NicDuplexN)rPÚnet_if_statsÚitemsÚhasattrrrZ	snicstats)rpÚnamerŸZisupZduplexÚspeedZmturJrJrKrž!s

ržcCru)z:The system boot time expressed in seconds since the epoch.N)rPÚ	boot_timerJrJrJrKr£1rwr£cCs\g}t ¡}d}|D]!}|\}}}}}}	|sq
||vrd}t |||||	¡}
| |
¡q
|S)z:Return currently connected users as a list of namedtuples.)z:0.0z:0Ú	localhostN)rPÚusersrZsuserr~)r€r”r¤r•r2ÚttyÚhostnameZtstampZuser_processr›rœrJrJrKr¥6sr¥cCsdd„t ttƒƒ¡DƒS)z7Returns a list of PIDs currently running on the system.cSsg|]
}| ¡rt|ƒ‘qSrJ)Úisdigitr]rhrJrJrKrkPszpids.<locals>.<listcomp>N)rGÚlistdirrrrJrJrJrKÚpidsNórªcCs
t |¡S)z&Check for the existence of a unix pid.N)rÚ
pid_exists)r›rJrJrKr¬Ss
r¬cst ˆ¡‡fdd„ƒ}|S)zƒCall callable into a try/except clause and translate ENOENT,
    EACCES and EPERM in NoSuchProcess or AccessDenied exceptions.
    c	s¢zˆ|g|¢Ri|¤ŽWSttfy*t|jƒs!t|j|jƒ‚t|j|j|jƒ‚ty7t	|j|jƒ‚t
yP|jdkrOdtƒvrNt	|j|jƒ‚‚‚w©Nr)rrr¬r›rÚ_namerÚ_ppidrr
r}rª)ÚselfÚargsÚkwargs©ÚfunrJrKÚwrapper\s


úz wrap_exceptions.<locals>.wrapperN)Ú	functoolsÚwraps)r´rµrJr³rKÚwrap_exceptionsXsr¸c@s¬eZdZdZgd¢Zdd„Zdd„Zdd„Zd	d
„Ze	e
dd„ƒƒZe	e
d
d„ƒƒZe	e
dd„ƒƒZ
e	dd„ƒZe	dd„ƒZe	dd„ƒZe	dd„ƒZe	dd„ƒZe	dd„ƒZe	dd„ƒZe	dd „ƒZe	d!d"„ƒZe	d#d$„ƒZe	d%d&„ƒZe	d'd(„ƒZe	d)d*„ƒZe	d+d,„ƒZe	d-d.„ƒZe	d/d0„ƒZeZe	d1d2„ƒZe	d3d4„ƒZ e	d5d6„ƒZ!d7d8„Z"e	dHd:d;„ƒZ#e$d<d=ƒZ%e$d<d>ƒZ&e	d?d@„ƒZ'e	dAdB„ƒZ(e	dCdD„ƒZ)e	dIdFdG„ƒZ*dES)JÚProcessz1Wrapper class around underlying C implementation.)r›r®r¯Ú_procfs_pathÚ_cachecCs||_d|_d|_tƒ|_dS©N)r›r®r¯rrº)r°r›rJrJrKÚ__init__yszProcess.__init__cCst d|j|jf¡dS)z+Raise NSP if the process disappeared on us.ú%s/%sN)rGÚstatrºr›©r°rJrJrKÚ
_assert_aliveszProcess._assert_alivecCó(|j |¡|j |¡|j |¡dSr¼)Ú_proc_name_and_argsZcache_activateÚ_proc_basic_infoÚ
_proc_credrÀrJrJrKÚ
oneshot_enter…ózProcess.oneshot_entercCrÂr¼)rÃZcache_deactivaterÄrÅrÀrJrJrKÚoneshot_exitŠrÇzProcess.oneshot_exitcCót |j|j¡Sr¼)rPZproc_name_and_argsr›rºrÀrJrJrKrÏózProcess._proc_name_and_argscCsT|jdkrtj d|j|jf¡st|jƒ‚t |j|j¡}t|ƒtt	ƒks(J‚|S)Nrz%s/%s/psinfo)
r›rGr@Úexistsrºr
rPZproc_basic_infoÚlenÚ
proc_info_map)r°rprJrJrKrĔs
ÿ
zProcess._proc_basic_infocCrÉr¼)rPZ	proc_credr›rºrÀrJrJrKrŞrÊzProcess._proc_credcCs| ¡dSr­)rÃrÀrJrJrKr¡£szProcess.namecCs8zt d|j|jf¡WStyYnw| ¡dS)Nz%s/%s/path/a.outrz)rGÚreadlinkrºr›r}ÚcmdlinerÀrJrJrKÚexe¨sÿÿzProcess.execCs| ¡d d¡S)NrrC)rÃr\rÀrJrJrKrϵózProcess.cmdlinecCrÉr¼)rPZproc_environr›rºrÀrJrJrKrS¹ózProcess.environcCó| ¡tdS)Nr(©rÄrÍrÀrJrJrKr(½rÒzProcess.create_timecCrÓ)Nr*rÔrÀrJrJrKr*ÁrÒzProcess.num_threadscCrÓ)Nr)rÔrÀrJrJrKÚnice_getÅszProcess.nice_getcCs&|jdvrt|j|jƒ‚t |j|¡S)N)rr)r›r
r®Ú
cext_posixÚsetpriority)r°ÚvaluerJrJrKÚnice_setÌs
zProcess.nice_setcCs| ¡td|_|jS)Nr%)rÄrÍr¯rÀrJrJrKr%ÖszProcess.ppidcCs^z| ¡\}}}}}}Wnty'| ¡td}| ¡td}d}Ynwt |||¡S)Nr-r.©rÅr
rÄrÍrZpuids)r°ÚrealÚ	effectiveÚsavedÚ_rJrJrKÚuidsÛóýzProcess.uidscCs^z| ¡\}}}}}}Wnty'| ¡td}| ¡td}d}Ynwt |||¡S)Nr/r0rÚ)r°rÞrÛrÜrÝrJrJrKÚgidsåràzProcess.gidsc
Cs\z
t |j|j¡}Wnty(}z|jtjkrtsd}n‚WYd}~nd}~wwtj	|ŽS)N)çrârârâ)
rPZproc_cpu_timesr›rºr}ÚerrnoÚ	EOVERFLOWÚ	IS_64_BITrr5)r°ÚtimesrƒrJrJrKrqïsþ€÷
zProcess.cpu_timescCrÉr¼)rPZproc_cpu_numr›rºrÀrJrJrKÚcpu_numrÒzProcess.cpu_numc	Csx|j}d}t| ¡tdƒ}|tjkr2dD]}zt d||j|f¡WSt	y1d}Yqw|r:| 
¡dSdS)NFr,)rrréÿz
%s/%d/path/%dT)rºr¸rÄrÍrPZPRNODEVrGrÎr›rrÁ)r°Úprocfs_pathÚ
hit_enoentr¦rjrJrJrKÚterminals$ÿ

ÿþÿzProcess.terminalcCsF|j}zt d||jf¡WSty"t d||jf¡YdSw)Nz%s/%s/path/cwdr¾)rºrGrÎr›rr¿)r°rérJrJrKÚcwdsþzProcess.cwdcCs2| ¡}|tdd}|tdd}t||ƒS)Nr&ir')rÄrÍr>)r°rpr&r'rJrJrKÚmemory_info#s
zProcess.memory_infocCs| ¡td}t |d¡S)Nr+ú?)rÄrÍÚ
PROC_STATUSESÚget)r°ÚcoderJrJrKr+,szProcess.statusc
CsÈ|j}g}t d||jf¡}d}|D]H}t|ƒ}zt |j||¡\}}Wn)tyN}z|jtj	kr;t
s;WYd}~q|jtjkrId}WYd}~q‚d}~wwt 
|||¡}	| |	¡q|rb| ¡|S)Nz	%s/%d/lwpFT)rºrGr©r›r]rPZquery_process_threadÚEnvironmentErrorrãräråÚENOENTrZpthreadr~rÁ)
r°rérpZtidsrêÚtidÚutimeZstimerƒrœrJrJrKÚthreads2s0ÿ€òzProcess.threadsc	Cs¤g}d}|j}d||jf}t d||jf¡D]1}tj ||¡}tj |¡rIzt |¡}Wnty9d}Yqwt	|ƒrI| 
t |t
|ƒ¡¡q|rP| ¡|S)NFz
%s/%d/pathz%s/%d/fdT)rºr›rGr©r@r‰ÚislinkrÎrrr~rZ	popenfiler]rÁ)r°r€rêréZpathdirr–r@ÚfilerJrJrKÚ
open_filesSs&þ€zProcess.open_filesccs(d|}tj|dtjtjd}| ¡\}}tr#dd„||fDƒ\}}|jdkrJd| ¡vr5t|j|j	ƒ‚d| ¡vrBt
|j|j	ƒ‚td	||fƒ‚| d
¡dd…}t
|ƒD]:\}}| ¡}| d
¡r‘| dd¡d}	||d ¡}
|
dkr|tj}
n
|
dkr„tj}
nd}
dtj|
|	dtjfVqWdS)z<Get UNIX sockets used by process by parsing 'pfiles' output.z	pfiles %sT)ÚshellrNr`cSsg|]	}| tjj¡‘qSrJ)rVrWrNrXrhrJrJrKrkqsÿz-Process._get_unix_sockets.<locals>.<listcomp>rzpermission deniedzno such processz%r command error
%srOrNzsockname: AF_UNIXrCÚSOCK_STREAMÚ
SOCK_DGRAMr„rz)rQrRrTrUrrYÚlowerr
r›r®rrZr\Ú	enumerateÚlstripÚ
startswithr[ÚsocketrûrüÚAF_UNIXrÚ	CONN_NONE)r°r›Úcmdr_rNr`raÚirbr@ÚtyperJrJrKÚ_get_unix_socketshs<€ÿ
ÿ

€õzProcess._get_unix_socketsÚinetcCsPt||jd}|st d|j|jf¡|dvr&| dd„| |j¡Dƒ¡|S)N)r’r¾)rr…cSsg|]}tj|Ž‘qSrJ)rrŽ)riÚconnrJrJrKrk–sz'Process.connections.<locals>.<listcomp>)rŠr›rGr¿rºÚextendr)r°r‘rprJrJrKÚconnectionsˆs

ÿzProcess.connectionsZmmapzpath rss anon lockedzaddr perms path rss anon lockedcCsdd„}|j}g}z	t |j|¡}Wnty/}z|jtjkr*ts*gWYd}~S‚d}~wwd}|D]R}|\}}	}
}}}
}|||	ƒ}| d¡s{z
t	 
d||j|f¡}Wn$tyz}z|jtjkrod||j|f}d}n‚WYd}~nd}~ww| ||
|||
|f¡q4|r| 
¡|S)NcSs0dt|ƒdd… d¡t|ƒdd… d¡fS)Nz%s-%srÚL)Úhexr[)ÚstartÚendrJrJrKÚtoaddrŸsÿz#Process.memory_maps.<locals>.toaddrFú[z
%s/%s/path/%sT)rºrPZproc_memory_mapsr›r}rãrärårrGrÎrór~rÁ)r°rrér€r”rƒrêr•rŒZaddrsizeÚpermr¡r&ZanonrArJrJrKÚmemory_mapss@€õ

ÿþ€÷zProcess.memory_mapscCstt d|j|jf¡ƒS)Nz%s/%s/fd)rÌrGr©rºr›rÀrJrJrKÚnum_fdsÌr«zProcess.num_fdscCstjt |j|j¡ŽSr¼)rZpctxswrPZproc_num_ctx_switchesr›rºrÀrJrJrKÚnum_ctx_switchesÐsÿzProcess.num_ctx_switchesNcCst |j||j¡Sr¼)rZwait_pidr›r®)r°ÚtimeoutrJrJrKÚwaitÕrÑzProcess.wait)rr¼)+Ú__name__Ú
__module__Ú__qualname__Ú__doc__Ú	__slots__r½rÁrÆrÈr¸rrÃrÄrÅr¡rÐrÏrSr(r*rÕrÙr%rßrárqrçrërìríZmemory_full_infor+rörùrrrZnt_mmap_groupedZnt_mmap_extrrrrrJrJrJrKr¹tsˆ







	

	
	






 
 


.

r¹)F)r„)srrãr¶rGrrQrWÚcollectionsrrrzrrrrÖrrPr	r
rrr
rrrrrrZ_compatrrrrrZ__extra__all__ZgetpagesizerIZAF_LINKÚmaxsizerårrZSSLEEPZSTATUS_SLEEPINGZSRUNZSTATUS_RUNNINGZSZOMBZ
STATUS_ZOMBIEZSSTOPZSTATUS_STOPPEDZSIDLZSTATUS_IDLEZSONPROCZSWAITZSTATUS_WAITINGrïZTCPS_ESTABLISHEDZCONN_ESTABLISHEDZ
TCPS_SYN_SENTZ
CONN_SYN_SENTZ
TCPS_SYN_RCVDZ
CONN_SYN_RECVZTCPS_FIN_WAIT_1ZCONN_FIN_WAIT1ZTCPS_FIN_WAIT_2ZCONN_FIN_WAIT2ZTCPS_TIME_WAITZCONN_TIME_WAITZTCPS_CLOSEDZ
CONN_CLOSEZTCPS_CLOSE_WAITZCONN_CLOSE_WAITZ
TCPS_LAST_ACKZ
CONN_LAST_ACKZTCPS_LISTENZCONN_LISTENZTCPS_CLOSINGZCONN_CLOSINGZPSUTIL_CONN_NONErZ	TCPS_IDLEZ
TCPS_BOUNDrÚdictrÍr1r5r8r>Zpfullmemr?r‰Ú_fieldsrBrLrerqrmrtrvrxZdisk_io_countersr|r{Znet_io_countersZnet_if_addrsrŠržr£r¥rªr¬r¸Úobjectr¹rJrJrJrKÚ<module>sÒ
ùòôÿÿÿ	&	

!
%