[Media Router] Implement an internal Media Routes observer.

chrome/browser/media/router/mojo/media_router_mojo_impl.cc

 // 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.
 
 #include "chrome/browser/media/router/mojo/media_router_mojo_impl.h"
 
 #include <stddef.h>
 
 #include <utility>
 
@@ skipping 287 matching lines @@
         error, mojo::RouteRequestResultCodeFromMojo(result_code));
   } else if (media_route->off_the_record != off_the_record) {
     std::string error = base::StringPrintf(
         "Mismatch in off the record status: request = %d, response = %d",
         off_the_record, media_route->off_the_record);
     result = RouteRequestResult::FromError(
         error, RouteRequestResult::OFF_THE_RECORD_MISMATCH);
   } else {
     result = RouteRequestResult::FromSuccess(
         media_route.To<std::unique_ptr<MediaRoute>>(), presentation_id);
-    if (result->route()->off_the_record())
-      OnOffTheRecordRouteCreated(result->route()->media_route_id());
   }
 
   // TODO(imcheng): Add UMA histogram based on result code (crbug.com/583044).
   for (const MediaRouteResponseCallback& callback : callbacks)
     callback.Run(*result);
 }
 
 void MediaRouterMojoImpl::CreateRoute(
     const MediaSource::Id& source_id,
     const MediaSink::Id& sink_id,
     const GURL& origin,
     content::WebContents* web_contents,
     const std::vector<MediaRouteResponseCallback>& callbacks,
     base::TimeDelta timeout,
     bool off_the_record) {
   DCHECK(thread_checker_.CalledOnValidThread());
 
   if (!origin.is_valid()) {
     DVLOG_WITH_INSTANCE(1) << "Invalid origin: " << origin;
-    std::unique_ptr<RouteRequestResult> result = RouteRequestResult::FromError(
-        "Invalid origin", RouteRequestResult::INVALID_ORIGIN);
+    std::unique_ptr<RouteRequestResult> error_result(
+        RouteRequestResult::FromError("Invalid origin",
+                                      RouteRequestResult::INVALID_ORIGIN));
     for (const MediaRouteResponseCallback& callback : callbacks)
-      callback.Run(*result);
+      callback.Run(*error_result);
     return;
   }
 
   SetWakeReason(MediaRouteProviderWakeReason::CREATE_ROUTE);
   int tab_id = SessionTabHelper::IdForTab(web_contents);
   RunOrDefer(base::Bind(&MediaRouterMojoImpl::DoCreateRoute,
                         base::Unretained(this), source_id, sink_id,
                         origin.is_empty() ? "" : origin.spec(), tab_id,
                         callbacks, timeout, off_the_record));
 }
 
 void MediaRouterMojoImpl::JoinRoute(
     const MediaSource::Id& source_id,
     const std::string& presentation_id,
     const GURL& origin,
     content::WebContents* web_contents,
     const std::vector<MediaRouteResponseCallback>& callbacks,
     base::TimeDelta timeout,
     bool off_the_record) {
   DCHECK(thread_checker_.CalledOnValidThread());
 
+  std::unique_ptr<RouteRequestResult> error_result;
   if (!origin.is_valid()) {
     DVLOG_WITH_INSTANCE(1) << "Invalid origin: " << origin;
-    std::unique_ptr<RouteRequestResult> result = RouteRequestResult::FromError(
+    error_result = RouteRequestResult::FromError(
         "Invalid origin", RouteRequestResult::INVALID_ORIGIN);
+  } else if (!HasLocalRoute()) {
+    DVLOG_WITH_INSTANCE(1) << "No local routes";
+    error_result = RouteRequestResult::FromError(
+        "Route not found", RouteRequestResult::ROUTE_NOT_FOUND);
+  }
+
+  if (error_result) {
     for (const MediaRouteResponseCallback& callback : callbacks)
-      callback.Run(*result);
+      callback.Run(*error_result);
     return;
   }
 
   SetWakeReason(MediaRouteProviderWakeReason::JOIN_ROUTE);
   int tab_id = SessionTabHelper::IdForTab(web_contents);
   RunOrDefer(base::Bind(&MediaRouterMojoImpl::DoJoinRoute,
                         base::Unretained(this), source_id, presentation_id,
                         origin.is_empty() ? "" : origin.spec(), tab_id,
                         callbacks, timeout, off_the_record));
 }
@@ skipping 319 matching lines @@
       source_id, route_id, presentation_id, origin, tab_id,
       timeout > base::TimeDelta() ? timeout.InMilliseconds() : 0,
       off_the_record, base::Bind(&MediaRouterMojoImpl::RouteResponseReceived,
                                  base::Unretained(this), presentation_id,
                                  off_the_record, callbacks));
 }
 
 void MediaRouterMojoImpl::DoTerminateRoute(const MediaRoute::Id& route_id) {
   DVLOG_WITH_INSTANCE(1) << "DoTerminateRoute " << route_id;
   media_route_provider_->TerminateRoute(route_id);
-  OnRouteTerminated(route_id);
 }
 
 void MediaRouterMojoImpl::DoDetachRoute(const MediaRoute::Id& route_id) {
   DVLOG_WITH_INSTANCE(1) << "DoDetachRoute " << route_id;
   media_route_provider_->DetachRoute(route_id);
 }
 
 void MediaRouterMojoImpl::DoSendSessionMessage(
     const MediaRoute::Id& route_id,
     const std::string& message,
@@ skipping 359 matching lines @@
                         base::Unretained(this), source_id));
 }
 
 void MediaRouterMojoImpl::DoUpdateMediaSinks(
     const MediaSource::Id& source_id) {
   DVLOG_WITH_INSTANCE(1) << "DoUpdateMediaSinks" << source_id;
   media_route_provider_->UpdateMediaSinks(source_id);
 }
 
 }  // namespace media_router