[pve-devel] [PATCH ha-manager v3 07/15] manager: read and update rules config

[Daniel Kral]

Read the rules configuration in each round and update the canonicalized
rules configuration if there were any changes since the last round to
reduce the amount of times of verifying the rule set.

Signed-off-by: Daniel Kral <d.kral at proxmox.com>
---
 src/PVE/HA/Manager.pm | 20 +++++++++++++++++++-
 1 file changed, 19 insertions(+), 1 deletion(-)

diff --git a/src/PVE/HA/Manager.pm b/src/PVE/HA/Manager.pm
index c57a280..88ff4a6 100644
--- a/src/PVE/HA/Manager.pm
+++ b/src/PVE/HA/Manager.pm
@@ -8,6 +8,8 @@ use Digest::MD5 qw(md5_base64);
 use PVE::Tools;
 use PVE::HA::Tools ':exit_codes';
 use PVE::HA::NodeStatus;
+use PVE::HA::Rules;
+use PVE::HA::Rules::NodeAffinity;
 use PVE::HA::Usage::Basic;
 use PVE::HA::Usage::Static;
 
@@ -41,7 +43,11 @@ sub new {
 
     my $class = ref($this) || $this;
 
-    my $self = bless { haenv => $haenv, crs => {} }, $class;
+    my $self = bless {
+        haenv => $haenv,
+        crs => {},
+        last_rules_digest => '',
+    }, $class;
 
     my $old_ms = $haenv->read_manager_status();
 
@@ -556,6 +562,18 @@ sub manage {
         delete $ss->{$sid};
     }
 
+    my $new_rules = $haenv->read_rules_config();
+
+    if ($new_rules->{digest} ne $self->{last_rules_digest}) {
+
+        my $messages = PVE::HA::Rules->canonicalize($new_rules);
+        $haenv->log('info', $_) for @$messages;
+
+        $self->{rules} = $new_rules;
+
+        $self->{last_rules_digest} = $self->{rules}->{digest};
+    }
+
     $self->update_crm_commands();
 
     for (;;) {
-- 
2.39.5