Niceness

ospd/misc.py

@@ -43,6 +43,7 @@
 from enum import Enum
 
 LOGGER = logging.getLogger(__name__)
+NICENESS = 10
 
 # Default file locations as used by a OpenVAS default installation
 KEY_FILE = "/usr/var/lib/gvm/private/CA/serverkey.pem"
@@ -868,6 +869,9 @@ def filename(string):
                         help='Path to the logging file.')
     parser.add_argument('--version', action='store_true',
                         help='Print version then exit.')
+    parser.add_argument('--niceness', default=NICENESS, type=int,
+                        help='Start the scan with the given niceness. Default %(default)s')
+
     return parser
 
 
@@ -920,6 +924,7 @@ def get_common_args(parser, args=None):
     common_args['foreground'] = options.foreground
     common_args['log_file'] = options.log_file
     common_args['version'] = options.version
+    common_args['niceness'] = options.niceness
 
     return common_args
 
@@ -952,7 +957,7 @@ def main(name, klass):
     cargs = get_common_args(parser)
     logging.getLogger().setLevel(cargs['log_level'])
     wrapper = klass(certfile=cargs['certfile'], keyfile=cargs['keyfile'],
-                    cafile=cargs['cafile'])
+                    cafile=cargs['cafile'], niceness=cargs['niceness'])
 
     if cargs['version']:
         print_version(wrapper)

ospd/ospd.py

@@ -200,7 +200,7 @@ class OSPDaemon(object):
       specific options eg. the w3af profile for w3af wrapper.
     """
 
-    def __init__(self, certfile, keyfile, cafile,
+    def __init__(self, certfile, keyfile, cafile, niceness=None,
                  customvtfilter=None, wrapper_logger=None):
         """ Initializes the daemon's internal data. """
         # @todo: Actually it makes sense to move the certificate params to

ospd/ospd_ssh.py

@@ -77,11 +77,13 @@ class OSPDaemonSimpleSSH(OSPDaemon):
     an array.
     """
 
-    def __init__(self, certfile, keyfile, cafile):
+    def __init__(self, certfile, keyfile, cafile, niceness=None):
         """ Initializes the daemon and add parameters needed to remote SSH execution. """
 
         super(OSPDaemonSimpleSSH, self).__init__(certfile=certfile, keyfile=keyfile,
-                                                 cafile=cafile)
+                                                 cafile=cafile, niceness=niceness)
+
+        self._niceness = niceness
 
         if paramiko is None:
             raise ImportError('paramiko needs to be installed in order to use'
@@ -140,6 +142,8 @@ def run_command(self, scan_id, host, cmd):
             self.add_scan_error(scan_id, host=host, value=str(err))
             return None
 
+        if self._niceness is not None:
+            cmd = "nice -n %s %s" % (self._niceness, cmd)
         _, stdout, _ = ssh.exec_command(cmd)
         result = stdout.readlines()
         ssh.close()

tests/testSSHDaemon.py

@@ -64,31 +64,31 @@ class TestSSH(unittest.TestCase):
 
     def testNoParamiko(self):
         ospd_ssh.paramiko = None
-        self.assertRaises(ImportError, OSPDaemonSimpleSSH, 'cert', 'key', 'ca')
+        self.assertRaises(ImportError, OSPDaemonSimpleSSH, 'cert', 'key', 'ca', '10')
 
     def testRunCommand(self):
         ospd_ssh.paramiko = fakeparamiko
-        daemon = OSPDaemonSimpleSSH('cert', 'key', 'ca')
+        daemon = OSPDaemonSimpleSSH('cert', 'key', 'ca', '10')
         scanid = daemon.create_scan(None, [['host.example.com', '80, 443', '', ''],],
                                     dict(port=5, ssh_timeout=15,
                                          username_password='dummy:pw'), '')
         res = daemon.run_command(scanid, 'host.example.com', 'cat /etc/passwd')
         self.assertTrue(isinstance(res, list))
-        self.assertEqual(commands, ['cat /etc/passwd'])
+        self.assertEqual(commands, ['nice -n 10 cat /etc/passwd'])
 
     def testRunCommandLegacyCredential(self):
         ospd_ssh.paramiko = fakeparamiko
-        daemon = OSPDaemonSimpleSSH('cert', 'key', 'ca')
+        daemon = OSPDaemonSimpleSSH('cert', 'key', 'ca', '10')
         scanid = daemon.create_scan(None, [['host.example.com', '80, 443', '', ''],],
                                     dict(port=5, ssh_timeout=15,
                                          username='dummy', password='pw'), '')
         res = daemon.run_command(scanid, 'host.example.com', 'cat /etc/passwd')
         self.assertTrue(isinstance(res, list))
-        self.assertEqual(commands, ['cat /etc/passwd'])
+        self.assertEqual(commands, ['nice -n 10 cat /etc/passwd'])
 
     def testRunCommandNewCredential(self):
         ospd_ssh.paramiko = fakeparamiko
-        daemon = OSPDaemonSimpleSSH('cert', 'key', 'ca')
+        daemon = OSPDaemonSimpleSSH('cert', 'key', 'ca', '10')
 
         cred_dict = {'ssh': {'type': 'up',
                              'password': 'mypass',
@@ -103,11 +103,11 @@ def testRunCommandNewCredential(self):
                                     dict(port=5, ssh_timeout=15), '')
         res = daemon.run_command(scanid, 'host.example.com', 'cat /etc/passwd')
         self.assertTrue(isinstance(res, list))
-        self.assertEqual(commands, ['cat /etc/passwd'])
+        self.assertEqual(commands, ['nice -n 10 cat /etc/passwd'])
 
     def testRunCommandNoCredential(self):
         ospd_ssh.paramiko = fakeparamiko
-        daemon = OSPDaemonSimpleSSH('cert', 'key', 'ca')
+        daemon = OSPDaemonSimpleSSH('cert', 'key', 'ca', '10')
         scanid = daemon.create_scan(None, [['host.example.com', '80, 443', '', ''],],
                                     dict(port=5, ssh_timeout=15), '')
         self.assertRaises(ValueError, daemon.run_command,

tests/testScanAndResult.py

@@ -47,7 +47,7 @@ def __init__(self, type_, **kwargs):
 
 class DummyWrapper(OSPDaemon):
     def __init__(self, results, checkresult=True):
-        OSPDaemon.__init__(self, 'cert', 'key', 'ca')
+        OSPDaemon.__init__(self, 'cert', 'key', 'ca', '10')
         self.checkresult = checkresult
         self.results = results