Compare commits
2 Commits
1a05077b10
...
0f24184b78
Author | SHA1 | Date | |
---|---|---|---|
0f24184b78 | |||
1ba37fe33d |
@ -115,6 +115,27 @@ def fence_node(node_name, zkhandler, config, logger):
|
|||||||
):
|
):
|
||||||
migrateFromFencedNode(zkhandler, node_name, config, logger)
|
migrateFromFencedNode(zkhandler, node_name, config, logger)
|
||||||
|
|
||||||
|
# Reset all node resource values
|
||||||
|
logger.out(
|
||||||
|
f"Resetting all resource values for dead node {node_name} to zero",
|
||||||
|
state="i",
|
||||||
|
prefix=f"fencing {node_name}",
|
||||||
|
)
|
||||||
|
zkhandler.write(
|
||||||
|
[
|
||||||
|
(("node.running_domains", node_name), "0"),
|
||||||
|
(("node.count.provisioned_domains", node_name), "0"),
|
||||||
|
(("node.cpu.load", node_name), "0"),
|
||||||
|
(("node.vcpu.allocated", node_name), "0"),
|
||||||
|
(("node.memory.total", node_name), "0"),
|
||||||
|
(("node.memory.used", node_name), "0"),
|
||||||
|
(("node.memory.free", node_name), "0"),
|
||||||
|
(("node.memory.allocated", node_name), "0"),
|
||||||
|
(("node.memory.provisioned", node_name), "0"),
|
||||||
|
(("node.monitoring.health", node_name), None),
|
||||||
|
]
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
# Migrate hosts away from a fenced node
|
# Migrate hosts away from a fenced node
|
||||||
def migrateFromFencedNode(zkhandler, node_name, config, logger):
|
def migrateFromFencedNode(zkhandler, node_name, config, logger):
|
||||||
|
@ -477,6 +477,10 @@ def collect_vm_stats(logger, config, zkhandler, this_node, queue):
|
|||||||
fixed_d_domain = this_node.d_domain.copy()
|
fixed_d_domain = this_node.d_domain.copy()
|
||||||
for domain, instance in fixed_d_domain.items():
|
for domain, instance in fixed_d_domain.items():
|
||||||
if domain in this_node.domain_list:
|
if domain in this_node.domain_list:
|
||||||
|
# Add the allocated memory to our memalloc value
|
||||||
|
memalloc += instance.getmemory()
|
||||||
|
memprov += instance.getmemory()
|
||||||
|
vcpualloc += instance.getvcpus()
|
||||||
if instance.getstate() == "start" and instance.getnode() == this_node.name:
|
if instance.getstate() == "start" and instance.getnode() == this_node.name:
|
||||||
if instance.getdom() is not None:
|
if instance.getdom() is not None:
|
||||||
try:
|
try:
|
||||||
@ -532,11 +536,6 @@ def collect_vm_stats(logger, config, zkhandler, this_node, queue):
|
|||||||
continue
|
continue
|
||||||
domain_memory_stats = domain.memoryStats()
|
domain_memory_stats = domain.memoryStats()
|
||||||
domain_cpu_stats = domain.getCPUStats(True)[0]
|
domain_cpu_stats = domain.getCPUStats(True)[0]
|
||||||
|
|
||||||
# Add the allocated memory to our memalloc value
|
|
||||||
memalloc += instance.getmemory()
|
|
||||||
memprov += instance.getmemory()
|
|
||||||
vcpualloc += instance.getvcpus()
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
if debug:
|
if debug:
|
||||||
try:
|
try:
|
||||||
|
Reference in New Issue
Block a user