From b9b7081eb453f741965489b303a0651f3c948cb8 Mon Sep 17 00:00:00 2001 From: Mr Chen Date: Tue, 4 Jun 2024 00:38:18 +0800 Subject: [PATCH] Update task_manager_index.py --- plugins/task_manager/task_manager_index.py | 34 +++++++++++++++++++++- 1 file changed, 33 insertions(+), 1 deletion(-) diff --git a/plugins/task_manager/task_manager_index.py b/plugins/task_manager/task_manager_index.py index 6e49afe599..9bce2b5aa5 100755 --- a/plugins/task_manager/task_manager_index.py +++ b/plugins/task_manager/task_manager_index.py @@ -132,6 +132,38 @@ def get_connects(self, pid): pass return connects + # 获取进程io写 + def get_io_write(self, pid, io_write): + # self.get_old() + disk_io_write = 0 + if not self.old_info: self.old_info = {} + if not pid in self.old_info: + self.new_info[pid]['io_write'] = io_write + return disk_io_write + if not 'time' in self.old_info: self.old_info['time'] = self.new_info['time'] + io_end = (io_write - self.old_info[pid]['io_write']) + if io_end > 0: + disk_io_write = io_end / (time.time() - self.old_info['time']) + self.new_info[pid]['io_write'] = io_write + if disk_io_write > 0: return int(disk_io_write) + return 0 + + # 获取io读 + def get_io_read(self, pid, io_read): + # self.get_old() + disk_io_read = 0 + if not self.old_info: self.old_info = {} + if not pid in self.old_info: + self.new_info[pid]['io_read'] = io_read + return disk_io_read + if not 'time' in self.old_info: self.old_info['time'] = self.new_info['time'] + io_end = (io_read - self.old_info[pid]['io_read']) + if io_end > 0: + disk_io_read = io_end / (time.time() - self.old_info['time']) + self.new_info[pid]['io_read'] = io_read + if disk_io_read > 0: return int(disk_io_read) + return 0 + def get_mem_info(self, get=None): mem = psutil.virtual_memory() if self.is_mac: @@ -740,7 +772,7 @@ def get_process_list_linux(self, get = {}): processList.append(tmp) del (p) del (tmp) - except: + except Exception as e: continue processList = self.__pro_s_s(processList)