| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "components/sync/core/processor_entity_tracker.h" | 5 #include "components/sync/core/processor_entity_tracker.h" |
| 6 | 6 |
| 7 #include <stdint.h> | 7 #include <stdint.h> |
| 8 | 8 |
| 9 #include <memory> | 9 #include <memory> |
| 10 #include <utility> | 10 #include <utility> |
| 11 | 11 |
| 12 #include "base/memory/ptr_util.h" | 12 #include "base/memory/ptr_util.h" |
| 13 #include "base/time/time.h" | 13 #include "base/time/time.h" |
| 14 #include "components/sync/base/model_type.h" | 14 #include "components/sync/base/model_type.h" |
| 15 #include "components/sync/base/time.h" | 15 #include "components/sync/base/time.h" |
| 16 #include "components/sync/core/non_blocking_sync_common.h" | 16 #include "components/sync/core/non_blocking_sync_common.h" |
| 17 #include "components/sync/protocol/sync.pb.h" | 17 #include "components/sync/protocol/sync.pb.h" |
| 18 #include "components/sync/syncable/syncable_util.h" | 18 #include "components/sync/syncable/syncable_util.h" |
| 19 #include "testing/gtest/include/gtest/gtest.h" | 19 #include "testing/gtest/include/gtest/gtest.h" |
| 20 | 20 |
| 21 namespace syncer_v2 { | 21 namespace syncer { |
| 22 | 22 |
| 23 namespace { | 23 namespace { |
| 24 | 24 |
| 25 const char kKey[] = "key"; | 25 const char kKey[] = "key"; |
| 26 const char kHash[] = "hash"; | 26 const char kHash[] = "hash"; |
| 27 const char kId[] = "id"; | 27 const char kId[] = "id"; |
| 28 const char kName[] = "name"; | 28 const char kName[] = "name"; |
| 29 const char kValue1[] = "value1"; | 29 const char kValue1[] = "value1"; |
| 30 const char kValue2[] = "value2"; | 30 const char kValue2[] = "value2"; |
| 31 const char kValue3[] = "value3"; | 31 const char kValue3[] = "value3"; |
| (...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 128 TEST_F(ProcessorEntityTrackerTest, DefaultTracker) { | 128 TEST_F(ProcessorEntityTrackerTest, DefaultTracker) { |
| 129 std::unique_ptr<ProcessorEntityTracker> entity = CreateNew(); | 129 std::unique_ptr<ProcessorEntityTracker> entity = CreateNew(); |
| 130 | 130 |
| 131 EXPECT_EQ(kKey, entity->storage_key()); | 131 EXPECT_EQ(kKey, entity->storage_key()); |
| 132 EXPECT_EQ(kHash, entity->metadata().client_tag_hash()); | 132 EXPECT_EQ(kHash, entity->metadata().client_tag_hash()); |
| 133 EXPECT_EQ("", entity->metadata().server_id()); | 133 EXPECT_EQ("", entity->metadata().server_id()); |
| 134 EXPECT_FALSE(entity->metadata().is_deleted()); | 134 EXPECT_FALSE(entity->metadata().is_deleted()); |
| 135 EXPECT_EQ(0, entity->metadata().sequence_number()); | 135 EXPECT_EQ(0, entity->metadata().sequence_number()); |
| 136 EXPECT_EQ(0, entity->metadata().acked_sequence_number()); | 136 EXPECT_EQ(0, entity->metadata().acked_sequence_number()); |
| 137 EXPECT_EQ(kUncommittedVersion, entity->metadata().server_version()); | 137 EXPECT_EQ(kUncommittedVersion, entity->metadata().server_version()); |
| 138 EXPECT_EQ(syncer::TimeToProtoTime(ctime_), | 138 EXPECT_EQ(TimeToProtoTime(ctime_), entity->metadata().creation_time()); |
| 139 entity->metadata().creation_time()); | |
| 140 EXPECT_EQ(0, entity->metadata().modification_time()); | 139 EXPECT_EQ(0, entity->metadata().modification_time()); |
| 141 EXPECT_TRUE(entity->metadata().specifics_hash().empty()); | 140 EXPECT_TRUE(entity->metadata().specifics_hash().empty()); |
| 142 EXPECT_TRUE(entity->metadata().base_specifics_hash().empty()); | 141 EXPECT_TRUE(entity->metadata().base_specifics_hash().empty()); |
| 143 | 142 |
| 144 EXPECT_FALSE(entity->IsUnsynced()); | 143 EXPECT_FALSE(entity->IsUnsynced()); |
| 145 EXPECT_FALSE(entity->RequiresCommitRequest()); | 144 EXPECT_FALSE(entity->RequiresCommitRequest()); |
| 146 EXPECT_FALSE(entity->RequiresCommitData()); | 145 EXPECT_FALSE(entity->RequiresCommitData()); |
| 147 EXPECT_FALSE(entity->CanClearMetadata()); | 146 EXPECT_FALSE(entity->CanClearMetadata()); |
| 148 EXPECT_FALSE(entity->UpdateIsReflection(1)); | 147 EXPECT_FALSE(entity->UpdateIsReflection(1)); |
| 149 EXPECT_FALSE(entity->HasCommitData()); | 148 EXPECT_FALSE(entity->HasCommitData()); |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 184 EXPECT_FALSE(entity->RequiresCommitData()); | 183 EXPECT_FALSE(entity->RequiresCommitData()); |
| 185 EXPECT_FALSE(entity->CanClearMetadata()); | 184 EXPECT_FALSE(entity->CanClearMetadata()); |
| 186 EXPECT_FALSE(entity->UpdateIsReflection(1)); | 185 EXPECT_FALSE(entity->UpdateIsReflection(1)); |
| 187 EXPECT_TRUE(entity->HasCommitData()); | 186 EXPECT_TRUE(entity->HasCommitData()); |
| 188 | 187 |
| 189 const EntityData& data = request.entity.value(); | 188 const EntityData& data = request.entity.value(); |
| 190 EXPECT_EQ("", data.id); | 189 EXPECT_EQ("", data.id); |
| 191 EXPECT_EQ(kHash, data.client_tag_hash); | 190 EXPECT_EQ(kHash, data.client_tag_hash); |
| 192 EXPECT_EQ(kName, data.non_unique_name); | 191 EXPECT_EQ(kName, data.non_unique_name); |
| 193 EXPECT_EQ(kValue1, data.specifics.preference().value()); | 192 EXPECT_EQ(kValue1, data.specifics.preference().value()); |
| 194 EXPECT_EQ(syncer::TimeToProtoTime(ctime_), | 193 EXPECT_EQ(TimeToProtoTime(ctime_), TimeToProtoTime(data.creation_time)); |
| 195 syncer::TimeToProtoTime(data.creation_time)); | |
| 196 EXPECT_EQ(entity->metadata().modification_time(), | 194 EXPECT_EQ(entity->metadata().modification_time(), |
| 197 syncer::TimeToProtoTime(data.modification_time)); | 195 TimeToProtoTime(data.modification_time)); |
| 198 EXPECT_FALSE(data.is_deleted()); | 196 EXPECT_FALSE(data.is_deleted()); |
| 199 EXPECT_EQ(1, request.sequence_number); | 197 EXPECT_EQ(1, request.sequence_number); |
| 200 EXPECT_EQ(kUncommittedVersion, request.base_version); | 198 EXPECT_EQ(kUncommittedVersion, request.base_version); |
| 201 EXPECT_EQ(entity->metadata().specifics_hash(), request.specifics_hash); | 199 EXPECT_EQ(entity->metadata().specifics_hash(), request.specifics_hash); |
| 202 | 200 |
| 203 // Ack the commit. | 201 // Ack the commit. |
| 204 entity->ReceiveCommitResponse(GenerateAckData(request, kId, 1)); | 202 entity->ReceiveCommitResponse(GenerateAckData(request, kId, 1)); |
| 205 | 203 |
| 206 EXPECT_EQ(kId, entity->metadata().server_id()); | 204 EXPECT_EQ(kId, entity->metadata().server_id()); |
| 207 EXPECT_FALSE(entity->metadata().is_deleted()); | 205 EXPECT_FALSE(entity->metadata().is_deleted()); |
| (...skipping 20 matching lines...) Expand all Loading... |
| 228 | 226 |
| 229 const base::Time mtime = base::Time::Now(); | 227 const base::Time mtime = base::Time::Now(); |
| 230 entity->RecordAcceptedUpdate( | 228 entity->RecordAcceptedUpdate( |
| 231 GenerateUpdate(*entity, kHash, kId, kName, kValue1, mtime, 10)); | 229 GenerateUpdate(*entity, kHash, kId, kName, kValue1, mtime, 10)); |
| 232 | 230 |
| 233 EXPECT_EQ(kId, entity->metadata().server_id()); | 231 EXPECT_EQ(kId, entity->metadata().server_id()); |
| 234 EXPECT_FALSE(entity->metadata().is_deleted()); | 232 EXPECT_FALSE(entity->metadata().is_deleted()); |
| 235 EXPECT_EQ(0, entity->metadata().sequence_number()); | 233 EXPECT_EQ(0, entity->metadata().sequence_number()); |
| 236 EXPECT_EQ(0, entity->metadata().acked_sequence_number()); | 234 EXPECT_EQ(0, entity->metadata().acked_sequence_number()); |
| 237 EXPECT_EQ(10, entity->metadata().server_version()); | 235 EXPECT_EQ(10, entity->metadata().server_version()); |
| 238 EXPECT_EQ(syncer::TimeToProtoTime(mtime), | 236 EXPECT_EQ(TimeToProtoTime(mtime), entity->metadata().modification_time()); |
| 239 entity->metadata().modification_time()); | |
| 240 EXPECT_FALSE(entity->metadata().specifics_hash().empty()); | 237 EXPECT_FALSE(entity->metadata().specifics_hash().empty()); |
| 241 EXPECT_TRUE(entity->metadata().base_specifics_hash().empty()); | 238 EXPECT_TRUE(entity->metadata().base_specifics_hash().empty()); |
| 242 | 239 |
| 243 EXPECT_FALSE(entity->IsUnsynced()); | 240 EXPECT_FALSE(entity->IsUnsynced()); |
| 244 EXPECT_FALSE(entity->RequiresCommitRequest()); | 241 EXPECT_FALSE(entity->RequiresCommitRequest()); |
| 245 EXPECT_FALSE(entity->RequiresCommitData()); | 242 EXPECT_FALSE(entity->RequiresCommitData()); |
| 246 EXPECT_FALSE(entity->CanClearMetadata()); | 243 EXPECT_FALSE(entity->CanClearMetadata()); |
| 247 EXPECT_TRUE(entity->UpdateIsReflection(9)); | 244 EXPECT_TRUE(entity->UpdateIsReflection(9)); |
| 248 EXPECT_TRUE(entity->UpdateIsReflection(10)); | 245 EXPECT_TRUE(entity->UpdateIsReflection(10)); |
| 249 EXPECT_FALSE(entity->UpdateIsReflection(11)); | 246 EXPECT_FALSE(entity->UpdateIsReflection(11)); |
| 250 EXPECT_FALSE(entity->HasCommitData()); | 247 EXPECT_FALSE(entity->HasCommitData()); |
| 251 } | 248 } |
| 252 | 249 |
| 253 // Test state for a tombstone received for a previously unknown item. | 250 // Test state for a tombstone received for a previously unknown item. |
| 254 TEST_F(ProcessorEntityTrackerTest, NewServerTombstone) { | 251 TEST_F(ProcessorEntityTrackerTest, NewServerTombstone) { |
| 255 std::unique_ptr<ProcessorEntityTracker> entity = CreateNew(); | 252 std::unique_ptr<ProcessorEntityTracker> entity = CreateNew(); |
| 256 | 253 |
| 257 const base::Time mtime = base::Time::Now(); | 254 const base::Time mtime = base::Time::Now(); |
| 258 entity->RecordAcceptedUpdate( | 255 entity->RecordAcceptedUpdate( |
| 259 GenerateTombstone(*entity, kHash, kId, kName, mtime, 1)); | 256 GenerateTombstone(*entity, kHash, kId, kName, mtime, 1)); |
| 260 | 257 |
| 261 EXPECT_EQ(kId, entity->metadata().server_id()); | 258 EXPECT_EQ(kId, entity->metadata().server_id()); |
| 262 EXPECT_TRUE(entity->metadata().is_deleted()); | 259 EXPECT_TRUE(entity->metadata().is_deleted()); |
| 263 EXPECT_EQ(0, entity->metadata().sequence_number()); | 260 EXPECT_EQ(0, entity->metadata().sequence_number()); |
| 264 EXPECT_EQ(0, entity->metadata().acked_sequence_number()); | 261 EXPECT_EQ(0, entity->metadata().acked_sequence_number()); |
| 265 EXPECT_EQ(1, entity->metadata().server_version()); | 262 EXPECT_EQ(1, entity->metadata().server_version()); |
| 266 EXPECT_EQ(syncer::TimeToProtoTime(mtime), | 263 EXPECT_EQ(TimeToProtoTime(mtime), entity->metadata().modification_time()); |
| 267 entity->metadata().modification_time()); | |
| 268 EXPECT_TRUE(entity->metadata().specifics_hash().empty()); | 264 EXPECT_TRUE(entity->metadata().specifics_hash().empty()); |
| 269 EXPECT_TRUE(entity->metadata().base_specifics_hash().empty()); | 265 EXPECT_TRUE(entity->metadata().base_specifics_hash().empty()); |
| 270 | 266 |
| 271 EXPECT_FALSE(entity->IsUnsynced()); | 267 EXPECT_FALSE(entity->IsUnsynced()); |
| 272 EXPECT_FALSE(entity->RequiresCommitRequest()); | 268 EXPECT_FALSE(entity->RequiresCommitRequest()); |
| 273 EXPECT_FALSE(entity->RequiresCommitData()); | 269 EXPECT_FALSE(entity->RequiresCommitData()); |
| 274 EXPECT_TRUE(entity->CanClearMetadata()); | 270 EXPECT_TRUE(entity->CanClearMetadata()); |
| 275 EXPECT_TRUE(entity->UpdateIsReflection(1)); | 271 EXPECT_TRUE(entity->UpdateIsReflection(1)); |
| 276 EXPECT_FALSE(entity->UpdateIsReflection(2)); | 272 EXPECT_FALSE(entity->UpdateIsReflection(2)); |
| 277 EXPECT_FALSE(entity->HasCommitData()); | 273 EXPECT_FALSE(entity->HasCommitData()); |
| 278 } | 274 } |
| 279 | 275 |
| 280 // Apply a deletion update to a synced item. | 276 // Apply a deletion update to a synced item. |
| 281 TEST_F(ProcessorEntityTrackerTest, ServerTombstone) { | 277 TEST_F(ProcessorEntityTrackerTest, ServerTombstone) { |
| 282 // Start with a non-deleted state with version 1. | 278 // Start with a non-deleted state with version 1. |
| 283 std::unique_ptr<ProcessorEntityTracker> entity = CreateSynced(); | 279 std::unique_ptr<ProcessorEntityTracker> entity = CreateSynced(); |
| 284 // A deletion update one version later. | 280 // A deletion update one version later. |
| 285 const base::Time mtime = base::Time::Now(); | 281 const base::Time mtime = base::Time::Now(); |
| 286 entity->RecordAcceptedUpdate( | 282 entity->RecordAcceptedUpdate( |
| 287 GenerateTombstone(*entity, kHash, kId, kName, mtime, 2)); | 283 GenerateTombstone(*entity, kHash, kId, kName, mtime, 2)); |
| 288 | 284 |
| 289 EXPECT_TRUE(entity->metadata().is_deleted()); | 285 EXPECT_TRUE(entity->metadata().is_deleted()); |
| 290 EXPECT_EQ(0, entity->metadata().sequence_number()); | 286 EXPECT_EQ(0, entity->metadata().sequence_number()); |
| 291 EXPECT_EQ(0, entity->metadata().acked_sequence_number()); | 287 EXPECT_EQ(0, entity->metadata().acked_sequence_number()); |
| 292 EXPECT_EQ(2, entity->metadata().server_version()); | 288 EXPECT_EQ(2, entity->metadata().server_version()); |
| 293 EXPECT_EQ(syncer::TimeToProtoTime(mtime), | 289 EXPECT_EQ(TimeToProtoTime(mtime), entity->metadata().modification_time()); |
| 294 entity->metadata().modification_time()); | |
| 295 EXPECT_TRUE(entity->metadata().specifics_hash().empty()); | 290 EXPECT_TRUE(entity->metadata().specifics_hash().empty()); |
| 296 EXPECT_TRUE(entity->metadata().base_specifics_hash().empty()); | 291 EXPECT_TRUE(entity->metadata().base_specifics_hash().empty()); |
| 297 | 292 |
| 298 EXPECT_FALSE(entity->IsUnsynced()); | 293 EXPECT_FALSE(entity->IsUnsynced()); |
| 299 EXPECT_FALSE(entity->RequiresCommitRequest()); | 294 EXPECT_FALSE(entity->RequiresCommitRequest()); |
| 300 EXPECT_FALSE(entity->RequiresCommitData()); | 295 EXPECT_FALSE(entity->RequiresCommitData()); |
| 301 EXPECT_TRUE(entity->CanClearMetadata()); | 296 EXPECT_TRUE(entity->CanClearMetadata()); |
| 302 EXPECT_TRUE(entity->UpdateIsReflection(2)); | 297 EXPECT_TRUE(entity->UpdateIsReflection(2)); |
| 303 EXPECT_FALSE(entity->UpdateIsReflection(3)); | 298 EXPECT_FALSE(entity->UpdateIsReflection(3)); |
| 304 EXPECT_FALSE(entity->HasCommitData()); | 299 EXPECT_FALSE(entity->HasCommitData()); |
| (...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 387 EXPECT_TRUE(entity->IsUnsynced()); | 382 EXPECT_TRUE(entity->IsUnsynced()); |
| 388 EXPECT_FALSE(entity->RequiresCommitRequest()); | 383 EXPECT_FALSE(entity->RequiresCommitRequest()); |
| 389 EXPECT_FALSE(entity->RequiresCommitData()); | 384 EXPECT_FALSE(entity->RequiresCommitData()); |
| 390 EXPECT_FALSE(entity->CanClearMetadata()); | 385 EXPECT_FALSE(entity->CanClearMetadata()); |
| 391 EXPECT_FALSE(entity->HasCommitData()); | 386 EXPECT_FALSE(entity->HasCommitData()); |
| 392 | 387 |
| 393 const EntityData& data = request.entity.value(); | 388 const EntityData& data = request.entity.value(); |
| 394 EXPECT_EQ(kId, data.id); | 389 EXPECT_EQ(kId, data.id); |
| 395 EXPECT_EQ(kHash, data.client_tag_hash); | 390 EXPECT_EQ(kHash, data.client_tag_hash); |
| 396 EXPECT_EQ("", data.non_unique_name); | 391 EXPECT_EQ("", data.non_unique_name); |
| 397 EXPECT_EQ(syncer::TimeToProtoTime(ctime_), | 392 EXPECT_EQ(TimeToProtoTime(ctime_), TimeToProtoTime(data.creation_time)); |
| 398 syncer::TimeToProtoTime(data.creation_time)); | |
| 399 EXPECT_EQ(entity->metadata().modification_time(), | 393 EXPECT_EQ(entity->metadata().modification_time(), |
| 400 syncer::TimeToProtoTime(data.modification_time)); | 394 TimeToProtoTime(data.modification_time)); |
| 401 EXPECT_TRUE(data.is_deleted()); | 395 EXPECT_TRUE(data.is_deleted()); |
| 402 EXPECT_EQ(1, request.sequence_number); | 396 EXPECT_EQ(1, request.sequence_number); |
| 403 EXPECT_EQ(1, request.base_version); | 397 EXPECT_EQ(1, request.base_version); |
| 404 EXPECT_EQ(entity->metadata().specifics_hash(), request.specifics_hash); | 398 EXPECT_EQ(entity->metadata().specifics_hash(), request.specifics_hash); |
| 405 | 399 |
| 406 // Ack the deletion. | 400 // Ack the deletion. |
| 407 entity->ReceiveCommitResponse(GenerateAckData(request, kId, 2)); | 401 entity->ReceiveCommitResponse(GenerateAckData(request, kId, 2)); |
| 408 | 402 |
| 409 EXPECT_TRUE(entity->metadata().is_deleted()); | 403 EXPECT_TRUE(entity->metadata().is_deleted()); |
| 410 EXPECT_EQ(1, entity->metadata().sequence_number()); | 404 EXPECT_EQ(1, entity->metadata().sequence_number()); |
| (...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 484 EXPECT_EQ(specifics_hash_v2, entity->metadata().specifics_hash()); | 478 EXPECT_EQ(specifics_hash_v2, entity->metadata().specifics_hash()); |
| 485 EXPECT_EQ("", entity->metadata().base_specifics_hash()); | 479 EXPECT_EQ("", entity->metadata().base_specifics_hash()); |
| 486 | 480 |
| 487 EXPECT_FALSE(entity->IsUnsynced()); | 481 EXPECT_FALSE(entity->IsUnsynced()); |
| 488 EXPECT_FALSE(entity->RequiresCommitRequest()); | 482 EXPECT_FALSE(entity->RequiresCommitRequest()); |
| 489 EXPECT_FALSE(entity->RequiresCommitData()); | 483 EXPECT_FALSE(entity->RequiresCommitData()); |
| 490 EXPECT_FALSE(entity->CanClearMetadata()); | 484 EXPECT_FALSE(entity->CanClearMetadata()); |
| 491 EXPECT_FALSE(entity->HasCommitData()); | 485 EXPECT_FALSE(entity->HasCommitData()); |
| 492 } | 486 } |
| 493 | 487 |
| 494 } // namespace syncer_v2 | 488 } // namespace syncer |
| OLD | NEW |