Lines Matching refs:trans
198 void Directory::OnUnrecoverableError(const BaseTransaction* trans,
201 DCHECK(trans != NULL);
262 BaseTransaction* trans, const Id& parent_id,
264 if (!SyncAssert(this == trans->directory(), FROM_HERE,
265 "Directories don't match", trans))
275 BaseTransaction* trans, int64 handle,
277 if (!SyncAssert(this == trans->directory(), FROM_HERE,
278 "Directories don't match", trans))
293 BaseTransaction* trans,
295 if (!SyncAssert(this == trans->directory(), FROM_HERE,
296 "Directories don't match", trans))
302 GetChildSetForKernel(trans, kernel, &child_sets);
309 GetChildSetForKernel(trans, *it, &child_sets);
317 BaseTransaction* trans,
333 BaseTransaction* trans,
346 bool Directory::InsertEntry(BaseWriteTransaction* trans, EntryKernel* entry) {
348 return InsertEntry(trans, entry, &lock);
351 bool Directory::InsertEntry(BaseWriteTransaction* trans,
355 if (!SyncAssert(NULL != entry, FROM_HERE, "Entry is null", trans))
365 trans)) {
373 trans)) {
380 trans)) {
387 "Server tag should be empty", trans)) {
391 "Client tag should be empty", trans))
397 bool Directory::ReindexId(BaseWriteTransaction* trans,
416 bool Directory::ReindexParentId(BaseWriteTransaction* trans,
430 bool Directory::unrecoverable_error_set(const BaseTransaction* trans) const {
431 DCHECK(trans != NULL);
440 bool Directory::SafeToPurgeFromMemory(WriteTransaction* trans,
451 "Dirty metahandles should be empty", trans))
457 trans))
462 trans))
470 ReadTransaction trans(FROM_HERE, this);
474 if (unrecoverable_error_set(&trans))
512 &trans, &snapshot->delete_journals, &snapshot->delete_journals_to_purge);
538 WriteTransaction trans(FROM_HERE, VACUUM_AFTER_SAVE, this);
547 if (entry && SafeToPurgeFromMemory(&trans, entry)) {
568 (&trans)))
572 if (trans.unrecoverable_error_set())
676 WriteTransaction trans(FROM_HERE, PURGE_ENTRIES, this);
730 delete_journal_->AddJournalBatch(&trans, entries_to_journal);
747 WriteTransaction trans(FROM_HERE, HANDLE_SAVE_FAILURE, this);
769 delete_journal_->AddJournalBatch(&trans, snapshot.delete_journals);
770 delete_journal_->PurgeDeleteJournals(&trans,
814 syncable::ReadTransaction trans(FROM_HERE, this);
818 if (InitialSyncEndedForType(&trans, i.Get())) {
826 syncable::ReadTransaction trans(FROM_HERE, this);
827 return InitialSyncEndedForType(&trans, type);
831 BaseTransaction* trans, ModelType type) {
833 syncable::Entry entry(trans,
875 Cryptographer* Directory::GetCryptographer(const BaseTransaction* trans) {
876 DCHECK_EQ(this, trans->directory());
880 void Directory::GetAllMetaHandles(BaseTransaction* trans,
890 void Directory::GetAllEntryKernels(BaseTransaction* trans,
900 void Directory::GetUnsyncedMetaHandles(BaseTransaction* trans,
919 BaseTransaction* trans,
937 syncable::ReadTransaction trans(FROM_HERE, this);
951 syncable::BaseTransaction* trans,
953 // NOTE: The trans may be in the process of being destructed. Be careful if
958 GetAllMetaHandles(trans
959 return CheckTreeInvariants(trans, all_handles);
962 return CheckTreeInvariants(trans, modified_handles);
972 bool Directory::FullyCheckTreeInvariants(syncable::BaseTransaction* trans) {
974 GetAllMetaHandles(trans, &handles);
975 return CheckTreeInvariants(trans, handles);
978 bool Directory::CheckTreeInvariants(syncable::BaseTransaction* trans,
983 Entry e(trans, GET_BY_HANDLE, metahandle);
984 if (!SyncAssert(e.good(), FROM_HERE, "Entry is bad", trans))
992 trans))
996 trans))
1000 trans))
1008 trans))
1012 trans))
1016 Entry parent(trans, GET_BY_ID, parentid);
1019 trans))
1025 trans))
1029 trans))
1034 trans))
1039 trans))
1053 trans))
1059 trans))
1067 trans))
1074 trans))
1083 trans))
1092 trans))
1100 trans))
1108 trans)) {
1138 bool Directory::HasChildren(BaseTransaction* trans, const Id& id) {
1143 Id Directory::GetFirstChildId(BaseTransaction* trans,
