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

    DISABLE_COPY_AND_MOVE(EPollPoller);

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

    void requestStop() noexcept;

    void stop();

    void wake();

    bool isRunning() const noexcept { return _isRunnning.load(std::memory_order::acquire); }
 
private:
    FdDatas::iterator _getFdData(BorrowedFd fd) noexcept;
    FdDatas::const_iterator _getFdData(BorrowedFd fd) const noexcept;
 
private:
    std::atomic_bool _shouldContinue{false};
    std::atomic_bool _isRunnning{false};
 
private:
    OwnedFd _epfd;
    OwnedFd _eventFd;
 
    std::queue<Callback> _deferedCb;
    FdDatas _fdData;
};
} // !namespace dfx::FdWatch