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;
        }
      }
    }
  }