| // 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. |
| |
| #pragma once |
| |
| #include <memory> |
| #include <string> |
| #include <unordered_map> |
| #include <vector> |
| |
| #include "garnet/bin/media/util/fidl_publisher.h" |
| #include "garnet/bin/netconnector/device_service_provider.h" |
| #include "garnet/bin/netconnector/ip_port.h" |
| #include "garnet/bin/netconnector/listener.h" |
| #include "garnet/bin/netconnector/mdns/mdns_service_impl.h" |
| #include "garnet/bin/netconnector/netconnector_params.h" |
| #include "garnet/bin/netconnector/requestor_agent.h" |
| #include "garnet/bin/netconnector/responding_service_host.h" |
| #include "garnet/bin/netconnector/service_agent.h" |
| #include "lib/app/cpp/application_context.h" |
| #include "lib/app/fidl/application_launcher.fidl.h" |
| #include "lib/app/fidl/service_provider.fidl.h" |
| #include "lib/fidl/cpp/bindings/binding_set.h" |
| #include "lib/fxl/macros.h" |
| #include "lib/netconnector/fidl/netconnector.fidl.h" |
| |
| namespace netconnector { |
| |
| class NetConnectorImpl : public NetConnector { |
| public: |
| NetConnectorImpl(NetConnectorParams* params); |
| |
| ~NetConnectorImpl() override; |
| |
| // Returns the service provider exposed to remote requestors. |
| app::ServiceProvider* responding_services() { |
| return responding_service_host_.services(); |
| } |
| |
| // Releases a service provider for a remote device. |
| void ReleaseDeviceServiceProvider( |
| DeviceServiceProvider* device_service_provider); |
| |
| // Adds an agent that represents a local requestor. |
| void AddRequestorAgent(std::unique_ptr<RequestorAgent> requestor_agent); |
| |
| // Releases an agent that manages a connection on behalf of a local requestor. |
| void ReleaseRequestorAgent(RequestorAgent* requestor_agent); |
| |
| // Releases an agent that manages a connection on behalf of a remote |
| // requestor. |
| void ReleaseServiceAgent(ServiceAgent* service_agent); |
| |
| // NetConnector implementation. |
| void RegisterServiceProvider( |
| const fidl::String& name, |
| fidl::InterfaceHandle<app::ServiceProvider> service_provider) override; |
| |
| void GetDeviceServiceProvider( |
| const fidl::String& device_name, |
| fidl::InterfaceRequest<app::ServiceProvider> service_provider) override; |
| |
| void GetKnownDeviceNames( |
| uint64_t version_last_seen, |
| const GetKnownDeviceNamesCallback& callback) override; |
| |
| private: |
| static const IpPort kPort; |
| static const std::string kFuchsiaServiceName; |
| static const std::string kLocalDeviceName; |
| |
| void AddDeviceServiceProvider( |
| std::unique_ptr<DeviceServiceProvider> device_service_provider); |
| |
| void AddServiceAgent(std::unique_ptr<ServiceAgent> service_agent); |
| |
| void StartMdns(); |
| |
| NetConnectorParams* params_; |
| std::unique_ptr<app::ApplicationContext> application_context_; |
| std::string host_name_; |
| fidl::BindingSet<NetConnector> bindings_; |
| Listener listener_; |
| RespondingServiceHost responding_service_host_; |
| std::unordered_map<DeviceServiceProvider*, |
| std::unique_ptr<DeviceServiceProvider>> |
| device_service_providers_; |
| std::unordered_map<RequestorAgent*, std::unique_ptr<RequestorAgent>> |
| requestor_agents_; |
| std::unordered_map<ServiceAgent*, std::unique_ptr<ServiceAgent>> |
| service_agents_; |
| |
| mdns::MdnsServiceImpl mdns_service_impl_; |
| |
| media::FidlPublisher<GetKnownDeviceNamesCallback> device_names_publisher_; |
| |
| FXL_DISALLOW_COPY_AND_ASSIGN(NetConnectorImpl); |
| }; |
| |
| } // namespace netconnector |