Queue.cpp

#include "../includes/Queue.h"
#include <iostream>

#pragma unmanaged

void EventQueue::clear() {
  std::lock_guard<std::mutex> lock(mutex);
  queue.clear();
}

std::size_t EventQueue::count() {
  std::lock_guard<std::mutex> lock(mutex);
  return queue.size();
}

std::unique_ptr<Event> EventQueue::dequeue() {
  std::lock_guard<std::mutex> lock(mutex);
  if (queue.empty()) {
    return nullptr;
  }

  auto &front = queue.front();
  auto retVal = std::move(front);
  queue.pop_front();

  return retVal;
}

std::unique_ptr<std::vector<std::unique_ptr<Event>>> EventQueue::dequeueAll() {
  std::lock_guard<std::mutex> lock(mutex);
  if (queue.empty()) {
    return nullptr;
  }

  const auto queueSize = queue.size();
  std::unique_ptr<std::vector<std::unique_ptr<Event>>> events(new std::vector<std::unique_ptr<Event>>);
  for (size_t i = 0; i < queueSize; ++i) {
    auto &front = queue.front();
    events->emplace_back(std::move(front));
    queue.pop_front();
  }

  return events;
}

void EventQueue::enqueue(
  const EventType type,
  const std::string &fromDirectory,
  const std::string &fromFile,
  const std::string &toDirectory,
  const std::string &toFile
) {
  if (mPaused) {
    return;
  }
  std::lock_guard<std::mutex> lock(mutex);
  queue.emplace_back(std::unique_ptr<Event>(new Event(type, fromDirectory, fromFile, toDirectory, toFile)));
}

void EventQueue::pause() {
  mPaused = true;
  clear();
}

void EventQueue::resume() {
  mPaused = false;
}

EventQueue::EventQueue():
  mPaused(false)
{}