diff options
Diffstat (limited to 'utilities/transactions')
| -rw-r--r-- | utilities/transactions/pessimistic_transaction.cc | 2 | ||||
| -rw-r--r-- | utilities/transactions/transaction_base.cc | 6 |
2 files changed, 4 insertions, 4 deletions
diff --git a/utilities/transactions/pessimistic_transaction.cc b/utilities/transactions/pessimistic_transaction.cc index 17ddd37ac..7d4276972 100644 --- a/utilities/transactions/pessimistic_transaction.cc +++ b/utilities/transactions/pessimistic_transaction.cc @@ -120,7 +120,7 @@ void PessimisticTransaction::Reinitialize( bool PessimisticTransaction::IsExpired() const { if (expiration_time_ > 0) { - if (db_->GetEnv()->NowMicros() >= expiration_time_) { + if (dbimpl_->GetSystemClock()->NowMicros() >= expiration_time_) { // Transaction is expired. return true; } diff --git a/utilities/transactions/transaction_base.cc b/utilities/transactions/transaction_base.cc index 1482dc961..49fa99d7d 100644 --- a/utilities/transactions/transaction_base.cc +++ b/utilities/transactions/transaction_base.cc @@ -28,7 +28,7 @@ TransactionBaseImpl::TransactionBaseImpl( write_options_(write_options), cmp_(GetColumnFamilyUserComparator(db->DefaultColumnFamily())), lock_tracker_factory_(lock_tracker_factory), - start_time_(db_->GetEnv()->NowMicros()), + start_time_(dbimpl_->GetSystemClock()->NowMicros()), write_batch_(cmp_, 0, true, 0), tracked_locks_(lock_tracker_factory_.Create()), indexing_enabled_(true) { @@ -67,7 +67,7 @@ void TransactionBaseImpl::Reinitialize(DB* db, name_.clear(); log_number_ = 0; write_options_ = write_options; - start_time_ = db_->GetEnv()->NowMicros(); + start_time_ = dbimpl_->GetSystemClock()->NowMicros(); indexing_enabled_ = true; cmp_ = GetColumnFamilyUserComparator(db_->DefaultColumnFamily()); } @@ -540,7 +540,7 @@ WriteBatchWithIndex* TransactionBaseImpl::GetWriteBatch() { } uint64_t TransactionBaseImpl::GetElapsedTime() const { - return (db_->GetEnv()->NowMicros() - start_time_) / 1000; + return (dbimpl_->GetSystemClock()->NowMicros() - start_time_) / 1000; } uint64_t TransactionBaseImpl::GetNumPuts() const { return num_puts_; } |