52     def __init__(self, host=None, ifname=None, port=None, name="", user="root"):  argument
53         self.host = host
54         self.name = name
55         self.user = user
56         self.monitors = []
57         self.monitor_thread = None
58         self.logs = []
59         self.ifname = ifname
60         self.port = port
61         self.dev = None
62         self.monitor_params = []
63         if self.name == "" and host != None:
64             self.name = host
66     def local_execute(self, command):  argument
82     def execute(self, command):  argument
83         if self.host is None:
84             return self.local_execute(command)
86         cmd = ["ssh", self.user + "@" + self.host, ' '.join(command)]
87         _cmd = self.name + " execute: " + ' '.join(cmd)
99         logger.debug(self.name + " status: " + str(status))
100         logger.debug(self.name + " buf: " + str(buf))
104     def thread_run(self, command, res, use_reaper=True):  argument
107             self.send_file(filename, filename)
108             self.execute(["chmod", "755", filename])
114         if self.host is None:
117             cmd = ["ssh", self.user + "@" + self.host, ' '.join(_command)]
118         _cmd = self.name + " thread_run: " + ' '.join(cmd)
124     def thread_stop(self, t):  argument
132             self.execute(cmd)
135         self.thread_wait(t, 5)
138             self.execute(cmd)
141         self.thread_wait(t, 5)
144             self.execute(cmd)
146         self.thread_wait(t, 5)
150         self.execute(["rm", pid_file])
151         self.execute(["rm", t.name])
152         self.local_execute(["rm", t.name])
154     def thread_wait(self, t, wait=None):  argument
160         logger.debug(self.name + " thread_wait(" + wait_str + "): ")
164     def proc_pending(self, proc, timeout=0):  argument
170     def proc_run(self, command):  argument
172         self.send_file(filename, filename)
173         self.execute(["chmod", "755", filename])
176         if self.host:
177             cmd = ["ssh", self.user + "@" + self.host, ' '.join(_command)]
181         _cmd = self.name + " proc_run: " + ' '.join(cmd)
189     def proc_wait_event(self, proc, events, timeout=10):  argument
193 …    logger.debug(self.name + " proc_wait_event: " + ' '.join(events) + " timeout: " + str(timeout))
197                 while self.proc_pending(proc):
210                 if not self.proc_pending(proc, timeout=remaining):
217     def proc_write(self, proc, cmd):  argument
220     def proc_read(self, proc, timeout=0):  argument
221         if not self.proc_pending(proc):
230     def proc_stop(self, proc):  argument
234         self.execute(["kill `cat " + proc.reaper_file + ".pid`"])
235         self.execute(["rm", proc.reaper_file + ".pid"])
236         self.execute(["rm", proc.reaper_file])
237         self.local_execute(["rm", proc.reaper_file])
240     def proc_dump(self, proc):  argument
245     def execute_and_wait_event(self, command, events, timeout=10):  argument
250             proc = self.proc_run(command)
251             ev = self.proc_wait_event(proc, events, timeout)
255         self.proc_stop(proc)
258     def add_log(self, log_file):  argument
259         self.logs.append(log_file)
261     def get_logs(self, local_log_dir=None):  argument
262         for log in self.logs:
264 …              self.local_execute(["scp", self.user + "@[" + self.host + "]:" + log, local_log_dir])
265             self.execute(["rm", log])
266         del self.logs[:]
268     def send_file(self, src, dst):  argument
269         if self.host is None:
271         self.local_execute(["scp", src,
272                             self.user + "@[" + self.host + "]:" + dst])