monitoring_main.cpp

#include "include/monitoring/api.hpp"
#include "monitoring/api.hpp"
#include "monitoring/macros.hpp"

#include <chrono>
#include <iostream>
#include <thread>

// using namespace monitor;
using namespace std::chrono_literals;

void handler(monitor::checkpoint &check) {
  (void)check;
  std::cout << "HANDLER CALLED" << std::endl;
}

void work1() {
  monitor::start_this_thread_monitoring();
  monitor::set_this_thread_handler(handler);

  // NOTE: deadlines are monotonic (reasonable assumption?)
  monitor::expect_progress_in(2000ms, 42, THIS_SOURCE_LOCATION);
  monitor::expect_progress_in(1000ms, 73, THIS_SOURCE_LOCATION);
  monitor::expect_progress_in(100ms, 21, THIS_SOURCE_LOCATION);

  std::this_thread::sleep_for(3s);
  std::this_thread::sleep_for(1ms);

  monitor::confirm_progress(THIS_SOURCE_LOCATION);
  monitor::confirm_progress(THIS_SOURCE_LOCATION);
  monitor::confirm_progress(THIS_SOURCE_LOCATION);

  monitor::stop_this_thread_monitoring();
}

void work2() {
  START_THIS_THREAD_MONITORING;
  SET_MONITORING_HANDLER(handler);
  UNSET_MONITORING_HANDLER;

  EXPECT_PROGRESS_IN(500ms, 66);

  std::this_thread::sleep_for(2s);
  std::this_thread::sleep_for(1ms);

  CONFIRM_PROGRESS;

  STOP_THIS_THREAD_MONITORING;
}

int main(void) {

  START_ACTIVE_MONITORING(50ms);

  std::this_thread::sleep_for(100ms);

  std::thread t1(&work1);
  std::thread t2(&work2);
  // std::thread t3(&work2);
  t1.join();
  t2.join();
  // t3.join();

  STOP_ACTIVE_MONITORING;

  monitor::print_stats();

  return EXIT_SUCCESS;
}