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 |