MqCommon.hpp

// SPDX-FileCopyrightText: 2026 Vincent Leroy
// SPDX-License-Identifier: MIT
//
// This file is part of dfx.
//
// Licensed under the MIT License. See the LICENSE file in the project root
// for full license information.
 
#pragma once
 
// Standard includes
#include <optional>
#include <mqueue.h>
 
// Third-party includes
#include <nlohmann/json.hpp>
 
// Project includes
#include <dfx-utilities/OwnedFd.hpp>
 
namespace dfx::Core::MqCommon
{
struct OpenAttr
{
    std::optional<long> maxMessage;
    std::optional<long> maxMessageSize;
 
    bool hasAnyValueSet() const noexcept;
    mq_attr toMqAttr() const noexcept;
};
 
void validateConfig(nlohmann::json const & config);
 
void fillMqAttrWithConfig(OpenAttr & attr, nlohmann::json const & config);
[[noreturn]] void onMqOpenFail(std::string_view addrUsed, OpenAttr const & attrUsed, int err);
 
Utils::OwnedFd openMq(std::string const & addr, int flags, nlohmann::json const & config);
} // !namespace dfx::Core::MqCommon