Home
last modified time | relevance | path

Searched refs:NowMicros (Results 1 – 25 of 62) sorted by relevance

123

/rocksdb-6.9/util/
Dstop_watch.h32 start_time_((stats_enabled_ || elapsed != nullptr) ? env->NowMicros() in env_()
38 *elapsed_ = env_->NowMicros() - start_time_; in ~StopWatch()
40 *elapsed_ += env_->NowMicros() - start_time_; in ~StopWatch()
50 : (env_->NowMicros() - start_time_)); in ~StopWatch()
58 delay_start_time_ = env_->NowMicros(); in DelayStart()
64 total_delay_ += env_->NowMicros() - delay_start_time_; in DelayStop()
Drate_limiter_test.cc79 auto until = thread_env->NowMicros() + 2 * 1000000; in TEST_F()
82 while (thread_env->NowMicros() < until) { in TEST_F()
103 auto start = env->NowMicros(); in TEST_F()
109 auto elapsed = env->NowMicros() - start; in TEST_F()
209 while (std::chrono::microseconds(special_env.NowMicros()) <= in TEST_F()
Dlog_write_bench.cc51 uint64_t start_time = env->NowMicros(); in RunBenchmark()
66 (i + 1) * FLAGS_record_interval - (env->NowMicros() - start_time); in RunBenchmark()
Drepeatable_thread.h84 uint64_t wait_until = env_->NowMicros() + delay; in wait()
91 if (env_->NowMicros() >= wait_until) { in wait()
Drepeatable_thread_test.cc31 uint64_t prev_time = env->NowMicros(); in TEST_F()
36 uint64_t now = env->NowMicros(); in TEST_F()
/rocksdb-6.9/logging/
Dauto_roll_logger.cc32 cached_now(static_cast<uint64_t>(env_->NowMicros() * 1e-6)), in AutoRollLogger()
70 cached_now = static_cast<uint64_t>(env_->NowMicros() * 1e-6); in ResetLogger()
82 uint64_t now = env_->NowMicros(); in RollLogFile()
241 cached_now = static_cast<uint64_t>(env_->NowMicros() * 1e-6); in LogExpired()
283 OldInfoLogFileName(dbname, env->NowMicros(), db_absolute_path, in CreateLoggerFromOptions()
Denv_logger.h53 last_flush_micros_ = env_->NowMicros(); in FlushLocked()
139 const uint64_t now_micros = env_->NowMicros(); in Logv()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_driver.cc66 uint64_t now = db_stress_env->NowMicros(); in RunStressTest()
101 now = db_stress_env->NowMicros(); in RunStressTest()
111 now = db_stress_env->NowMicros(); in RunStressTest()
136 now = db_stress_env->NowMicros(); in RunStressTest()
Ddb_stress_stat.h74 start_ = Env::Default()->NowMicros(); in Start()
102 finish_ = Env::Default()->NowMicros(); in Stop()
108 auto now = Env::Default()->NowMicros(); in FinishedSingleOp()
/rocksdb-6.9/trace_replay/
Dtrace_replay.cc76 trace.ts = env_->NowMicros(); in Write()
88 trace.ts = env_->NowMicros(); in Get()
100 trace.ts = env_->NowMicros(); in IteratorSeek()
112 trace.ts = env_->NowMicros(); in IteratorSeekForPrev()
150 trace.ts = env_->NowMicros(); in WriteHeader()
158 trace.ts = env_->NowMicros(); in WriteFooter()
Dblock_cache_tracer_test.cc66 record.access_timestamp = env_->NowMicros(); in WriteBlockAccess()
96 record.access_timestamp = env_->NowMicros(); in GenerateAccessRecord()
/rocksdb-6.9/monitoring/
Dhistogram_windowing.cc47 last_swap_time_.store(env_->NowMicros(), std::memory_order_relaxed); in Clear()
134 uint64_t curr_time = env_->NowMicros(); in TimerTick()
149 last_swap_time_.store(env_->NowMicros(), std::memory_order_relaxed); in SwapHistoryBucket()
/rocksdb-6.9/test_util/
Dmock_time_env.h24 virtual uint64_t NowMicros() override { in NowMicros() function
34 uint64_t RealNowMicros() { return target()->NowMicros(); } in RealNowMicros()
/rocksdb-6.9/file/
Ddelete_scheduler_test.cc164 uint64_t delete_start_time = env_->NowMicros(); in TEST_F()
167 uint64_t time_spent_deleting = env_->NowMicros() - delete_start_time; in TEST_F()
284 uint64_t delete_start_time = env_->NowMicros(); in TEST_F()
287 uint64_t time_spent_deleting = env_->NowMicros() - delete_start_time; in TEST_F()
595 uint64_t delete_start_time = env_->NowMicros(); in TEST_F()
598 uint64_t time_spent_deleting = env_->NowMicros() - delete_start_time; in TEST_F()
Ddelete_scheduler.cc204 uint64_t start_time = env_->NowMicros(); in BackgroundEmptyTrash()
211 start_time = env_->NowMicros(); in BackgroundEmptyTrash()
/rocksdb-6.9/hdfs/
Denv_hdfs.h128 uint64_t NowMicros() override { return posixEnv->NowMicros(); } in NowMicros() function
352 virtual uint64_t NowMicros() override { return 0; } in NowMicros() function
/rocksdb-6.9/cache/
Dcache_bench.cc171 uint64_t start_time = env->NowMicros(); in Run()
183 uint64_t end_time = env->NowMicros(); in Run()
/rocksdb-6.9/utilities/transactions/
Dtransaction_lock_mgr.cc263 auto now = env->NowMicros(); in IsLockExpired()
322 uint64_t start_time = env->NowMicros(); in AcquireWithTimeout()
382 uint64_t now = env->NowMicros(); in AcquireWithTimeout()
622 txn->GetExpirationTime() < env->NowMicros()); in UnLockKey()
Dtransaction_base.cc28 start_time_(db_->GetEnv()->NowMicros()), in TransactionBaseImpl()
66 start_time_ = db_->GetEnv()->NowMicros(); in Reinitialize()
596 return (db_->GetEnv()->NowMicros() - start_time_) / 1000; in GetElapsedTime()
/rocksdb-6.9/db/
Ddb_test_util.h77 uint64_t start = env_->NowMicros(); in WaitFor()
79 uint64_t now = env_->NowMicros(); in WaitFor()
81 if (env_->NowMicros() - start > /*10s*/ 10 * 1000 * 1000) { in WaitFor()
524 virtual uint64_t NowMicros() override { in NowMicros() function
525 return (time_elapse_only_sleep_ ? 0 : target()->NowMicros()) + in NowMicros()
Dflush_job.cc300 const uint64_t start_micros = db_options_.env->NowMicros(); in WriteLevel0Table()
437 stats.micros = db_options_.env->NowMicros() - start_micros; in WriteLevel0Table()
Dexternal_sst_file_ingestion_job.h86 job_start_time_(env_->NowMicros()), in ExternalSstFileIngestionJob()
/rocksdb-6.9/port/win/
Denv_win.h158 virtual uint64_t NowMicros();
290 uint64_t NowMicros() override;
/rocksdb-6.9/env/
Dmock_env.cc339 last_flush_micros_ = env_->NowMicros(); in Flush()
732 uint64_t MockEnv::NowMicros() { in NowMicros() function in ROCKSDB_NAMESPACE::MockEnv
733 return EnvWrapper::NowMicros() + fake_sleep_micros_.load(); in NowMicros()
/rocksdb-6.9/include/rocksdb/
Denv.h431 virtual uint64_t NowMicros() = 0;
438 virtual uint64_t NowNanos() { return NowMicros() * 1000; } in NowNanos()
1311 uint64_t NowMicros() override { return target_->NowMicros(); } in NowMicros() function

123