OLD | NEW |
---|---|
(Empty) | |
1 // Copyright 2017 The Chromium Authors. All rights reserved. | |
2 // Use of this source code is governed by a BSD-style license that can be | |
3 // found in the LICENSE file. | |
4 | |
5 #include "chrome/browser/media/router/discovery/dial/dial_media_sink_service.h" | |
6 | |
7 #include "chrome/browser/media/router/discovery/dial/dial_device_data.h" | |
8 #include "chrome/browser/media/router/discovery/media_sink_internal.h" | |
9 #include "chrome/browser/profiles/profile.h" | |
10 #include "content/public/browser/browser_thread.h" | |
11 | |
12 using content::BrowserThread; | |
13 | |
14 namespace { | |
15 // Time interval when media sink service sends sinks to MRP. | |
16 const int kFetchCompleteTimeoutSecs = 3; | |
17 } | |
18 | |
19 namespace media_router { | |
20 | |
21 DialMediaSinkService::DialMediaSinkService( | |
22 const OnSinksDiscoveredCallback& callback, | |
23 content::BrowserContext* browser_context) | |
24 : MediaSinkService(callback), browser_context_(browser_context) { | |
25 DCHECK_CURRENTLY_ON(BrowserThread::UI); | |
26 auto* profile = Profile::FromBrowserContext(browser_context_); | |
27 request_context_ = profile->GetRequestContext(); | |
28 | |
29 DCHECK(request_context_); | |
30 } | |
31 | |
32 DialMediaSinkService::~DialMediaSinkService() {} | |
33 | |
34 void DialMediaSinkService::Start() { | |
35 DCHECK_CURRENTLY_ON(BrowserThread::IO); | |
36 dial_registry()->RegisterObserver(this); | |
37 dial_registry()->DiscoverNow(); | |
38 } | |
39 | |
40 void DialMediaSinkService::Stop() { | |
41 DCHECK_CURRENTLY_ON(BrowserThread::IO); | |
42 dial_registry()->UnregisterObserver(this); | |
43 } | |
44 | |
45 void DialMediaSinkService::AddSinkQuery(MediaSinksObserver* observer) { | |
46 // TODO(crbug.com/687375): Implement DIAL sink query. | |
47 NOTIMPLEMENTED(); | |
48 } | |
49 | |
50 void DialMediaSinkService::RemoveSinkQuery(MediaSinksObserver* observer) { | |
51 // TODO(crbug.com/687375): Implement DIAL sink query. | |
52 NOTIMPLEMENTED(); | |
53 } | |
54 | |
55 DialRegistry* DialMediaSinkService::dial_registry() { | |
56 DCHECK_CURRENTLY_ON(BrowserThread::IO); | |
57 return DialRegistry::GetInstance(); | |
58 } | |
59 | |
60 DeviceDescriptionService* DialMediaSinkService::GetDescriptionService() { | |
61 DCHECK_CURRENTLY_ON(BrowserThread::IO); | |
62 if (!description_service_.get()) { | |
63 description_service_.reset(new DeviceDescriptionService( | |
64 base::Bind(&DialMediaSinkService::OnDeviceDescriptionAvailable, | |
65 base::Unretained(this)), | |
66 base::Bind(&DialMediaSinkService::OnDeviceDescriptionError, | |
67 base::Unretained(this)))); | |
68 } | |
69 return description_service_.get(); | |
70 } | |
71 | |
72 void DialMediaSinkService::OnDialDeviceEvent( | |
73 const DialRegistry::DeviceList& devices) { | |
74 DCHECK_CURRENTLY_ON(BrowserThread::IO); | |
75 DVLOG(2) << "DialMediaSinkService::OnDialDeviceEvent found " << devices.size() | |
76 << " devices"; | |
77 | |
78 // Add a finish timer. | |
79 finish_timer_.reset(new base::OneShotTimer()); | |
80 base::TimeDelta finish_delay = | |
81 base::TimeDelta::FromSeconds(kFetchCompleteTimeoutSecs); | |
82 finish_timer_->Start(FROM_HERE, finish_delay, this, | |
83 &DialMediaSinkService::FetchCompleted); | |
84 | |
85 current_sinks_.clear(); | |
86 GetDescriptionService()->GetDeviceDescriptions(devices, request_context_); | |
87 } | |
88 | |
89 void DialMediaSinkService::OnDialError(DialRegistry::DialErrorCode type) { | |
90 DCHECK_CURRENTLY_ON(BrowserThread::IO); | |
91 DVLOG(2) << "OnDialError [DialErrorCode]: " << static_cast<int>(type); | |
92 } | |
93 | |
94 void DialMediaSinkService::OnDeviceDescriptionAvailable( | |
95 const DialDeviceData& device_data, | |
96 const ParsedDialDeviceDescription& description_data) { | |
97 DCHECK_CURRENTLY_ON(BrowserThread::IO); | |
98 | |
99 MediaSink sink(description_data.unique_id, description_data.friendly_name, | |
100 MediaSink::IconType::GENERIC); | |
101 DialSinkExtraData extra_data; | |
102 extra_data.app_url = description_data.app_url; | |
103 extra_data.model_name = description_data.model_name; | |
104 std::string ip_address = device_data.device_description_url().host(); | |
105 if (!extra_data.ip_address.AssignFromIPLiteral(ip_address)) { | |
106 DVLOG(1) << "Invalid ip_address: " << ip_address; | |
107 return; | |
108 } | |
109 | |
110 current_sinks_.insert(MediaSinkInternal(sink, extra_data)); | |
111 | |
112 if (finish_timer_) | |
113 return; | |
114 | |
115 // Start fetch timer again if device description comes back after | |
116 // |finish_timer_| fires. | |
117 base::TimeDelta finish_delay = | |
118 base::TimeDelta::FromSeconds(kFetchCompleteTimeoutSecs); | |
119 finish_timer_.reset(new base::OneShotTimer()); | |
120 finish_timer_->Start(FROM_HERE, finish_delay, this, | |
121 &DialMediaSinkService::FetchCompleted); | |
122 } | |
123 | |
124 void DialMediaSinkService::OnDeviceDescriptionError( | |
125 const DialDeviceData& device, | |
126 const std::string& error_message) { | |
127 DCHECK_CURRENTLY_ON(BrowserThread::IO); | |
128 DVLOG(2) << "OnDescriptionFetchesError [message]: " << error_message; | |
129 } | |
130 | |
131 void DialMediaSinkService::FetchCompleted() { | |
132 DCHECK_CURRENTLY_ON(BrowserThread::IO); | |
133 DCHECK(!sink_discovery_callback_.is_null()); | |
134 | |
135 finish_timer_.reset(); | |
136 | |
137 auto sinks = current_sinks_; | |
138 if (sinks == mrp_sinks_) { | |
139 DVLOG(2) << "No update to sink list."; | |
140 return; | |
141 } | |
142 | |
143 DVLOG(2) << "Send sinks to media router, [size]: " << sinks.size(); | |
144 std::vector<MediaSinkInternal> vec_sinks(sinks.begin(), sinks.end()); | |
mark a. foltz
2017/04/18 18:16:27
Can this be inlined into Run()?
zhaobin
2017/04/21 23:12:59
Done.
| |
145 sink_discovery_callback_.Run(vec_sinks); | |
146 mrp_sinks_ = std::move(sinks); | |
147 } | |
148 | |
149 } // namespace media_router | |
OLD | NEW |