notifier.hpp

#pragma once
 
#include <coroio/corochain.hpp>
 
#include <atomic>
 
namespace NNet {
 
#ifndef _WIN32

class TNotifier {
public:
    explicit TNotifier(TPollerBase& poller);
    ~TNotifier();
 
    TNotifier(const TNotifier&) = delete;
    TNotifier& operator=(const TNotifier&) = delete;

    void Notify();

    TFuture<void> Wait();
 
private:
    bool TryRead();
 
    TPollerBase& Poller_;
    int ReadFd_ = -1;
    int WriteFd_ = -1;
    std::atomic<bool> Pending_ = false;
    bool Waiting_ = false;
};
 
#endif // _WIN32
 
} // namespace NNet