| // 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. |
| |
| #ifndef GARNET_BIN_NETCONNECTOR_NETCONNECTOR_IMPL_H_ |
| #define GARNET_BIN_NETCONNECTOR_NETCONNECTOR_IMPL_H_ |
| |
| #include <fuchsia/net/mdns/cpp/fidl.h> |
| #include <fuchsia/netconnector/cpp/fidl.h> |
| #include <fuchsia/sys/cpp/fidl.h> |
| #include <lib/fit/function.h> |
| #include <lib/sys/cpp/component_context.h> |
| |
| #include <memory> |
| #include <string> |
| #include <unordered_map> |
| #include <vector> |
| |
| #include "garnet/bin/netconnector/device_service_provider.h" |
| #include "garnet/bin/netconnector/fidl_publisher.h" |
| #include "garnet/bin/netconnector/listener.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 "garnet/lib/inet/ip_port.h" |
| #include "lib/fidl/cpp/binding_set.h" |
| #include "src/lib/fxl/macros.h" |
| |
| namespace netconnector { |
| |
| class NetConnectorImpl : public fuchsia::netconnector::NetConnector, |
| public fuchsia::net::mdns::ServiceSubscriber { |
| public: |
| NetConnectorImpl(NetConnectorParams* params, fit::closure quit_callback); |
| |
| ~NetConnectorImpl() override; |
| |
| // Returns the service provider exposed to remote requestors. |
| fuchsia::sys::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( |
| std::string name, |
| fidl::InterfaceHandle<fuchsia::sys::ServiceProvider> service_provider) |
| override; |
| |
| void GetDeviceServiceProvider( |
| std::string device_name, |
| fidl::InterfaceRequest<fuchsia::sys::ServiceProvider> service_provider) |
| override; |
| |
| void GetKnownDeviceNames(uint64_t version_last_seen, |
| GetKnownDeviceNamesCallback callback) override; |
| |
| private: |
| static const inet::IpPort kPort; |
| static const std::string kFuchsiaServiceName; |
| static const std::string kLocalDeviceName; |
| |
| void StartListener(); |
| |
| void AddDeviceServiceProvider( |
| std::unique_ptr<DeviceServiceProvider> device_service_provider); |
| |
| void AddServiceAgent(std::unique_ptr<ServiceAgent> service_agent); |
| |
| // fuchsia::net::mdns::ServiceSubscriber implementation. |
| void OnInstanceDiscovered(fuchsia::net::mdns::ServiceInstance instance, |
| OnInstanceDiscoveredCallback callback) override; |
| |
| void OnInstanceChanged(fuchsia::net::mdns::ServiceInstance instance, |
| OnInstanceChangedCallback callback) override; |
| |
| void OnInstanceLost(std::string service_name, std::string instance_name, |
| OnInstanceLostCallback callback) override; |
| |
| NetConnectorParams* params_; |
| fit::closure quit_callback_; |
| std::unique_ptr<sys::ComponentContext> component_context_; |
| std::string host_name_; |
| fidl::BindingSet<fuchsia::netconnector::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_; |
| |
| fuchsia::net::mdns::SubscriberPtr mdns_subscriber_; |
| fidl::Binding<fuchsia::net::mdns::ServiceSubscriber> mdns_subscriber_binding_; |
| |
| FidlPublisher<GetKnownDeviceNamesCallback> device_names_publisher_; |
| |
| FXL_DISALLOW_COPY_AND_ASSIGN(NetConnectorImpl); |
| }; |
| |
| } // namespace netconnector |
| |
| #endif // GARNET_BIN_NETCONNECTOR_NETCONNECTOR_IMPL_H_ |