Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(155)

Side by Side Diff: chrome/browser/chromeos/arc/arc_downloads_watcher_service.cc

Issue 2133503002: arc: Revamp the ArcBridgeService interface (Closed) Base URL: https://chromium.googlesource.com/a/chromium/src.git@master
Patch Set: More rebasing Created 4 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 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/chromeos/arc/arc_downloads_watcher_service.h" 5 #include "chrome/browser/chromeos/arc/arc_downloads_watcher_service.h"
6 6
7 #include <map>
7 #include <memory> 8 #include <memory>
8 #include <utility> 9 #include <utility>
9 10
10 #include "base/callback.h" 11 #include "base/callback.h"
11 #include "base/files/file_enumerator.h" 12 #include "base/files/file_enumerator.h"
12 #include "base/files/file_path.h" 13 #include "base/files/file_path.h"
13 #include "base/files/file_path_watcher.h" 14 #include "base/files/file_path_watcher.h"
14 #include "base/memory/ptr_util.h" 15 #include "base/memory/ptr_util.h"
15 #include "base/time/time.h" 16 #include "base/time/time.h"
16 #include "chrome/browser/download/download_prefs.h" 17 #include "chrome/browser/download/download_prefs.h"
(...skipping 151 matching lines...) Expand 10 before | Expand all | Expand 10 after
168 const base::FileEnumerator::FileInfo& info = enumerator.GetInfo(); 169 const base::FileEnumerator::FileInfo& info = enumerator.GetInfo();
169 timestamp_map[android_path] = info.GetLastModifiedTime(); 170 timestamp_map[android_path] = info.GetLastModifiedTime();
170 } 171 }
171 return timestamp_map; 172 return timestamp_map;
172 } 173 }
173 174
174 ArcDownloadsWatcherService::ArcDownloadsWatcherService( 175 ArcDownloadsWatcherService::ArcDownloadsWatcherService(
175 ArcBridgeService* bridge_service) 176 ArcBridgeService* bridge_service)
176 : ArcService(bridge_service), weak_ptr_factory_(this) { 177 : ArcService(bridge_service), weak_ptr_factory_(this) {
177 DCHECK_CURRENTLY_ON(BrowserThread::UI); 178 DCHECK_CURRENTLY_ON(BrowserThread::UI);
178 arc_bridge_service()->AddObserver(this); 179 arc_bridge_service()->file_system()->AddObserver(this);
179 } 180 }
180 181
181 ArcDownloadsWatcherService::~ArcDownloadsWatcherService() { 182 ArcDownloadsWatcherService::~ArcDownloadsWatcherService() {
182 DCHECK_CURRENTLY_ON(BrowserThread::UI); 183 DCHECK_CURRENTLY_ON(BrowserThread::UI);
183 arc_bridge_service()->RemoveObserver(this); 184 arc_bridge_service()->file_system()->RemoveObserver(this);
184 StopWatchingDownloads(); 185 StopWatchingDownloads();
185 DCHECK(!watcher_); 186 DCHECK(!watcher_);
186 } 187 }
187 188
188 void ArcDownloadsWatcherService::OnFileSystemInstanceReady() { 189 void ArcDownloadsWatcherService::OnInstanceReady() {
189 DCHECK_CURRENTLY_ON(BrowserThread::UI); 190 DCHECK_CURRENTLY_ON(BrowserThread::UI);
190 StartWatchingDownloads(); 191 StartWatchingDownloads();
191 } 192 }
192 193
193 void ArcDownloadsWatcherService::OnFileSystemInstanceClosed() { 194 void ArcDownloadsWatcherService::OnInstanceClosed() {
194 DCHECK_CURRENTLY_ON(BrowserThread::UI); 195 DCHECK_CURRENTLY_ON(BrowserThread::UI);
195 StopWatchingDownloads(); 196 StopWatchingDownloads();
196 } 197 }
197 198
198 void ArcDownloadsWatcherService::StartWatchingDownloads() { 199 void ArcDownloadsWatcherService::StartWatchingDownloads() {
199 DCHECK_CURRENTLY_ON(BrowserThread::UI); 200 DCHECK_CURRENTLY_ON(BrowserThread::UI);
200 StopWatchingDownloads(); 201 StopWatchingDownloads();
201 DCHECK(!watcher_); 202 DCHECK(!watcher_);
202 watcher_ = base::MakeUnique<DownloadsWatcher>( 203 watcher_ = base::MakeUnique<DownloadsWatcher>(
203 base::Bind(&ArcDownloadsWatcherService::OnDownloadsChanged, 204 base::Bind(&ArcDownloadsWatcherService::OnDownloadsChanged,
204 weak_ptr_factory_.GetWeakPtr())); 205 weak_ptr_factory_.GetWeakPtr()));
205 BrowserThread::PostTask( 206 BrowserThread::PostTask(
206 BrowserThread::FILE, FROM_HERE, 207 BrowserThread::FILE, FROM_HERE,
207 base::Bind(&DownloadsWatcher::Start, base::Unretained(watcher_.get()))); 208 base::Bind(&DownloadsWatcher::Start, base::Unretained(watcher_.get())));
208 } 209 }
209 210
210 void ArcDownloadsWatcherService::StopWatchingDownloads() { 211 void ArcDownloadsWatcherService::StopWatchingDownloads() {
211 DCHECK_CURRENTLY_ON(BrowserThread::UI); 212 DCHECK_CURRENTLY_ON(BrowserThread::UI);
212 if (watcher_) { 213 if (watcher_) {
213 BrowserThread::DeleteSoon(BrowserThread::FILE, FROM_HERE, 214 BrowserThread::DeleteSoon(BrowserThread::FILE, FROM_HERE,
214 watcher_.release()); 215 watcher_.release());
215 } 216 }
216 } 217 }
217 218
218 void ArcDownloadsWatcherService::OnDownloadsChanged( 219 void ArcDownloadsWatcherService::OnDownloadsChanged(
219 const std::vector<base::FilePath>& paths) { 220 const std::vector<base::FilePath>& paths) {
220 DCHECK_CURRENTLY_ON(BrowserThread::FILE); 221 DCHECK_CURRENTLY_ON(BrowserThread::FILE);
221 222
222 auto* instance = arc_bridge_service()->file_system_instance(); 223 auto* instance = arc_bridge_service()->file_system()->instance();
223 if (!instance) 224 if (!instance)
224 return; 225 return;
225 226
226 mojo::Array<mojo::String> mojo_paths(paths.size()); 227 mojo::Array<mojo::String> mojo_paths(paths.size());
227 for (size_t i = 0; i < paths.size(); ++i) { 228 for (size_t i = 0; i < paths.size(); ++i) {
228 mojo_paths[i] = paths[i].value(); 229 mojo_paths[i] = paths[i].value();
229 } 230 }
230 instance->RequestMediaScan(std::move(mojo_paths)); 231 instance->RequestMediaScan(std::move(mojo_paths));
231 } 232 }
232 233
233 } // namespace arc 234 } // namespace arc
OLDNEW
« no previous file with comments | « chrome/browser/chromeos/arc/arc_downloads_watcher_service.h ('k') | chrome/browser/chromeos/arc/arc_navigation_throttle.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698