Proxmox/pve-manager
5
0
Fork 0
Code Pull Requests Releases Activity

pvestatd: broadcast static node information

Browse Source 
Planned to be used for static resource scheduling in the HA manager.

It's enough to broadcast the values whenever they are outdated or not
set in the node's local kv store, because pmxcfs will re-broadcast the
local kv store whenever the quorate partition changes. This is already
relied upon for the 'ceph-versions' kv pair.

Suggested-by: Thomas Lamprecht <t.lamprecht@proxmox.com>
Signed-off-by: Fiona Ebner <f.ebner@proxmox.com>
This commit is contained in:
Fiona Ebner 2022-11-10 15:37:45 +01:00 committed by Thomas Lamprecht
parent 63d389bc51
commit 955912c54e
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
PVE/Service/pvestatd.pm
View File

@ -123,6 +123,24 @@ my $generate_rrd_string = sub {
return join(':', map { $_ // 'U' } @$data);
};
my sub broadcast_static_node_info {
my ($cpus, $memory) = @_;
my $old = PVE::Cluster::get_node_kv('static-info', $nodename);
$old = eval { decode_json($old->{$nodename}) } if defined($old->{$nodename});
if (
!defined($old->{cpus}) || $old->{cpus} != $cpus
|| !defined($old->{memory}) || $old->{memory} != $memory
) {
my $info = {
cpus => $cpus,
memory => $memory,
};
PVE::Cluster::broadcast_node_kv('static-info', encode_json($info));
}
}
sub update_node_status {
my ($status_cfg) = @_;
@ -175,6 +193,8 @@ sub update_node_status {
my $transactions = PVE::ExtMetric::transactions_start($status_cfg);
PVE::ExtMetric::update_all($transactions, 'node', $nodename, $node_metric, $ctime);
PVE::ExtMetric::transactions_finish($transactions);
broadcast_static_node_info($maxcpu, $meminfo->{memtotal});
}
sub auto_balloning {