| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/sync_file_system/local/canned_syncable_file_system.h" | 5 #include "chrome/browser/sync_file_system/local/canned_syncable_file_system.h" |
| 6 | 6 |
| 7 #include <stddef.h> | 7 #include <stddef.h> |
| 8 #include <algorithm> | 8 #include <algorithm> |
| 9 #include <iterator> | 9 #include <iterator> |
| 10 #include <utility> | 10 #include <utility> |
| (...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 62 template <typename R> | 62 template <typename R> |
| 63 R RunOnThread( | 63 R RunOnThread( |
| 64 base::SingleThreadTaskRunner* task_runner, | 64 base::SingleThreadTaskRunner* task_runner, |
| 65 const tracked_objects::Location& location, | 65 const tracked_objects::Location& location, |
| 66 const base::Callback<void(const base::Callback<void(R)>& callback)>& task) { | 66 const base::Callback<void(const base::Callback<void(R)>& callback)>& task) { |
| 67 R result; | 67 R result; |
| 68 base::RunLoop run_loop; | 68 base::RunLoop run_loop; |
| 69 task_runner->PostTask( | 69 task_runner->PostTask( |
| 70 location, | 70 location, |
| 71 base::Bind(task, base::Bind(&AssignAndQuit<R>, | 71 base::Bind(task, base::Bind(&AssignAndQuit<R>, |
| 72 base::ThreadTaskRunnerHandle::Get(), | 72 base::RetainedRef( |
| 73 run_loop.QuitClosure(), | 73 base::ThreadTaskRunnerHandle::Get()), |
| 74 &result))); | 74 run_loop.QuitClosure(), &result))); |
| 75 run_loop.Run(); | 75 run_loop.Run(); |
| 76 return result; | 76 return result; |
| 77 } | 77 } |
| 78 | 78 |
| 79 void RunOnThread(base::SingleThreadTaskRunner* task_runner, | 79 void RunOnThread(base::SingleThreadTaskRunner* task_runner, |
| 80 const tracked_objects::Location& location, | 80 const tracked_objects::Location& location, |
| 81 const base::Closure& task) { | 81 const base::Closure& task) { |
| 82 base::RunLoop run_loop; | 82 base::RunLoop run_loop; |
| 83 task_runner->PostTaskAndReply( | 83 task_runner->PostTaskAndReply( |
| 84 location, task, | 84 location, task, |
| 85 base::Bind(base::IgnoreResult( | 85 base::Bind(base::IgnoreResult( |
| 86 base::Bind(&base::SingleThreadTaskRunner::PostTask, | 86 base::Bind(&base::SingleThreadTaskRunner::PostTask, |
| 87 base::ThreadTaskRunnerHandle::Get(), | 87 base::ThreadTaskRunnerHandle::Get(), |
| 88 FROM_HERE, run_loop.QuitClosure())))); | 88 FROM_HERE, run_loop.QuitClosure())))); |
| 89 run_loop.Run(); | 89 run_loop.Run(); |
| 90 } | 90 } |
| 91 | 91 |
| 92 void EnsureRunningOn(base::SingleThreadTaskRunner* runner) { | 92 void EnsureRunningOn(base::SingleThreadTaskRunner* runner) { |
| 93 EXPECT_TRUE(runner->RunsTasksOnCurrentThread()); | 93 EXPECT_TRUE(runner->RunsTasksOnCurrentThread()); |
| 94 } | 94 } |
| 95 | 95 |
| 96 void VerifySameTaskRunner( | 96 void VerifySameTaskRunner( |
| 97 base::SingleThreadTaskRunner* runner1, | 97 base::SingleThreadTaskRunner* runner1, |
| 98 base::SingleThreadTaskRunner* runner2) { | 98 base::SingleThreadTaskRunner* runner2) { |
| 99 ASSERT_TRUE(runner1 != nullptr); | 99 ASSERT_TRUE(runner1 != nullptr); |
| 100 ASSERT_TRUE(runner2 != nullptr); | 100 ASSERT_TRUE(runner2 != nullptr); |
| 101 runner1->PostTask(FROM_HERE, | 101 runner1->PostTask(FROM_HERE, |
| 102 base::Bind(&EnsureRunningOn, make_scoped_refptr(runner2))); | 102 base::Bind(&EnsureRunningOn, base::RetainedRef(runner2))); |
| 103 } | 103 } |
| 104 | 104 |
| 105 void OnCreateSnapshotFileAndVerifyData( | 105 void OnCreateSnapshotFileAndVerifyData( |
| 106 const std::string& expected_data, | 106 const std::string& expected_data, |
| 107 const CannedSyncableFileSystem::StatusCallback& callback, | 107 const CannedSyncableFileSystem::StatusCallback& callback, |
| 108 base::File::Error result, | 108 base::File::Error result, |
| 109 const base::File::Info& file_info, | 109 const base::File::Info& file_info, |
| 110 const base::FilePath& platform_path, | 110 const base::FilePath& platform_path, |
| 111 const scoped_refptr<storage::ShareableFileReference>& /* file_ref */) { | 111 const scoped_refptr<storage::ShareableFileReference>& /* file_ref */) { |
| 112 if (result != base::File::FILE_OK) { | 112 if (result != base::File::FILE_OK) { |
| (...skipping 172 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 285 GURL url(root_url_.spec() + path); | 285 GURL url(root_url_.spec() + path); |
| 286 return file_system_context_->CrackURL(url); | 286 return file_system_context_->CrackURL(url); |
| 287 } | 287 } |
| 288 | 288 |
| 289 File::Error CannedSyncableFileSystem::OpenFileSystem() { | 289 File::Error CannedSyncableFileSystem::OpenFileSystem() { |
| 290 EXPECT_TRUE(is_filesystem_set_up_); | 290 EXPECT_TRUE(is_filesystem_set_up_); |
| 291 | 291 |
| 292 base::RunLoop run_loop; | 292 base::RunLoop run_loop; |
| 293 io_task_runner_->PostTask( | 293 io_task_runner_->PostTask( |
| 294 FROM_HERE, | 294 FROM_HERE, |
| 295 base::Bind(&CannedSyncableFileSystem::DoOpenFileSystem, | 295 base::Bind( |
| 296 base::Unretained(this), | 296 &CannedSyncableFileSystem::DoOpenFileSystem, base::Unretained(this), |
| 297 base::Bind(&CannedSyncableFileSystem::DidOpenFileSystem, | 297 base::Bind(&CannedSyncableFileSystem::DidOpenFileSystem, |
| 298 base::Unretained(this), | 298 base::Unretained(this), |
| 299 base::ThreadTaskRunnerHandle::Get(), | 299 base::RetainedRef(base::ThreadTaskRunnerHandle::Get()), |
| 300 run_loop.QuitClosure()))); | 300 run_loop.QuitClosure()))); |
| 301 run_loop.Run(); | 301 run_loop.Run(); |
| 302 | 302 |
| 303 if (backend()->sync_context()) { | 303 if (backend()->sync_context()) { |
| 304 // Register 'this' as a sync status observer. | 304 // Register 'this' as a sync status observer. |
| 305 RunOnThread( | 305 RunOnThread( |
| 306 io_task_runner_.get(), | 306 io_task_runner_.get(), |
| 307 FROM_HERE, | 307 FROM_HERE, |
| 308 base::Bind(&CannedSyncableFileSystem::InitializeSyncStatusObserver, | 308 base::Bind(&CannedSyncableFileSystem::InitializeSyncStatusObserver, |
| 309 base::Unretained(this))); | 309 base::Unretained(this))); |
| 310 } | 310 } |
| (...skipping 420 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 731 const GURL& root, | 731 const GURL& root, |
| 732 const std::string& name, | 732 const std::string& name, |
| 733 File::Error result) { | 733 File::Error result) { |
| 734 if (io_task_runner_->RunsTasksOnCurrentThread()) { | 734 if (io_task_runner_->RunsTasksOnCurrentThread()) { |
| 735 EXPECT_FALSE(is_filesystem_opened_); | 735 EXPECT_FALSE(is_filesystem_opened_); |
| 736 is_filesystem_opened_ = true; | 736 is_filesystem_opened_ = true; |
| 737 } | 737 } |
| 738 if (!original_task_runner->RunsTasksOnCurrentThread()) { | 738 if (!original_task_runner->RunsTasksOnCurrentThread()) { |
| 739 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); | 739 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); |
| 740 original_task_runner->PostTask( | 740 original_task_runner->PostTask( |
| 741 FROM_HERE, | 741 FROM_HERE, base::Bind(&CannedSyncableFileSystem::DidOpenFileSystem, |
| 742 base::Bind(&CannedSyncableFileSystem::DidOpenFileSystem, | 742 base::Unretained(this), |
| 743 base::Unretained(this), | 743 base::RetainedRef(original_task_runner), |
| 744 make_scoped_refptr(original_task_runner), | 744 quit_closure, root, name, result)); |
| 745 quit_closure, | |
| 746 root, name, result)); | |
| 747 return; | 745 return; |
| 748 } | 746 } |
| 749 result_ = result; | 747 result_ = result; |
| 750 root_url_ = root; | 748 root_url_ = root; |
| 751 quit_closure.Run(); | 749 quit_closure.Run(); |
| 752 } | 750 } |
| 753 | 751 |
| 754 void CannedSyncableFileSystem::DidInitializeFileSystemContext( | 752 void CannedSyncableFileSystem::DidInitializeFileSystemContext( |
| 755 const base::Closure& quit_closure, | 753 const base::Closure& quit_closure, |
| 756 SyncStatusCode status) { | 754 SyncStatusCode status) { |
| 757 sync_status_ = status; | 755 sync_status_ = status; |
| 758 quit_closure.Run(); | 756 quit_closure.Run(); |
| 759 } | 757 } |
| 760 | 758 |
| 761 void CannedSyncableFileSystem::InitializeSyncStatusObserver() { | 759 void CannedSyncableFileSystem::InitializeSyncStatusObserver() { |
| 762 ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread()); | 760 ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread()); |
| 763 backend()->sync_context()->sync_status()->AddObserver(this); | 761 backend()->sync_context()->sync_status()->AddObserver(this); |
| 764 } | 762 } |
| 765 | 763 |
| 766 } // namespace sync_file_system | 764 } // namespace sync_file_system |
| OLD | NEW |