Method processMultiSourcePayload

app/src/IO/ConnectionManager.cpp:555–579

* @brief Injects per-source payloads for multi-source playback. */

 * @brief Injects per-source payloads for multi-source playback.
 */
void IO::ConnectionManager::processMultiSourcePayload(const QByteArray& fullPayload,
                                                      const QMap<int, QByteArray>& sourcePayloads)
{
  Q_ASSERT(!fullPayload.isEmpty());
  Q_ASSERT(!sourcePayloads.isEmpty());

  if (fullPayload.isEmpty())
    return;

  static auto& console      = Console::Handler::instance();
  static auto& server       = API::Server::instance();
  static auto& frameBuilder = DataModel::FrameBuilder::instance();

  const auto captured = makeCapturedData(fullPayload);
  server.hotpathTxData(captured->data);
  console.hotpathRxData(captured->data);

  for (auto it = sourcePayloads.constBegin(); it != sourcePayloads.constEnd(); ++it)
    frameBuilder.hotpathRxSourceFrame(it.key(), makeCapturedData(it.value(), captured->timestamp));

#ifdef ENABLE_GRPC
  static auto& grpcServer = API::GRPC::GRPCServer::instance();
  grpcServer.hotpathTxData(captured->data);
#endif
}

/**
 * @brief Writes @p data to device 0.