a

\��h*�@s:dd
lZdd
l
Z
ddlmZmZmZ
Gdd�dee�Zd
S)�N)�Plugin�IndependentPlugin�	PluginOptc
@sleZ
dZd
ZdZdZedddd�edd	d
d�edd	dd�ed
dedd�eddedd�gZdd�Z	dd�Z
dS)�Processzprocess informationZprocess)
�system�lsofTzcollect info on all open files)�default�desc�lsof-threadsFz,collect threads' open file info if supported�smapszcollect /proc/*/smaps files�samples�z"number of iotop samples to collect)rZval_typer	�numprocsiz*number of process to collect /proc data ofc

Csv
d
}
d}d}|d7}|�gd�
�

dd�|�
d�
D�
}|�d	�
rR|d|�d	�
�}|D]@}|�d
|�d�d
|�d�d
|�d
�d
|�d�d
|�d�g�

qV|�d�
r�|�d�

|jddgd�
dd�
|jddd�
|�d�
r�|jdddddd�
|�d�
�
r
|jd ddd!�
|jgd"�
d#d$�
|�|
�d%|��|
�d%|��g�

|�d&�
�
rd|jd'|�d&�
��d(d)�
|�d*d+g�

dS),Nzps axoz3pid,ppid,user,group,lwp,nlwp,start_time,comm,cgroupz3flags,state,uid,pid,ppid,pgid,sid,cls,pri,psr,addr,zsz,wchan:20,lstart,tty,time,cmd)z/proc/sched_debugz
/proc/statz/sys/kernel/debug/sched/debugz /sys/kernel/debug/sched/featuresz/sys/kernel/sched_ext/c
Ssg|]}
t�
d|
�r|
�qS)
z[0-9])�re�match)�.0�
p�r�>/usr/lib/python3.9/site-packages/sos/report/plugins/process.py�
<listcomp>0�z!Process.setup.<locals>.<listcomp>z/procrz/proc/z/statusz/cpusetz/oom_*z/stackz/limitsrz/proc/[0-9]*/smapsz
ps auxwwwmZps)Zps_auxZps_auxwwZ	ps_auxwwwZ
ps_auxwwwmZ	ps_auxcww�
)�root_symlink�tags�priorityz
pstree -lpZpstree)
rrzlsof +M -n -l -c ''��2)r�timeoutrrr
z
lsof +M -n -l)rr)z	ps alxwwwz
ps auxfwwwzps -elfLT)
Z
cmd_as_tag�
 rziotop -b -o -d 0.5 -t -n �d)
rz#pidstat -p ALL -rudvwsRU --human -hzpidstat -tl)Z
add_copy_spec�listdirZ
get_optionZadd_cmd_output)�selfZps_axoZ
ps_group_optsZ
ps_sched_optsZprocs�procrrr�setup!s\
















�



�



�

�

�

��

�z
Process.setupc
Cs
|�d
�
��}
|j
jjs0|
�d�

Wd�
dS|�d�
}i}i}|ddksr|
�d|d���

Wd�
dS|d��D]X}|����}|d}|d}|�	|�
s�q~||v
r�|j
j�
|�
||<|||d	�||<q~|
�tj|dd
��

Wd�
n1�
s0


Y
dS)Nzpids_to_packages.jsonz/Package manager not configured for path querieszps --no-headers aex�statusr
zUnable to get process list: �output�)�path�package)
�indent)
Zcollection_fileZpolicyZpackage_managerZquery_path_command�writeZexec_cmd�
splitlines�strip�splitZpath_existsZpkg_by_path�json�dumps)r!ZpfileZ_psZpidpkg�pathsr"�pidr'rrr�collectbs(






















zProcess.collectN)�__name__�
__module__�__qualname__Z
short_descZplugin_nameZprofilesr�intZoption_listr#r2rrrrrs"


�

�
��Ar)r.rZsos.report.pluginsrrrrrrrr�<module>	s