migration-stress/guestperf/engine.py

111     def _migrate(self, hardware, scenario, src,  argument
135         if scenario._auto_converge:
142                            cpu_throttle_increment=scenario._auto_converge_step)
144         if scenario._post_copy:
157                        max_bandwidth=scenario._bandwidth * 1024 * 1024)
160                        downtime_limit=scenario._downtime)
162         if scenario._compression_mt:
169                            compress_threads=scenario._compression_mt_threads)
176                            decompress_threads=scenario._compression_mt_threads)
178         if scenario._compression_xbzrle:
193                                scenario._compression_xbzrle_cache))
195         if scenario._multifd:
196             if (scenario._multifd_compression and
197                 (scenario._multifd_compression not in MULTIFD_CMP_ALGS)):
200                                     scenario._multifd_compression)
208                            multifd_channels=scenario._multifd_channels)
215                            multifd_channels=scenario._multifd_channels)
217             if scenario._multifd_compression:
219                     multifd_compression=scenario._multifd_compression)
221                     multifd_compression=scenario._multifd_compression)
223         if scenario._dirty_limit:
234                 x_vcpu_dirty_limit_period=scenario._x_vcpu_dirty_limit_period)
236                            vcpu_dirty_limit=scenario._vcpu_dirty_limit)
294             if progress._ram._iterations > scenario._max_iters:
296                     print("No completion after %d iterations over RAM" % scenario._max_iters)
300             if time.time() > (start + scenario._max_time):
302                     print("No completion after %d seconds" % scenario._max_time)
306             if (scenario._post_copy and
307                 progress._ram._iterations >= scenario._post_copy_iters and
310                     print("Switching to post-copy after %d iterations" % scenario._post_copy_iters)
314             if (scenario._pause and
315                 progress._ram._iterations >= scenario._pause_iters and
318                     print("Pausing VM after %d iterations" % scenario._pause_iters)
449     def run(self, hardware, scenario, result_dir=os.getcwd()):  argument
450         abs_result_dir = os.path.join(result_dir, scenario._name)
467         if scenario._multifd:
492             ret = self._migrate(hardware, scenario, src,
513             return Report(hardware, scenario, progress_history,