#pragma once

#include "public.h"

#include <util/system/platform.h>

#ifdef _win_
    #include <util/system/pipe.h>
#endif

namespace NYT::NThreading {

////////////////////////////////////////////////////////////////////////////////

//! Provides a handle which can be used to wake up a polling thread.
/*!
 *  Internally implemented via |eventfd| API (for Linux) or pipes (for all other platforms).
 */
class TNotificationHandle
{
public:
    explicit TNotificationHandle(bool blocking = false);
    ~TNotificationHandle();

    //! Called from an arbitrary thread to wake up the polling thread.
    //! Multiple wakeups are coalesced.
    void Raise();

    //! Called from the polling thread to clear all outstanding notification.
    void Clear();

    //! Returns the pollable handle, which becomes readable when #Raise is invoked.
    int GetFD() const;

private:
#ifdef _linux_
    int EventFD_ = -1;
#elif defined(_win_)
    TPipeHandle Reader_;
    TPipeHandle Writer_;
#else
    int PipeFDs_[2] = {-1, -1};
#endif

};

////////////////////////////////////////////////////////////////////////////////

} // namespace NYT::NThreading