EPollPoller.hpp

// SPDX-FileCopyrightText: 2025-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 <queue>
#include <vector>
 
// Project includes
#include "Poller.hpp"
#include <dfx-utilities/CopyMoveControl.hpp>
#include <dfx-utilities/OwnedFd.hpp>
 
namespace dfx::FdWatch
{
class EPollPoller : public Poller
{
    struct FdData
    {
        Utils::BorrowedFd fd;
        FdCallback cb;
    };
 
    using FdDatas = std::vector<FdData>;
 
public:
    EPollPoller();

    DFX_DISABLE_COPY_AND_MOVE(EPollPoller);
 
public:
    void registerFd(Utils::BorrowedFd fd, EventInterests events, FdCallback cb) override;
    void deregisterFd(Utils::BorrowedFd fd) noexcept override;
    void updateFdEvents(Utils::BorrowedFd fd, EventInterests events) override;
    void deferCall(Callback cb) override;
 
public:
    void exec();

    void exec(std::stop_token stopToken);

    void requestStop() noexcept;

    void stop();

    void wake();

    bool isRunning() const noexcept { return _isRunnning; }
 
private:
    void _execImpl(std::stop_token stopToken);
 
    FdDatas::iterator _getFdData(Utils::BorrowedFd fd) noexcept;
    FdDatas::const_iterator _getFdData(Utils::BorrowedFd fd) const noexcept;
 
private:
    std::stop_source _stopSource;
    bool _isRunnning = false;
 
private:
    Utils::OwnedFd _epfd;
    Utils::OwnedFd _eventFd;
 
    std::queue<Callback> _deferedCb;
    FdDatas _fdData;
};
} // !namespace dfx::FdWatch