X-Git-Url: https://git.proxmox.com/?a=blobdiff_plain;f=src%2FPVE%2FHA%2FEnv.pm;h=a173deba47f57de3fb7e9f7721b8fe6311e81094;hb=ed408b449128239641048f315cd5849ab90da8bd;hp=dc75985f14fffa97dd8dfc4a2ca989383eca3e6a;hpb=2a045f55cfbd3cfd45586bbb0b5976b68e08cf69;p=pve-ha-manager.git

diff --git a/src/PVE/HA/Env.pm b/src/PVE/HA/Env.pm
index dc75985..a173deb 100644
--- a/src/PVE/HA/Env.pm
+++ b/src/PVE/HA/Env.pm
@@ -81,22 +81,41 @@ sub read_crm_commands {
     return $self->{plug}->read_crm_commands();
 }
 
-sub service_config_exists {
+sub read_service_config {
     my ($self) = @_;
 
-    return $self->{plug}->service_config_exists();
+    return $self->{plug}->read_service_config();
 }
 
-sub read_service_config {
+sub parse_sid {
+    my ($self, $sid) = @_;
+
+    return $self->{plug}->parse_sid($sid);
+}
+
+sub read_fence_config {
     my ($self) = @_;
 
-    return $self->{plug}->read_service_config();
+    return $self->{plug}->read_fence_config();
 }
 
-sub change_service_location {
+sub fencing_mode {
+    my ($self) = @_;
+
+    return $self->{plug}->fencing_mode();
+}
+
+sub exec_fence_agent {
+    my ($self, $agent, $node, @param) = @_;
+
+    return $self->{plug}->exec_fence_agent($agent, $node, @param);
+}
+
+# this is normally only allowed by the master to recover a _fenced_ service
+sub steal_service {
     my ($self, $sid, $current_node, $new_node) = @_;
 
-    return $self->{plug}->change_service_location($sid, $current_node, $new_node);
+    return $self->{plug}->steal_service($sid, $current_node, $new_node);
 }
 
 sub read_group_config {
@@ -119,6 +138,12 @@ sub log {
     return $self->{plug}->log($level, @args);
 }
 
+sub sendmail {
+    my ($self, $subject, $text) = @_;
+
+    return $self->{plug}->sendmail($subject, $text);
+}
+
 # acquire a cluster wide manager lock
 sub get_ha_manager_lock {
     my ($self) = @_;
@@ -190,6 +215,12 @@ sub loop_end_hook {
     return $self->{plug}->loop_end_hook(@args);
 }
 
+sub cluster_state_update {
+    my ($self) = @_;
+
+    return $self->{plug}->cluster_state_update();
+}
+
 sub watchdog_open {
     my ($self) = @_;
 
@@ -211,11 +242,25 @@ sub watchdog_close {
     return $self->{plug}->watchdog_close($wfh);
 }
 
-# hack to support regression tests
-sub can_fork {
+sub after_fork {
+    my ($self) = @_;
+
+    return $self->{plug}->after_fork();
+}
+
+# maximal number of workers to fork,
+# return 0 as a hack to support regression tests
+sub get_max_workers {
+    my ($self) = @_;
+
+    return $self->{plug}->get_max_workers();
+}
+
+# return cluster wide enforced HA settings
+sub get_ha_settings {
     my ($self) = @_;
 
-    return $self->{plug}->can_fork();
+    return $self->{plug}->get_ha_settings();
 }
 
 1;