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 <stddef.h> | 5 #include <stddef.h> |
6 #include <stdint.h> | 6 #include <stdint.h> |
7 #include <map> | 7 #include <map> |
8 #include <queue> | 8 #include <queue> |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
(...skipping 176 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
187 SetUp(true, true); | 187 SetUp(true, true); |
188 } | 188 } |
189 | 189 |
190 void SetUpNoValidator() { | 190 void SetUpNoValidator() { |
191 SetUp(true, false); | 191 SetUp(true, false); |
192 } | 192 } |
193 | 193 |
194 void SetUp(bool require_copy_or_move_validator, | 194 void SetUp(bool require_copy_or_move_validator, |
195 bool init_copy_or_move_validator) { | 195 bool init_copy_or_move_validator) { |
196 ASSERT_TRUE(base_.CreateUniqueTempDir()); | 196 ASSERT_TRUE(base_.CreateUniqueTempDir()); |
197 base::FilePath base_dir = base_.path(); | 197 base::FilePath base_dir = base_.GetPath(); |
198 quota_manager_ = | 198 quota_manager_ = |
199 new MockQuotaManager(false /* is_incognito */, base_dir, | 199 new MockQuotaManager(false /* is_incognito */, base_dir, |
200 base::ThreadTaskRunnerHandle::Get().get(), | 200 base::ThreadTaskRunnerHandle::Get().get(), |
201 base::ThreadTaskRunnerHandle::Get().get(), | 201 base::ThreadTaskRunnerHandle::Get().get(), |
202 NULL /* special storage policy */); | 202 NULL /* special storage policy */); |
203 quota_manager_proxy_ = new MockQuotaManagerProxy( | 203 quota_manager_proxy_ = new MockQuotaManagerProxy( |
204 quota_manager_.get(), base::ThreadTaskRunnerHandle::Get().get()); | 204 quota_manager_.get(), base::ThreadTaskRunnerHandle::Get().get()); |
205 file_system_context_ = | 205 file_system_context_ = |
206 CreateFileSystemContextForTesting(quota_manager_proxy_.get(), base_dir); | 206 CreateFileSystemContextForTesting(quota_manager_proxy_.get(), base_dir); |
207 | 207 |
(...skipping 508 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
716 current_size = records[j].size; | 716 current_size = records[j].size; |
717 } | 717 } |
718 } | 718 } |
719 } | 719 } |
720 } | 720 } |
721 } | 721 } |
722 | 722 |
723 TEST(LocalFileSystemCopyOrMoveOperationTest, StreamCopyHelper) { | 723 TEST(LocalFileSystemCopyOrMoveOperationTest, StreamCopyHelper) { |
724 base::ScopedTempDir temp_dir; | 724 base::ScopedTempDir temp_dir; |
725 ASSERT_TRUE(temp_dir.CreateUniqueTempDir()); | 725 ASSERT_TRUE(temp_dir.CreateUniqueTempDir()); |
726 base::FilePath source_path = temp_dir.path().AppendASCII("source"); | 726 base::FilePath source_path = temp_dir.GetPath().AppendASCII("source"); |
727 base::FilePath dest_path = temp_dir.path().AppendASCII("dest"); | 727 base::FilePath dest_path = temp_dir.GetPath().AppendASCII("dest"); |
728 const char kTestData[] = "abcdefghijklmnopqrstuvwxyz0123456789"; | 728 const char kTestData[] = "abcdefghijklmnopqrstuvwxyz0123456789"; |
729 base::WriteFile(source_path, kTestData, | 729 base::WriteFile(source_path, kTestData, |
730 arraysize(kTestData) - 1); // Exclude trailing '\0'. | 730 arraysize(kTestData) - 1); // Exclude trailing '\0'. |
731 | 731 |
732 base::MessageLoopForIO message_loop; | 732 base::MessageLoopForIO message_loop; |
733 base::Thread file_thread("file_thread"); | 733 base::Thread file_thread("file_thread"); |
734 ASSERT_TRUE(file_thread.Start()); | 734 ASSERT_TRUE(file_thread.Start()); |
735 ScopedThreadStopper thread_stopper(&file_thread); | 735 ScopedThreadStopper thread_stopper(&file_thread); |
736 ASSERT_TRUE(thread_stopper.is_valid()); | 736 ASSERT_TRUE(thread_stopper.is_valid()); |
737 | 737 |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
771 EXPECT_EQ(kTestData, content); | 771 EXPECT_EQ(kTestData, content); |
772 } | 772 } |
773 | 773 |
774 TEST(LocalFileSystemCopyOrMoveOperationTest, StreamCopyHelperWithFlush) { | 774 TEST(LocalFileSystemCopyOrMoveOperationTest, StreamCopyHelperWithFlush) { |
775 // Testing the same configuration as StreamCopyHelper, but with |need_flush| | 775 // Testing the same configuration as StreamCopyHelper, but with |need_flush| |
776 // parameter set to true. Since it is hard to test that the flush is indeed | 776 // parameter set to true. Since it is hard to test that the flush is indeed |
777 // taking place, this test just only verifies that the file is correctly | 777 // taking place, this test just only verifies that the file is correctly |
778 // written with or without the flag. | 778 // written with or without the flag. |
779 base::ScopedTempDir temp_dir; | 779 base::ScopedTempDir temp_dir; |
780 ASSERT_TRUE(temp_dir.CreateUniqueTempDir()); | 780 ASSERT_TRUE(temp_dir.CreateUniqueTempDir()); |
781 base::FilePath source_path = temp_dir.path().AppendASCII("source"); | 781 base::FilePath source_path = temp_dir.GetPath().AppendASCII("source"); |
782 base::FilePath dest_path = temp_dir.path().AppendASCII("dest"); | 782 base::FilePath dest_path = temp_dir.GetPath().AppendASCII("dest"); |
783 const char kTestData[] = "abcdefghijklmnopqrstuvwxyz0123456789"; | 783 const char kTestData[] = "abcdefghijklmnopqrstuvwxyz0123456789"; |
784 base::WriteFile(source_path, kTestData, | 784 base::WriteFile(source_path, kTestData, |
785 arraysize(kTestData) - 1); // Exclude trailing '\0'. | 785 arraysize(kTestData) - 1); // Exclude trailing '\0'. |
786 | 786 |
787 | 787 |
788 base::MessageLoopForIO message_loop; | 788 base::MessageLoopForIO message_loop; |
789 base::Thread file_thread("file_thread"); | 789 base::Thread file_thread("file_thread"); |
790 ASSERT_TRUE(file_thread.Start()); | 790 ASSERT_TRUE(file_thread.Start()); |
791 ScopedThreadStopper thread_stopper(&file_thread); | 791 ScopedThreadStopper thread_stopper(&file_thread); |
792 ASSERT_TRUE(thread_stopper.is_valid()); | 792 ASSERT_TRUE(thread_stopper.is_valid()); |
(...skipping 30 matching lines...) Expand all Loading... |
823 EXPECT_EQ(36, progress[4]); | 823 EXPECT_EQ(36, progress[4]); |
824 | 824 |
825 std::string content; | 825 std::string content; |
826 ASSERT_TRUE(base::ReadFileToString(dest_path, &content)); | 826 ASSERT_TRUE(base::ReadFileToString(dest_path, &content)); |
827 EXPECT_EQ(kTestData, content); | 827 EXPECT_EQ(kTestData, content); |
828 } | 828 } |
829 | 829 |
830 TEST(LocalFileSystemCopyOrMoveOperationTest, StreamCopyHelper_Cancel) { | 830 TEST(LocalFileSystemCopyOrMoveOperationTest, StreamCopyHelper_Cancel) { |
831 base::ScopedTempDir temp_dir; | 831 base::ScopedTempDir temp_dir; |
832 ASSERT_TRUE(temp_dir.CreateUniqueTempDir()); | 832 ASSERT_TRUE(temp_dir.CreateUniqueTempDir()); |
833 base::FilePath source_path = temp_dir.path().AppendASCII("source"); | 833 base::FilePath source_path = temp_dir.GetPath().AppendASCII("source"); |
834 base::FilePath dest_path = temp_dir.path().AppendASCII("dest"); | 834 base::FilePath dest_path = temp_dir.GetPath().AppendASCII("dest"); |
835 const char kTestData[] = "abcdefghijklmnopqrstuvwxyz0123456789"; | 835 const char kTestData[] = "abcdefghijklmnopqrstuvwxyz0123456789"; |
836 base::WriteFile(source_path, kTestData, | 836 base::WriteFile(source_path, kTestData, |
837 arraysize(kTestData) - 1); // Exclude trailing '\0'. | 837 arraysize(kTestData) - 1); // Exclude trailing '\0'. |
838 | 838 |
839 base::MessageLoopForIO message_loop; | 839 base::MessageLoopForIO message_loop; |
840 base::Thread file_thread("file_thread"); | 840 base::Thread file_thread("file_thread"); |
841 ASSERT_TRUE(file_thread.Start()); | 841 ASSERT_TRUE(file_thread.Start()); |
842 ScopedThreadStopper thread_stopper(&file_thread); | 842 ScopedThreadStopper thread_stopper(&file_thread); |
843 ASSERT_TRUE(thread_stopper.is_valid()); | 843 ASSERT_TRUE(thread_stopper.is_valid()); |
844 | 844 |
(...skipping 23 matching lines...) Expand all Loading... |
868 | 868 |
869 base::File::Error error = base::File::FILE_ERROR_FAILED; | 869 base::File::Error error = base::File::FILE_ERROR_FAILED; |
870 base::RunLoop run_loop; | 870 base::RunLoop run_loop; |
871 helper.Run(base::Bind(&AssignAndQuit, &run_loop, &error)); | 871 helper.Run(base::Bind(&AssignAndQuit, &run_loop, &error)); |
872 run_loop.Run(); | 872 run_loop.Run(); |
873 | 873 |
874 EXPECT_EQ(base::File::FILE_ERROR_ABORT, error); | 874 EXPECT_EQ(base::File::FILE_ERROR_ABORT, error); |
875 } | 875 } |
876 | 876 |
877 } // namespace content | 877 } // namespace content |
OLD | NEW |