OLD | NEW |
1 // Copyright (c) 2009 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2009 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "chrome/browser/sync/syncable/syncable.h" | 5 #include "chrome/browser/sync/syncable/syncable.h" |
6 | 6 |
7 #include "build/build_config.h" | 7 #include "build/build_config.h" |
8 | 8 |
9 #include <sys/types.h> | 9 #include <sys/types.h> |
10 | 10 |
(...skipping 24 matching lines...) Expand all Loading... |
35 #include "base/logging.h" | 35 #include "base/logging.h" |
36 #include "base/platform_thread.h" | 36 #include "base/platform_thread.h" |
37 #include "base/scoped_ptr.h" | 37 #include "base/scoped_ptr.h" |
38 #include "chrome/browser/sync/syncable/directory_backing_store.h" | 38 #include "chrome/browser/sync/syncable/directory_backing_store.h" |
39 #include "chrome/browser/sync/syncable/directory_manager.h" | 39 #include "chrome/browser/sync/syncable/directory_manager.h" |
40 #include "chrome/browser/sync/util/closure.h" | 40 #include "chrome/browser/sync/util/closure.h" |
41 #include "chrome/browser/sync/util/event_sys-inl.h" | 41 #include "chrome/browser/sync/util/event_sys-inl.h" |
42 #include "chrome/browser/sync/util/path_helpers.h" | 42 #include "chrome/browser/sync/util/path_helpers.h" |
43 #include "chrome/browser/sync/util/query_helpers.h" | 43 #include "chrome/browser/sync/util/query_helpers.h" |
44 #include "chrome/test/sync/engine/test_id_factory.h" | 44 #include "chrome/test/sync/engine/test_id_factory.h" |
| 45 #include "chrome/test/sync/engine/test_syncable_utils.h" |
45 #include "testing/gtest/include/gtest/gtest.h" | 46 #include "testing/gtest/include/gtest/gtest.h" |
46 #include "third_party/sqlite/preprocessed/sqlite3.h" | 47 #include "third_party/sqlite/preprocessed/sqlite3.h" |
47 | 48 |
48 using browser_sync::TestIdFactory; | 49 using browser_sync::TestIdFactory; |
49 using std::cout; | 50 using std::cout; |
50 using std::endl; | 51 using std::endl; |
51 using std::string; | 52 using std::string; |
52 | 53 |
53 namespace syncable { | 54 namespace syncable { |
54 | 55 |
| 56 namespace { |
55 // A lot of these tests were written expecting to be able to read and write | 57 // A lot of these tests were written expecting to be able to read and write |
56 // object data on entries. However, the design has changed. | 58 // object data on entries. However, the design has changed. |
57 void PutDataAsExtendedAttribute(WriteTransaction* wtrans, | 59 void PutDataAsExtendedAttribute(WriteTransaction* wtrans, |
58 MutableEntry* e, | 60 MutableEntry* e, |
59 const char* bytes, | 61 const char* bytes, |
60 size_t bytes_length) { | 62 size_t bytes_length) { |
61 ExtendedAttributeKey key(e->Get(META_HANDLE), PSTR("DATA")); | 63 ExtendedAttributeKey key(e->Get(META_HANDLE), PSTR("DATA")); |
62 MutableExtendedAttribute attr(wtrans, CREATE, key); | 64 MutableExtendedAttribute attr(wtrans, CREATE, key); |
63 Blob bytes_blob(bytes, bytes + bytes_length); | 65 Blob bytes_blob(bytes, bytes + bytes_length); |
64 attr.mutable_value()->swap(bytes_blob); | 66 attr.mutable_value()->swap(bytes_blob); |
65 } | 67 } |
66 | 68 |
67 void ExpectDataFromExtendedAttributeEquals(BaseTransaction* trans, | 69 void ExpectDataFromExtendedAttributeEquals(BaseTransaction* trans, |
68 Entry* e, | 70 Entry* e, |
69 const char* bytes, | 71 const char* bytes, |
70 size_t bytes_length) { | 72 size_t bytes_length) { |
| 73 ASSERT_TRUE(e->good()); |
71 Blob expected_value(bytes, bytes + bytes_length); | 74 Blob expected_value(bytes, bytes + bytes_length); |
72 ExtendedAttributeKey key(e->Get(META_HANDLE), PSTR("DATA")); | 75 ExtendedAttributeKey key(e->Get(META_HANDLE), PSTR("DATA")); |
73 ExtendedAttribute attr(trans, GET_BY_HANDLE, key); | 76 ExtendedAttribute attr(trans, GET_BY_HANDLE, key); |
74 EXPECT_FALSE(attr.is_deleted()); | 77 EXPECT_FALSE(attr.is_deleted()); |
75 EXPECT_EQ(expected_value, attr.value()); | 78 EXPECT_EQ(expected_value, attr.value()); |
76 } | 79 } |
77 | 80 } // namespace |
78 | 81 |
79 TEST(Syncable, General) { | 82 TEST(Syncable, General) { |
80 remove("SimpleTest.sqlite3"); | 83 remove("SimpleTest.sqlite3"); |
81 Directory dir; | 84 Directory dir; |
82 FilePath test_db(FILE_PATH_LITERAL("SimpleTest.sqlite3")); | 85 FilePath test_db(FILE_PATH_LITERAL("SimpleTest.sqlite3")); |
83 dir.Open(test_db, PSTR("SimpleTest")); | 86 dir.Open(test_db, PSTR("SimpleTest")); |
84 bool entry_exists = false; | 87 |
85 int64 metahandle; | 88 int64 written_metahandle; |
86 const Id id = TestIdFactory::FromNumber(99); | 89 const Id id = TestIdFactory::FromNumber(99); |
87 // Test simple read operations. | 90 PathString name = PSTR("Jeff"); |
| 91 // Test simple read operations on an empty DB. |
88 { | 92 { |
89 ReadTransaction rtrans(&dir, __FILE__, __LINE__); | 93 ReadTransaction rtrans(&dir, __FILE__, __LINE__); |
90 Entry e(&rtrans, GET_BY_ID, id); | 94 Entry e(&rtrans, GET_BY_ID, id); |
91 if (e.good()) { | 95 ASSERT_FALSE(e.good()); // Hasn't been written yet. |
92 entry_exists = true; | 96 |
93 metahandle = e.Get(META_HANDLE); | |
94 } | |
95 Directory::ChildHandles child_handles; | 97 Directory::ChildHandles child_handles; |
96 dir.GetChildHandles(&rtrans, rtrans.root_id(), &child_handles); | 98 dir.GetChildHandles(&rtrans, rtrans.root_id(), &child_handles); |
97 for (Directory::ChildHandles::iterator i = child_handles.begin(); | 99 EXPECT_TRUE(child_handles.empty()); |
98 i != child_handles.end(); ++i) | |
99 cout << *i << endl; | |
100 | |
101 Entry e2(&rtrans, GET_BY_PATH, PSTR("/Hello\\World/")); | |
102 } | 100 } |
103 | 101 |
104 // Test creating a new meta entry. | 102 // Test creating a new meta entry. |
105 { | 103 { |
106 WriteTransaction wtrans(&dir, UNITTEST, __FILE__, __LINE__); | 104 WriteTransaction wtrans(&dir, UNITTEST, __FILE__, __LINE__); |
107 MutableEntry me(&wtrans, CREATE, wtrans.root_id(), PSTR("Jeff")); | 105 MutableEntry me(&wtrans, CREATE, wtrans.root_id(), name); |
108 ASSERT_TRUE(entry_exists ? !me.good() : me.good()); | 106 ASSERT_TRUE(me.good()); |
109 if (me.good()) { | 107 me.Put(ID, id); |
110 me.Put(ID, id); | 108 me.Put(BASE_VERSION, 1); |
111 me.Put(BASE_VERSION, 1); | 109 written_metahandle = me.Get(META_HANDLE); |
112 metahandle = me.Get(META_HANDLE); | 110 } |
| 111 |
| 112 // Test GetChildHandles after something is now in the DB. |
| 113 // Also check that GET_BY_ID works. |
| 114 { |
| 115 ReadTransaction rtrans(&dir, __FILE__, __LINE__); |
| 116 Entry e(&rtrans, GET_BY_ID, id); |
| 117 ASSERT_TRUE(e.good()); |
| 118 |
| 119 Directory::ChildHandles child_handles; |
| 120 dir.GetChildHandles(&rtrans, rtrans.root_id(), &child_handles); |
| 121 EXPECT_EQ(1u, child_handles.size()); |
| 122 |
| 123 for (Directory::ChildHandles::iterator i = child_handles.begin(); |
| 124 i != child_handles.end(); ++i) { |
| 125 EXPECT_EQ(*i, written_metahandle); |
113 } | 126 } |
114 } | 127 } |
115 | 128 |
116 // Test writing data to an entity. | 129 // Test writing data to an entity. Also check that GET_BY_HANDLE works. |
117 static const char s[] = "Hello World."; | 130 static const char s[] = "Hello World."; |
118 { | 131 { |
119 WriteTransaction trans(&dir, UNITTEST, __FILE__, __LINE__); | 132 WriteTransaction trans(&dir, UNITTEST, __FILE__, __LINE__); |
120 MutableEntry e(&trans, GET_BY_PATH, | 133 MutableEntry e(&trans, GET_BY_HANDLE, written_metahandle); |
121 PathString(kPathSeparator) + PSTR("Jeff")); | |
122 ASSERT_TRUE(e.good()); | 134 ASSERT_TRUE(e.good()); |
123 PutDataAsExtendedAttribute(&trans, &e, s, sizeof(s)); | 135 PutDataAsExtendedAttribute(&trans, &e, s, sizeof(s)); |
124 } | 136 } |
125 | 137 |
126 // Test reading back the name contents that we just wrote. | 138 // Test reading back the contents that we just wrote. |
127 { | 139 { |
128 WriteTransaction trans(&dir, UNITTEST, __FILE__, __LINE__); | 140 WriteTransaction trans(&dir, UNITTEST, __FILE__, __LINE__); |
129 MutableEntry e(&trans, GET_BY_PATH, | 141 MutableEntry e(&trans, GET_BY_HANDLE, written_metahandle); |
130 PathString(kPathSeparator) + PSTR("Jeff")); | |
131 ASSERT_TRUE(e.good()); | 142 ASSERT_TRUE(e.good()); |
132 ExpectDataFromExtendedAttributeEquals(&trans, &e, s, sizeof(s)); | 143 ExpectDataFromExtendedAttributeEquals(&trans, &e, s, sizeof(s)); |
133 } | 144 } |
134 | 145 |
| 146 // Verify it exists in the folder. |
| 147 { |
| 148 ReadTransaction rtrans(&dir, __FILE__, __LINE__); |
| 149 EXPECT_EQ(1, CountEntriesWithName(&rtrans, rtrans.root_id(), name)); |
| 150 } |
| 151 |
135 // Now delete it. | 152 // Now delete it. |
136 { | 153 { |
137 WriteTransaction trans(&dir, UNITTEST, __FILE__, __LINE__); | 154 WriteTransaction trans(&dir, UNITTEST, __FILE__, __LINE__); |
138 MutableEntry e(&trans, CREATE, trans.root_id(), PSTR("New File")); | 155 MutableEntry e(&trans, GET_BY_HANDLE, written_metahandle); |
139 e.Put(IS_DEL, true); | 156 e.Put(IS_DEL, true); |
| 157 |
| 158 EXPECT_EQ(0, CountEntriesWithName(&trans, trans.root_id(), name)); |
140 } | 159 } |
141 | 160 |
142 dir.SaveChanges(); | 161 dir.SaveChanges(); |
143 } | 162 remove("SimpleTest.sqlite3"); |
144 | |
145 TEST(Syncable, NameClassTest) { | |
146 const PathString foo(PSTR("foo")); | |
147 const PathString bar(PSTR("bar")); | |
148 | |
149 Name name1(foo); | |
150 EXPECT_EQ(name1.value(), foo); | |
151 EXPECT_EQ(name1.db_value(), foo); | |
152 EXPECT_FALSE(name1.HasBeenSanitized()); | |
153 EXPECT_TRUE(name1.GetUnsanitizedName().empty()); | |
154 | |
155 Name name2(foo, foo); | |
156 EXPECT_EQ(name2.value(), foo); | |
157 EXPECT_EQ(name2.db_value(), foo); | |
158 EXPECT_FALSE(name2.HasBeenSanitized()); | |
159 EXPECT_TRUE(name2.GetUnsanitizedName().empty()); | |
160 | |
161 Name name3(foo, bar); | |
162 EXPECT_EQ(name3.value(), bar); | |
163 EXPECT_EQ(name3.db_value(), foo); | |
164 EXPECT_TRUE(name3.HasBeenSanitized()); | |
165 EXPECT_EQ(name3.GetUnsanitizedName(), bar); | |
166 | |
167 EXPECT_TRUE(name1 == name2); | |
168 EXPECT_FALSE(name1 != name2); | |
169 EXPECT_FALSE(name2 == name3); | |
170 EXPECT_TRUE(name2 != name3); | |
171 } | 163 } |
172 | 164 |
173 namespace { | 165 namespace { |
174 | 166 |
175 // A Directory whose backing store always fails SaveChanges by returning false. | 167 // A Directory whose backing store always fails SaveChanges by returning false. |
176 class TestUnsaveableDirectory : public Directory { | 168 class TestUnsaveableDirectory : public Directory { |
177 public: | 169 public: |
178 class UnsaveableBackingStore : public DirectoryBackingStore { | 170 class UnsaveableBackingStore : public DirectoryBackingStore { |
179 public: | 171 public: |
180 UnsaveableBackingStore(const PathString& dir_name, | 172 UnsaveableBackingStore(const PathString& dir_name, |
(...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
253 ASSERT_FALSE(e.good()); | 245 ASSERT_FALSE(e.good()); |
254 } | 246 } |
255 | 247 |
256 TEST_F(SyncableDirectoryTest, TestBasicLookupValidID) { | 248 TEST_F(SyncableDirectoryTest, TestBasicLookupValidID) { |
257 CreateEntry(PSTR("rtc")); | 249 CreateEntry(PSTR("rtc")); |
258 ReadTransaction rtrans(dir_.get(), __FILE__, __LINE__); | 250 ReadTransaction rtrans(dir_.get(), __FILE__, __LINE__); |
259 Entry e(&rtrans, GET_BY_ID, kId); | 251 Entry e(&rtrans, GET_BY_ID, kId); |
260 ASSERT_TRUE(e.good()); | 252 ASSERT_TRUE(e.good()); |
261 } | 253 } |
262 | 254 |
263 TEST_F(SyncableDirectoryTest, TestBasicCaseSensitivity) { | |
264 PathString name = PSTR("RYAN"); | |
265 PathString conflicting_name = PSTR("ryan"); | |
266 CreateEntry(name); | |
267 | |
268 WriteTransaction wtrans(dir_.get(), UNITTEST, __FILE__, __LINE__); | |
269 MutableEntry me(&wtrans, CREATE, wtrans.root_id(), conflicting_name); | |
270 ASSERT_FALSE(me.good()); | |
271 } | |
272 | |
273 TEST_F(SyncableDirectoryTest, TestDelete) { | 255 TEST_F(SyncableDirectoryTest, TestDelete) { |
274 PathString name = PSTR("peanut butter jelly time"); | 256 PathString name = PSTR("peanut butter jelly time"); |
275 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); | 257 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); |
276 MutableEntry e1(&trans, CREATE, trans.root_id(), name); | 258 MutableEntry e1(&trans, CREATE, trans.root_id(), name); |
277 ASSERT_TRUE(e1.good()); | 259 ASSERT_TRUE(e1.good()); |
278 ASSERT_TRUE(e1.Put(IS_DEL, true)); | 260 ASSERT_TRUE(e1.Put(IS_DEL, true)); |
279 MutableEntry e2(&trans, CREATE, trans.root_id(), name); | 261 MutableEntry e2(&trans, CREATE, trans.root_id(), name); |
280 ASSERT_TRUE(e2.good()); | 262 ASSERT_TRUE(e2.good()); |
281 ASSERT_TRUE(e2.Put(IS_DEL, true)); | 263 ASSERT_TRUE(e2.Put(IS_DEL, true)); |
282 MutableEntry e3(&trans, CREATE, trans.root_id(), name); | 264 MutableEntry e3(&trans, CREATE, trans.root_id(), name); |
283 ASSERT_TRUE(e3.good()); | 265 ASSERT_TRUE(e3.good()); |
284 ASSERT_TRUE(e3.Put(IS_DEL, true)); | 266 ASSERT_TRUE(e3.Put(IS_DEL, true)); |
285 | 267 |
| 268 ASSERT_TRUE(e1.Put(IS_DEL, false)); |
| 269 ASSERT_TRUE(e2.Put(IS_DEL, false)); |
286 ASSERT_TRUE(e3.Put(IS_DEL, false)); | 270 ASSERT_TRUE(e3.Put(IS_DEL, false)); |
287 ASSERT_FALSE(e1.Put(IS_DEL, false)); | 271 |
288 ASSERT_FALSE(e2.Put(IS_DEL, false)); | 272 ASSERT_TRUE(e1.Put(IS_DEL, true)); |
| 273 ASSERT_TRUE(e2.Put(IS_DEL, true)); |
289 ASSERT_TRUE(e3.Put(IS_DEL, true)); | 274 ASSERT_TRUE(e3.Put(IS_DEL, true)); |
290 | |
291 ASSERT_TRUE(e1.Put(IS_DEL, false)); | |
292 ASSERT_FALSE(e2.Put(IS_DEL, false)); | |
293 ASSERT_FALSE(e3.Put(IS_DEL, false)); | |
294 ASSERT_TRUE(e1.Put(IS_DEL, true)); | |
295 } | 275 } |
296 | 276 |
297 TEST_F(SyncableDirectoryTest, TestGetUnsynced) { | 277 TEST_F(SyncableDirectoryTest, TestGetUnsynced) { |
298 Directory::UnsyncedMetaHandles handles; | 278 Directory::UnsyncedMetaHandles handles; |
299 int64 handle1, handle2; | 279 int64 handle1, handle2; |
300 { | 280 { |
301 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); | 281 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); |
302 | 282 |
303 dir_->GetUnsyncedMetaHandles(&trans, &handles); | 283 dir_->GetUnsyncedMetaHandles(&trans, &handles); |
304 ASSERT_TRUE(0 == handles.size()); | 284 ASSERT_TRUE(0 == handles.size()); |
(...skipping 150 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
455 child.Put(BASE_VERSION, 1); | 435 child.Put(BASE_VERSION, 1); |
456 MutableEntry grandchild(&wtrans, CREATE, child.Get(ID), PSTR("Bob")); | 436 MutableEntry grandchild(&wtrans, CREATE, child.Get(ID), PSTR("Bob")); |
457 ASSERT_TRUE(grandchild.good()); | 437 ASSERT_TRUE(grandchild.good()); |
458 grandchild.Put(ID, id_factory.NewServerId()); | 438 grandchild.Put(ID, id_factory.NewServerId()); |
459 grandchild.Put(BASE_VERSION, 1); | 439 grandchild.Put(BASE_VERSION, 1); |
460 ASSERT_TRUE(grandchild.Put(IS_DEL, true)); | 440 ASSERT_TRUE(grandchild.Put(IS_DEL, true)); |
461 MutableEntry twin(&wtrans, CREATE, child.Get(ID), PSTR("Bob")); | 441 MutableEntry twin(&wtrans, CREATE, child.Get(ID), PSTR("Bob")); |
462 ASSERT_TRUE(twin.good()); | 442 ASSERT_TRUE(twin.good()); |
463 ASSERT_TRUE(twin.Put(IS_DEL, true)); | 443 ASSERT_TRUE(twin.Put(IS_DEL, true)); |
464 ASSERT_TRUE(grandchild.Put(IS_DEL, false)); | 444 ASSERT_TRUE(grandchild.Put(IS_DEL, false)); |
465 ASSERT_FALSE(twin.Put(IS_DEL, false)); | 445 |
466 grandchild_handle = grandchild.Get(META_HANDLE); | 446 grandchild_handle = grandchild.Get(META_HANDLE); |
467 twin_handle = twin.Get(META_HANDLE); | 447 twin_handle = twin.Get(META_HANDLE); |
468 } | 448 } |
469 dir_->SaveChanges(); | 449 dir_->SaveChanges(); |
470 { | 450 { |
471 WriteTransaction wtrans(dir_.get(), UNITTEST, __FILE__, __LINE__); | 451 WriteTransaction wtrans(dir_.get(), UNITTEST, __FILE__, __LINE__); |
472 MutableEntry grandchild(&wtrans, GET_BY_HANDLE, grandchild_handle); | 452 MutableEntry grandchild(&wtrans, GET_BY_HANDLE, grandchild_handle); |
473 grandchild.Put(IS_DEL, true); // Used to CHECK fail here. | 453 grandchild.Put(IS_DEL, true); // Used to CHECK fail here. |
474 } | 454 } |
475 } | 455 } |
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
524 ASSERT_TRUE(IsLegalNewParent(child, parent)); | 504 ASSERT_TRUE(IsLegalNewParent(child, parent)); |
525 ASSERT_FALSE(IsLegalNewParent(child, child)); | 505 ASSERT_FALSE(IsLegalNewParent(child, child)); |
526 ASSERT_FALSE(IsLegalNewParent(child, grandchild)); | 506 ASSERT_FALSE(IsLegalNewParent(child, grandchild)); |
527 ASSERT_TRUE(IsLegalNewParent(child, parent2)); | 507 ASSERT_TRUE(IsLegalNewParent(child, parent2)); |
528 ASSERT_TRUE(IsLegalNewParent(child, grandchild2)); | 508 ASSERT_TRUE(IsLegalNewParent(child, grandchild2)); |
529 ASSERT_FALSE(IsLegalNewParent(parent, grandchild)); | 509 ASSERT_FALSE(IsLegalNewParent(parent, grandchild)); |
530 ASSERT_FALSE(IsLegalNewParent(root, grandchild)); | 510 ASSERT_FALSE(IsLegalNewParent(root, grandchild)); |
531 ASSERT_FALSE(IsLegalNewParent(parent, grandchild)); | 511 ASSERT_FALSE(IsLegalNewParent(parent, grandchild)); |
532 } | 512 } |
533 | 513 |
534 TEST_F(SyncableDirectoryTest, TestFindEntryInFolder) { | 514 TEST_F(SyncableDirectoryTest, TestEntryIsInFolder) { |
535 // Create a subdir and an entry. | 515 // Create a subdir and an entry. |
536 int64 entry_handle; | 516 int64 entry_handle; |
| 517 syncable::Id folder_id; |
| 518 syncable::Id entry_id; |
| 519 PathString entry_name = PSTR("entry"); |
| 520 |
537 { | 521 { |
538 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); | 522 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); |
539 MutableEntry folder(&trans, CREATE, trans.root_id(), PSTR("folder")); | 523 MutableEntry folder(&trans, CREATE, trans.root_id(), PSTR("folder")); |
540 ASSERT_TRUE(folder.good()); | 524 ASSERT_TRUE(folder.good()); |
541 EXPECT_TRUE(folder.Put(IS_DIR, true)); | 525 EXPECT_TRUE(folder.Put(IS_DIR, true)); |
542 EXPECT_TRUE(folder.Put(IS_UNSYNCED, true)); | 526 EXPECT_TRUE(folder.Put(IS_UNSYNCED, true)); |
543 MutableEntry entry(&trans, CREATE, folder.Get(ID), PSTR("entry")); | 527 folder_id = folder.Get(ID); |
| 528 |
| 529 MutableEntry entry(&trans, CREATE, folder.Get(ID), entry_name); |
544 ASSERT_TRUE(entry.good()); | 530 ASSERT_TRUE(entry.good()); |
545 entry_handle = entry.Get(META_HANDLE); | 531 entry_handle = entry.Get(META_HANDLE); |
546 entry.Put(IS_UNSYNCED, true); | 532 entry.Put(IS_UNSYNCED, true); |
| 533 entry_id = entry.Get(ID); |
547 } | 534 } |
548 | 535 |
549 // Make sure we can find the entry in the folder. | 536 // Make sure we can find the entry in the folder. |
550 { | 537 { |
551 ReadTransaction trans(dir_.get(), __FILE__, __LINE__); | 538 ReadTransaction trans(dir_.get(), __FILE__, __LINE__); |
552 Entry entry(&trans, GET_BY_PATH, PathString(kPathSeparator) + | 539 EXPECT_EQ(0, CountEntriesWithName(&trans, trans.root_id(), entry_name)); |
553 PSTR("folder") + | 540 EXPECT_EQ(1, CountEntriesWithName(&trans, folder_id, entry_name)); |
554 kPathSeparator + PSTR("entry")); | 541 |
| 542 Entry entry(&trans, GET_BY_ID, entry_id); |
555 ASSERT_TRUE(entry.good()); | 543 ASSERT_TRUE(entry.good()); |
556 ASSERT_TRUE(entry.Get(META_HANDLE) == entry_handle); | 544 EXPECT_EQ(entry_handle, entry.Get(META_HANDLE)); |
| 545 EXPECT_TRUE(entry.Get(NON_UNIQUE_NAME) == entry_name); |
| 546 EXPECT_TRUE(entry.Get(PARENT_ID) == folder_id); |
557 } | 547 } |
558 } | 548 } |
559 | 549 |
560 TEST_F(SyncableDirectoryTest, TestGetByParentIdAndName) { | 550 TEST_F(SyncableDirectoryTest, TestParentIdIndexUpdate) { |
561 PathString name = PSTR("Bob"); | 551 PathString child_name = PSTR("child"); |
562 Id id = TestIdFactory::MakeServer("ID for Bob"); | |
563 { | |
564 WriteTransaction wtrans(dir_.get(), UNITTEST, __FILE__, __LINE__); | |
565 MutableEntry entry(&wtrans, CREATE, wtrans.root_id() /*entry id*/, name); | |
566 ASSERT_TRUE(entry.good()); | |
567 entry.Put(IS_DIR, true); | |
568 entry.Put(ID, id); | |
569 entry.Put(BASE_VERSION, 1); | |
570 entry.Put(IS_UNSYNCED, true); | |
571 } | |
572 { | |
573 WriteTransaction wtrans(dir_.get(), UNITTEST, __FILE__, __LINE__); | |
574 MutableEntry entry(&wtrans, GET_BY_PARENTID_AND_NAME, wtrans.root_id(), | |
575 name); | |
576 ASSERT_TRUE(entry.good()); | |
577 ASSERT_TRUE(id == entry.Get(ID)); | |
578 } | |
579 { | |
580 ReadTransaction trans(dir_.get(), __FILE__, __LINE__); | |
581 Entry entry(&trans, GET_BY_PARENTID_AND_NAME, trans.root_id(), name); | |
582 ASSERT_TRUE(entry.good()); | |
583 ASSERT_TRUE(id == entry.Get(ID)); | |
584 } | |
585 } | |
586 | 552 |
587 TEST_F(SyncableDirectoryTest, TestParentIDIndexUpdate) { | |
588 WriteTransaction wt(dir_.get(), UNITTEST, __FILE__, __LINE__); | 553 WriteTransaction wt(dir_.get(), UNITTEST, __FILE__, __LINE__); |
589 MutableEntry folder(&wt, CREATE, wt.root_id(), PSTR("oldname")); | 554 MutableEntry parent_folder(&wt, CREATE, wt.root_id(), PSTR("folder1")); |
590 folder.Put(NAME, PSTR("newname")); | 555 parent_folder.Put(IS_UNSYNCED, true); |
591 folder.Put(IS_UNSYNCED, true); | 556 EXPECT_TRUE(parent_folder.Put(IS_DIR, true)); |
592 Entry entry(&wt, GET_BY_PATH, PSTR("newname")); | 557 |
593 ASSERT_TRUE(entry.good()); | 558 MutableEntry parent_folder2(&wt, CREATE, wt.root_id(), PSTR("folder2")); |
| 559 parent_folder2.Put(IS_UNSYNCED, true); |
| 560 EXPECT_TRUE(parent_folder2.Put(IS_DIR, true)); |
| 561 |
| 562 MutableEntry child(&wt, CREATE, parent_folder.Get(ID), child_name); |
| 563 EXPECT_TRUE(child.Put(IS_DIR, true)); |
| 564 child.Put(IS_UNSYNCED, true); |
| 565 |
| 566 ASSERT_TRUE(child.good()); |
| 567 |
| 568 EXPECT_EQ(0, CountEntriesWithName(&wt, wt.root_id(), child_name)); |
| 569 EXPECT_EQ(parent_folder.Get(ID), child.Get(PARENT_ID)); |
| 570 EXPECT_EQ(1, CountEntriesWithName(&wt, parent_folder.Get(ID), child_name)); |
| 571 EXPECT_EQ(0, CountEntriesWithName(&wt, parent_folder2.Get(ID), child_name)); |
| 572 child.Put(PARENT_ID, parent_folder2.Get(ID)); |
| 573 EXPECT_EQ(parent_folder2.Get(ID), child.Get(PARENT_ID)); |
| 574 EXPECT_EQ(0, CountEntriesWithName(&wt, parent_folder.Get(ID), child_name)); |
| 575 EXPECT_EQ(1, CountEntriesWithName(&wt, parent_folder2.Get(ID), child_name)); |
| 576 |
594 } | 577 } |
595 | 578 |
596 TEST_F(SyncableDirectoryTest, TestNoReindexDeletedItems) { | 579 TEST_F(SyncableDirectoryTest, TestNoReindexDeletedItems) { |
| 580 PathString folder_name = PSTR("folder"); |
| 581 PathString new_name = PSTR("new_name"); |
| 582 |
597 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); | 583 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); |
598 MutableEntry folder(&trans, CREATE, trans.root_id(), PSTR("folder")); | 584 MutableEntry folder(&trans, CREATE, trans.root_id(), folder_name); |
599 ASSERT_TRUE(folder.good()); | 585 ASSERT_TRUE(folder.good()); |
600 ASSERT_TRUE(folder.Put(IS_DIR, true)); | 586 ASSERT_TRUE(folder.Put(IS_DIR, true)); |
601 ASSERT_TRUE(folder.Put(IS_DEL, true)); | 587 ASSERT_TRUE(folder.Put(IS_DEL, true)); |
602 Entry gone(&trans, GET_BY_PARENTID_AND_NAME, trans.root_id(), PSTR("folder")); | 588 |
603 ASSERT_FALSE(gone.good()); | 589 EXPECT_EQ(0, CountEntriesWithName(&trans, trans.root_id(), folder_name)); |
604 ASSERT_TRUE(folder.PutParentIdAndName(trans.root_id(), | 590 |
605 Name(PSTR("new_name")))); | 591 MutableEntry deleted(&trans, GET_BY_ID, folder.Get(ID)); |
| 592 ASSERT_TRUE(deleted.good()); |
| 593 ASSERT_TRUE(deleted.Put(PARENT_ID, trans.root_id())); |
| 594 ASSERT_TRUE(deleted.Put(NON_UNIQUE_NAME, new_name)); |
| 595 |
| 596 EXPECT_EQ(0, CountEntriesWithName(&trans, trans.root_id(), folder_name)); |
| 597 EXPECT_EQ(0, CountEntriesWithName(&trans, trans.root_id(), new_name)); |
606 } | 598 } |
607 | 599 |
608 TEST_F(SyncableDirectoryTest, TestCaseChangeRename) { | 600 TEST_F(SyncableDirectoryTest, TestCaseChangeRename) { |
609 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); | 601 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); |
610 MutableEntry folder(&trans, CREATE, trans.root_id(), PSTR("CaseChange")); | 602 MutableEntry folder(&trans, CREATE, trans.root_id(), PSTR("CaseChange")); |
611 ASSERT_TRUE(folder.good()); | 603 ASSERT_TRUE(folder.good()); |
612 EXPECT_TRUE(folder.PutParentIdAndName(trans.root_id(), | 604 EXPECT_TRUE(folder.Put(PARENT_ID, trans.root_id())); |
613 Name(PSTR("CASECHANGE")))); | 605 EXPECT_TRUE(folder.Put(NON_UNIQUE_NAME, PSTR("CASECHANGE"))); |
614 EXPECT_TRUE(folder.Put(IS_DEL, true)); | 606 EXPECT_TRUE(folder.Put(IS_DEL, true)); |
615 } | 607 } |
616 | 608 |
617 TEST_F(SyncableDirectoryTest, TestShareInfo) { | 609 TEST_F(SyncableDirectoryTest, TestShareInfo) { |
618 dir_->set_last_sync_timestamp(100); | 610 dir_->set_last_sync_timestamp(100); |
619 dir_->set_store_birthday("Jan 31st"); | 611 dir_->set_store_birthday("Jan 31st"); |
620 { | 612 { |
621 ReadTransaction trans(dir_.get(), __FILE__, __LINE__); | 613 ReadTransaction trans(dir_.get(), __FILE__, __LINE__); |
622 EXPECT_EQ(100, dir_->last_sync_timestamp()); | 614 EXPECT_EQ(100, dir_->last_sync_timestamp()); |
623 EXPECT_EQ("Jan 31st", dir_->store_birthday()); | 615 EXPECT_EQ("Jan 31st", dir_->store_birthday()); |
624 } | 616 } |
625 dir_->set_last_sync_timestamp(200); | 617 dir_->set_last_sync_timestamp(200); |
626 dir_->set_store_birthday("April 10th"); | 618 dir_->set_store_birthday("April 10th"); |
627 dir_->SaveChanges(); | 619 dir_->SaveChanges(); |
628 { | 620 { |
629 ReadTransaction trans(dir_.get(), __FILE__, __LINE__); | 621 ReadTransaction trans(dir_.get(), __FILE__, __LINE__); |
630 EXPECT_EQ(200, dir_->last_sync_timestamp()); | 622 EXPECT_EQ(200, dir_->last_sync_timestamp()); |
631 EXPECT_EQ("April 10th", dir_->store_birthday()); | 623 EXPECT_EQ("April 10th", dir_->store_birthday()); |
632 } | 624 } |
633 } | 625 } |
634 | 626 |
635 TEST_F(SyncableDirectoryTest, TestSimpleFieldsPreservedDuringSaveChanges) { | 627 TEST_F(SyncableDirectoryTest, TestSimpleFieldsPreservedDuringSaveChanges) { |
636 Id id = TestIdFactory::FromNumber(1); | 628 Id update_id = TestIdFactory::FromNumber(1); |
| 629 Id create_id; |
637 EntryKernel create_pre_save, update_pre_save; | 630 EntryKernel create_pre_save, update_pre_save; |
638 EntryKernel create_post_save, update_post_save; | 631 EntryKernel create_post_save, update_post_save; |
| 632 PathString create_name = PSTR("Create"); |
| 633 |
639 { | 634 { |
640 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); | 635 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); |
641 MutableEntry create(&trans, CREATE, trans.root_id(), PSTR("Create")); | 636 MutableEntry create(&trans, CREATE, trans.root_id(), create_name); |
642 MutableEntry update(&trans, CREATE_NEW_UPDATE_ITEM, id); | 637 MutableEntry update(&trans, CREATE_NEW_UPDATE_ITEM, update_id); |
643 create.Put(IS_UNSYNCED, true); | 638 create.Put(IS_UNSYNCED, true); |
644 update.Put(IS_UNAPPLIED_UPDATE, true); | 639 update.Put(IS_UNAPPLIED_UPDATE, true); |
645 create_pre_save = create.GetKernelCopy(); | 640 create_pre_save = create.GetKernelCopy(); |
646 update_pre_save = update.GetKernelCopy(); | 641 update_pre_save = update.GetKernelCopy(); |
| 642 create_id = create.Get(ID); |
647 } | 643 } |
648 dir_->SaveChanges(); | 644 dir_->SaveChanges(); |
| 645 |
649 { | 646 { |
650 ReadTransaction trans(dir_.get(), __FILE__, __LINE__); | 647 ReadTransaction trans(dir_.get(), __FILE__, __LINE__); |
651 Entry create(&trans, GET_BY_PARENTID_AND_NAME, trans.root_id(), | 648 Entry create(&trans, GET_BY_ID, create_id); |
652 PSTR("Create")); | 649 EXPECT_EQ(1, CountEntriesWithName(&trans, trans.root_id(), create_name)); |
653 Entry update(&trans, GET_BY_ID, id); | 650 Entry update(&trans, GET_BY_ID, update_id); |
654 create_post_save = create.GetKernelCopy(); | 651 create_post_save = create.GetKernelCopy(); |
655 update_post_save = update.GetKernelCopy(); | 652 update_post_save = update.GetKernelCopy(); |
656 } | 653 } |
657 int i = BEGIN_FIELDS; | 654 int i = BEGIN_FIELDS; |
658 for ( ; i < INT64_FIELDS_END ; ++i) { | 655 for ( ; i < INT64_FIELDS_END ; ++i) { |
659 EXPECT_EQ(create_pre_save.ref((Int64Field)i), | 656 EXPECT_EQ(create_pre_save.ref((Int64Field)i), |
660 create_post_save.ref((Int64Field)i)) | 657 create_post_save.ref((Int64Field)i)) |
661 << "int64 field #" << i << " changed during save/load"; | 658 << "int64 field #" << i << " changed during save/load"; |
662 EXPECT_EQ(update_pre_save.ref((Int64Field)i), | 659 EXPECT_EQ(update_pre_save.ref((Int64Field)i), |
663 update_post_save.ref((Int64Field)i)) | 660 update_post_save.ref((Int64Field)i)) |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
706 dir_.reset(new TestUnsaveableDirectory()); | 703 dir_.reset(new TestUnsaveableDirectory()); |
707 ASSERT_TRUE(dir_.get()); | 704 ASSERT_TRUE(dir_.get()); |
708 ASSERT_TRUE(OPENED == dir_->Open(FilePath(kFilePath), kName)); | 705 ASSERT_TRUE(OPENED == dir_->Open(FilePath(kFilePath), kName)); |
709 ASSERT_TRUE(dir_->good()); | 706 ASSERT_TRUE(dir_->good()); |
710 int64 handle2 = 0; | 707 int64 handle2 = 0; |
711 { | 708 { |
712 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); | 709 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); |
713 | 710 |
714 MutableEntry aguilera(&trans, GET_BY_HANDLE, handle1); | 711 MutableEntry aguilera(&trans, GET_BY_HANDLE, handle1); |
715 ASSERT_TRUE(aguilera.good()); | 712 ASSERT_TRUE(aguilera.good()); |
716 aguilera.Put(NAME, PSTR("christina")); | 713 aguilera.Put(NON_UNIQUE_NAME, PSTR("christina")); |
717 ASSERT_TRUE(aguilera.GetKernelCopy().dirty[NAME]); | 714 ASSERT_TRUE(aguilera.GetKernelCopy().dirty[NON_UNIQUE_NAME]); |
718 | 715 |
719 MutableEntry kids_on_block(&trans, CREATE, trans.root_id(), PSTR("kids")); | 716 MutableEntry kids_on_block(&trans, CREATE, trans.root_id(), PSTR("kids")); |
720 ASSERT_TRUE(kids_on_block.good()); | 717 ASSERT_TRUE(kids_on_block.good()); |
721 handle2 = kids_on_block.Get(META_HANDLE); | 718 handle2 = kids_on_block.Get(META_HANDLE); |
722 kids_on_block.Put(BASE_VERSION, 1); | 719 kids_on_block.Put(BASE_VERSION, 1); |
723 kids_on_block.Put(IS_DIR, true); | 720 kids_on_block.Put(IS_DIR, true); |
724 kids_on_block.Put(ID, TestIdFactory::FromNumber(102)); | 721 kids_on_block.Put(ID, TestIdFactory::FromNumber(102)); |
725 EXPECT_TRUE(kids_on_block.Get(IS_NEW)); | 722 EXPECT_TRUE(kids_on_block.Get(IS_NEW)); |
726 } | 723 } |
727 | 724 |
728 // We are using an unsaveable directory, so this can't succeed. However, | 725 // We are using an unsaveable directory, so this can't succeed. However, |
729 // the HandleSaveChangesFailure code path should have been triggered. | 726 // the HandleSaveChangesFailure code path should have been triggered. |
730 ASSERT_FALSE(dir_->SaveChanges()); | 727 ASSERT_FALSE(dir_->SaveChanges()); |
731 | 728 |
732 // Make sure things were rolled back and the world is as it was before call. | 729 // Make sure things were rolled back and the world is as it was before call. |
733 { | 730 { |
734 ReadTransaction trans(dir_.get(), __FILE__, __LINE__); | 731 ReadTransaction trans(dir_.get(), __FILE__, __LINE__); |
735 Entry e1(&trans, GET_BY_HANDLE, handle1); | 732 Entry e1(&trans, GET_BY_HANDLE, handle1); |
736 ASSERT_TRUE(e1.good()); | 733 ASSERT_TRUE(e1.good()); |
737 const EntryKernel& aguilera = e1.GetKernelCopy(); | 734 const EntryKernel& aguilera = e1.GetKernelCopy(); |
738 Entry kids_on_block(&trans, GET_BY_HANDLE, handle2); | 735 Entry kids_on_block(&trans, GET_BY_HANDLE, handle2); |
739 ASSERT_TRUE(kids_on_block.good()); | 736 ASSERT_TRUE(kids_on_block.good()); |
740 | 737 |
741 EXPECT_TRUE(aguilera.dirty[NAME]); | 738 EXPECT_TRUE(aguilera.dirty[NON_UNIQUE_NAME]); |
742 EXPECT_TRUE(kids_on_block.Get(IS_NEW)); | 739 EXPECT_TRUE(kids_on_block.Get(IS_NEW)); |
743 } | 740 } |
744 } | 741 } |
745 | 742 |
746 | 743 |
747 void SyncableDirectoryTest::ValidateEntry(BaseTransaction* trans, int64 id, | 744 void SyncableDirectoryTest::ValidateEntry(BaseTransaction* trans, int64 id, |
748 bool check_name, PathString name, int64 base_version, int64 server_version, | 745 bool check_name, PathString name, int64 base_version, int64 server_version, |
749 bool is_del) { | 746 bool is_del) { |
750 Entry e(trans, GET_BY_ID, TestIdFactory::FromNumber(id)); | 747 Entry e(trans, GET_BY_ID, TestIdFactory::FromNumber(id)); |
751 ASSERT_TRUE(e.good()); | 748 ASSERT_TRUE(e.good()); |
752 if (check_name) | 749 if (check_name) { |
753 ASSERT_TRUE(name == e.Get(NAME)); | 750 ASSERT_TRUE(name == e.Get(NON_UNIQUE_NAME)); |
| 751 } |
754 ASSERT_TRUE(base_version == e.Get(BASE_VERSION)); | 752 ASSERT_TRUE(base_version == e.Get(BASE_VERSION)); |
755 ASSERT_TRUE(server_version == e.Get(SERVER_VERSION)); | 753 ASSERT_TRUE(server_version == e.Get(SERVER_VERSION)); |
756 ASSERT_TRUE(is_del == e.Get(IS_DEL)); | 754 ASSERT_TRUE(is_del == e.Get(IS_DEL)); |
757 } | 755 } |
758 | 756 |
759 TEST(SyncableDirectoryManager, TestFileRelease) { | 757 TEST(SyncableDirectoryManager, TestFileRelease) { |
760 DirectoryManager dm(FilePath(FILE_PATH_LITERAL("."))); | 758 DirectoryManager dm(FilePath(FILE_PATH_LITERAL("."))); |
761 ASSERT_TRUE(dm.Open(PSTR("ScopeTest"))); | 759 ASSERT_TRUE(dm.Open(PSTR("ScopeTest"))); |
762 { | 760 { |
763 ScopedDirLookup(&dm, PSTR("ScopeTest")); | 761 ScopedDirLookup(&dm, PSTR("ScopeTest")); |
(...skipping 120 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
884 class DirectoryKernelStalenessBugDelegate : public ThreadBugDelegate { | 882 class DirectoryKernelStalenessBugDelegate : public ThreadBugDelegate { |
885 public: | 883 public: |
886 DirectoryKernelStalenessBugDelegate(int role, Step* step, | 884 DirectoryKernelStalenessBugDelegate(int role, Step* step, |
887 DirectoryManager* dirman) | 885 DirectoryManager* dirman) |
888 : ThreadBugDelegate(role, step, dirman) {} | 886 : ThreadBugDelegate(role, step, dirman) {} |
889 | 887 |
890 virtual void ThreadMain() { | 888 virtual void ThreadMain() { |
891 const char test_bytes[] = "test data"; | 889 const char test_bytes[] = "test data"; |
892 const PathString dirname = PSTR("DirectoryKernelStalenessBug"); | 890 const PathString dirname = PSTR("DirectoryKernelStalenessBug"); |
893 AutoLock scoped_lock(step_->mutex); | 891 AutoLock scoped_lock(step_->mutex); |
| 892 const Id jeff_id = TestIdFactory::FromNumber(100); |
894 | 893 |
895 while (step_->number < 4) { | 894 while (step_->number < 4) { |
896 while (step_->number % 2 != role_) { | 895 while (step_->number % 2 != role_) { |
897 step_->condvar.Wait(); | 896 step_->condvar.Wait(); |
898 } | 897 } |
899 switch (step_->number) { | 898 switch (step_->number) { |
900 case 0: | 899 case 0: |
901 { | 900 { |
902 // Clean up remnants of earlier test runs. | 901 // Clean up remnants of earlier test runs. |
903 file_util::Delete(directory_manager_->GetSyncDataDatabasePath(), | 902 file_util::Delete(directory_manager_->GetSyncDataDatabasePath(), |
904 true); | 903 true); |
905 // Test. | 904 // Test. |
906 directory_manager_->Open(dirname); | 905 directory_manager_->Open(dirname); |
907 ScopedDirLookup dir(directory_manager_, dirname); | 906 ScopedDirLookup dir(directory_manager_, dirname); |
908 CHECK(dir.good()); | 907 CHECK(dir.good()); |
909 WriteTransaction trans(dir, UNITTEST, __FILE__, __LINE__); | 908 WriteTransaction trans(dir, UNITTEST, __FILE__, __LINE__); |
910 MutableEntry me(&trans, CREATE, trans.root_id(), PSTR("Jeff")); | 909 MutableEntry me(&trans, CREATE, trans.root_id(), PSTR("Jeff")); |
911 me.Put(BASE_VERSION, 1); | 910 me.Put(BASE_VERSION, 1); |
912 me.Put(ID, TestIdFactory::FromNumber(100)); | 911 me.Put(ID, jeff_id); |
913 PutDataAsExtendedAttribute(&trans, &me, test_bytes, | 912 PutDataAsExtendedAttribute(&trans, &me, test_bytes, |
914 sizeof(test_bytes)); | 913 sizeof(test_bytes)); |
915 } | 914 } |
916 { | 915 { |
917 ScopedDirLookup dir(directory_manager_, dirname); | 916 ScopedDirLookup dir(directory_manager_, dirname); |
918 CHECK(dir.good()); | 917 CHECK(dir.good()); |
919 dir->SaveChanges(); | 918 dir->SaveChanges(); |
920 } | 919 } |
921 directory_manager_->Close(dirname); | 920 directory_manager_->Close(dirname); |
922 break; | 921 break; |
923 case 1: | 922 case 1: |
924 { | 923 { |
925 directory_manager_->Open(dirname); | 924 directory_manager_->Open(dirname); |
926 ScopedDirLookup dir(directory_manager_, dirname); | 925 ScopedDirLookup dir(directory_manager_, dirname); |
927 CHECK(dir.good()); | 926 CHECK(dir.good()); |
928 } | 927 } |
929 break; | 928 break; |
930 case 2: | 929 case 2: |
931 { | 930 { |
932 ScopedDirLookup dir(directory_manager_, dirname); | 931 ScopedDirLookup dir(directory_manager_, dirname); |
933 CHECK(dir.good()); | 932 CHECK(dir.good()); |
934 } | 933 } |
935 break; | 934 break; |
936 case 3: | 935 case 3: |
937 { | 936 { |
938 ScopedDirLookup dir(directory_manager_, dirname); | 937 ScopedDirLookup dir(directory_manager_, dirname); |
939 CHECK(dir.good()); | 938 CHECK(dir.good()); |
940 ReadTransaction trans(dir, __FILE__, __LINE__); | 939 ReadTransaction trans(dir, __FILE__, __LINE__); |
941 Entry e(&trans, GET_BY_PATH, PSTR("Jeff")); | 940 Entry e(&trans, GET_BY_ID, jeff_id); |
942 ExpectDataFromExtendedAttributeEquals(&trans, &e, test_bytes, | 941 ExpectDataFromExtendedAttributeEquals(&trans, &e, test_bytes, |
943 sizeof(test_bytes)); | 942 sizeof(test_bytes)); |
944 } | 943 } |
945 // Same result as CloseAllDirectories, but more code coverage. | 944 // Same result as CloseAllDirectories, but more code coverage. |
946 directory_manager_->Close(dirname); | 945 directory_manager_->Close(dirname); |
947 break; | 946 break; |
948 } | 947 } |
949 step_->number += 1; | 948 step_->number += 1; |
950 step_->condvar.Signal(); | 949 step_->condvar.Signal(); |
951 } | 950 } |
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
987 virtual void ThreadMain() { | 986 virtual void ThreadMain() { |
988 ScopedDirLookup dir(directory_manager_, dirname_); | 987 ScopedDirLookup dir(directory_manager_, dirname_); |
989 CHECK(dir.good()); | 988 CHECK(dir.good()); |
990 int entry_count = 0; | 989 int entry_count = 0; |
991 PathString path_name; | 990 PathString path_name; |
992 | 991 |
993 for (int i = 0; i < 20; ++i) { | 992 for (int i = 0; i < 20; ++i) { |
994 const int rand_action = rand() % 10; | 993 const int rand_action = rand() % 10; |
995 if (rand_action < 4 && !path_name.empty()) { | 994 if (rand_action < 4 && !path_name.empty()) { |
996 ReadTransaction trans(dir, __FILE__, __LINE__); | 995 ReadTransaction trans(dir, __FILE__, __LINE__); |
997 Entry e(&trans, GET_BY_PARENTID_AND_NAME, trans.root_id(), path_name); | 996 CHECK(1 == CountEntriesWithName(&trans, trans.root_id(), path_name)); |
998 PlatformThread::Sleep(rand() % 10); | 997 PlatformThread::Sleep(rand() % 10); |
999 CHECK(e.good()); | |
1000 } else { | 998 } else { |
1001 string unique_name = StringPrintf("%d.%d", thread_number_, | 999 string unique_name = StringPrintf("%d.%d", thread_number_, |
1002 entry_count++); | 1000 entry_count++); |
1003 path_name.assign(unique_name.begin(), unique_name.end()); | 1001 path_name.assign(unique_name.begin(), unique_name.end()); |
1004 WriteTransaction trans(dir, UNITTEST, __FILE__, __LINE__); | 1002 WriteTransaction trans(dir, UNITTEST, __FILE__, __LINE__); |
1005 MutableEntry e(&trans, CREATE, trans.root_id(), path_name); | 1003 MutableEntry e(&trans, CREATE, trans.root_id(), path_name); |
1006 CHECK(e.good()); | 1004 CHECK(e.good()); |
1007 PlatformThread::Sleep(rand() % 20); | 1005 PlatformThread::Sleep(rand() % 20); |
1008 e.Put(IS_UNSYNCED, true); | 1006 e.Put(IS_UNSYNCED, true); |
1009 if (e.Put(ID, TestIdFactory::FromNumber(rand())) && | 1007 if (e.Put(ID, TestIdFactory::FromNumber(rand())) && |
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1064 PathString b(1, tests[i].b); | 1062 PathString b(1, tests[i].b); |
1065 const int result = ComparePathNames(a, b); | 1063 const int result = ComparePathNames(a, b); |
1066 if (result != tests[i].expected_result) { | 1064 if (result != tests[i].expected_result) { |
1067 ADD_FAILURE() << "ComparePathNames(" << tests[i].a << ", " << tests[i].b | 1065 ADD_FAILURE() << "ComparePathNames(" << tests[i].a << ", " << tests[i].b |
1068 << ") returned " << result << "; expected " | 1066 << ") returned " << result << "; expected " |
1069 << tests[i].expected_result; | 1067 << tests[i].expected_result; |
1070 } | 1068 } |
1071 } | 1069 } |
1072 } | 1070 } |
1073 | 1071 |
1074 #if defined(OS_WIN) | |
1075 TEST(Syncable, PathNameMatch) { | |
1076 // basic stuff, not too many otherwise we're testing the os. | |
1077 EXPECT_TRUE(PathNameMatch(PSTR("bob"), PSTR("bob"))); | |
1078 EXPECT_FALSE(PathNameMatch(PSTR("bob"), PSTR("fred"))); | |
1079 // Test our ; extension. | |
1080 EXPECT_TRUE(PathNameMatch(PSTR("bo;b"), PSTR("bo;b"))); | |
1081 EXPECT_TRUE(PathNameMatch(PSTR("bo;b"), PSTR("bo*"))); | |
1082 EXPECT_FALSE(PathNameMatch(PSTR("bo;b"), PSTR("co;b"))); | |
1083 EXPECT_FALSE(PathNameMatch(PSTR("bo;b"), PSTR("co*"))); | |
1084 // Test our fixes for prepended spaces. | |
1085 EXPECT_TRUE(PathNameMatch(PSTR(" bob"), PSTR(" bo*"))); | |
1086 EXPECT_TRUE(PathNameMatch(PSTR(" bob"), PSTR(" bob"))); | |
1087 EXPECT_FALSE(PathNameMatch(PSTR("bob"), PSTR(" bob"))); | |
1088 EXPECT_FALSE(PathNameMatch(PSTR(" bob"), PSTR("bob"))); | |
1089 // Combo test. | |
1090 EXPECT_TRUE(PathNameMatch(PSTR(" b;ob"), PSTR(" b;o*"))); | |
1091 EXPECT_TRUE(PathNameMatch(PSTR(" b;ob"), PSTR(" b;ob"))); | |
1092 EXPECT_FALSE(PathNameMatch(PSTR("b;ob"), PSTR(" b;ob"))); | |
1093 EXPECT_FALSE(PathNameMatch(PSTR(" b;ob"), PSTR("b;ob"))); | |
1094 // other whitespace should give no matches. | |
1095 EXPECT_FALSE(PathNameMatch(PSTR("bob"), PSTR("\tbob"))); | |
1096 } | |
1097 #endif // defined(OS_WIN) | |
1098 | |
1099 void FakeSync(MutableEntry* e, const char* fake_id) { | 1072 void FakeSync(MutableEntry* e, const char* fake_id) { |
1100 e->Put(IS_UNSYNCED, false); | 1073 e->Put(IS_UNSYNCED, false); |
1101 e->Put(BASE_VERSION, 2); | 1074 e->Put(BASE_VERSION, 2); |
1102 e->Put(ID, Id::CreateFromServerId(fake_id)); | 1075 e->Put(ID, Id::CreateFromServerId(fake_id)); |
1103 } | 1076 } |
1104 | 1077 |
1105 TEST_F(SyncableDirectoryTest, Bug1509232) { | 1078 TEST_F(SyncableDirectoryTest, Bug1509232) { |
1106 const PathString a = PSTR("alpha"); | 1079 const PathString a = PSTR("alpha"); |
1107 | 1080 const Id entry_id = dir_.get()->NextId(); |
1108 CreateEntry(a, dir_.get()->NextId()); | 1081 CreateEntry(a, entry_id); |
1109 { | 1082 { |
1110 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); | 1083 WriteTransaction trans(dir_.get(), UNITTEST, __FILE__, __LINE__); |
1111 MutableEntry e(&trans, GET_BY_PATH, a); | 1084 MutableEntry e(&trans, GET_BY_ID, entry_id); |
1112 ASSERT_TRUE(e.good()); | 1085 ASSERT_TRUE(e.good()); |
1113 ExtendedAttributeKey key(e.Get(META_HANDLE), PSTR("resourcefork")); | 1086 ExtendedAttributeKey key(e.Get(META_HANDLE), PSTR("resourcefork")); |
1114 MutableExtendedAttribute ext(&trans, CREATE, key); | 1087 MutableExtendedAttribute ext(&trans, CREATE, key); |
1115 ASSERT_TRUE(ext.good()); | 1088 ASSERT_TRUE(ext.good()); |
1116 const char value[] = "stuff"; | 1089 const char value[] = "stuff"; |
1117 Blob value_blob(value, value + arraysize(value)); | 1090 Blob value_blob(value, value + arraysize(value)); |
1118 ext.mutable_value()->swap(value_blob); | 1091 ext.mutable_value()->swap(value_blob); |
1119 ext.delete_attribute(); | 1092 ext.delete_attribute(); |
1120 } | 1093 } |
1121 // This call to SaveChanges used to CHECK fail. | 1094 // This call to SaveChanges used to CHECK fail. |
1122 dir_.get()->SaveChanges(); | 1095 dir_.get()->SaveChanges(); |
1123 } | 1096 } |
1124 | 1097 |
1125 } // namespace | 1098 } // namespace |
1126 } // namespace syncable | 1099 } // namespace syncable |
OLD | NEW |