diff options
| author | Marco Capitani <m.capitani@nextworks.it> | 2017-04-24 15:00:21 +0200 |
|---|---|---|
| committer | Marco Capitani <m.capitani@nextworks.it> | 2017-04-24 15:00:21 +0200 |
| commit | eda14393d20cdd0b9ef9303f024f4c8a0b47eda2 (patch) | |
| tree | d5fffe103ad8f39669147b69e59274b0e4731fe8 /rumba/testbeds/qemu.py | |
| parent | bec81866d4da33405c35c8eb4dc15d4fc5bfbfb7 (diff) | |
| download | rumba-eda14393d20cdd0b9ef9303f024f4c8a0b47eda2.tar.gz rumba-eda14393d20cdd0b9ef9303f024f4c8a0b47eda2.zip | |
Logging: added set and reset logging level method, small logging modifications.
Diffstat (limited to 'rumba/testbeds/qemu.py')
| -rw-r--r-- | rumba/testbeds/qemu.py | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/rumba/testbeds/qemu.py b/rumba/testbeds/qemu.py index 6121e6b..a916525 100644 --- a/rumba/testbeds/qemu.py +++ b/rumba/testbeds/qemu.py @@ -114,6 +114,7 @@ class Testbed(mod.Testbed): raise Exception('Not authenticated') logger.info("swapping in") + logger.info('Setting up interfaces.') # Building bridges and taps shim_processes = [] @@ -203,6 +204,9 @@ class Testbed(mod.Testbed): except: max_waiting_time -= 1 + logger.info('Interfaces setup complete. ' + 'Building VMs (this might take a while).') + # Building vms boot_batch_size = max(1, multiprocessing.cpu_count() // 2) @@ -300,11 +304,14 @@ class Testbed(mod.Testbed): self.recover_if_names(experiment) + logger.info('Experiment has been successfully swapped in.') + def swap_out(self, experiment): """ :rtype str :return: The script to tear down the experiment """ + logger.info('Killing qemu processes.') # TERM qemu processes for process in self.boot_processes: process.terminate() @@ -313,6 +320,7 @@ class Testbed(mod.Testbed): for process in self.boot_processes: process.wait() + logger.info('Destroying interfaces.') port_processes = [] error_queue = multiprocessing.Queue() results_queue = multiprocessing.Queue() @@ -394,3 +402,4 @@ class Testbed(mod.Testbed): % (over_processes, total_processes)) except: max_waiting_time -= 1 + logger.info('Experiment has been swapped out.') |