cachepc-qemu

Fork of AMDESE/qemu with changes for cachepc side-channel attack
git clone https://git.sinitax.com/sinitax/cachepc-qemu
Log | Files | Refs | Submodules | LICENSE | sfeed.txt

progress.py (3862B)

      1#
      2# Migration test migration operation progress
      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
     21class ProgressStats(object):
     22
     23    def __init__(self,
     24                 transferred_bytes,
     25                 remaining_bytes,
     26                 total_bytes,
     27                 duplicate_pages,
     28                 skipped_pages,
     29                 normal_pages,
     30                 normal_bytes,
     31                 dirty_rate_pps,
     32                 transfer_rate_mbs,
     33                 iterations):
     34        self._transferred_bytes = transferred_bytes
     35        self._remaining_bytes = remaining_bytes
     36        self._total_bytes = total_bytes
     37        self._duplicate_pages = duplicate_pages
     38        self._skipped_pages = skipped_pages
     39        self._normal_pages = normal_pages
     40        self._normal_bytes = normal_bytes
     41        self._dirty_rate_pps = dirty_rate_pps
     42        self._transfer_rate_mbs = transfer_rate_mbs
     43        self._iterations = iterations
     44
     45    def serialize(self):
     46        return {
     47            "transferred_bytes": self._transferred_bytes,
     48            "remaining_bytes": self._remaining_bytes,
     49            "total_bytes": self._total_bytes,
     50            "duplicate_pages": self._duplicate_pages,
     51            "skipped_pages": self._skipped_pages,
     52            "normal_pages": self._normal_pages,
     53            "normal_bytes": self._normal_bytes,
     54            "dirty_rate_pps": self._dirty_rate_pps,
     55            "transfer_rate_mbs": self._transfer_rate_mbs,
     56            "iterations": self._iterations,
     57        }
     58
     59    @classmethod
     60    def deserialize(cls, data):
     61        return cls(
     62            data["transferred_bytes"],
     63            data["remaining_bytes"],
     64            data["total_bytes"],
     65            data["duplicate_pages"],
     66            data["skipped_pages"],
     67            data["normal_pages"],
     68            data["normal_bytes"],
     69            data["dirty_rate_pps"],
     70            data["transfer_rate_mbs"],
     71            data["iterations"])
     72
     73
     74class Progress(object):
     75
     76    def __init__(self,
     77                 status,
     78                 ram,
     79                 now,
     80                 duration,
     81                 downtime,
     82                 downtime_expected,
     83                 setup_time,
     84                 throttle_pcent):
     85
     86        self._status = status
     87        self._ram = ram
     88        self._now = now
     89        self._duration = duration
     90        self._downtime = downtime
     91        self._downtime_expected = downtime_expected
     92        self._setup_time = setup_time
     93        self._throttle_pcent = throttle_pcent
     94
     95    def serialize(self):
     96        return {
     97            "status": self._status,
     98            "ram": self._ram.serialize(),
     99            "now": self._now,
    100            "duration": self._duration,
    101            "downtime": self._downtime,
    102            "downtime_expected": self._downtime_expected,
    103            "setup_time": self._setup_time,
    104            "throttle_pcent": self._throttle_pcent,
    105        }
    106
    107    @classmethod
    108    def deserialize(cls, data):
    109        return cls(
    110            data["status"],
    111            ProgressStats.deserialize(data["ram"]),
    112            data["now"],
    113            data["duration"],
    114            data["downtime"],
    115            data["downtime_expected"],
    116            data["setup_time"],
    117            data["throttle_pcent"])