Merge remote-tracking branch 'remotes/kevin/tags/for-upstream' into staging
[qemu.git] / tests / migration / guestperf / scenario.py
1 #
2 # Migration test scenario parameter description
3 #
4 # Copyright (c) 2016 Red Hat, Inc.
5 #
6 # This library is free software; you can redistribute it and/or
7 # modify it under the terms of the GNU Lesser General Public
8 # License as published by the Free Software Foundation; either
9 # version 2.1 of the License, or (at your option) any later version.
10 #
11 # This library is distributed in the hope that it will be useful,
12 # but WITHOUT ANY WARRANTY; without even the implied warranty of
13 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 # Lesser General Public License for more details.
15 #
16 # You should have received a copy of the GNU Lesser General Public
17 # License along with this library; if not, see <http://www.gnu.org/licenses/>.
18 #
19
20
21 class Scenario(object):
22
23 def __init__(self, name,
24 downtime=500,
25 bandwidth=125000, # 1000 gig-e, effectively unlimited
26 max_iters=30,
27 max_time=300,
28 pause=False, pause_iters=5,
29 post_copy=False, post_copy_iters=5,
30 auto_converge=False, auto_converge_step=10,
31 compression_mt=False, compression_mt_threads=1,
32 compression_xbzrle=False, compression_xbzrle_cache=10,
33 multifd=False, multifd_channels=2):
34
35 self._name = name
36
37 # General migration tunables
38 self._downtime = downtime # milliseconds
39 self._bandwidth = bandwidth # MiB per second
40 self._max_iters = max_iters
41 self._max_time = max_time # seconds
42
43
44 # Strategies for ensuring completion
45 self._pause = pause
46 self._pause_iters = pause_iters
47
48 self._post_copy = post_copy
49 self._post_copy_iters = post_copy_iters
50
51 self._auto_converge = auto_converge
52 self._auto_converge_step = auto_converge_step # percentage CPU time
53
54 self._compression_mt = compression_mt
55 self._compression_mt_threads = compression_mt_threads
56
57 self._compression_xbzrle = compression_xbzrle
58 self._compression_xbzrle_cache = compression_xbzrle_cache # percentage of guest RAM
59
60 self._multifd = multifd
61 self._multifd_channels = multifd_channels
62
63 def serialize(self):
64 return {
65 "name": self._name,
66 "downtime": self._downtime,
67 "bandwidth": self._bandwidth,
68 "max_iters": self._max_iters,
69 "max_time": self._max_time,
70 "pause": self._pause,
71 "pause_iters": self._pause_iters,
72 "post_copy": self._post_copy,
73 "post_copy_iters": self._post_copy_iters,
74 "auto_converge": self._auto_converge,
75 "auto_converge_step": self._auto_converge_step,
76 "compression_mt": self._compression_mt,
77 "compression_mt_threads": self._compression_mt_threads,
78 "compression_xbzrle": self._compression_xbzrle,
79 "compression_xbzrle_cache": self._compression_xbzrle_cache,
80 "multifd": self._multifd,
81 "multifd_channels": self._multifd_channels,
82 }
83
84 @classmethod
85 def deserialize(cls, data):
86 return cls(
87 data["name"],
88 data["downtime"],
89 data["bandwidth"],
90 data["max_iters"],
91 data["max_time"],
92 data["pause"],
93 data["pause_iters"],
94 data["post_copy"],
95 data["post_copy_iters"],
96 data["auto_converge"],
97 data["auto_converge_step"],
98 data["compression_mt"],
99 data["compression_mt_threads"],
100 data["compression_xbzrle"],
101 data["compression_xbzrle_cache"],
102 data["multifd"],
103 data["multifd_channels"])