added logic

Author: aklyuchev86

core/src/utils/periodic_task.cpp

@@ -84,7 +84,7 @@ void PeriodicTask::SetSettings(Settings settings) {
   {
     auto writer = settings_.StartWrite();
     settings.flags = writer->flags;
-    has_changed = settings.period != writer->period;
+    has_changed = settings.period != writer->period || settings.enabled != writer->enabled;
     *writer = std::move(settings);
     writer.Commit();
   }
@@ -99,6 +99,10 @@ void PeriodicTask::SetSettings(Settings settings) {
 
 void PeriodicTask::ForceStepAsync() {
   should_force_step_ = true;
+  if (!writer->enabled) {
+      writer->enabled = true;
+      writer.Commit();
+  }
   changed_event_.Send();
 }
 
@@ -125,11 +129,12 @@ void PeriodicTask::Run() {
     const auto before = std::chrono::steady_clock::now();
     bool no_exception = true;
 
-    if (!std::exchange(skip_step, false)) {
+    const auto settings = settings_.Read();
+    bool taskEnabled = settings->enabled;
+    if (!std::exchange(skip_step, false) && taskEnabled) {
       no_exception = Step();
     }
 
-    const auto settings = settings_.Read();
     auto period = settings->period;
     const auto exception_period = settings->exception_period.value_or(period);
 
@@ -142,12 +147,16 @@ void PeriodicTask::Run() {
       start = std::chrono::steady_clock::now();
     }
 
-    while (changed_event_.WaitForEventUntil(start + MutatePeriod(period))) {
+    while ((!taskEnabled && changed_event_.WaitForEvent()) || (taskEnabled && changed_event_.WaitForEventUntil(start + MutatePeriod(period)))) {
       if (should_force_step_.exchange(false)) {
         break;
       }
       // The config variable value has been changed, reload
       const auto settings = settings_.Read();
+      taskEnabled = settings->enabled;
+      if(!taskEnabled) {
+          break;
+      }
       period = settings->period;
       const auto exception_period = settings->exception_period.value_or(period);
       if (!no_exception) period = exception_period;