[Media Router] Wiring for searching route providers for new sinks.

chrome/browser/media/router/media_router_mojo_impl.h

 // Copyright 2015 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.
 
 #ifndef CHROME_BROWSER_MEDIA_ROUTER_MEDIA_ROUTER_MOJO_IMPL_H_
 #define CHROME_BROWSER_MEDIA_ROUTER_MEDIA_ROUTER_MOJO_IMPL_H_
 
 #include <stdint.h>
 
 #include <deque>
@@ skipping 142 matching lines @@
 
     // Cached list of sinks for the query, if |has_cached_result| is true.
     // Empty otherwise.
     std::vector<MediaSink> cached_sink_list;
     base::ObserverList<MediaSinksObserver> observers;
 
    private:
     DISALLOW_COPY_AND_ASSIGN(MediaSinksQuery);
   };
 
+  // Represents a query to the MRPM for media sinks with a certain sink ID and
+  // holds observers for the query. This struct owns the observers because after
+  // they are notified they need to be destroyed.
+  struct MediaSinksSearchQuery {
+   public:
+    MediaSinksSearchQuery();
+    ~MediaSinksSearchQuery();
+
+    std::vector<scoped_ptr<MediaSinksSearchRequest>> observers;
+
+   private:
+    DISALLOW_COPY_AND_ASSIGN(MediaSinksSearchQuery);
+  };
+
   struct MediaRoutesQuery {
    public:
     MediaRoutesQuery();
     ~MediaRoutesQuery();
 
     // True if the query has been sent to the MRPM.  False otherwise.
     bool is_active = false;
     base::ObserverList<MediaRoutesObserver> observers;
 
    private:
@@ skipping 22 matching lines @@
   // Dispatches the Mojo requests queued in |pending_requests_|.
   void ExecutePendingRequests();
 
   // Drops all pending requests. Called when we have a connection error to
   // component extension and further reattempts are unlikely to help.
   void DrainPendingRequests();
 
   // MediaRouter implementation.
   bool RegisterMediaSinksObserver(MediaSinksObserver* observer) override;
   void UnregisterMediaSinksObserver(MediaSinksObserver* observer) override;
+  bool RegisterMediaSinksSearchRequest(
+      scoped_ptr<MediaSinksSearchRequest> request) override;
   void RegisterMediaRoutesObserver(MediaRoutesObserver* observer) override;
   void UnregisterMediaRoutesObserver(MediaRoutesObserver* observer) override;
   void RegisterIssuesObserver(IssuesObserver* observer) override;
   void UnregisterIssuesObserver(IssuesObserver* observer) override;
   void RegisterPresentationSessionMessagesObserver(
       PresentationSessionMessagesObserver* observer) override;
   void UnregisterPresentationSessionMessagesObserver(
       PresentationSessionMessagesObserver* observer) override;
 
   // These calls invoke methods in the component extension via Mojo.
@@ skipping 25 matching lines @@
                             const SendRouteMessageCallback& callback);
   void DoSendSessionBinaryMessage(const MediaRoute::Id& route_id,
                                   scoped_ptr<std::vector<uint8_t>> data,
                                   const SendRouteMessageCallback& callback);
   void DoListenForRouteMessages(const MediaRoute::Id& route_id);
   void DoStopListeningForRouteMessages(const MediaRoute::Id& route_id);
   void DoStartObservingMediaSinks(const MediaSource::Id& source_id);
   void DoStopObservingMediaSinks(const MediaSource::Id& source_id);
   void DoStartObservingMediaRoutes(const MediaSource::Id& source_id);
   void DoStopObservingMediaRoutes(const MediaSource::Id& source_id);
+  void DoSearchProviders(const MediaSource::Id& source_id,
+                         const MediaSink::Id& sink_id);
 
   // Invoked when the next batch of messages arrives.
   // |route_id|: ID of route of the messages.
   // |messages|: A list of messages received.
   // |error|: true if an error occurred.
   void OnRouteMessagesReceived(
       const MediaRoute::Id& route_id,
       mojo::Array<interfaces::RouteMessagePtr> messages,
       bool error);
 
   // Error handler callback for |binding_| and |media_route_provider_|.
   void OnConnectionError();
 
   // interfaces::MediaRouter implementation.
   void RegisterMediaRouteProvider(
       interfaces::MediaRouteProviderPtr media_route_provider_ptr,
       const interfaces::MediaRouter::RegisterMediaRouteProviderCallback&
           callback) override;
   void OnIssue(interfaces::IssuePtr issue) override;
   void OnSinksReceived(const mojo::String& media_source,
                        mojo::Array<interfaces::MediaSinkPtr> sinks) override;
+  void OnSearchSinksReceived(
+      const mojo::String& sink_id,
+      mojo::Array<interfaces::MediaSinkPtr> sinks) override;
   void OnRoutesUpdated(mojo::Array<interfaces::MediaRoutePtr> routes,
-      const mojo::String& media_source,
-      mojo::Array<mojo::String> joinable_route_ids) override;
+       const mojo::String& media_source,
+       mojo::Array<mojo::String> joinable_route_ids) override;
   void OnSinkAvailabilityUpdated(
       interfaces::MediaRouter::SinkAvailability availability) override;
   void OnPresentationConnectionStateChanged(
       const mojo::String& route_id,
       interfaces::MediaRouter::PresentationConnectionState state) override;
   void OnPresentationConnectionClosed(
       const mojo::String& route_id,
       interfaces::MediaRouter::PresentationConnectionCloseReason reason,
       const mojo::String& message) override;
 
@@ skipping 30 matching lines @@
   // Clears the wake reason after the extension has been awoken.
   void ClearWakeReason();
 
   // Pending requests queued to be executed once component extension
   // becomes ready.
   std::deque<base::Closure> pending_requests_;
 
   base::ScopedPtrHashMap<MediaSource::Id, scoped_ptr<MediaSinksQuery>>
       sinks_queries_;
 
+  std::unordered_map<MediaSink::Id, scoped_ptr<MediaSinksSearchQuery>>
+      search_queries_;
+
   base::ScopedPtrHashMap<MediaSource::Id, scoped_ptr<MediaRoutesQuery>>
       routes_queries_;
 
   using PresentationSessionMessagesObserverList =
       base::ObserverList<PresentationSessionMessagesObserver>;
   base::ScopedPtrHashMap<MediaRoute::Id,
                          scoped_ptr<PresentationSessionMessagesObserverList>>
       messages_observers_;
 
   // IDs of MediaRoutes being listened for messages. Note that this is
@@ skipping 38 matching lines @@
   MediaRouteProviderWakeReason current_wake_reason_;
 
   base::WeakPtrFactory<MediaRouterMojoImpl> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(MediaRouterMojoImpl);
 };
 
 }  // namespace media_router
 
 #endif  // CHROME_BROWSER_MEDIA_ROUTER_MEDIA_ROUTER_MOJO_IMPL_H_