| 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 <algorithm> | 5 #include <algorithm> |
| 6 #include <vector> | 6 #include <vector> |
| 7 | 7 |
| 8 #include "base/file_util.h" | 8 #include "base/file_util.h" |
| 9 #include "base/message_loop.h" | 9 #include "base/message_loop.h" |
| 10 #include "base/path_service.h" | 10 #include "base/path_service.h" |
| (...skipping 97 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 108 *out_to_upload = to_upload; | 108 *out_to_upload = to_upload; |
| 109 } | 109 } |
| 110 | 110 |
| 111 // Copies results from GetResourceIdsCallback. | 111 // Copies results from GetResourceIdsCallback. |
| 112 void OnGetResourceIds(std::vector<std::string>* out_resource_ids, | 112 void OnGetResourceIds(std::vector<std::string>* out_resource_ids, |
| 113 const std::vector<std::string>& resource_ids) { | 113 const std::vector<std::string>& resource_ids) { |
| 114 *out_resource_ids = resource_ids; | 114 *out_resource_ids = resource_ids; |
| 115 } | 115 } |
| 116 | 116 |
| 117 // Copies results from ClearAllOnUIThread. | 117 // Copies results from ClearAllOnUIThread. |
| 118 void OnClearAll(GDataFileError* out_error, | 118 void OnClearAll(DriveFileError* out_error, |
| 119 FilePath* out_file_path, | 119 FilePath* out_file_path, |
| 120 GDataFileError error, | 120 DriveFileError error, |
| 121 const FilePath& file_path) { | 121 const FilePath& file_path) { |
| 122 *out_file_path = file_path; | 122 *out_file_path = file_path; |
| 123 *out_error = error; | 123 *out_error = error; |
| 124 } | 124 } |
| 125 | 125 |
| 126 } // namespace | 126 } // namespace |
| 127 | 127 |
| 128 class DriveCacheTest : public testing::Test { | 128 class DriveCacheTest : public testing::Test { |
| 129 protected: | 129 protected: |
| 130 DriveCacheTest() | 130 DriveCacheTest() |
| 131 : ui_thread_(content::BrowserThread::UI, &message_loop_), | 131 : ui_thread_(content::BrowserThread::UI, &message_loop_), |
| 132 io_thread_(content::BrowserThread::IO), | 132 io_thread_(content::BrowserThread::IO), |
| 133 cache_(NULL), | 133 cache_(NULL), |
| 134 num_callback_invocations_(0), | 134 num_callback_invocations_(0), |
| 135 expected_error_(GDATA_FILE_OK), | 135 expected_error_(DRIVE_FILE_OK), |
| 136 expected_cache_state_(0), | 136 expected_cache_state_(0), |
| 137 expected_sub_dir_type_(DriveCache::CACHE_TYPE_META), | 137 expected_sub_dir_type_(DriveCache::CACHE_TYPE_META), |
| 138 expected_success_(true), | 138 expected_success_(true), |
| 139 expect_outgoing_symlink_(false), | 139 expect_outgoing_symlink_(false), |
| 140 root_feed_changestamp_(0) { | 140 root_feed_changestamp_(0) { |
| 141 } | 141 } |
| 142 | 142 |
| 143 virtual void SetUp() OVERRIDE { | 143 virtual void SetUp() OVERRIDE { |
| 144 io_thread_.StartIOThread(); | 144 io_thread_.StartIOThread(); |
| 145 | 145 |
| (...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 241 | 241 |
| 242 void TestInitializeCache() { | 242 void TestInitializeCache() { |
| 243 for (size_t i = 0; i < ARRAYSIZE_UNSAFE(initial_cache_resources); ++i) { | 243 for (size_t i = 0; i < ARRAYSIZE_UNSAFE(initial_cache_resources); ++i) { |
| 244 const struct InitialCacheResource& resource = initial_cache_resources[i]; | 244 const struct InitialCacheResource& resource = initial_cache_resources[i]; |
| 245 // Check cache file. | 245 // Check cache file. |
| 246 num_callback_invocations_ = 0; | 246 num_callback_invocations_ = 0; |
| 247 TestGetFileFromCacheByResourceIdAndMd5( | 247 TestGetFileFromCacheByResourceIdAndMd5( |
| 248 resource.resource_id, | 248 resource.resource_id, |
| 249 resource.md5, | 249 resource.md5, |
| 250 test_util::ToCacheEntry(resource.cache_state).is_present() ? | 250 test_util::ToCacheEntry(resource.cache_state).is_present() ? |
| 251 GDATA_FILE_OK : | 251 DRIVE_FILE_OK : |
| 252 GDATA_FILE_ERROR_NOT_FOUND, | 252 DRIVE_FILE_ERROR_NOT_FOUND, |
| 253 resource.expected_file_extension); | 253 resource.expected_file_extension); |
| 254 EXPECT_EQ(1, num_callback_invocations_); | 254 EXPECT_EQ(1, num_callback_invocations_); |
| 255 | 255 |
| 256 // Verify cache state. | 256 // Verify cache state. |
| 257 std::string md5; | 257 std::string md5; |
| 258 if (test_util::ToCacheEntry(resource.cache_state).is_present()) | 258 if (test_util::ToCacheEntry(resource.cache_state).is_present()) |
| 259 md5 = resource.md5; | 259 md5 = resource.md5; |
| 260 DriveCacheEntry cache_entry; | 260 DriveCacheEntry cache_entry; |
| 261 ASSERT_TRUE(GetCacheEntryFromOriginThread( | 261 ASSERT_TRUE(GetCacheEntryFromOriginThread( |
| 262 resource.resource_id, md5, &cache_entry)); | 262 resource.resource_id, md5, &cache_entry)); |
| 263 EXPECT_TRUE(test_util::CacheStatesEqual( | 263 EXPECT_TRUE(test_util::CacheStatesEqual( |
| 264 test_util::ToCacheEntry(resource.cache_state), | 264 test_util::ToCacheEntry(resource.cache_state), |
| 265 cache_entry)); | 265 cache_entry)); |
| 266 EXPECT_EQ(resource.expected_sub_dir_type, | 266 EXPECT_EQ(resource.expected_sub_dir_type, |
| 267 DriveCache::GetSubDirectoryType(cache_entry)); | 267 DriveCache::GetSubDirectoryType(cache_entry)); |
| 268 } | 268 } |
| 269 } | 269 } |
| 270 | 270 |
| 271 void TestGetFileFromCacheByResourceIdAndMd5( | 271 void TestGetFileFromCacheByResourceIdAndMd5( |
| 272 const std::string& resource_id, | 272 const std::string& resource_id, |
| 273 const std::string& md5, | 273 const std::string& md5, |
| 274 GDataFileError expected_error, | 274 DriveFileError expected_error, |
| 275 const std::string& expected_file_extension) { | 275 const std::string& expected_file_extension) { |
| 276 expected_error_ = expected_error; | 276 expected_error_ = expected_error; |
| 277 expected_file_extension_ = expected_file_extension; | 277 expected_file_extension_ = expected_file_extension; |
| 278 | 278 |
| 279 cache_->GetFileOnUIThread( | 279 cache_->GetFileOnUIThread( |
| 280 resource_id, md5, | 280 resource_id, md5, |
| 281 base::Bind(&DriveCacheTest::VerifyGetFromCache, | 281 base::Bind(&DriveCacheTest::VerifyGetFromCache, |
| 282 base::Unretained(this))); | 282 base::Unretained(this))); |
| 283 | 283 |
| 284 test_util::RunBlockingPoolTask(); | 284 test_util::RunBlockingPoolTask(); |
| 285 } | 285 } |
| 286 | 286 |
| 287 void TestStoreToCache( | 287 void TestStoreToCache( |
| 288 const std::string& resource_id, | 288 const std::string& resource_id, |
| 289 const std::string& md5, | 289 const std::string& md5, |
| 290 const FilePath& source_path, | 290 const FilePath& source_path, |
| 291 GDataFileError expected_error, | 291 DriveFileError expected_error, |
| 292 int expected_cache_state, | 292 int expected_cache_state, |
| 293 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { | 293 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { |
| 294 expected_error_ = expected_error; | 294 expected_error_ = expected_error; |
| 295 expected_cache_state_ = expected_cache_state; | 295 expected_cache_state_ = expected_cache_state; |
| 296 expected_sub_dir_type_ = expected_sub_dir_type; | 296 expected_sub_dir_type_ = expected_sub_dir_type; |
| 297 | 297 |
| 298 cache_->StoreOnUIThread( | 298 cache_->StoreOnUIThread( |
| 299 resource_id, md5, source_path, | 299 resource_id, md5, source_path, |
| 300 DriveCache::FILE_OPERATION_COPY, | 300 DriveCache::FILE_OPERATION_COPY, |
| 301 base::Bind(&DriveCacheTest::VerifyCacheFileState, | 301 base::Bind(&DriveCacheTest::VerifyCacheFileState, |
| 302 base::Unretained(this))); | 302 base::Unretained(this))); |
| 303 | 303 |
| 304 test_util::RunBlockingPoolTask(); | 304 test_util::RunBlockingPoolTask(); |
| 305 } | 305 } |
| 306 | 306 |
| 307 void VerifyGetFromCache(GDataFileError error, | 307 void VerifyGetFromCache(DriveFileError error, |
| 308 const std::string& resource_id, | 308 const std::string& resource_id, |
| 309 const std::string& md5, | 309 const std::string& md5, |
| 310 const FilePath& cache_file_path) { | 310 const FilePath& cache_file_path) { |
| 311 ++num_callback_invocations_; | 311 ++num_callback_invocations_; |
| 312 | 312 |
| 313 EXPECT_EQ(expected_error_, error); | 313 EXPECT_EQ(expected_error_, error); |
| 314 | 314 |
| 315 if (error == GDATA_FILE_OK) { | 315 if (error == DRIVE_FILE_OK) { |
| 316 // Verify filename of |cache_file_path|. | 316 // Verify filename of |cache_file_path|. |
| 317 FilePath base_name = cache_file_path.BaseName(); | 317 FilePath base_name = cache_file_path.BaseName(); |
| 318 EXPECT_EQ(util::EscapeCacheFileName(resource_id) + | 318 EXPECT_EQ(util::EscapeCacheFileName(resource_id) + |
| 319 FilePath::kExtensionSeparator + | 319 FilePath::kExtensionSeparator + |
| 320 util::EscapeCacheFileName( | 320 util::EscapeCacheFileName( |
| 321 expected_file_extension_.empty() ? | 321 expected_file_extension_.empty() ? |
| 322 md5 : expected_file_extension_), | 322 md5 : expected_file_extension_), |
| 323 base_name.value()); | 323 base_name.value()); |
| 324 } else { | 324 } else { |
| 325 EXPECT_TRUE(cache_file_path.empty()); | 325 EXPECT_TRUE(cache_file_path.empty()); |
| 326 } | 326 } |
| 327 } | 327 } |
| 328 | 328 |
| 329 void TestRemoveFromCache(const std::string& resource_id, | 329 void TestRemoveFromCache(const std::string& resource_id, |
| 330 GDataFileError expected_error) { | 330 DriveFileError expected_error) { |
| 331 expected_error_ = expected_error; | 331 expected_error_ = expected_error; |
| 332 | 332 |
| 333 cache_->RemoveOnUIThread( | 333 cache_->RemoveOnUIThread( |
| 334 resource_id, | 334 resource_id, |
| 335 base::Bind(&DriveCacheTest::VerifyRemoveFromCache, | 335 base::Bind(&DriveCacheTest::VerifyRemoveFromCache, |
| 336 base::Unretained(this))); | 336 base::Unretained(this))); |
| 337 | 337 |
| 338 test_util::RunBlockingPoolTask(); | 338 test_util::RunBlockingPoolTask(); |
| 339 } | 339 } |
| 340 | 340 |
| 341 void VerifyRemoveFromCache(GDataFileError error, | 341 void VerifyRemoveFromCache(DriveFileError error, |
| 342 const std::string& resource_id, | 342 const std::string& resource_id, |
| 343 const std::string& md5) { | 343 const std::string& md5) { |
| 344 ++num_callback_invocations_; | 344 ++num_callback_invocations_; |
| 345 | 345 |
| 346 EXPECT_EQ(expected_error_, error); | 346 EXPECT_EQ(expected_error_, error); |
| 347 | 347 |
| 348 // Verify cache map. | 348 // Verify cache map. |
| 349 DriveCacheEntry cache_entry; | 349 DriveCacheEntry cache_entry; |
| 350 const bool cache_entry_found = | 350 const bool cache_entry_found = |
| 351 GetCacheEntryFromOriginThread(resource_id, md5, &cache_entry); | 351 GetCacheEntryFromOriginThread(resource_id, md5, &cache_entry); |
| (...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 429 EXPECT_EQ(0U, num_files_found); | 429 EXPECT_EQ(0U, num_files_found); |
| 430 else | 430 else |
| 431 EXPECT_EQ(1U, num_files_found); | 431 EXPECT_EQ(1U, num_files_found); |
| 432 } | 432 } |
| 433 } | 433 } |
| 434 } | 434 } |
| 435 | 435 |
| 436 void TestPin( | 436 void TestPin( |
| 437 const std::string& resource_id, | 437 const std::string& resource_id, |
| 438 const std::string& md5, | 438 const std::string& md5, |
| 439 GDataFileError expected_error, | 439 DriveFileError expected_error, |
| 440 int expected_cache_state, | 440 int expected_cache_state, |
| 441 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { | 441 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { |
| 442 expected_error_ = expected_error; | 442 expected_error_ = expected_error; |
| 443 expected_cache_state_ = expected_cache_state; | 443 expected_cache_state_ = expected_cache_state; |
| 444 expected_sub_dir_type_ = expected_sub_dir_type; | 444 expected_sub_dir_type_ = expected_sub_dir_type; |
| 445 | 445 |
| 446 cache_->PinOnUIThread( | 446 cache_->PinOnUIThread( |
| 447 resource_id, md5, | 447 resource_id, md5, |
| 448 base::Bind(&DriveCacheTest::VerifyCacheFileState, | 448 base::Bind(&DriveCacheTest::VerifyCacheFileState, |
| 449 base::Unretained(this))); | 449 base::Unretained(this))); |
| 450 | 450 |
| 451 test_util::RunBlockingPoolTask(); | 451 test_util::RunBlockingPoolTask(); |
| 452 } | 452 } |
| 453 | 453 |
| 454 void TestUnpin( | 454 void TestUnpin( |
| 455 const std::string& resource_id, | 455 const std::string& resource_id, |
| 456 const std::string& md5, | 456 const std::string& md5, |
| 457 GDataFileError expected_error, | 457 DriveFileError expected_error, |
| 458 int expected_cache_state, | 458 int expected_cache_state, |
| 459 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { | 459 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { |
| 460 expected_error_ = expected_error; | 460 expected_error_ = expected_error; |
| 461 expected_cache_state_ = expected_cache_state; | 461 expected_cache_state_ = expected_cache_state; |
| 462 expected_sub_dir_type_ = expected_sub_dir_type; | 462 expected_sub_dir_type_ = expected_sub_dir_type; |
| 463 | 463 |
| 464 cache_->UnpinOnUIThread( | 464 cache_->UnpinOnUIThread( |
| 465 resource_id, md5, | 465 resource_id, md5, |
| 466 base::Bind(&DriveCacheTest::VerifyCacheFileState, | 466 base::Bind(&DriveCacheTest::VerifyCacheFileState, |
| 467 base::Unretained(this))); | 467 base::Unretained(this))); |
| 468 | 468 |
| 469 test_util::RunBlockingPoolTask(); | 469 test_util::RunBlockingPoolTask(); |
| 470 } | 470 } |
| 471 | 471 |
| 472 void TestMarkDirty( | 472 void TestMarkDirty( |
| 473 const std::string& resource_id, | 473 const std::string& resource_id, |
| 474 const std::string& md5, | 474 const std::string& md5, |
| 475 GDataFileError expected_error, | 475 DriveFileError expected_error, |
| 476 int expected_cache_state, | 476 int expected_cache_state, |
| 477 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { | 477 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { |
| 478 expected_error_ = expected_error; | 478 expected_error_ = expected_error; |
| 479 expected_cache_state_ = expected_cache_state; | 479 expected_cache_state_ = expected_cache_state; |
| 480 expected_sub_dir_type_ = expected_sub_dir_type; | 480 expected_sub_dir_type_ = expected_sub_dir_type; |
| 481 expect_outgoing_symlink_ = false; | 481 expect_outgoing_symlink_ = false; |
| 482 | 482 |
| 483 cache_->MarkDirtyOnUIThread( | 483 cache_->MarkDirtyOnUIThread( |
| 484 resource_id, md5, | 484 resource_id, md5, |
| 485 base::Bind(&DriveCacheTest::VerifyMarkDirty, | 485 base::Bind(&DriveCacheTest::VerifyMarkDirty, |
| 486 base::Unretained(this))); | 486 base::Unretained(this))); |
| 487 | 487 |
| 488 test_util::RunBlockingPoolTask(); | 488 test_util::RunBlockingPoolTask(); |
| 489 } | 489 } |
| 490 | 490 |
| 491 void VerifyMarkDirty(GDataFileError error, | 491 void VerifyMarkDirty(DriveFileError error, |
| 492 const std::string& resource_id, | 492 const std::string& resource_id, |
| 493 const std::string& md5, | 493 const std::string& md5, |
| 494 const FilePath& cache_file_path) { | 494 const FilePath& cache_file_path) { |
| 495 VerifyCacheFileState(error, resource_id, md5); | 495 VerifyCacheFileState(error, resource_id, md5); |
| 496 | 496 |
| 497 // Verify filename of |cache_file_path|. | 497 // Verify filename of |cache_file_path|. |
| 498 if (error == GDATA_FILE_OK) { | 498 if (error == DRIVE_FILE_OK) { |
| 499 FilePath base_name = cache_file_path.BaseName(); | 499 FilePath base_name = cache_file_path.BaseName(); |
| 500 EXPECT_EQ(util::EscapeCacheFileName(resource_id) + | 500 EXPECT_EQ(util::EscapeCacheFileName(resource_id) + |
| 501 FilePath::kExtensionSeparator + | 501 FilePath::kExtensionSeparator + |
| 502 "local", | 502 "local", |
| 503 base_name.value()); | 503 base_name.value()); |
| 504 } else { | 504 } else { |
| 505 EXPECT_TRUE(cache_file_path.empty()); | 505 EXPECT_TRUE(cache_file_path.empty()); |
| 506 } | 506 } |
| 507 } | 507 } |
| 508 | 508 |
| 509 void TestCommitDirty( | 509 void TestCommitDirty( |
| 510 const std::string& resource_id, | 510 const std::string& resource_id, |
| 511 const std::string& md5, | 511 const std::string& md5, |
| 512 GDataFileError expected_error, | 512 DriveFileError expected_error, |
| 513 int expected_cache_state, | 513 int expected_cache_state, |
| 514 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { | 514 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { |
| 515 expected_error_ = expected_error; | 515 expected_error_ = expected_error; |
| 516 expected_cache_state_ = expected_cache_state; | 516 expected_cache_state_ = expected_cache_state; |
| 517 expected_sub_dir_type_ = expected_sub_dir_type; | 517 expected_sub_dir_type_ = expected_sub_dir_type; |
| 518 expect_outgoing_symlink_ = true; | 518 expect_outgoing_symlink_ = true; |
| 519 | 519 |
| 520 cache_->CommitDirtyOnUIThread( | 520 cache_->CommitDirtyOnUIThread( |
| 521 resource_id, md5, | 521 resource_id, md5, |
| 522 base::Bind(&DriveCacheTest::VerifyCacheFileState, | 522 base::Bind(&DriveCacheTest::VerifyCacheFileState, |
| 523 base::Unretained(this))); | 523 base::Unretained(this))); |
| 524 | 524 |
| 525 test_util::RunBlockingPoolTask(); | 525 test_util::RunBlockingPoolTask(); |
| 526 } | 526 } |
| 527 | 527 |
| 528 void TestClearDirty( | 528 void TestClearDirty( |
| 529 const std::string& resource_id, | 529 const std::string& resource_id, |
| 530 const std::string& md5, | 530 const std::string& md5, |
| 531 GDataFileError expected_error, | 531 DriveFileError expected_error, |
| 532 int expected_cache_state, | 532 int expected_cache_state, |
| 533 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { | 533 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { |
| 534 expected_error_ = expected_error; | 534 expected_error_ = expected_error; |
| 535 expected_cache_state_ = expected_cache_state; | 535 expected_cache_state_ = expected_cache_state; |
| 536 expected_sub_dir_type_ = expected_sub_dir_type; | 536 expected_sub_dir_type_ = expected_sub_dir_type; |
| 537 expect_outgoing_symlink_ = false; | 537 expect_outgoing_symlink_ = false; |
| 538 | 538 |
| 539 cache_->ClearDirtyOnUIThread(resource_id, md5, | 539 cache_->ClearDirtyOnUIThread(resource_id, md5, |
| 540 base::Bind(&DriveCacheTest::VerifyCacheFileState, | 540 base::Bind(&DriveCacheTest::VerifyCacheFileState, |
| 541 base::Unretained(this))); | 541 base::Unretained(this))); |
| 542 | 542 |
| 543 test_util::RunBlockingPoolTask(); | 543 test_util::RunBlockingPoolTask(); |
| 544 } | 544 } |
| 545 | 545 |
| 546 void TestSetMountedState( | 546 void TestSetMountedState( |
| 547 const std::string& resource_id, | 547 const std::string& resource_id, |
| 548 const std::string& md5, | 548 const std::string& md5, |
| 549 const FilePath& file_path, | 549 const FilePath& file_path, |
| 550 bool to_mount, | 550 bool to_mount, |
| 551 GDataFileError expected_error, | 551 DriveFileError expected_error, |
| 552 int expected_cache_state, | 552 int expected_cache_state, |
| 553 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { | 553 DriveCache::CacheSubDirectoryType expected_sub_dir_type) { |
| 554 expected_error_ = expected_error; | 554 expected_error_ = expected_error; |
| 555 expected_cache_state_ = expected_cache_state; | 555 expected_cache_state_ = expected_cache_state; |
| 556 expected_sub_dir_type_ = expected_sub_dir_type; | 556 expected_sub_dir_type_ = expected_sub_dir_type; |
| 557 expect_outgoing_symlink_ = false; | 557 expect_outgoing_symlink_ = false; |
| 558 | 558 |
| 559 cache_->SetMountedStateOnUIThread(file_path, to_mount, | 559 cache_->SetMountedStateOnUIThread(file_path, to_mount, |
| 560 base::Bind(&DriveCacheTest::VerifySetMountedState, | 560 base::Bind(&DriveCacheTest::VerifySetMountedState, |
| 561 base::Unretained(this), resource_id, md5, to_mount)); | 561 base::Unretained(this), resource_id, md5, to_mount)); |
| 562 | 562 |
| 563 test_util::RunBlockingPoolTask(); | 563 test_util::RunBlockingPoolTask(); |
| 564 } | 564 } |
| 565 | 565 |
| 566 void VerifySetMountedState(const std::string& resource_id, | 566 void VerifySetMountedState(const std::string& resource_id, |
| 567 const std::string& md5, | 567 const std::string& md5, |
| 568 bool to_mount, | 568 bool to_mount, |
| 569 GDataFileError error, | 569 DriveFileError error, |
| 570 const FilePath& file_path) { | 570 const FilePath& file_path) { |
| 571 ++num_callback_invocations_; | 571 ++num_callback_invocations_; |
| 572 EXPECT_TRUE(file_util::PathExists(file_path)); | 572 EXPECT_TRUE(file_util::PathExists(file_path)); |
| 573 EXPECT_TRUE(file_path == cache_->GetCacheFilePath( | 573 EXPECT_TRUE(file_path == cache_->GetCacheFilePath( |
| 574 resource_id, | 574 resource_id, |
| 575 md5, | 575 md5, |
| 576 expected_sub_dir_type_, | 576 expected_sub_dir_type_, |
| 577 to_mount ? | 577 to_mount ? |
| 578 DriveCache::CACHED_FILE_MOUNTED : | 578 DriveCache::CACHED_FILE_MOUNTED : |
| 579 DriveCache::CACHED_FILE_FROM_SERVER)); | 579 DriveCache::CACHED_FILE_FROM_SERVER)); |
| 580 } | 580 } |
| 581 | 581 |
| 582 void VerifyCacheFileState(GDataFileError error, | 582 void VerifyCacheFileState(DriveFileError error, |
| 583 const std::string& resource_id, | 583 const std::string& resource_id, |
| 584 const std::string& md5) { | 584 const std::string& md5) { |
| 585 ++num_callback_invocations_; | 585 ++num_callback_invocations_; |
| 586 | 586 |
| 587 EXPECT_EQ(expected_error_, error); | 587 EXPECT_EQ(expected_error_, error); |
| 588 | 588 |
| 589 // Verify cache map. | 589 // Verify cache map. |
| 590 DriveCacheEntry cache_entry; | 590 DriveCacheEntry cache_entry; |
| 591 const bool cache_entry_found = | 591 const bool cache_entry_found = |
| 592 GetCacheEntryFromOriginThread(resource_id, md5, &cache_entry); | 592 GetCacheEntryFromOriginThread(resource_id, md5, &cache_entry); |
| (...skipping 174 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 767 // See also content/browser/browser_thread_imple.cc. | 767 // See also content/browser/browser_thread_imple.cc. |
| 768 content::TestBrowserThread ui_thread_; | 768 content::TestBrowserThread ui_thread_; |
| 769 content::TestBrowserThread io_thread_; | 769 content::TestBrowserThread io_thread_; |
| 770 scoped_refptr<base::SequencedTaskRunner> blocking_task_runner_; | 770 scoped_refptr<base::SequencedTaskRunner> blocking_task_runner_; |
| 771 scoped_ptr<TestingProfile> profile_; | 771 scoped_ptr<TestingProfile> profile_; |
| 772 DriveCache* cache_; | 772 DriveCache* cache_; |
| 773 MockFreeDiskSpaceGetter* mock_free_disk_space_checker_; | 773 MockFreeDiskSpaceGetter* mock_free_disk_space_checker_; |
| 774 scoped_ptr<StrictMock<MockDriveCacheObserver> > mock_cache_observer_; | 774 scoped_ptr<StrictMock<MockDriveCacheObserver> > mock_cache_observer_; |
| 775 | 775 |
| 776 int num_callback_invocations_; | 776 int num_callback_invocations_; |
| 777 GDataFileError expected_error_; | 777 DriveFileError expected_error_; |
| 778 int expected_cache_state_; | 778 int expected_cache_state_; |
| 779 DriveCache::CacheSubDirectoryType expected_sub_dir_type_; | 779 DriveCache::CacheSubDirectoryType expected_sub_dir_type_; |
| 780 bool expected_success_; | 780 bool expected_success_; |
| 781 bool expect_outgoing_symlink_; | 781 bool expect_outgoing_symlink_; |
| 782 std::string expected_file_extension_; | 782 std::string expected_file_extension_; |
| 783 int root_feed_changestamp_; | 783 int root_feed_changestamp_; |
| 784 }; | 784 }; |
| 785 | 785 |
| 786 TEST_F(DriveCacheTest, InitializeCache) { | 786 TEST_F(DriveCacheTest, InitializeCache) { |
| 787 PrepareForInitCacheTest(); | 787 PrepareForInitCacheTest(); |
| (...skipping 23 matching lines...) Expand all Loading... |
| 811 | 811 |
| 812 TEST_F(DriveCacheTest, StoreToCacheSimple) { | 812 TEST_F(DriveCacheTest, StoreToCacheSimple) { |
| 813 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 813 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 814 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 814 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 815 | 815 |
| 816 std::string resource_id("pdf:1a2b"); | 816 std::string resource_id("pdf:1a2b"); |
| 817 std::string md5("abcdef0123456789"); | 817 std::string md5("abcdef0123456789"); |
| 818 | 818 |
| 819 // Store an existing file. | 819 // Store an existing file. |
| 820 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 820 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 821 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 821 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 822 DriveCache::CACHE_TYPE_TMP); | 822 DriveCache::CACHE_TYPE_TMP); |
| 823 EXPECT_EQ(1, num_callback_invocations_); | 823 EXPECT_EQ(1, num_callback_invocations_); |
| 824 | 824 |
| 825 // Store a non-existent file to the same |resource_id| and |md5|. | 825 // Store a non-existent file to the same |resource_id| and |md5|. |
| 826 num_callback_invocations_ = 0; | 826 num_callback_invocations_ = 0; |
| 827 TestStoreToCache(resource_id, md5, FilePath("./non_existent.json"), | 827 TestStoreToCache(resource_id, md5, FilePath("./non_existent.json"), |
| 828 GDATA_FILE_ERROR_FAILED, | 828 DRIVE_FILE_ERROR_FAILED, |
| 829 test_util::TEST_CACHE_STATE_PRESENT, | 829 test_util::TEST_CACHE_STATE_PRESENT, |
| 830 DriveCache::CACHE_TYPE_TMP); | 830 DriveCache::CACHE_TYPE_TMP); |
| 831 EXPECT_EQ(1, num_callback_invocations_); | 831 EXPECT_EQ(1, num_callback_invocations_); |
| 832 | 832 |
| 833 // Store a different existing file to the same |resource_id| but different | 833 // Store a different existing file to the same |resource_id| but different |
| 834 // |md5|. | 834 // |md5|. |
| 835 md5 = "new_md5"; | 835 md5 = "new_md5"; |
| 836 num_callback_invocations_ = 0; | 836 num_callback_invocations_ = 0; |
| 837 TestStoreToCache(resource_id, md5, GetTestFilePath("subdir_feed.json"), | 837 TestStoreToCache(resource_id, md5, GetTestFilePath("subdir_feed.json"), |
| 838 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 838 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 839 DriveCache::CACHE_TYPE_TMP); | 839 DriveCache::CACHE_TYPE_TMP); |
| 840 EXPECT_EQ(1, num_callback_invocations_); | 840 EXPECT_EQ(1, num_callback_invocations_); |
| 841 | 841 |
| 842 // Verify that there's only one file with name <resource_id>, i.e. previously | 842 // Verify that there's only one file with name <resource_id>, i.e. previously |
| 843 // cached file with the different md5 should be deleted. | 843 // cached file with the different md5 should be deleted. |
| 844 EXPECT_EQ(1U, CountCacheFiles(resource_id, md5)); | 844 EXPECT_EQ(1U, CountCacheFiles(resource_id, md5)); |
| 845 } | 845 } |
| 846 | 846 |
| 847 TEST_F(DriveCacheTest, GetFromCacheSimple) { | 847 TEST_F(DriveCacheTest, GetFromCacheSimple) { |
| 848 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 848 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 849 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 849 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 850 | 850 |
| 851 std::string resource_id("pdf:1a2b"); | 851 std::string resource_id("pdf:1a2b"); |
| 852 std::string md5("abcdef0123456789"); | 852 std::string md5("abcdef0123456789"); |
| 853 // First store a file to cache. | 853 // First store a file to cache. |
| 854 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 854 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 855 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 855 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 856 DriveCache::CACHE_TYPE_TMP); | 856 DriveCache::CACHE_TYPE_TMP); |
| 857 | 857 |
| 858 // Then try to get the existing file from cache. | 858 // Then try to get the existing file from cache. |
| 859 num_callback_invocations_ = 0; | 859 num_callback_invocations_ = 0; |
| 860 TestGetFileFromCacheByResourceIdAndMd5( | 860 TestGetFileFromCacheByResourceIdAndMd5( |
| 861 resource_id, md5, GDATA_FILE_OK, md5); | 861 resource_id, md5, DRIVE_FILE_OK, md5); |
| 862 EXPECT_EQ(1, num_callback_invocations_); | 862 EXPECT_EQ(1, num_callback_invocations_); |
| 863 | 863 |
| 864 // Get file from cache with same resource id as existing file but different | 864 // Get file from cache with same resource id as existing file but different |
| 865 // md5. | 865 // md5. |
| 866 num_callback_invocations_ = 0; | 866 num_callback_invocations_ = 0; |
| 867 TestGetFileFromCacheByResourceIdAndMd5( | 867 TestGetFileFromCacheByResourceIdAndMd5( |
| 868 resource_id, "9999", GDATA_FILE_ERROR_NOT_FOUND, md5); | 868 resource_id, "9999", DRIVE_FILE_ERROR_NOT_FOUND, md5); |
| 869 EXPECT_EQ(1, num_callback_invocations_); | 869 EXPECT_EQ(1, num_callback_invocations_); |
| 870 | 870 |
| 871 // Get file from cache with different resource id from existing file but same | 871 // Get file from cache with different resource id from existing file but same |
| 872 // md5. | 872 // md5. |
| 873 num_callback_invocations_ = 0; | 873 num_callback_invocations_ = 0; |
| 874 resource_id = "document:1a2b"; | 874 resource_id = "document:1a2b"; |
| 875 TestGetFileFromCacheByResourceIdAndMd5( | 875 TestGetFileFromCacheByResourceIdAndMd5( |
| 876 resource_id, md5, GDATA_FILE_ERROR_NOT_FOUND, md5); | 876 resource_id, md5, DRIVE_FILE_ERROR_NOT_FOUND, md5); |
| 877 EXPECT_EQ(1, num_callback_invocations_); | 877 EXPECT_EQ(1, num_callback_invocations_); |
| 878 } | 878 } |
| 879 | 879 |
| 880 TEST_F(DriveCacheTest, RemoveFromCacheSimple) { | 880 TEST_F(DriveCacheTest, RemoveFromCacheSimple) { |
| 881 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 881 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 882 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 882 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 883 | 883 |
| 884 // Use alphanumeric characters for resource id. | 884 // Use alphanumeric characters for resource id. |
| 885 std::string resource_id("pdf:1a2b"); | 885 std::string resource_id("pdf:1a2b"); |
| 886 std::string md5("abcdef0123456789"); | 886 std::string md5("abcdef0123456789"); |
| 887 // First store a file to cache. | 887 // First store a file to cache. |
| 888 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 888 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 889 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 889 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 890 DriveCache::CACHE_TYPE_TMP); | 890 DriveCache::CACHE_TYPE_TMP); |
| 891 | 891 |
| 892 // Then try to remove existing file from cache. | 892 // Then try to remove existing file from cache. |
| 893 num_callback_invocations_ = 0; | 893 num_callback_invocations_ = 0; |
| 894 TestRemoveFromCache(resource_id, GDATA_FILE_OK); | 894 TestRemoveFromCache(resource_id, DRIVE_FILE_OK); |
| 895 EXPECT_EQ(1, num_callback_invocations_); | 895 EXPECT_EQ(1, num_callback_invocations_); |
| 896 | 896 |
| 897 // Repeat using non-alphanumeric characters for resource id, including '.' | 897 // Repeat using non-alphanumeric characters for resource id, including '.' |
| 898 // which is an extension separator. | 898 // which is an extension separator. |
| 899 resource_id = "pdf:`~!@#$%^&*()-_=+[{|]}\\;',<.>/?"; | 899 resource_id = "pdf:`~!@#$%^&*()-_=+[{|]}\\;',<.>/?"; |
| 900 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 900 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 901 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 901 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 902 DriveCache::CACHE_TYPE_TMP); | 902 DriveCache::CACHE_TYPE_TMP); |
| 903 | 903 |
| 904 num_callback_invocations_ = 0; | 904 num_callback_invocations_ = 0; |
| 905 TestRemoveFromCache(resource_id, GDATA_FILE_OK); | 905 TestRemoveFromCache(resource_id, DRIVE_FILE_OK); |
| 906 EXPECT_EQ(1, num_callback_invocations_); | 906 EXPECT_EQ(1, num_callback_invocations_); |
| 907 } | 907 } |
| 908 | 908 |
| 909 TEST_F(DriveCacheTest, PinAndUnpin) { | 909 TEST_F(DriveCacheTest, PinAndUnpin) { |
| 910 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 910 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 911 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 911 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 912 | 912 |
| 913 std::string resource_id("pdf:1a2b"); | 913 std::string resource_id("pdf:1a2b"); |
| 914 std::string md5("abcdef0123456789"); | 914 std::string md5("abcdef0123456789"); |
| 915 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(2); | 915 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(2); |
| 916 EXPECT_CALL(*mock_cache_observer_, OnCacheUnpinned(resource_id, md5)) | 916 EXPECT_CALL(*mock_cache_observer_, OnCacheUnpinned(resource_id, md5)) |
| 917 .Times(1); | 917 .Times(1); |
| 918 | 918 |
| 919 // First store a file to cache. | 919 // First store a file to cache. |
| 920 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 920 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 921 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 921 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 922 DriveCache::CACHE_TYPE_TMP); | 922 DriveCache::CACHE_TYPE_TMP); |
| 923 | 923 |
| 924 // Pin the existing file in cache. | 924 // Pin the existing file in cache. |
| 925 num_callback_invocations_ = 0; | 925 num_callback_invocations_ = 0; |
| 926 TestPin(resource_id, md5, GDATA_FILE_OK, | 926 TestPin(resource_id, md5, DRIVE_FILE_OK, |
| 927 test_util::TEST_CACHE_STATE_PRESENT | | 927 test_util::TEST_CACHE_STATE_PRESENT | |
| 928 test_util::TEST_CACHE_STATE_PINNED | | 928 test_util::TEST_CACHE_STATE_PINNED | |
| 929 test_util::TEST_CACHE_STATE_PERSISTENT, | 929 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 930 DriveCache::CACHE_TYPE_PERSISTENT); | 930 DriveCache::CACHE_TYPE_PERSISTENT); |
| 931 EXPECT_EQ(1, num_callback_invocations_); | 931 EXPECT_EQ(1, num_callback_invocations_); |
| 932 | 932 |
| 933 // Unpin the existing file in cache. | 933 // Unpin the existing file in cache. |
| 934 num_callback_invocations_ = 0; | 934 num_callback_invocations_ = 0; |
| 935 TestUnpin(resource_id, md5, GDATA_FILE_OK, | 935 TestUnpin(resource_id, md5, DRIVE_FILE_OK, |
| 936 test_util::TEST_CACHE_STATE_PRESENT, | 936 test_util::TEST_CACHE_STATE_PRESENT, |
| 937 DriveCache::CACHE_TYPE_TMP); | 937 DriveCache::CACHE_TYPE_TMP); |
| 938 EXPECT_EQ(1, num_callback_invocations_); | 938 EXPECT_EQ(1, num_callback_invocations_); |
| 939 | 939 |
| 940 // Pin back the same existing file in cache. | 940 // Pin back the same existing file in cache. |
| 941 num_callback_invocations_ = 0; | 941 num_callback_invocations_ = 0; |
| 942 TestPin(resource_id, md5, GDATA_FILE_OK, | 942 TestPin(resource_id, md5, DRIVE_FILE_OK, |
| 943 test_util::TEST_CACHE_STATE_PRESENT | | 943 test_util::TEST_CACHE_STATE_PRESENT | |
| 944 test_util::TEST_CACHE_STATE_PINNED | | 944 test_util::TEST_CACHE_STATE_PINNED | |
| 945 test_util::TEST_CACHE_STATE_PERSISTENT, | 945 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 946 DriveCache::CACHE_TYPE_PERSISTENT); | 946 DriveCache::CACHE_TYPE_PERSISTENT); |
| 947 EXPECT_EQ(1, num_callback_invocations_); | 947 EXPECT_EQ(1, num_callback_invocations_); |
| 948 | 948 |
| 949 // Pin a non-existent file in cache. | 949 // Pin a non-existent file in cache. |
| 950 resource_id = "document:1a2b"; | 950 resource_id = "document:1a2b"; |
| 951 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); | 951 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); |
| 952 EXPECT_CALL(*mock_cache_observer_, OnCacheUnpinned(resource_id, md5)) | 952 EXPECT_CALL(*mock_cache_observer_, OnCacheUnpinned(resource_id, md5)) |
| 953 .Times(1); | 953 .Times(1); |
| 954 | 954 |
| 955 num_callback_invocations_ = 0; | 955 num_callback_invocations_ = 0; |
| 956 TestPin(resource_id, md5, GDATA_FILE_OK, | 956 TestPin(resource_id, md5, DRIVE_FILE_OK, |
| 957 test_util::TEST_CACHE_STATE_PINNED, | 957 test_util::TEST_CACHE_STATE_PINNED, |
| 958 DriveCache::CACHE_TYPE_TMP); | 958 DriveCache::CACHE_TYPE_TMP); |
| 959 EXPECT_EQ(1, num_callback_invocations_); | 959 EXPECT_EQ(1, num_callback_invocations_); |
| 960 | 960 |
| 961 // Unpin the previously pinned non-existent file in cache. | 961 // Unpin the previously pinned non-existent file in cache. |
| 962 num_callback_invocations_ = 0; | 962 num_callback_invocations_ = 0; |
| 963 TestUnpin(resource_id, md5, GDATA_FILE_OK, | 963 TestUnpin(resource_id, md5, DRIVE_FILE_OK, |
| 964 test_util::TEST_CACHE_STATE_NONE, | 964 test_util::TEST_CACHE_STATE_NONE, |
| 965 DriveCache::CACHE_TYPE_TMP); | 965 DriveCache::CACHE_TYPE_TMP); |
| 966 EXPECT_EQ(1, num_callback_invocations_); | 966 EXPECT_EQ(1, num_callback_invocations_); |
| 967 | 967 |
| 968 // Unpin a file that doesn't exist in cache and is not pinned, i.e. cache | 968 // Unpin a file that doesn't exist in cache and is not pinned, i.e. cache |
| 969 // has zero knowledge of the file. | 969 // has zero knowledge of the file. |
| 970 resource_id = "not-in-cache:1a2b"; | 970 resource_id = "not-in-cache:1a2b"; |
| 971 // Because unpinning will fail, OnCacheUnpinned() won't be run. | 971 // Because unpinning will fail, OnCacheUnpinned() won't be run. |
| 972 EXPECT_CALL(*mock_cache_observer_, OnCacheUnpinned(resource_id, md5)) | 972 EXPECT_CALL(*mock_cache_observer_, OnCacheUnpinned(resource_id, md5)) |
| 973 .Times(0); | 973 .Times(0); |
| 974 | 974 |
| 975 num_callback_invocations_ = 0; | 975 num_callback_invocations_ = 0; |
| 976 TestUnpin(resource_id, md5, GDATA_FILE_ERROR_NOT_FOUND, | 976 TestUnpin(resource_id, md5, DRIVE_FILE_ERROR_NOT_FOUND, |
| 977 test_util::TEST_CACHE_STATE_NONE, | 977 test_util::TEST_CACHE_STATE_NONE, |
| 978 DriveCache::CACHE_TYPE_TMP /* non-applicable */); | 978 DriveCache::CACHE_TYPE_TMP /* non-applicable */); |
| 979 EXPECT_EQ(1, num_callback_invocations_); | 979 EXPECT_EQ(1, num_callback_invocations_); |
| 980 } | 980 } |
| 981 | 981 |
| 982 TEST_F(DriveCacheTest, StoreToCachePinned) { | 982 TEST_F(DriveCacheTest, StoreToCachePinned) { |
| 983 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 983 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 984 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 984 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 985 | 985 |
| 986 std::string resource_id("pdf:1a2b"); | 986 std::string resource_id("pdf:1a2b"); |
| 987 std::string md5("abcdef0123456789"); | 987 std::string md5("abcdef0123456789"); |
| 988 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); | 988 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); |
| 989 | 989 |
| 990 // Pin a non-existent file. | 990 // Pin a non-existent file. |
| 991 TestPin(resource_id, md5, GDATA_FILE_OK, | 991 TestPin(resource_id, md5, DRIVE_FILE_OK, |
| 992 test_util::TEST_CACHE_STATE_PINNED, | 992 test_util::TEST_CACHE_STATE_PINNED, |
| 993 DriveCache::CACHE_TYPE_TMP); | 993 DriveCache::CACHE_TYPE_TMP); |
| 994 | 994 |
| 995 // Store an existing file to a previously pinned file. | 995 // Store an existing file to a previously pinned file. |
| 996 num_callback_invocations_ = 0; | 996 num_callback_invocations_ = 0; |
| 997 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 997 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 998 GDATA_FILE_OK, | 998 DRIVE_FILE_OK, |
| 999 test_util::TEST_CACHE_STATE_PRESENT | | 999 test_util::TEST_CACHE_STATE_PRESENT | |
| 1000 test_util::TEST_CACHE_STATE_PINNED | | 1000 test_util::TEST_CACHE_STATE_PINNED | |
| 1001 test_util::TEST_CACHE_STATE_PERSISTENT, | 1001 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1002 DriveCache::CACHE_TYPE_PERSISTENT); | 1002 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1003 EXPECT_EQ(1, num_callback_invocations_); | 1003 EXPECT_EQ(1, num_callback_invocations_); |
| 1004 | 1004 |
| 1005 // Store a non-existent file to a previously pinned and stored file. | 1005 // Store a non-existent file to a previously pinned and stored file. |
| 1006 num_callback_invocations_ = 0; | 1006 num_callback_invocations_ = 0; |
| 1007 TestStoreToCache(resource_id, md5, FilePath("./non_existent.json"), | 1007 TestStoreToCache(resource_id, md5, FilePath("./non_existent.json"), |
| 1008 GDATA_FILE_ERROR_FAILED, | 1008 DRIVE_FILE_ERROR_FAILED, |
| 1009 test_util::TEST_CACHE_STATE_PRESENT | | 1009 test_util::TEST_CACHE_STATE_PRESENT | |
| 1010 test_util::TEST_CACHE_STATE_PINNED | | 1010 test_util::TEST_CACHE_STATE_PINNED | |
| 1011 test_util::TEST_CACHE_STATE_PERSISTENT, | 1011 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1012 DriveCache::CACHE_TYPE_PERSISTENT); | 1012 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1013 EXPECT_EQ(1, num_callback_invocations_); | 1013 EXPECT_EQ(1, num_callback_invocations_); |
| 1014 } | 1014 } |
| 1015 | 1015 |
| 1016 TEST_F(DriveCacheTest, GetFromCachePinned) { | 1016 TEST_F(DriveCacheTest, GetFromCachePinned) { |
| 1017 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 1017 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 1018 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 1018 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 1019 | 1019 |
| 1020 std::string resource_id("pdf:1a2b"); | 1020 std::string resource_id("pdf:1a2b"); |
| 1021 std::string md5("abcdef0123456789"); | 1021 std::string md5("abcdef0123456789"); |
| 1022 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); | 1022 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); |
| 1023 | 1023 |
| 1024 // Pin a non-existent file. | 1024 // Pin a non-existent file. |
| 1025 TestPin(resource_id, md5, GDATA_FILE_OK, | 1025 TestPin(resource_id, md5, DRIVE_FILE_OK, |
| 1026 test_util::TEST_CACHE_STATE_PINNED, | 1026 test_util::TEST_CACHE_STATE_PINNED, |
| 1027 DriveCache::CACHE_TYPE_TMP); | 1027 DriveCache::CACHE_TYPE_TMP); |
| 1028 | 1028 |
| 1029 // Get the non-existent pinned file from cache. | 1029 // Get the non-existent pinned file from cache. |
| 1030 num_callback_invocations_ = 0; | 1030 num_callback_invocations_ = 0; |
| 1031 TestGetFileFromCacheByResourceIdAndMd5( | 1031 TestGetFileFromCacheByResourceIdAndMd5( |
| 1032 resource_id, md5, GDATA_FILE_ERROR_NOT_FOUND, md5); | 1032 resource_id, md5, DRIVE_FILE_ERROR_NOT_FOUND, md5); |
| 1033 EXPECT_EQ(1, num_callback_invocations_); | 1033 EXPECT_EQ(1, num_callback_invocations_); |
| 1034 | 1034 |
| 1035 // Store an existing file to the previously pinned non-existent file. | 1035 // Store an existing file to the previously pinned non-existent file. |
| 1036 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 1036 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 1037 GDATA_FILE_OK, | 1037 DRIVE_FILE_OK, |
| 1038 test_util::TEST_CACHE_STATE_PRESENT | | 1038 test_util::TEST_CACHE_STATE_PRESENT | |
| 1039 test_util::TEST_CACHE_STATE_PINNED | | 1039 test_util::TEST_CACHE_STATE_PINNED | |
| 1040 test_util::TEST_CACHE_STATE_PERSISTENT, | 1040 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1041 DriveCache::CACHE_TYPE_PERSISTENT); | 1041 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1042 | 1042 |
| 1043 // Get the previously pinned and stored file from cache. | 1043 // Get the previously pinned and stored file from cache. |
| 1044 num_callback_invocations_ = 0; | 1044 num_callback_invocations_ = 0; |
| 1045 TestGetFileFromCacheByResourceIdAndMd5( | 1045 TestGetFileFromCacheByResourceIdAndMd5( |
| 1046 resource_id, md5, GDATA_FILE_OK, md5); | 1046 resource_id, md5, DRIVE_FILE_OK, md5); |
| 1047 EXPECT_EQ(1, num_callback_invocations_); | 1047 EXPECT_EQ(1, num_callback_invocations_); |
| 1048 } | 1048 } |
| 1049 | 1049 |
| 1050 TEST_F(DriveCacheTest, RemoveFromCachePinned) { | 1050 TEST_F(DriveCacheTest, RemoveFromCachePinned) { |
| 1051 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 1051 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 1052 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 1052 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 1053 | 1053 |
| 1054 // Use alphanumeric characters for resource_id. | 1054 // Use alphanumeric characters for resource_id. |
| 1055 std::string resource_id("pdf:1a2b"); | 1055 std::string resource_id("pdf:1a2b"); |
| 1056 std::string md5("abcdef0123456789"); | 1056 std::string md5("abcdef0123456789"); |
| 1057 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); | 1057 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); |
| 1058 | 1058 |
| 1059 // Store a file to cache, and pin it. | 1059 // Store a file to cache, and pin it. |
| 1060 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 1060 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 1061 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 1061 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 1062 DriveCache::CACHE_TYPE_TMP); | 1062 DriveCache::CACHE_TYPE_TMP); |
| 1063 TestPin(resource_id, md5, GDATA_FILE_OK, | 1063 TestPin(resource_id, md5, DRIVE_FILE_OK, |
| 1064 test_util::TEST_CACHE_STATE_PRESENT | | 1064 test_util::TEST_CACHE_STATE_PRESENT | |
| 1065 test_util::TEST_CACHE_STATE_PINNED | | 1065 test_util::TEST_CACHE_STATE_PINNED | |
| 1066 test_util::TEST_CACHE_STATE_PERSISTENT, | 1066 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1067 DriveCache::CACHE_TYPE_PERSISTENT); | 1067 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1068 | 1068 |
| 1069 // Remove |resource_id| from cache. | 1069 // Remove |resource_id| from cache. |
| 1070 num_callback_invocations_ = 0; | 1070 num_callback_invocations_ = 0; |
| 1071 TestRemoveFromCache(resource_id, GDATA_FILE_OK); | 1071 TestRemoveFromCache(resource_id, DRIVE_FILE_OK); |
| 1072 EXPECT_EQ(1, num_callback_invocations_); | 1072 EXPECT_EQ(1, num_callback_invocations_); |
| 1073 | 1073 |
| 1074 // Repeat using non-alphanumeric characters for resource id, including '.' | 1074 // Repeat using non-alphanumeric characters for resource id, including '.' |
| 1075 // which is an extension separator. | 1075 // which is an extension separator. |
| 1076 resource_id = "pdf:`~!@#$%^&*()-_=+[{|]}\\;',<.>/?"; | 1076 resource_id = "pdf:`~!@#$%^&*()-_=+[{|]}\\;',<.>/?"; |
| 1077 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); | 1077 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); |
| 1078 | 1078 |
| 1079 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 1079 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 1080 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 1080 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 1081 DriveCache::CACHE_TYPE_TMP); | 1081 DriveCache::CACHE_TYPE_TMP); |
| 1082 TestPin(resource_id, md5, GDATA_FILE_OK, | 1082 TestPin(resource_id, md5, DRIVE_FILE_OK, |
| 1083 test_util::TEST_CACHE_STATE_PRESENT | | 1083 test_util::TEST_CACHE_STATE_PRESENT | |
| 1084 test_util::TEST_CACHE_STATE_PINNED | | 1084 test_util::TEST_CACHE_STATE_PINNED | |
| 1085 test_util::TEST_CACHE_STATE_PERSISTENT, | 1085 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1086 DriveCache::CACHE_TYPE_PERSISTENT); | 1086 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1087 | 1087 |
| 1088 num_callback_invocations_ = 0; | 1088 num_callback_invocations_ = 0; |
| 1089 TestRemoveFromCache(resource_id, GDATA_FILE_OK); | 1089 TestRemoveFromCache(resource_id, DRIVE_FILE_OK); |
| 1090 EXPECT_EQ(1, num_callback_invocations_); | 1090 EXPECT_EQ(1, num_callback_invocations_); |
| 1091 } | 1091 } |
| 1092 | 1092 |
| 1093 TEST_F(DriveCacheTest, DirtyCacheSimple) { | 1093 TEST_F(DriveCacheTest, DirtyCacheSimple) { |
| 1094 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 1094 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 1095 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 1095 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 1096 | 1096 |
| 1097 std::string resource_id("pdf:1a2b"); | 1097 std::string resource_id("pdf:1a2b"); |
| 1098 std::string md5("abcdef0123456789"); | 1098 std::string md5("abcdef0123456789"); |
| 1099 EXPECT_CALL(*mock_cache_observer_, OnCacheCommitted(resource_id)).Times(1); | 1099 EXPECT_CALL(*mock_cache_observer_, OnCacheCommitted(resource_id)).Times(1); |
| 1100 | 1100 |
| 1101 // First store a file to cache. | 1101 // First store a file to cache. |
| 1102 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 1102 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 1103 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 1103 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 1104 DriveCache::CACHE_TYPE_TMP); | 1104 DriveCache::CACHE_TYPE_TMP); |
| 1105 | 1105 |
| 1106 // Mark the file dirty. | 1106 // Mark the file dirty. |
| 1107 num_callback_invocations_ = 0; | 1107 num_callback_invocations_ = 0; |
| 1108 TestMarkDirty(resource_id, md5, GDATA_FILE_OK, | 1108 TestMarkDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1109 test_util::TEST_CACHE_STATE_PRESENT | | 1109 test_util::TEST_CACHE_STATE_PRESENT | |
| 1110 test_util::TEST_CACHE_STATE_DIRTY | | 1110 test_util::TEST_CACHE_STATE_DIRTY | |
| 1111 test_util::TEST_CACHE_STATE_PERSISTENT, | 1111 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1112 DriveCache::CACHE_TYPE_PERSISTENT); | 1112 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1113 EXPECT_EQ(1, num_callback_invocations_); | 1113 EXPECT_EQ(1, num_callback_invocations_); |
| 1114 | 1114 |
| 1115 // Commit the file dirty. | 1115 // Commit the file dirty. |
| 1116 num_callback_invocations_ = 0; | 1116 num_callback_invocations_ = 0; |
| 1117 TestCommitDirty(resource_id, md5, GDATA_FILE_OK, | 1117 TestCommitDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1118 test_util::TEST_CACHE_STATE_PRESENT | | 1118 test_util::TEST_CACHE_STATE_PRESENT | |
| 1119 test_util::TEST_CACHE_STATE_DIRTY | | 1119 test_util::TEST_CACHE_STATE_DIRTY | |
| 1120 test_util::TEST_CACHE_STATE_PERSISTENT, | 1120 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1121 DriveCache::CACHE_TYPE_PERSISTENT); | 1121 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1122 EXPECT_EQ(1, num_callback_invocations_); | 1122 EXPECT_EQ(1, num_callback_invocations_); |
| 1123 | 1123 |
| 1124 // Clear dirty state of the file. | 1124 // Clear dirty state of the file. |
| 1125 num_callback_invocations_ = 0; | 1125 num_callback_invocations_ = 0; |
| 1126 TestClearDirty(resource_id, md5, GDATA_FILE_OK, | 1126 TestClearDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1127 test_util::TEST_CACHE_STATE_PRESENT, | 1127 test_util::TEST_CACHE_STATE_PRESENT, |
| 1128 DriveCache::CACHE_TYPE_TMP); | 1128 DriveCache::CACHE_TYPE_TMP); |
| 1129 EXPECT_EQ(1, num_callback_invocations_); | 1129 EXPECT_EQ(1, num_callback_invocations_); |
| 1130 } | 1130 } |
| 1131 | 1131 |
| 1132 TEST_F(DriveCacheTest, DirtyCachePinned) { | 1132 TEST_F(DriveCacheTest, DirtyCachePinned) { |
| 1133 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 1133 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 1134 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 1134 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 1135 | 1135 |
| 1136 std::string resource_id("pdf:1a2b"); | 1136 std::string resource_id("pdf:1a2b"); |
| 1137 std::string md5("abcdef0123456789"); | 1137 std::string md5("abcdef0123456789"); |
| 1138 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); | 1138 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); |
| 1139 EXPECT_CALL(*mock_cache_observer_, OnCacheCommitted(resource_id)).Times(1); | 1139 EXPECT_CALL(*mock_cache_observer_, OnCacheCommitted(resource_id)).Times(1); |
| 1140 | 1140 |
| 1141 // First store a file to cache and pin it. | 1141 // First store a file to cache and pin it. |
| 1142 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 1142 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 1143 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 1143 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 1144 DriveCache::CACHE_TYPE_TMP); | 1144 DriveCache::CACHE_TYPE_TMP); |
| 1145 TestPin(resource_id, md5, GDATA_FILE_OK, | 1145 TestPin(resource_id, md5, DRIVE_FILE_OK, |
| 1146 test_util::TEST_CACHE_STATE_PRESENT | | 1146 test_util::TEST_CACHE_STATE_PRESENT | |
| 1147 test_util::TEST_CACHE_STATE_PINNED | | 1147 test_util::TEST_CACHE_STATE_PINNED | |
| 1148 test_util::TEST_CACHE_STATE_PERSISTENT, | 1148 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1149 DriveCache::CACHE_TYPE_PERSISTENT); | 1149 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1150 | 1150 |
| 1151 // Mark the file dirty. | 1151 // Mark the file dirty. |
| 1152 num_callback_invocations_ = 0; | 1152 num_callback_invocations_ = 0; |
| 1153 TestMarkDirty(resource_id, md5, GDATA_FILE_OK, | 1153 TestMarkDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1154 test_util::TEST_CACHE_STATE_PRESENT | | 1154 test_util::TEST_CACHE_STATE_PRESENT | |
| 1155 test_util::TEST_CACHE_STATE_DIRTY | | 1155 test_util::TEST_CACHE_STATE_DIRTY | |
| 1156 test_util::TEST_CACHE_STATE_PINNED | | 1156 test_util::TEST_CACHE_STATE_PINNED | |
| 1157 test_util::TEST_CACHE_STATE_PERSISTENT, | 1157 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1158 DriveCache::CACHE_TYPE_PERSISTENT); | 1158 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1159 EXPECT_EQ(1, num_callback_invocations_); | 1159 EXPECT_EQ(1, num_callback_invocations_); |
| 1160 | 1160 |
| 1161 // Commit the file dirty. | 1161 // Commit the file dirty. |
| 1162 num_callback_invocations_ = 0; | 1162 num_callback_invocations_ = 0; |
| 1163 TestCommitDirty(resource_id, md5, GDATA_FILE_OK, | 1163 TestCommitDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1164 test_util::TEST_CACHE_STATE_PRESENT | | 1164 test_util::TEST_CACHE_STATE_PRESENT | |
| 1165 test_util::TEST_CACHE_STATE_DIRTY | | 1165 test_util::TEST_CACHE_STATE_DIRTY | |
| 1166 test_util::TEST_CACHE_STATE_PINNED | | 1166 test_util::TEST_CACHE_STATE_PINNED | |
| 1167 test_util::TEST_CACHE_STATE_PERSISTENT, | 1167 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1168 DriveCache::CACHE_TYPE_PERSISTENT); | 1168 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1169 EXPECT_EQ(1, num_callback_invocations_); | 1169 EXPECT_EQ(1, num_callback_invocations_); |
| 1170 | 1170 |
| 1171 // Clear dirty state of the file. | 1171 // Clear dirty state of the file. |
| 1172 num_callback_invocations_ = 0; | 1172 num_callback_invocations_ = 0; |
| 1173 TestClearDirty(resource_id, md5, GDATA_FILE_OK, | 1173 TestClearDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1174 test_util::TEST_CACHE_STATE_PRESENT | | 1174 test_util::TEST_CACHE_STATE_PRESENT | |
| 1175 test_util::TEST_CACHE_STATE_PINNED | | 1175 test_util::TEST_CACHE_STATE_PINNED | |
| 1176 test_util::TEST_CACHE_STATE_PERSISTENT, | 1176 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1177 DriveCache::CACHE_TYPE_PERSISTENT); | 1177 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1178 EXPECT_EQ(1, num_callback_invocations_); | 1178 EXPECT_EQ(1, num_callback_invocations_); |
| 1179 } | 1179 } |
| 1180 | 1180 |
| 1181 // Test is disabled because it is flaky (http://crbug.com/134146) | 1181 // Test is disabled because it is flaky (http://crbug.com/134146) |
| 1182 TEST_F(DriveCacheTest, PinAndUnpinDirtyCache) { | 1182 TEST_F(DriveCacheTest, PinAndUnpinDirtyCache) { |
| 1183 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 1183 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 1184 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 1184 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 1185 | 1185 |
| 1186 std::string resource_id("pdf:1a2b"); | 1186 std::string resource_id("pdf:1a2b"); |
| 1187 std::string md5("abcdef0123456789"); | 1187 std::string md5("abcdef0123456789"); |
| 1188 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); | 1188 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); |
| 1189 EXPECT_CALL(*mock_cache_observer_, OnCacheUnpinned(resource_id, md5)) | 1189 EXPECT_CALL(*mock_cache_observer_, OnCacheUnpinned(resource_id, md5)) |
| 1190 .Times(1); | 1190 .Times(1); |
| 1191 | 1191 |
| 1192 // First store a file to cache and mark it as dirty. | 1192 // First store a file to cache and mark it as dirty. |
| 1193 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 1193 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 1194 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 1194 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 1195 DriveCache::CACHE_TYPE_TMP); | 1195 DriveCache::CACHE_TYPE_TMP); |
| 1196 TestMarkDirty(resource_id, md5, GDATA_FILE_OK, | 1196 TestMarkDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1197 test_util::TEST_CACHE_STATE_PRESENT | | 1197 test_util::TEST_CACHE_STATE_PRESENT | |
| 1198 test_util::TEST_CACHE_STATE_DIRTY | | 1198 test_util::TEST_CACHE_STATE_DIRTY | |
| 1199 test_util::TEST_CACHE_STATE_PERSISTENT, | 1199 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1200 DriveCache::CACHE_TYPE_PERSISTENT); | 1200 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1201 | 1201 |
| 1202 // Verifies dirty file exists. | 1202 // Verifies dirty file exists. |
| 1203 FilePath dirty_path = GetCacheFilePath( | 1203 FilePath dirty_path = GetCacheFilePath( |
| 1204 resource_id, | 1204 resource_id, |
| 1205 md5, | 1205 md5, |
| 1206 DriveCache::CACHE_TYPE_PERSISTENT, | 1206 DriveCache::CACHE_TYPE_PERSISTENT, |
| 1207 DriveCache::CACHED_FILE_LOCALLY_MODIFIED); | 1207 DriveCache::CACHED_FILE_LOCALLY_MODIFIED); |
| 1208 EXPECT_TRUE(file_util::PathExists(dirty_path)); | 1208 EXPECT_TRUE(file_util::PathExists(dirty_path)); |
| 1209 | 1209 |
| 1210 // Pin the dirty file. | 1210 // Pin the dirty file. |
| 1211 TestPin(resource_id, md5, GDATA_FILE_OK, | 1211 TestPin(resource_id, md5, DRIVE_FILE_OK, |
| 1212 test_util::TEST_CACHE_STATE_PRESENT | | 1212 test_util::TEST_CACHE_STATE_PRESENT | |
| 1213 test_util::TEST_CACHE_STATE_DIRTY | | 1213 test_util::TEST_CACHE_STATE_DIRTY | |
| 1214 test_util::TEST_CACHE_STATE_PINNED | | 1214 test_util::TEST_CACHE_STATE_PINNED | |
| 1215 test_util::TEST_CACHE_STATE_PERSISTENT, | 1215 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1216 DriveCache::CACHE_TYPE_PERSISTENT); | 1216 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1217 | 1217 |
| 1218 // Verify dirty file still exist at the same pathname. | 1218 // Verify dirty file still exist at the same pathname. |
| 1219 EXPECT_TRUE(file_util::PathExists(dirty_path)); | 1219 EXPECT_TRUE(file_util::PathExists(dirty_path)); |
| 1220 | 1220 |
| 1221 // Unpin the dirty file. | 1221 // Unpin the dirty file. |
| 1222 TestUnpin(resource_id, md5, GDATA_FILE_OK, | 1222 TestUnpin(resource_id, md5, DRIVE_FILE_OK, |
| 1223 test_util::TEST_CACHE_STATE_PRESENT | | 1223 test_util::TEST_CACHE_STATE_PRESENT | |
| 1224 test_util::TEST_CACHE_STATE_DIRTY | | 1224 test_util::TEST_CACHE_STATE_DIRTY | |
| 1225 test_util::TEST_CACHE_STATE_PERSISTENT, | 1225 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1226 DriveCache::CACHE_TYPE_PERSISTENT); | 1226 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1227 | 1227 |
| 1228 // Verify dirty file still exist at the same pathname. | 1228 // Verify dirty file still exist at the same pathname. |
| 1229 EXPECT_TRUE(file_util::PathExists(dirty_path)); | 1229 EXPECT_TRUE(file_util::PathExists(dirty_path)); |
| 1230 } | 1230 } |
| 1231 | 1231 |
| 1232 TEST_F(DriveCacheTest, DirtyCacheRepetitive) { | 1232 TEST_F(DriveCacheTest, DirtyCacheRepetitive) { |
| 1233 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 1233 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 1234 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 1234 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 1235 | 1235 |
| 1236 std::string resource_id("pdf:1a2b"); | 1236 std::string resource_id("pdf:1a2b"); |
| 1237 std::string md5("abcdef0123456789"); | 1237 std::string md5("abcdef0123456789"); |
| 1238 EXPECT_CALL(*mock_cache_observer_, OnCacheCommitted(resource_id)).Times(3); | 1238 EXPECT_CALL(*mock_cache_observer_, OnCacheCommitted(resource_id)).Times(3); |
| 1239 | 1239 |
| 1240 // First store a file to cache. | 1240 // First store a file to cache. |
| 1241 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 1241 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 1242 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 1242 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 1243 DriveCache::CACHE_TYPE_TMP); | 1243 DriveCache::CACHE_TYPE_TMP); |
| 1244 | 1244 |
| 1245 // Mark the file dirty. | 1245 // Mark the file dirty. |
| 1246 num_callback_invocations_ = 0; | 1246 num_callback_invocations_ = 0; |
| 1247 TestMarkDirty(resource_id, md5, GDATA_FILE_OK, | 1247 TestMarkDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1248 test_util::TEST_CACHE_STATE_PRESENT | | 1248 test_util::TEST_CACHE_STATE_PRESENT | |
| 1249 test_util::TEST_CACHE_STATE_DIRTY | | 1249 test_util::TEST_CACHE_STATE_DIRTY | |
| 1250 test_util::TEST_CACHE_STATE_PERSISTENT, | 1250 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1251 DriveCache::CACHE_TYPE_PERSISTENT); | 1251 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1252 EXPECT_EQ(1, num_callback_invocations_); | 1252 EXPECT_EQ(1, num_callback_invocations_); |
| 1253 | 1253 |
| 1254 // Again, mark the file dirty. Nothing should change. | 1254 // Again, mark the file dirty. Nothing should change. |
| 1255 num_callback_invocations_ = 0; | 1255 num_callback_invocations_ = 0; |
| 1256 TestMarkDirty(resource_id, md5, GDATA_FILE_OK, | 1256 TestMarkDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1257 test_util::TEST_CACHE_STATE_PRESENT | | 1257 test_util::TEST_CACHE_STATE_PRESENT | |
| 1258 test_util::TEST_CACHE_STATE_DIRTY | | 1258 test_util::TEST_CACHE_STATE_DIRTY | |
| 1259 test_util::TEST_CACHE_STATE_PERSISTENT, | 1259 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1260 DriveCache::CACHE_TYPE_PERSISTENT); | 1260 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1261 EXPECT_EQ(1, num_callback_invocations_); | 1261 EXPECT_EQ(1, num_callback_invocations_); |
| 1262 | 1262 |
| 1263 // Commit the file dirty. Outgoing symlink should be created. | 1263 // Commit the file dirty. Outgoing symlink should be created. |
| 1264 num_callback_invocations_ = 0; | 1264 num_callback_invocations_ = 0; |
| 1265 TestCommitDirty(resource_id, md5, GDATA_FILE_OK, | 1265 TestCommitDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1266 test_util::TEST_CACHE_STATE_PRESENT | | 1266 test_util::TEST_CACHE_STATE_PRESENT | |
| 1267 test_util::TEST_CACHE_STATE_DIRTY | | 1267 test_util::TEST_CACHE_STATE_DIRTY | |
| 1268 test_util::TEST_CACHE_STATE_PERSISTENT, | 1268 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1269 DriveCache::CACHE_TYPE_PERSISTENT); | 1269 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1270 EXPECT_EQ(1, num_callback_invocations_); | 1270 EXPECT_EQ(1, num_callback_invocations_); |
| 1271 | 1271 |
| 1272 // Again, commit the file dirty. Nothing should change. | 1272 // Again, commit the file dirty. Nothing should change. |
| 1273 num_callback_invocations_ = 0; | 1273 num_callback_invocations_ = 0; |
| 1274 TestCommitDirty(resource_id, md5, GDATA_FILE_OK, | 1274 TestCommitDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1275 test_util::TEST_CACHE_STATE_PRESENT | | 1275 test_util::TEST_CACHE_STATE_PRESENT | |
| 1276 test_util::TEST_CACHE_STATE_DIRTY | | 1276 test_util::TEST_CACHE_STATE_DIRTY | |
| 1277 test_util::TEST_CACHE_STATE_PERSISTENT, | 1277 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1278 DriveCache::CACHE_TYPE_PERSISTENT); | 1278 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1279 EXPECT_EQ(1, num_callback_invocations_); | 1279 EXPECT_EQ(1, num_callback_invocations_); |
| 1280 | 1280 |
| 1281 // Mark the file dirty agian after it's being committed. Outgoing symlink | 1281 // Mark the file dirty agian after it's being committed. Outgoing symlink |
| 1282 // should be deleted. | 1282 // should be deleted. |
| 1283 num_callback_invocations_ = 0; | 1283 num_callback_invocations_ = 0; |
| 1284 TestMarkDirty(resource_id, md5, GDATA_FILE_OK, | 1284 TestMarkDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1285 test_util::TEST_CACHE_STATE_PRESENT | | 1285 test_util::TEST_CACHE_STATE_PRESENT | |
| 1286 test_util::TEST_CACHE_STATE_DIRTY | | 1286 test_util::TEST_CACHE_STATE_DIRTY | |
| 1287 test_util::TEST_CACHE_STATE_PERSISTENT, | 1287 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1288 DriveCache::CACHE_TYPE_PERSISTENT); | 1288 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1289 EXPECT_EQ(1, num_callback_invocations_); | 1289 EXPECT_EQ(1, num_callback_invocations_); |
| 1290 | 1290 |
| 1291 // Commit the file dirty. Outgoing symlink should be created again. | 1291 // Commit the file dirty. Outgoing symlink should be created again. |
| 1292 num_callback_invocations_ = 0; | 1292 num_callback_invocations_ = 0; |
| 1293 TestCommitDirty(resource_id, md5, GDATA_FILE_OK, | 1293 TestCommitDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1294 test_util::TEST_CACHE_STATE_PRESENT | | 1294 test_util::TEST_CACHE_STATE_PRESENT | |
| 1295 test_util::TEST_CACHE_STATE_DIRTY | | 1295 test_util::TEST_CACHE_STATE_DIRTY | |
| 1296 test_util::TEST_CACHE_STATE_PERSISTENT, | 1296 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1297 DriveCache::CACHE_TYPE_PERSISTENT); | 1297 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1298 EXPECT_EQ(1, num_callback_invocations_); | 1298 EXPECT_EQ(1, num_callback_invocations_); |
| 1299 | 1299 |
| 1300 // Clear dirty state of the file. | 1300 // Clear dirty state of the file. |
| 1301 num_callback_invocations_ = 0; | 1301 num_callback_invocations_ = 0; |
| 1302 TestClearDirty(resource_id, md5, GDATA_FILE_OK, | 1302 TestClearDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1303 test_util::TEST_CACHE_STATE_PRESENT, | 1303 test_util::TEST_CACHE_STATE_PRESENT, |
| 1304 DriveCache::CACHE_TYPE_TMP); | 1304 DriveCache::CACHE_TYPE_TMP); |
| 1305 EXPECT_EQ(1, num_callback_invocations_); | 1305 EXPECT_EQ(1, num_callback_invocations_); |
| 1306 | 1306 |
| 1307 // Again, clear dirty state of the file, which is no longer dirty. | 1307 // Again, clear dirty state of the file, which is no longer dirty. |
| 1308 num_callback_invocations_ = 0; | 1308 num_callback_invocations_ = 0; |
| 1309 TestClearDirty(resource_id, md5, GDATA_FILE_ERROR_INVALID_OPERATION, | 1309 TestClearDirty(resource_id, md5, DRIVE_FILE_ERROR_INVALID_OPERATION, |
| 1310 test_util::TEST_CACHE_STATE_PRESENT, | 1310 test_util::TEST_CACHE_STATE_PRESENT, |
| 1311 DriveCache::CACHE_TYPE_TMP); | 1311 DriveCache::CACHE_TYPE_TMP); |
| 1312 EXPECT_EQ(1, num_callback_invocations_); | 1312 EXPECT_EQ(1, num_callback_invocations_); |
| 1313 } | 1313 } |
| 1314 | 1314 |
| 1315 TEST_F(DriveCacheTest, DirtyCacheInvalid) { | 1315 TEST_F(DriveCacheTest, DirtyCacheInvalid) { |
| 1316 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 1316 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 1317 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 1317 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 1318 | 1318 |
| 1319 std::string resource_id("pdf:1a2b"); | 1319 std::string resource_id("pdf:1a2b"); |
| 1320 std::string md5("abcdef0123456789"); | 1320 std::string md5("abcdef0123456789"); |
| 1321 | 1321 |
| 1322 // Mark a non-existent file dirty. | 1322 // Mark a non-existent file dirty. |
| 1323 num_callback_invocations_ = 0; | 1323 num_callback_invocations_ = 0; |
| 1324 TestMarkDirty(resource_id, md5, GDATA_FILE_ERROR_NOT_FOUND, | 1324 TestMarkDirty(resource_id, md5, DRIVE_FILE_ERROR_NOT_FOUND, |
| 1325 test_util::TEST_CACHE_STATE_NONE, | 1325 test_util::TEST_CACHE_STATE_NONE, |
| 1326 DriveCache::CACHE_TYPE_TMP); | 1326 DriveCache::CACHE_TYPE_TMP); |
| 1327 EXPECT_EQ(1, num_callback_invocations_); | 1327 EXPECT_EQ(1, num_callback_invocations_); |
| 1328 | 1328 |
| 1329 // Commit a non-existent file dirty. | 1329 // Commit a non-existent file dirty. |
| 1330 num_callback_invocations_ = 0; | 1330 num_callback_invocations_ = 0; |
| 1331 TestCommitDirty(resource_id, md5, GDATA_FILE_ERROR_NOT_FOUND, | 1331 TestCommitDirty(resource_id, md5, DRIVE_FILE_ERROR_NOT_FOUND, |
| 1332 test_util::TEST_CACHE_STATE_NONE, | 1332 test_util::TEST_CACHE_STATE_NONE, |
| 1333 DriveCache::CACHE_TYPE_TMP); | 1333 DriveCache::CACHE_TYPE_TMP); |
| 1334 EXPECT_EQ(1, num_callback_invocations_); | 1334 EXPECT_EQ(1, num_callback_invocations_); |
| 1335 | 1335 |
| 1336 // Clear dirty state of a non-existent file. | 1336 // Clear dirty state of a non-existent file. |
| 1337 num_callback_invocations_ = 0; | 1337 num_callback_invocations_ = 0; |
| 1338 TestClearDirty(resource_id, md5, GDATA_FILE_ERROR_NOT_FOUND, | 1338 TestClearDirty(resource_id, md5, DRIVE_FILE_ERROR_NOT_FOUND, |
| 1339 test_util::TEST_CACHE_STATE_NONE, | 1339 test_util::TEST_CACHE_STATE_NONE, |
| 1340 DriveCache::CACHE_TYPE_TMP); | 1340 DriveCache::CACHE_TYPE_TMP); |
| 1341 EXPECT_EQ(1, num_callback_invocations_); | 1341 EXPECT_EQ(1, num_callback_invocations_); |
| 1342 | 1342 |
| 1343 // Store a file to cache. | 1343 // Store a file to cache. |
| 1344 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 1344 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 1345 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 1345 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 1346 DriveCache::CACHE_TYPE_TMP); | 1346 DriveCache::CACHE_TYPE_TMP); |
| 1347 | 1347 |
| 1348 // Commit a non-dirty existing file dirty. | 1348 // Commit a non-dirty existing file dirty. |
| 1349 num_callback_invocations_ = 0; | 1349 num_callback_invocations_ = 0; |
| 1350 TestCommitDirty(resource_id, md5, GDATA_FILE_ERROR_INVALID_OPERATION, | 1350 TestCommitDirty(resource_id, md5, DRIVE_FILE_ERROR_INVALID_OPERATION, |
| 1351 test_util::TEST_CACHE_STATE_PRESENT, | 1351 test_util::TEST_CACHE_STATE_PRESENT, |
| 1352 DriveCache::CACHE_TYPE_TMP); | 1352 DriveCache::CACHE_TYPE_TMP); |
| 1353 EXPECT_EQ(1, num_callback_invocations_); | 1353 EXPECT_EQ(1, num_callback_invocations_); |
| 1354 | 1354 |
| 1355 // Clear dirty state of a non-dirty existing file. | 1355 // Clear dirty state of a non-dirty existing file. |
| 1356 num_callback_invocations_ = 0; | 1356 num_callback_invocations_ = 0; |
| 1357 TestClearDirty(resource_id, md5, GDATA_FILE_ERROR_INVALID_OPERATION, | 1357 TestClearDirty(resource_id, md5, DRIVE_FILE_ERROR_INVALID_OPERATION, |
| 1358 test_util::TEST_CACHE_STATE_PRESENT, | 1358 test_util::TEST_CACHE_STATE_PRESENT, |
| 1359 DriveCache::CACHE_TYPE_TMP); | 1359 DriveCache::CACHE_TYPE_TMP); |
| 1360 EXPECT_EQ(1, num_callback_invocations_); | 1360 EXPECT_EQ(1, num_callback_invocations_); |
| 1361 | 1361 |
| 1362 // Mark an existing file dirty, then store a new file to the same resource id | 1362 // Mark an existing file dirty, then store a new file to the same resource id |
| 1363 // but different md5, which should fail. | 1363 // but different md5, which should fail. |
| 1364 TestMarkDirty(resource_id, md5, GDATA_FILE_OK, | 1364 TestMarkDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1365 test_util::TEST_CACHE_STATE_PRESENT | | 1365 test_util::TEST_CACHE_STATE_PRESENT | |
| 1366 test_util::TEST_CACHE_STATE_DIRTY | | 1366 test_util::TEST_CACHE_STATE_DIRTY | |
| 1367 test_util::TEST_CACHE_STATE_PERSISTENT, | 1367 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1368 DriveCache::CACHE_TYPE_PERSISTENT); | 1368 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1369 num_callback_invocations_ = 0; | 1369 num_callback_invocations_ = 0; |
| 1370 md5 = "new_md5"; | 1370 md5 = "new_md5"; |
| 1371 TestStoreToCache(resource_id, md5, GetTestFilePath("subdir_feed.json"), | 1371 TestStoreToCache(resource_id, md5, GetTestFilePath("subdir_feed.json"), |
| 1372 GDATA_FILE_ERROR_IN_USE, | 1372 DRIVE_FILE_ERROR_IN_USE, |
| 1373 test_util::TEST_CACHE_STATE_PRESENT | | 1373 test_util::TEST_CACHE_STATE_PRESENT | |
| 1374 test_util::TEST_CACHE_STATE_DIRTY | | 1374 test_util::TEST_CACHE_STATE_DIRTY | |
| 1375 test_util::TEST_CACHE_STATE_PERSISTENT, | 1375 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1376 DriveCache::CACHE_TYPE_PERSISTENT); | 1376 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1377 EXPECT_EQ(1, num_callback_invocations_); | 1377 EXPECT_EQ(1, num_callback_invocations_); |
| 1378 } | 1378 } |
| 1379 | 1379 |
| 1380 TEST_F(DriveCacheTest, RemoveFromDirtyCache) { | 1380 TEST_F(DriveCacheTest, RemoveFromDirtyCache) { |
| 1381 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 1381 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 1382 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 1382 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 1383 | 1383 |
| 1384 std::string resource_id("pdf:1a2b"); | 1384 std::string resource_id("pdf:1a2b"); |
| 1385 std::string md5("abcdef0123456789"); | 1385 std::string md5("abcdef0123456789"); |
| 1386 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); | 1386 EXPECT_CALL(*mock_cache_observer_, OnCachePinned(resource_id, md5)).Times(1); |
| 1387 EXPECT_CALL(*mock_cache_observer_, OnCacheCommitted(resource_id)).Times(1); | 1387 EXPECT_CALL(*mock_cache_observer_, OnCacheCommitted(resource_id)).Times(1); |
| 1388 | 1388 |
| 1389 // Store a file to cache, pin it, mark it dirty and commit it. | 1389 // Store a file to cache, pin it, mark it dirty and commit it. |
| 1390 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 1390 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 1391 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 1391 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 1392 DriveCache::CACHE_TYPE_TMP); | 1392 DriveCache::CACHE_TYPE_TMP); |
| 1393 TestPin(resource_id, md5, GDATA_FILE_OK, | 1393 TestPin(resource_id, md5, DRIVE_FILE_OK, |
| 1394 test_util::TEST_CACHE_STATE_PRESENT | | 1394 test_util::TEST_CACHE_STATE_PRESENT | |
| 1395 test_util::TEST_CACHE_STATE_PINNED | | 1395 test_util::TEST_CACHE_STATE_PINNED | |
| 1396 test_util::TEST_CACHE_STATE_PERSISTENT, | 1396 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1397 DriveCache::CACHE_TYPE_PERSISTENT); | 1397 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1398 TestMarkDirty(resource_id, md5, GDATA_FILE_OK, | 1398 TestMarkDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1399 test_util::TEST_CACHE_STATE_PRESENT | | 1399 test_util::TEST_CACHE_STATE_PRESENT | |
| 1400 test_util::TEST_CACHE_STATE_PINNED | | 1400 test_util::TEST_CACHE_STATE_PINNED | |
| 1401 test_util::TEST_CACHE_STATE_DIRTY | | 1401 test_util::TEST_CACHE_STATE_DIRTY | |
| 1402 test_util::TEST_CACHE_STATE_PERSISTENT, | 1402 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1403 DriveCache::CACHE_TYPE_PERSISTENT); | 1403 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1404 TestCommitDirty(resource_id, md5, GDATA_FILE_OK, | 1404 TestCommitDirty(resource_id, md5, DRIVE_FILE_OK, |
| 1405 test_util::TEST_CACHE_STATE_PRESENT | | 1405 test_util::TEST_CACHE_STATE_PRESENT | |
| 1406 test_util::TEST_CACHE_STATE_PINNED | | 1406 test_util::TEST_CACHE_STATE_PINNED | |
| 1407 test_util::TEST_CACHE_STATE_DIRTY | | 1407 test_util::TEST_CACHE_STATE_DIRTY | |
| 1408 test_util::TEST_CACHE_STATE_PERSISTENT, | 1408 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1409 DriveCache::CACHE_TYPE_PERSISTENT); | 1409 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1410 | 1410 |
| 1411 // Try to remove the file. Since file is dirty, it and the corresponding | 1411 // Try to remove the file. Since file is dirty, it and the corresponding |
| 1412 // pinned and outgoing symlinks should not be removed. | 1412 // pinned and outgoing symlinks should not be removed. |
| 1413 num_callback_invocations_ = 0; | 1413 num_callback_invocations_ = 0; |
| 1414 TestRemoveFromCache(resource_id, GDATA_FILE_OK); | 1414 TestRemoveFromCache(resource_id, DRIVE_FILE_OK); |
| 1415 EXPECT_EQ(1, num_callback_invocations_); | 1415 EXPECT_EQ(1, num_callback_invocations_); |
| 1416 } | 1416 } |
| 1417 | 1417 |
| 1418 TEST_F(DriveCacheTest, MountUnmount) { | 1418 TEST_F(DriveCacheTest, MountUnmount) { |
| 1419 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 1419 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 1420 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 1420 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 1421 | 1421 |
| 1422 FilePath file_path; | 1422 FilePath file_path; |
| 1423 std::string resource_id("pdf:1a2b"); | 1423 std::string resource_id("pdf:1a2b"); |
| 1424 std::string md5("abcdef0123456789"); | 1424 std::string md5("abcdef0123456789"); |
| 1425 | 1425 |
| 1426 // First store a file to cache in the tmp subdir. | 1426 // First store a file to cache in the tmp subdir. |
| 1427 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 1427 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 1428 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 1428 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 1429 DriveCache::CACHE_TYPE_TMP); | 1429 DriveCache::CACHE_TYPE_TMP); |
| 1430 | 1430 |
| 1431 // Mark the file mounted. | 1431 // Mark the file mounted. |
| 1432 num_callback_invocations_ = 0; | 1432 num_callback_invocations_ = 0; |
| 1433 file_path = cache_->GetCacheFilePath(resource_id, md5, | 1433 file_path = cache_->GetCacheFilePath(resource_id, md5, |
| 1434 DriveCache::CACHE_TYPE_TMP, | 1434 DriveCache::CACHE_TYPE_TMP, |
| 1435 DriveCache::CACHED_FILE_FROM_SERVER); | 1435 DriveCache::CACHED_FILE_FROM_SERVER); |
| 1436 TestSetMountedState(resource_id, md5, file_path, true, | 1436 TestSetMountedState(resource_id, md5, file_path, true, |
| 1437 GDATA_FILE_OK, | 1437 DRIVE_FILE_OK, |
| 1438 test_util::TEST_CACHE_STATE_PRESENT | | 1438 test_util::TEST_CACHE_STATE_PRESENT | |
| 1439 test_util::TEST_CACHE_STATE_MOUNTED | | 1439 test_util::TEST_CACHE_STATE_MOUNTED | |
| 1440 test_util::TEST_CACHE_STATE_PERSISTENT, | 1440 test_util::TEST_CACHE_STATE_PERSISTENT, |
| 1441 DriveCache::CACHE_TYPE_PERSISTENT); | 1441 DriveCache::CACHE_TYPE_PERSISTENT); |
| 1442 EXPECT_EQ(1, num_callback_invocations_); | 1442 EXPECT_EQ(1, num_callback_invocations_); |
| 1443 EXPECT_TRUE(CacheEntryExists(resource_id, md5)); | 1443 EXPECT_TRUE(CacheEntryExists(resource_id, md5)); |
| 1444 | 1444 |
| 1445 // Clear mounted state of the file. | 1445 // Clear mounted state of the file. |
| 1446 num_callback_invocations_ = 0; | 1446 num_callback_invocations_ = 0; |
| 1447 file_path = cache_->GetCacheFilePath(resource_id, | 1447 file_path = cache_->GetCacheFilePath(resource_id, |
| 1448 md5, | 1448 md5, |
| 1449 DriveCache::CACHE_TYPE_PERSISTENT, | 1449 DriveCache::CACHE_TYPE_PERSISTENT, |
| 1450 DriveCache::CACHED_FILE_MOUNTED); | 1450 DriveCache::CACHED_FILE_MOUNTED); |
| 1451 TestSetMountedState(resource_id, md5, file_path, false, | 1451 TestSetMountedState(resource_id, md5, file_path, false, |
| 1452 GDATA_FILE_OK, | 1452 DRIVE_FILE_OK, |
| 1453 test_util::TEST_CACHE_STATE_PRESENT, | 1453 test_util::TEST_CACHE_STATE_PRESENT, |
| 1454 DriveCache::CACHE_TYPE_TMP); | 1454 DriveCache::CACHE_TYPE_TMP); |
| 1455 EXPECT_EQ(1, num_callback_invocations_); | 1455 EXPECT_EQ(1, num_callback_invocations_); |
| 1456 EXPECT_TRUE(CacheEntryExists(resource_id, md5)); | 1456 EXPECT_TRUE(CacheEntryExists(resource_id, md5)); |
| 1457 | 1457 |
| 1458 // Try to remove the file. | 1458 // Try to remove the file. |
| 1459 num_callback_invocations_ = 0; | 1459 num_callback_invocations_ = 0; |
| 1460 TestRemoveFromCache(resource_id, GDATA_FILE_OK); | 1460 TestRemoveFromCache(resource_id, DRIVE_FILE_OK); |
| 1461 EXPECT_EQ(1, num_callback_invocations_); | 1461 EXPECT_EQ(1, num_callback_invocations_); |
| 1462 } | 1462 } |
| 1463 | 1463 |
| 1464 TEST_F(DriveCacheTest, GetResourceIdsOfBacklogOnUIThread) { | 1464 TEST_F(DriveCacheTest, GetResourceIdsOfBacklogOnUIThread) { |
| 1465 PrepareForInitCacheTest(); | 1465 PrepareForInitCacheTest(); |
| 1466 | 1466 |
| 1467 std::vector<std::string> to_fetch; | 1467 std::vector<std::string> to_fetch; |
| 1468 std::vector<std::string> to_upload; | 1468 std::vector<std::string> to_upload; |
| 1469 cache_->GetResourceIdsOfBacklogOnUIThread( | 1469 cache_->GetResourceIdsOfBacklogOnUIThread( |
| 1470 base::Bind(&OnGetResourceIdsOfBacklog, &to_fetch, &to_upload)); | 1470 base::Bind(&OnGetResourceIdsOfBacklog, &to_fetch, &to_upload)); |
| (...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1517 PrepareForInitCacheTest(); | 1517 PrepareForInitCacheTest(); |
| 1518 | 1518 |
| 1519 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 1519 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 1520 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); | 1520 .Times(AtLeast(1)).WillRepeatedly(Return(kLotsOfSpace)); |
| 1521 | 1521 |
| 1522 std::string resource_id("pdf:1a2b"); | 1522 std::string resource_id("pdf:1a2b"); |
| 1523 std::string md5("abcdef0123456789"); | 1523 std::string md5("abcdef0123456789"); |
| 1524 | 1524 |
| 1525 // Store an existing file. | 1525 // Store an existing file. |
| 1526 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 1526 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 1527 GDATA_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, | 1527 DRIVE_FILE_OK, test_util::TEST_CACHE_STATE_PRESENT, |
| 1528 DriveCache::CACHE_TYPE_TMP); | 1528 DriveCache::CACHE_TYPE_TMP); |
| 1529 EXPECT_EQ(1, num_callback_invocations_); | 1529 EXPECT_EQ(1, num_callback_invocations_); |
| 1530 | 1530 |
| 1531 // Verify that there's only one cached file. | 1531 // Verify that there's only one cached file. |
| 1532 EXPECT_EQ(1U, CountCacheFiles(resource_id, md5)); | 1532 EXPECT_EQ(1U, CountCacheFiles(resource_id, md5)); |
| 1533 | 1533 |
| 1534 // Clear cache. | 1534 // Clear cache. |
| 1535 GDataFileError error = GDATA_FILE_OK; | 1535 DriveFileError error = DRIVE_FILE_OK; |
| 1536 FilePath file_path; | 1536 FilePath file_path; |
| 1537 cache_->ClearAllOnUIThread(base::Bind(&OnClearAll, | 1537 cache_->ClearAllOnUIThread(base::Bind(&OnClearAll, |
| 1538 &error, | 1538 &error, |
| 1539 &file_path)); | 1539 &file_path)); |
| 1540 test_util::RunBlockingPoolTask(); | 1540 test_util::RunBlockingPoolTask(); |
| 1541 EXPECT_EQ(GDATA_FILE_OK, error); | 1541 EXPECT_EQ(DRIVE_FILE_OK, error); |
| 1542 | 1542 |
| 1543 // Verify that all the cache is removed. | 1543 // Verify that all the cache is removed. |
| 1544 VerifyRemoveFromCache(error, resource_id, md5); | 1544 VerifyRemoveFromCache(error, resource_id, md5); |
| 1545 EXPECT_EQ(0U, CountCacheFiles(resource_id, md5)); | 1545 EXPECT_EQ(0U, CountCacheFiles(resource_id, md5)); |
| 1546 } | 1546 } |
| 1547 | 1547 |
| 1548 TEST_F(DriveCacheTest, StoreToCacheNoSpace) { | 1548 TEST_F(DriveCacheTest, StoreToCacheNoSpace) { |
| 1549 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) | 1549 EXPECT_CALL(*mock_free_disk_space_checker_, AmountOfFreeDiskSpace()) |
| 1550 .Times(AtLeast(1)).WillRepeatedly(Return(0)); | 1550 .Times(AtLeast(1)).WillRepeatedly(Return(0)); |
| 1551 | 1551 |
| 1552 std::string resource_id("pdf:1a2b"); | 1552 std::string resource_id("pdf:1a2b"); |
| 1553 std::string md5("abcdef0123456789"); | 1553 std::string md5("abcdef0123456789"); |
| 1554 | 1554 |
| 1555 // Try to store an existing file. | 1555 // Try to store an existing file. |
| 1556 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), | 1556 TestStoreToCache(resource_id, md5, GetTestFilePath("root_feed.json"), |
| 1557 GDATA_FILE_ERROR_NO_SPACE, | 1557 DRIVE_FILE_ERROR_NO_SPACE, |
| 1558 test_util::TEST_CACHE_STATE_NONE, | 1558 test_util::TEST_CACHE_STATE_NONE, |
| 1559 DriveCache::CACHE_TYPE_TMP); | 1559 DriveCache::CACHE_TYPE_TMP); |
| 1560 EXPECT_EQ(1, num_callback_invocations_); | 1560 EXPECT_EQ(1, num_callback_invocations_); |
| 1561 | 1561 |
| 1562 // Verify that there's no files added. | 1562 // Verify that there's no files added. |
| 1563 EXPECT_EQ(0U, CountCacheFiles(resource_id, md5)); | 1563 EXPECT_EQ(0U, CountCacheFiles(resource_id, md5)); |
| 1564 } | 1564 } |
| 1565 | 1565 |
| 1566 | 1566 |
| 1567 } // namespace gdata | 1567 } // namespace gdata |
| OLD | NEW |