diff --git a/minerva/command.py b/minerva/command.py index bc31120..135c79e 100644 --- a/minerva/command.py +++ b/minerva/command.py @@ -19,7 +19,7 @@ class Command: self.machine = machine self.command = command self.disown = disown - self.watch = watch + self.watch = True#watch self.logset = logset self.thread = None @@ -36,6 +36,8 @@ class Command: # https://github.com/paramiko/paramiko/issues/593#issuecomment-145377328 # def execute(self): + print(f"running: {self.command}") + print("\t", self.logset) stdin, stdout, stderr = self.machine.ssh.client.exec_command(self.command) # this is the same for all three inputs @@ -86,16 +88,20 @@ class Command: break for c in readq: if c.recv_ready(): + print(f"\t{len(c.in_buffer)} in stdout") flush_data(channel.recv(len(c.in_buffer)), out, (self.watch and sys.stdout.buffer)) got_chunk = True + print(f"\t{len(c.in_buffer)} left in stdout") if c.recv_stderr_ready(): + print(f"\t{len(c.in_stderr_buffer)} in stderr") flush_data(channel.recv_stderr(len(c.in_stderr_buffer)), err, (self.watch and sys.stderr.buffer)) got_chunk = True + print(f"\t{len(c.in_stderr_buffer)} left in stderr") # for c """ @@ -132,8 +138,6 @@ class Command: self.thread.start() if not self.disown: - print(f"running: {self.command}") - print(self.logset) self.thread.join()