Lines Matching refs:Env
88 Env* env_;
90 EnvPosixTest() : env_(Env::Default()), direct_io_(false) {} in EnvPosixTest()
95 public ::testing::WithParamInterface<std::pair<Env*, bool>> {
98 std::pair<Env*, bool> param_pair = GetParam(); in EnvPosixTestWithParam()
105 while (env_->GetThreadPoolQueueLen(Env::Priority::LOW) != 0) { in WaitThreadPoolsEmpty()
106 Env::Default()->SleepForMicroseconds(kDelayMicros); in WaitThreadPoolsEmpty()
108 while (env_->GetThreadPoolQueueLen(Env::Priority::HIGH) != 0) { in WaitThreadPoolsEmpty()
109 Env::Default()->SleepForMicroseconds(kDelayMicros); in WaitThreadPoolsEmpty()
121 for (int pri = Env::BOTTOM; pri < Env::TOTAL; ++pri) { in TEST_F()
123 env_->SetBackgroundThreads(1, static_cast<Env::Priority>(pri)); in TEST_F()
124 env_->Schedule(&SetBool, &called, static_cast<Env::Priority>(pri)); in TEST_F()
125 Env::Default()->SleepForMicroseconds(kDelayMicros); in TEST_F()
150 auto* env = Env::Default(); in TEST_F()
171 if (env_ == Env::Default()) { in TEST_F()
290 env_->SetBackgroundThreads(1, Env::LOW); in TEST_P()
295 Env::Priority::LOW); in TEST_P()
299 Env::Priority::LOW, &sleeping_task1); in TEST_P()
302 ASSERT_EQ(0, env_->UnSchedule(&called, Env::Priority::LOW)); in TEST_P()
305 ASSERT_EQ(1, env_->UnSchedule(&sleeping_task1, Env::Priority::LOW)); in TEST_P()
316 Env::Default()->SleepForMicroseconds(1); in TEST_P()
356 Env::Default()->SleepForMicroseconds(kDelayMicros); in TEST_P()
391 Env::Default()->SleepForMicroseconds(kDelayMicros); in TEST_P()
472 env_->SetBackgroundThreads(kHighPoolSize, Env::Priority::HIGH); in TEST_P()
474 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_P()
475 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
480 env_->Schedule(&CB::Run, &high_pool_job, Env::Priority::HIGH); in TEST_P()
485 env_->GetThreadPoolQueueLen(Env::Priority::LOW) || in TEST_P()
487 env_->GetThreadPoolQueueLen(Env::Priority::HIGH)) { in TEST_P()
497 env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_P()
499 env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
514 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_P()
515 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
522 env_->IncBackgroundThreadsIfNeeded(kLowPoolSize - 1, Env::Priority::LOW); in TEST_P()
523 env_->IncBackgroundThreadsIfNeeded(kHighPoolSize + 1, Env::Priority::HIGH); in TEST_P()
530 env_->Schedule(&CB::Run, &high_pool_job, Env::Priority::HIGH); in TEST_P()
535 env_->GetThreadPoolQueueLen(Env::Priority::LOW) || in TEST_P()
537 env_->GetThreadPoolQueueLen(Env::Priority::HIGH)) { in TEST_P()
546 env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_P()
548 env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
563 env_->SetBackgroundThreads(kHighPoolSize, Env::Priority::HIGH); in TEST_P()
573 env_->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_P()
578 Env::Priority::HIGH); in TEST_P()
581 ASSERT_EQ(2U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
587 env_->SetBackgroundThreads(2, Env::Priority::HIGH); in TEST_P()
589 ASSERT_EQ(1U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
595 env_->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_P()
596 Env::Default()->SleepForMicroseconds(kDelayMicros); in TEST_P()
597 ASSERT_EQ(1U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
605 ASSERT_EQ(1U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
611 env_->SetBackgroundThreads(5, Env::Priority::HIGH); in TEST_P()
613 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
620 env_->SetBackgroundThreads(7, Env::Priority::HIGH); in TEST_P()
623 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
624 env_->SetBackgroundThreads(3, Env::Priority::HIGH); in TEST_P()
625 Env::Default()->SleepForMicroseconds(kDelayMicros); in TEST_P()
626 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
627 env_->SetBackgroundThreads(4, Env::Priority::HIGH); in TEST_P()
628 Env::Default()->SleepForMicroseconds(kDelayMicros); in TEST_P()
629 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
630 env_->SetBackgroundThreads(5, Env::Priority::HIGH); in TEST_P()
631 Env::Default()->SleepForMicroseconds(kDelayMicros); in TEST_P()
632 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
633 env_->SetBackgroundThreads(4, Env::Priority::HIGH); in TEST_P()
634 Env::Default()->SleepForMicroseconds(kDelayMicros); in TEST_P()
635 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
637 Env::Default()->SleepForMicroseconds(kDelayMicros * 50); in TEST_P()
643 Env::Priority::HIGH); in TEST_P()
648 ASSERT_EQ(2U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
666 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
672 env_->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_P()
673 Env::Default()->SleepForMicroseconds(kDelayMicros); in TEST_P()
692 Env::Priority::HIGH); in TEST_P()
694 Env::Priority::HIGH); in TEST_P()
695 Env::Default()->SleepForMicroseconds(kDelayMicros); in TEST_P()
696 ASSERT_GT(env_->GetThreadPoolQueueLen(Env::Priority::HIGH), (unsigned int)0); in TEST_P()
700 env_->SetBackgroundThreads(4, Env::Priority::HIGH); in TEST_P()
701 Env::Default()->SleepForMicroseconds(kDelayMicros); in TEST_P()
702 ASSERT_EQ((unsigned int)0, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
707 env_->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_P()
897 if (env_ == Env::Default()) { in TEST_P()
942 if (env_ == Env::Default()) { in TEST_P()
1031 if (env_ == Env::Default()) { in TEST_P()
1072 if (env_ == Env::Default()) { in TEST_P()
1551 std::vector<Env::FileAttributes> file_attrs; in TEST_P()
1559 [&name](const Env::FileAttributes& fm) { return fm.name == name; }); in TEST_P()
1634 void SetIOPriority(Env::IOPriority /*pri*/) override { inc(11); } in TEST_P()
1636 Env::IOPriority GetIOPriority() override { in TEST_P()
1638 return Env::IOPriority::IO_LOW; in TEST_P()
1641 void SetWriteLifeTimeHint(Env::WriteLifeTimeHint /*hint*/) override { in TEST_P()
1645 Env::WriteLifeTimeHint GetWriteLifeTimeHint() override { in TEST_P()
1647 return Env::WriteLifeTimeHint::WLTH_NOT_SET; in TEST_P()
1708 w.SetIOPriority(Env::IOPriority::IO_HIGH); in TEST_P()
1710 w.SetWriteLifeTimeHint(Env::WriteLifeTimeHint::WLTH_NOT_SET); in TEST_P()
1901 explicit TestEnv() : EnvWrapper(Env::Default()), in TEST_P()
1966 ::testing::Values(std::pair<Env*, bool>(Env::Default(), in TEST_P()
1970 ::testing::Values(std::pair<Env*, bool>(Env::Default(), in TEST_P()
1975 static std::unique_ptr<Env> chroot_env( in TEST_P()
1976 NewChrootEnv(Env::Default(), test::TmpDir(Env::Default()))); in TEST_P()
1979 ::testing::Values(std::pair<Env*, bool>(chroot_env.get(), false))); in TEST_P()
1982 ::testing::Values(std::pair<Env*, bool>(chroot_env.get(), true))); in TEST_P()
1994 env_ = env_non_null ? (env_default ? Env::Default() : nullptr) : nullptr; in TEST_P()
2002 env_ptr_ = std::unique_ptr<Env>(new FaultInjectionTestEnv(Env::Default())); in TEST_P()
2006 env_ptr_.reset(new FaultInjectionTestEnv(Env::Default())); in TEST_P()
2019 Env* env_; in TEST_P()
2020 std::unique_ptr<Env> env_ptr_; in TEST_P()
2021 std::unique_ptr<Env> composite_env_ptr_; in TEST_P()
2082 std::unique_ptr<Env> env1 = NewCompositeEnv(fs1); in TEST_P()
2083 std::unique_ptr<Env> env2 = NewCompositeEnv(fs2); in TEST_P()
2084 Env::Default()->SetBackgroundThreads(8, Env::HIGH); in TEST_P()
2085 Env::Default()->SetBackgroundThreads(16, Env::LOW); in TEST_P()
2087 ASSERT_EQ(env1->GetBackgroundThreads(Env::LOW), 16); in TEST_P()
2088 ASSERT_EQ(env1->GetBackgroundThreads(Env::HIGH), 8); in TEST_P()
2089 ASSERT_EQ(env2->GetBackgroundThreads(Env::LOW), 16); in TEST_P()
2090 ASSERT_EQ(env2->GetBackgroundThreads(Env::HIGH), 8); in TEST_P()