Memlock.cpp

// Copyright Mihai Preda.

#include "Memlock.h"
#include "File.h"
#include "common.h"
#include "Signal.h"

#include <thread>
#include <chrono>

namespace {

error_code& noThrow() {
  static error_code dummy;
  return dummy;
}

}

Memlock::Memlock(fs::path base, u32 device) : lock{base / ("memlock-"s + to_string(device))} {
  if (!fs::create_directory(lock, noThrow())) {
    log("Waiting for memory lock '%s'\n", lock.string().c_str());
    Signal signal;
    do {
      std::this_thread::sleep_for(std::chrono::seconds(5));
      if (signal.stopRequested()) { throw "stop requested"; }
    } while (!fs::create_directory(lock, noThrow()));
  }
  
  log("Acquired memory lock '%s'\n", lock.string().c_str());
}

Memlock::~Memlock() {
  fs::remove(lock, noThrow());
  log("Released memory lock '%s'\n", lock.string().c_str());
}