Method stopServer

app/src/API/GRPC/GRPCServer.cpp:484–513

* @brief Stops the gRPC server and cancels all active streams. */

 * @brief Stops the gRPC server and cancels all active streams.
 */
void API::GRPC::GRPCServer::stopServer()
{
  {
    std::lock_guard<std::mutex> lock(m_frameStreamsMutex);
    for (auto& ctx : m_frameStreams)
      ctx->cancelled.store(true);
  }

  {
    std::lock_guard<std::mutex> lock(m_rawStreamsMutex);
    for (auto& ctx : m_rawStreams)
      ctx->cancelled.store(true);
  }

  m_writerRunning.store(false);
  if (m_writerThread.joinable())
    m_writerThread.join();

  if (m_grpcServer)
    m_grpcServer->Shutdown(std::chrono::system_clock::now() + std::chrono::seconds(3));

  if (m_serverThread.joinable())
    m_serverThread.join();

  m_grpcServer.reset();
  m_service.reset();

  m_clientCount.store(0, std::memory_order_relaxed);
  Q_EMIT clientCountChanged();
}

/**
 * @brief Writes a RawBatch to every active raw stream, marking unwritable streams cancelled.