1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
# -*- coding: utf-8 -*-
import threading
import subprocess
class ProcessRunner(threading.Thread):
"""
ProcessRunner is class designed to run arbitrary command
in background (separate thread). It's replacement for old
stuff.call_program function.
When called program is finished, its output can be accessed
through .stdout and .stderr fields
"""
def __init__(self, args, autorun=True):
"""
@param args - program name and its arguments
@param autorun - if True, then automatically starts new thread
"""
threading.Thread.__init__(self)
self.args = args
self.lock = threading.Lock()
self.stdout = ""
self.stderr = ""
if autorun:
self.start()
def run(self):
self.lock.acquire()
subp = subprocess.Popen(
self.args, stdout=subprocess.PIPE, stderr=subprocess.PIPE
)
self.stdout, self.stderr = subp.communicate()
self.lock.release()
def is_ready(self):
"""Checks whether current command is finished"""
return not self.lock.locked()
def wait(self):
"""Waits until called program finishes"""
self.lock.acquire()
self.lock.release()
class ScanRunner(threading.Thread):
"""
ScanRunner is a class for calling scanelf in separate
thread, so several instances could be called at a time,
and then all results could be consolidated.
Consolidated output is available through .out
"""
def __init__(self, params, files, max_args, autorun=True):
"""
@param params is list of parameters that should be passed into scanelf app.
@param files list of files to scan.
@param max_args number of files to process at once
@param autorun automatically start new thread
When files count is greater CMD_MAX_ARGS, then scanelf will be called
several times.
"""
threading.Thread.__init__(self)
self.params = params
self.files = files
self.max_args = max_args
self.out = []
self.lock = threading.Lock()
if autorun:
self.start()
def run(self):
self.lock.acquire()
process_pool = []
for i in range(0, len(self.files), self.max_args):
process_pool.append(
ProcessRunner(
["scanelf"] + self.params + self.files[i : i + self.max_args]
)
)
while process_pool:
p = process_pool.pop()
p.wait()
self.out += p.stdout.strip().split("\n")
self.lock.release()
def is_ready(self):
"""Checks whether scanning is finished"""
return not self.lock.locked()
def wait(self):
"""Waits until all scanning instances are finished"""
self.lock.acquire()
self.lock.release()
|
GitWeb