Scheduler.h

Go to the documentation of this file.

#pragma once
 
#include "Arduino.h"  // for millis
#include "DLNADevice.h"
#include "IUDPService.h"
#include "Schedule.h"
 
namespace tiny_dlna {
 
class Scheduler {
 public:
  void add(Schedule *schedule) {
    schedule->active = true;
    DlnaLogger.log(DlnaInfo, "Schedule %s", schedule->name());
    queue.push_back(schedule);
  }
 
  void execute(IUDPService &udp) {
    // DlnaLogger.log(DlnaDebug, "Scheduler::execute");
    bool is_cleanup = false;
    for (auto &p_s : queue) {
      if (p_s == nullptr) continue;
      Schedule &s = *p_s;
      if (millis() >= s.time) {
        // handle end time: if expired set inactive
        if (s.end_time > millis()) {
          s.active = false;
        }
        // process active schedules
        if (s.active) {
          DlnaLogger.log(DlnaDebug, "Executing %s", s.name());
 
          s.process(udp);
          // reschedule if necessary
          if (s.repeat_ms > 0) {
            s.time = millis() + s.repeat_ms;
          } else {
            s.active = false;
            is_cleanup = true;
          }
        }
      }
    }
 
    if (is_cleanup) cleanup();
  }
 
 protected:
  Vector<Schedule *> queue;
 
  void cleanup() {
    for (auto it = queue.begin(); it != queue.end(); ++it) {
      auto p_rule = *it;
      if (!(p_rule)->active) {
        DlnaLogger.log(DlnaDebug, "cleanup queue: %s", p_rule->name());
        // remove schedule from collection
        queue.erase(it);
        // delete schedule
        delete p_rule;
        break;
      }
    }
  }
};
 
}  // namespace tiny_dlna