#include <engine.h>

Inheritance diagram for flutter_runner::Engine:

Classes
class	Delegate

Public Member Functions
	Engine (Delegate &delegate, std::string thread_label, std::shared_ptr< sys::ServiceDirectory > svc, std::shared_ptr< sys::ServiceDirectory > runner_services, flutter::Settings settings, fuchsia::ui::views::ViewCreationToken view_creation_token, std::pair< fuchsia::ui::views::ViewRefControl, fuchsia::ui::views::ViewRef > view_ref_pair, UniqueFDIONS fdio_ns, fidl::InterfaceRequest< fuchsia::io::Directory > directory_request, FlutterRunnerProductConfiguration product_config, const std::vector< std::string > &dart_entrypoint_args)

	~Engine ()

std::optional< uint32_t >	GetEngineReturnCode () const

void	WriteProfileToTrace () const

Static Public Member Functions
static flutter::ThreadHost	CreateThreadHost (const std::string &name_prefix, const std::shared_ptr< sys::ServiceDirectory > &runner_services=nullptr)

Private Member Functions
void	OnLevelChanged (fuchsia::memorypressure::Level level, fuchsia::memorypressure::Watcher::OnLevelChangedCallback callback) override

Friends
class	testing::EngineTest

Detailed Description

Definition at line 39 of file engine.h.

Constructor & Destructor Documentation

◆ Engine()

flutter_runner::Engine::Engine	(	Delegate &	delegate,
		std::string	thread_label,
		std::shared_ptr< sys::ServiceDirectory >	svc,
		std::shared_ptr< sys::ServiceDirectory >	runner_services,
		flutter::Settings	settings,
		fuchsia::ui::views::ViewCreationToken	view_creation_token,
		std::pair< fuchsia::ui::views::ViewRefControl, fuchsia::ui::views::ViewRef >	view_ref_pair,
		UniqueFDIONS	fdio_ns,
		fidl::InterfaceRequest< fuchsia::io::Directory >	directory_request,
		FlutterRunnerProductConfiguration	product_config,
		const std::vector< std::string > &	dart_entrypoint_args
	)

Definition at line 202 of file engine.cc.

    : delegate_(delegate),
      thread_label_(std::move(thread_label)),
      thread_host_(CreateThreadHost(thread_label_, runner_services)),
      view_creation_token_(std::move(view_creation_token)),
      memory_pressure_watcher_binding_(this),
      latest_memory_pressure_level_(fuchsia::memorypressure::Level::NORMAL),
      intercept_all_input_(product_config.get_intercept_all_input()),
      weak_factory_(this) {
  Initialize(std::move(view_ref_pair), std::move(svc),
             std::move(runner_services), std::move(settings),
             std::move(fdio_ns), std::move(directory_request),
             std::move(product_config), dart_entrypoint_args);
}

◆ ~Engine()

flutter_runner::Engine::~Engine ( )

Definition at line 694 of file engine.cc.

                {
  shell_.reset();
 
  // Destroy rendering objects on the raster thread.
  fml::AutoResetWaitableEvent view_embedder_latch;
  thread_host_.raster_thread->GetTaskRunner()->PostTask(
      fml::MakeCopyable([this, &view_embedder_latch]() mutable {
        view_embedder_.reset();
        flatland_connection_.reset();
        surface_producer_.reset();
        view_embedder_latch.Signal();
      }));
  view_embedder_latch.Wait();
}

Member Function Documentation

◆ CreateThreadHost()

flutter::ThreadHost flutter_runner::Engine::CreateThreadHost	(	const std::string &	name_prefix,
		const std::shared_ptr< sys::ServiceDirectory > &	runner_services = `nullptr`
	)

static

Definition at line 136 of file engine.cc.

                                                        {
  fml::Thread::SetCurrentThreadName(
      fml::Thread::ThreadConfig(name_prefix + ".platform"));
 
  // Default the config setter to setup the thread name only.
  flutter::ThreadConfigSetter config_setter = fml::Thread::SetCurrentThreadName;
 
  // Override the config setter if the media profile provider is available.
  if (services) {
    // Connect to the media profile provider to assign thread priorities using
    // Fuchsia's scheduler role API. Failure to connect will print a warning and
    // proceed with engine initialization, leaving threads created by the engine
    // at default priority.
    //
    // The use of std::shared_ptr here is to work around the unfortunate
    // requirement for flutter::ThreadConfigSetter (i.e. std::function<>) that
    // the target callable be copy-constructible. This awkwardly conflicts with
    // fuchsia::media::ProfileProviderSyncPtr being move-only. std::shared_ptr
    // provides copyable object that references the move-only SyncPtr.
    std::shared_ptr<fuchsia::media::ProfileProviderSyncPtr>
        media_profile_provider =
            std::make_shared<fuchsia::media::ProfileProviderSyncPtr>();
 
    const zx_status_t connect_status =
        services->Connect(media_profile_provider->NewRequest());
    if (connect_status != ZX_OK) {
      FML_LOG(WARNING)
          << "Failed to connect to " << fuchsia::media::ProfileProvider::Name_
          << ": " << zx_status_get_string(connect_status)
          << " This is not a fatal error, but threads created by the engine "
             "will run at default priority, regardless of the requested "
             "priority.";
    } else {
      // Set the role for (this) platform thread. See comment above about the
      // role naming scheme.
      SetThreadRole(*media_profile_provider, name_prefix + ".type.platform");
 
      // This lambda must be copyable or the assignment fails to compile,
      // necessitating the use of std::shared_ptr for the profile provider.
      config_setter = [name_prefix, media_profile_provider](
                          const fml::Thread::ThreadConfig& config) {
        SetThreadConfig(name_prefix, *media_profile_provider, config);
      };
    }
  }
 
  flutter::ThreadHost::ThreadHostConfig thread_host_config{config_setter};
 
  thread_host_config.SetRasterConfig(
      {flutter::ThreadHost::ThreadHostConfig::MakeThreadName(
           flutter::ThreadHost::Type::kRaster, name_prefix),
       fml::Thread::ThreadPriority::kRaster});
  thread_host_config.SetUIConfig(
      {flutter::ThreadHost::ThreadHostConfig::MakeThreadName(
           flutter::ThreadHost::Type::kUi, name_prefix),
       fml::Thread::ThreadPriority::kDisplay});
  thread_host_config.SetIOConfig(
      {flutter::ThreadHost::ThreadHostConfig::MakeThreadName(
           flutter::ThreadHost::Type::kIo, name_prefix),
       fml::Thread::ThreadPriority::kNormal});
 
  return flutter::ThreadHost(thread_host_config);
}

◆ GetEngineReturnCode()

std::optional< uint32_t > flutter_runner::Engine::GetEngineReturnCode ( ) const

Definition at line 709 of file engine.cc.

                                                        {
  if (!shell_) {
    return std::nullopt;
  }
  std::optional<uint32_t> code;
  fml::AutoResetWaitableEvent latch;
  fml::TaskRunner::RunNowOrPostTask(
      shell_->GetTaskRunners().GetUITaskRunner(),
      [&latch, &code, engine = shell_->GetEngine()]() {
        if (engine) {
          code = engine->GetUIIsolateReturnCode();
        }
        latch.Signal();
      });
  latch.Wait();
  return code;
}

◆ OnLevelChanged()

void flutter_runner::Engine::OnLevelChanged	(	fuchsia::memorypressure::Level	level,
		fuchsia::memorypressure::Watcher::OnLevelChangedCallback	callback
	)

overrideprivate

Definition at line 962 of file engine.cc.

                                                                 {
  // The callback must be invoked immediately to acknowledge the message.
  // This is the "Throttle push using acknowledgements" pattern:
  // https://fuchsia.dev/fuchsia-src/concepts/api/fidl#throttle_push_using_acknowledgements
  callback();
 
  FML_LOG(WARNING) << "memorypressure watcher: OnLevelChanged from "
                   << static_cast<int>(latest_memory_pressure_level_) << " to "
                   << static_cast<int>(level);
 
  if (latest_memory_pressure_level_ == fuchsia::memorypressure::Level::NORMAL &&
      (level == fuchsia::memorypressure::Level::WARNING ||
       level == fuchsia::memorypressure::Level::CRITICAL)) {
    FML_LOG(WARNING)
        << "memorypressure watcher: notifying Flutter that memory is low";
    shell_->NotifyLowMemoryWarning();
  }
  latest_memory_pressure_level_ = level;
}

◆ WriteProfileToTrace()

void flutter_runner::Engine::WriteProfileToTrace ( ) const

Definition at line 807 of file engine.cc.

                                       {
  Dart_Port main_port = shell_->GetEngine()->GetUIIsolateMainPort();
  char* error = NULL;
  bool success = Dart_WriteProfileToTimeline(main_port, &error);
  if (!success) {
    FML_LOG(ERROR) << "Failed to write Dart profile to trace: " << error;
    free(error);
  }
}

Friends And Related Symbol Documentation

◆ testing::EngineTest

friend class testing::EngineTest

friend

Definition at line 149 of file engine.h.

The documentation for this class was generated from the following files:

shell/platform/fuchsia/flutter/engine.h
shell/platform/fuchsia/flutter/engine.cc

Classes

Public Member Functions

Static Public Member Functions

Private Member Functions

Friends