1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chrome/browser/sync/abstract_profile_sync_service_test.h"
#include "base/tracked.h"
#include "chrome/browser/sync/internal_api/write_transaction.h"
#include "chrome/browser/sync/protocol/sync.pb.h"
#include "chrome/browser/sync/syncable/directory_manager.h"
#include "chrome/browser/sync/syncable/syncable.h"
#include "chrome/browser/sync/test_profile_sync_service.h"
#include "chrome/browser/sync/test/engine/test_id_factory.h"
#include "chrome/browser/sync/util/cryptographer.h"
using browser_sync::TestIdFactory;
using sync_api::UserShare;
using syncable::BASE_VERSION;
using syncable::CREATE;
using syncable::DirectoryManager;
using syncable::IS_DEL;
using syncable::IS_DIR;
using syncable::IS_UNAPPLIED_UPDATE;
using syncable::IS_UNSYNCED;
using syncable::ModelType;
using syncable::MutableEntry;
using syncable::SERVER_IS_DIR;
using syncable::SERVER_VERSION;
using syncable::SPECIFICS;
using syncable::ScopedDirLookup;
using syncable::UNIQUE_SERVER_TAG;
using syncable::UNITTEST;
using syncable::WriteTransaction;
const std::string ProfileSyncServiceTestHelper::GetTagForType(
ModelType model_type) {
return syncable::ModelTypeToRootTag(model_type);
}
bool ProfileSyncServiceTestHelper::CreateRoot(
ModelType model_type, UserShare* user_share,
TestIdFactory* ids) {
DirectoryManager* dir_manager = user_share->dir_manager.get();
ScopedDirLookup dir(dir_manager, user_share->name);
if (!dir.good())
return false;
std::string tag_name = GetTagForType(model_type);
WriteTransaction wtrans(FROM_HERE, UNITTEST, dir);
MutableEntry node(&wtrans,
CREATE,
wtrans.root_id(),
tag_name);
node.Put(UNIQUE_SERVER_TAG, tag_name);
node.Put(IS_DIR, true);
node.Put(SERVER_IS_DIR, false);
node.Put(IS_UNSYNCED, false);
node.Put(IS_UNAPPLIED_UPDATE, false);
node.Put(SERVER_VERSION, 20);
node.Put(BASE_VERSION, 20);
node.Put(IS_DEL, false);
node.Put(syncable::ID, ids->MakeServer(tag_name));
sync_pb::EntitySpecifics specifics;
syncable::AddDefaultExtensionValue(model_type, &specifics);
node.Put(SPECIFICS, specifics);
return true;
}
AbstractProfileSyncServiceTest::AbstractProfileSyncServiceTest()
: ui_thread_(BrowserThread::UI, &ui_loop_),
db_thread_(BrowserThread::DB),
io_thread_(BrowserThread::IO),
token_service_(new TokenService) {}
AbstractProfileSyncServiceTest::~AbstractProfileSyncServiceTest() {}
void AbstractProfileSyncServiceTest::SetUp() {
db_thread_.Start();
base::Thread::Options options;
options.message_loop_type = MessageLoop::TYPE_IO;
io_thread_.StartWithOptions(options);
}
void AbstractProfileSyncServiceTest::TearDown() {
// Pump messages posted by the sync core thread (which may end up
// posting on the IO thread).
ui_loop_.RunAllPending();
// We need to destroy the |token_service_| here before we stop the
// |io_thread_| because it holds references to a ref-counted
// URLRequestContext. The deletion is passed to the |io_thread_|
// by scoped_refptr. If |token_service_| is destroyed after stopping
// the |io_thread_|, the deletion never happens.
token_service_.reset(NULL);
io_thread_.Stop();
db_thread_.Stop();
ui_loop_.RunAllPending();
}
bool AbstractProfileSyncServiceTest::CreateRoot(ModelType model_type) {
return ProfileSyncServiceTestHelper::CreateRoot(
model_type,
service_->GetUserShare(),
service_->id_factory());
}
CreateRootTask::CreateRootTask(
AbstractProfileSyncServiceTest* test, ModelType model_type)
: test_(test), model_type_(model_type), success_(false) {
}
CreateRootTask::~CreateRootTask() {}
void CreateRootTask::Run() {
success_ = test_->CreateRoot(model_type_);
}
bool CreateRootTask::success() {
return success_;
}
|
