refactor: improve protability

nvitop/process.py

@@ -7,7 +7,6 @@
 import datetime
 import functools
 import os
-import sys
 import threading
 import time
 
@@ -17,7 +16,7 @@ from cachetools.func import ttl_cache
 from .utils import bytes2human, timedelta2human, Snapshot
 
 
-if sys.platform != 'windows':
+if psutil.POSIX:
     def _add_quotes(s):
         if '$' not in s and '\\' not in s:
             if ' ' not in s:
@@ -27,7 +26,7 @@ if sys.platform != 'windows':
         if "'" not in s:
             return "'{}'".format(s)
         return '"{}"'.format(s.replace('\\', '\\\\').replace('"', '\\"').replace('$', '\\$'))
-else:
+elif psutil.WINDOWS:
     def _add_quotes(s):
         if '%' not in s and '^' not in s:
             if ' ' not in s:
@@ -35,6 +34,9 @@ else:
             if '"' not in s:
                 return '"{}"'.format(s)
         return '"{}"'.format(s.replace('^', '^^').replace('"', '^"').replace('%', '^%'))
+else:
+    def _add_quotes(s):
+        return s
 
 
 def _auto_garbage_clean(default=None):

nvitop/ui/panels/process.py

@@ -28,10 +28,7 @@ class Selected(object):
     @property
     def identity(self):
         if self._ident is None:
-            try:
-                self._ident = self.process._ident  # pylint: disable=protected-access
-            except AttributeError:
-                pass
+            self._ident = self.process._ident  # pylint: disable=protected-access
         return self._ident
 
     @property
@@ -56,8 +53,7 @@ class Selected(object):
         if direction == 0:
             return
 
-        with self.panel.snapshot_lock:
-            processes = self.panel.snapshots
+        processes = self.panel.snapshots
         if len(processes) > 0:
             if not self.is_set():
                 if direction > 0:
@@ -80,15 +76,29 @@ class Selected(object):
             except psutil.Error:
                 pass
             else:
-                if sig != signal.SIGINT:
+                time.sleep(0.5)
+                if not self.process.is_running():
                     self.clear()
-                time.sleep(1.0)
-
-    def kill(self):
-        return self.send_signal(signal.SIGKILL)
 
     def terminate(self):
-        return self.send_signal(signal.SIGTERM)
+        if self.owned():
+            try:
+                self.process.terminate()
+            except psutil.Error:
+                pass
+            else:
+                time.sleep(0.5)
+                self.clear()
+
+    def kill(self):
+        if self.owned():
+            try:
+                self.process.kill()
+            except psutil.Error:
+                pass
+            else:
+                time.sleep(0.5)
+                self.clear()
 
     def interrupt(self):
         return self.send_signal(signal.SIGINT)
@@ -179,12 +189,14 @@ class ProcessPanel(Displayable):
             self.height = height
             self.host_offset = max(-1, min(self.host_offset, info_length - 45))
 
-            selected = self.selected
-            selected.index = None
-            for i, process in enumerate(snapshots):
-                if process.identity == selected.identity:
-                    selected.index = i
-                    selected.process = process
+            if self.selected.is_set():
+                identity = self.selected.identity
+                self.selected.clear()
+                for i, process in enumerate(snapshots):
+                    if process.identity == identity:
+                        self.selected.index = i
+                        self.selected.process = process
+                        break
 
     def take_snapshots(self):
         snapshots = list(filter(None, map(lambda process: process.snapshot(), self.processes.values())))