libxr_pipe.hpp

Go to the documentation of this file.

#pragma once
 
#include "libxr_def.hpp"
#include "libxr_rw.hpp"
 
namespace LibXR
{
 
class Pipe
{
 public:
  explicit Pipe(size_t buffer_size) : read_port_(0), write_port_(0, buffer_size)
  {
    ASSERT(write_port_.queue_data_ != nullptr);
    read_port_.BindQueue(write_port_.queue_data_);
    write_port_ = &WriteFun;
  }
 
  ~Pipe() = default;
 
  Pipe(const Pipe&) = delete;
  Pipe& operator=(const Pipe&) = delete;
 
  ReadPort& GetReadPort() { return read_port_; }
 
  WritePort& GetWritePort() { return write_port_; }
 
 private:
  static void WriteFun(WritePort& port, bool in_isr)
  {
    auto* pipe = LibXR::ContainerOf(&port, &Pipe::write_port_);
    pipe->read_port_.NotifyDataAvailable(in_isr);
  }
 
  ReadPort read_port_;    
  WritePort write_port_;  
};
 
}  // namespace LibXR