Lines Matching refs:kernel_
105 : kernel_(NULL),
136 kernel_->metahandles_map.swap(*handles_map);
137 for (MetahandlesMap::const_iterator it = kernel_->metahandles_map.begin();
138 it != kernel_->metahandles_map.end(); ++it) {
141 kernel_->parent_child_index.Insert(entry);
144 kernel_->unsynced_metahandles.insert(metahandle);
147 kernel_->unapplied_update_metahandles[type].insert(metahandle);
150 DCHECK(kernel_->server_tags_map.find(entry->ref(UNIQUE_SERVER_TAG)) ==
151 kernel_->server_tags_map.end())
153 kernel_->server_tags_map[entry->ref(UNIQUE_SERVER_TAG)] = entry;
156 DCHECK(kernel_->server_tags_map.find(entry->ref(UNIQUE_SERVER_TAG)) ==
157 kernel_->server_tags_map.end())
159 kernel_->client_tags_map[entry->ref(UNIQUE_CLIENT_TAG)] = entry;
161 DCHECK(kernel_->ids_map.find(entry->ref(ID).value()) ==
162 kernel_->ids_map.end()) << "Unexpected duplicate use of ID";
163 kernel_->ids_map[entry->ref(ID).value()] = entry;
175 // Temporary indices before kernel_ initialized in case Load fails. We 0(1)
190 kernel_ = new Kernel(name, info, delegate, transaction_observer);
197 kernel_->info_status = KERNEL_SHARE_INFO_DIRTY;
211 if (kernel_) {
212 delete kernel_;
213 kernel_ = NULL;
233 DCHECK(kernel_);
235 IdsMap::iterator id_found = kernel_->ids_map.find(id.value());
236 if (id_found != kernel_->ids_map.end()) {
244 DCHECK(kernel_);
246 TagsMap::iterator it = kernel_->client_tags_map.find(tag);
247 if (it != kernel_->client_tags_map.end()) {
255 DCHECK(kernel_);
256 TagsMap::iterator it = kernel_->server_tags_map.find(tag);
257 if (it != kernel_->server_tags_map.end()) {
272 kernel_->metahandles_map.find(metahandle);
273 if (found != kernel_->metahandles_map.end()) {
325 kernel_->parent_child_index.GetChildren(kernel->ref(ID));
337 kernel_->parent_child_index.GetChildren(kernel->ref(PARENT_ID));
357 kernel_->metahandles_map.insert(
365 kernel_->ids_map.insert(
373 if (!SyncAssert(kernel_->parent_child_index.Insert(entry),
405 &kernel_->parent_child_index);
406 size_t num_erased = kernel_->ids_map.erase(entry->ref(ID).value());
409 kernel_->ids_map[entry->ref(ID).value()] = entry;
422 &kernel_->parent_child_index);
436 kernel_->index_by_attachment_id.find(unique_id);
437 if (iter != kernel_->index_by_attachment_id.end()) {
440 kernel_->index_by_attachment_id.erase(iter);
454 kernel_->index_by_attachment_id.find(unique_id);
455 if (iter == kernel_->index_by_attachment_id.end()) {
456 iter = kernel_->index_by_attachment_id.insert(std::make_pair(
481 kernel_->index_by_attachment_id.find(attachment_id_proto.unique_id());
482 if (index_iter == kernel_->index_by_attachment_id.end())
495 kernel_->transaction_mutex.AssertAcquired();
496 kernel_->dirty_metahandles.clear();
508 if (!SyncAssert(kernel_->dirty_metahandles.count(handle) == 0U,
513 if (!SyncAssert(!kernel_->unsynced_metahandles.count(handle),
518 if (!SyncAssert(!kernel_->unapplied_update_metahandles[type].count(handle),
536 // Deep copy dirty entries from kernel_->metahandles_index into snapshot and
538 for (MetahandleSet::const_iterator i = kernel_->dirty_metahandles.begin();
539 i != kernel_->dirty_metahandles.end(); ++i) {
548 DCHECK_EQ(1U, kernel_->dirty_metahandles.count(*i));
557 snapshot->metahandles_to_purge.swap(kernel_->metahandles_to_purge);
560 snapshot->kernel_info = kernel_->persisted_info;
566 snapshot->kernel_info_status = kernel_->info_status;
568 kernel_->info_status = KERNEL_SHARE_INFO_VALID;
577 base::AutoLock scoped_lock(kernel_->save_changes_mutex);
603 kernel_->metahandles_map.find((*i)->ref(META_HANDLE));
604 EntryKernel* entry = (found == kernel_->metahandles_map.end() ?
610 num_erased = kernel_->metahandles_map.erase(entry->ref(META_HANDLE));
612 num_erased = kernel_->ids_map.erase(entry->ref(ID).value());
616 kernel_->server_tags_map.erase(entry->ref(UNIQUE_SERVER_TAG));
621 kernel_->client_tags_map.erase(entry->ref(UNIQUE_CLIENT_TAG));
624 if (!SyncAssert(!kernel_->parent_child_index.Contains(entry),
658 kernel_->unapplied_update_metahandles[server_type].insert(handle);
659 entry->mark_dirty(&kernel_->dirty_metahandles);
664 kernel_->unsynced_metahandles.erase(handle);
666 entry->mark_dirty(&kernel_->dirty_metahandles);
672 kernel_->parent_child_index.Remove(entry);
674 entry->mark_dirty(&kernel_->dirty_metahandles);
680 entry->mark_dirty(&kernel_->dirty_metahandles);
697 kernel_->metahandles_to_purge.insert(handle);
700 num_erased = kernel_->metahandles_map.erase(entry->ref(META_HANDLE));
702 num_erased = kernel_->ids_map.erase(entry->ref(ID).value());
704 num_erased = kernel_->unsynced_metahandles.erase(handle);
707 kernel_->unapplied_update_metahandles[server_type].erase(handle);
709 if (kernel_->parent_child_index.Contains(entry))
710 kernel_->parent_child_index.Remove(entry);
714 kernel_->client_tags_map.erase(entry->ref(UNIQUE_CLIENT_TAG));
719 kernel_->server_tags_map.erase(entry->ref(UNIQUE_SERVER_TAG));
751 if (!kernel_->persisted_info.HasEmptyDownloadProgress(iter.Get()))
767 for (MetahandlesMap::iterator it = kernel_->metahandles_map.begin();
768 it != kernel_->metahandles_map.end(); ++it) {
811 kernel_->persisted_info.transaction_version[it.Get()] = 0;
815 kernel_->persisted_info.ResetDownloadProgress(it.Get());
816 kernel_->persisted_info.datatype_context[it.Get()].Clear();
820 kernel_->info_status = KERNEL_SHARE_INFO_DIRTY;
854 entry->mark_dirty(&kernel_->dirty_metahandles);
864 kernel_->index_by_attachment_id.find(attachment_id_proto.unique_id());
865 if (iter != kernel_->index_by_attachment_id.end() && !iter->second.empty()) {
874 kernel_->info_status = KERNEL_SHARE_INFO_DIRTY;
884 kernel_->metahandles_map.find((*i)->ref(META_HANDLE));
885 if (found != kernel_->metahandles_map.end()) {
886 found->second->mark_dirty(&kernel_->dirty_metahandles);
890 kernel_->metahandles_to_purge.insert(snapshot.metahandles_to_purge.begin(),
904 kernel_->persisted_info.download_progress[model_type]);
911 kernel_->persisted_info.download_progress[model_type].SerializeToString(
917 return kernel_->metahandles_map.size();
924 kernel_->persisted_info.download_progress[model_type].CopyFrom(new_progress);
925 kernel_->info_status = KERNEL_SHARE_INFO_DIRTY;
929 kernel_->transaction_mutex.AssertAcquired();
930 return kernel_->persisted_info.transaction_version[type];
934 kernel_->transaction_mutex.AssertAcquired();
935 kernel_->persisted_info.transaction_version[type]++;
942 context->CopyFrom(kernel_->persisted_info.datatype_context[type]);
950 kernel_->persisted_info.datatype_context[type].CopyFrom(context);
951 kernel_->info_status = KERNEL_SHARE_INFO_DIRTY;
980 return kernel_->persisted_info.store_birthday;
985 if (kernel_->persisted_info.store_birthday == store_birthday)
987 kernel_->persisted_info.store_birthday = store_birthday;
988 kernel_->info_status = KERNEL_SHARE_INFO_DIRTY;
993 return kernel_->persisted_info.bag_of_chips;
998 if (kernel_->persisted_info.bag_of_chips == bag_of_chips)
1000 kernel_->persisted_info.bag_of_chips = bag_of_chips;
1001 kernel_->info_status = KERNEL_SHARE_INFO_DIRTY;
1007 return kernel_->cache_guid;
1023 for (MetahandlesMap::iterator i = kernel_->metahandles_map.begin();
1024 i != kernel_->metahandles_map.end(); ++i) {
1033 copy(kernel_->unsynced_metahandles.begin(),
1034 kernel_->unsynced_metahandles.end(), back_inserter(*result));
1039 return kernel_->unsynced_metahandles.size();
1044 return !kernel_->unapplied_update_metahandles[type].empty();
1056 std::copy(kernel_->unapplied_update_metahandles[type].begin(),
1057 kernel_->unapplied_update_metahandles[type].end(),
1075 for (MetahandlesMap::iterator it = kernel_->metahandles_map.begin();
1076 it != kernel_->metahandles_map.end(); ++it) {
1091 for (MetahandlesMap::iterator it = kernel_->metahandles_map.begin();
1092 it != kernel_->metahandles_map.end(); ++it) {
1107 for (MetahandlesMap::iterator it = kernel_->metahandles_map.begin();
1108 it != kernel_->metahandles_map.end(); ++it) {
1301 int64 metahandle = (kernel_->next_metahandle)++;
1311 result = (kernel_->persisted_info.next_id)--;
1312 kernel_->info_status = KERNEL_SHARE_INFO_DIRTY;
1320 return kernel_->parent_child_index.GetChildren(id) != NULL;
1330 kernel_->parent_child_index.GetChildren(parent->ref(ID));
1344 kernel_->parent_child_index.GetChildren(e->ref(PARENT_ID));
1362 kernel_->parent_child_index.GetChildren(e->ref(PARENT_ID));
1389 ScopedParentChildIndexUpdater updater(lock, e, &kernel_->parent_child_index);
1394 kernel_->parent_child_index.GetChildren(e->ref(PARENT_ID));
1464 kernel_->parent_child_index.GetChildren(parent_id);
1477 entry->kernel_->clear_dirty(&kernel_->dirty_metahandles);