Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/extensions/file_browser_event_router.h" | 5 #include "chrome/browser/chromeos/extensions/file_browser_event_router.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/file_util.h" | 8 #include "base/file_util.h" |
| 9 #include "base/json/json_writer.h" | 9 #include "base/json/json_writer.h" |
| 10 #include "base/message_loop.h" | 10 #include "base/message_loop.h" |
| (...skipping 214 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 225 base::Bind(&DirectoryExistsOnBlockingPool, | 225 base::Bind(&DirectoryExistsOnBlockingPool, |
| 226 directory_path, | 226 directory_path, |
| 227 success_callback, | 227 success_callback, |
| 228 failure_callback)); | 228 failure_callback)); |
| 229 }; | 229 }; |
| 230 | 230 |
| 231 } // namespace | 231 } // namespace |
| 232 | 232 |
| 233 FileBrowserEventRouter::FileBrowserEventRouter( | 233 FileBrowserEventRouter::FileBrowserEventRouter( |
| 234 Profile* profile) | 234 Profile* profile) |
| 235 : weak_factory_(this), | 235 : notifications_(new FileBrowserNotifications(profile)), |
| 236 notifications_(new FileBrowserNotifications(profile)), | |
| 237 pref_change_registrar_(new PrefChangeRegistrar), | 236 pref_change_registrar_(new PrefChangeRegistrar), |
| 238 profile_(profile), | 237 profile_(profile), |
| 239 num_remote_update_requests_(0), | 238 num_remote_update_requests_(0), |
| 240 shift_pressed_(false) { | 239 shift_pressed_(false), |
| 240 ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)) { | |
| 241 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 241 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
| 242 | 242 |
| 243 // Bind a weak reference back to |this| to avoid memory errors in case we | |
| 244 // shut down while a callback is in flight. | |
| 245 file_watcher_callback_ = | 243 file_watcher_callback_ = |
| 246 base::Bind(&RelayFileWatcherCallbackToUIThread, | 244 base::Bind(&RelayFileWatcherCallbackToUIThread, |
| 247 base::Bind(&FileBrowserEventRouter::HandleFileWatchNotification, | 245 base::Bind(&FileBrowserEventRouter::HandleFileWatchNotification, |
| 248 weak_factory_.GetWeakPtr())); | 246 weak_factory_.GetWeakPtr())); |
| 249 | 247 |
| 250 // Listen for the Shift modifier's state changes. | 248 // Listen for the Shift modifier's state changes. |
| 251 chromeos::SystemKeyEventListener* key_event_listener = | 249 chromeos::SystemKeyEventListener* key_event_listener = |
| 252 chromeos::SystemKeyEventListener::GetInstance(); | 250 chromeos::SystemKeyEventListener::GetInstance(); |
| 253 if (key_event_listener) | 251 if (key_event_listener) |
| 254 key_event_listener->AddModifiersObserver(this); | 252 key_event_listener->AddModifiersObserver(this); |
| (...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 317 chromeos::ConnectivityStateHelper::Get()-> | 315 chromeos::ConnectivityStateHelper::Get()-> |
| 318 AddNetworkManagerObserver(this); | 316 AddNetworkManagerObserver(this); |
| 319 } | 317 } |
| 320 suspend_state_delegate_.reset(new SuspendStateDelegateImpl()); | 318 suspend_state_delegate_.reset(new SuspendStateDelegateImpl()); |
| 321 | 319 |
| 322 pref_change_registrar_->Init(profile_->GetPrefs()); | 320 pref_change_registrar_->Init(profile_->GetPrefs()); |
| 323 | 321 |
| 324 pref_change_registrar_->Add( | 322 pref_change_registrar_->Add( |
| 325 prefs::kExternalStorageDisabled, | 323 prefs::kExternalStorageDisabled, |
| 326 base::Bind(&FileBrowserEventRouter::OnExternalStorageDisabledChanged, | 324 base::Bind(&FileBrowserEventRouter::OnExternalStorageDisabledChanged, |
| 327 base::Unretained(this))); | 325 weak_factory_.GetWeakPtr())); |
| 328 | 326 |
| 329 base::Closure callback = | 327 base::Closure callback = |
| 330 base::Bind(&FileBrowserEventRouter::OnFileBrowserPrefsChanged, | 328 base::Bind(&FileBrowserEventRouter::OnFileBrowserPrefsChanged, |
| 331 base::Unretained(this)); | 329 weak_factory_.GetWeakPtr()); |
| 332 pref_change_registrar_->Add(prefs::kDisableDriveOverCellular, callback); | 330 pref_change_registrar_->Add(prefs::kDisableDriveOverCellular, callback); |
| 333 pref_change_registrar_->Add(prefs::kDisableDriveHostedFiles, callback); | 331 pref_change_registrar_->Add(prefs::kDisableDriveHostedFiles, callback); |
| 334 pref_change_registrar_->Add(prefs::kDisableDrive, callback); | 332 pref_change_registrar_->Add(prefs::kDisableDrive, callback); |
| 335 pref_change_registrar_->Add(prefs::kUse24HourClock, callback); | 333 pref_change_registrar_->Add(prefs::kUse24HourClock, callback); |
| 336 } | 334 } |
| 337 | 335 |
| 338 // File watch setup routines. | 336 // File watch setup routines. |
| 339 bool FileBrowserEventRouter::AddFileWatch( | 337 bool FileBrowserEventRouter::AddFileWatch( |
| 340 const base::FilePath& local_path, | 338 const base::FilePath& local_path, |
| 341 const base::FilePath& virtual_path, | 339 const base::FilePath& virtual_path, |
| 342 const std::string& extension_id) { | 340 const std::string& extension_id) { |
| 343 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE)); | 341 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE)); |
| 344 | 342 |
| 345 base::AutoLock lock(lock_); | 343 base::AutoLock lock(lock_); |
| 346 base::FilePath watch_path = local_path; | 344 base::FilePath watch_path = local_path; |
| 347 bool is_remote_watch = false; | 345 bool is_remote_watch = false; |
| 348 // Tweak watch path for remote sources - we need to drop leading /special | 346 // Tweak watch path for remote sources - we need to drop leading /special |
| 349 // directory from there in order to be able to pair these events with | 347 // directory from there in order to be able to pair these events with |
| 350 // their change notifications. | 348 // their change notifications. |
| 351 if (drive::util::GetSpecialRemoteRootPath().IsParent(watch_path)) { | 349 if (drive::util::GetSpecialRemoteRootPath().IsParent(watch_path)) { |
| 352 watch_path = drive::util::ExtractDrivePath(watch_path); | 350 watch_path = drive::util::ExtractDrivePath(watch_path); |
| 353 is_remote_watch = true; | 351 is_remote_watch = true; |
| 354 BrowserThread::PostTask( | 352 BrowserThread::PostTask( |
| 355 BrowserThread::UI, FROM_HERE, | 353 BrowserThread::UI, FROM_HERE, |
| 356 base::Bind(&FileBrowserEventRouter::HandleRemoteUpdateRequestOnUIThread, | 354 base::Bind(&FileBrowserEventRouter::HandleRemoteUpdateRequestOnUIThread, |
| 357 this, true)); | 355 weak_factory_.GetWeakPtr(), true)); |
|
satorux1
2013/04/08 06:34:36
Hmm, this is also broken, as weak_factory_.GetWea
| |
| 358 } | 356 } |
| 359 | 357 |
| 360 WatcherMap::iterator iter = file_watchers_.find(watch_path); | 358 WatcherMap::iterator iter = file_watchers_.find(watch_path); |
| 361 if (iter == file_watchers_.end()) { | 359 if (iter == file_watchers_.end()) { |
| 362 scoped_ptr<FileWatcherExtensions> | 360 scoped_ptr<FileWatcherExtensions> |
| 363 watch(new FileWatcherExtensions(virtual_path, | 361 watch(new FileWatcherExtensions(virtual_path, |
| 364 extension_id, | 362 extension_id, |
| 365 is_remote_watch)); | 363 is_remote_watch)); |
| 366 | 364 |
| 367 if (watch->Watch(watch_path, file_watcher_callback_)) | 365 if (watch->Watch(watch_path, file_watcher_callback_)) |
| (...skipping 14 matching lines...) Expand all Loading... | |
| 382 base::AutoLock lock(lock_); | 380 base::AutoLock lock(lock_); |
| 383 base::FilePath watch_path = local_path; | 381 base::FilePath watch_path = local_path; |
| 384 // Tweak watch path for remote sources - we need to drop leading /special | 382 // Tweak watch path for remote sources - we need to drop leading /special |
| 385 // directory from there in order to be able to pair these events with | 383 // directory from there in order to be able to pair these events with |
| 386 // their change notifications. | 384 // their change notifications. |
| 387 if (drive::util::GetSpecialRemoteRootPath().IsParent(watch_path)) { | 385 if (drive::util::GetSpecialRemoteRootPath().IsParent(watch_path)) { |
| 388 watch_path = drive::util::ExtractDrivePath(watch_path); | 386 watch_path = drive::util::ExtractDrivePath(watch_path); |
| 389 BrowserThread::PostTask( | 387 BrowserThread::PostTask( |
| 390 BrowserThread::UI, FROM_HERE, | 388 BrowserThread::UI, FROM_HERE, |
| 391 base::Bind(&FileBrowserEventRouter::HandleRemoteUpdateRequestOnUIThread, | 389 base::Bind(&FileBrowserEventRouter::HandleRemoteUpdateRequestOnUIThread, |
| 392 this, false)); | 390 weak_factory_.GetWeakPtr(), false)); |
| 393 } | 391 } |
| 394 WatcherMap::iterator iter = file_watchers_.find(watch_path); | 392 WatcherMap::iterator iter = file_watchers_.find(watch_path); |
| 395 if (iter == file_watchers_.end()) | 393 if (iter == file_watchers_.end()) |
| 396 return; | 394 return; |
| 397 // Remove the renderer process for this watch. | 395 // Remove the renderer process for this watch. |
| 398 iter->second->RemoveExtension(extension_id); | 396 iter->second->RemoveExtension(extension_id); |
| 399 if (iter->second->GetRefCount() == 0) { | 397 if (iter->second->GetRefCount() == 0) { |
| 400 delete iter->second; | 398 delete iter->second; |
| 401 file_watchers_.erase(iter); | 399 file_watchers_.erase(iter); |
| 402 } | 400 } |
| (...skipping 568 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 971 } | 969 } |
| 972 | 970 |
| 973 bool FileBrowserEventRouter::FileWatcherExtensions::Watch( | 971 bool FileBrowserEventRouter::FileWatcherExtensions::Watch( |
| 974 const base::FilePath& path, | 972 const base::FilePath& path, |
| 975 const base::FilePathWatcher::Callback& callback) { | 973 const base::FilePathWatcher::Callback& callback) { |
| 976 if (is_remote_file_system_) | 974 if (is_remote_file_system_) |
| 977 return true; | 975 return true; |
| 978 | 976 |
| 979 return file_watcher_->Watch(path, false, callback); | 977 return file_watcher_->Watch(path, false, callback); |
| 980 } | 978 } |
| OLD | NEW |