Searched refs:txns (Results 1 – 6 of 6) sorted by relevance
598 auto& txns = stripe_iter->second.txn_ids; in UnLockKey() local599 auto txn_it = std::find(txns.begin(), txns.end(), txn_id); in UnLockKey()601 if (txn_it != txns.end()) { in UnLockKey()602 if (txns.size() == 1) { in UnLockKey()605 auto last_it = txns.end() - 1; in UnLockKey()609 txns.pop_back(); in UnLockKey()
504 ASSERT_TRUE(txns[i]); in TEST_P()523 txns[i]->Rollback(); in TEST_P()524 delete txns[i]; in TEST_P()585 txns[i]->Rollback(); in TEST_P()586 delete txns[i]; in TEST_P()711 ASSERT_TRUE(txns[i]); in TEST_P()729 txns[i]->Rollback(); in TEST_P()730 delete txns[i]; in TEST_P()791 delete txns[len - 1]; in TEST_P()895 txns.push_back(txn); in TEST_P()[all …]
1327 std::vector<Transaction*> txns; in TEST_P() local1334 txns.push_back(txn); in TEST_P()1355 for (auto txn : txns) { in TEST_P()1598 std::vector<Transaction*> txns, committed_txns; in TEST_P() local1608 txns.push_back(txn); in TEST_P()1619 txn = txns[index]; in TEST_P()1620 txns.erase(txns.begin() + index); in TEST_P()1632 if (txns.empty()) { in TEST_P()1636 ASSERT_LE(min_uncommitted, (*txns.begin())->GetId()); in TEST_P()
220 final List<Transaction> txns = new ArrayList<>(); in getAllPreparedTransactions() local227 txns.add(txn); in getAllPreparedTransactions()229 return txns; in getAllPreparedTransactions()
293 std::vector<ROCKSDB_NAMESPACE::Transaction*> txns; in Java_org_rocksdb_TransactionDB_getAllPreparedTransactions() local294 txn_db->GetAllPreparedTransactions(&txns); in Java_org_rocksdb_TransactionDB_getAllPreparedTransactions()296 const size_t size = txns.size(); in Java_org_rocksdb_TransactionDB_getAllPreparedTransactions()302 tmp[i] = reinterpret_cast<jlong>(txns[i]); in Java_org_rocksdb_TransactionDB_getAllPreparedTransactions()
376 * Fix a bug in WritePrepared txns where if the number of old snapshots goes beyond the snapshot cac…