dart_runner::DartComponentController Class Reference

Starts a Dart component written in CFv2. More...

#include <dart_component_controller.h>

Inheritance diagram for dart_runner::DartComponentController:

Public Member Functions
	DartComponentController (fuchsia::component::runner::ComponentStartInfo start_info, std::shared_ptr< sys::ServiceDirectory > runner_incoming_services, fidl::InterfaceRequest< fuchsia::component::runner::ComponentController > controller)
	~DartComponentController () override
bool	SetUp ()
void	Run ()

Private Member Functions
void	EchoString (fidl::StringPtr value, EchoStringCallback callback) override
void	Kill () override
void	Stop () override

Detailed Description

Starts a Dart component written in CFv2.

Definition at line 29 of file dart_component_controller.h.

Constructor & Destructor Documentation

DartComponentController()

dart_runner::DartComponentController::DartComponentController	(	fuchsia::component::runner::ComponentStartInfo	start_info,
		std::shared_ptr< sys::ServiceDirectory >	runner_incoming_services,
		fidl::InterfaceRequest< fuchsia::component::runner::ComponentController >	controller
	)

Definition at line 100 of file dart_component_controller.cc.

    : loop_(new async::Loop(&kLoopConfig)),
      label_(GetLabelFromUrl(start_info.resolved_url())),
      url_(start_info.resolved_url()),
      runner_incoming_services_(std::move(runner_incoming_services)),
      dart_outgoing_dir_(new vfs::PseudoDir()),
      start_info_(std::move(start_info)),
      binding_(this, std::move(controller)) {
  binding_.set_error_handler([this](zx_status_t status) { Kill(); });
 
  // TODO(fxb/84537): This data path is configured based how we build Flutter
  // applications in tree currently, but the way we build the Flutter
  // application may change. We should avoid assuming the data path and let the
  // CML file specify this data path instead.
  const std::string component_name = GetComponentNameFromUrl(url_);
  data_path_ = "pkg/data/" + component_name;
 
  zx_status_t idle_timer_status =
      zx::timer::create(ZX_TIMER_SLACK_LATE, ZX_CLOCK_MONOTONIC, &idle_timer_);
  if (idle_timer_status != ZX_OK) {
    FML_LOG(INFO) << "Idle timer creation failed: "
                  << zx_status_get_string(idle_timer_status);
  } else {
    idle_wait_.set_object(idle_timer_.get());
    idle_wait_.set_trigger(ZX_TIMER_SIGNALED);
    idle_wait_.Begin(async_get_default_dispatcher());
  }
 
  // Close the runtime_dir channel if we don't intend to serve it. Otherwise any
  // access to the runtime_dir will hang forever.
  start_info_.clear_runtime_dir();
}

~DartComponentController()

dart_runner::DartComponentController::~DartComponentController ( )

override

Definition at line 137 of file dart_component_controller.cc.

                                                  {
  if (namespace_) {
    fdio_ns_destroy(namespace_);
    namespace_ = nullptr;
  }
  close(stdout_fd_);
  close(stderr_fd_);
}

Member Function Documentation

EchoString()

void dart_runner::DartComponentController::EchoString ( fidl::StringPtr  value, EchoStringCallback  callback  )

overrideprivate

Definition at line 538 of file dart_component_controller.cc.

                                                                      {
  Dart_EnterScope();
 
  Dart_Handle builtin_lib = Dart_LookupLibrary(ToDart("dart:fuchsia.builtin"));
  FML_CHECK(!tonic::CheckAndHandleError(builtin_lib));
 
  Dart_Handle receive_echo_string = ToDart("_receiveEchoString");
  Dart_Handle string_to_echo =
      value.has_value() ? tonic::ToDart(*value) : Dart_Null();
  Dart_Handle result =
      Dart_Invoke(builtin_lib, receive_echo_string, 1, &string_to_echo);
  FML_CHECK(!tonic::CheckAndHandleError(result));
 
  fidl::StringPtr echo_string;
  if (!Dart_IsNull(result)) {
    echo_string = tonic::StdStringFromDart(result);
  }
  callback(std::move(echo_string));
 
  Dart_ExitScope();
}

Kill()

void dart_runner::DartComponentController::Kill ( )

overrideprivate

Definition at line 561 of file dart_component_controller.cc.

                                   {
  if (Dart_CurrentIsolate()) {
    tonic::DartMicrotaskQueue* queue =
        tonic::DartMicrotaskQueue::GetForCurrentThread();
    if (queue) {
      queue->Destroy();
    }
 
    loop_->Quit();
 
    // TODO(rosswang): The docs warn of threading issues if doing this again,
    // but without this, attempting to shut down the isolate finalizes app
    // contexts that can't tell a shutdown is in progress and so fatal.
    Dart_SetMessageNotifyCallback(nullptr);
 
    Dart_ShutdownIsolate();
  }
}

Run()

void dart_runner::DartComponentController::Run

(

)

Runs the Dart component in a task, sending the return code back to the Fuchsia component controller.

This should be called after |SetUp|.

Definition at line 428 of file dart_component_controller.cc.

                                  {
  async::PostTask(loop_->dispatcher(), [loop = loop_.get(), app = this] {
    if (!app->RunDartMain()) {
      loop->Quit();
    }
  });
  loop_->Run();
 
  if (binding_.is_bound()) {
    // From the documentation for ComponentController, ZX_OK should be sent when
    // the ComponentController receives a termination request. However, if the
    // component exited with a non-zero return code, we indicate this by sending
    // an INTERNAL epitaph instead.
    //
    // TODO(fxb/86666): Communicate return code from the ComponentController
    // once v2 has support.
    if (return_code_ == 0) {
      binding_.Close(ZX_OK);
    } else {
      FML_LOG(ERROR) << "Component exited with non-zero return code: "
                     << return_code_;
      binding_.Close(zx_status_t(fuchsia::component::Error::INTERNAL));
    }
  }
}

SetUp()

bool dart_runner::DartComponentController::SetUp

(

)

Sets up the controller.

This should be called before |Run|.

Definition at line 146 of file dart_component_controller.cc.

                                    {
  // Name the thread after the url of the component being launched.
  zx::thread::self()->set_property(ZX_PROP_NAME, label_.c_str(), label_.size());
  Dart_SetThreadName(label_.c_str());
 
  if (!CreateAndBindNamespace()) {
    return false;
  }
 
  if (SetUpFromAppSnapshot()) {
    FML_LOG(INFO) << url_ << " is running from an app snapshot";
  } else if (SetUpFromKernel()) {
    FML_LOG(INFO) << url_ << " is running from kernel";
  } else {
    FML_LOG(ERROR) << "Failed to set up component controller for " << url_;
    return false;
  }
 
  return true;
}

Stop()

void dart_runner::DartComponentController::Stop ( )

overrideprivate

Definition at line 580 of file dart_component_controller.cc.

                                   {
  Kill();
}

---

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

• shell/platform/fuchsia/dart_runner/dart_component_controller.h
• shell/platform/fuchsia/dart_runner/dart_component_controller.cc