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:
  Pipe(size_t buffer_size) : read_port_(0), write_port_(1, buffer_size)
  {
    // 绑定回调并共享同一数据队列。
    // Bind callbacks and share the same data queue.
    read_port_.read_fun_ = ReadFun;
    write_port_.write_fun_ = WriteFun;
    read_port_.queue_data_ = write_port_.queue_data_;
  }
 
  ~Pipe() {}
 
  Pipe(const Pipe&) = delete;
 
  Pipe& operator=(const Pipe&) = delete;
 
  ReadPort& GetReadPort() { return read_port_; }
 
  WritePort& GetWritePort() { return write_port_; }
 
 private:
  static ErrorCode ReadFun(ReadPort&, bool) { return ErrorCode::PENDING; }
 
  static ErrorCode WriteFun(WritePort& port, bool in_isr)
  {
    Pipe* pipe = CONTAINER_OF(&port, Pipe, write_port_);
    WriteInfoBlock info;
    if (port.queue_info_->Pop(info) != ErrorCode::OK)
    {
      ASSERT(false);
      return ErrorCode::EMPTY;
    }
 
    // 推动读端从共享队列中取数。
    // Drive the reader to consume from the shared queue.
    pipe->read_port_.ProcessPendingReads(in_isr);
 
    return ErrorCode::OK;
  }
 
  ReadPort read_port_;    
  WritePort write_port_;  
};
}  // namespace LibXR