| // Copyright 2016 The Fuchsia 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 <fuchsia/media/cpp/fidl.h> |
| #include <fuchsia/media/playback/cpp/fidl.h> |
| #include <lib/async-loop/cpp/loop.h> |
| #include <lib/async-loop/default.h> |
| #include <lib/async/cpp/task.h> |
| #include <lib/sys/cpp/component_context.h> |
| #include <lib/sys/cpp/service_directory.h> |
| #include <lib/syslog/cpp/log_settings.h> |
| #include <lib/trace-provider/provider.h> |
| |
| #include <string> |
| |
| #include <fs/pseudo_file.h> |
| |
| #include "lib/fidl/cpp/interface_request.h" |
| #include "src/media/playback/mediaplayer/audio_consumer_impl.h" |
| #include "src/media/playback/mediaplayer/player_impl.h" |
| |
| const std::string kIsolateUrl = "fuchsia-pkg://fuchsia.com/mediaplayer#meta/mediaplayer.cmx"; |
| const std::string kIsolateArgument = "--transient"; |
| |
| // Connects to the requested service in a mediaplayer isolate. |
| template <typename Interface> |
| void ConnectToIsolate(fidl::InterfaceRequest<Interface> request, fuchsia::sys::Launcher* launcher) { |
| fuchsia::sys::LaunchInfo launch_info; |
| launch_info.url = kIsolateUrl; |
| launch_info.arguments.emplace({kIsolateArgument}); |
| std::shared_ptr<sys::ServiceDirectory> services = |
| sys::ServiceDirectory::CreateWithRequest(&launch_info.directory_request); |
| |
| fuchsia::sys::ComponentControllerPtr controller; |
| launcher->CreateComponent(std::move(launch_info), controller.NewRequest()); |
| services->Connect<Interface>(std::move(request)); |
| |
| controller->Detach(); |
| } |
| |
| int main(int argc, const char** argv) { |
| syslog::SetTags({"mediaplayer"}); |
| |
| bool transient = false; |
| for (int arg_index = 0; arg_index < argc; ++arg_index) { |
| if (argv[arg_index] == kIsolateArgument) { |
| transient = true; |
| break; |
| } |
| } |
| |
| async::Loop loop(&kAsyncLoopConfigAttachToCurrentThread); |
| trace::TraceProviderWithFdio trace_provider(loop.dispatcher()); |
| |
| std::unique_ptr<sys::ComponentContext> component_context = |
| sys::ComponentContext::CreateAndServeOutgoingDirectory(); |
| |
| if (transient) { |
| std::unique_ptr<media_player::PlayerImpl> player; |
| component_context->outgoing()->AddPublicService<fuchsia::media::playback::Player>( |
| [component_context = component_context.get(), &player, |
| &loop](fidl::InterfaceRequest<fuchsia::media::playback::Player> request) { |
| player = media_player::PlayerImpl::Create( |
| std::move(request), component_context, |
| [&loop]() { async::PostTask(loop.dispatcher(), [&loop]() { loop.Quit(); }); }); |
| }); |
| |
| std::unique_ptr<media_player::SessionAudioConsumerFactoryImpl> factory; |
| component_context->outgoing()->AddPublicService<fuchsia::media::SessionAudioConsumerFactory>( |
| [component_context = component_context.get(), &factory, |
| &loop](fidl::InterfaceRequest<fuchsia::media::SessionAudioConsumerFactory> request) { |
| factory = media_player::SessionAudioConsumerFactoryImpl::Create( |
| std::move(request), component_context, |
| [&loop]() { async::PostTask(loop.dispatcher(), [&loop]() { loop.Quit(); }); }); |
| }); |
| |
| loop.Run(); |
| } else { |
| fuchsia::sys::LauncherPtr launcher; |
| fuchsia::sys::EnvironmentPtr environment; |
| component_context->svc()->Connect(environment.NewRequest()); |
| environment->GetLauncher(launcher.NewRequest()); |
| |
| component_context->outgoing()->AddPublicService<fuchsia::media::playback::Player>( |
| [&launcher](fidl::InterfaceRequest<fuchsia::media::playback::Player> request) { |
| ConnectToIsolate<fuchsia::media::playback::Player>(std::move(request), launcher.get()); |
| }); |
| |
| component_context->outgoing()->AddPublicService<fuchsia::media::SessionAudioConsumerFactory>( |
| [&launcher](fidl::InterfaceRequest<fuchsia::media::SessionAudioConsumerFactory> request) { |
| ConnectToIsolate<fuchsia::media::SessionAudioConsumerFactory>(std::move(request), |
| launcher.get()); |
| }); |
| |
| loop.Run(); |
| } |
| |
| return 0; |
| } |