driver.hpp

 
static void ThreadFun(Terminal* term)
{
  Semaphore read_sem, write_sem;
  ReadOperation op(read_sem);
 
  term->write_op_ = WriteOperation(write_sem, 10);
 
  while (true)
  {
    term->request_read_size_ = LibXR::min(term->read_port_->Size(), READ_BUFF_SIZE);
    auto buffer = RawData(term->read_buff_, term->request_read_size_);
 
    if ((*term->read_port_)(buffer, op) == ErrorCode::OK && term->request_read_size_ > 0)
    {
      term->write_mutex_->Lock();
      term->Parse(buffer);
      term->write_stream_.Commit();
      term->write_mutex_->Unlock();
    }
  }
}
 
static void TaskFun(Terminal* term)
{
  ReadOperation op(term->read_status_);
 
  auto start_read = [&]()
  {
    term->request_read_size_ =
        LibXR::min(LibXR::max(1u, term->read_port_->Size()), READ_BUFF_SIZE);
    auto buffer = RawData(term->read_buff_, term->request_read_size_);
    (*term->read_port_)(buffer, op);
  };
 
  while (true)
  {
    switch (term->read_status_)
    {
      case ReadOperation::OperationPollingStatus::READY:
      {
        term->request_read_size_ =
            LibXR::min(LibXR::max(1u, term->read_port_->Size()), READ_BUFF_SIZE);
        auto buffer = RawData(term->read_buff_, term->request_read_size_);
        (*term->read_port_)(buffer, op);
        continue;
      }
      case ReadOperation::OperationPollingStatus::RUNNING:
        return;
      case ReadOperation::OperationPollingStatus::DONE:
      {
        term->write_mutex_->Lock();
        auto buffer = RawData(term->read_buff_, term->request_read_size_);
        term->Parse(buffer);
        term->write_stream_.Commit();
        term->write_mutex_->Unlock();
        start_read();
        return;
      }
      case ReadOperation::OperationPollingStatus::ERROR:
      {
        start_read();
        return;
      }
    }
  }
}