OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "chrome/browser/media/router/media_router_mojo_impl.h" | 5 #include "chrome/browser/media/router/media_router_mojo_impl.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/guid.h" | 8 #include "base/guid.h" |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/memory/scoped_vector.h" | 10 #include "base/memory/scoped_vector.h" |
(...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
84 [](const media_router::MediaRoute& route) { | 84 [](const media_router::MediaRoute& route) { |
85 return route.is_local(); }) != | 85 return route.is_local(); }) != |
86 routes.end(); | 86 routes.end(); |
87 | 87 |
88 // |this| will be deleted in UpdateHasLocalRoute() if |has_local_route| is | 88 // |this| will be deleted in UpdateHasLocalRoute() if |has_local_route| is |
89 // false. Note that ObserverList supports removing an observer while | 89 // false. Note that ObserverList supports removing an observer while |
90 // iterating through it. | 90 // iterating through it. |
91 router_->UpdateHasLocalRoute(has_local_route); | 91 router_->UpdateHasLocalRoute(has_local_route); |
92 } | 92 } |
93 | 93 |
94 // TODO(mfoltz): Flip the default sink availability to UNAVAILABLE, once the | |
95 // MRPM sends initial availability status. | |
96 MediaRouterMojoImpl::MediaRouterMojoImpl( | 94 MediaRouterMojoImpl::MediaRouterMojoImpl( |
97 extensions::EventPageTracker* event_page_tracker) | 95 extensions::EventPageTracker* event_page_tracker) |
98 : event_page_tracker_(event_page_tracker), | 96 : event_page_tracker_(event_page_tracker), |
99 instance_id_(base::GenerateGUID()), | 97 instance_id_(base::GenerateGUID()), |
100 has_local_route_(false), | 98 has_local_route_(false), |
101 availability_(interfaces::MediaRouter::SINK_AVAILABILITY_AVAILABLE), | 99 availability_(interfaces::MediaRouter::SINK_AVAILABILITY_UNAVAILABLE), |
102 wakeup_attempt_count_(0), | 100 wakeup_attempt_count_(0), |
103 weak_factory_(this) { | 101 weak_factory_(this) { |
104 DCHECK(event_page_tracker_); | 102 DCHECK(event_page_tracker_); |
105 } | 103 } |
106 | 104 |
107 MediaRouterMojoImpl::~MediaRouterMojoImpl() { | 105 MediaRouterMojoImpl::~MediaRouterMojoImpl() { |
108 DCHECK(thread_checker_.CalledOnValidThread()); | 106 DCHECK(thread_checker_.CalledOnValidThread()); |
109 | 107 |
110 // Make sure |routes_observer_| is destroyed first, because it triggers | 108 // Make sure |routes_observer_| is destroyed first, because it triggers |
111 // additional cleanup logic in this class that depends on other fields. | 109 // additional cleanup logic in this class that depends on other fields. |
(...skipping 668 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
780 } | 778 } |
781 | 779 |
782 void MediaRouterMojoImpl::DrainPendingRequests() { | 780 void MediaRouterMojoImpl::DrainPendingRequests() { |
783 DLOG_WITH_INSTANCE(ERROR) | 781 DLOG_WITH_INSTANCE(ERROR) |
784 << "Draining request queue. (queue-length=" << pending_requests_.size() | 782 << "Draining request queue. (queue-length=" << pending_requests_.size() |
785 << ")"; | 783 << ")"; |
786 pending_requests_.clear(); | 784 pending_requests_.clear(); |
787 } | 785 } |
788 | 786 |
789 } // namespace media_router | 787 } // namespace media_router |
OLD | NEW |