Lines Matching refs:env_
201 options.env = env_; in TEST_F()
219 options.env = env_; in TEST_F()
267 options.env = env_; in TEST_F()
328 options.env = env_; in TEST_F()
356 env_->SleepForMicroseconds(3000000ULL); in TEST_F()
384 options.env = env_; in TEST_F()
427 env_->SleepForMicroseconds(3000000ULL); in TEST_F()
677 options.env = env_; in TEST_F()
711 options.env = env_; in TEST_F()
759 options.env = env_; in TEST_F()
766 env_->delay_sstable_sync_.store(true, std::memory_order_release); in TEST_F()
772 env_->delay_sstable_sync_.store(false, std::memory_order_release); in TEST_F()
976 db_test->env_->addon_time_.fetch_add(1000); in Filter()
1286 options.env = env_; in TEST_F()
1709 env_->addon_time_.fetch_add(1); in TEST_F()
2115 ASSERT_OK(env_->CreateDirIfMissing(dbname)); in TEST_F()
2117 ASSERT_OK(env_->CreateDirIfMissing(metadbname)); in TEST_F()
2119 ASSERT_OK(env_->CreateDirIfMissing(metametadbname)); in TEST_F()
2184 ASSERT_OK(env_->CreateDirIfMissing(snapdir)); in TEST_F()
2194 ASSERT_OK(env_->GetFileSize(src, &size)); in TEST_F()
2226 opts.env = env_; in TEST_F()
2264 ASSERT_OK(env_->GetFileSize(src, &size)); in TEST_F()
2303 env_->GetFileSize(dbname_ + "/" + f, &size_on_disk); in TEST_F()
2321 env_->CreateDirIfMissing(options.db_log_dir); in TEST_F()
2330 env_->GetChildren(options.db_log_dir.empty() ? dbname_ : options.db_log_dir, in TEST_F()
2344 env_->GetChildren(dbname_, &db_files); in TEST_F()
2351 env_->GetChildren(options.db_log_dir, &files); in TEST_F()
2353 env_->DeleteFile(options.db_log_dir + "/" + file); in TEST_F()
2355 env_->DeleteDir(options.db_log_dir); in TEST_F()
2536 env_->StartThread(MTThreadBody, &thread[id]); in TEST_P()
2540 env_->SleepForMicroseconds(kTestSeconds * 1000000); in TEST_P()
2546 env_->SleepForMicroseconds(100000); in TEST_P()
2591 options.env = env_; in TEST_F()
2608 env_->StartThread(GCThreadBody, &thread[id]); in TEST_F()
2610 env_->WaitForJoin(); in TEST_F()
3463 env_->time_elapse_only_sleep_ = false; in TEST_F()
3464 options.env = env_; in TEST_F()
3469 env_->addon_time_.store(0); in TEST_F()
3491 env_->addon_time_.fetch_add(2 * 60 * 60); in TEST_F()
3523 env_->addon_time_.fetch_add(2 * 60 * 60); in TEST_F()
3565 env_->addon_time_.fetch_add(2 * 60 * 60); in TEST_F()
3606 env_->addon_time_.fetch_add(2 * 60 * 60); in TEST_F()
3680 options.env = env_; in TEST_F()
3690 uint64_t start = env_->NowMicros(); in TEST_F()
3696 uint64_t elapsed = env_->NowMicros() - start; in TEST_F()
3697 double raw_rate = env_->bytes_written_ * 1000000.0 / elapsed; in TEST_F()
3706 env_->bytes_written_ = 0; in TEST_F()
3709 start = env_->NowMicros(); in TEST_F()
3718 elapsed = env_->NowMicros() - start; in TEST_F()
3720 ASSERT_EQ(options.rate_limiter->GetTotalBytesThrough(), env_->bytes_written_); in TEST_F()
3725 double ratio = env_->bytes_written_ * 1000000 / elapsed / raw_rate; in TEST_F()
3732 env_->bytes_written_ = 0; in TEST_F()
3735 start = env_->NowMicros(); in TEST_F()
3741 elapsed = env_->NowMicros() - start; in TEST_F()
3746 ASSERT_EQ(options.rate_limiter->GetTotalBytesThrough(), env_->bytes_written_); in TEST_F()
3751 ratio = env_->bytes_written_ * 1000000 / elapsed / raw_rate; in TEST_F()
3817 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
3828 env_->SleepForMicroseconds(1000); in TEST_F()
3853 env_->SleepForMicroseconds(10000); in TEST_F()
3855 env_->SleepForMicroseconds(10000); in TEST_F()
3922 options.env = env_; in TEST_F()
3992 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
3994 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
4000 env_->SetBackgroundThreads(0, Env::HIGH); in TEST_F()
4029 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
4052 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
4090 options.env = env_; in TEST_F()
4095 Status s = env_->GetThreadList(&thread_list); in TEST_F()
4105 env_->SetBackgroundThreads(kHighPriCounts[test], Env::HIGH); in TEST_F()
4106 env_->SetBackgroundThreads(kLowPriCounts[test], Env::LOW); in TEST_F()
4107 env_->SetBackgroundThreads(kBottomPriCounts[test], Env::BOTTOM); in TEST_F()
4114 env_->SleepForMicroseconds(1000); in TEST_F()
4116 s = env_->GetThreadList(&thread_list); in TEST_F()
4145 env_->GetThreadStatusUpdater()->TEST_VerifyColumnFamilyInfoMap(handles_, in TEST_F()
4152 env_->GetThreadStatusUpdater()->TEST_VerifyColumnFamilyInfoMap(handles_, in TEST_F()
4155 env_->GetThreadStatusUpdater()->TEST_VerifyColumnFamilyInfoMap(handles_, in TEST_F()
4161 options.env = env_; in TEST_F()
4166 env_->GetThreadStatusUpdater()->TEST_VerifyColumnFamilyInfoMap(handles_, in TEST_F()
4172 options.env = env_; in TEST_F()
4184 VerifyOperationCount(env_, ThreadStatus::OP_FLUSH, 0); in TEST_F()
4188 VerifyOperationCount(env_, ThreadStatus::OP_FLUSH, 0); in TEST_F()
4200 VerifyOperationCount(env_, ThreadStatus::OP_FLUSH, 1); in TEST_F()
4223 options.env = env_; in TEST_P()
4263 VerifyOperationCount(env_, ThreadStatus::OP_COMPACTION, 1); in TEST_P()
4266 VerifyOperationCount(env_, ThreadStatus::OP_COMPACTION, 0); in TEST_P()
4347 env_->SetBackgroundThreads(kHighPriCount, Env::HIGH); in TEST_P()
4348 env_->SetBackgroundThreads(kLowPriCount, Env::LOW); in TEST_P()
4359 options.env = env_; in TEST_P()
4395 Status s = env_->GetThreadList(&thread_list); in TEST_P()
4420 Status s = env_->GetThreadList(&thread_list); in TEST_P()
4436 env_->SetBackgroundThreads(kHighPriCount, Env::HIGH); in TEST_P()
4437 env_->SetBackgroundThreads(kLowPriCount, Env::LOW); in TEST_P()
4448 options.env = env_; in TEST_P()
4482 Status s = env_->GetThreadList(&thread_list); in TEST_P()
4507 Status s = env_->GetThreadList(&thread_list); in TEST_P()
4737 options.env = env_; in TEST_F()
4755 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
4756 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
4849 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
4880 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
5068 options.env = env_; in TEST_F()
5090 env_->non_writeable_rate_.store(90); in TEST_F()
5118 env_->non_writeable_rate_.store(0); in TEST_F()
5131 options.env = env_; in TEST_F()
5312 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
5313 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
5315 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
5318 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
5322 env_->GetChildren(dbname_, &filenames); in TEST_F()
5325 env_->DeleteFile(dbname_ + "/" + filenames[i]); in TEST_F()
5327 env_->DeleteDir(dbname_); in TEST_F()
5331 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
5332 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
5365 db_test_->env_->addon_time_.fetch_add(1000); in FullMergeV2()
5383 this->env_->addon_time_.store(0); in TEST_F()
5384 this->env_->time_elapse_only_sleep_ = true; in TEST_F()
5385 this->env_->no_slowdown_ = true; in TEST_F()
5420 this->env_->time_elapse_only_sleep_ = false; in TEST_F()
5826 options.env = env_; in TEST_F()
5922 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
5923 options.env = env_; in TEST_F()
5924 env_->no_slowdown_ = true; in TEST_F()
5939 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
5963 env_->SleepForMicroseconds(2666); in TEST_F()
5973 ASSERT_GT(env_->addon_time_.load(), in TEST_F()
5975 ASSERT_LT(env_->addon_time_.load(), in TEST_F()
5978 env_->no_slowdown_ = false; in TEST_F()
5986 options.env = env_; in TEST_F()
5987 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
6000 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
6002 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
6053 options.env = env_; in TEST_F()
6130 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
6162 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
6166 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
6239 options.env = env_; in TEST_F()
6252 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task, in TEST_F()
6394 env_->is_wal_sync_thread_safe_.store(false); in TEST_F()
6418 env_->SleepForMicroseconds(200000); in TEST_F()
6492 env_->time_elapse_only_sleep_ = false; in TEST_F()
6493 options.env = env_; in TEST_F()
6495 env_->addon_time_.store(0); in TEST_F()
6502 env_->GetCurrentTime(&time_1); in TEST_F()
6506 env_->addon_time_.fetch_add(50 * 60 * 60); in TEST_F()
6509 env_->GetCurrentTime(&time_2); in TEST_F()
6560 env_->time_elapse_only_sleep_ = false; in TEST_F()
6561 options.env = env_; in TEST_F()
6563 env_->addon_time_.store(0); in TEST_F()