Directory:~$ /lib/python2.7/site-packages/iotop/

Upload File

[Home] [System Details] [Kill Me]

�
���[c@
sdd
lm
Z

ddlZddlZddlZddlZddlZddlZddlZddl	Z	ej
jd�
Zyddl
mZ
e�ZWn



eZnXeZes�er

ed�

ed�

es�ed�

nes�ed�

nejd	�

ndd
lmZmZ
ddlmZmZmZmZ
ddlmZmZ
d
e
f
d��YZ!de!f
d��YZ"d	Z#d	Z$dZ%d	Z&dZ'de
f
d��YZ(d�Z)d�Z*d�Z+de!f
d��YZ,de!f
d��YZ-de!f
d��YZ.dS(i����(
tprint_functionNs
/proc/self/io(
tVmStats<Could
not run iotop as some of the requirements are not met:s- Linux >=
2.6.20 withs`  - I/O accounting support (CONFIG_TASKSTATS,
CONFIG_TASK_DELAY_ACCT, CONFIG_TASK_IO_ACCOUNTING)s0  - VM event counters
(CONFIG_VM_EVENT_COUNTERS)i
(tiopriotvmstat(t
ConnectiontNETLINK_GENERICtU32Attrt
NLM_F_REQUEST(t
ControllertGeNlMessagetDumpableObjectc
B
seZ
dZd
�ZRS(sFBase class
for all objects that allows easy introspection when
printedc

C
s*d
tt
|�
�
d tj|j�
fS(Ns%s:
%s>i����(tstrttypetpprinttpformatt__dict__(
tself((s./usr/lib/python2.7/site-packages/iotop/data.pyt__repr__?s
(t__name__t
__module__t__doc__R(((s./usr/lib/python2.7/site-packages/iotop/data.pyR
=s

tStatscB
sYeZ
dddddgZeZd
�Zdd�
Zd
�Zd�Ze	d��
Z
RS(tblkio_delay_totali(tswapin_delay_totali8t
read_bytesi�twrite_bytesi
tcancelled_write_bytesi
cC
sp|j}xBt
jD]7\}}|
||d
!}tjd|�d||<qWt
jsl|jdkt
_ndS(Nit
Qi(RRtmembers_offsetststructtunpackthas_blkio_delay_totalR(Rttask_stats_buffertsdtnametoffsettdata((s./usr/lib/python2.7/site-packages/iotop/data.pyt__init__Rs
	


	
i
c	C
sS|j}|j}|
j}x1t
jD]&\}}|||||||<q%Wd
S(s3Update
destination from operator(self,
other_stats)N(RRR(	Rtother_statstdestinationtcoefftddR!todtmemberR#((s./usr/lib/python2.7/site-packages/iotop/data.pyt
accumulate]s
	
	
	

cC
s|j|
|d
d�
S(s*Update destination with self -
other_statsR(i����(
R,(RR&R'((s./usr/lib/python2.7/site-packages/iotop/data.pytdeltaesc
C
s;|j}
x+t
jD]
\}}|
|d
krtSqWtS(Ni(RRRtFalsetTrue(RR!R"R#((s./usr/lib/python2.7/site-packages/iotop/data.pytis_all_zerois

	



cC
s@tj
t�
}|j}
x!tjD]\}}d
|
|<q"W|S(Ni(Rt__new__RR(tstatststdR"R#((s./usr/lib/python2.7/site-packages/iotop/data.pytbuild_all_zerops

	


(sblkio_delay_totali((sswapin_delay_totali8(s
read_bytesi�(swrite_bytesi
(Ri
(RRRR.RR%R,R-R0tstaticmethodR4(((s./usr/lib/python2.7/site-packages/iotop/data.pyRGs



				iitTaskStatsNetlinkc
B
s#eZ
d�Zd
�Zd�ZRS(cC
s=|
|_t
t�
|_t|j�
}|jd
�
|_dS(Nt	TASKSTATS(toptionsRRt
connectionRt
get_family_idt	family_id(RR8t
controller((s./usr/lib/python2.7/site-packages/iotop/data.pyR%�s
	


cC
s+t|j
d
tdtt|
�g
dt�
S(Ntcmdtattrstflags(R	R;tTASKSTATS_CMD_GETRtTASKSTATS_CMD_ATTR_PIDR(Rttid((s./usr/lib/python2.7/site-packages/iotop/data.pyt
build_request�s


cC
s�|
jj
|j�

ytj|j�
}Wn,tk
rW
}
|jtjkrQdS�n
Xx=|jj	�D](\}}|t
krh|j�}PqhqhWdS|tj
}t|�
d
kr�dStjd|d
�d}t|�
S(Ni
t
Hii(ttask_stats_requesttsendR9R	trecvtOSErrorterrnotESRCHR>titemstTASKSTATS_TYPE_AGGR_PIDtnestedtTASKSTATS_TYPE_STATSR$tlenRRR(Rtthreadtreplyt
et	attr_typet
attr_valuettaskstats_datattaskstats_version((s./usr/lib/python2.7/site-packages/iotop/data.pytget_single_task_stats�s"













(RRR%RCRW(((s./usr/lib/python2.7/site-packages/iotop/data.pyR6�s		c
C
s�g|_t
}
x�|jpgD]�}yt|�
}Wn]tk
r�


ytj|�
}Wn-tk
r�


td
|dt	j
�

t}
q�X|j}n
X|
s|jj
|�

qqW|
r�t	jd�

ndS(sDBuild
options.uids from options.users by resolving usernames to UIDss
Unknown
user:tfilei
N(tuidsR.tuserstintt
ValueErrortpwdtgetpwnamtKeyErrortprinttsyststderrR/tpw_uidtappendtexit(R8terrort
utuidtpasswd((s./usr/lib/python2.7/site-packages/iotop/data.pyt	find_uids�s
	

















c
C
s�i}
ybx[td
|�
D]I}y|j
dd�\}}Wntk
rR


qn
X|j�|
|<qWWntk
r{


n
X|
S(Ns/proc/%d/statust
:i
(topentsplitR\tstriptIOError(tpidtresult_dicttlinetkeytvalue((s./usr/lib/python2.7/site-packages/iotop/data.pytparse_proc_pid_status�s











c

C
sDy|jd
�
SWn,t
k
r.


|jd�
Stk
r?


|SXdS(Nsutf-8t
string_escape(tdecodetUnicodeDecodeErrortencodetAttributeError(
t
s((s./usr/lib/python2.7/site-packages/iotop/data.pytsafe_utf8_decode�s








t
ThreadInfoc
B
s2eZ
dZd
�Zd�Zd�Zd�ZRS(sStats for a single
threadcC
sC|
|_t
|_d|_tjt�
|_|j|
�
|_	dS(
N(
RBR/tmarktNonetstats_totalRR1tstats_deltaRCRE(RRBttaskstats_connection((s./usr/lib/python2.7/site-packages/iotop/data.pyR%�s

	
	
	

c

C
stj
|j�
S(
N(RtgetRB(
R((s./usr/lib/python2.7/site-packages/iotop/data.pyt
get_ioprio�s
cC
stj
tj|j|
|�S(
N(Rt
set_iopriotIOPRIO_WHO_PROCESSRB(Rtioprio_classtioprio_data((s./usr/lib/python2.7/site-packages/iotop/data.pyR��s

cC
s8|js|
|_n|
j
|j|j�
|
|_dS(
N(R�R-R�(RR2((s./usr/lib/python2.7/site-packages/iotop/data.pytupdate_stats�s
	


(RRRR%R�R�R�(((s./usr/lib/python2.7/site-packages/iotop/data.pyR}�s


			tProcessInfoc
B
sqeZ
dZd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
RS(s�Stats for a single process (a single line in the
output): if
    options.processes is set, it is a collection of threads, otherwise a
single
    thread.cC
sU|
|_d|_d|_i|_tj�|_tj�|_t	j	�|_
dS(
N(RpRRhtusertthreadsRR4R�tstats_accumttimetstats_accum_timestamp(RRp((s./usr/lib/python2.7/site-packages/iotop/data.pyR%�s
	
	
	
	


cC
sO|
jr)|
j
r)|j|
jkr)tS|
jrK|j�|
jkrKtStS(
N(tpidst	processesRpR.RYtget_uidR/(RR8((s./usr/lib/python2.7/site-packages/iotop/data.pytis_monitored�s

c
C
ss|jr|jSy!t
jd
|j�
tj}
Wntk
rJ


d}
n
X|
|jkrod|_|
|_n|
S(Ns/proc/%d(RhtoststatRptST_UIDRHRR�(RRh((s./usr/lib/python2.7/site-packages/iotop/data.pyR�	
s
	

!



	

c
C
sz|j�}
|
dk	rm|jrmyttj|
�
j�
|_Wqmttfk
ri


t	|
�
|_qmXn|jpyd
S(Ns{none}(
R�RR�R|R]tgetpwuidtpw_nameR_RzR(RRh((s./usr/lib/python2.7/site-packages/iotop/data.pytget_user
s






c
C
sj
y&td
|j
�
}
|
jd�
}Wntk
r:


dSXt|j
�
}|s|jdd�}|rud|}nd}|Sd}t|jd|j
��
}||j
kr�t|�
jdd�}|jdd�}||kr�|d	|7}q�n|jd
�
}	|	djd�
rG
|	dj	d�
d
}
|	d|
|	d<ndj
|	�
j�}t||�
S(Ns/proc/%d/cmdlineis{no such
process}tNamets[%s]s	{no name}tTgids [%s]t
it
/i
t

(
RlRptreadRoRuR�R[Rmt
startswithtrfindtjoinRnR|(Rtproc_cmdlinetcmdlinetproc_statustproc_status_nametsuffixttgidt	tgid_nametthread_nametpartstfirst_command_char((s./usr/lib/python2.7/site-packages/iotop/data.pytget_cmdline#
s2






















cC
sE|
r|jj
�Sx*|jj�D]}|jj
�s$tSq$WtS(
N(R�R0R�tvaluesR�R/R.(Rtaccumulatedt
t((s./usr/lib/python2.7/site-packages/iotop/data.pytdid_some_ioB
s





c
C
s?td
�|j
j�D�
�
}
t|
�
dkr;|
j�SdS(Nc
s
s|]}
|
j�V
qdS(
N(
R�(t.0R�((s./usr/lib/python2.7/site-packages/iotop/data.pys	<genexpr>K
si
s?dif(tsetR�R�ROtpop(Rt
priorities((s./usr/lib/python2.7/site-packages/iotop/data.pyR�J
s




cC
s.x'|jj
�D]}|j|
|�
qWdS(
N(R�R�R�(RR�R�RP((s./usr/lib/python2.7/site-packages/iotop/data.pyR�P
s

c

C
stj
|j��
S(
N(Rtsort_keyR�(
R((s./usr/lib/python2.7/site-packages/iotop/data.pytioprio_sort_keyT
s
cC
s>|jj
|
d�}|s:t|
|�}||j|
<n|S(
N(R�R�RR}(RRBR�RP((s./usr/lib/python2.7/site-packages/iotop/data.pyt
get_threadW
s





c
C
s�tj
�}
x<|jj�D]+\}}|js|
j|j|
�
qqWtg|jj�D]!\}}|js^||f^q^�
|_t|j�
}|s�t	S|
j
|:_
|
j|:_|
|_|jj|j|j�
t
S(
N(RR4R�RKR~R,R�tdictROR.RRR�R/(RR�RBRPt
nr_threads((s./usr/lib/python2.7/site-packages/iotop/data.pyR�^
s


	


:


	
(RRRR%R�R�R�R�R�R�R�R�R�R�(((s./usr/lib/python2.7/site-packages/iotop/data.pyR��s
												tProcessListc
B
sGeZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�ZRS(cC
sGi|_|
|_
||_tj�|_tj�|_|j�
dS(
N(R�R�R8R�t	timestampRR
tupdate_process_counts(RR�R8((s./usr/lib/python2.7/site-packages/iotop/data.pyR%s
s	
	
	

cC
sQ|jj
|
d
�}|s7t|
�
}||j|
<n|j|j�
rM|Sd
S(syEither
get the specified PID from self.processes or build a new
        ProcessInfo if we see this PID for the first
timeN(R�R�RR�R�R8(RRptprocess((s./usr/lib/python2.7/site-packages/iotop/data.pytget_process~
s



c
C
s�|jj
r|jj
Stjd
�
}
|jjrng|
D]2}d|dk
oYdk
n
r8t|�
^q8Sg}xp|
D]h}d|dk
o�dk
n
r{y+|jtttjd|d�
��

Wq�tk
r�


q�Xq{q{W|S(Ns/proct
0it
9s/proc/s/task(	R8R�R�tlistdirR�R[textendtmapRH(RttgidsR�ttids((s./usr/lib/python2.7/site-packages/iotop/data.pyt
list_tgids�
s




=





+


cC
s�|jj
s|
g
Sy&ttttjd
|
�
��
}Wntk
rM


gSX|jjr�tt	|jj�
j
t	|�
�
�
}n|S(Ns
/proc/%d/task(R8R�tlistR�R[R�R�RHR�R�tintersection(RR�R�((s./usr/lib/python2.7/site-packages/iotop/data.pyt	list_tids�
s


&



*c

C
s�tj�}
|
|j
|_|
|_
d
}}x�|j�D]�}|j|�
}|s]q<nx�|j|�
D]o}|j||j�}|jj|�
}|rm|j	|�

|j
}	||	j7}||	j7}t
|_qmqmWq<W||f|jj�fS(Ni(R�R�tdurationR�R�R�R�R�RWR�R�RRR.R~RR-(
Rt
new_timestampt
total_readttotal_writeR�R�RBRPR2R-((s./usr/lib/python2.7/site-packages/iotop/data.pyR��
s$


	










	





c
C
s�x:|jj
�D])}
x
|
jj
�D]}t|_q&WqW|j�}tg|jj�D]$\}}
|
j�r\||
f^q\�
|_|S(
N(	R�R�R�R/R~R�R�RKR�(RR�RPttotal_read_and_writeRp((s./usr/lib/python2.7/site-packages/iotop/data.pytrefresh_processes�
s




$c

C
s
i|_dS(
N(
R�(
R((s./usr/lib/python2.7/site-packages/iotop/data.pytclear�
s
(	RRR%R�R�R�R�R�R�(((s./usr/lib/python2.7/site-packages/iotop/data.pyR�r
s
						
(/t
__future__RRIR�R
R]R�RRaR�tpathtexiststioaccountingtiotop.vmstatR
tvmstat_fR.tvm_event_countersR/R`RetiotopRRt
iotop.netlinkRRRRtiotop.genetlinkRR	tobjectR
RR@RARLtTASKSTATS_TYPE_PIDRNR6RjRuR|R}R�R�(((s./usr/lib/python2.7/site-packages/iotop/data.pyt<module>sP























"

5



)			�