Lines Matching refs:txn
88 DB* db, Transaction* txn, ReadOptions& read_options, uint16_t set_i, in DBGet() argument
105 if (txn != nullptr) { in DBGet()
107 s = txn->GetForUpdate(read_options, key, &value); in DBGet()
109 s = txn->Get(read_options, key, &value); in DBGet()
131 bool RandomTransactionInserter::DoInsert(DB* db, Transaction* txn, in DoInsert() argument
149 const bool get_for_update = txn ? rand_->OneIn(2) : false; in DoInsert()
150 s = DBGet(db, txn, read_options_, set_i, rand_key, get_for_update, in DoInsert()
167 if (txn != nullptr) { in DoInsert()
168 s = txn->Put(key, sum); in DoInsert()
184 if (txn != nullptr) { in DoInsert()
188 txn->GetName().c_str(), s.ToString().c_str(), in DoInsert()
189 txn->GetSnapshot()->GetSequenceNumber(), full_key.c_str(), in DoInsert()
195 if (txn != nullptr) { in DoInsert()
199 s = txn->Prepare(); in DoInsert()
202 "Prepare of %" PRIu64 " %s (%s)", txn->GetId(), in DoInsert()
203 s.ToString().c_str(), txn->GetName().c_str()); in DoInsert()
214 s = txn->Commit(); in DoInsert()
217 "Commit of %" PRIu64 " %s (%s)", txn->GetId(), in DoInsert()
218 s.ToString().c_str(), txn->GetName().c_str()); in DoInsert()
221 s = txn->Rollback(); in DoInsert()
223 "Rollback %" PRIu64 " %s %s", txn->GetId(), in DoInsert()
224 txn->GetName().c_str(), s.ToString().c_str()); in DoInsert()
259 if (txn != nullptr) { in DoInsert()
260 assert(txn->Rollback().ok()); in DoInsert()
262 s.ToString().c_str(), txn->GetName().c_str()); in DoInsert()