Method writerLoop

src/loggers/bt_sqlite_logger.cpp:210–246

}

void SqliteLogger::writerLoop()
{
  std::deque<Transition> transitions;

  // Signal readiness while holding the lock (establishes happens-before with constructor)
  {
    std::scoped_lock lk(queue_mutex_);
    writer_ready_.store(true, std::memory_order_release);
  }
  queue_cv_.notify_one();

  while(loop_)
  {
    transitions.clear();
    {
      std::unique_lock lk(queue_mutex_);
      queue_cv_.wait(lk, [this]() { return !transitions_queue_.empty() || !loop_; });
      std::swap(transitions, transitions_queue_);
    }

    while(!transitions.empty())
    {
      auto const trans = transitions.front();
      transitions.pop_front();

      sqlite3_stmt* stmt = prepareStatement(db_, "INSERT INTO Transitions VALUES (?, ?, "
                                                 "?, ?, ?, ?)");
      sqlite3_bind_int64(stmt, 1, trans.timestamp);
      sqlite3_bind_int(stmt, 2, session_id_);
      sqlite3_bind_int(stmt, 3, trans.node_uid);
      sqlite3_bind_int64(stmt, 4, trans.duration);
      sqlite3_bind_int(stmt, 5, static_cast<int>(trans.status));
      sqlite3_bind_text(stmt, 6, trans.extra_data.c_str(), -1, SQLITE_TRANSIENT);
      execStatement(stmt);
    }
  }
}

void BT::SqliteLogger::flush()
{