This source file includes following definitions.
- CountEntriesWithName
- GetFirstEntryWithName
- GetOnlyEntryWithName
- CreateTypeRoot
#include "sync/test/engine/test_syncable_utils.h"
#include "sync/syncable/directory.h"
#include "sync/syncable/entry.h"
#include "sync/syncable/mutable_entry.h"
#include "sync/syncable/syncable_base_transaction.h"
#include "sync/syncable/syncable_write_transaction.h"
#include "sync/test/engine/test_id_factory.h"
using std::string;
namespace syncer {
namespace syncable {
int CountEntriesWithName(BaseTransaction* rtrans,
const syncable::Id& parent_id,
const string& name) {
Directory::Metahandles child_handles;
rtrans->directory()->GetChildHandlesById(rtrans, parent_id, &child_handles);
if (child_handles.size() <= 0) {
return 0;
}
int number_of_entries_with_name = 0;
for (Directory::Metahandles::iterator i = child_handles.begin();
i != child_handles.end(); ++i) {
Entry e(rtrans, GET_BY_HANDLE, *i);
CHECK(e.good());
if (e.GetNonUniqueName()== name) {
++number_of_entries_with_name;
}
}
return number_of_entries_with_name;
}
Id GetFirstEntryWithName(BaseTransaction* rtrans,
const syncable::Id& parent_id,
const string& name) {
Directory::Metahandles child_handles;
rtrans->directory()->GetChildHandlesById(rtrans, parent_id, &child_handles);
for (Directory::Metahandles::iterator i = child_handles.begin();
i != child_handles.end(); ++i) {
Entry e(rtrans, GET_BY_HANDLE, *i);
CHECK(e.good());
if (e.GetNonUniqueName()== name) {
return e.GetId();
}
}
CHECK(false);
return Id();
}
Id GetOnlyEntryWithName(BaseTransaction* rtrans,
const syncable::Id& parent_id,
const string& name) {
CHECK(1 == CountEntriesWithName(rtrans, parent_id, name));
return GetFirstEntryWithName(rtrans, parent_id, name);
}
void CreateTypeRoot(WriteTransaction* trans,
syncable::Directory *dir,
ModelType type) {
std::string tag_name = syncer::ModelTypeToRootTag(type);
syncable::MutableEntry node(trans,
syncable::CREATE,
type,
TestIdFactory::root(),
tag_name);
DCHECK(node.good());
node.PutUniqueServerTag(tag_name);
node.PutIsDir(true);
node.PutServerIsDir(false);
node.PutIsUnsynced(false);
node.PutIsUnappliedUpdate(false);
node.PutServerVersion(20);
node.PutBaseVersion(20);
node.PutIsDel(false);
node.PutId(syncer::TestIdFactory::MakeServer(tag_name));
sync_pb::EntitySpecifics specifics;
syncer::AddDefaultFieldValue(type, &specifics);
node.PutServerSpecifics(specifics);
node.PutSpecifics(specifics);
}
}
}