Daemon.h

Go to the documentation of this file.

/*
 * Copyright (c) 2026 MQSS Maintainers
 * All rights reserved.
 *
 * SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
 */

 
#pragma once
 
#include "qrmci/BackendRegistry.h"
#include "qrmci/Config.h"
#include "qrmci/Error.h"
#include "qrmci/PublicationThrottle.h"
#include "scheduler/scheduler.hpp"
 
#include <MQSSCIInterfaces/MQSSCompiler.h>
#include <atomic>
#include <csignal>
#include <expected>
#include <mqss/submitter/Device.h>
#include <optional>
#include <string_view>
 
namespace mqss::qrmci {

using TaskScheduler = mqss::scheduler::Scheduler<mqss::QuantumTask>;

inline constinit std::atomic<bool> terminationRequested{false};
static_assert(std::atomic<bool>::is_always_lock_free);

inline void installTerminationHandlers() {
  const auto handler = [](int signal) {
    if (signal == SIGINT || signal == SIGTERM) {
      terminationRequested.store(true, std::memory_order_relaxed);
    }
  };
  std::signal(SIGINT, handler);
  std::signal(SIGTERM, handler);
}

[[nodiscard]] std::expected<Config, Error> initializeDaemon();

[[nodiscard]] std::expected<mqss::submitter::Device, Error>
openConfiguredDevice(const SubmitterConfig &config);

[[nodiscard]] std::expected<void, Error>
registerOwnDevice(const mqss::submitter::Device &device,
                  BackendRegistry &backends,
                  std::string_view dispatchQueue = "");

std::optional<mqss::Backend>
refreshOwnDeviceStatus(const mqss::submitter::Device &device,
                       BackendRegistry &backends, PublicationThrottle &throttle,
                       std::string_view dispatchQueue = "");

void logRegisteredBackends(const BackendRegistry &backends);

[[nodiscard]] std::expected<void, Error> selectCompileAndSchedule(
    mqss::QuantumTask &task, const BackendRegistry &backends,
    mqss::mqssci::MQSSCompiler &compiler, TaskScheduler &scheduler,
    BackendSelectionPolicy policy = BackendSelectionPolicy::LowestName);

[[nodiscard]] std::expected<void, Error>
compileAndSchedule(mqss::QuantumTask &task, const BackendRegistry &backends,
                   mqss::mqssci::MQSSCompiler &compiler,
                   TaskScheduler &scheduler);
 
} // namespace mqss::qrmci