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 "components/drive/chromeos/file_cache.h" | 5 #include "components/drive/chromeos/file_cache.h" |
| 6 | 6 |
| 7 #include <linux/fs.h> | |
| 7 #include <stddef.h> | 8 #include <stddef.h> |
| 8 #include <stdint.h> | 9 #include <stdint.h> |
| 9 #include <sys/stat.h> | 10 #include <sys/ioctl.h> |
| 10 #include <sys/types.h> | 11 #include <sys/xattr.h> |
| 11 #include <unistd.h> | |
| 12 | 12 |
| 13 #include <string> | 13 #include <string> |
| 14 #include <vector> | 14 #include <vector> |
| 15 | 15 |
| 16 #include "base/callback_helpers.h" | 16 #include "base/callback_helpers.h" |
| 17 #include "base/files/file.h" | |
| 17 #include "base/files/file_enumerator.h" | 18 #include "base/files/file_enumerator.h" |
| 18 #include "base/files/file_util.h" | 19 #include "base/files/file_util.h" |
| 19 #include "base/files/scoped_temp_dir.h" | 20 #include "base/files/scoped_temp_dir.h" |
| 20 #include "base/md5.h" | 21 #include "base/md5.h" |
| 21 #include "base/path_service.h" | 22 #include "base/path_service.h" |
| 22 #include "base/single_thread_task_runner.h" | 23 #include "base/single_thread_task_runner.h" |
| 24 #include "base/stl_util.h" | |
| 23 #include "base/strings/stringprintf.h" | 25 #include "base/strings/stringprintf.h" |
| 24 #include "base/thread_task_runner_handle.h" | 26 #include "base/thread_task_runner_handle.h" |
| 25 #include "base/time/time.h" | 27 #include "base/time/time.h" |
| 26 #include "components/drive/chromeos/drive_test_util.h" | 28 #include "components/drive/chromeos/drive_test_util.h" |
| 27 #include "components/drive/chromeos/fake_free_disk_space_getter.h" | 29 #include "components/drive/chromeos/fake_free_disk_space_getter.h" |
| 28 #include "components/drive/drive.pb.h" | 30 #include "components/drive/drive.pb.h" |
| 29 #include "components/drive/file_system_core_util.h" | 31 #include "components/drive/file_system_core_util.h" |
| 30 #include "components/drive/resource_metadata_storage.h" | 32 #include "components/drive/resource_metadata_storage.h" |
| 31 #include "content/public/test/test_browser_thread_bundle.h" | 33 #include "content/public/test/test_browser_thread_bundle.h" |
| 32 #include "google_apis/drive/test_util.h" | 34 #include "google_apis/drive/test_util.h" |
| 33 #include "testing/gtest/include/gtest/gtest.h" | 35 #include "testing/gtest/include/gtest/gtest.h" |
| 34 | 36 |
| 35 namespace drive { | 37 namespace drive { |
| 36 namespace internal { | 38 namespace internal { |
| 37 namespace { | 39 namespace { |
| 38 | 40 |
| 39 const base::FilePath::CharType kCacheFileDirectory[] = | 41 const base::FilePath::CharType kCacheFileDirectory[] = |
| 40 FILE_PATH_LITERAL("files"); | 42 FILE_PATH_LITERAL("files"); |
| 41 const base::FilePath::CharType kNewCacheFileDirectory[] = | |
| 42 FILE_PATH_LITERAL("blobs"); | |
| 43 const base::FilePath::CharType kLinkDirectory[] = FILE_PATH_LITERAL("links"); | |
| 44 | 43 |
| 45 const int kTemporaryFileSizeInBytes = 10; | 44 const int kTemporaryFileSizeInBytes = 10; |
| 46 | 45 |
| 47 int GetNumberOfLinks(const base::FilePath& file_path) { | 46 int64_t GetFileAttributes(const base::FilePath& file_path) { |
| 48 struct stat result; | 47 base::File file(file_path, base::File::FLAG_OPEN | base::File::FLAG_READ); |
| 49 if (stat(file_path.AsUTF8Unsafe().c_str(), &result) != 0) { | 48 if (!file.IsValid()) return -1; |
| 50 return -1; | 49 int64_t flags = 0; |
| 51 } | 50 if (ioctl(file.GetPlatformFile(), FS_IOC_GETFLAGS, &flags) < 0) return -1; |
| 52 return result.st_nlink; | 51 return flags; |
| 52 } | |
| 53 | |
| 54 void ExpectIsRemovable(const base::FilePath& file_path) { | |
| 55 EXPECT_EQ(static_cast<int64_t>(FS_NODUMP_FL | FS_EXTENT_FL), | |
|
hashimoto
2016/05/10 10:33:49
When something goes wrong, EXPECT_EQ here results
oka
2016/05/11 04:24:10
Done.
| |
| 56 GetFileAttributes(file_path)); | |
| 57 } | |
| 58 | |
| 59 void ExpectIsUnremovable(const base::FilePath& file_path) { | |
| 60 EXPECT_EQ(static_cast<int64_t>(FS_EXTENT_FL), GetFileAttributes(file_path)); | |
| 53 } | 61 } |
| 54 | 62 |
| 55 } // namespace | 63 } // namespace |
| 56 | 64 |
| 57 // Tests FileCache methods working with the blocking task runner. | 65 // Tests FileCache methods working with the blocking task runner. |
| 58 class FileCacheTest : public testing::Test { | 66 class FileCacheTest : public testing::Test { |
| 59 protected: | 67 protected: |
| 60 void SetUp() override { | 68 void SetUp() override { |
| 61 ASSERT_TRUE(temp_dir_.CreateUniqueTempDir()); | 69 ASSERT_TRUE(temp_dir_.CreateUniqueTempDir()); |
| 62 const base::FilePath metadata_dir = temp_dir_.path().AppendASCII("meta"); | 70 const base::FilePath metadata_dir = temp_dir_.path().AppendASCII("meta"); |
| (...skipping 12 matching lines...) Expand all Loading... | |
| 75 cache_.reset(new FileCache(metadata_storage_.get(), cache_files_dir_, | 83 cache_.reset(new FileCache(metadata_storage_.get(), cache_files_dir_, |
| 76 base::ThreadTaskRunnerHandle::Get().get(), | 84 base::ThreadTaskRunnerHandle::Get().get(), |
| 77 fake_free_disk_space_getter_.get())); | 85 fake_free_disk_space_getter_.get())); |
| 78 ASSERT_TRUE(cache_->Initialize()); | 86 ASSERT_TRUE(cache_->Initialize()); |
| 79 } | 87 } |
| 80 | 88 |
| 81 static bool RenameCacheFilesToNewFormat(FileCache* cache) { | 89 static bool RenameCacheFilesToNewFormat(FileCache* cache) { |
| 82 return cache->RenameCacheFilesToNewFormat(); | 90 return cache->RenameCacheFilesToNewFormat(); |
| 83 } | 91 } |
| 84 | 92 |
| 93 base::FilePath GetCacheFilePath(const std::string& id) { | |
| 94 return cache_->GetCacheFilePath(id); | |
| 95 } | |
| 96 | |
| 85 base::FilePath AddTestEntry(const std::string id, | 97 base::FilePath AddTestEntry(const std::string id, |
| 86 const std::string md5, | 98 const std::string md5, |
| 87 const time_t last_accessed, | 99 const time_t last_accessed, |
| 88 const base::FilePath& src_file) { | 100 const base::FilePath& src_file) { |
| 89 ResourceEntry entry; | 101 ResourceEntry entry; |
| 90 entry.set_local_id(id); | 102 entry.set_local_id(id); |
| 91 entry.mutable_file_info()->set_last_accessed(last_accessed); | 103 entry.mutable_file_info()->set_last_accessed(last_accessed); |
| 92 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry)); | 104 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry)); |
| 93 EXPECT_EQ(FILE_ERROR_OK, | 105 EXPECT_EQ(FILE_ERROR_OK, |
| 94 cache_->Store(id, md5, src_file, FileCache::FILE_OPERATION_COPY)); | 106 cache_->Store(id, md5, src_file, FileCache::FILE_OPERATION_COPY)); |
| (...skipping 320 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 415 id, md5, src_file_path, FileCache::FILE_OPERATION_COPY)); | 427 id, md5, src_file_path, FileCache::FILE_OPERATION_COPY)); |
| 416 | 428 |
| 417 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); | 429 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); |
| 418 EXPECT_TRUE(entry.file_specific_info().cache_state().is_present()); | 430 EXPECT_TRUE(entry.file_specific_info().cache_state().is_present()); |
| 419 EXPECT_EQ(md5, entry.file_specific_info().cache_state().md5()); | 431 EXPECT_EQ(md5, entry.file_specific_info().cache_state().md5()); |
| 420 | 432 |
| 421 base::FilePath cache_file_path; | 433 base::FilePath cache_file_path; |
| 422 EXPECT_EQ(FILE_ERROR_OK, cache_->GetFile(id, &cache_file_path)); | 434 EXPECT_EQ(FILE_ERROR_OK, cache_->GetFile(id, &cache_file_path)); |
| 423 EXPECT_TRUE(base::ContentsEqual(src_file_path, cache_file_path)); | 435 EXPECT_TRUE(base::ContentsEqual(src_file_path, cache_file_path)); |
| 424 | 436 |
| 437 base::FilePath dest_file_path = GetCacheFilePath(id); | |
| 438 ExpectIsRemovable(dest_file_path); | |
| 439 | |
| 425 // Store a non-existent file. | 440 // Store a non-existent file. |
| 426 EXPECT_EQ(FILE_ERROR_FAILED, cache_->Store( | 441 EXPECT_EQ(FILE_ERROR_FAILED, cache_->Store( |
| 427 id, md5, base::FilePath::FromUTF8Unsafe("non_existent_file"), | 442 id, md5, base::FilePath::FromUTF8Unsafe("non_existent_file"), |
| 428 FileCache::FILE_OPERATION_COPY)); | 443 FileCache::FILE_OPERATION_COPY)); |
| 429 | 444 |
| 430 // Passing empty MD5 marks the entry as dirty. | 445 // Passing empty MD5 marks the entry as dirty. |
| 431 EXPECT_EQ(FILE_ERROR_OK, cache_->Store( | 446 EXPECT_EQ(FILE_ERROR_OK, cache_->Store( |
| 432 id, std::string(), src_file_path, FileCache::FILE_OPERATION_COPY)); | 447 id, std::string(), src_file_path, FileCache::FILE_OPERATION_COPY)); |
| 433 | 448 |
| 434 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); | 449 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); |
| 435 EXPECT_TRUE(entry.file_specific_info().cache_state().is_present()); | 450 EXPECT_TRUE(entry.file_specific_info().cache_state().is_present()); |
| 436 EXPECT_TRUE(entry.file_specific_info().cache_state().md5().empty()); | 451 EXPECT_TRUE(entry.file_specific_info().cache_state().md5().empty()); |
| 437 EXPECT_TRUE(entry.file_specific_info().cache_state().is_dirty()); | 452 EXPECT_TRUE(entry.file_specific_info().cache_state().is_dirty()); |
| 453 ExpectIsUnremovable(dest_file_path); | |
| 438 | 454 |
| 439 // No free space available. | 455 // No free space available. |
| 440 fake_free_disk_space_getter_->set_default_value(0); | 456 fake_free_disk_space_getter_->set_default_value(0); |
| 441 | 457 |
| 442 EXPECT_EQ(FILE_ERROR_NO_LOCAL_SPACE, cache_->Store( | 458 EXPECT_EQ(FILE_ERROR_NO_LOCAL_SPACE, cache_->Store( |
| 443 id, md5, src_file_path, FileCache::FILE_OPERATION_COPY)); | 459 id, md5, src_file_path, FileCache::FILE_OPERATION_COPY)); |
| 444 } | 460 } |
| 445 | 461 |
| 446 TEST_F(FileCacheTest, PinAndUnpin) { | 462 TEST_F(FileCacheTest, PinAndUnpin) { |
| 447 const base::FilePath src_file_path = temp_dir_.path().Append("test.dat"); | 463 const base::FilePath src_file_path = temp_dir_.path().Append("test.dat"); |
| 448 const std::string src_contents = "test"; | 464 const std::string src_contents = "test"; |
| 449 EXPECT_TRUE(google_apis::test_util::WriteStringToFile(src_file_path, | 465 EXPECT_TRUE(google_apis::test_util::WriteStringToFile(src_file_path, |
| 450 src_contents)); | 466 src_contents)); |
| 451 std::string id("id_present"); | 467 std::string id("id_present"); |
| 452 std::string md5(base::MD5String(src_contents)); | 468 std::string md5(base::MD5String(src_contents)); |
| 453 | 469 |
| 454 // Store a file. | 470 // Store a file. |
| 455 ResourceEntry entry; | 471 ResourceEntry entry; |
| 456 entry.set_local_id(id); | 472 entry.set_local_id(id); |
| 457 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry)); | 473 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry)); |
| 458 EXPECT_EQ(FILE_ERROR_OK, cache_->Store( | 474 EXPECT_EQ(FILE_ERROR_OK, cache_->Store( |
| 459 id, md5, src_file_path, FileCache::FILE_OPERATION_COPY)); | 475 id, md5, src_file_path, FileCache::FILE_OPERATION_COPY)); |
| 460 | 476 |
| 477 const base::FilePath dest_file_path = GetCacheFilePath(id); | |
| 461 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); | 478 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); |
| 462 EXPECT_FALSE(entry.file_specific_info().cache_state().is_pinned()); | 479 EXPECT_FALSE(entry.file_specific_info().cache_state().is_pinned()); |
| 480 ExpectIsRemovable(dest_file_path); | |
| 463 | 481 |
| 464 // Pin the existing file. | 482 // Pin the existing file. |
| 465 EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(id)); | 483 EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(id)); |
| 466 | 484 |
| 467 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); | 485 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); |
| 468 EXPECT_TRUE(entry.file_specific_info().cache_state().is_pinned()); | 486 EXPECT_TRUE(entry.file_specific_info().cache_state().is_pinned()); |
| 487 ExpectIsUnremovable(dest_file_path); | |
| 469 | 488 |
| 470 // Unpin the file. | 489 // Unpin the file. |
| 471 EXPECT_EQ(FILE_ERROR_OK, cache_->Unpin(id)); | 490 EXPECT_EQ(FILE_ERROR_OK, cache_->Unpin(id)); |
| 472 | 491 |
| 473 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); | 492 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); |
| 474 EXPECT_FALSE(entry.file_specific_info().cache_state().is_pinned()); | 493 EXPECT_FALSE(entry.file_specific_info().cache_state().is_pinned()); |
| 494 ExpectIsRemovable(dest_file_path); | |
| 475 | 495 |
| 476 // Pin a non-present file. | 496 // Pin a non-present file. |
| 477 std::string id_non_present = "id_non_present"; | 497 std::string id_non_present = "id_non_present"; |
| 478 entry.Clear(); | 498 entry.Clear(); |
| 479 entry.set_local_id(id_non_present); | 499 entry.set_local_id(id_non_present); |
| 480 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry)); | 500 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry)); |
| 481 EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(id_non_present)); | 501 EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(id_non_present)); |
| 482 | 502 |
| 483 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id_non_present, &entry)); | 503 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id_non_present, &entry)); |
| 484 EXPECT_TRUE(entry.file_specific_info().cache_state().is_pinned()); | 504 EXPECT_TRUE(entry.file_specific_info().cache_state().is_pinned()); |
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 533 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry)); | 553 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry)); |
| 534 ASSERT_EQ(FILE_ERROR_OK, cache_->Store(id, "md5", src_file, | 554 ASSERT_EQ(FILE_ERROR_OK, cache_->Store(id, "md5", src_file, |
| 535 FileCache::FILE_OPERATION_COPY)); | 555 FileCache::FILE_OPERATION_COPY)); |
| 536 EXPECT_EQ(0, entry.file_info().last_modified()); | 556 EXPECT_EQ(0, entry.file_info().last_modified()); |
| 537 | 557 |
| 538 // Entry is not dirty nor opened. | 558 // Entry is not dirty nor opened. |
| 539 EXPECT_FALSE(cache_->IsOpenedForWrite(id)); | 559 EXPECT_FALSE(cache_->IsOpenedForWrite(id)); |
| 540 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); | 560 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); |
| 541 EXPECT_FALSE(entry.file_specific_info().cache_state().is_dirty()); | 561 EXPECT_FALSE(entry.file_specific_info().cache_state().is_dirty()); |
| 542 | 562 |
| 563 const base::FilePath dest_file = GetCacheFilePath(id); | |
| 564 ExpectIsRemovable(dest_file); | |
| 565 | |
| 543 // Open (1). | 566 // Open (1). |
| 544 std::unique_ptr<base::ScopedClosureRunner> file_closer1; | 567 std::unique_ptr<base::ScopedClosureRunner> file_closer1; |
| 545 EXPECT_EQ(FILE_ERROR_OK, cache_->OpenForWrite(id, &file_closer1)); | 568 EXPECT_EQ(FILE_ERROR_OK, cache_->OpenForWrite(id, &file_closer1)); |
| 546 EXPECT_TRUE(cache_->IsOpenedForWrite(id)); | 569 EXPECT_TRUE(cache_->IsOpenedForWrite(id)); |
| 547 | 570 |
| 548 // Entry is dirty. | 571 // Entry is dirty. |
| 549 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); | 572 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); |
| 550 EXPECT_TRUE(entry.file_specific_info().cache_state().is_dirty()); | 573 EXPECT_TRUE(entry.file_specific_info().cache_state().is_dirty()); |
| 574 ExpectIsUnremovable(dest_file); | |
| 551 | 575 |
| 552 // Open (2). | 576 // Open (2). |
| 553 std::unique_ptr<base::ScopedClosureRunner> file_closer2; | 577 std::unique_ptr<base::ScopedClosureRunner> file_closer2; |
| 554 EXPECT_EQ(FILE_ERROR_OK, cache_->OpenForWrite(id, &file_closer2)); | 578 EXPECT_EQ(FILE_ERROR_OK, cache_->OpenForWrite(id, &file_closer2)); |
| 555 EXPECT_TRUE(cache_->IsOpenedForWrite(id)); | 579 EXPECT_TRUE(cache_->IsOpenedForWrite(id)); |
| 556 | 580 |
| 557 // Close (1). | 581 // Close (1). |
| 558 file_closer1.reset(); | 582 file_closer1.reset(); |
| 559 base::RunLoop().RunUntilIdle(); | 583 base::RunLoop().RunUntilIdle(); |
| 560 EXPECT_TRUE(cache_->IsOpenedForWrite(id)); | 584 EXPECT_TRUE(cache_->IsOpenedForWrite(id)); |
| (...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 619 base::FilePath src_file; | 643 base::FilePath src_file; |
| 620 ASSERT_TRUE(base::CreateTemporaryFileInDir(temp_dir_.path(), &src_file)); | 644 ASSERT_TRUE(base::CreateTemporaryFileInDir(temp_dir_.path(), &src_file)); |
| 621 | 645 |
| 622 const std::string id = "id"; | 646 const std::string id = "id"; |
| 623 ResourceEntry entry; | 647 ResourceEntry entry; |
| 624 entry.set_local_id(id); | 648 entry.set_local_id(id); |
| 625 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry)); | 649 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry)); |
| 626 ASSERT_EQ(FILE_ERROR_OK, cache_->Store(id, "md5", src_file, | 650 ASSERT_EQ(FILE_ERROR_OK, cache_->Store(id, "md5", src_file, |
| 627 FileCache::FILE_OPERATION_COPY)); | 651 FileCache::FILE_OPERATION_COPY)); |
| 628 | 652 |
| 653 const base::FilePath dest_file = GetCacheFilePath(id); | |
| 654 ExpectIsRemovable(dest_file); | |
| 655 | |
| 629 // Open the file. | 656 // Open the file. |
| 630 std::unique_ptr<base::ScopedClosureRunner> file_closer; | 657 std::unique_ptr<base::ScopedClosureRunner> file_closer; |
| 631 EXPECT_EQ(FILE_ERROR_OK, cache_->OpenForWrite(id, &file_closer)); | 658 EXPECT_EQ(FILE_ERROR_OK, cache_->OpenForWrite(id, &file_closer)); |
| 632 | 659 |
| 633 // Entry is dirty. | 660 // Entry is dirty. |
| 634 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); | 661 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); |
| 635 EXPECT_TRUE(entry.file_specific_info().cache_state().is_dirty()); | 662 EXPECT_TRUE(entry.file_specific_info().cache_state().is_dirty()); |
| 663 ExpectIsUnremovable(dest_file); | |
| 636 | 664 |
| 637 // Cannot clear the dirty bit of an opened entry. | 665 // Cannot clear the dirty bit of an opened entry. |
| 638 EXPECT_EQ(FILE_ERROR_IN_USE, cache_->ClearDirty(id)); | 666 EXPECT_EQ(FILE_ERROR_IN_USE, cache_->ClearDirty(id)); |
| 667 ExpectIsUnremovable(dest_file); | |
| 639 | 668 |
| 640 // Close the file and clear the dirty bit. | 669 // Close the file and clear the dirty bit. |
| 641 file_closer.reset(); | 670 file_closer.reset(); |
| 642 base::RunLoop().RunUntilIdle(); | 671 base::RunLoop().RunUntilIdle(); |
| 643 EXPECT_EQ(FILE_ERROR_OK, cache_->ClearDirty(id)); | 672 EXPECT_EQ(FILE_ERROR_OK, cache_->ClearDirty(id)); |
| 644 | 673 |
| 645 // Entry is not dirty. | 674 // Entry is not dirty. |
| 646 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); | 675 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id, &entry)); |
| 647 EXPECT_FALSE(entry.file_specific_info().cache_state().is_dirty()); | 676 EXPECT_FALSE(entry.file_specific_info().cache_state().is_dirty()); |
| 677 ExpectIsRemovable(dest_file); | |
| 648 } | 678 } |
| 649 | 679 |
| 650 TEST_F(FileCacheTest, Remove) { | 680 TEST_F(FileCacheTest, Remove) { |
| 651 const base::FilePath src_file_path = temp_dir_.path().Append("test.dat"); | 681 const base::FilePath src_file_path = temp_dir_.path().Append("test.dat"); |
| 652 const std::string src_contents = "test"; | 682 const std::string src_contents = "test"; |
| 653 EXPECT_TRUE(google_apis::test_util::WriteStringToFile(src_file_path, | 683 EXPECT_TRUE(google_apis::test_util::WriteStringToFile(src_file_path, |
| 654 src_contents)); | 684 src_contents)); |
| 655 std::string id("id"); | 685 std::string id("id"); |
| 656 std::string md5(base::MD5String(src_contents)); | 686 std::string md5(base::MD5String(src_contents)); |
| 657 | 687 |
| (...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 704 contents.clear(); | 734 contents.clear(); |
| 705 EXPECT_TRUE(base::ReadFileToString(file_directory.AppendASCII("id_koo"), | 735 EXPECT_TRUE(base::ReadFileToString(file_directory.AppendASCII("id_koo"), |
| 706 &contents)); | 736 &contents)); |
| 707 EXPECT_EQ("koo", contents); | 737 EXPECT_EQ("koo", contents); |
| 708 contents.clear(); | 738 contents.clear(); |
| 709 EXPECT_TRUE(base::ReadFileToString(file_directory.AppendASCII("id_kyu"), | 739 EXPECT_TRUE(base::ReadFileToString(file_directory.AppendASCII("id_kyu"), |
| 710 &contents)); | 740 &contents)); |
| 711 EXPECT_EQ("kyu", contents); | 741 EXPECT_EQ("kyu", contents); |
| 712 } | 742 } |
| 713 | 743 |
| 714 // Test for migrating cache files from files to blobs. | 744 // Test for migrating cache files resolving inconsistency in metadata. |
| 715 TEST_F(FileCacheTest, MigrateCacheFiles) { | 745 TEST_F(FileCacheTest, MigrateCacheFiles) { |
| 716 // Create test files and metadata. | 746 // Create test files and metadata. |
| 717 base::FilePath temp_file; | 747 base::FilePath temp_file; |
| 718 ASSERT_TRUE(base::CreateTemporaryFileInDir(temp_dir_.path(), &temp_file)); | 748 ASSERT_TRUE(base::CreateTemporaryFileInDir(temp_dir_.path(), &temp_file)); |
| 719 | 749 |
| 720 const base::FilePath old_cache_dir = | 750 // Entry A: pinned cache file. |
| 721 temp_dir_.path().Append(kCacheFileDirectory); | |
| 722 const base::FilePath new_cache_dir = | |
| 723 temp_dir_.path().Append(kNewCacheFileDirectory); | |
| 724 const base::FilePath link_dir = temp_dir_.path().Append(kLinkDirectory); | |
| 725 ASSERT_TRUE(base::CreateDirectory(old_cache_dir)); | |
| 726 ASSERT_TRUE(base::CreateDirectory(new_cache_dir)); | |
| 727 ASSERT_TRUE(base::CreateDirectory(link_dir)); | |
| 728 | |
| 729 // Entry A: cache file in old cache directory with metadata. | |
| 730 const std::string id_a = "id_a"; | 751 const std::string id_a = "id_a"; |
| 731 ResourceEntry entry_a; | 752 ResourceEntry entry_a; |
| 732 entry_a.set_local_id(id_a); | 753 entry_a.set_local_id(id_a); |
| 733 entry_a.mutable_file_specific_info()->mutable_cache_state()->set_is_present( | 754 FileCacheEntry* file_cache_entry_a = |
| 734 true); | 755 entry_a.mutable_file_specific_info()->mutable_cache_state(); |
| 756 file_cache_entry_a->set_is_present(true); | |
| 757 file_cache_entry_a->set_is_pinned(true); | |
| 758 file_cache_entry_a->set_is_dirty(false); | |
| 735 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_a)); | 759 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_a)); |
| 736 const base::FilePath old_file_path_a = old_cache_dir.AppendASCII(id_a); | 760 const base::FilePath file_path_a = GetCacheFilePath(id_a); |
| 737 const base::FilePath new_file_path_a = new_cache_dir.AppendASCII(id_a); | 761 ASSERT_TRUE(base::CopyFile(temp_file, file_path_a)); |
| 738 ASSERT_TRUE(base::CopyFile(temp_file, old_file_path_a)); | |
| 739 | 762 |
| 740 // Entry B: cache file in old cache directory without metadata. | 763 // Entry B: dirty cache file. |
| 741 const std::string id_b = "id_b"; | 764 const std::string id_b = "id_b"; |
| 742 const base::FilePath old_file_path_b = old_cache_dir.AppendASCII(id_b); | 765 ResourceEntry entry_b; |
| 743 ASSERT_TRUE(base::CopyFile(temp_file, old_file_path_b)); | 766 entry_b.set_local_id(id_b); |
| 767 FileCacheEntry* file_cache_entry_b = | |
| 768 entry_b.mutable_file_specific_info()->mutable_cache_state(); | |
| 769 file_cache_entry_b->set_is_present(true); | |
| 770 file_cache_entry_b->set_is_pinned(false); | |
| 771 file_cache_entry_b->set_is_dirty(true); | |
| 772 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_b)); | |
| 773 const base::FilePath file_path_b = GetCacheFilePath(id_b); | |
| 774 ASSERT_TRUE(base::CopyFile(temp_file, file_path_b)); | |
| 744 | 775 |
| 745 // Entry C: already migrated cache file. | 776 // Entry C: not pinned nor dirty cache file. |
| 746 const std::string id_c = "id_c"; | 777 const std::string id_c = "id_c"; |
| 747 ResourceEntry entry_c; | 778 ResourceEntry entry_c; |
| 748 entry_c.set_local_id(id_c); | 779 entry_c.set_local_id(id_c); |
| 749 entry_c.mutable_file_specific_info()->mutable_cache_state()->set_is_present( | 780 FileCacheEntry* file_cache_entry_c = |
| 750 true); | 781 entry_c.mutable_file_specific_info()->mutable_cache_state(); |
| 782 file_cache_entry_c->set_is_present(true); | |
| 783 file_cache_entry_c->set_is_pinned(false); | |
| 784 file_cache_entry_c->set_is_dirty(false); | |
| 751 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_c)); | 785 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_c)); |
| 752 const base::FilePath new_file_path_c = new_cache_dir.AppendASCII(id_c); | 786 const base::FilePath file_path_c = GetCacheFilePath(id_c); |
| 753 ASSERT_TRUE(base::CopyFile(temp_file, new_file_path_c)); | 787 ASSERT_TRUE(base::CopyFile(temp_file, file_path_c)); |
| 754 | 788 |
| 755 // Entry D: metadata entry without cache file. | 789 // Entry D: pinned cache file somehow having removable flag. |
| 756 const std::string id_d = "id_d"; | 790 const std::string id_d = "id_d"; |
| 757 ResourceEntry entry_d; | 791 ResourceEntry entry_d; |
| 758 entry_d.set_local_id(id_d); | 792 entry_d.set_local_id(id_d); |
| 759 entry_d.mutable_file_specific_info()->mutable_cache_state()->set_is_present( | 793 FileCacheEntry* file_cache_entry_d = |
| 760 true); | 794 entry_d.mutable_file_specific_info()->mutable_cache_state(); |
| 795 file_cache_entry_d->set_is_present(true); | |
| 796 file_cache_entry_d->set_is_pinned(true); | |
| 797 file_cache_entry_d->set_is_dirty(false); | |
| 761 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_d)); | 798 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_d)); |
| 799 const base::FilePath file_path_d = GetCacheFilePath(id_d); | |
| 800 ASSERT_TRUE(base::CopyFile(temp_file, file_path_d)); | |
| 762 | 801 |
| 763 // Entry E: pinned cache file. | 802 // Set removable flag. |
| 803 int64_t flags = GetFileAttributes(file_path_d); | |
| 804 ASSERT_GE(flags, 0); | |
| 805 flags |= FS_NODUMP_FL; | |
| 806 base::File file_d(file_path_d, base::File::FLAG_OPEN | base::File::FLAG_READ); | |
| 807 ASSERT_EQ(ioctl(file_d.GetPlatformFile(), FS_IOC_SETFLAGS, &flags), 0); | |
| 808 | |
| 809 // Entry E: there is no file; removed by cryptohome. | |
| 764 const std::string id_e = "id_e"; | 810 const std::string id_e = "id_e"; |
| 765 ResourceEntry entry_e; | 811 ResourceEntry entry_e; |
| 766 entry_e.set_local_id(id_e); | 812 entry_e.set_local_id(id_e); |
| 767 FileCacheEntry* file_cache_entry_e = | 813 FileCacheEntry* file_cache_entry_e = |
| 768 entry_e.mutable_file_specific_info()->mutable_cache_state(); | 814 entry_e.mutable_file_specific_info()->mutable_cache_state(); |
| 769 file_cache_entry_e->set_is_present(true); | 815 file_cache_entry_e->set_is_present(true); |
| 770 file_cache_entry_e->set_is_pinned(true); | 816 file_cache_entry_e->set_is_pinned(false); |
| 771 file_cache_entry_e->set_is_dirty(false); | 817 file_cache_entry_e->set_is_dirty(false); |
| 772 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_e)); | 818 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_e)); |
| 773 const base::FilePath old_file_path_e = old_cache_dir.AppendASCII(id_e); | 819 const base::FilePath file_path_e = GetCacheFilePath(id_e); |
| 774 const base::FilePath new_file_path_e = new_cache_dir.AppendASCII(id_e); | |
| 775 const base::FilePath link_path_e = link_dir.AppendASCII(id_e); | |
| 776 ASSERT_TRUE(base::CopyFile(temp_file, old_file_path_e)); | |
| 777 | 820 |
| 778 // Entry F: dirty cache file. | 821 // Entry F: there is a file, but metadata says not. |
| 779 const std::string id_f = "id_f"; | 822 const std::string id_f = "id_f"; |
| 780 ResourceEntry entry_f; | 823 ResourceEntry entry_f; |
| 781 entry_f.set_local_id(id_f); | 824 entry_f.set_local_id(id_f); |
| 782 FileCacheEntry* file_cache_entry_f = | 825 entry_f.mutable_file_specific_info()->mutable_cache_state()->set_is_present( |
| 783 entry_f.mutable_file_specific_info()->mutable_cache_state(); | 826 false); |
| 784 file_cache_entry_f->set_is_present(true); | |
| 785 file_cache_entry_f->set_is_pinned(false); | |
| 786 file_cache_entry_f->set_is_dirty(true); | |
| 787 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_f)); | 827 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_f)); |
| 788 const base::FilePath old_file_path_f = old_cache_dir.AppendASCII(id_f); | 828 const base::FilePath file_path_f = GetCacheFilePath(id_f); |
| 789 const base::FilePath new_file_path_f = new_cache_dir.AppendASCII(id_f); | 829 ASSERT_TRUE(base::CopyFile(temp_file, file_path_f)); |
| 790 const base::FilePath link_path_f = link_dir.AppendASCII(id_f); | |
| 791 ASSERT_TRUE(base::CopyFile(temp_file, old_file_path_f)); | |
| 792 | 830 |
| 793 // Entry G: partially migrated pinned cache file. | 831 // Initialize resolves metadta inconsistency and invokes migration. |
| 794 const std::string id_g = "id_g"; | 832 ASSERT_TRUE(cache_->Initialize()); |
| 795 ResourceEntry entry_g; | |
| 796 entry_g.set_local_id(id_g); | |
| 797 FileCacheEntry* file_cache_entry_g = | |
| 798 entry_g.mutable_file_specific_info()->mutable_cache_state(); | |
| 799 file_cache_entry_g->set_is_present(true); | |
| 800 file_cache_entry_g->set_is_pinned(true); | |
| 801 file_cache_entry_g->set_is_dirty(false); | |
| 802 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_g)); | |
| 803 const base::FilePath old_file_path_g = old_cache_dir.AppendASCII(id_g); | |
| 804 const base::FilePath new_file_path_g = new_cache_dir.AppendASCII(id_g); | |
| 805 const base::FilePath link_path_g = link_dir.AppendASCII(id_g); | |
| 806 ASSERT_TRUE(base::CopyFile(temp_file, old_file_path_g)); | |
| 807 ASSERT_EQ(0, link(old_file_path_g.AsUTF8Unsafe().c_str(), | |
| 808 link_path_g.AsUTF8Unsafe().c_str())); | |
| 809 | |
| 810 // Entry H: pinned entry without cache file. | |
| 811 const std::string id_h = "id_h"; | |
| 812 ResourceEntry entry_h; | |
| 813 entry_h.set_local_id(id_h); | |
| 814 FileCacheEntry* file_cache_entry_h = | |
| 815 entry_h.mutable_file_specific_info()->mutable_cache_state(); | |
| 816 file_cache_entry_h->set_is_present(true); | |
| 817 file_cache_entry_h->set_is_pinned(true); | |
| 818 file_cache_entry_h->set_is_dirty(false); | |
| 819 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_h)); | |
| 820 | |
| 821 // Entry I: already migrated pinned cache file. | |
| 822 const std::string id_i = "id_i"; | |
| 823 ResourceEntry entry_i; | |
| 824 entry_i.set_local_id(id_i); | |
| 825 FileCacheEntry* file_cache_entry_i = | |
| 826 entry_i.mutable_file_specific_info()->mutable_cache_state(); | |
| 827 file_cache_entry_i->set_is_present(true); | |
| 828 file_cache_entry_i->set_is_pinned(true); | |
| 829 file_cache_entry_i->set_is_dirty(false); | |
| 830 ASSERT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry_i)); | |
| 831 const base::FilePath new_file_path_i = new_cache_dir.AppendASCII(id_i); | |
| 832 const base::FilePath link_path_i = link_dir.AppendASCII(id_i); | |
| 833 ASSERT_TRUE(base::CopyFile(temp_file, new_file_path_i)); | |
| 834 ASSERT_EQ(0, link(new_file_path_i.AsUTF8Unsafe().c_str(), | |
| 835 link_path_i.AsUTF8Unsafe().c_str())); | |
| 836 | |
| 837 // Run migration. | |
| 838 ASSERT_TRUE(FileCache::MigrateCacheFiles(old_cache_dir, new_cache_dir, | |
| 839 link_dir, metadata_storage_.get())); | |
| 840 | 833 |
| 841 // Check result. | 834 // Check result. |
| 842 EXPECT_FALSE(base::PathExists(old_file_path_a)); | 835 ExpectIsUnremovable(file_path_a); |
| 843 EXPECT_TRUE(base::PathExists(new_file_path_a)); | 836 ExpectIsUnremovable(file_path_b); |
| 844 EXPECT_EQ(1, GetNumberOfLinks(new_file_path_a)); | 837 ExpectIsRemovable(file_path_c); |
| 845 // MigrateCacheFiles doesn't delete invalid cache file. | 838 ExpectIsUnremovable(file_path_d); |
| 846 EXPECT_TRUE(base::PathExists(old_file_path_b)); | 839 ExpectIsRemovable(file_path_f); |
| 847 EXPECT_TRUE(base::PathExists(new_file_path_c)); | 840 |
| 848 EXPECT_EQ(1, GetNumberOfLinks(new_file_path_c)); | 841 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id_e, &entry_e)); |
| 849 EXPECT_FALSE(base::PathExists(old_file_path_e)); | 842 EXPECT_FALSE(entry_e.file_specific_info().cache_state().is_present()); |
| 850 EXPECT_TRUE(base::PathExists(new_file_path_e)); | 843 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->GetEntry(id_f, &entry_f)); |
| 851 EXPECT_TRUE(base::PathExists(link_path_e)); | 844 EXPECT_TRUE(entry_f.file_specific_info().cache_state().is_present()); |
| 852 EXPECT_EQ(2, GetNumberOfLinks(new_file_path_e)); | 845 |
| 853 EXPECT_FALSE(base::PathExists(old_file_path_f)); | 846 // Check the cache dir has appropriate attributes. |
| 854 EXPECT_TRUE(base::PathExists(new_file_path_f)); | 847 ExpectIsRemovable(cache_files_dir_); |
| 855 EXPECT_TRUE(base::PathExists(link_path_f)); | 848 EXPECT_GE(getxattr(cache_files_dir_.value().c_str(), |
| 856 EXPECT_EQ(2, GetNumberOfLinks(new_file_path_f)); | 849 FileCache::kGCacheFilesAttribute.c_str(), nullptr, 0), 0); |
| 857 EXPECT_FALSE(base::PathExists(old_file_path_g)); | |
| 858 EXPECT_TRUE(base::PathExists(new_file_path_g)); | |
| 859 EXPECT_TRUE(base::PathExists(link_path_g)); | |
| 860 EXPECT_EQ(2, GetNumberOfLinks(new_file_path_g)); | |
| 861 EXPECT_TRUE(base::PathExists(new_file_path_i)); | |
| 862 EXPECT_TRUE(base::PathExists(link_path_i)); | |
| 863 EXPECT_EQ(2, GetNumberOfLinks(new_file_path_i)); | |
| 864 } | 850 } |
| 865 | 851 |
| 866 TEST_F(FileCacheTest, ClearAll) { | 852 TEST_F(FileCacheTest, ClearAll) { |
| 867 const std::string id("1a2b"); | 853 const std::string id("1a2b"); |
| 868 const std::string md5("abcdef0123456789"); | 854 const std::string md5("abcdef0123456789"); |
| 869 | 855 |
| 870 // Store an existing file. | 856 // Store an existing file. |
| 871 ResourceEntry entry; | 857 ResourceEntry entry; |
| 872 entry.set_local_id(id); | 858 entry.set_local_id(id); |
| 873 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry)); | 859 EXPECT_EQ(FILE_ERROR_OK, metadata_storage_->PutEntry(entry)); |
| 874 base::FilePath src_file; | 860 base::FilePath src_file; |
| 875 ASSERT_TRUE(base::CreateTemporaryFileInDir(temp_dir_.path(), &src_file)); | 861 ASSERT_TRUE(base::CreateTemporaryFileInDir(temp_dir_.path(), &src_file)); |
| 876 ASSERT_EQ(FILE_ERROR_OK, | 862 ASSERT_EQ(FILE_ERROR_OK, |
| 877 cache_->Store(id, md5, src_file, FileCache::FILE_OPERATION_COPY)); | 863 cache_->Store(id, md5, src_file, FileCache::FILE_OPERATION_COPY)); |
| 878 | 864 |
| 879 // Clear cache. | 865 // Clear cache. |
| 880 EXPECT_TRUE(cache_->ClearAll()); | 866 EXPECT_TRUE(cache_->ClearAll()); |
| 881 | 867 |
| 882 // Verify that the cache is removed. | 868 // Verify that the cache is removed. |
| 883 EXPECT_TRUE(base::IsDirectoryEmpty(cache_files_dir_)); | 869 EXPECT_TRUE(base::IsDirectoryEmpty(cache_files_dir_)); |
| 884 } | 870 } |
| 885 | 871 |
| 886 } // namespace internal | 872 } // namespace internal |
| 887 } // namespace drive | 873 } // namespace drive |
| OLD | NEW |