mirror of
https://github.com/encounter/engine.git
synced 2026-03-30 11:09:55 -07:00
Adam Barth
9878b58878
After this patch, we're able to run spinning_square on Fuchsia. I've left some TODO comments about some shortcuts I've taken that we'll need to improve in the future.
78 lines
2.6 KiB
C++
78 lines
2.6 KiB
C++
// Copyright 2016 The Chromium Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style license that can be
|
|
// found in the LICENSE file.
|
|
|
|
#include "flutter/content_handler/application_impl.h"
|
|
|
|
#include <utility>
|
|
|
|
#include "apps/dart_content_handler/zip/unzipper.h"
|
|
#include "flutter/content_handler/runtime_holder.h"
|
|
#include "lib/ftl/logging.h"
|
|
#include "lib/mtl/data_pipe/vector.h"
|
|
#include "mojo/public/cpp/application/connect.h"
|
|
|
|
namespace flutter_content_handler {
|
|
namespace {
|
|
|
|
constexpr char kSnapshotKey[] = "snapshot_blob.bin";
|
|
|
|
std::vector<char> ExtractSnapshot(std::vector<char> bundle) {
|
|
zip::Unzipper unzipper(std::move(bundle));
|
|
return unzipper.Extract(kSnapshotKey);
|
|
}
|
|
|
|
} // namespace
|
|
|
|
ApplicationImpl::ApplicationImpl(
|
|
mojo::InterfaceRequest<mojo::Application> application,
|
|
mojo::URLResponsePtr response)
|
|
: binding_(this, std::move(application)) {
|
|
// TODO(abarth): Currently we block the UI thread to drain the response body,
|
|
// but we should do that work asynchronously instead. However, there when I
|
|
// tried draining the data pipe asynchronously, the drain didn't complete.
|
|
// We'll need to investigate why in more detail.
|
|
std::vector<char> bundle;
|
|
bool result = mtl::BlockingCopyToVector(std::move(response->body), &bundle);
|
|
if (!result) {
|
|
FTL_LOG(ERROR) << "Failed to receive bundle.";
|
|
return;
|
|
}
|
|
snapshot_ = ExtractSnapshot(std::move(bundle));
|
|
// TODO(abarth): In principle, we should call StartRuntimeIfReady() here but
|
|
// because we're draining the data pipe synchronously, we know that we can't
|
|
// possibly be ready yet because we haven't received the Initialize() message.
|
|
}
|
|
|
|
ApplicationImpl::~ApplicationImpl() {}
|
|
|
|
void ApplicationImpl::Initialize(mojo::InterfaceHandle<mojo::Shell> shell,
|
|
mojo::Array<mojo::String> args,
|
|
const mojo::String& url) {
|
|
shell_ = mojo::ShellPtr::Create(shell.Pass());
|
|
url_ = url;
|
|
mojo::ApplicationConnectorPtr connector;
|
|
shell_->CreateApplicationConnector(mojo::GetProxy(&connector));
|
|
runtime_holder_.reset(new RuntimeHolder());
|
|
runtime_holder_->Init(std::move(connector));
|
|
StartRuntimeIfReady();
|
|
}
|
|
|
|
void ApplicationImpl::AcceptConnection(
|
|
const mojo::String& requestor_url,
|
|
const mojo::String& resolved_url,
|
|
mojo::InterfaceRequest<mojo::ServiceProvider> services) {}
|
|
|
|
void ApplicationImpl::RequestQuit() {
|
|
binding_.Close();
|
|
delete this;
|
|
}
|
|
|
|
void ApplicationImpl::StartRuntimeIfReady() {
|
|
if (!runtime_holder_ || snapshot_.empty())
|
|
return;
|
|
runtime_holder_->Run(url_, std::move(snapshot_));
|
|
}
|
|
|
|
} // namespace flutter_content_handler
|