a MÝ_µ@ã @sÚdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddlm&Z&ddlm'Z'ddlm(Z(ddlm)Z)ddl*m+Z+ddl*m,Z,ddl*m-Z-dd l*m.Z.dd!l*m/Z/dd"l*m0Z0e j1d#krîddl2Z2ndZ2gd$¢Z3d%Z4ej5 6d&e 7¡¡Z8e9ed'ƒZ:e9ed(ƒZ;e<ƒZ=e >d)¡Z?e @¡ZAdaBe0rLd*nd+ZCe jDd,kZEd-ZFe2durpe jGZHne2 Id.d/eJe jGƒi¡ZKeKjHZHe2dur¨dZLdZMd0ZNd1ZOn Gd2d3„d3e2jIƒZPeQƒ RePjS¡ejTejUejVejWejXejYejZejZej[ej\ej]ej^d4œ Z_ej`ejaejbejcejdejeejfejgejhejiejjd5œ Zked6gd7¢ƒZled8gd9¢ƒZmed:gd;¢ƒZnedeojpd?ƒZqed@gdA¢ƒZredBdCdD serjp¡ƒZtedEgdF¢ƒZuedGgdH¢ƒZvdIdJ„ZwdKdL„ZxdMdN„ZyedOdP„ƒZze=dQfdRdS„Z{z ezdTƒWn.e|y e  }¡edUdVƒdWdWdWƒa~Yn0dZzddXl€mZWn@eyvddl‚Z‚e‚jƒddQdYZ„e9e„dZƒrrd™d[dZ„ZYn0edurše3 …d\d]„e†eƒDƒ¡d^d_„Z‡d`da„Zˆdbdc„Z‰ddde„ZŠdfdg„Z‹dhdi„ZŒdjdk„Zdldm„ZŽej5 6dn¡söej5 6do¡rdpdq„Zn ej5 6dr¡rdsdq„Zndtdq„ZejZGdudv„dve|ƒZ‘Gdwdx„dxƒZ’e’ƒZ“dšdzd{„Z”d|d}„Z•d~d„Z–ej—Z—d›dd‚„Z˜dœdƒd„„Z™d…d†„Zšd‡dˆ„Z›d‰dŠ„Zœd‹dŒ„ZddŽ„Zždd„ZŸd‘d’„Z d“d”„Z¡d•d–„Z¢Gd—d˜„d˜e<ƒZ£dS)zLinux platform implementation.é)ÚdivisionN)Ú defaultdict)Ú namedtupleé)Ú_common)Ú_psposix)Ú _psutil_linux)Ú _psutil_posix)Ú AccessDenied)Údebug)Údecode)Úget_procfs_path)Ú isfile_strict)Úmemoize)Úmemoize_when_activated)ÚNIC_DUPLEX_FULL)ÚNIC_DUPLEX_HALF)ÚNIC_DUPLEX_UNKNOWN)Ú NoSuchProcess)Ú open_binary)Ú open_text)Úparse_environ_block)Úpath_exists_strict)Ú supports_ipv6)Ú usage_percent)Ú ZombieProcess)Úb)Ú basestring)ÚFileNotFoundError)ÚPermissionError)ÚProcessLookupError)ÚPY3)éé)Z PROCFS_PATHÚIOPRIO_CLASS_NONEÚIOPRIO_CLASS_RTÚIOPRIO_CLASS_BEÚIOPRIO_CLASS_IDLEÚCONN_ESTABLISHEDÚ CONN_SYN_SENTÚ CONN_SYN_RECVÚCONN_FIN_WAIT1ÚCONN_FIN_WAIT2ÚCONN_TIME_WAITÚ CONN_CLOSEÚCONN_CLOSE_WAITÚ CONN_LAST_ACKÚ CONN_LISTENÚ CONN_CLOSINGz/sys/class/power_supplyz/proc/%s/smapsÚproc_ioprio_getÚproc_cpu_affinity_getÚ SC_CLK_TCKéÿÿÿÿi ÚlittleiÚ AddressFamilyÚAF_LINKér"c@seZdZdZdZdZdZdS)Ú IOPriorityrrr:r"N)Ú__name__Ú __module__Ú __qualname__r$r%r&r'©r?r?ú5/usr/lib64/python3.9/site-packages/psutil/_pslinux.pyr;wsr;) ÚRÚSÚDÚTÚtÚZÚXÚxÚKÚWÚIÚP) Z01Z02Z03Z04Z05Z06Z07Z08Z09Z0AZ0BÚsvmem) ÚtotalÚ availableÚpercentÚusedÚfreeÚactiveÚinactiveÚbuffersÚcachedÚsharedÚslabÚsdiskio) Ú read_countÚ write_countÚ read_bytesÚ write_bytesZ read_timeZ write_timeZread_merged_countZwrite_merged_countÚ busy_timeÚ popenfile)ÚpathÚfdZpositionÚmodeÚflagsÚpmemz"rss vms shared text lib data dirtyÚpfullmem)ÚussÚpssÚswapÚ pmmap_grouped) r`ÚrssÚsizergZ shared_cleanZ shared_dirtyZ private_cleanZ private_dirtyZ referencedZ anonymousrhÚ pmmap_extz addr perms ú Úpio)rZr[r\r]Z read_charsZ write_charsÚ pcputimes)ÚuserÚsystemÚ children_userÚchildren_systemÚiowaitcCsLt|tƒsJ|ƒ‚t |¡}| d¡d}| d¡rHt|ƒsH|dd…}|S)zWrapper around os.readlink().úrú (deleted)Néöÿÿÿ)Ú isinstancerÚosÚreadlinkÚsplitÚendswithr)r`r?r?r@rzÐs   rzcCsXtjdtjdtjdi}||tjtjBtjB@}|tj@rH| ddd¡}| dd¡}|S)zZConvert file's open() flags into a readable string. Used by Process.open_files(). ÚrÚwzw+Úarzr+)ryÚO_RDONLYÚO_WRONLYÚO_RDWRÚO_APPENDÚreplace)rcZ modes_maprbr?r?r@Úfile_flags_to_modeäs   r…cCs4| dd¡}d}|rd|}nd|}t |tj¡S)zÜReturn True if the given name refers to a root device (e.g. "sda", "nvme0n1") as opposed to a logical partition (e.g. "sda1", "nvme0n1p1"). If name is a virtual device (e.g. "loop1", "ram") return True. ú/ú!Tz /sys/block/%sz/sys/block/%s/device)r„ryÚaccessÚF_OK)ÚnameZincluding_virtualr`r?r?r@Úis_storage_deviceñs  r‹cCs”td|ƒ$}| ¡ ¡dd…}Wdƒn1s60Ygd¢}t|ƒ}|dkrb| d¡|dkrt| d¡|d kr†| d ¡td |ƒadS) zøSet a namedtuple of variable fields depending on the CPU times available on this Linux kernel version which may be: (user, nice, system, idle, iowait, irq, softirq, [steal, [guest, [guest_nice]]]) Used by cpu_times() function. ú%s/statrN)rpÚnicerqZidlertZirqZsoftirqéZstealé Zguesté Z guest_niceÚ scputimes)rÚreadliner{ÚlenÚappendrr‘)Ú procfs_pathÚfÚvaluesÚfieldsZvlenr?r?r@Úset_scputimes_ntuples 2   r™Tc CstzF|rt|ƒnt|ƒ}| ¡ ¡WdƒWS1s:0YWn(ttfyn|turh|YS‚Yn0dS)z·Return file content. fallback: the value returned in case the file does not exist or cannot be read binary: whether to open the file in binary or text mode. N)rrÚreadÚstripÚIOErrorÚOSErrorÚ_DEFAULT)ÚfnameÚfallbackÚbinaryr–r?r?r@Úcats0r¢ú/procr‘zuser system idleç)Úprlimit)Z use_errnor¥cCsšGdd„dtjƒ}|ƒ}|dur8t ||dt |¡¡}n6|ƒ}|d|_|d|_t ||t |¡t |¡¡}|dkrŽt ¡}t|t   |¡ƒ‚|j|jfS)Nc@s eZdZdejfdejfgZdS)zprlimit..StructRlimitÚrlim_curÚrlim_maxN)r<r=r>ÚctypesZ c_longlongZ_fields_r?r?r?r@Ú StructRlimitJsÿr©rr) r¨Z StructureÚlibcr¥Zbyrefr¦r§Z get_errnorryÚstrerror)ÚpidÚ resource_Úlimitsr©ÚcurrentÚretÚnewÚerrnor?r?r@r¥Is  ÿcCs"g|]}| d¡r| ¡r|‘qS)ZRLIM)Ú startswithÚisupper©Ú.0rHr?r?r@Ú bór·c Cs|d}|| dd¡}z|d}|d}|d}WntyJ|YS0ztdtƒƒ}Wntyt|YS0d}|@|D]*}| ¡}| d¡r„|t| ¡d ƒ7}q„Wd ƒn1sÄ0Y|t 9}||} ||} | t | d |ƒ8} | | 7} | |t |d |ƒ7} t| ƒS) a…Fallback for kernels < 3.14 where /proc/meminfo does not provide "MemAvailable:" column, see: https://blog.famzah.net/2014/09/24/ This code reimplements the algorithm outlined here: https://git.kernel.org/cgit/linux/kernel/git/torvalds/linux.git/ commit/?id=34e431b0ae398fc54ea69ff85ec700722c9da773 XXX: on recent kernels this calculation differs by ~1.5% than "MemAvailable:" as it's calculated slightly differently, see: https://gitlab.com/procps-ng/procps/issues/42 https://github.com/famzah/linux-memavailable-procfs/issues/2 It is still way more realistic than doing (free + cached) though. óMemFree:óCached:rs Active(file):sInactive(file):ó SReclaimable:z %s/zoneinfoslowrNr:g@) ÚgetÚKeyErrorrr rœr›r³Úintr{ÚPAGESIZEÚmin) ÚmemsrRr Zlru_active_fileZlru_inactive_fileZslab_reclaimabler–Z watermark_lowÚlineÚavailZ pagecacher?r?r@Úcalculate_avail_vmemjs2      4rÄc Cs¼g}i}tdtƒƒ:}|D]$}| ¡}t|dƒd||d<qWdƒn1sV0Y|d}|d}z |d}Wn tyœd}| d ¡Yn0z |d }Wn tyÊd}| d ¡Yn0|| d d¡7}z |d } WnDty,z |d} Wn"ty&d} | d¡Yn0Yn0z |d} Wn"ty\d} | d¡Yn0z |d} WnTty¾z|d|d|d} Wn"ty¸d} | d¡Yn0Yn0z |d} Wntyäd} Yn0||||} | dkr||} z |d}Wnty0t|ƒ}Yn0|dkrJd}| d¡||krX|}t|||dd}|r dd  |¡t |ƒdkrŒdndf}t   |t ¡t|||| || | ||| | ƒ S)a“Report virtual memory stats. This implementation matches "free" and "vmstat -s" cmdline utility values and procps-ng-3.3.12 source was used as a reference (2016-09-18): https://gitlab.com/procps-ng/procps/blob/ 24fd2605c51fccc375ab0287cec33aa767f06718/proc/sysinfo.c For reference, procps-ng-3.3.10 is the version available on Ubuntu 16.04. Note about "available" memory: up until psutil 4.3 it was calculated as "avail = (free + buffers + cached)". Now "MemAvailable:" column (kernel 3.14) from /proc/meminfo is used as it's more accurate. That matches "available" column in newer versions of "free". ú %s/meminforérNs MemTotal:r¹sBuffers:rUrºrVr»sShmem:s MemShared:rWsActive:rSs Inactive:s Inact_dirty:s Inact_clean:sInact_laundry:rTsSlab:s MemAvailable:rO©Zround_z6%s memory stats couldn't be determined and %s set to 0ú, ZwasZwere)rr r{r¾r½r”r¼rÄrÚjoinr“ÚwarningsÚwarnÚRuntimeWarningrM)Zmissing_fieldsrÁr–rÂr˜rNrRrUrVrWrSrTrXrQrÃrPÚmsgr?r?r@Úvirtual_memoryžsŽ8        ÿþÿ        þ   ÿrÎc Csèi}tdtƒƒ:}|D]$}| ¡}t|dƒd||d<qWdƒn1sR0Yz|d}|d}Wn8ty¨t ¡\}}}}}}}||9}||9}Yn0||}t||dd} ztd tƒƒ}WnFty} z,d t | ƒ} t   | t ¡d} } WYd} ~ nÄd} ~ 00|¤d} } |D]n}|  d ¡rXt| d ¡dƒd d} n&|  d¡r~t| d ¡dƒd d} | dur,| dur,q´q,d} t   | t ¡d} } Wdƒn1sÊ0Yt |||| | | ¡S)zReturn swap memory metrics.rÅrrÆrNs SwapTotal:s SwapFree:rÇz %s/vmstatzP'sin' and 'sout' swap memory stats couldn't be determined and were set to 0 (%s)spswpinó r#spswpoutzK'sin' and 'sout' swap memory stats couldn't be determined and were set to 0)rr r{r¾r½ÚcextZ linux_sysinforrœÚstrrÊrËrÌr³rZsswap)rÁr–rÂr˜rNrRÚ_Zunit_multiplierrQrPÚerrrÍZsinZsoutr?r?r@Ú swap_memorysF8  ÿ     (rÔcCsrtƒ}t|ƒtd|ƒ}| ¡ ¡}Wdƒn1s<0Y|dttjƒd…}dd„|Dƒ}t|ŽS)zíReturn a named tuple representing the following system-wide CPU times: (user, nice, system, idle, iowait, irq, softirq [steal, [guest, [guest_nice]]]) Last 3 fields may not be available on all Linux kernel versions. rŒNrcSsg|]}t|ƒt‘qSr?©ÚfloatÚ CLOCK_TICKSrµr?r?r@r·^r¸zcpu_times..)r r™rr’r{r“r‘Ú_fields)r•r–r—r˜r?r?r@Ú cpu_timesRs*rÙcCs tƒ}t|ƒg}td|ƒn}| ¡|D]L}| d¡r,| ¡}|dttjƒd…}dd„|Dƒ}t|Ž}|  |¡q,|WdƒS1s’0YdS)zfReturn a list of namedtuple representing the CPU times for every CPU available on the system. rŒscpurcSsg|]}t|ƒt‘qSr?rÕrµr?r?r@r·pr¸z!per_cpu_times..N) r r™rr’r³r{r“r‘rØr”)r•Úcpusr–rÂr—r˜Úentryr?r?r@Ú per_cpu_timesbs  rÜc Csòz t d¡WStyìd}tdtƒƒ0}|D]}| ¡ d¡r2|d7}q2Wdƒn1sb0Y|dkrÖt d¡}t dtƒƒ:}|D]$}|  d ¡d}|  |¡r’|d7}q’Wdƒn1sÌ0Y|dkräYdS|YS0dS) z0Return the number of logical CPUs in the system.ÚSC_NPROCESSORS_ONLNrú %s/cpuinfos processorrNzcpu\drŒrm) ryÚsysconfÚ ValueErrorrr Úlowerr³ÚreÚcompilerr{Úmatch)Únumr–rÂÚsearchr?r?r@Úcpu_count_logicalvs$  (  (rçc Cs2tƒ}d}d}t |¡p t |¡D]>}t|ƒ"}| | ¡ ¡¡Wdƒq"1sV0Yq"t|ƒ}|dkrv|Si}i}tdtƒƒ~}|D]h}| ¡ ¡}|sÔz|d||d<Wnt yÌYn0i}q’|  d¡r’|  d d ¡\} } t | ƒ|| <q’Wdƒn1s0Yt | ¡ƒ}|p0dS) z2Return the number of physical cores in the system.z9/sys/devices/system/cpu/cpu[0-9]*/topology/core_cpus_listz?/sys/devices/system/cpu/cpu[0-9]*/topology/thread_siblings_listNrrÞó cpu coresó physical id)rérès :r)ÚsetÚglobrÚaddršr›r“r rár½r³r{r¾Úsumr—) ÚlsZp1Zp2r`r–ÚresultÚmappingZ current_inforÂÚkeyÚvaluer?r?r@Úcpu_count_physical“s4 2 ÿ  . rócCsÆtdtƒƒ”}d}d}d}|D]r}| d¡r@t| ¡dƒ}n6| d¡r\t| ¡dƒ}n| d¡rvt| ¡dƒ}|dur |dur |dur q”q Wdƒn1s¨0Yd}t ||||¡S)z*Return various CPU stats as a named tuple.rŒNsctxtrsintrssoftirqr)rr r³r¾r{rZ scpustats)r–Z ctx_switchesZ interruptsZsoft_interruptsrÂZsyscallsr?r?r@Ú cpu_stats½s&   ÿ$ÿrôz'/sys/devices/system/cpu/cpufreq/policy0z$/sys/devices/system/cpu/cpu0/cpufreqcCs¾dd„}g}ttƒƒD]¢}||ƒ}|s(qtjj}t||dƒdd}|durlt||dƒdd}|durltdƒ‚t|ƒd}tt||d ƒƒƒd}tt||d ƒƒƒd}| t   |||¡¡q|S) z‚Return frequency metrics for all CPUs. Contrarily to other OSes, Linux updates these values in real-time. cSs.d|d|fD]}tj |¡r|SqdS)Nz(/sys/devices/system/cpu/cpufreq/policy%sz%/sys/devices/system/cpu/cpu%s/cpufreq)ryr`Úexists)råÚpr?r?r@Úget_pathÙs ÿ zcpu_freq..get_pathZscaling_cur_freqN©r Zcpuinfo_cur_freqz!can't find current frequency fileièZscaling_max_freqZscaling_min_freq) Úrangerçryr`rÉr¢ÚNotImplementedErrorr¾r”rÚscpufreq)r÷r°Únr`ZpjoinZcurrZmax_Zmin_r?r?r@Úcpu_freqÔs&ÿ rýz /proc/cpuinfoc Csvg}tdtƒƒP}|D]:}| ¡ d¡r| dd¡\}}| t t|ƒdd¡¡qWdƒn1sh0Y|S)z}Alternate implementation using /proc/cpuinfo. min and max frequencies are not available and are set to None. rÞscpu mhzó:rr¤N) rr rár³r{r”rrûrÖ)r°r–rÂrñròr?r?r@rýõs8cCsgS)zGDummy implementation when none of the above files are present. r?r?r?r?r@rýsc@s eZdZdS)Ú_Ipv6UnsupportedErrorN)r<r=r>r?r?r?r@rÿsrÿc@sZeZdZdZdd„Zdd„Zdd„Zedd „ƒZedd d „ƒZ edd d„ƒZ ddd„Z d S)Ú ConnectionsawA wrapper on top of /proc/net/* files, retrieving per-process and system-wide open connections (TCP, UDP, UNIX) similarly to "netstat -an". Note: in case of UNIX sockets we're only able to determine the local endpoint/path, not the one it's connected to. According to [1] it would be possible but not easily. [1] http://serverfault.com/a/417946 c Cs˜dtjtjf}dtjtjf}dtjtjf}dtjtjf}dtjdf}|||||f||f|f|f||f|f|f|f||||f||f||fdœ |_d|_dS)NÚtcpÚtcp6ÚudpÚudp6Úunix) ÚallrÚtcp4rrÚudp4rrÚinetZinet4Zinet6)ÚsocketÚAF_INETÚ SOCK_STREAMÚAF_INET6Z SOCK_DGRAMZAF_UNIXÚtmapÚ _procfs_path)Úselfrrrrrr?r?r@Ú__init__ s$   õ zConnections.__init__c CsÊttƒ}t d|j|f¡D]¨}ztd|j||fƒ}WnVttfyRYqYqtyŽ}z&|j t j krxWYd}~q‚WYd}~qd}~00|  d¡r|dd…dd…}||  |t |ƒf¡q|S)Nú%s/%s/fdú %s/%s/fd/%szsocket:[rŽr6)rÚlistryÚlistdirrrzrr rr²ÚEINVALr³r”r¾)rr¬ÚinodesraÚinoderÓr?r?r@Úget_proc_inodes7s   zConnections.get_proc_inodesc CsFi}tƒD]6}z| | |¡¡Wq tttfy>Yq Yq 0q |S©N)ÚpidsÚupdaterrr r)rrr¬r?r?r@Úget_all_inodesMs  zConnections.get_all_inodesc Csø| d¡\}}t|dƒ}|s dStr.| d¡}|tjkrntrZt |t  |¡ddd…¡}qìt |t  |¡¡}n~t  |¡}zRtr¤t tj t j dgt   d|¡¢RŽ¡}n$t tj t j dgt   d|¡¢RŽ¡}Wn tyêtƒsät‚n‚Yn0t ||¡S) a†Accept an "ip:port" address as displayed in /proc/net/* and convert it into a human readable form, like: "0500000A:0016" -> ("10.0.0.5", 22) "0000000000000000FFFF00000100007F:9E49" -> ("::ffff:127.0.0.1", 40521) The IP address portion is a little or big endian four-byte hexadecimal number; that is, the least significant byte is listed first, so we need to reverse the order of the bytes to convert it to an IP address. The port is represented as a two-byte hexadecimal number. Reference: http://linuxdevcenter.com/pub/a/linux/2000/11/16/LinuxAdmin.html ú:ér?ÚasciiNr6z>4Iz<4I)r{r¾r!Úencoder r Ú LITTLE_ENDIANZ inet_ntopÚbase64Z b16decoder ÚstructÚpackÚunpackràrrÿrÚaddr)r'ÚfamilyZipÚportr?r?r@Údecode_address]s4    þþ zConnections.decode_addressNc csR| d¡rtj |¡sdSt|td}| ¡t|dƒD]ð\}}z(| ¡dd…\ }} } } }}}}}} Wn$t yt d|||fƒ‚Yn0| |vr¬|| d\} }nd\} }|durÈ|| krÈq.z %s/net/%s)r6)rràrÉr rrrrêr r r r;r@rZpconnZsconnrìr)rÚkindr¬rr°Z proto_namer(r5r`rîrar8r9r:Z bound_pidZconnr?r?r@ÚretrieveÞs< ÿ  ÿÿÿÿzConnections.retrieve)N)N)N) r<r=r>Ú__doc__rrrÚ staticmethodr*r;r@rCr?r?r?r@rs  2 ' %rr cCs t |¡S)z$Return system-wide open connections.)Ú _connectionsrC)rBr?r?r@Únet_connectionssrGcCsØtdtƒƒ}| ¡}Wdƒn1s,0Yi}|dd…D]Œ}| d¡}|dkshJt|ƒƒ‚|d|… ¡}||dd… ¡ ¡}tt|ƒ\}}} } } } } }}}}}}}}}||||| || |f||<qF|S)zsReturn network I/O statistics for every network interface installed on the system as a dict of raw tuples. z %s/net/devNr:rrr) rr Ú readlinesÚrfindrAr›r{Úmapr¾)r–ÚlinesÚretdictrÂÚcolonrŠr˜Z bytes_recvZ packets_recvZerrinZdropinZfifoinZframeinZ compressedinZ multicastinZ bytes_sentZ packets_sentZerroutZdropoutZfifooutZ collisionsoutZ carrieroutZ compressedoutr?r?r@Únet_io_counterss:& ðÿ rNc Cs¤tjttjttjti}tƒ ¡}i}|D]v}z&t   |¡}t   |¡}t  |¡\}}Wn2t y„}z|jtjkrp‚WYd}~q(d}~00t |||||¡||<q(|S)z)Get NIC stats (isup, duplex, speed, mtu).N)rÐZ DUPLEX_FULLrZ DUPLEX_HALFrZDUPLEX_UNKNOWNrrNÚkeysÚ cext_posixZ net_if_mtuZnet_if_is_runningZnet_if_duplex_speedrr²ZENODEVrZ snicstats) Z duplex_mapÚnamesr°rŠZmtuZisupZduplexZspeedrÓr?r?r@Ú net_if_stats+s þ    rRFc Cs®dd„}dd„}tj dtƒ¡r*|ƒ}n"tj d¡r>|ƒ}ntdtƒƒ‚i}|D]T}|\ }}}} } } } } }}|s~t|ƒs~qT| t9} | t9} ||| | | | | ||f ||<qT|S)zcReturn disk I/O statistics for every disk installed on the system as a dict of raw tuples. c ssDtdtƒƒ}| ¡}Wdƒn1s,0Y|D]}| ¡}t|ƒ}|dkr”|d}t|dƒ}tt|dd…ƒ\ }}} } } } } }}}n|dks¤|dkrÖ|d}tt|dd…ƒ\ }}}} } } } } }}}nN|dkr|d}tt|dd…ƒ\}}} } d } } }} }n td |ƒ‚||| || | | || |f Vq:dS) Nú %s/diskstatsér"r:r#éér<rz!not sure how to interpret line %r)rr rHr{r“r¾rJrà)r–rKrÂr˜ZflenrŠÚreadsÚ reads_mergedÚrbytesÚrtimeÚwritesÚ writes_mergedÚwbytesÚwtimerÒr^r?r?r@Ú read_procfsLs4&  ÿ  ÿÿ ÿ  ÿz%disk_io_counters..read_procfsc ssÌt d¡D]¼}t tj d|¡¡D]¢\}}}d|vr6q"ttj |d¡ƒ }| ¡ ¡ ¡}Wdƒn1sn0Ytj  |¡}t t |dd…ƒ\ }}} } } } } }}}||| | | | ||| |f Vq"q dS)Nú /sys/blockÚstatr) ryrÚwalkr`rÉrršr›r{ÚbasenamerJr¾)ÚblockÚrootrÒÚfilesr–r˜rŠrWrXrYrZr[r\r]r^r^r?r?r@Ú read_sysfsws. ÿ ÿz$disk_io_counters..read_sysfsrSr`zC%s/diskstats nor /sys/block filesystem are available on this system)ryr`rõr rúr‹ÚDISK_SECTOR_SIZE)Zperdiskr_rgÚgenrLrÛrŠrWr[rYr]rZr^rXr\r^r?r?r@Údisk_io_countersHs0+  ÿÿÿ  ÿ rjc Cs&tƒ}tƒ}td|ƒ\}|D]F}| ¡}| d¡sD| | ¡¡q| d¡d}|dkr| d¡qWdƒn1sz0Y|dkr¦tj  d¡r¦tj  d¡}ntj  d |¡}g}t   |¡}|D]X} | \} } }} | d kräd } |sú| d ksÈ||vrúqÈd} }t  | | || | |¡}| |¡qÈ|S) z8Return mounted disk partitions as a list of namedtuples.z%s/filesystemsZnodevú rZzfsNr£z /etc/mtabz%s/self/mountsZnoner=)rêr rr›r³rìr{ryr`ÚisfileÚrealpathrÐÚdisk_partitionsrZ sdiskpartr”)rZfstypesr•r–rÂZfstypeZ mounts_pathÚretlistZ partitionsÚ partitionZdeviceZ mountpointZoptsZmaxfileZmaxpathÚntupler?r?r@rn§s8 *   ÿ rnc Csdt t¡}t d¡}| t d¡¡ttdd„|Dƒƒƒ}t d¡}t d¡}|D]"}|  d|¡}||vrR|  |¡qR|D]}z>|d}t t |ƒƒd }t j t j |¡d ¡}t |d d } WntttfyÚYqzYn0t |d dd} t |ddd} t |ddd d} | durBzt | ƒd } Wnty@d} Yn0| durvzt | ƒd } Wntytd} Yn0||   | || | f¡qz|s\t d¡}tt|ƒƒ}|D]ª}z.z5/sys/devices/platform/coretemp.*/hwmon/hwmon*/temp*_*z'/sys/devices/platform/coretemp.*/hwmon/z/sys/class/hwmon/Ú_inputg@@rŠF©r¡Z_maxNrøZ_critÚ_labelr=©r r¡z /sys/class/thermal/thermal_zone*ZtempÚtypezignoring %r for file %rz /trip_point*cSs,g|]$}d tj |¡ d¡dd…¡‘qS)rÒrr")rÉryr`rcr{)r¶rör?r?r@r·%sÿÿZ_typeÚcriticalZ_tempÚhigh)Ú collectionsrrrëÚextendÚsortedrêrârãÚsubr”rÖr¢ryr`rÉÚdirnamerœrràr Údict)r°Ú basenamesZ basenames2ÚreplrŠZaltnameÚbaser`r¯Ú unit_namerzryÚlabelrÓZ trip_pathsZ trip_pointsZ trip_pointZ trip_typer?r?r@Úsensors_temperaturesÒs–  ÿ            $ÿ ÿ ÿ   r†c Csêt t¡}t d¡}|s"t d¡}ttdd„|Dƒƒƒ}|D]¤}ztt|dƒƒ}WnDtt fy˜}z(t   d|t ¡WYd}~q.rtz ignoring %rNrŠFrurvr=rw)r{rrrër}rêr¾r¢rœrrÊrËrÌryr`rÉrr”rZsfanr€)r°rrƒr¯rÓr„r…r?r?r@Ú sensors_fansCs"   "ÿr‡c sÚtƒ‰‡fdd„}dd„t t¡Dƒ}|s.dStj tt|ƒd¡}||d|dƒ}||d |d ƒ}||d |d ƒ}||d ƒ}|durÀ|durÀzd||}Wqàty¼d}Yqà0n tt |dddƒ}|dkràdSd}|tj td¡tj td¡ƒ} | dur| dk}n4t |dddd  ¡} | dkr.multi_catcSs&g|]}| d¡sd| ¡vr|‘qS)ZBATZbattery)r³rárµr?r?r@r·vs ÿz#sensors_battery..Nrz /energy_nowz /charge_nowz /power_nowz /current_nowz /energy_fullz /charge_fullz/time_to_empty_nowgY@r¤z /capacityr6røz AC0/onlinez AC/onlinerz/statusr=FrwZ discharging)ZchargingZfullTié<)ÚobjectryrÚPOWER_SUPPLY_PATHr`rÉr}ÚZeroDivisionErrorr¾r¢rárZPOWER_TIME_UNLIMITEDZPOWER_TIME_UNKNOWNZsbattery) r‹ZbatsreZ energy_nowZ power_nowZ energy_fullZ time_to_emptyrPZ power_pluggedZonliner:Zsecsleftr?rŠr@Úsensors_batterycsh þþþ     þ       rc Cs\g}t ¡}|D]F}|\}}}}}}|s*q|dvr6d}t ||pBd|||¡} | | ¡q|S)z:Return currently connected users as a list of namedtuples.)z:0.0z:0Z localhostN)rÐÚusersrZsuserr”) roZrawlistÚitemrpZttyÚhostnameZtstampZ user_processr¬Úntr?r?r@r‘Ás r‘cCs„dtƒ}t|ƒ^}|D]<}| d¡rt| ¡ ¡dƒ}|a|WdƒSqtd|ƒ‚Wdƒn1sv0YdS)zAReturn the system boot time expressed in seconds since the epoch.rŒsbtimerNzline 'btime' not found in %s)r rr³rÖr›r{Ú BOOT_TIMEr1)r`r–rÂr°r?r?r@Ú boot_timeÓs   ÿr–cCsdd„t ttƒƒ¡DƒS)z7Returns a list of PIDs currently running on the system.cSsg|]}| ¡rt|ƒ‘qSr?)rˆr¾rµr?r?r@r·èr¸zpids..)ryrrr r?r?r?r@ræsrc Csºt |¡sdSz†dtƒ|f}t|ƒ\}|D]:}| d¡r,t| ¡dƒ}||kWdƒWSq,td|ƒ‚Wdƒn1sˆ0YWn ttfy´|t ƒvYS0dS)zcCheck for the existence of a unix PID. Linux TIDs are not supported (always return False). Fú %s/%s/statussTgid:rNz'Tgid' line not found in %s) rÚ pid_existsr rr³r¾r{ràÚEnvironmentErrorr)r¬r`r–rÂZtgidr?r?r@r˜ës    .r˜c Cs i}tƒ}tƒD]Š}z.wrapper)Ú functoolsÚwraps)r¥r¦r?r¤r@Úwrap_exceptions!s r©c@sneZdZdZgd¢Zdd„Zdd„Zeedd„ƒƒZ eed d „ƒƒZ eed d „ƒƒZ d d„Z dd„Z edd„ƒZdd„Zedd„ƒZedd„ƒZedd„ƒZej de ¡¡r¼edd„ƒZedd„ƒZed d!„ƒZed\d#d$„ƒZed%d&„ƒZed'd(„ƒZer(ee d)¡e d*¡e d+¡fd,d-„ƒZ neZ er>ed.d/„ƒZ!ed0d1„ƒZ"ee d2¡fd3d4„ƒZ#ee d5¡fd6d7„ƒZ$ed8d9„ƒZ%ed:d;„ƒZ&edd?„ƒZ)e d@¡fdAdB„Z*edCdD„ƒZ+e,rèedEdF„ƒZ-edGdH„ƒZ.e/d"ured]dIdJ„ƒZ0edKdL„ƒZ1edMdN„ƒZ2ed^dPdQ„ƒZ3edRdS„ƒZ4edTdU„ƒZ5ee dV¡fdWdX„ƒZ6ee dY¡fdZd[„ƒZ7d"S)_ÚProcesszLinux process implementation.)r¬r¡Ú_ppidrÚ_cachecCs||_d|_d|_tƒ|_dSr)r¬r¡r«r r)rr¬r?r?r@r;szProcess.__init__cCst d|j|jf¡dS)z+Raise NSP if the process disappeared on us.r N)ryrarr¬©rr?r?r@Ú _assert_aliveAszProcess._assert_alivecCsøtd|j|jfƒ}| ¡}Wdƒn1s20Y| d¡}|| d¡d|…}||dd… ¡}i}||d<|d|d <|d|d <|d |d <|d |d<|d|d<|d|d<|d|d<|d|d<|d|d<|d|d<|S)aZParse /proc/{pid}/stat file and return a dict with various process info. Using "man proc" as a reference: where "man proc" refers to position N always substract 3 (e.g ppid position 4 in 'man proc' == position 1 in here). The return value is cached in case oneshot() ctx manager is in use. ršNr›ó(rr:rŠrr:ržr#Úttynré Úutimeé Ústimeé Úchildren_utimerUÚchildren_stimeéÚ create_timeé$Úcpu_numé'Ú blkio_ticks)rrr¬ršrIÚfindr{)rr–rœrrŠr˜r°r?r?r@Ú_parse_stat_fileGs$ &           zProcess._parse_stat_filecCs@td|j|jfƒ}| ¡WdƒS1s20YdS)zRead /proc/{pid}/stat file and return its content. The return value is cached in case oneshot() ctx manager is in use. r—N)rrr¬rš©rr–r?r?r@Ú_read_status_filejszProcess._read_status_filecCsHtd|j|jftd}| ¡ ¡WdƒS1s:0YdS)Nz %s/%s/smapsr,)rrr¬r/ršr›rÀr?r?r@Ú_read_smaps_filets ÿzProcess._read_smaps_filecCs(|j |¡|j |¡|j |¡dSr)r¿Zcache_activaterÁrÂr­r?r?r@Ú oneshot_enter{s  zProcess.oneshot_entercCs(|j |¡|j |¡|j |¡dSr)r¿Zcache_deactivaterÁrÂr­r?r?r@Ú oneshot_exit€s  zProcess.oneshot_exitcCs| ¡d}trt|ƒ}|S)NrŠ)r¿r!r )rrŠr?r?r@rŠ…s z Process.namec Csšztd|j|jfƒWSttfyvtj d|j|jf¡rFYdSt|jƒs`t |j|j ƒ‚nt |j|j |j ƒ‚Yn t y”t|j|j ƒ‚Yn0dS)Nz %s/%s/exer r=)rzrr¬rr ryr`Úlexistsr˜rr¡rr«rr r­r?r?r@Úexes  z Process.execCs td|j|jfƒ}| ¡}Wdƒn1s20Y|sDgS| d¡rRdnd}| |¡rl|dd…}| |¡}|dkrœt|ƒdkrœd|vrœ| d¡}|S)Nz %s/%s/cmdlinerurmr6r)rrr¬ršr|r{r“)rr–rœÚsepÚcmdliner?r?r@rÈžs&    zProcess.cmdlinecCsDtd|j|jfƒ}| ¡}Wdƒn1s20Yt|ƒS)Nz %s/%s/environ)rrr¬ršr)rr–rœr?r?r@Úenviron·s&zProcess.environcCs<t| ¡dƒ}t ¡}z ||WSty6YdS0dS)Nr°)r¾r¿rZget_terminal_mapr½)rZtty_nrrr?r?r@Úterminal½s   zProcess.terminalz /proc/%s/ioc Csd|j|jf}i}t|ƒ\}|D]F}| ¡}|r"z| d¡\}}WntyZYq"Yq"0t|ƒ||<q"Wdƒn1s~0Y|s˜td|ƒ‚z,t|d|d|d|d|d|d ƒWSt y}z"td |d ||fƒ‚WYd}~n d}~00dS) Nz%s/%s/ios: z%s file was emptyssyscrssyscws read_bytess write_bytessrcharswcharz1%r field was not found in %s; found fields are %rr) rr¬rr›r{ràr¾r1rnr½)rrŸr˜r–rÂrŠròrÓr?r?r@Ú io_countersÈs4   , ú ÿzProcess.io_counterscCsh| ¡}t|dƒt}t|dƒt}t|dƒt}t|dƒt}t|dƒt}t|||||ƒS)Nr²r´r¶r·r½)r¿rÖr×ro)rr—r²r´r¶r·rtr?r?r@rÙçszProcess.cpu_timescCst| ¡dƒS)zWhat CPU the process is on.r»©r¾r¿r­r?r?r@r»ñszProcess.cpu_numNcCst |j||j¡Sr)rZwait_pidr¬r¡)rÚtimeoutr?r?r@Úwaitösz Process.waitcCs&t| ¡dƒ}tptƒ}|t|S)Nr¹)rÖr¿r•r–r×)rÚctimeZbtr?r?r@r¹ús zProcess.create_timec Csttd|j|jfƒ<}dd„| ¡ ¡dd…Dƒ\}}}}}}}Wdƒn1sV0Yt|||||||ƒS)Nz %s/%s/statmcSsg|]}t|ƒt‘qSr?)r¾r¿rµr?r?r@r·r¸z'Process.memory_info..r<)rrr¬r’r{rd) rr–ZvmsrjrWÚtextÚlibrœZdirtyr?r?r@Ú memory_infos ÿ.zProcess.memory_infos\nPrivate.*:\s+(\d+)s\nPss\:\s+(\d+)s\nSwap\:\s+(\d+)c Csj| ¡}| ¡}ttt| |¡ƒƒd}ttt| |¡ƒƒd}ttt| |¡ƒƒd}t||||fŽS)NrÆ)rÒrÂrírJr¾Úfindallre) rZ _private_reZ_pss_reZ_swap_reZ basic_memZ smaps_datarfrgrhr?r?r@Úmemory_full_infos  zProcess.memory_full_infocCsRdd„}| ¡}|sgS| d¡}g}| d¡}|g}|||ƒD] \}}| dd¡}z|\} } } } } }Wn(ty’|dg\} } } } } }Yn0|sžd}n2trªt|ƒ}| ¡}| d ¡rÐt|ƒsÐ|dd …}|  t| ƒt| ƒ||  d d¡|  d d¡|  d d¡|  dd¡|  dd¡|  dd¡|  dd¡|  dd¡|  dd¡|  dd¡f ¡q@|S)aPReturn process's mapped memory regions as a list of named tuples. Fields are explained in 'man proc'; here is an updated (Apr 2012) version: http://goo.gl/fmebo /proc/{PID}/smaps does not exist on kernels < 2.6.14 or if CONFIG_MMU kernel configuration option is not enabled. c ss¤i}|D]ˆ}| dd¡}|d d¡s@| ¡|fV| |¡qzt|dƒd||d<WqtyŽ|d d¡r~Yqn td|ƒ‚Yq0q| ¡|fVdS)NérrþrrÆsVmFlags:z#don't know how to interpret line %r)r{r|Úpopr”r¾ràr³)rKÚ current_blockrœrÂr˜r?r?r@Ú get_blocksEs   ÿz'Process.memory_maps..get_blocksó rNrÕr=z[anon]rvrwsRss:sSize:sPss:s Shared_Clean:s Shared_Dirty:sPrivate_Clean:sPrivate_Dirty:s Referenced:s Anonymous:sSwap:) rÂr{rÖràr!r r›r|rr”r¼)rrØrœrKrîZ first_liner×ÚheaderZhfieldsr'ZpermsÚoffsetÚdevrr`r?r?r@Ú memory_maps<sL     ÿ ÿ           õ zProcess.memory_mapsc Cs^ztd|j|jfƒWSttfyXt|jƒsBt|j|jƒ‚nt|j|j|j ƒ‚Yn0dS)Nz %s/%s/cwd) rzrr¬rr r˜rr¡rr«r­r?r?r@Úcwd€s  z Process.cwdsctxt_switches:\t(\d+)cCsL| ¡}| |¡}|s,td|j|jfƒ‚nt t|dƒt|dƒ¡SdS)Nzˆ'voluntary_ctxt_switches' and 'nonvoluntary_ctxt_switches'lines were not found in %s/%s/status; the kernel is probably older than 2.6.23rr)rÁrÓrúrr¬rZpctxswr¾)rZ _ctxsw_rerœZctxswr?r?r@Únum_ctx_switches‹s ÿþÿzProcess.num_ctx_switchessThreads:\t(\d+)cCs| ¡}t| |¡dƒS©Nr)rÁr¾rÓ)rZ_num_threads_rerœr?r?r@Ú num_threads™szProcess.num_threadsc Cst d|j|jf¡}| ¡g}d}|D]Æ}d|j|j|f}z8t|ƒ}| ¡ ¡}Wdƒn1sl0YWnty’d}Yq*Yn0||  d¡dd…}|  d¡}t |dƒt } t |d ƒt } t  t|ƒ| | ¡} | | ¡q*|rþ| ¡|S) Nz %s/%s/taskFz%s/%s/task/%s/statTr›r:rÏr±r³)ryrrr¬Úsortrršr›rr¾r{rÖr×rZpthreadr¾r”r®) rZ thread_idsroÚ hit_enoentZ thread_idrŸr–Ústr—r²r´rqr?r?r@Úthreads¡s. ÿ .    zProcess.threadscCs t |j¡Sr)rPÚ getpriorityr¬r­r?r?r@Únice_get½szProcess.nice_getcCst |j|¡Sr)rPÚ setpriorityr¬)rròr?r?r@Únice_setÆszProcess.nice_setcCs t |j¡Sr)rÐr4r¬r­r?r?r@Úcpu_affinity_getÍszProcess.cpu_affinity_getsCpus_allowed_list:\t(\d+)-(\d+)cCsV| ¡}| |¡}|r@ttt|ddƒt|ddƒdƒƒSttttƒƒƒƒSdS)Nrr)rÁrÓrrùr¾r“rÜ)rÚ_rerœrär?r?r@Ú_get_eligible_cpusÑs  *zProcess._get_eligible_cpusc Cs¬zt |j|¡Wn”ttfy¦}zxt|tƒs<|jtjkr| ¡}t t t t ƒƒƒƒ}|D]4}||vrvtd||fƒ‚||vrZtd||fƒ‚qZ‚WYd}~n d}~00dS)Nz(invalid CPU number %r; choose between %sz0CPU number %r is not eligible; choose between %s) rÐZproc_cpu_affinity_setr¬rràrxr²rrìÚtuplerùr“rÜ)rrÚrÓZ eligible_cpusZall_cpusZcpur?r?r@Úcpu_affinity_setÛs(ÿÿÿÿzProcess.cpu_affinity_setcCs,t |j¡\}}tdur t|ƒ}t ||¡Sr)rÐr3r¬Úenumr;rZpionice©rZioclassròr?r?r@Ú ionice_getñszProcess.ionice_getcCsP|dur d}|r(|ttfvr(td|ƒ‚|dks8|dkr@tdƒ‚t |j||¡S)Nrz%r ioclass accepts no valuer<zvalue not in 0-7 range)r'r$ràrÐZproc_ioprio_setr¬rðr?r?r@Ú ionice_setøs zProcess.ionice_setc Cs¬|jdkrtdƒ‚zD|dur*t|j|ƒWSt|ƒdkrFtdt|ƒƒ‚t|j||ƒWnPty¦}z8|jtjkrt|jƒrt |j|j |j ƒ‚n‚WYd}~n d}~00dS)Nrz)can't use prlimit() against PID 0 processr:z4second argument must be a (soft, hard) tuple, got %s) r¬ràr¥r“rArr²ZENOSYSr˜rr¡r«)rr­r®rÓr?r?r@Úrlimits   ÿÿzProcess.rlimitcCs$| ¡d}tr| ¡}t |d¡S)Nr:ú?)r¿r!r Ú PROC_STATUSESr¼)rZletterr?r?r@r:s zProcess.statusc Csvg}t d|j|jf¡}d}|D]>}d|j|j|f}z t|ƒ}WnZttfydd}Yq"Yq"ty }z&|jtj krŠWYd}~q"‚WYd}~q"d}~00|  d¡r"t |ƒr"d|j|j|f}zXt |ƒ:}t | ¡ ¡dƒ} t | ¡ ¡ddƒ} Wdƒn1s0YWnty6d}Yq"0t| ƒ} t|t |ƒt | ƒ| | ƒ} | | ¡q"|rr| ¡|S) NrFrTr†z%s/%s/fdinfo/%srrŽ)ryrrr¬rzrr rr²rr³rrr¾r’r{r…r_r”r®) rrorfrãrar4r`rÓr–Úposrcrbrqr?r?r@Ú open_files&s@     ÿ : ÿ zProcess.open_filesr cCst ||j¡}| ¡|Sr)rFrCr¬r®)rrBr°r?r?r@Ú connectionsRszProcess.connectionscCstt d|j|jf¡ƒS)Nr)r“ryrrr¬r­r?r?r@Únum_fdsXszProcess.num_fdscCst| ¡dƒS)NržrÌr­r?r?r@rž\sz Process.ppidsUid:\t(\d+)\t(\d+)\t(\d+)cCs6| ¡}| |¡d\}}}t t|ƒt|ƒt|ƒ¡Srà)rÁrÓrZpuidsr¾)rZ_uids_rerœÚrealÚ effectiveÚsavedr?r?r@Úuids`sz Process.uidssGid:\t(\d+)\t(\d+)\t(\d+)cCs6| ¡}| |¡d\}}}t t|ƒt|ƒt|ƒ¡Srà)rÁrÓrZpgidsr¾)rZ_gids_rerœrúrûrür?r?r@Úgidsfsz Process.gids)N)N)r )8r<r=r>rDÚ __slots__rr®r©rr¿rÁrÂrÃrÄrŠrÆrÈrÉrÊryr`rõÚgetpidrËrÙr»rÎr¹rÒÚ HAS_SMAPSrârãrÔrÝrÞrßrárårçréÚHAS_CPU_AFFINITYrêrìrîÚHAS_PROC_IO_PRIORITYrñròr¥rór:r÷rørùržrýrþr?r?r?r@rª6s² !            û C ÿ     ÿ       +   rª)N)r )F)F)¤rDZ __future__rr#r{r²r§rëryrâr r$ÚsysÚ tracebackrÊrrr=rrrrÐr rPr r r r rrrrrrrrrrrrrrZ_compatrrrrr r!Ú version_inforïZ__extra__all__rŽr`rõrrÚhasattrrrrržrßr×Z getpagesizer¿r•r/Ú byteorderr"rhZ AF_PACKETr9ÚIntEnumr¾r8r$r%r&r'r;ÚglobalsrÚ __members__ZSTATUS_RUNNINGZSTATUS_SLEEPINGZSTATUS_DISK_SLEEPZSTATUS_STOPPEDZSTATUS_TRACING_STOPZ STATUS_ZOMBIEZ STATUS_DEADZSTATUS_WAKE_KILLZ STATUS_WAKINGZ STATUS_IDLEZ STATUS_PARKEDrõr(r)r*r+r,r-r.r/r0r1r2r2rMrYr_rdrØrerirÉrlrnrorzr…r‹r™r¢Ú ExceptionÚ print_excr‘r¥ÚresourceÚ ImportErrorr¨ZCDLLrªr|ÚdirrÄrÎrÔrÙrÜrçrórôrýZ net_if_addrsrÿrrFrGrNrRÚ disk_usagerjrnr†r‡rr‘r–rr˜rŸr©rªr?r?r?r@Úsb                                       ÿ ôõÿÿÿ þÿÿ       ÿ 4z:* ÿ   k % _ +q ^