Use the module units to refer bytes type
Change-Id: I7d3e1b93fcbd7d60593d44bb86899fb43dc69003
This commit is contained in:
parent
4c6941a0ac
commit
8000a62030
@ -26,6 +26,7 @@ from ceilometer.openstack.common import log
|
||||
from ceilometer.openstack.common.rpc import dispatcher as rpc_dispatcher
|
||||
from ceilometer.openstack.common.rpc import service as rpc_service
|
||||
from ceilometer.openstack.common import service as os_service
|
||||
from ceilometer.openstack.common import units
|
||||
from ceilometer import service
|
||||
|
||||
OPTS = [
|
||||
@ -70,7 +71,7 @@ class CollectorService(service.DispatchedService, rpc_service.Service):
|
||||
while self.udp_run:
|
||||
# NOTE(jd) Arbitrary limit of 64K because that ought to be
|
||||
# enough for anybody.
|
||||
data, source = udp.recvfrom(64 * 1024)
|
||||
data, source = udp.recvfrom(64 * units.Ki)
|
||||
try:
|
||||
sample = msgpack.loads(data)
|
||||
except Exception:
|
||||
|
@ -21,6 +21,7 @@ from oslo.config import cfg
|
||||
from ceilometer.compute.virt.hyperv import utilsv2
|
||||
from ceilometer.compute.virt import inspector as virt_inspector
|
||||
from ceilometer.openstack.common import log
|
||||
from ceilometer.openstack.common import units
|
||||
|
||||
CONF = cfg.CONF
|
||||
LOG = log.getLogger(__name__)
|
||||
@ -46,8 +47,7 @@ class HyperVInspector(virt_inspector.Inspector):
|
||||
cpu_percent_used = (cpu_clock_used /
|
||||
float(host_cpu_clock * cpu_count))
|
||||
# Nanoseconds
|
||||
cpu_time = (long(uptime * cpu_percent_used) *
|
||||
1000)
|
||||
cpu_time = (long(uptime * cpu_percent_used) * units.k)
|
||||
|
||||
return virt_inspector.CPUStats(number=cpu_count, time=cpu_time)
|
||||
|
||||
@ -77,9 +77,9 @@ class HyperVInspector(virt_inspector.Inspector):
|
||||
stats = virt_inspector.DiskStats(
|
||||
read_requests=0,
|
||||
# Return bytes
|
||||
read_bytes=disk_metrics['read_mb'] * 1024,
|
||||
read_bytes=disk_metrics['read_mb'] * units.Ki,
|
||||
write_requests=0,
|
||||
write_bytes=disk_metrics['write_mb'] * 1024,
|
||||
write_bytes=disk_metrics['write_mb'] * units.Ki,
|
||||
errors=0)
|
||||
|
||||
yield (disk, stats)
|
||||
|
@ -23,6 +23,7 @@ import datetime
|
||||
import decimal
|
||||
|
||||
from ceilometer.openstack.common import timeutils
|
||||
from ceilometer.openstack.common import units
|
||||
|
||||
|
||||
def recursive_keypairs(d, separator=':'):
|
||||
@ -73,7 +74,7 @@ def decimal_to_dt(dec):
|
||||
return None
|
||||
|
||||
integer = int(dec)
|
||||
micro = (dec - decimal.Decimal(integer)) * decimal.Decimal(1000000)
|
||||
micro = (dec - decimal.Decimal(integer)) * decimal.Decimal(units.M)
|
||||
daittyme = datetime.datetime.utcfromtimestamp(integer)
|
||||
return daittyme.replace(microsecond=int(round(micro)))
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user