Lines Matching defs:Transaction
182 static void PutBool(LevelDBTransaction* transaction,
187 transaction->Put(key, &buffer);
221 static void PutInt(LevelDBTransaction* transaction,
227 transaction->Put(key, &buffer);
247 static void PutVarInt(LevelDBTransaction* transaction,
252 transaction->Put(key, &buffer);
274 static void PutString(LevelDBTransaction* transaction,
279 transaction->Put(key, &buffer);
282 static void PutIDBKeyPath(LevelDBTransaction* transaction,
287 transaction->Put(key, &buffer);
356 scoped_refptr<LevelDBTransaction> transaction =
363 GetInt(transaction.get(), schema_version_key, &db_schema_version, &found);
371 PutInt(transaction.get(), schema_version_key, db_schema_version);
373 PutInt(transaction.get(), data_version_key, db_data_version);
385 PutInt(transaction.get(), schema_version_key, db_schema_version);
396 s = GetInt(transaction.get(), it->Key(), &database_id, &found);
407 PutVarInt(transaction.get(),
414 PutInt(transaction.get(), schema_version_key, db_schema_version);
416 PutInt(transaction.get(), data_version_key, db_data_version);
434 s = GetInt(transaction.get(), data_version_key, &db_data_version, &found);
445 PutInt(transaction.get(), data_version_key, db_data_version);
451 s = transaction->Commit();
1252 LevelDBTransaction* transaction,
1258 GetInt(transaction, MaxDatabaseIdKey::Encode(), &max_database_id, &found);
1269 PutInt(transaction, MaxDatabaseIdKey::Encode(), database_id);
1279 scoped_refptr<LevelDBTransaction> transaction =
1282 leveldb::Status s = GetNewDatabaseId(transaction.get(), row_id);
1290 PutInt(transaction.get(),
1294 transaction.get(),
1297 PutVarInt(transaction.get(),
1302 transaction.get(),
1307 s = transaction->Commit();
1314 IndexedDBBackingStore::Transaction* transaction,
1320 PutVarInt(transaction->transaction(),
1329 static leveldb::Status DeleteRangeBasic(LevelDBTransaction* transaction,
1333 scoped_ptr<LevelDBIterator> it = transaction->CreateIterator();
1339 transaction->Remove(it->Key());
1344 IndexedDBBackingStore::Transaction* transaction,
1350 scoped_ptr<LevelDBIterator> it = transaction->transaction()->CreateIterator();
1363 transaction->PutBlobInfo(
1370 IndexedDBBackingStore::Transaction* transaction,
1379 transaction, database_id, object_store_id, start_key, stop_key, true);
1385 scoped_ptr<LevelDBDirectTransaction> transaction =
1409 transaction->Remove(it->Key());
1416 transaction->Remove(key);
1421 s = MergeDatabaseIntoLiveBlobJournal(transaction.get(), metadata.id);
1425 UpdateBlobJournalWithDatabase(transaction.get(), metadata.id);
1429 s = transaction->Commit();
1647 LevelDBTransaction* transaction,
1654 transaction, max_object_store_id_key, &max_object_store_id);
1664 PutInt(transaction, max_object_store_id_key, object_store_id);
1671 IndexedDBBackingStore::Transaction* transaction,
1680 LevelDBTransaction* leveldb_transaction = transaction->transaction();
1722 IndexedDBBackingStore::Transaction* transaction,
1728 LevelDBTransaction* leveldb_transaction = transaction->transaction();
1747 s = DeleteBlobsInObjectStore(transaction, database_id, object_store_id);
1783 return ClearObjectStore(transaction, database_id, object_store_id);
1787 IndexedDBBackingStore::Transaction* transaction,
1795 LevelDBTransaction* leveldb_transaction = transaction->transaction();
1824 return transaction->GetBlobInfoForRecord(database_id, leveldb_key, record);
1828 LevelDBTransaction* transaction,
1839 GetInt(transaction, last_version_key, &last_version, &found);
1850 PutInt(transaction, last_version_key, version);
1860 IndexedDBBackingStore::Transaction* transaction,
1872 LevelDBTransaction* leveldb_transaction = transaction->transaction();
1887 s = transaction->PutBlobInfoIfNeeded(database_id,
1909 IndexedDBBackingStore::Transaction* transaction,
1921 DeleteRangeBasic(transaction->transaction(), start_key, stop_key, true);
1926 return DeleteBlobsInObjectStore(transaction, database_id, object_store_id);
1930 IndexedDBBackingStore::Transaction* transaction,
1937 LevelDBTransaction* leveldb_transaction = transaction->transaction();
1942 leveldb::Status s = transaction->PutBlobInfoIfNeeded(
1954 IndexedDBBackingStore::Transaction* transaction,
1960 OpenObjectStoreCursor(transaction,
1972 OpenObjectStoreCursor(transaction,
1997 s = DeleteBlobsInRange(transaction,
2005 s = DeleteRangeBasic(transaction->transaction(), start_key, stop_key, false);
2013 transaction->transaction(), start_key, stop_key, false);
2017 IndexedDBBackingStore::Transaction* transaction,
2023 LevelDBTransaction* leveldb_transaction = transaction->transaction();
2089 IndexedDBBackingStore::Transaction* transaction,
2100 transaction, database_id, object_store_id, ¤t_number);
2113 transaction->transaction(), key_generator_current_number_key, new_number);
2118 IndexedDBBackingStore::Transaction* transaction,
2133 transaction->transaction()->Get(leveldb_key, &data, found);
2156 class IndexedDBBackingStore::Transaction::ChainedBlobWriterImpl
2157 : public IndexedDBBackingStore::Transaction::ChainedBlobWriter {
2159 typedef IndexedDBBackingStore::Transaction::WriteDescriptorVec
2245 LocalWriteClosure(IndexedDBBackingStore::Transaction::ChainedBlobWriter*
2302 IndexedDBBackingStore::Transaction::ChainedBlobWriter* chained_blob_writer_;
2311 const Transaction::WriteDescriptor& descriptor,
2312 Transaction::ChainedBlobWriter* chained_blob_writer) {
2344 base::Bind(&Transaction::ChainedBlobWriter::ReportWriteCompletion,
2369 scoped_refptr<LevelDBTransaction> transaction =
2374 if (!GetBlobJournal(live_blob_key, transaction.get(), &live_blob_journal)
2381 if (!GetBlobJournal(primary_key, transaction.get(), &primary_journal).ok())
2422 UpdatePrimaryJournalWithBlobList(transaction.get(), primary_journal);
2423 UpdateLiveBlobJournalWithBlobList(transaction.get(), new_live_blob_journal);
2424 transaction->Commit();
2604 leveldb::Status IndexedDBBackingStore::Transaction::GetBlobInfoForRecord(
2633 scoped_ptr<LevelDBIterator> it = transaction()->CreateIterator();
2673 LevelDBTransaction* transaction,
2682 GetInt(transaction, max_index_id_key, &max_index_id, &found);
2695 PutInt(transaction, max_index_id_key, index_id);
2700 IndexedDBBackingStore::Transaction* transaction,
2711 LevelDBTransaction* leveldb_transaction = transaction->transaction();
2735 IndexedDBBackingStore::Transaction* transaction,
2742 LevelDBTransaction* leveldb_transaction = transaction->transaction();
2767 IndexedDBBackingStore::Transaction* transaction,
2793 transaction->transaction()->Put(index_data_key, &data);
2797 static bool FindGreatestKeyLessThanOrEqual(LevelDBTransaction* transaction,
2801 scoped_ptr<LevelDBIterator> it = transaction->CreateIterator();
2828 static leveldb::Status VersionExists(LevelDBTransaction* transaction,
2838 leveldb::Status s = transaction->Get(key, &data, exists);
2855 IndexedDBBackingStore::Transaction* transaction,
2868 LevelDBTransaction* leveldb_transaction = transaction->transaction();
2914 IndexedDBBackingStore::Transaction* transaction,
2926 leveldb::Status s = FindKeyInIndex(transaction,
2952 IndexedDBBackingStore::Transaction* transaction,
2965 leveldb::Status s = FindKeyInIndex(transaction,
2998 iterator_ = transaction_->transaction()->CreateIterator();
3010 IndexedDBBackingStore::Transaction* transaction,
3014 transaction_(transaction),
3021 iterator_ = transaction_->transaction()->CreateIterator();
3205 IndexedDBBackingStore::Transaction* transaction,
3209 transaction,
3271 IndexedDBBackingStore::Transaction* transaction,
3275 transaction,
3341 IndexedDBBackingStore::Transaction* transaction,
3345 transaction,
3423 transaction_->transaction()->Get(primary_leveldb_key, &result, &found);
3429 transaction_->transaction()->Remove(iterator_->Key());
3445 transaction_->transaction()->Remove(iterator_->Key());
3456 IndexedDBBackingStore::Transaction* transaction,
3460 transaction,
3539 transaction_->transaction()->Get(primary_leveldb_key_, &result, &found);
3545 transaction_->transaction()->Remove(iterator_->Key());
3561 transaction_->transaction()->Remove(iterator_->Key());
3572 LevelDBTransaction* transaction,
3610 if (!FindGreatestKeyLessThanOrEqual(transaction,
3627 transaction, cursor_options->high_key, &found_high_key, s))
3644 LevelDBTransaction* transaction,
3651 DCHECK(transaction);
3685 if (!FindGreatestKeyLessThanOrEqual(transaction,
3701 transaction, cursor_options->high_key, &found_high_key, s))
3718 IndexedDBBackingStore::Transaction* transaction,
3726 LevelDBTransaction* leveldb_transaction = transaction->transaction();
3736 this, transaction, database_id, cursor_options));
3745 IndexedDBBackingStore::Transaction* transaction,
3753 LevelDBTransaction* leveldb_transaction = transaction->transaction();
3763 this, transaction, database_id, cursor_options));
3772 IndexedDBBackingStore::Transaction* transaction,
3781 LevelDBTransaction* leveldb_transaction = transaction->transaction();
3792 new IndexKeyCursorImpl(this, transaction, database_id, cursor_options));
3801 IndexedDBBackingStore::Transaction* transaction,
3809 LevelDBTransaction* leveldb_transaction = transaction->transaction();
3820 new IndexCursorImpl(this, transaction, database_id, cursor_options));
3827 IndexedDBBackingStore::Transaction::Transaction(
3832 IndexedDBBackingStore::Transaction::~Transaction() {
3839 void IndexedDBBackingStore::Transaction::Begin() {
3840 IDB_TRACE("IndexedDBBackingStore::Transaction::Begin");
3858 leveldb::Status IndexedDBBackingStore::Transaction::HandleBlobPreTransaction(
3923 bool IndexedDBBackingStore::Transaction::CollectBlobFilesToRemove() {
3928 // Look up all old files to remove as part of the transaction, store their
3968 leveldb::Status IndexedDBBackingStore::Transaction::SortBlobsToRemove() {
3990 leveldb::Status IndexedDBBackingStore::Transaction::CommitPhaseOne(
3992 IDB_TRACE("IndexedDBBackingStore::Transaction::CommitPhaseOne");
4036 leveldb::Status IndexedDBBackingStore::Transaction::CommitPhaseTwo() {
4037 IDB_TRACE("IndexedDBBackingStore::Transaction::CommitPhaseTwo");
4076 class IndexedDBBackingStore::Transaction::BlobWriteCallbackWrapper
4079 BlobWriteCallbackWrapper(IndexedDBBackingStore::Transaction* transaction,
4081 : transaction_(transaction), callback_(callback) {}
4092 IndexedDBBackingStore::Transaction* transaction_;
4098 void IndexedDBBackingStore::Transaction::WriteNewBlobs(
4108 // Add the new blob-table entry for each blob to the main transaction, or
4124 void IndexedDBBackingStore::Transaction::Rollback() {
4125 IDB_TRACE("IndexedDBBackingStore::Transaction::Rollback");
4170 leveldb::Status IndexedDBBackingStore::Transaction::PutBlobInfoIfNeeded(
4190 transaction()->Get(blob_entry_key.Encode(), &value, &found);
4203 // leveldb transaction, but only w.r.t. the user keys altered--we don't keep the
4205 void IndexedDBBackingStore::Transaction::PutBlobInfo(
4230 IndexedDBBackingStore::Transaction::WriteDescriptor::WriteDescriptor(
4237 IndexedDBBackingStore::Transaction::WriteDescriptor::WriteDescriptor(
