Web   ·   Wiki   ·   Activities   ·   Blog   ·   Lists   ·   Chat   ·   Meeting   ·   Bugs   ·   Git   ·   Translate   ·   Archive   ·   People   ·   Donate
summaryrefslogtreecommitdiffstats
path: root/services
diff options
context:
space:
mode:
authorEduardo Silva <edsiper@monotop.(none)>2007-08-07 21:56:14 (GMT)
committer Eduardo Silva <edsiper@monotop.(none)>2007-08-07 21:56:14 (GMT)
commitcc745f990ff2d53eb3e448353d0b013eeb929b1a (patch)
tree6f671ac2843a5fd8c58797562db56efb1534bc62 /services
parent2485e15030d2ae8b61272dbc16081e5e4f9c3e40 (diff)
DevConsole: Fix broken procfs parser
Diffstat (limited to 'services')
-rw-r--r--services/console/interface/memphis/plugins/memphis_init/info.py1
-rw-r--r--services/console/lib/procmem/proc.py47
-rw-r--r--services/console/lib/procmem/proc_smaps.py4
3 files changed, 32 insertions, 20 deletions
diff --git a/services/console/interface/memphis/plugins/memphis_init/info.py b/services/console/interface/memphis/plugins/memphis_init/info.py
index 6e524c7..667645c 100644
--- a/services/console/interface/memphis/plugins/memphis_init/info.py
+++ b/services/console/interface/memphis/plugins/memphis_init/info.py
@@ -11,3 +11,4 @@ def plg_on_top_data_refresh(self, ppinfo):
data = [ppinfo['pid'], ppinfo['name'], ppinfo['state_name']]
return data
+
diff --git a/services/console/lib/procmem/proc.py b/services/console/lib/procmem/proc.py
index adc2f6b..d50242b 100644
--- a/services/console/lib/procmem/proc.py
+++ b/services/console/lib/procmem/proc.py
@@ -1,4 +1,6 @@
-import sys, os
+import os
+import re
+import sys
import string
class ProcInfo:
@@ -36,10 +38,12 @@ class ProcInfo:
return None
# Parsing data , check 'man 5 proc' for details
- data = infile.read().split()
-
+ stat_data = infile.read()
infile.close()
-
+
+ process_name = self._get_process_name(stat_data)
+ data = self._get_safe_split(stat_data)
+
state_dic = {
'R': 'Running',
'S': 'Sleeping',
@@ -48,27 +52,34 @@ class ProcInfo:
'T': 'Traced/Stopped',
'W': 'Paging'
}
-
+
# user and group owners
pidstat = os.stat(pidfile)
-
info = {
- 'pid': int(data[0]), # Process ID
- 'name': data[1].strip('()'), # Process name
- 'state': data[2], # Process State, ex: R|S|D|Z|T|W
- 'state_name': state_dic[data[2]], # Process State name, ex: Running, sleeping, Zombie, etc
- 'ppid': int(data[3]), # Parent process ID
- 'utime': int(data[13]), # Used jiffies in user mode
- 'stime': int(data[14]), # Used jiffies in kernel mode
- 'start_time': int(data[21]), # Process time from system boot (jiffies)
- 'vsize': int(data[22]), # Virtual memory size used (bytes)
- 'rss': int(data[23])*4, # Resident Set Size (bytes)
+ 'pid': int(data[0]), # Process ID
+ 'name': process_name,
+ 'state': data[2], # Process State, ex: R|S|D|Z|T|W
+ 'state_name': state_dic[data[2]], # Process State name, ex: Running, sleeping, Zombie, etc
+ 'ppid': int(data[3]), # Parent process ID
+ 'utime': int(data[13]), # Used jiffies in user mode
+ 'stime': int(data[14]), # Used jiffies in kernel mode
+ 'start_time': int(data[21]), # Process time from system boot (jiffies)
+ 'vsize': int(data[22]), # Virtual memory size used (bytes)
+ 'rss': int(data[23])*4, # Resident Set Size (bytes)
'user_id': pidstat.st_uid, # process owner
'group_id': pidstat.st_gid # owner group
}
-
+
return info
-
+
+ # Return the process name
+ def _get_process_name(self, data):
+ m = re.search("\(.*\)", data)
+ return m.string[m.start()+1:m.end()-1]
+
+ def _get_safe_split(self, data):
+ new_data = re.sub("\(.*\)", '()', data)
+ return new_data.split()
# Returns the CPU usage expressed in Jiffies
def get_CPU_usage(self, cpu_hz, used_jiffies, start_time):
diff --git a/services/console/lib/procmem/proc_smaps.py b/services/console/lib/procmem/proc_smaps.py
index ce93cb2..174bc6b 100644
--- a/services/console/lib/procmem/proc_smaps.py
+++ b/services/console/lib/procmem/proc_smaps.py
@@ -56,8 +56,8 @@ class ProcSmaps:
mapping = Mapping (size, rss, shared_clean, shared_dirty, private_clean, private_dirty, permissions, name)
self.mappings.append (mapping)
- num_lines -= 7
- line_idx += 7
+ num_lines -= 8
+ line_idx += 8
# Parses a line of the form "foo: 42 kB" and returns an integer for the "42" field
def parse_smaps_size_line (self, line):