Method hotpathTxFrame

app/src/DataModel/FrameBuilder.cpp:1853–1889

* @brief Publishes a fully constructed DataModel frame to all registered output modules. The * dashboard draws the pooled slot directly; async sinks (gated on the cached m_anyAsyncSink * flag) get one detached copy so a slow-export backlog can never pin the pool. */

 *        flag) get one detached copy so a slow-export backlog can never pin the pool.
 */
void DataModel::FrameBuilder::hotpathTxFrame(const DataModel::TimestampedFramePtr& frame)
{
  Q_ASSERT(frame);
  Q_ASSERT(!frame->data.groups.empty());
  Q_ASSERT(!frame->data.title.isEmpty());

  static auto& dashboard = UI::Dashboard::instance();
  dashboard.hotpathRxFrame(frame);

  if (!m_anyAsyncSink)
    return;

  static auto& csvExport     = CSV::Export::instance();
  static auto& mdf4Export    = MDF4::Export::instance();
  static auto& pluginsServer = API::Server::instance();
#ifdef BUILD_COMMERCIAL
  static auto& sqliteExport  = Sessions::Export::instance();
  static auto& mqttPublisher = MQTT::Publisher::instance();
#endif
#ifdef ENABLE_GRPC
  static auto& grpcServer = API::GRPC::GRPCServer::instance();
#endif

  const auto detached =
    std::make_shared<DataModel::TimestampedFrame>(frame->data, frame->timestamp);

  csvExport.hotpathTxFrame(detached);
  mdf4Export.hotpathTxFrame(detached);
  pluginsServer.hotpathTxFrame(detached);
#ifdef BUILD_COMMERCIAL
  sqliteExport.hotpathTxFrame(detached);
  mqttPublisher.hotpathTxFrame(detached);
#endif
#ifdef ENABLE_GRPC
  grpcServer.hotpathTxFrame(detached);
#endif
}

//--------------------------------------------------------------------------------------------------
// Per-dataset value transforms