Method startServer

app/src/API/GRPC/GRPCServer.cpp:453–479

* @brief Starts the gRPC server on a background thread. */

 * @brief Starts the gRPC server on a background thread.
 */
void API::GRPC::GRPCServer::startServer()
{
  const bool external = API::Server::instance().externalConnections();
  const auto address  = external ? QStringLiteral("0.0.0.0:%1").arg(API_GRPC_PORT)
                                 : QStringLiteral("127.0.0.1:%1").arg(API_GRPC_PORT);

  (void)API::CommandHandler::instance();

  m_service = std::make_unique<SerialStudioServiceImpl>(this);
  grpc::ServerBuilder builder;
  builder.AddListeningPort(address.toStdString(), grpc::InsecureServerCredentials());
  builder.RegisterService(m_service.get());

  m_grpcServer = builder.BuildAndStart();
  if (!m_grpcServer) {
    m_service.reset();
    Misc::Utilities::showMessageBox(tr("Unable to start gRPC server"),
                                    tr("Failed to bind to %1").arg(address),
                                    QMessageBox::Warning);
    return;
  }

  m_serverThread = std::thread([this]() { m_grpcServer->Wait(); });

  m_writerRunning.store(true);
  m_writerThread = std::thread([this]() { writerLoop(); });
}

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