pipe.h

#pragma once
 
#include <cassert>
#include <memory>
#include <unistd.h>
 
#include "uringpp/error.h"
#include "uringpp/event_loop.h"
namespace uringpp {
 
class pipe {
  std::shared_ptr<event_loop> loop_;
  int fds_[2];
 
public:
  pipe(std::shared_ptr<event_loop> loop) : loop_(loop) {
    check_errno(::pipe(fds_), "failed to create pipe");
    assert(fds_[0] > 0);
    assert(fds_[1] > 0);
  }
 
  pipe(pipe &&other) noexcept
      : loop_(std::move(other.loop_)), fds_{std::exchange(other.fds_[0], -1),
                                            std::exchange(other.fds_[1], -1)} {}
 
  int readable_fd() const {
    assert(fds_[0] > 0);
    return fds_[0];
  }
 
  int writable_fd() const {
    assert(fds_[1] > 0);
    return fds_[1];
  }
 
  task<void> close_read() {
    co_await loop_->close(readable_fd());
    fds_[0] = -1;
  }
 
  task<void> close_write() {
    co_await loop_->close(writable_fd());
    fds_[1] = -1;
  }
 
  task<void> close() {
    if (fds_[0] > 0) {
      co_await loop_->close(fds_[0]);
      fds_[0] = -1;
    }
    if (fds_[1] > 0) {
      co_await loop_->close(fds_[1]);
      fds_[1] = -1;
    }
  }
 
  ~pipe() {
    if (fds_[0] > 0) {
      loop_->close_detach(fds_[0]);
    }
    if (fds_[1] > 0) {
      loop_->close_detach(fds_[1]);
    }
  }
};
 
} // namespace uringpp