FdListener.hpp

// SPDX-FileCopyrightText: 2025 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 <atomic>
#include <functional>
#include <thread>
 
// Project includes
#include <dfx-fdwatch/BorrowedFd.hpp>
#include <dfx-fdwatch/Events.hpp>
#include <dfx-fdwatch/OwnedFd.hpp>
 
namespace dfx::Runtime
{
class FdListener
{
public:
    using Callback = std::move_only_function<void (FdWatch::BorrowedFd, FdWatch::EventTriggers)>;
 
public:
    FdListener(Callback cb);

    ~FdListener();

    bool isRunning() const noexcept { return _running.load(std::memory_order::relaxed); }

    void registerFd(FdWatch::BorrowedFd fd, FdWatch::EventInterests events);

    void deregisterFd(FdWatch::BorrowedFd fd) noexcept;
 
private:
    void _start();
    void _stop();
 
    void _init();
    void _listen(std::stop_token stopToken) noexcept;
    void _cleanup() noexcept;
 
private:
    FdWatch::OwnedFd _epfd;
    FdWatch::OwnedFd _evtfd;
    Callback _cb;
 
private:
    std::atomic_bool _running{false};
    std::jthread     _listener;
};
} // !namespace dfx::Runtime