| 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/drive/file_system.h" | 5 #include "chrome/browser/chromeos/drive/file_system.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/prefs/pref_service.h" | 9 #include "base/prefs/pref_service.h" |
| 10 #include "chrome/browser/chromeos/drive/change_list_loader.h" | 10 #include "chrome/browser/chromeos/drive/change_list_loader.h" |
| (...skipping 275 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 286 ResetComponents(); | 286 ResetComponents(); |
| 287 | 287 |
| 288 base::PostTaskAndReplyWithResult( | 288 base::PostTaskAndReplyWithResult( |
| 289 blocking_task_runner_, | 289 blocking_task_runner_, |
| 290 FROM_HERE, | 290 FROM_HERE, |
| 291 base::Bind(&ResetOnBlockingPool, resource_metadata_, cache_), | 291 base::Bind(&ResetOnBlockingPool, resource_metadata_, cache_), |
| 292 callback); | 292 callback); |
| 293 } | 293 } |
| 294 | 294 |
| 295 void FileSystem::ResetComponents() { | 295 void FileSystem::ResetComponents() { |
| 296 file_system::OperationObserver* observer = this; | 296 file_system::OperationDelegate* delegate = this; |
| 297 | 297 |
| 298 about_resource_loader_.reset(new internal::AboutResourceLoader(scheduler_)); | 298 about_resource_loader_.reset(new internal::AboutResourceLoader(scheduler_)); |
| 299 loader_controller_.reset(new internal::LoaderController); | 299 loader_controller_.reset(new internal::LoaderController); |
| 300 change_list_loader_.reset(new internal::ChangeListLoader( | 300 change_list_loader_.reset(new internal::ChangeListLoader( |
| 301 logger_, | 301 logger_, |
| 302 blocking_task_runner_.get(), | 302 blocking_task_runner_.get(), |
| 303 resource_metadata_, | 303 resource_metadata_, |
| 304 scheduler_, | 304 scheduler_, |
| 305 about_resource_loader_.get(), | 305 about_resource_loader_.get(), |
| 306 loader_controller_.get())); | 306 loader_controller_.get())); |
| 307 change_list_loader_->AddObserver(this); | 307 change_list_loader_->AddObserver(this); |
| 308 directory_loader_.reset(new internal::DirectoryLoader( | 308 directory_loader_.reset(new internal::DirectoryLoader( |
| 309 logger_, | 309 logger_, |
| 310 blocking_task_runner_.get(), | 310 blocking_task_runner_.get(), |
| 311 resource_metadata_, | 311 resource_metadata_, |
| 312 scheduler_, | 312 scheduler_, |
| 313 about_resource_loader_.get(), | 313 about_resource_loader_.get(), |
| 314 loader_controller_.get())); | 314 loader_controller_.get())); |
| 315 directory_loader_->AddObserver(this); | 315 directory_loader_->AddObserver(this); |
| 316 | 316 |
| 317 sync_client_.reset(new internal::SyncClient(blocking_task_runner_.get(), | 317 sync_client_.reset(new internal::SyncClient(blocking_task_runner_.get(), |
| 318 observer, | 318 delegate, |
| 319 scheduler_, | 319 scheduler_, |
| 320 resource_metadata_, | 320 resource_metadata_, |
| 321 cache_, | 321 cache_, |
| 322 loader_controller_.get(), | 322 loader_controller_.get(), |
| 323 temporary_file_directory_)); | 323 temporary_file_directory_)); |
| 324 | 324 |
| 325 copy_operation_.reset( | 325 copy_operation_.reset( |
| 326 new file_system::CopyOperation( | 326 new file_system::CopyOperation( |
| 327 blocking_task_runner_.get(), | 327 blocking_task_runner_.get(), |
| 328 observer, | 328 delegate, |
| 329 scheduler_, | 329 scheduler_, |
| 330 resource_metadata_, | 330 resource_metadata_, |
| 331 cache_, | 331 cache_, |
| 332 drive_service_->GetResourceIdCanonicalizer())); | 332 drive_service_->GetResourceIdCanonicalizer())); |
| 333 create_directory_operation_.reset(new file_system::CreateDirectoryOperation( | 333 create_directory_operation_.reset(new file_system::CreateDirectoryOperation( |
| 334 blocking_task_runner_.get(), observer, resource_metadata_)); | 334 blocking_task_runner_.get(), delegate, resource_metadata_)); |
| 335 create_file_operation_.reset( | 335 create_file_operation_.reset( |
| 336 new file_system::CreateFileOperation(blocking_task_runner_.get(), | 336 new file_system::CreateFileOperation(blocking_task_runner_.get(), |
| 337 observer, | 337 delegate, |
| 338 resource_metadata_)); | 338 resource_metadata_)); |
| 339 move_operation_.reset( | 339 move_operation_.reset( |
| 340 new file_system::MoveOperation(blocking_task_runner_.get(), | 340 new file_system::MoveOperation(blocking_task_runner_.get(), |
| 341 observer, | 341 delegate, |
| 342 resource_metadata_)); | 342 resource_metadata_)); |
| 343 open_file_operation_.reset( | 343 open_file_operation_.reset( |
| 344 new file_system::OpenFileOperation(blocking_task_runner_.get(), | 344 new file_system::OpenFileOperation(blocking_task_runner_.get(), |
| 345 observer, | 345 delegate, |
| 346 scheduler_, | 346 scheduler_, |
| 347 resource_metadata_, | 347 resource_metadata_, |
| 348 cache_, | 348 cache_, |
| 349 temporary_file_directory_)); | 349 temporary_file_directory_)); |
| 350 remove_operation_.reset( | 350 remove_operation_.reset( |
| 351 new file_system::RemoveOperation(blocking_task_runner_.get(), | 351 new file_system::RemoveOperation(blocking_task_runner_.get(), |
| 352 observer, | 352 delegate, |
| 353 resource_metadata_, | 353 resource_metadata_, |
| 354 cache_)); | 354 cache_)); |
| 355 touch_operation_.reset(new file_system::TouchOperation( | 355 touch_operation_.reset(new file_system::TouchOperation( |
| 356 blocking_task_runner_.get(), observer, resource_metadata_)); | 356 blocking_task_runner_.get(), delegate, resource_metadata_)); |
| 357 truncate_operation_.reset( | 357 truncate_operation_.reset( |
| 358 new file_system::TruncateOperation(blocking_task_runner_.get(), | 358 new file_system::TruncateOperation(blocking_task_runner_.get(), |
| 359 observer, | 359 delegate, |
| 360 scheduler_, | 360 scheduler_, |
| 361 resource_metadata_, | 361 resource_metadata_, |
| 362 cache_, | 362 cache_, |
| 363 temporary_file_directory_)); | 363 temporary_file_directory_)); |
| 364 download_operation_.reset( | 364 download_operation_.reset( |
| 365 new file_system::DownloadOperation(blocking_task_runner_.get(), | 365 new file_system::DownloadOperation(blocking_task_runner_.get(), |
| 366 observer, | 366 delegate, |
| 367 scheduler_, | 367 scheduler_, |
| 368 resource_metadata_, | 368 resource_metadata_, |
| 369 cache_, | 369 cache_, |
| 370 temporary_file_directory_)); | 370 temporary_file_directory_)); |
| 371 search_operation_.reset(new file_system::SearchOperation( | 371 search_operation_.reset(new file_system::SearchOperation( |
| 372 blocking_task_runner_.get(), scheduler_, resource_metadata_, | 372 blocking_task_runner_.get(), scheduler_, resource_metadata_, |
| 373 loader_controller_.get())); | 373 loader_controller_.get())); |
| 374 get_file_for_saving_operation_.reset( | 374 get_file_for_saving_operation_.reset( |
| 375 new file_system::GetFileForSavingOperation(logger_, | 375 new file_system::GetFileForSavingOperation(logger_, |
| 376 blocking_task_runner_.get(), | 376 blocking_task_runner_.get(), |
| 377 observer, | 377 delegate, |
| 378 scheduler_, | 378 scheduler_, |
| 379 resource_metadata_, | 379 resource_metadata_, |
| 380 cache_, | 380 cache_, |
| 381 temporary_file_directory_)); | 381 temporary_file_directory_)); |
| 382 } | 382 } |
| 383 | 383 |
| 384 void FileSystem::CheckForUpdates() { | 384 void FileSystem::CheckForUpdates() { |
| 385 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 385 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
| 386 DVLOG(1) << "CheckForUpdates"; | 386 DVLOG(1) << "CheckForUpdates"; |
| 387 | 387 |
| (...skipping 601 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 989 FROM_HERE, | 989 FROM_HERE, |
| 990 base::Bind(&GetPathFromResourceIdOnBlockingPool, | 990 base::Bind(&GetPathFromResourceIdOnBlockingPool, |
| 991 resource_metadata_, | 991 resource_metadata_, |
| 992 resource_id, | 992 resource_id, |
| 993 file_path), | 993 file_path), |
| 994 base::Bind(&GetPathFromResourceIdAfterGetPath, | 994 base::Bind(&GetPathFromResourceIdAfterGetPath, |
| 995 base::Owned(file_path), | 995 base::Owned(file_path), |
| 996 callback)); | 996 callback)); |
| 997 } | 997 } |
| 998 } // namespace drive | 998 } // namespace drive |
| OLD | NEW |