monitor-fd.hh

#pragma once
 
#include <thread>
#include <atomic>
 
#include <poll.h>
#include <sys/types.h>
#include <unistd.h>
 
#include "lix/libutil/error.hh"
#include "lix/libutil/file-descriptor.hh"
#include "lix/libutil/signals.hh"
#include "lix/libutil/thread-name.hh"
 
namespace nix {

class MonitorFdHup
{
private:
    std::thread thread;
    Pipe terminatePipe;
    std::atomic_bool quit = false;
    std::function<void()> callback;
 
    void runThread(int watchFd, int terminateFd);
 
public:
    MonitorFdHup(int fd, std::function<void()> callback = nix::triggerInterrupt);
 
    ~MonitorFdHup();
};
 
 
}